feat: enable creation of channels with query options (#137)

* feat: enable creation of channels with query options

* feat: allow options for create channel

* fix: linting issue

* feat: added test

Author: totalimmersion

stream_chat/async_chat/channel.py

@@ -35,9 +35,12 @@ async def delete_reaction(
             params={"user_id": user_id},
         )
 
-    async def create(self, user_id: str) -> StreamResponse:
+    async def create(self, user_id: str, **options: Any) -> StreamResponse:
         self.custom_data["created_by"] = {"id": user_id}
-        return await self.query(watch=False, state=False, presence=False)
+        options["watch"] = False
+        options["state"] = False
+        options["presence"] = False
+        return await self.query(**options)
 
     async def query(self, **options: Any) -> StreamResponse:
         payload = {"state": True, "data": self.custom_data, **options}

stream_chat/base/channel.py

@@ -86,7 +86,9 @@ def delete_reaction(
         pass
 
     @abc.abstractmethod
-    def create(self, user_id: str) -> Union[StreamResponse, Awaitable[StreamResponse]]:
+    def create(
+        self, user_id: str, **options: Any
+    ) -> Union[StreamResponse, Awaitable[StreamResponse]]:
         """
         Create the channel
 

stream_chat/channel.py

@@ -30,9 +30,12 @@ def delete_reaction(
             params={"user_id": user_id},
         )
 
-    def create(self, user_id: str) -> StreamResponse:
+    def create(self, user_id: str, **options: Any) -> StreamResponse:
         self.custom_data["created_by"] = {"id": user_id}
-        return self.query(watch=False, state=False, presence=False)
+        options["watch"] = False
+        options["state"] = False
+        options["presence"] = False
+        return self.query(**options)
 
     def get_messages(self, message_ids: List[str]) -> StreamResponse:
         return self.client.get(

stream_chat/tests/async_chat/test_channel.py

@@ -35,6 +35,17 @@ async def test_create_without_id(
         await channel.create(random_users[0]["id"])
         assert channel.id is not None
 
+    async def test_create_with_options(
+        self, client: StreamChatAsync, random_users: List[Dict]
+    ):
+        channel = client.channel(
+            "messaging", data={"members": [u["id"] for u in random_users]}
+        )
+        assert channel.id is None
+
+        await channel.create(random_users[0]["id"], hide_for_creator=True)
+        assert channel.id is not None
+
     async def test_send_message_with_options(self, channel: Channel, random_user: Dict):
         response = await channel.send_message(
             {"text": "hi"}, random_user["id"], skip_push=True

stream_chat/tests/test_channel.py

@@ -31,6 +31,15 @@ def test_create_without_id(self, client: StreamChat, random_users: List[Dict]):
         channel.create(random_users[0]["id"])
         assert channel.id is not None
 
+    def test_create_with_options(self, client: StreamChat, random_users: List[Dict]):
+        channel = client.channel(
+            "messaging", data={"members": [u["id"] for u in random_users]}
+        )
+        assert channel.id is None
+
+        channel.create(random_users[0]["id"], hide_for_creator=True)
+        assert channel.id is not None
+
     def test_send_message_with_options(self, channel: Channel, random_user: Dict):
         response = channel.send_message(
             {"text": "hi"}, random_user["id"], skip_push=True