query_campaigns & query_segments => POST requests

GetStream · Feb 12, 2024 · 86813fb · 86813fb
1 parent 7561524
commit 86813fb
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/stream_chat/async_chat/client.py b/stream_chat/async_chat/client.py
@@ -545,7 +545,7 @@ async def create_segment(self, segment_type: SegmentType, segment_id: str, name:
 
     async def query_segments(self, filter_conditions: Dict, options: QuerySegmentsOptions) -> StreamResponse:
         payload = {"filter": filter_conditions, **options}
-        return await self.get("segments", params={"payload": json.dumps(payload)})
+        return await self.post("segments/query", params=payload)
 
     async def update_segment(self, segment_id: str, data: UpdateSegmentData) -> StreamResponse:
         return await self.put(f"segments/{segment_id}", data=data)
@@ -558,7 +558,7 @@ async def create_campaign(self, params: CampaignData) -> StreamResponse:
 
     async def query_campaigns(self, filter_conditions: Dict[str, Any], options: QueryCampaignsOptions = None) -> StreamResponse:
         payload = {"filter": filter_conditions, **options}
-        return await self.get("campaigns", params={"payload": json.dumps(payload)})
+        return await self.post("campaigns/query", params=payload)
 
     async def update_campaign(self, campaign_id: str, params: CampaignData) -> StreamResponse:
         return await self.put(f"campaigns/{campaign_id}", data=params)

diff --git a/stream_chat/client.py b/stream_chat/client.py
@@ -526,20 +526,20 @@ def create_segment(self, segment_type: SegmentType, segment_id: str, name: str,
 
     def query_segments(self, filter_conditions: Dict, options: QuerySegmentsOptions) -> StreamResponse:
         payload = {"filter": filter_conditions, **options}
-        return self.get("segments", params={"payload": json.dumps(payload)})
+        return self.post("segments", params=payload)
 
     def update_segment(self, segment_id: str, data: UpdateSegmentData) -> StreamResponse:
         return self.put(f"segments/{segment_id}", data=data)
 
     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", data={"campaign": campaign})
+    def create_campaign(self, params: CampaignData) -> StreamResponse:
+        return self.post("campaigns", data=params)
 
     def query_campaigns(self, filter_conditions: Dict[str, Any], options: QueryCampaignsOptions = None) -> StreamResponse:
         payload = {"filter": filter_conditions, **options}
-        return self.get("campaigns", params={"payload": json.dumps(payload)})
+        return self.post("campaigns/query", params=payload)
 
     def update_campaign(self, campaign_id: str, params: CampaignData) -> StreamResponse:
         return self.put(f"campaigns/{campaign_id}", data=params)