feat: add provider management (#106)

Author: peterdeme

stream_chat/async_chat/client.py

@@ -594,6 +594,19 @@ async def get_task(self, task_id: str) -> StreamResponse:
     async def send_user_custom_event(self, user_id: str, event: Dict) -> StreamResponse:
         return await self.post(f"users/{user_id}/event", data={"event": event})
 
+    async def upsert_push_provider(self, push_provider_config: Dict) -> StreamResponse:
+        return await self.post(
+            "push_providers", data={"push_provider": push_provider_config}
+        )
+
+    async def delete_push_provider(
+        self, provider_type: str, name: str
+    ) -> StreamResponse:
+        return await self.delete(f"push_providers/{provider_type}/{name}")
+
+    async def list_push_providers(self) -> StreamResponse:
+        return await self.get("push_providers")
+
     async def close(self) -> None:
         await self.session.close()
 

stream_chat/base/client.py

@@ -866,6 +866,31 @@ def send_user_custom_event(
         """
         pass
 
+    @abc.abstractmethod
+    def upsert_push_provider(
+        self, push_provider_config: Dict
+    ) -> Union[StreamResponse, Awaitable[StreamResponse]]:
+        """
+        Create or update a push provider.
+        """
+        pass
+
+    @abc.abstractmethod
+    def delete_push_provider(
+        self, provider_type: str, name: str
+    ) -> Union[StreamResponse, Awaitable[StreamResponse]]:
+        """
+        Delete a push provider.
+        """
+        pass
+
+    @abc.abstractmethod
+    def list_push_providers(self) -> Union[StreamResponse, Awaitable[StreamResponse]]:
+        """
+        Get all push providers in the app.
+        """
+        pass
+
     #####################
     #  Private methods  #
     #####################

stream_chat/client.py

@@ -563,3 +563,12 @@ def get_task(self, task_id: str) -> StreamResponse:
 
     def send_user_custom_event(self, user_id: str, event: Dict) -> StreamResponse:
         return self.post(f"users/{user_id}/event", data={"event": event})
+
+    def upsert_push_provider(self, push_provider_config: Dict) -> StreamResponse:
+        return self.post("push_providers", data={"push_provider": push_provider_config})
+
+    def delete_push_provider(self, provider_type: str, name: str) -> StreamResponse:
+        return self.delete(f"push_providers/{provider_type}/{name}")
+
+    def list_push_providers(self) -> StreamResponse:
+        return self.get("push_providers")