Build code from latest spec

getstream/chat/rest_client.py

@@ -645,6 +645,7 @@ def create_channel_type(
         typing_events: Optional[bool] = None,
         uploads: Optional[bool] = None,
         url_enrichment: Optional[bool] = None,
+        user_message_reminders: Optional[bool] = None,
         blocklists: Optional[List[BlockListOptions]] = None,
         commands: Optional[List[str]] = None,
         permissions: Optional[List[PolicyRequest]] = None,
@@ -674,6 +675,7 @@ def create_channel_type(
             typing_events=typing_events,
             uploads=uploads,
             url_enrichment=url_enrichment,
+            user_message_reminders=user_message_reminders,
             blocklists=blocklists,
             commands=commands,
             permissions=permissions,
@@ -730,6 +732,7 @@ def update_channel_type(
         typing_events: Optional[bool] = None,
         uploads: Optional[bool] = None,
         url_enrichment: Optional[bool] = None,
+        user_message_reminders: Optional[bool] = None,
         allowed_flag_reasons: Optional[List[str]] = None,
         blocklists: Optional[List[BlockListOptions]] = None,
         commands: Optional[List[str]] = None,
@@ -764,6 +767,7 @@ def update_channel_type(
             typing_events=typing_events,
             uploads=uploads,
             url_enrichment=url_enrichment,
+            user_message_reminders=user_message_reminders,
             allowed_flag_reasons=allowed_flag_reasons,
             blocklists=blocklists,
             commands=commands,
@@ -1171,6 +1175,59 @@ def remove_poll_vote(
             path_params=path_params,
         )
 
+    def delete_reminder(
+        self, message_id: str, user_id: Optional[str] = None
+    ) -> StreamResponse[DeleteReminderResponse]:
+        query_params = build_query_param(user_id=user_id)
+        path_params = {
+            "message_id": message_id,
+        }
+
+        return self.delete(
+            "/api/v2/chat/messages/{message_id}/reminders",
+            DeleteReminderResponse,
+            query_params=query_params,
+            path_params=path_params,
+        )
+
+    def update_reminder(
+        self,
+        message_id: str,
+        remind_at: Optional[datetime] = None,
+        user_id: Optional[str] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[UpdateReminderResponse]:
+        path_params = {
+            "message_id": message_id,
+        }
+        json = build_body_dict(remind_at=remind_at, user_id=user_id, user=user)
+
+        return self.patch(
+            "/api/v2/chat/messages/{message_id}/reminders",
+            UpdateReminderResponse,
+            path_params=path_params,
+            json=json,
+        )
+
+    def create_reminder(
+        self,
+        message_id: str,
+        remind_at: Optional[datetime] = None,
+        user_id: Optional[str] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[ReminderResponseData]:
+        path_params = {
+            "message_id": message_id,
+        }
+        json = build_body_dict(remind_at=remind_at, user_id=user_id, user=user)
+
+        return self.post(
+            "/api/v2/chat/messages/{message_id}/reminders",
+            ReminderResponseData,
+            path_params=path_params,
+            json=json,
+        )
+
     def get_replies(
         self,
         parent_id: str,
@@ -1551,6 +1608,30 @@ def query_banned_users(
             query_params=query_params,
         )
 
+    def query_reminders(
+        self,
+        limit: Optional[int] = None,
+        next: Optional[str] = None,
+        prev: Optional[str] = None,
+        user_id: Optional[str] = None,
+        sort: Optional[List[SortParamRequest]] = None,
+        filter: Optional[Dict[str, object]] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[QueryRemindersResponse]:
+        json = build_body_dict(
+            limit=limit,
+            next=next,
+            prev=prev,
+            user_id=user_id,
+            sort=sort,
+            filter=filter,
+            user=user,
+        )
+
+        return self.post(
+            "/api/v2/chat/reminders/query", QueryRemindersResponse, json=json
+        )
+
     def search(
         self, payload: Optional[SearchPayload] = None
     ) -> StreamResponse[SearchResponse]:

getstream/common/rest_client.py

@@ -55,6 +55,7 @@ def update_app(
         sqs_url: Optional[str] = None,
         webhook_url: Optional[str] = None,
         allowed_flag_reasons: Optional[List[str]] = None,
+        event_hooks: Optional[List[EventHook]] = None,
         image_moderation_block_labels: Optional[List[str]] = None,
         image_moderation_labels: Optional[List[str]] = None,
         user_search_disallowed_roles: Optional[List[str]] = None,
@@ -103,6 +104,7 @@ def update_app(
             sqs_url=sqs_url,
             webhook_url=webhook_url,
             allowed_flag_reasons=allowed_flag_reasons,
+            event_hooks=event_hooks,
             image_moderation_block_labels=image_moderation_block_labels,
             image_moderation_labels=image_moderation_labels,
             user_search_disallowed_roles=user_search_disallowed_roles,
@@ -190,6 +192,7 @@ def update_block_list(
     def check_push(
         self,
         apn_template: Optional[str] = None,
+        event_type: Optional[str] = None,
         firebase_data_template: Optional[str] = None,
         firebase_template: Optional[str] = None,
         message_id: Optional[str] = None,
@@ -201,6 +204,7 @@ def check_push(
     ) -> StreamResponse[CheckPushResponse]:
         json = build_body_dict(
             apn_template=apn_template,
+            event_type=event_type,
             firebase_data_template=firebase_data_template,
             firebase_template=firebase_template,
             message_id=message_id,
@@ -472,6 +476,33 @@ def get_task(self, id: str) -> StreamResponse[GetTaskResponse]:
 
         return self.get("/api/v2/tasks/{id}", GetTaskResponse, path_params=path_params)
 
+    def delete_file(self, url: Optional[str] = None) -> StreamResponse[Response]:
+        query_params = build_query_param(url=url)
+
+        return self.delete("/api/v2/uploads/file", Response, query_params=query_params)
+
+    def upload_file(
+        self, file: Optional[str] = None, user: Optional[OnlyUserID] = None
+    ) -> StreamResponse[FileUploadResponse]:
+        json = build_body_dict(file=file, user=user)
+
+        return self.post("/api/v2/uploads/file", FileUploadResponse, json=json)
+
+    def delete_image(self, url: Optional[str] = None) -> StreamResponse[Response]:
+        query_params = build_query_param(url=url)
+
+        return self.delete("/api/v2/uploads/image", Response, query_params=query_params)
+
+    def upload_image(
+        self,
+        file: Optional[str] = None,
+        upload_sizes: Optional[List[ImageSize]] = None,
+        user: Optional[OnlyUserID] = None,
+    ) -> StreamResponse[ImageUploadResponse]:
+        json = build_body_dict(file=file, upload_sizes=upload_sizes, user=user)
+
+        return self.post("/api/v2/uploads/image", ImageUploadResponse, json=json)
+
     def query_users(
         self, payload: Optional[QueryUsersPayload] = None
     ) -> StreamResponse[QueryUsersResponse]: