fix: attempt to fix tests

Author: javierdfm

stream_chat/tests/async_chat/conftest.py

@@ -93,13 +93,27 @@ async def channel(client: StreamChatAsync, random_user: Dict):
 
 @pytest.fixture(scope="function")
 async def command(client: StreamChatAsync):
+    try:
+        commands = await client.list_commands()
+        for cmd in commands.get("commands", []):
+            if cmd.get("name") not in ("giphy", "imgur", "flag", "ban", "unban", "mute", "unmute"):
+                try:
+                    await client.delete_command(cmd["name"])
+                except Exception:
+                    pass
+    except Exception:
+        pass
+
     response = await client.create_command(
         dict(name=str(uuid.uuid4()), description="My command")
     )
 
     yield response["command"]
 
-    await client.delete_command(response["command"]["name"])
+    try:
+        await client.delete_command(response["command"]["name"])
+    except Exception:
+        pass
 
 
 @pytest.fixture(scope="function")
@@ -121,6 +135,10 @@ async def fellowship_of_the_ring(client: StreamChatAsync):
         },
         {"id": "peregrin-took", "name": "Peregrin Took", "race": "Hobbit", "age": 28},
     ]
+    try:
+        await client.restore_users([m["id"] for m in members])
+    except Exception:
+        pass
     await client.upsert_users(members)
     channel = client.channel(
         "team", "fellowship-of-the-ring", {"members": [m["id"] for m in members]}

stream_chat/tests/async_chat/test_client.py

@@ -1,3 +1,4 @@
+import asyncio
 import json
 import os
 import sys
@@ -173,14 +174,14 @@ async def test_delete_users(self, client: StreamChatAsync, random_user: Dict):
         )
         assert "task_id" in response
 
-        for _ in range(20):
+        for _ in range(60):
             response = await client.get_task(response["task_id"])
             if response["status"] == "completed" and response["result"][
                 random_user["id"]
             ] == {"status": "ok"}:
                 return
 
-            time.sleep(1)
+            await asyncio.sleep(1)
 
         pytest.fail("task did not succeed")
 
@@ -810,14 +811,14 @@ async def test_delete_channels(self, client: StreamChatAsync, channel: Channel):
         response = await client.delete_channels([channel.cid])
         assert "task_id" in response
 
-        for _ in range(20):
+        for _ in range(60):
             response = await client.get_task(response["task_id"])
             if response["status"] == "completed" and response["result"][
                 channel.cid
             ] == {"status": "ok"}:
                 return
 
-            time.sleep(1)
+            await asyncio.sleep(1)
 
         pytest.fail("task did not succeed")
 

stream_chat/tests/conftest.py

@@ -84,13 +84,27 @@ def channel(client: StreamChat, random_user: Dict):
 
 @pytest.fixture(scope="function")
 def command(client: StreamChat):
+    try:
+        commands = client.list_commands()
+        for cmd in commands.get("commands", []):
+            if cmd.get("name") not in ("giphy", "imgur", "flag", "ban", "unban", "mute", "unmute"):
+                try:
+                    client.delete_command(cmd["name"])
+                except Exception:
+                    pass
+    except Exception:
+        pass
+
     response = client.create_command(
         dict(name=str(uuid.uuid4()), description="My command")
     )
 
     yield response["command"]
 
-    client.delete_command(response["command"]["name"])
+    try:
+        client.delete_command(response["command"]["name"])
+    except Exception:
+        pass
 
 
 @pytest.fixture(scope="module")
@@ -111,6 +125,10 @@ def fellowship_of_the_ring(client: StreamChat):
         },
         {"id": "peregrin-took", "name": "Peregrin Took", "race": "Hobbit", "age": 28},
     ]
+    try:
+        client.restore_users([m["id"] for m in members])
+    except Exception:
+        pass
     client.upsert_users(members)
     channel = client.channel(
         "team", "fellowship-of-the-ring", {"members": [m["id"] for m in members]}

stream_chat/tests/test_client.py

@@ -229,7 +229,7 @@ def test_delete_users(self, client: StreamChat, random_user: Dict):
         )
         assert "task_id" in response
 
-        for _ in range(20):
+        for _ in range(60):
             response = client.get_task(response["task_id"])
             if response["status"] == "completed" and response["result"][
                 random_user["id"]
@@ -818,7 +818,7 @@ def test_delete_channels(self, client: StreamChat, channel: Channel):
         response = client.delete_channels([channel.cid])
         assert "task_id" in response
 
-        for _ in range(20):
+        for _ in range(60):
             response = client.get_task(response["task_id"])
             if response["status"] == "completed" and response["result"][
                 channel.cid