feat(verify_webhook): bytes as signature header (#119)

Author: peterdeme

stream_chat/base/client.py

@@ -89,14 +89,19 @@ def create_search_params(
 
         return params
 
-    def verify_webhook(self, request_body: bytes, x_signature: str) -> bool:
+    def verify_webhook(
+        self, request_body: bytes, x_signature: Union[str, bytes]
+    ) -> bool:
         """
         Verify the signature added to a webhook event
 
         :param request_body: the request body received from webhook
         :param x_signature: the x-signature header included in the request
         :return: bool
         """
+        if isinstance(x_signature, bytes):
+            x_signature = x_signature.decode()
+
         signature = hmac.new(
             key=self.api_secret.encode(), msg=request_body, digestmod=hashlib.sha256
         ).hexdigest()

stream_chat/tests/async_chat/test_client.py

@@ -153,7 +153,7 @@ async def test_delete_users(self, client: StreamChatAsync, random_user: Dict):
         )
         assert "task_id" in response
 
-        for _ in range(10):
+        for _ in range(20):
             response = await client.get_task(response["task_id"])
             if response["status"] == "completed" and response["result"][
                 random_user["id"]
@@ -690,7 +690,7 @@ async def test_delete_channels(self, client: StreamChatAsync, channel: Channel):
         response = await client.delete_channels([channel.cid])
         assert "task_id" in response
 
-        for _ in range(10):
+        for _ in range(20):
             response = await client.get_task(response["task_id"])
             if response["status"] == "completed" and response["result"][
                 channel.cid

stream_chat/tests/test_client.py

@@ -143,7 +143,7 @@ def test_delete_users(self, client: StreamChat, random_user: Dict):
         )
         assert "task_id" in response
 
-        for _ in range(10):
+        for _ in range(20):
             response = client.get_task(response["task_id"])
             if response["status"] == "completed" and response["result"][
                 random_user["id"]
@@ -646,7 +646,7 @@ def test_delete_channels(self, client: StreamChat, channel: Channel):
         response = client.delete_channels([channel.cid])
         assert "task_id" in response
 
-        for _ in range(10):
+        for _ in range(20):
             response = client.get_task(response["task_id"])
             if response["status"] == "completed" and response["result"][
                 channel.cid