client->getActivities (get activities by id or foreign_id / time combination)

Author: pterk

lib/GetStream/Stream/Client.php

@@ -228,6 +228,28 @@ public function buildRequestUrl($uri)
         return "{$baseUrl}/{$this->api_version}/{$uri}";
     }
 
+    public function getActivities($ids=null, $foreign_id_times=null)
+    {
+        if($ids!==null){
+            $query_params = ["ids" => join(',', $ids)];
+        } else {
+            $fids = [];
+            $times = [];
+            foreach($foreign_id_times as $fit){
+                $fids[] = $fit[0];
+                $times[] = $fit[1];
+            }
+            $query_params = [
+                "foreign_ids" => join(',', $fid),
+                "timestamps" => join(',', $times)
+            ];
+
+        }
+        $token = $this->signer->jwtScopeToken('*', 'activities', '*');
+        $activities = new Activities($this, $this->api_key, $token);
+        return $activities->_getActivities($query_params);
+    }
+
     public function updateActivities($activities)
     {
         if (empty($activities)) {

tests/integration/FeedTest.php

@@ -683,4 +683,19 @@ public function testEnrichment(){
         unset($bear['id']);
         $this->assertEquals($response["results"][0]["object"]['data'], $bear, $canonicalize=true);
     }
+
+    public function testGetActivities(){
+        $now = new DateTime('now', new DateTimeZone('Pacific/Nauru'));
+        $time = $now->format(DateTime::ISO8601);
+        $activities = [
+            ['actor' => 'multi1', 'verb' => 'tweet', 'object' => 1, 'time' => $time, 'foreign_id' => 'fid:ga1'],
+            ['actor' => 'multi2', 'verb' => 'tweet', 'object' => 2, 'time' => $time, 'foreign_id' => 'fid:ga2'],
+        ];
+        $response = $this->user1->addActivities($activities);
+        $activities = $this->user1->getActivities(0, 2)['results'];
+        $this->assertCount(2, $activities);
+        $ids = [$activities[0]['id'], $activities[1]['id']];
+        $response = $this->client->getActivities($ids=$ids)['results'];
+        $this->assertEquals($activities, $response, $canonicalize=true);
+    }
 }