Merge pull request #19 from GetStream/query-members

add queryMembers implementation

Author: pterk

lib/GetStream/StreamChat/Channel.php

@@ -182,6 +182,37 @@ public function query($options)
         return $state;
     }
 
+    /**
+     * @param array $filterConditions
+     * @param array $sort
+     * @param array $options
+     * @return mixed
+     * @throws StreamException
+     */
+    public function queryMembers($filterConditions, $sort = null, $options = null)
+    {
+        if ($options === null) {
+            $options = array();
+        }
+        $sortFields = [];
+        if ($sort !== null) {
+            foreach ($sort as $k => $v) {
+                $sortFields[] = ["field" => $k, "direction" => $v];
+            }
+        }
+
+        if ($this->id !== null) {
+            $options["id"] = $this->id;
+        } else if ($this->customData !== null && is_array($this->customData["members"])) {
+            // member based channel aka distinct channel
+            $options["members"] = $this->customData["members"];
+        }
+        $options["type"] = $this->channelType;
+        $options["filter_conditions"] = $filterConditions;
+        $options["sort"] = $sortFields;
+        return $this->client->get("members", ["payload" => json_encode($options)]);
+    }
+
    /**
      * @param array $channelData
      * @param string $updateMessage

tests/integration/IntegrationTest.php

@@ -304,6 +304,52 @@ public function testQueryChannelsMembersIn()
         $this->assertSame(count($response["channels"][0]["members"]), 9);
     }
 
+    public function testQueryMembers()
+    {
+        $bob = ["id" => Uuid::uuid4()->toString(), "name" => "bob the builder"];
+        $bobSponge = ["id" => Uuid::uuid4()->toString(), "name" => "bob the sponge"];
+        $this->client->updateUsers([$bob, $bobSponge]);
+        $channel = $this->client->Channel(
+            "messaging",
+            Uuid::uuid4()->toString(),
+            ["members" => [$bob["id"], $bobSponge["id"]]]
+        );
+        $channel->create($bob["id"]);
+
+        $response = $channel->queryMembers(["id" => $bob["id"]]);
+        $this->assertSame(count($response["members"]), 1);
+        $this->assertSame($response["members"][0]["user_id"], $bob["id"]);
+
+        $response = $channel->queryMembers(["name" => ['$autocomplete' => "bob"]], []);
+        $this->assertSame(count($response["members"]), 2);
+
+        $response = $channel->queryMembers(["name" => ['$autocomplete' => "bob"]], [], ["limit" => 1]);
+        $this->assertSame(count($response["members"]), 1);
+    }
+
+    public function testQueryMembersMemberBasedChannel()
+    {
+        $bob = ["id" => Uuid::uuid4()->toString(), "name" => "bob the builder"];
+        $bobSponge = ["id" => Uuid::uuid4()->toString(), "name" => "bob the sponge"];
+        $this->client->updateUsers([$bob, $bobSponge]);
+        $channel = $this->client->Channel(
+            "messaging",
+            null,
+            ["members" => [$bob["id"], $bobSponge["id"]]]
+        );
+        $channel->create($bob["id"]);
+
+        $response = $channel->queryMembers(["id" => $bob["id"]]);
+        $this->assertSame(count($response["members"]), 1);
+        $this->assertSame($response["members"][0]["user_id"], $bob["id"]);
+
+        $response = $channel->queryMembers(["name" => ['$autocomplete' => "bob"]], []);
+        $this->assertSame(count($response["members"]), 2);
+
+        $response = $channel->queryMembers(["name" => ['$autocomplete' => "bob"]], [], ["limit" => 1]);
+        $this->assertSame(count($response["members"]), 1);
+    }
+
     public function testDevices()
     {
         $user = $this->getUser();