fix unit tesrts

Author: Rafael Marinho

stream_chat/client.py

@@ -955,6 +955,11 @@ def mark_delivered(self, data: Dict[str, Any]) -> Optional[StreamResponse]:
         if not data.get("user") and not data.get("user_id"):
             raise ValueError("either user or user_id must be provided")
 
+        # Extract user_id from data
+        user_id = data.get("user_id") or data.get("user", {}).get("id")
+        if not user_id:
+            raise ValueError("user_id must be provided")
+
         params = {"user_id": user_id}
         return self.post("channels/delivered", data=data, params=params)
 

stream_chat/tests/async_chat/test_client.py

@@ -6,7 +6,7 @@
 from contextlib import suppress
 from datetime import datetime
 from operator import itemgetter
-from typing import Dict, List
+from typing import Dict, List, Any, Optional
 
 import aiohttp
 import jwt
@@ -15,7 +15,7 @@
 from stream_chat.async_chat import StreamChatAsync
 from stream_chat.async_chat.channel import Channel
 from stream_chat.base.exceptions import StreamAPIException
-from stream_chat.tests.async_chat.conftest import hard_delete_users
+from stream_chat.tests.async_chat.conftest import hard_delete_users, cleanup_blocklists_async
 from stream_chat.tests.utils import wait_for_async
 
 

stream_chat/tests/test_client.py

@@ -6,7 +6,7 @@
 from contextlib import suppress
 from datetime import datetime
 from operator import itemgetter
-from typing import Dict, List
+from typing import Dict, List, Any, Optional
 
 import jwt
 import pytest
@@ -15,7 +15,7 @@
 from stream_chat import StreamChat
 from stream_chat.base.exceptions import StreamAPIException
 from stream_chat.channel import Channel
-from stream_chat.tests.conftest import hard_delete_users
+from stream_chat.tests.conftest import hard_delete_users, cleanup_blocklists
 from stream_chat.tests.utils import wait_for