mirror of
https://github.com/buddypress/buddypress.git
synced 2026-07-22 20:56:55 +08:00
a3ddbe1c32
A new Github Action is added with a simple matrix to run our unit tests with object cache services, currently Memcache and Redis. Props imath See #9076 Fixes #9129 Closes https://github.com/buddypress/buddypress/pull/284 git-svn-id: https://buddypress.svn.wordpress.org/trunk@13859 cdf35c40-ae34-48e0-9cc9-0c9da1808c22
896 lines
24 KiB
PHP
896 lines
24 KiB
PHP
<?php
|
|
|
|
/**
|
|
* @group BP_Messages_Thread
|
|
* @group messages
|
|
*/
|
|
class BP_Tests_BP_Messages_Thread extends BP_UnitTestCase {
|
|
|
|
/**
|
|
* @group cache
|
|
*/
|
|
public function 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.'
|
|
);
|
|
}
|
|
|
|
public function test_get_messages_with_invalid_thread_id() {
|
|
$this->assertTrue( empty( BP_Messages_Thread::get_messages( 0 ) ) );
|
|
}
|
|
|
|
public function test_get_messages_using_arguments() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
$m1 = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
self::factory()->message->create_many(
|
|
98,
|
|
array(
|
|
'thread_id' => $m1->thread_id,
|
|
'sender_id' => $u2,
|
|
'recipients' => array( $u1 ),
|
|
'subject' => 'Bar',
|
|
)
|
|
);
|
|
|
|
// Last message
|
|
self::factory()->message->create(
|
|
array(
|
|
'thread_id' => $m1->thread_id,
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
'subject' => 'Last Message',
|
|
)
|
|
);
|
|
|
|
// Default results.
|
|
$messages = BP_Messages_Thread::get_messages( $m1->thread_id );
|
|
$this->assertCount( 100, $messages );
|
|
|
|
// Get first 10 messages.
|
|
$messages = BP_Messages_Thread::get_messages( $m1->thread_id, array( 'page' => 1, 'per_page' => 10 ) );
|
|
$this->assertCount( 10, $messages );
|
|
|
|
// Get first 10 messages differently.
|
|
$thread = new BP_Messages_Thread( $m1->thread_id, 'ASC', array( 'page' => 1, 'per_page' => 10 ) );
|
|
$this->assertCount( 10, $thread->messages );
|
|
|
|
// Get all messages.
|
|
$messages = BP_Messages_Thread::get_messages( $m1->thread_id, array( 'page' => null, 'per_page' => null ) );
|
|
$this->assertCount( 100, $messages );
|
|
|
|
// Get all mesages differently.
|
|
$thread = new BP_Messages_Thread( $m1->thread_id, 'ASC', array( 'page' => null, 'per_page' => null ) );
|
|
$this->assertCount( 100, $thread->messages );
|
|
}
|
|
|
|
public function test_get_messages_total_count() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
$m1 = self::factory()->message->create_and_get(
|
|
[
|
|
'sender_id' => $u1,
|
|
'recipients' => [ $u2 ],
|
|
'subject' => 'Foo',
|
|
]
|
|
);
|
|
|
|
self::factory()->message->create_many(
|
|
98,
|
|
[
|
|
'thread_id' => $m1->thread_id,
|
|
'sender_id' => $u2,
|
|
'recipients' => [ $u1 ],
|
|
'subject' => 'Bar',
|
|
]
|
|
);
|
|
|
|
// Last message
|
|
self::factory()->message->create(
|
|
[
|
|
'thread_id' => $m1->thread_id,
|
|
'sender_id' => $u1,
|
|
'recipients' => [ $u2 ],
|
|
'subject' => 'Last Message',
|
|
]
|
|
);
|
|
|
|
$count = BP_Messages_Thread::get_total_thread_message_count( $m1->thread_id );
|
|
$this->assertSame( 100, $count );
|
|
|
|
$thread = new BP_Messages_Thread( $m1->thread_id );
|
|
$this->assertSame( 100, $thread->messages_total_count );
|
|
|
|
$thread = new BP_Messages_Thread( $m1->thread_id, 'ASC', [ 'page' => 1, 'per_page' => 10 ] );
|
|
$this->assertCount( 10, $thread->messages );
|
|
$this->assertSame( 100, $thread->messages_total_count );
|
|
}
|
|
|
|
/**
|
|
* @group cache
|
|
*/
|
|
public function test_get_messages_total_count_cached() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
$m1 = self::factory()->message->create_and_get(
|
|
[
|
|
'sender_id' => $u1,
|
|
'recipients' => [ $u2 ],
|
|
'subject' => 'Foo',
|
|
]
|
|
);
|
|
|
|
self::factory()->message->create(
|
|
[
|
|
'thread_id' => $m1->thread_id,
|
|
'sender_id' => $u2,
|
|
'recipients' => [ $u1 ],
|
|
'subject' => 'Middle Message',
|
|
]
|
|
);
|
|
|
|
$cache_key = "{$m1->thread_id}_bp_messages_thread_total_count";
|
|
$count = BP_Messages_Thread::get_total_thread_message_count( $m1->thread_id );
|
|
|
|
$this->assertSame( 2, $count );
|
|
$this->assertSame( 2, wp_cache_get( $cache_key, 'bp_messages_threads' ) );
|
|
|
|
self::factory()->message->create(
|
|
[
|
|
'thread_id' => $m1->thread_id,
|
|
'sender_id' => $u2,
|
|
'recipients' => [ $u1 ],
|
|
'subject' => 'Last Message',
|
|
]
|
|
);
|
|
|
|
// Update cache.
|
|
BP_Messages_Thread::get_total_thread_message_count( $m1->thread_id );
|
|
|
|
$this->assertSame( 3, wp_cache_get( $cache_key, 'bp_messages_threads' ) );
|
|
|
|
// Delete thread.
|
|
messages_delete_thread( $m1->thread_id );
|
|
|
|
$this->assertFalse( wp_cache_get( $cache_key, 'bp_messages_threads' ) );
|
|
}
|
|
|
|
/**
|
|
* @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',
|
|
) );
|
|
|
|
// create reply
|
|
$message_2 = self::factory()->message->create_and_get( array(
|
|
'thread_id' => $message_1->thread_id,
|
|
'sender_id' => $u2,
|
|
'date_sent' => '2030-10-27 19:21:40',
|
|
'recipients' => array( $u1 ),
|
|
'content' => 'Bar'
|
|
) );
|
|
|
|
// Default sort from constructor.
|
|
$thread = new BP_Messages_Thread( $message_1->thread_id );
|
|
|
|
$this->assertEquals(
|
|
array( $message_1->id, $message_2->id ),
|
|
wp_list_pluck( $thread->messages, 'id' )
|
|
);
|
|
|
|
// Default via the helper method.
|
|
$messages = BP_Messages_Thread::get_messages( $message_1->thread_id );
|
|
$this->assertEquals(
|
|
array( $message_1->id, $message_2->id ),
|
|
wp_list_pluck( $messages, 'id' )
|
|
);
|
|
|
|
// Now get thread by DESC via the constructor.
|
|
$thread = new BP_Messages_Thread( $message_1->thread_id, 'DESC' );
|
|
$this->assertEquals(
|
|
array( $message_2->id, $message_1->id ),
|
|
wp_list_pluck( $thread->messages, 'id' )
|
|
);
|
|
|
|
// Testing sort with lowercase.
|
|
$thread = new BP_Messages_Thread( $message_1->thread_id, 'desc' );
|
|
$this->assertEquals(
|
|
array( $message_2->id, $message_1->id ),
|
|
wp_list_pluck( $thread->messages, 'id' )
|
|
);
|
|
|
|
// Testing sort with lowercase and space.
|
|
$thread = new BP_Messages_Thread( $message_1->thread_id, ' desc' );
|
|
$this->assertEquals(
|
|
array( $message_2->id, $message_1->id ),
|
|
wp_list_pluck( $thread->messages, 'id' )
|
|
);
|
|
|
|
// Now sorting via the helper method.
|
|
$messages = BP_Messages_Thread::get_messages( $message_1->thread_id, array( 'order' => 'desc' ) );
|
|
$this->assertEquals(
|
|
array( $message_2->id, $message_1->id ),
|
|
wp_list_pluck( $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();
|
|
|
|
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();
|
|
|
|
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();
|
|
|
|
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_current_threads_for_user
|
|
*/
|
|
public function test_get_current_threads_setting_per_page_messages_and_recipients() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
|
|
// create initial thread
|
|
$message_1 = self::factory()->message->create_and_get(
|
|
array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
)
|
|
);
|
|
|
|
// create some replies to thread
|
|
self::factory()->message->create_and_get(
|
|
array(
|
|
'thread_id' => $message_1->thread_id,
|
|
'sender_id' => $u2,
|
|
'recipients' => array( $u1 ),
|
|
)
|
|
);
|
|
|
|
self::factory()->message->create_and_get(
|
|
array(
|
|
'thread_id' => $message_1->thread_id,
|
|
'sender_id' => $u2,
|
|
'recipients' => array( $u1 ),
|
|
)
|
|
);
|
|
|
|
self::factory()->message->create_and_get(
|
|
array(
|
|
'thread_id' => $message_1->thread_id,
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2 ),
|
|
)
|
|
);
|
|
|
|
$threads = BP_Messages_Thread::get_current_threads_for_user(
|
|
array( 'user_id' => $u1 )
|
|
)['threads'];
|
|
|
|
$this->assertCount( 4, $threads[0]->messages );
|
|
$this->assertCount( 2, $threads[0]->recipients );
|
|
|
|
$threads = BP_Messages_Thread::get_current_threads_for_user(
|
|
array(
|
|
'user_id' => $u1,
|
|
'messages_page' => 1,
|
|
'messages_per_page' => 2,
|
|
'recipients_page' => 1,
|
|
'recipients_per_page' => 1,
|
|
)
|
|
)['threads'];
|
|
|
|
$this->assertCount( 2, $threads[0]->messages );
|
|
$this->assertNotCount( 2, $threads[0]->recipients );
|
|
$this->assertCount( 1, $threads[0]->recipients );
|
|
}
|
|
|
|
/**
|
|
* @group get_recipients
|
|
*/
|
|
public function test_get_recipients_paginated() {
|
|
$u1 = self::factory()->user->create();
|
|
$user_ids = self::factory()->user->create_many( 9 );
|
|
$m = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => $user_ids,
|
|
'subject' => 'Foo',
|
|
) );
|
|
|
|
$thread_1 = new BP_Messages_Thread( $m->thread_id );
|
|
$this->assertTrue( 10 === count( $thread_1->get_recipients() ) );
|
|
|
|
$thread_2 = new BP_Messages_Thread( $m->thread_id, 'ASC', array( 'recipients_page' => 1, 'recipients_per_page' => 5 ) );
|
|
$this->assertTrue( 5 === count( $thread_2->recipients ) );
|
|
|
|
$thread_3 = new BP_Messages_Thread( $m->thread_id );
|
|
$this->assertTrue( 8 === count( $thread_3->get_recipients( $m->thread_id, array( 'recipients_page' => 1, 'recipients_per_page' => 8 ) ) ) );
|
|
}
|
|
|
|
/**
|
|
* @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 );
|
|
$thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$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;
|
|
$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 );
|
|
$thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$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 );
|
|
$thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$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 cache
|
|
*/
|
|
public function test_marking_a_thread_as_read_with_specific_user_id() {
|
|
$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_id = $message->thread_id;
|
|
|
|
// Populate cache.
|
|
$thread = BP_Messages_Thread::get_recipients_for_thread( $thread_id );
|
|
|
|
// Cache should be populated.
|
|
$this->assertTrue( (bool) wp_cache_get( 'thread_recipients_' . $thread_id, 'bp_messages' ) );
|
|
|
|
// Mark thread as read.
|
|
messages_mark_thread_read( $thread_id, $u2 );
|
|
|
|
// Cache should be empty.
|
|
$this->assertFalse( (bool) wp_cache_get( 'thread_recipients_' . $thread_id, 'bp_messages' ) );
|
|
|
|
$thread = new BP_Messages_Thread( $thread_id );
|
|
|
|
$this->assertFalse( (bool) $thread->unread_count );
|
|
$this->assertFalse( (bool) $thread->recipients[ $u1 ]->unread_count );
|
|
$this->assertFalse( (bool) $thread->recipients[ $u2 ]->unread_count );
|
|
}
|
|
|
|
/**
|
|
* @group cache
|
|
*/
|
|
public function test_marking_a_thread_as_unread_with_specific_user_id() {
|
|
$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_id = $message->thread_id;
|
|
|
|
// Populate cache.
|
|
$thread = BP_Messages_Thread::get_recipients_for_thread( $thread_id );
|
|
|
|
// Cache should be populated.
|
|
$this->assertTrue( (bool) wp_cache_get( 'thread_recipients_' . $thread_id, 'bp_messages' ) );
|
|
|
|
// Mark thread as unread.
|
|
messages_mark_thread_unread( $thread_id, $u2 );
|
|
|
|
// Cache should be empty.
|
|
$this->assertFalse( (bool) wp_cache_get( 'thread_recipients_' . $thread_id, 'bp_messages' ) );
|
|
|
|
$thread = new BP_Messages_Thread( $thread_id );
|
|
|
|
$this->assertFalse( (bool) $thread->recipients[ $u1 ]->unread_count );
|
|
$this->assertTrue( (bool) $thread->recipients[ $u2 ]->unread_count );
|
|
}
|
|
|
|
/**
|
|
* @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 );
|
|
$thread->get_recipients();
|
|
|
|
// Verify that the cache is populated.
|
|
$num_queries = $wpdb->num_queries;
|
|
$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 latest_message
|
|
*/
|
|
public function test_get_latest_message_data() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
$subject = 'Last One';
|
|
$content = 'Bar and baz';
|
|
|
|
$m = self::factory()->message->create_and_get(
|
|
[
|
|
'sender_id' => $u1,
|
|
'recipients' => [ $u2 ],
|
|
'subject' => 'Foo',
|
|
'content' => 'Bar',
|
|
]
|
|
);
|
|
|
|
self::factory()->message->create_many(
|
|
8,
|
|
[
|
|
'thread_id' => $m->thread_id,
|
|
'sender_id' => $u2,
|
|
'recipients' => [ $u1 ],
|
|
'subject' => 'Bar',
|
|
]
|
|
);
|
|
|
|
$date = '2030-10-27 19:21:40';
|
|
|
|
// Last(est) message.
|
|
$m2 = self::factory()->message->create_and_get(
|
|
[
|
|
'thread_id' => $m->thread_id,
|
|
'sender_id' => $u1,
|
|
'recipients' => [ $u2 ],
|
|
'date_sent' => $date,
|
|
'subject' => $subject,
|
|
'content' => $content,
|
|
]
|
|
);
|
|
|
|
$thread = new BP_Messages_Thread( $m->thread_id, 'ASC', [ 'page' => 1, 'per_page' => 3 ] );
|
|
|
|
$this->assertCount( 3, $thread->messages );
|
|
$this->assertEquals( $m2->id, $thread->last_message_id );
|
|
$this->assertEquals( $m2->sender_id, $thread->last_sender_id );
|
|
$this->assertEquals( $date, $thread->last_message_date );
|
|
$this->assertEquals( $subject, $thread->last_message_subject );
|
|
$this->assertEquals( $content, $thread->last_message_content );
|
|
}
|
|
|
|
/**
|
|
* @group latest_message
|
|
* @group cache
|
|
*/
|
|
public function test_get_latest_message_from_cache() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
$date = '2030-10-27 19:21:40';
|
|
|
|
$m1 = self::factory()->message->create_and_get(
|
|
[
|
|
'sender_id' => $u1,
|
|
'recipients' => [ $u2 ],
|
|
'subject' => 'Foo',
|
|
]
|
|
);
|
|
|
|
$m2 = self::factory()->message->create_and_get(
|
|
[
|
|
'thread_id' => $m1->thread_id,
|
|
'sender_id' => $u1,
|
|
'recipients' => [ $u2 ],
|
|
'date_sent' => $date,
|
|
'subject' => 'Last Message',
|
|
'content' => 'Last Message Content',
|
|
]
|
|
);
|
|
|
|
$thread_id = $m1->thread_id;
|
|
$latest_message = wp_cache_get( "{$thread_id}_bp_messages_thread_latest_message", 'bp_messages_threads' );
|
|
|
|
$this->assertEquals( $thread_id, $latest_message->thread_id );
|
|
$this->assertEquals( $m2->id, $latest_message->id );
|
|
$this->assertEquals( $m2->sender_id, $latest_message->sender_id );
|
|
$this->assertEquals( $date, $latest_message->date_sent );
|
|
$this->assertEquals( 'Last Message', $latest_message->subject );
|
|
$this->assertEquals( 'Last Message Content', $latest_message->message );
|
|
}
|
|
|
|
/**
|
|
* @group exit
|
|
* @ticket BP7540
|
|
*/
|
|
public function test_bp_messages_thread_exit() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
$u3 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2, $u3 ),
|
|
'subject' => 'Foo Bar',
|
|
'date_sent' => bp_core_current_time(),
|
|
'content' => 'Foo Bar is there.',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$this->assertTrue( BP_Messages_Thread::exit_thread( $t1, $u3 ) );
|
|
}
|
|
|
|
/**
|
|
* @group exit
|
|
* @ticket BP7540
|
|
*/
|
|
public function test_bp_messages_thread_exit_not_enough_recipients() {
|
|
$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' => 'Bar Foo',
|
|
'date_sent' => bp_core_current_time(),
|
|
'content' => 'Bar Foo is also there.',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$this->assertFalse( BP_Messages_Thread::exit_thread( $t1, $u2 ) );
|
|
}
|
|
|
|
/**
|
|
* @group exit
|
|
* @ticket BP7540
|
|
*/
|
|
public function test_bp_messages_thread_exit_not_one_of_recipients() {
|
|
$u1 = self::factory()->user->create();
|
|
$u2 = self::factory()->user->create();
|
|
$u3 = self::factory()->user->create();
|
|
$u4 = self::factory()->user->create();
|
|
|
|
$message = self::factory()->message->create_and_get( array(
|
|
'sender_id' => $u1,
|
|
'recipients' => array( $u2, $u3 ),
|
|
'subject' => 'Taz',
|
|
'date_sent' => bp_core_current_time(),
|
|
'content' => 'Where is Taz?',
|
|
) );
|
|
|
|
$t1 = $message->thread_id;
|
|
|
|
$this->assertFalse( BP_Messages_Thread::exit_thread( $t1, $u4 ) );
|
|
}
|
|
}
|
