Ticket #6220: 6220.read.patch

src/bp-messages/classes/class-bp_messages-thread.php

@@ -508 +508 @@
                 $sql = $wpdb->prepare( "UPDATE {$bp->messages->table_name_recipients} SET unread_count = 0 WHERE user_id = %d AND thread_id = %d", bp_loggedin_user_id(), $thread_id );
                 $wpdb->query($sql);
 
+                wp_cache_delete( 'thread_recipients_' . $thread_id, 'bp_messages' );
                 wp_cache_delete( bp_loggedin_user_id(), 'bp_messages_unread_count' );
         }
 
@@ -525 +526 @@
                 $sql = $wpdb->prepare( "UPDATE {$bp->messages->table_name_recipients} SET unread_count = 1 WHERE user_id = %d AND thread_id = %d", bp_loggedin_user_id(), $thread_id );
                 $wpdb->query($sql);
 
+                wp_cache_delete( 'thread_recipients_' . $thread_id, 'bp_messages' );
                 wp_cache_delete( bp_loggedin_user_id(), 'bp_messages_unread_count' );
         }
 

tests/phpunit/testcases/messages/class.bp-messages-thread.php

@@ -216 +216 @@
                 // Cache should be empty.
                 $this->assertFalse( wp_cache_get( 'thread_recipients_' . $t1, 'bp_messages' ) );
         }
+
+        /**
+         * @group get_recipients
+         * @group cache
+         * @group raymsg
+         */
+        public function test_get_recipients_cache_should_be_busted_when_thread_is_read() {
+                global $wpdb;
+
+                $u1 = $this->factory->user->create();
+                $u2 = $this->factory->user->create();
+
+                $t1 = $this->factory->message->create( array(
+                        'sender_id' => $u1,
+                        'recipients' => array( $u2 ),
+                        'subject' => 'Foo',
+                ) );
+
+                $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 = $this->factory->user->create();
+                $u2 = $this->factory->user->create();
+
+                $t1 = $this->factory->message->create( array(
+                        'sender_id' => $u1,
+                        'recipients' => array( $u2 ),
+                        'subject' => 'Foo',
+                ) );
+
+                $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 );
+        }
 }