feat: add filter tags support for channels

Author: javierdfm

stream_chat/async_chat/channel.py

@@ -272,3 +272,19 @@ async def get_draft(
         if parent_id:
             params["parent_id"] = parent_id
         return await self.client.get(f"{self.url}/draft", params=params)
+
+    async def add_filter_tags(
+        self,
+        tags: Iterable[str],
+        message: Dict = None,
+    ) -> StreamResponse:
+        payload = {"add_filter_tags": tags, "message": message}
+        return await self.client.post(self.url, data=payload)
+
+    async def remove_filter_tags(
+        self,
+        tags: Iterable[str],
+        message: Dict = None,
+    ) -> StreamResponse:
+        payload = {"remove_filter_tags": tags, "message": message}
+        return await self.client.post(self.url, data=payload)

stream_chat/base/channel.py

@@ -527,6 +527,32 @@ def get_draft(
         """
         pass
 
+    @abc.abstractmethod
+    def add_filter_tags(
+        self, tags: Iterable[str], message: Dict = None
+    ) -> Union[StreamResponse, Awaitable[StreamResponse]]:
+        """
+        Adds filter tags to the channel
+
+        :param tags: list of tags to add
+        :param message: optional system message
+        :return: The server response
+        """
+        pass
+
+    @abc.abstractmethod
+    def remove_filter_tags(
+        self, tags: Iterable[str], message: Dict = None
+    ) -> Union[StreamResponse, Awaitable[StreamResponse]]:
+        """
+        Removes filter tags from the channel
+
+        :param tags: list of tags to remove
+        :param message: optional system message
+        :return: The server response
+        """
+        pass
+
 
 def add_user_id(payload: Dict, user_id: str) -> Dict:
     return {**payload, "user": {"id": user_id}}

stream_chat/channel.py

@@ -276,3 +276,19 @@ def get_draft(
             params["parent_id"] = parent_id
 
         return self.client.get(f"{self.url}/draft", params=params)
+
+    def add_filter_tags(
+        self,
+        tags: Iterable[str],
+        message: Dict = None,
+    ) -> StreamResponse:
+        payload = {"add_filter_tags": tags, "message": message}
+        return self.client.post(self.url, data=payload)
+
+    def remove_filter_tags(
+        self,
+        tags: Iterable[str],
+        message: Dict = None,
+    ) -> StreamResponse:
+        payload = {"remove_filter_tags": tags, "message": message}
+        return self.client.post(self.url, data=payload)