Add async delete channels (#63)

Author: ferhatelmas

lib/GetStream/StreamChat/Client.php

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

tests/integration/IntegrationTest.php

@@ -108,12 +108,37 @@ public function testDeleteUsers()
         $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++) {
+        for ($i=0;$i<30;$i++) {
+            $response = $this->client->getTask($taskId);
+            if ($response["status"] == "completed") {
+                $this->assertSame($response["result"][$user["id"]]["status"], "ok");
+                return;
+            }
+            usleep(300000);
+        }
+        $this->assertSame($response["status"], "completed");
+    }
+
+    public function testDeleteChannels()
+    {
+        $user = ["id" => Uuid::uuid4()->toString()];
+        $response = $this->client->updateUser($user);
+
+        $c1 = $this->getChannel();
+        $c2 = $this->getChannel();
+
+        $response = $this->client->deleteChannels([$c1->getCID(), $c2->getCID()], ["hard_delete" => true]);
+        $this->assertTrue(array_key_exists("task_id", $response));
+
+        $taskId = $response["task_id"];
+        for ($i=0;$i<30;$i++) {
             $response = $this->client->getTask($taskId);
             if ($response["status"] == "completed") {
+                $this->assertSame($response["result"][$c1->getCID()]["status"], "ok");
+                $this->assertSame($response["result"][$c2->getCID()]["status"], "ok");
                 return;
             }
-            sleep(1);
+            usleep(300000);
         }
         $this->assertSame($response["status"], "completed");
     }