lint

Author: Rafael Marinho

stream_chat/async_chat/channel.py

@@ -138,7 +138,7 @@ async def mark_read(self, user_id: str, **data: Any) -> StreamResponse:
     async def mark_unread(self, user_id: str, **data: Any) -> StreamResponse:
         payload = add_user_id(data, user_id)
         return await self.client.post(f"{self.url}/unread", data=payload)
-    
+
     async def get_replies(self, parent_id: str, **options: Any) -> StreamResponse:
         return await self.client.get(f"messages/{parent_id}/replies", params=options)
 

stream_chat/async_chat/client.py

@@ -989,24 +989,24 @@ async def update_user_location(
     async def mark_delivered(self, data: Dict[str, Any]) -> Optional[StreamResponse]:
         """
         Send the mark delivered event for this user, only works if the `delivery_receipts` setting is enabled
-        
+
         :param data: MarkDeliveredOptions containing latest_delivered_messages and other optional fields
         :return: The server response or None if delivery receipts are disabled
         """
         # Validate required fields
         if not data.get("latest_delivered_messages"):
             raise ValueError("latest_delivered_messages must not be empty")
-        
+
         # Ensure either user or user_id is provided
         if not data.get("user") and not data.get("user_id"):
             raise ValueError("either user or user_id must be provided")
-        
+
         return await self.post("channels/delivered", data=data)
 
     async def mark_delivered_simple(self, user_id: str, message_id: str, channel_cid: str) -> Optional[StreamResponse]:
         """
         Convenience method to mark a message as delivered for a specific user.
-        
+
         :param user_id: The user ID
         :param message_id: The message ID
         :param channel_cid: The channel CID (channel_type:channel_id)
@@ -1018,19 +1018,14 @@ async def mark_delivered_simple(self, user_id: str, message_id: str, channel_cid
             raise ValueError("message ID must not be empty")
         if not channel_cid:
             raise ValueError("channel CID must not be empty")
-        
+
         data = {
-            "latest_delivered_messages": [
-                {
-                    "cid": channel_cid,
-                    "id": message_id
-                }
-            ],
+            "latest_delivered_messages": [{"cid": channel_cid,"id": message_id}],
             "user_id": user_id
         }
-        
+
         return await self.mark_delivered(data)
-    
+
     async def close(self) -> None:
         await self.session.close()
 

stream_chat/base/channel.py

@@ -292,7 +292,7 @@ def mark_unread(
         :return: The server response
         """
         pass
-    
+
     @abc.abstractmethod
     def get_replies(
         self, parent_id: str, **options: Any

stream_chat/channel.py

@@ -139,7 +139,7 @@ def mark_read(self, user_id: str, **data: Any) -> StreamResponse:
     def mark_unread(self, user_id: str, **data: Any) -> StreamResponse:
         payload = add_user_id(data, user_id)
         return self.client.post(f"{self.url}/unread", data=payload)
-    
+
     def get_replies(self, parent_id: str, **options: Any) -> StreamResponse:
         return self.client.get(f"messages/{parent_id}/replies", params=options)
 

stream_chat/client.py

@@ -943,24 +943,26 @@ def update_user_location(
     def mark_delivered(self, data: Dict[str, Any]) -> Optional[StreamResponse]:
         """
         Send the mark delivered event for this user, only works if the `delivery_receipts` setting is enabled
-        
+
         :param data: MarkDeliveredOptions containing latest_delivered_messages and other optional fields
         :return: The server response or None if delivery receipts are disabled
         """
         # Validate required fields
         if not data.get("latest_delivered_messages"):
             raise ValueError("latest_delivered_messages must not be empty")
-        
+
         # Ensure either user or user_id is provided
         if not data.get("user") and not data.get("user_id"):
             raise ValueError("either user or user_id must be provided")
-        
+
         return self.post("channels/delivered", data=data)
 
-    def mark_delivered_simple(self, user_id: str, message_id: str, channel_cid: str) -> Optional[StreamResponse]:
+    def mark_delivered_simple(
+        self, user_id: str, message_id: str, channel_cid: str
+    ) -> Optional[StreamResponse]:
         """
         Convenience method to mark a message as delivered for a specific user.
-        
+
         :param user_id: The user ID
         :param message_id: The message ID
         :param channel_cid: The channel CID (channel_type:channel_id)
@@ -972,15 +974,8 @@ def mark_delivered_simple(self, user_id: str, message_id: str, channel_cid: str)
             raise ValueError("message ID must not be empty")
         if not channel_cid:
             raise ValueError("channel CID must not be empty")
-        
         data = {
-            "latest_delivered_messages": [
-                {
-                    "cid": channel_cid,
-                    "id": message_id
-                }
-            ],
+            "latest_delivered_messages": [{"cid": channel_cid,"id": message_id}],
             "user_id": user_id
         }
-        
         return self.mark_delivered(data)

stream_chat/tests/test_channel.py

@@ -202,7 +202,7 @@ def test_mark_unread(self, channel: Channel, random_user: Dict):
         channel.send_message({"id": msg_id, "text": "helloworld"}, random_user["id"])
         response = channel.mark_unread(random_user["id"], message_id=msg_id)
         assert "duration" in response
-    
+
     def test_get_messages(self, channel: Channel, random_user: Dict):
         msg_id = str(uuid.uuid4())
         channel.send_message({"id": msg_id, "text": "helloworld"}, random_user["id"])