[Summary view] [Print] [Text view]

   1  <?php
   2  
   3  /**
   4   * @group activity
   5   * @group cache
   6   */
   7  class BP_Tests_Activity_Cache extends BP_UnitTestCase {
   8      /**
   9       * @group bp_activity_update_meta_cache
  10       */
  11  	public function test_bp_activity_update_meta_cache() {
  12          $a1 = self::factory()->activity->create();
  13          $a2 = self::factory()->activity->create();
  14  
  15          // Set up some data
  16          bp_activity_update_meta( $a1, 'foo', 'bar' );
  17          bp_activity_update_meta( $a1, 'Boone', 'Rules' );
  18  
  19          bp_activity_update_meta( $a2, 'foo', 'baz' );
  20          bp_activity_update_meta( $a2, 'BuddyPress', 'Is Cool' );
  21  
  22          // Prime the cache for $a1
  23          bp_activity_get_meta( $a1, 'foo' );
  24  
  25          // Ensure an empty cache for $a2
  26          wp_cache_delete( $a2, 'activity_meta' );
  27  
  28          bp_activity_update_meta_cache( array( $a1, $a2 ) );
  29  
  30          $expected = array(
  31              $a1 => array(
  32                  'foo' => array(
  33                      'bar',
  34                  ),
  35                  'Boone' => array(
  36                      'Rules',
  37                  ),
  38              ),
  39              $a2 => array(
  40                  'foo' => array(
  41                      'baz',
  42                  ),
  43                  'BuddyPress' => array(
  44                      'Is Cool',
  45                  ),
  46              ),
  47          );
  48  
  49          $found = array(
  50              $a1 => wp_cache_get( $a1, 'activity_meta' ),
  51              $a2 => wp_cache_get( $a2, 'activity_meta' ),
  52          );
  53  
  54          $this->assertEquals( $expected, $found );
  55      }
  56  
  57      /**
  58       * @group bp_activity_clear_cache_for_activity
  59       */
  60  	public function test_bp_activity_clear_cache_for_activity() {
  61          $u = self::factory()->user->create();
  62  
  63          $a = self::factory()->activity->create( array(
  64              'component'     => buddypress()->activity->id,
  65              'type'          => 'activity_update',
  66              'user_id'       => $u,
  67              'content'       => 'foo bar',
  68          ) );
  69  
  70          $a_fp = bp_activity_get( array(
  71              'type' => 'activity_update',
  72              'user' => array( 'filter' => array( 'user_id' => $u ) ),
  73          ) );
  74  
  75          $activity_updated = new BP_Activity_Activity( $a );
  76          $activity_updated->content = 'bar foo';
  77          $activity_updated->save();
  78  
  79          $a_fp = bp_activity_get( array(
  80              'type' => 'activity_update',
  81              'user' => array( 'filter' => array( 'user_id' => $u ) ),
  82          ) );
  83  
  84          $this->assertSame( 'bar foo', $a_fp['activities'][0]->content );
  85      }
  86  
  87      /**
  88       * @ticket BP7237
  89       * @ticket BP6643
  90       */
  91  	public function test_query_should_be_cached() {
  92          global $wpdb;
  93  
  94          $u = self::factory()->user->create();
  95          $a = self::factory()->activity->create( array(
  96              'component'     => buddypress()->activity->id,
  97              'type'          => 'activity_update',
  98              'user_id'       => $u,
  99              'content'       => 'foo bar',
 100          ) );
 101  
 102          $activity_args = array(
 103              'per_page' => 10,
 104              'fields' => 'ids',
 105              'count_total' => true,
 106          );
 107  
 108          $a1 = bp_activity_get( $activity_args );
 109  
 110          $num_queries = $wpdb->num_queries;
 111  
 112          $a2 = bp_activity_get( $activity_args );
 113  
 114          $this->assertEqualSets( $a1, $a2 );
 115          $this->assertSame( $num_queries, $wpdb->num_queries );
 116      }
 117  
 118      /**
 119       * @ticket BP7237
 120       * @ticket BP6643
 121       */
 122      public function test_query_cache_should_be_skipped_for_different_query_params() {
 123          global $wpdb;
 124  
 125          $u = self::factory()->user->create();
 126          $a = self::factory()->activity->create( array(
 127              'component'     => buddypress()->activity->id,
 128              'type'          => 'activity_update',
 129              'user_id'       => $u,
 130              'content'       => 'foo bar',
 131          ) );
 132  
 133          $activity_args = array(
 134              'per_page' => 10,
 135              'fields' => 'ids',
 136              'count_total' => true,
 137              'filter' => array(
 138                  'component' => buddypress()->activity->id,
 139              ),
 140          );
 141  
 142          $a1 = bp_activity_get( $activity_args );
 143  
 144          $num_queries = $wpdb->num_queries;
 145  
 146          // This is enough to make the ID and COUNT clause miss the cache.
 147          $activity_args['filter']['action'] = 'activity_update';
 148          $a2 = bp_activity_get( $activity_args );
 149  
 150          $this->assertEqualSets( $a1, $a2 );
 151  
 152          // Two extra queries: one for the IDs, one for the count.
 153          $n = $num_queries + 2;
 154          $this->assertSame( $num_queries + 2, $wpdb->num_queries );
 155      }
 156  
 157      /**
 158       * @ticket BP7237
 159       * @ticket BP6643
 160       */
 161      public function test_query_cache_should_be_invalidated_by_activity_add() {
 162          global $wpdb;
 163  
 164          $u = self::factory()->user->create();
 165          $a1 = self::factory()->activity->create( array(
 166              'component'     => buddypress()->activity->id,
 167              'type'          => 'activity_update',
 168              'user_id'       => $u,
 169              'content'       => 'foo bar',
 170          ) );
 171  
 172          $activity_args = array(
 173              'per_page' => 10,
 174              'fields' => 'ids',
 175              'count_total' => true,
 176          );
 177  
 178          $q1 = bp_activity_get( $activity_args );
 179  
 180          // Bust the cache.
 181          $a2 = self::factory()->activity->create( array(
 182              'component'     => buddypress()->activity->id,
 183              'type'          => 'activity_update',
 184              'user_id'       => $u,
 185              'content'       => 'foo bar',
 186          ) );
 187  
 188          $num_queries = $wpdb->num_queries;
 189  
 190          $q2 = bp_activity_get( $activity_args );
 191  
 192          $expected = array( $a1, $a2 );
 193  
 194          $this->assertEqualSets( $expected, $q2['activities'] );
 195          $this->assertEquals( 2, $q2['total'] );
 196          $this->assertSame( $num_queries + 2, $wpdb->num_queries );
 197      }
 198  
 199      /**
 200       * @ticket BP7237
 201       * @ticket BP6643
 202       */
 203      public function test_query_cache_should_be_invalidated_by_activity_edit() {
 204          global $wpdb;
 205  
 206          $u = self::factory()->user->create();
 207          $a = self::factory()->activity->create( array(
 208              'component'     => buddypress()->activity->id,
 209              'type'          => 'activity_update',
 210              'user_id'       => $u,
 211              'content'       => 'foo bar',
 212          ) );
 213  
 214          $activity_args = array(
 215              'per_page' => 10,
 216              'fields' => 'ids',
 217              'count_total' => true,
 218          );
 219  
 220          $q1 = bp_activity_get( $activity_args );
 221  
 222          // Bust the cache.
 223          self::factory()->activity->create( array(
 224              'id'            => $a,
 225              'component'     => buddypress()->activity->id,
 226              'type'          => 'activity_update',
 227              'user_id'       => $u,
 228              'content'       => 'foo bar baz',
 229          ) );
 230  
 231          $num_queries = $wpdb->num_queries;
 232  
 233          $q2 = bp_activity_get( $activity_args );
 234  
 235          $this->assertEqualSets( $q1, $q2 );
 236          $this->assertSame( $num_queries + 2, $wpdb->num_queries );
 237      }
 238  
 239      /**
 240       * @ticket BP7237
 241       * @ticket BP6643
 242       */
 243      public function test_query_cache_should_be_invalidated_by_activity_delete() {
 244          global $wpdb;
 245  
 246          $u = self::factory()->user->create();
 247          $a = self::factory()->activity->create( array(
 248              'component'     => buddypress()->activity->id,
 249              'type'          => 'activity_update',
 250              'user_id'       => $u,
 251              'content'       => 'foo bar',
 252          ) );
 253  
 254          $activity_args = array(
 255              'per_page' => 10,
 256              'fields' => 'ids',
 257              'count_total' => true,
 258          );
 259  
 260          $q1 = bp_activity_get( $activity_args );
 261  
 262          // Bust the cache.
 263          bp_activity_delete( array(
 264              'id' => $a,
 265          ) );
 266  
 267          $num_queries = $wpdb->num_queries;
 268  
 269          $q2 = bp_activity_get( $activity_args );
 270  
 271          $this->assertEqualSets( array(), $q2['activities'] );
 272          $this->assertEquals( 0, $q2['total'] );
 273          $this->assertSame( $num_queries + 2, $wpdb->num_queries );
 274      }
 275  
 276      /**
 277       * @ticket BP7237
 278       * @ticket BP6643
 279       */
 280      public function test_query_cache_should_be_invalidated_by_activitymeta_add() {
 281          global $wpdb;
 282  
 283          $activities = self::factory()->activity->create_many( 2 );
 284          bp_activity_add_meta( $activities[0], 'foo', 'bar' );
 285  
 286          $activity_args = array(
 287              'meta_query' => array(
 288                  array(
 289                      'key' => 'foo',
 290                      'value' => 'bar',
 291                  ),
 292              ),
 293          );
 294  
 295          $q1 = bp_activity_get( $activity_args );
 296          $this->assertEqualSets( array( $activities[0] ), wp_list_pluck( $q1['activities'], 'id' ) );
 297  
 298          bp_activity_add_meta( $activities[1], 'foo', 'bar' );
 299  
 300          $q2 = bp_activity_get( $activity_args );
 301          $this->assertEqualSets( array( $activities[0], $activities[1] ), wp_list_pluck( $q2['activities'], 'id' ) );
 302      }
 303  
 304      /**
 305       * @ticket BP7237
 306       * @ticket BP6643
 307       */
 308      public function test_query_cache_should_be_invalidated_by_activitymeta_update() {
 309          global $wpdb;
 310  
 311          $activities = self::factory()->activity->create_many( 2 );
 312          bp_activity_add_meta( $activities[0], 'foo', 'bar' );
 313          bp_activity_add_meta( $activities[1], 'foo', 'baz' );
 314  
 315          $activity_args = array(
 316              'meta_query' => array(
 317                  array(
 318                      'key' => 'foo',
 319                      'value' => 'bar',
 320                  ),
 321              ),
 322          );
 323  
 324          $q1 = bp_activity_get( $activity_args );
 325          $this->assertEqualSets( array( $activities[0] ), wp_list_pluck( $q1['activities'], 'id' ) );
 326  
 327          bp_activity_update_meta( $activities[1], 'foo', 'bar' );
 328  
 329          $q2 = bp_activity_get( $activity_args );
 330          $this->assertEqualSets( array( $activities[0], $activities[1] ), wp_list_pluck( $q2['activities'], 'id' ) );
 331      }
 332  
 333      /**
 334       * @ticket BP7237
 335       * @ticket BP6643
 336       */
 337      public function test_query_cache_should_be_invalidated_by_activitymeta_delete() {
 338          global $wpdb;
 339  
 340          $activities = self::factory()->activity->create_many( 2 );
 341          bp_activity_add_meta( $activities[0], 'foo', 'bar' );
 342          bp_activity_add_meta( $activities[1], 'foo', 'bar' );
 343  
 344          $activity_args = array(
 345              'meta_query' => array(
 346                  array(
 347                      'key' => 'foo',
 348                      'value' => 'bar',
 349                  ),
 350              ),
 351          );
 352  
 353          $q1 = bp_activity_get( $activity_args );
 354          $this->assertEqualSets( array( $activities[0], $activities[1] ), wp_list_pluck( $q1['activities'], 'id' ) );
 355  
 356          bp_activity_delete_meta( $activities[1], 'foo', 'bar' );
 357  
 358          $q2 = bp_activity_get( $activity_args );
 359          $this->assertEqualSets( array( $activities[0] ), wp_list_pluck( $q2['activities'], 'id' ) );
 360      }
 361  }