chore: more campaign api changes (#128)

Author: ferhatelmas

stream_chat/async_chat/client.py

@@ -511,7 +511,7 @@ async def list_roles(self) -> StreamResponse:
         return await self.get("roles")
 
     async def create_segment(self, segment: Dict) -> StreamResponse:
-        return await self.post("segments", data={"segment": segment})
+        return await self.post("segments/new", data={"segment": segment})
 
     async def query_segments(self, **params: Any) -> StreamResponse:
         return await self.post("segments", data=params)
@@ -523,7 +523,7 @@ 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", data={"campaign": campaign})
+        return await self.post("campaigns/new", data={"campaign": campaign})
 
     async def query_campaigns(self, **params: Any) -> StreamResponse:
         return await self.post("campaigns", params)
@@ -536,10 +536,10 @@ async def delete_campaign(self, campaign_id: str) -> StreamResponse:
         return await self.delete(f"campaigns/{campaign_id}")
 
     async def schedule_campaign(
-        self, campaign_id: str, send_at: int = None
+        self, campaign_id: str, scheduled_for: int = None
     ) -> StreamResponse:
         return await self.patch(
-            f"campaigns/{campaign_id}/schedule", data={"send_at": send_at}
+            f"campaigns/{campaign_id}/schedule", data={"scheduled_for": scheduled_for}
         )
 
     async def query_recipients(self, **params: Any) -> StreamResponse:

stream_chat/base/client.py

@@ -971,7 +971,7 @@ def delete_campaign(
 
     @abc.abstractmethod
     def schedule_campaign(
-        self, campaign_id: str, send_at: int = None
+        self, campaign_id: str, scheduled_for: int = None
     ) -> Union[StreamResponse, Awaitable[StreamResponse]]:
         """
         Schedule a campaign at given time

stream_chat/client.py

@@ -489,7 +489,7 @@ def list_roles(self) -> StreamResponse:
         return self.get("roles")
 
     def create_segment(self, segment: Dict) -> StreamResponse:
-        return self.post("segments", data={"segment": segment})
+        return self.post("segments/new", data={"segment": segment})
 
     def query_segments(self, **params: Any) -> StreamResponse:
         return self.post("segments", data=params)
@@ -501,7 +501,7 @@ 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})
+        return self.post("campaigns/new", data={"campaign": campaign})
 
     def query_campaigns(self, **params: Any) -> StreamResponse:
         return self.post("campaigns", data=params)
@@ -513,10 +513,10 @@ def delete_campaign(self, campaign_id: str) -> StreamResponse:
         return self.delete(f"campaigns/{campaign_id}")
 
     def schedule_campaign(
-        self, campaign_id: str, send_at: int = None
+        self, campaign_id: str, scheduled_for: int = None
     ) -> StreamResponse:
         return self.patch(
-            f"campaigns/{campaign_id}/schedule", data={"send_at": send_at}
+            f"campaigns/{campaign_id}/schedule", data={"scheduled_for": scheduled_for}
         )
 
     def stop_campaign(self, campaign_id: str) -> StreamResponse: