mirror of
https://github.com/buddypress/buddypress.git
synced 2026-07-22 20:56:55 +08:00
0ed016254c
See #7620. git-svn-id: https://buddypress.svn.wordpress.org/trunk@11737 cdf35c40-ae34-48e0-9cc9-0c9da1808c22
440 lines
11 KiB
PHP
440 lines
11 KiB
PHP
<?php
|
|
|
|
/**
|
|
* @group BP_Messages_Thread
|
|
* @group messages
|
|
*/
|
|
class BP_Tests_BP_Messages_Thread extends BP_UnitTestCase {
|
|
|
|
/**
|
|
* @group cache
|
|
*/
|
|
public function test_construct_cache() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
// prime cache
|
|
new BP_Messages_Thread( $message->thread_id );
|
|
|
|
// Cache should exist
|
|
$this->assertThat(
|
|
wp_cache_get( $message->thread_id, 'bp_messages_threads' ),
|
|
$this->logicalNot( $this->equalTo( false ) ),
|
|
'Message thread cache should exist.'
|
|
);
|
|
}
|
|
|
|
/**
|
|
* @group order
|
|
*/
|
|
public function test_construct_order_desc() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
// create thread
|
|
$message_1 = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
$m1 = $message_1->id;
|
|
|
|
// create reply
|
|
$message_2 = self::factory()->message->create_and_get( array(
|
|
'thread_id' => $message_1->thread_id,
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'content' => 'Bar'
|
|
) );
|
|
$m2 = $message_2->id;
|
|
|
|
// now get thread by DESC
|
|
$thread = new BP_Messages_Thread( $message_1->thread_id, 'DESC' );
|
|
|
|
// assert!
|
|
$this->assertEquals(
|
|
array( $m2, $m1 ),
|
|
wp_list_pluck( $thread->messages, 'id' )
|
|
);
|
|
}
|
|
|
|
/**
|
|
* @group get_current_threads_for_user
|
|
*/
|
|
public function test_get_current_threads_for_user_with_search_terms_inbox() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message_1 = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$message_2 = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Bar',
|
|
) );
|
|
|
|
$threads = BP_Messages_Thread::get_current_threads_for_user( array(
|
|
'user_id' => $u2,
|
|
'search_terms' => 'ar',
|
|
) );
|
|
|
|
$expected = array( $message_2->thread_id );
|
|
$found = wp_parse_id_list( wp_list_pluck( $threads['threads'], 'thread_id' ) );
|
|
|
|
$this->assertSame( $expected, $found );
|
|
}
|
|
|
|
/**
|
|
* @group get_current_threads_for_user
|
|
*/
|
|
public function test_get_current_threads_for_user_with_search_terms_sentbox() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message_1 = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$message_2 = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Bar',
|
|
) );
|
|
|
|
$threads = BP_Messages_Thread::get_current_threads_for_user( array(
|
|
'user_id' => $u1,
|
|
'box' => 'sentbox',
|
|
'search_terms' => 'ar',
|
|
) );
|
|
|
|
$expected = array( $message_2->thread_id );
|
|
$found = wp_parse_id_list( wp_list_pluck( $threads['threads'], 'thread_id' ) );
|
|
|
|
$this->assertSame( $expected, $found );
|
|
}
|
|
|
|
/**
|
|
* @group get_current_threads_for_user
|
|
* @expectedDeprecated BP_Messages_Thread::get_current_threads_for_user
|
|
*/
|
|
public function test_get_current_threads_for_user_with_old_args() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message_1 = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$message_2 = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Bar',
|
|
) );
|
|
|
|
$threads = BP_Messages_Thread::get_current_threads_for_user( $u1, 'sentbox', 'all', null, null, 'ar' );
|
|
|
|
$expected = array( $message_2->thread_id );
|
|
$found = wp_parse_id_list( wp_list_pluck( $threads['threads'], 'thread_id' ) );
|
|
|
|
$this->assertSame( $expected, $found );
|
|
}
|
|
|
|
/**
|
|
* @group get_recipients
|
|
* @group cache
|
|
*/
|
|
public function test_get_recipients_should_cache_its_values() {
|
|
global $wpdb;
|
|
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$thread = new BP_Messages_Thread( $message->thread_id );
|
|
$recipients = $thread->get_recipients();
|
|
|
|
$num_queries = $wpdb->num_queries;
|
|
$recipients_cached = $thread->get_recipients();
|
|
|
|
$this->assertEquals( $recipients, $recipients_cached );
|
|
$this->assertEquals( $num_queries, $wpdb->num_queries );
|
|
}
|
|
|
|
/**
|
|
* @group get_recipients
|
|
* @group cache
|
|
*/
|
|
public function test_get_recipients_cache_should_be_busted_when_thread_message_is_sent() {
|
|
global $wpdb;
|
|
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$thread = new BP_Messages_Thread( $message->thread_id );
|
|
$recipients = $thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$recipients_cached = $thread->get_recipients();
|
|
$this->assertEquals( $num_queries, $wpdb->num_queries );
|
|
|
|
messages_new_message( array(
|
|
'sender_id' => $u2,
|
|
'thread_id' => $message->thread_id,
|
|
'recipients' => array( $u1 ),
|
|
'subject' => 'Bar',
|
|
'content' => 'Baz',
|
|
) );
|
|
|
|
// Cache should be empty.
|
|
$num_queries = $wpdb->num_queries;
|
|
$recipients_uncached = $thread->get_recipients();
|
|
$this->assertEquals( $num_queries + 1, $wpdb->num_queries );
|
|
}
|
|
|
|
/**
|
|
* @group get_recipients
|
|
* @group cache
|
|
*/
|
|
public function test_get_recipients_cache_should_be_busted_when_single_thread_is_deleted() {
|
|
global $wpdb;
|
|
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$thread = new BP_Messages_Thread( $t1 );
|
|
$recipients = $thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$recipients_cached = $thread->get_recipients();
|
|
$this->assertEquals( $num_queries, $wpdb->num_queries );
|
|
|
|
messages_delete_thread( $t1 );
|
|
|
|
// Cache should be empty.
|
|
$this->assertFalse( wp_cache_get( 'thread_recipients_' . $t1, 'bp_messages' ) );
|
|
}
|
|
|
|
/**
|
|
* @group get_recipients
|
|
* @group cache
|
|
*/
|
|
public function test_get_recipients_cache_should_be_busted_when_array_of_threads_is_deleted() {
|
|
global $wpdb;
|
|
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$thread = new BP_Messages_Thread( $t1 );
|
|
$recipients = $thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$recipients_cached = $thread->get_recipients();
|
|
$this->assertEquals( $num_queries, $wpdb->num_queries );
|
|
|
|
messages_delete_thread( array( $t1 ) );
|
|
|
|
// Cache should be empty.
|
|
$this->assertFalse( wp_cache_get( 'thread_recipients_' . $t1, 'bp_messages' ) );
|
|
}
|
|
|
|
/**
|
|
* @group get_recipients
|
|
* @group cache
|
|
*/
|
|
public function test_get_recipients_cache_should_be_busted_when_thread_is_read() {
|
|
global $wpdb;
|
|
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$thread = new BP_Messages_Thread( $t1 );
|
|
$recipients = $thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$recipients_cached = $thread->get_recipients();
|
|
$this->assertEquals( $num_queries, $wpdb->num_queries );
|
|
|
|
// Mark thread as read
|
|
$current_user = get_current_user_id();
|
|
$this->set_current_user( $u2 );
|
|
messages_mark_thread_read( $t1 );
|
|
|
|
// Cache should be empty.
|
|
$this->assertFalse( wp_cache_get( 'thread_recipients_' . $t1, 'bp_messages' ) );
|
|
|
|
$this->set_current_user( $current_user );
|
|
}
|
|
|
|
/**
|
|
* @group get_recipients
|
|
* @group cache
|
|
*/
|
|
public function test_get_recipients_cache_should_be_busted_when_thread_is_unread() {
|
|
global $wpdb;
|
|
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$thread = new BP_Messages_Thread( $t1 );
|
|
$recipients = $thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$recipients_cached = $thread->get_recipients();
|
|
$this->assertEquals( $num_queries, $wpdb->num_queries );
|
|
|
|
// Mark thread as unread
|
|
$current_user = get_current_user_id();
|
|
$this->set_current_user( $u2 );
|
|
messages_mark_thread_unread( $t1 );
|
|
|
|
// Cache should be empty.
|
|
$this->assertFalse( wp_cache_get( 'thread_recipients_' . $t1, 'bp_messages' ) );
|
|
|
|
$this->set_current_user( $current_user );
|
|
}
|
|
|
|
/**
|
|
* @group check_access
|
|
*/
|
|
public function test_check_access_valid_thread() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
// save recipient ID
|
|
$thread = new BP_Messages_Thread( $t1 );
|
|
$r1 = wp_list_pluck( $thread->recipients, 'id' );
|
|
$r1 = array_pop( $r1 );
|
|
|
|
$this->assertEquals( $r1, BP_Messages_Thread::check_access( $t1, $u1 ) );
|
|
}
|
|
|
|
/**
|
|
* @group check_access
|
|
*/
|
|
public function test_check_access_invalid_thread() {
|
|
$this->assertEquals( null, BP_Messages_Thread::check_access( 999, 1 ) );
|
|
}
|
|
|
|
/**
|
|
* @group is_valid
|
|
*/
|
|
public function test_is_valid_valid_thread() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$this->assertEquals( $t1, BP_Messages_Thread::is_valid( $t1 ) );
|
|
}
|
|
|
|
/**
|
|
* @group is_valid
|
|
*/
|
|
public function test_is_valid_invalid_thread() {
|
|
$this->assertEquals( null, BP_Messages_Thread::is_valid( 999 ) );
|
|
}
|
|
|
|
/**
|
|
* @group last_message
|
|
*/
|
|
public function test_last_message_populated() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
$date = bp_core_current_time();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
'date_sent' => $date,
|
|
'content' => 'Bar and baz.',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$thread = new BP_Messages_Thread( $t1 );
|
|
|
|
$this->assertNotNull( $thread->last_message_id );
|
|
$this->assertEquals( 'Foo', $thread->last_message_subject );
|
|
$this->assertEquals( $u1, $thread->last_sender_id );
|
|
$this->assertEquals( $date, $thread->last_message_date );
|
|
$this->assertEquals( 'Bar and baz.', $thread->last_message_content );
|
|
}
|
|
}
|
