Regenerated code from spec

getstream/chat/rest_client.py

@@ -1,3 +1,4 @@
+# Code generated by GetStream internal OpenAPI code generator. DO NOT EDIT.
 from getstream.base import BaseClient
 from getstream.models import *
 from getstream.stream_response import StreamResponse
@@ -20,6 +21,65 @@ def __init__(self, api_key: str, base_url: str, timeout: float, token: str):
             token=token,
         )
 
+    def query_campaigns(
+        self,
+        limit: Optional[int] = None,
+        next: Optional[str] = None,
+        prev: Optional[str] = None,
+        sort: Optional[List[Optional[SortParamRequest]]] = None,
+        filter: Optional[Dict[str, object]] = None,
+    ) -> StreamResponse[QueryCampaignsResponse]:
+        json = build_body_dict(
+            limit=limit, next=next, prev=prev, sort=sort, filter=filter
+        )
+
+        return self.post(
+            "/api/v2/chat/campaigns/query", QueryCampaignsResponse, json=json
+        )
+
+    def get_campaign(self, id: str) -> StreamResponse[GetCampaignResponse]:
+        path_params = {
+            "id": id,
+        }
+
+        return self.get(
+            "/api/v2/chat/campaigns/{id}", GetCampaignResponse, path_params=path_params
+        )
+
+    def start_campaign(
+        self,
+        id: str,
+        scheduled_for: Optional[datetime] = None,
+        stop_at: Optional[datetime] = None,
+    ) -> StreamResponse[StartCampaignResponse]:
+        path_params = {
+            "id": id,
+        }
+        json = build_body_dict(scheduled_for=scheduled_for, stop_at=stop_at)
+
+        return self.post(
+            "/api/v2/chat/campaigns/{id}/start",
+            StartCampaignResponse,
+            path_params=path_params,
+            json=json,
+        )
+
+    def schedule_campaign(
+        self,
+        id: str,
+    ) -> StreamResponse[CampaignResponse]:
+        path_params = {
+            "id": id,
+        }
+        json = build_body_dict()
+
+        return self.post(
+            "/api/v2/chat/campaigns/{id}/stop",
+            CampaignResponse,
+            path_params=path_params,
+            json=json,
+        )
+
     def query_channels(
         self,
         limit: Optional[int] = None,
@@ -522,6 +582,7 @@ def create_channel_type(
         read_events: Optional[bool] = None,
         replies: Optional[bool] = None,
         search: Optional[bool] = None,
+        skip_last_msg_update_for_system_msgs: Optional[bool] = None,
         typing_events: Optional[bool] = None,
         uploads: Optional[bool] = None,
         url_enrichment: Optional[bool] = None,
@@ -550,6 +611,7 @@ def create_channel_type(
             read_events=read_events,
             replies=replies,
             search=search,
+            skip_last_msg_update_for_system_msgs=skip_last_msg_update_for_system_msgs,
             typing_events=typing_events,
             uploads=uploads,
             url_enrichment=url_enrichment,
@@ -605,6 +667,7 @@ def update_channel_type(
         reminders: Optional[bool] = None,
         replies: Optional[bool] = None,
         search: Optional[bool] = None,
+        skip_last_msg_update_for_system_msgs: Optional[bool] = None,
         typing_events: Optional[bool] = None,
         uploads: Optional[bool] = None,
         url_enrichment: Optional[bool] = None,
@@ -638,6 +701,7 @@ def update_channel_type(
             reminders=reminders,
             replies=replies,
             search=search,
+            skip_last_msg_update_for_system_msgs=skip_last_msg_update_for_system_msgs,
             typing_events=typing_events,
             uploads=uploads,
             url_enrichment=url_enrichment,
@@ -1374,6 +1438,92 @@ def search(
             "/api/v2/chat/search", SearchResponse, query_params=query_params
         )
 
+    def query_segments(
+        self,
+        filter: Dict[str, object],
+        limit: Optional[int] = None,
+        next: Optional[str] = None,
+        prev: Optional[str] = None,
+        sort: Optional[List[Optional[SortParamRequest]]] = None,
+    ) -> StreamResponse[QuerySegmentsResponse]:
+        json = build_body_dict(
+            filter=filter, limit=limit, next=next, prev=prev, sort=sort
+        )
+
+        return self.post(
+            "/api/v2/chat/segments/query", QuerySegmentsResponse, json=json
+        )
+
+    def delete_segment(self, id: str) -> StreamResponse[Response]:
+        path_params = {
+            "id": id,
+        }
+
+        return self.delete(
+            "/api/v2/chat/segments/{id}", Response, path_params=path_params
+        )
+
+    def get_segment(self, id: str) -> StreamResponse[GetSegmentResponse]:
+        path_params = {
+            "id": id,
+        }
+
+        return self.get(
+            "/api/v2/chat/segments/{id}", GetSegmentResponse, path_params=path_params
+        )
+
+    def delete_segment_targets(
+        self, id: str, target_ids: List[str]
+    ) -> StreamResponse[Response]:
+        path_params = {
+            "id": id,
+        }
+        json = build_body_dict(target_ids=target_ids)
+
+        return self.post(
+            "/api/v2/chat/segments/{id}/deletetargets",
+            Response,
+            path_params=path_params,
+            json=json,
+        )
+
+    def segment_target_exists(
+        self, id: str, target_id: str
+    ) -> StreamResponse[Response]:
+        path_params = {
+            "id": id,
+            "target_id": target_id,
+        }
+
+        return self.get(
+            "/api/v2/chat/segments/{id}/target/{target_id}",
+            Response,
+            path_params=path_params,
+        )
+
+    def query_segment_targets(
+        self,
+        id: str,
+        limit: Optional[int] = None,
+        next: Optional[str] = None,
+        prev: Optional[str] = None,
+        sort: Optional[List[Optional[SortParamRequest]]] = None,
+        filter: Optional[Dict[str, object]] = None,
+    ) -> StreamResponse[QuerySegmentTargetsResponse]:
+        path_params = {
+            "id": id,
+        }
+        json = build_body_dict(
+            limit=limit, next=next, prev=prev, sort=sort, filter=filter
+        )
+
+        return self.post(
+            "/api/v2/chat/segments/{id}/targets/query",
+            QuerySegmentTargetsResponse,
+            path_params=path_params,
+            json=json,
+        )
+
     def query_threads(
         self,
         limit: Optional[int] = None,

getstream/common/rest_client.py

@@ -1,3 +1,4 @@
+# Code generated by GetStream internal OpenAPI code generator. DO NOT EDIT.
 from getstream.base import BaseClient
 from getstream.models import *
 from getstream.stream_response import StreamResponse