regen

Author: tbarbugli

getstream/common/rest_client.py

@@ -122,6 +122,46 @@ def update_app(
 
         return self.patch("/api/v2/app", Response, json=json)
 
+    def list_block_lists(self) -> StreamResponse[ListBlockListResponse]:
+        return self.get("/api/v2/blocklists", ListBlockListResponse)
+
+    def create_block_list(
+        self, name: str, words: List[str], type: Optional[str] = None
+    ) -> StreamResponse[Response]:
+        json = build_body_dict(name=name, words=words, type=type)
+
+        return self.post("/api/v2/blocklists", Response, json=json)
+
+    def delete_block_list(self, name: str) -> StreamResponse[Response]:
+        path_params = {
+            "name": name,
+        }
+
+        return self.delete(
+            "/api/v2/blocklists/{name}", Response, path_params=path_params
+        )
+
+    def get_block_list(self, name: str) -> StreamResponse[GetBlockListResponse]:
+        path_params = {
+            "name": name,
+        }
+
+        return self.get(
+            "/api/v2/blocklists/{name}", GetBlockListResponse, path_params=path_params
+        )
+
+    def update_block_list(
+        self, name: str, words: Optional[List[str]] = None
+    ) -> StreamResponse[Response]:
+        path_params = {
+            "name": name,
+        }
+        json = build_body_dict(words=words)
+
+        return self.put(
+            "/api/v2/blocklists/{name}", Response, path_params=path_params, json=json
+        )
+
     def check_push(
         self,
         apn_template: Optional[str] = None,
@@ -428,6 +468,27 @@ def update_users(
 
         return self.post("/api/v2/users", UpdateUsersResponse, json=json)
 
+    def get_blocked_users(
+        self, user_id: Optional[str] = None
+    ) -> StreamResponse[GetBlockedUsersResponse]:
+        query_params = build_query_param(user_id=user_id)
+
+        return self.get(
+            "/api/v2/users/block", GetBlockedUsersResponse, query_params=query_params
+        )
+
+    def block_users(
+        self,
+        blocked_user_id: str,
+        user_id: Optional[str] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[BlockUsersResponse]:
+        json = build_body_dict(
+            blocked_user_id=blocked_user_id, user_id=user_id, user=user
+        )
+
+        return self.post("/api/v2/users/block", BlockUsersResponse, json=json)
+
     def deactivate_users(
         self,
         user_ids: List[str],
@@ -487,6 +548,18 @@ def restore_users(self, user_ids: List[str]) -> StreamResponse[Response]:
 
         return self.post("/api/v2/users/restore", Response, json=json)
 
+    def unblock_users(
+        self,
+        blocked_user_id: str,
+        user_id: Optional[str] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[UnblockUsersResponse]:
+        json = build_body_dict(
+            blocked_user_id=blocked_user_id, user_id=user_id, user=user
+        )
+
+        return self.post("/api/v2/users/unblock", UnblockUsersResponse, json=json)
+
     def deactivate_user(
         self,
         user_id: str,

getstream/models/__init__.py

@@ -6789,9 +6789,7 @@ class MessageNewEvent(DataClassJsonMixin):
         )
     )
     watcher_count: int = dc_field(metadata=dc_config(field_name="watcher_count"))
-    type: str = dc_field(
-        default="notification.thread_message_new", metadata=dc_config(field_name="type")
-    )
+    type: str = dc_field(default="message.new", metadata=dc_config(field_name="type"))
     team: Optional[str] = dc_field(default=None, metadata=dc_config(field_name="team"))
     thread_participants: "Optional[List[User]]" = dc_field(
         default=None, metadata=dc_config(field_name="thread_participants")