[CHAT-2191] Async delete_users (#62)

Co-authored-by: Anatoly Rugalev <[email protected]>

Author: gumuz

lib/GetStream/StreamChat/Channel.php

@@ -432,7 +432,7 @@ public function rejectInvite($options=null)
     /**
       * @param string $url
       * @param string $name
-      * @param string $user
+      * @param string|array $user
       * @param string $contentType
       * @return mixed
       * @throws StreamException
@@ -445,7 +445,7 @@ public function sendFile($url, $name, $user, $contentType=null)
     /**
       * @param string $url
       * @param string $name
-      * @param string $user
+      * @param string|array $user
       * @param string $contentType
       * @return mixed
       * @throws StreamException

lib/GetStream/StreamChat/Client.php

@@ -378,6 +378,21 @@ public function deleteUser($userId, $options=null)
         return $this->delete("users/" . $userId, $options);
     }
 
+    /**
+     * @param  array $userIds
+     * @param  array $options
+     * @return mixed
+     * @throws StreamException
+     */
+    public function deleteUsers($userIds, $options=null)
+    {
+        if ($options === null) {
+            $options = (object)[];
+        }
+        $options["user_ids"] = $userIds;
+        return $this->post("users/delete", $options);
+    }
+
     /**
      * @param  string $userId
      * @param  array $options

tests/integration/IntegrationTest.php

@@ -102,6 +102,22 @@ public function testDeleteUser()
         $this->assertSame($user["id"], $response["user"]["id"]);
     }
 
+    public function testDeleteUsers()
+    {
+        $user = $this->getUser();
+        $response = $this->client->deleteUsers([$user["id"]], ["user" => "hard"]);
+        $this->assertTrue(array_key_exists("task_id", $response));
+        $taskId = $response["task_id"];
+        for ($i=0;$i<10;$i++) {
+            $response = $this->client->getTask($taskId);
+            if ($response["status"] == "completed") {
+                return;
+            }
+            sleep(1);
+        }
+        $this->assertSame($response["status"], "completed");
+    }
+
     public function testDeactivateUser()
     {
         $user = $this->getUser();