Add batchPartialActivityUpdate method

Author: pterk

lib/GetStream/Stream/ActivityUpdateOperation.php

@@ -37,7 +37,6 @@ protected function getHttpRequestHeaders($resource, $action)
 
     public function partiallyUpdateActivity($data){
         return $this->makeHttpRequest('activity/', 'POST', $data);
-
     }
 
     public function updateActivities($activities)

lib/GetStream/Stream/Client.php

@@ -256,6 +256,16 @@ public function getActivities($ids=null, $foreign_id_times=null)
         return $activities->_getActivities($query_params);
     }
 
+    public function batchPartialActivityUpdate($data)
+    {
+        if(count($data) > 100){
+            throw new Exception("Max 100 activities allowed in batch update");
+        }
+        $token = $this->signer->jwtScopeToken('*', 'activities', '*');
+        $activityUpdateOp = new ActivityUpdateOperation($this, $this->api_key, $token);
+        return $activityUpdateOp->partiallyUpdateActivity(["changes" => $data]);
+    }
+
     public function doPartialActivityUpdate($id=null, $foreign_id=null, $time=null, $set=null, $unset=null)
     {
         $token = $this->signer->jwtScopeToken('*', 'activities', '*');

tests/integration/FeedTest.php

@@ -91,6 +91,83 @@ public function testUpdateActivity()
         $this->client->updateActivity($activity);
     }
 
+    public function testBatchPartialUpdateActivity()
+    {
+        $now = new DateTime('now', new DateTimeZone('Pacific/Nauru'));
+        $activity_data = [
+            'actor' => 1,
+            'verb' => 'tweet',
+            'object' => 1,
+            'time' => $now->format(DateTime::ISO8601),
+            'foreign_id' => 'batch1',
+            'popularity' => 100,
+            'new' => true,
+        ];
+        $act1 = $this->user1->addActivity($activity_data);
+        $activity_data = [
+            'actor' => 2,
+            'verb' => 'tweet',
+            'object' => 2,
+            'time' => $now->format(DateTime::ISO8601),
+            'foreign_id' => 'batch2',
+            'popularity' => 100,
+            'new' => true,
+        ];
+        $act2 = $this->user1->addActivity($activity_data);
+        $payload = [
+            [
+                "id" => $act1["id"],
+                "set" => ["popularity" => 999],
+                "unset" => ['new'],
+            ],
+            [
+                "id" => $act2["id"],
+                "set" => ["popularity" => 5],
+                //"unset" => [],
+            ],
+        ];
+        $response = $this->client->batchPartialActivityUpdate($payload);
+        $updated = $this->user1->getActivities(0,2)["results"];
+        if($updated[0]["id"] == $act1["id"]){
+            $updated1 = $updated[0];
+            $updated2 = $updated[1];
+        } else {
+            $updated1 = $updated[1];
+            $updated2 = $updated[0];
+        }
+        $this->assertEquals($updated1['popularity'], 999);
+        $this->assertFalse(in_array("new", $updated1));
+        $this->assertEquals($updated2['popularity'], 5);
+        $this->assertTrue(in_array("new", $updated2));
+
+        $payload = [
+            [
+                "foreign_id" => $act1["foreign_id"],
+                "time" => $act1["time"],
+                "set" => ["popularity" => 1242],
+            ],
+            [
+                "foreign_id" => $act2["foreign_id"],
+                "time" => $act2["time"],
+                "set" => ["popularity" => -3],
+                "unset" => ["new"],
+            ],
+        ];
+        $response = $this->client->batchPartialActivityUpdate($payload);
+        $updated = $this->user1->getActivities(0,2)["results"];
+        if($updated[0]["id"] == $act1["id"]){
+            $updated1 = $updated[0];
+            $updated2 = $updated[1];
+        } else {
+            $updated1 = $updated[1];
+            $updated2 = $updated[0];
+        }
+        $this->assertEquals($updated1['popularity'], 1242);
+        $this->assertFalse(in_array("new", $updated1));
+        $this->assertEquals($updated2['popularity'], -3);
+        $this->assertFalse(in_array("new", $updated2));
+    }
+
     public function testPartialUpdateActivity()
     {
         $now = new DateTime('now', new DateTimeZone('Pacific/Nauru'));
@@ -102,8 +179,8 @@ public function testPartialUpdateActivity()
             'foreign_id' => 'batch1',
             'product' => ["name"=> "shoes", "price"=> 9.99, "color"=> "blue"],
         ];
-        $response = $this->user1->addActivity($activity_data);
-        $activity = $response;
+        $activity = $this->user1->addActivity($activity_data);
+
         $set = [
             "product.name" => "boots",
             "product.price" => 7.99,