Merge pull request #91 from GetStream/status-endpoint

Call status endpoint

Author: tbarbugli

getstream/chat/rest_client.py

@@ -641,6 +641,7 @@ def create_channel_type(
         read_events: Optional[bool] = None,
         replies: Optional[bool] = None,
         search: Optional[bool] = None,
+        shared_locations: Optional[bool] = None,
         skip_last_msg_update_for_system_msgs: Optional[bool] = None,
         typing_events: Optional[bool] = None,
         uploads: Optional[bool] = None,
@@ -671,6 +672,7 @@ def create_channel_type(
             read_events=read_events,
             replies=replies,
             search=search,
+            shared_locations=shared_locations,
             skip_last_msg_update_for_system_msgs=skip_last_msg_update_for_system_msgs,
             typing_events=typing_events,
             uploads=uploads,
@@ -728,6 +730,7 @@ def update_channel_type(
         reminders: Optional[bool] = None,
         replies: Optional[bool] = None,
         search: Optional[bool] = None,
+        shared_locations: Optional[bool] = None,
         skip_last_msg_update_for_system_msgs: Optional[bool] = None,
         typing_events: Optional[bool] = None,
         uploads: Optional[bool] = None,
@@ -763,6 +766,7 @@ def update_channel_type(
             reminders=reminders,
             replies=replies,
             search=search,
+            shared_locations=shared_locations,
             skip_last_msg_update_for_system_msgs=skip_last_msg_update_for_system_msgs,
             typing_events=typing_events,
             uploads=uploads,

getstream/common/rest_client.py

@@ -583,6 +583,42 @@ def delete_users(
 
         return self.post("/api/v2/users/delete", DeleteUsersResponse, json=json)
 
+    def get_user_live_locations(
+        self, user_id: Optional[str] = None
+    ) -> StreamResponse[SharedLocationsResponse]:
+        query_params = build_query_param(user_id=user_id)
+
+        return self.get(
+            "/api/v2/users/live_locations",
+            SharedLocationsResponse,
+            query_params=query_params,
+        )
+
+    def update_live_location(
+        self,
+        created_by_device_id: str,
+        message_id: str,
+        end_at: Optional[datetime] = None,
+        latitude: Optional[float] = None,
+        longitude: Optional[float] = None,
+        user_id: Optional[str] = None,
+    ) -> StreamResponse[SharedLocationResponse]:
+        query_params = build_query_param(user_id=user_id)
+        json = build_body_dict(
+            created_by_device_id=created_by_device_id,
+            message_id=message_id,
+            end_at=end_at,
+            latitude=latitude,
+            longitude=longitude,
+        )
+
+        return self.put(
+            "/api/v2/users/live_locations",
+            SharedLocationResponse,
+            query_params=query_params,
+            json=json,
+        )
+
     def reactivate_users(
         self,
         user_ids: List[str],