feat!: [FEEDS-1830] regenerate OpenAPI client

getstream/chat/async_channel.py

@@ -9,7 +9,7 @@ def __init__(
         self,
         client,
         channel_type: str,
-        channel_id: str | None = None,
+        channel_id: str = None,
         custom_data: Dict = None,
     ):
         self.channel_id = channel_id

getstream/chat/async_rest_client.py

@@ -13,7 +13,7 @@ def __init__(
         base_url: str,
         timeout: float,
         token: str,
-        user_agent: str | None = None,
+        user_agent: str = None,
     ):
         """
         Initializes ChatClient with BaseClient instance
@@ -243,11 +243,18 @@ async def channel_batch_update(
         self,
         operation: str,
         filter: Dict[str, object],
+        custom_unset: Optional[List[str]] = None,
         members: Optional[List[ChannelBatchMemberRequest]] = None,
+        custom_set: Optional[Dict[str, object]] = None,
         data: Optional[ChannelDataUpdate] = None,
     ) -> StreamResponse[ChannelBatchUpdateResponse]:
         json = ChannelBatchUpdateRequest(
-            operation=operation, filter=filter, members=members, data=data
+            operation=operation,
+            filter=filter,
+            custom_unset=custom_unset,
+            members=members,
+            custom_set=custom_set,
+            data=data,
         ).to_dict()
         return await self.put(
             "/api/v2/chat/channels/batch", ChannelBatchUpdateResponse, json=json
@@ -1465,14 +1472,14 @@ async def query_reactions(
     @telemetry.operation_name("getstream.api.chat.translate_message")
     async def translate_message(
         self, id: str, language: str
-    ) -> StreamResponse[MessageActionResponse]:
+    ) -> StreamResponse[TranslateMessageResponse]:
         path_params = {
             "id": id,
         }
         json = TranslateMessageRequest(language=language).to_dict()
         return await self.post(
             "/api/v2/chat/messages/{id}/translate",
-            MessageActionResponse,
+            TranslateMessageResponse,
             path_params=path_params,
             json=json,
         )
@@ -1573,7 +1580,7 @@ async def create_reminder(
         remind_at: Optional[datetime] = None,
         user_id: Optional[str] = None,
         user: Optional[UserRequest] = None,
-    ) -> StreamResponse[ReminderResponseData]:
+    ) -> StreamResponse[CreateReminderResponse]:
         path_params = {
             "message_id": message_id,
         }
@@ -1582,7 +1589,7 @@ async def create_reminder(
         ).to_dict()
         return await self.post(
             "/api/v2/chat/messages/{message_id}/reminders",
-            ReminderResponseData,
+            CreateReminderResponse,
             path_params=path_params,
             json=json,
         )

getstream/chat/channel.py

@@ -9,7 +9,7 @@ def __init__(
         self,
         client,
         channel_type: str,
-        channel_id: str | None = None,
+        channel_id: str = None,
         custom_data: Dict = None,
     ):
         self.channel_id = channel_id

getstream/chat/rest_client.py

@@ -13,7 +13,7 @@ def __init__(
         base_url: str,
         timeout: float,
         token: str,
-        user_agent: str | None = None,
+        user_agent: str = None,
     ):
         """
         Initializes ChatClient with BaseClient instance
@@ -239,11 +239,18 @@ def channel_batch_update(
         self,
         operation: str,
         filter: Dict[str, object],
+        custom_unset: Optional[List[str]] = None,
         members: Optional[List[ChannelBatchMemberRequest]] = None,
+        custom_set: Optional[Dict[str, object]] = None,
         data: Optional[ChannelDataUpdate] = None,
     ) -> StreamResponse[ChannelBatchUpdateResponse]:
         json = ChannelBatchUpdateRequest(
-            operation=operation, filter=filter, members=members, data=data
+            operation=operation,
+            filter=filter,
+            custom_unset=custom_unset,
+            members=members,
+            custom_set=custom_set,
+            data=data,
         ).to_dict()
         return self.put(
             "/api/v2/chat/channels/batch", ChannelBatchUpdateResponse, json=json
@@ -1453,14 +1460,14 @@ def query_reactions(
     @telemetry.operation_name("getstream.api.chat.translate_message")
     def translate_message(
         self, id: str, language: str
-    ) -> StreamResponse[MessageActionResponse]:
+    ) -> StreamResponse[TranslateMessageResponse]:
         path_params = {
             "id": id,
         }
         json = TranslateMessageRequest(language=language).to_dict()
         return self.post(
             "/api/v2/chat/messages/{id}/translate",
-            MessageActionResponse,
+            TranslateMessageResponse,
             path_params=path_params,
             json=json,
         )
@@ -1561,7 +1568,7 @@ def create_reminder(
         remind_at: Optional[datetime] = None,
         user_id: Optional[str] = None,
         user: Optional[UserRequest] = None,
-    ) -> StreamResponse[ReminderResponseData]:
+    ) -> StreamResponse[CreateReminderResponse]:
         path_params = {
             "message_id": message_id,
         }
@@ -1570,7 +1577,7 @@ def create_reminder(
         ).to_dict()
         return self.post(
             "/api/v2/chat/messages/{message_id}/reminders",
-            ReminderResponseData,
+            CreateReminderResponse,
             path_params=path_params,
             json=json,
         )

getstream/common/async_rest_client.py

@@ -13,7 +13,7 @@ def __init__(
         base_url: str,
         timeout: float,
         token: str,
-        user_agent: str | None = None,
+        user_agent: str = None,
     ):
         """
         Initializes CommonClient with BaseClient instance
@@ -56,7 +56,9 @@ async def update_app(
         guest_user_creation_disabled: Optional[bool] = None,
         image_moderation_enabled: Optional[bool] = None,
         max_aggregated_activities_length: Optional[int] = None,
+        member_custom_on_mentioned_users_enabled: Optional[bool] = None,
         member_custom_on_messages_enabled: Optional[bool] = None,
+        member_custom_on_typing_events_enabled: Optional[bool] = None,
         migrate_permissions_to_v2: Optional[bool] = None,
         moderation_analytics_enabled: Optional[bool] = None,
         moderation_enabled: Optional[bool] = None,
@@ -118,7 +120,9 @@ async def update_app(
             guest_user_creation_disabled=guest_user_creation_disabled,
             image_moderation_enabled=image_moderation_enabled,
             max_aggregated_activities_length=max_aggregated_activities_length,
+            member_custom_on_mentioned_users_enabled=member_custom_on_mentioned_users_enabled,
             member_custom_on_messages_enabled=member_custom_on_messages_enabled,
+            member_custom_on_typing_events_enabled=member_custom_on_typing_events_enabled,
             migrate_permissions_to_v2=migrate_permissions_to_v2,
             moderation_analytics_enabled=moderation_analytics_enabled,
             moderation_enabled=moderation_enabled,

getstream/common/rest_client.py

@@ -13,7 +13,7 @@ def __init__(
         base_url: str,
         timeout: float,
         token: str,
-        user_agent: str | None = None,
+        user_agent: str = None,
     ):
         """
         Initializes CommonClient with BaseClient instance
@@ -56,7 +56,9 @@ def update_app(
         guest_user_creation_disabled: Optional[bool] = None,
         image_moderation_enabled: Optional[bool] = None,
         max_aggregated_activities_length: Optional[int] = None,
+        member_custom_on_mentioned_users_enabled: Optional[bool] = None,
         member_custom_on_messages_enabled: Optional[bool] = None,
+        member_custom_on_typing_events_enabled: Optional[bool] = None,
         migrate_permissions_to_v2: Optional[bool] = None,
         moderation_analytics_enabled: Optional[bool] = None,
         moderation_enabled: Optional[bool] = None,
@@ -118,7 +120,9 @@ def update_app(
             guest_user_creation_disabled=guest_user_creation_disabled,
             image_moderation_enabled=image_moderation_enabled,
             max_aggregated_activities_length=max_aggregated_activities_length,
+            member_custom_on_mentioned_users_enabled=member_custom_on_mentioned_users_enabled,
             member_custom_on_messages_enabled=member_custom_on_messages_enabled,
+            member_custom_on_typing_events_enabled=member_custom_on_typing_events_enabled,
             migrate_permissions_to_v2=migrate_permissions_to_v2,
             moderation_analytics_enabled=moderation_analytics_enabled,
             moderation_enabled=moderation_enabled,

getstream/feeds/rest_client.py

@@ -13,7 +13,7 @@ def __init__(
         base_url: str,
         timeout: float,
         token: str,
-        user_agent: str | None = None,
+        user_agent: str = None,
     ):
         """
         Initializes FeedsClient with BaseClient instance
@@ -1323,10 +1323,12 @@ def list_feed_groups(
     def create_feed_group(
         self,
         id: str,
+        default_follower_role: Optional[str] = None,
         default_visibility: Optional[str] = None,
         activity_processors: Optional[List[ActivityProcessorConfig]] = None,
         activity_selectors: Optional[List[ActivitySelectorConfig]] = None,
         activity_filter: Optional[ActivityFilterConfig] = None,
+        activity_processing: Optional[ActivityProcessingConfig] = None,
         aggregation: Optional[AggregationConfig] = None,
         custom: Optional[Dict[str, object]] = None,
         notification: Optional[NotificationConfig] = None,
@@ -1336,10 +1338,12 @@ def create_feed_group(
     ) -> StreamResponse[CreateFeedGroupResponse]:
         json = CreateFeedGroupRequest(
             id=id,
+            default_follower_role=default_follower_role,
             default_visibility=default_visibility,
             activity_processors=activity_processors,
             activity_selectors=activity_selectors,
             activity_filter=activity_filter,
+            activity_processing=activity_processing,
             aggregation=aggregation,
             custom=custom,
             notification=notification,
@@ -1779,10 +1783,12 @@ def get_feed_group(
     def get_or_create_feed_group(
         self,
         id: str,
+        default_follower_role: Optional[str] = None,
         default_visibility: Optional[str] = None,
         activity_processors: Optional[List[ActivityProcessorConfig]] = None,
         activity_selectors: Optional[List[ActivitySelectorConfig]] = None,
         activity_filter: Optional[ActivityFilterConfig] = None,
+        activity_processing: Optional[ActivityProcessingConfig] = None,
         aggregation: Optional[AggregationConfig] = None,
         custom: Optional[Dict[str, object]] = None,
         notification: Optional[NotificationConfig] = None,
@@ -1794,10 +1800,12 @@ def get_or_create_feed_group(
             "id": id,
         }
         json = GetOrCreateFeedGroupRequest(
+            default_follower_role=default_follower_role,
             default_visibility=default_visibility,
             activity_processors=activity_processors,
             activity_selectors=activity_selectors,
             activity_filter=activity_filter,
+            activity_processing=activity_processing,
             aggregation=aggregation,
             custom=custom,
             notification=notification,
@@ -1816,10 +1824,12 @@ def get_or_create_feed_group(
     def update_feed_group(
         self,
         id: str,
+        default_follower_role: Optional[str] = None,
         default_visibility: Optional[str] = None,
         activity_processors: Optional[List[ActivityProcessorConfig]] = None,
         activity_selectors: Optional[List[ActivitySelectorConfig]] = None,
         activity_filter: Optional[ActivityFilterConfig] = None,
+        activity_processing: Optional[ActivityProcessingConfig] = None,
         aggregation: Optional[AggregationConfig] = None,
         custom: Optional[Dict[str, object]] = None,
         notification: Optional[NotificationConfig] = None,
@@ -1831,10 +1841,12 @@ def update_feed_group(
             "id": id,
         }
         json = UpdateFeedGroupRequest(
+            default_follower_role=default_follower_role,
             default_visibility=default_visibility,
             activity_processors=activity_processors,
             activity_selectors=activity_selectors,
             activity_filter=activity_filter,
+            activity_processing=activity_processing,
             aggregation=aggregation,
             custom=custom,
             notification=notification,
@@ -1971,10 +1983,13 @@ def update_feed_visibility(
 
     @telemetry.operation_name("getstream.api.feeds.create_feeds_batch")
     def create_feeds_batch(
-        self, feeds: List[FeedRequest], enrich_own_fields: Optional[bool] = None
+        self,
+        feeds: List[FeedRequest],
+        create_users: Optional[bool] = None,
+        enrich_own_fields: Optional[bool] = None,
     ) -> StreamResponse[CreateFeedsBatchResponse]:
         json = CreateFeedsBatchRequest(
-            feeds=feeds, enrich_own_fields=enrich_own_fields
+            feeds=feeds, create_users=create_users, enrich_own_fields=enrich_own_fields
         ).to_dict()
         return self.post(
             "/api/v2/feeds/feeds/batch", CreateFeedsBatchResponse, json=json