refact(cha-769): reformat

Author: Rafael Marinho

stream_chat/async_chat/client.py

@@ -873,7 +873,9 @@ async def get_user_locations(self, user_id: str, **options: Any) -> StreamRespon
         return await self.get("users/live_locations", params=params)
 
     async def update_user_location(
-        self, message_id: str, options: Optional[SharedLocationsOptions] = None,
+        self,
+        message_id: str,
+        options: Optional[SharedLocationsOptions] = None,
     ) -> StreamResponse:
         data = {"message_id": message_id}
         if options is not None:
@@ -893,5 +895,3 @@ async def __aexit__(
         exc_tb: Optional[TracebackType],
     ) -> None:
         await self.close()
-
-    

stream_chat/base/client.py

@@ -1448,7 +1448,9 @@ def get_user_locations(self, user_id: str, **options: Any) -> StreamResponse:
         pass
 
     @abc.abstractmethod
-    def update_user_location(self, message_id: str, options: Optional[SharedLocationsOptions] = None) -> StreamResponse:
+    def update_user_location(
+        self, message_id: str, options: Optional[SharedLocationsOptions] = None
+    ) -> StreamResponse:
         """
         Update the location of a user.
         """

stream_chat/client.py

@@ -831,7 +831,9 @@ def get_user_locations(self, user_id: str, **options: Any) -> StreamResponse:
         return self.get("users/live_locations", params=params)
 
     def update_user_location(
-        self, message_id: str, options: Optional[SharedLocationsOptions] = None,
+        self,
+        message_id: str,
+        options: Optional[SharedLocationsOptions] = None,
     ) -> StreamResponse:
         data = {"message_id": message_id}
         if options is not None:

stream_chat/tests/async_chat/test_live_locations.py

@@ -17,19 +17,26 @@ async def test_get_user_locations(self, client: StreamChatAsync, random_user: Di
             "longitude": -122.4194,
         }
 
-        channel.send_message({"text": "Message with location", "shared_location": shared_location}, random_user["id"])
+        channel.send_message(
+            {"text": "Message with location", "shared_location": shared_location},
+            random_user["id"],
+        )
 
         # Get user locations
         response = await client.get_user_locations(random_user["id"])
 
         assert "active_live_locations" in response
         assert isinstance(response["active_live_locations"], list)
 
-    async def test_update_user_location(self, client: StreamChatAsync, random_user: Dict):
+    async def test_update_user_location(
+        self, client: StreamChatAsync, random_user: Dict
+    ):
         # First create a message to attach location to
         channel = client.channel("messaging", str(random_user["id"]))
         await channel.create(random_user["id"])
-        msg = await channel.send_message({"text": "Message with location"}, random_user["id"])
+        msg = await channel.send_message(
+            {"text": "Message with location"}, random_user["id"]
+        )
         message_id = msg["message"]["id"]
 
         # Update user location
@@ -55,4 +62,4 @@ async def test_update_user_location(self, client: StreamChatAsync, random_user:
         try:
             await channel.delete()
         except Exception:
-            pass 
+            pass

stream_chat/tests/test_live_locations.py

@@ -17,7 +17,10 @@ def test_get_user_locations(self, client: StreamChat, random_user: Dict):
             "longitude": -122.4194,
         }
 
-        channel.send_message({"text": "Message with location", "shared_location": shared_location}, random_user["id"])
+        channel.send_message(
+            {"text": "Message with location", "shared_location": shared_location},
+            random_user["id"],
+        )
 
         # Get user locations
         response = client.get_user_locations(random_user["id"])
@@ -36,7 +39,10 @@ def test_update_user_location(self, client: StreamChat, random_user: Dict):
             "longitude": -122.4194,
         }
 
-        msg = channel.send_message({"text": "Message with location", "shared_location": shared_location}, random_user["id"])
+        msg = channel.send_message(
+            {"text": "Message with location", "shared_location": shared_location},
+            random_user["id"],
+        )
         message_id = msg["message"]["id"]
 
         # Update user location
@@ -62,4 +68,4 @@ def test_update_user_location(self, client: StreamChat, random_user: Dict):
         try:
             channel.delete()
         except Exception:
-            pass 
+            pass

stream_chat/types/shared_locations.py

@@ -5,4 +5,4 @@
 class SharedLocationsOptions(TypedDict):
     longitude: Optional[int]
     latitude: Optional[int]
-    end_at: Optional[datetime]
+    end_at: Optional[datetime]