chore: more campaign endpoint changes (#130)

Author: ferhatelmas

stream_chat/async_chat/client.py

@@ -511,10 +511,10 @@ async def list_roles(self) -> StreamResponse:
         return await self.get("roles")
 
     async def create_segment(self, segment: Dict) -> StreamResponse:
-        return await self.post("segments/new", data={"segment": segment})
+        return await self.post("segments", data={"segment": segment})
 
     async def query_segments(self, **params: Any) -> StreamResponse:
-        return await self.post("segments", data=params)
+        return await self.get("segments", params={"payload": json.dumps(params)})
 
     async def update_segment(self, segment_id: str, data: Dict) -> StreamResponse:
         return await self.put(f"segments/{segment_id}", data={"segment": data})
@@ -523,10 +523,10 @@ async def delete_segment(self, segment_id: str) -> StreamResponse:
         return await self.delete(f"segments/{segment_id}")
 
     async def create_campaign(self, campaign: Dict) -> StreamResponse:
-        return await self.post("campaigns/new", data={"campaign": campaign})
+        return await self.post("campaigns", data={"campaign": campaign})
 
     async def query_campaigns(self, **params: Any) -> StreamResponse:
-        return await self.post("campaigns", params)
+        return await self.get("campaigns", params={"payload": json.dumps(params)})
 
     async def update_campaign(self, campaign_id: str, data: Dict) -> StreamResponse:
         return await self.put(f"campaigns/{campaign_id}", data={"campaign": data})
@@ -543,7 +543,7 @@ async def schedule_campaign(
         )
 
     async def query_recipients(self, **params: Any) -> StreamResponse:
-        return await self.post("recipients", data=params)
+        return await self.get("recipients", params={"payload": json.dumps(params)})
 
     async def stop_campaign(self, campaign_id: str) -> StreamResponse:
         return await self.patch(f"campaigns/{campaign_id}/stop")

stream_chat/client.py

@@ -489,10 +489,10 @@ def list_roles(self) -> StreamResponse:
         return self.get("roles")
 
     def create_segment(self, segment: Dict) -> StreamResponse:
-        return self.post("segments/new", data={"segment": segment})
+        return self.post("segments", data={"segment": segment})
 
     def query_segments(self, **params: Any) -> StreamResponse:
-        return self.post("segments", data=params)
+        return self.get("segments", params={"payload": json.dumps(params)})
 
     def update_segment(self, segment_id: str, data: Dict) -> StreamResponse:
         return self.put(f"segments/{segment_id}", data={"segment": data})
@@ -501,10 +501,10 @@ def delete_segment(self, segment_id: str) -> StreamResponse:
         return self.delete(f"segments/{segment_id}")
 
     def create_campaign(self, campaign: Dict) -> StreamResponse:
-        return self.post("campaigns/new", data={"campaign": campaign})
+        return self.post("campaigns", data={"campaign": campaign})
 
     def query_campaigns(self, **params: Any) -> StreamResponse:
-        return self.post("campaigns", data=params)
+        return self.get("campaigns", params={"payload": json.dumps(params)})
 
     def update_campaign(self, campaign_id: str, data: Dict) -> StreamResponse:
         return self.put(f"campaigns/{campaign_id}", data={"campaign": data})
@@ -529,7 +529,7 @@ def test_campaign(self, campaign_id: str, users: Iterable[str]) -> StreamRespons
         return self.post(f"campaigns/{campaign_id}/test", data={"users": users})
 
     def query_recipients(self, **params: Any) -> StreamResponse:
-        return self.post("recipients", data=params)
+        return self.get("recipients", params={"payload": json.dumps(params)})
 
     def revoke_tokens(self, since: Union[str, datetime.datetime]) -> StreamResponse:
         if isinstance(since, datetime.datetime):