[FEEDS-0]chore: feeds v3 sdk

.github/workflows/ci.yml

@@ -12,7 +12,7 @@ on:
 jobs:
   test:
     name: Tests
-    environment: ci
+    environment: feeds-v3-ci
     runs-on: ubuntu-latest
     continue-on-error: true
     strategy:

getstream/chat/rest_client.py

@@ -717,6 +717,7 @@ def update_channel_type(
         blocklist: Optional[str] = None,
         blocklist_behavior: Optional[str] = None,
         connect_events: Optional[bool] = None,
+        count_messages: Optional[bool] = None,
         custom_events: Optional[bool] = None,
         mark_messages_pending: Optional[bool] = None,
         mutes: Optional[bool] = None,
@@ -753,6 +754,7 @@ def update_channel_type(
             blocklist=blocklist,
             blocklist_behavior=blocklist_behavior,
             connect_events=connect_events,
+            count_messages=count_messages,
             custom_events=custom_events,
             mark_messages_pending=mark_messages_pending,
             mutes=mutes,
@@ -910,9 +912,15 @@ def query_message_history(
         )
 
     def delete_message(
-        self, id: str, hard: Optional[bool] = None, deleted_by: Optional[str] = None
+        self,
+        id: str,
+        hard: Optional[bool] = None,
+        deleted_by: Optional[str] = None,
+        delete_for_me: Optional[bool] = None,
     ) -> StreamResponse[DeleteMessageResponse]:
-        query_params = build_query_param(hard=hard, deleted_by=deleted_by)
+        query_params = build_query_param(
+            hard=hard, deleted_by=deleted_by, delete_for_me=delete_for_me
+        )
         path_params = {
             "id": id,
         }

getstream/common/rest_client.py

@@ -39,6 +39,7 @@ def update_app(
         feeds_v2_region: Optional[str] = None,
         guest_user_creation_disabled: Optional[bool] = None,
         image_moderation_enabled: Optional[bool] = None,
+        max_aggregated_activities_length: Optional[int] = None,
         migrate_permissions_to_v2: Optional[bool] = None,
         moderation_enabled: Optional[bool] = None,
         moderation_webhook_url: Optional[str] = None,
@@ -89,6 +90,7 @@ def update_app(
             feeds_v2_region=feeds_v2_region,
             guest_user_creation_disabled=guest_user_creation_disabled,
             image_moderation_enabled=image_moderation_enabled,
+            max_aggregated_activities_length=max_aggregated_activities_length,
             migrate_permissions_to_v2=migrate_permissions_to_v2,
             moderation_enabled=moderation_enabled,
             moderation_webhook_url=moderation_webhook_url,

getstream/feeds/feeds.py

@@ -0,0 +1,193 @@
+# Code generated by GetStream internal OpenAPI code generator. DO NOT EDIT.
+from getstream.models import *
+from getstream.stream_response import StreamResponse
+
+
+class Feed:
+    def __init__(self, client, feed_group: str, feed_id: str, custom_data: Dict = None):
+        self.id = feed_id
+        self.feed_group = feed_group
+        self.client = client
+        self.custom_data = custom_data or {}
+
+    def _sync_from_response(self, data):
+        if hasattr(data, "feed") and isinstance(data.feed, FeedResponse):
+            self.custom_data = data.feed.custom
+
+    def delete(
+        self, hard_delete: Optional[bool] = None
+    ) -> StreamResponse[DeleteFeedResponse]:
+        response = self.client.delete_feed(
+            feed_group_id=self.feed_group, feed_id=self.id, hard_delete=hard_delete
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def get_or_create(
+        self,
+        limit: Optional[int] = None,
+        next: Optional[str] = None,
+        prev: Optional[str] = None,
+        user_id: Optional[str] = None,
+        view: Optional[str] = None,
+        watch: Optional[bool] = None,
+        activity_selector_options: Optional[Dict[str, object]] = None,
+        data: Optional[FeedInput] = None,
+        external_ranking: Optional[Dict[str, object]] = None,
+        filter: Optional[Dict[str, object]] = None,
+        followers_pagination: Optional[PagerRequest] = None,
+        following_pagination: Optional[PagerRequest] = None,
+        interest_weights: Optional[Dict[str, float]] = None,
+        member_pagination: Optional[PagerRequest] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[GetOrCreateFeedResponse]:
+        response = self.client.get_or_create_feed(
+            feed_group_id=self.feed_group,
+            feed_id=self.id,
+            limit=limit,
+            next=next,
+            prev=prev,
+            user_id=user_id,
+            view=view,
+            watch=watch,
+            activity_selector_options=activity_selector_options,
+            data=data,
+            external_ranking=external_ranking,
+            filter=filter,
+            followers_pagination=followers_pagination,
+            following_pagination=following_pagination,
+            interest_weights=interest_weights,
+            member_pagination=member_pagination,
+            user=user,
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def update(
+        self,
+        created_by_id: Optional[str] = None,
+        custom: Optional[Dict[str, object]] = None,
+    ) -> StreamResponse[UpdateFeedResponse]:
+        response = self.client.update_feed(
+            feed_group_id=self.feed_group,
+            feed_id=self.id,
+            created_by_id=created_by_id,
+            custom=custom,
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def mark_activity(
+        self,
+        mark_all_read: Optional[bool] = None,
+        mark_all_seen: Optional[bool] = None,
+        user_id: Optional[str] = None,
+        mark_read: Optional[List[str]] = None,
+        mark_seen: Optional[List[str]] = None,
+        mark_watched: Optional[List[str]] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[Response]:
+        response = self.client.mark_activity(
+            feed_group_id=self.feed_group,
+            feed_id=self.id,
+            mark_all_read=mark_all_read,
+            mark_all_seen=mark_all_seen,
+            user_id=user_id,
+            mark_read=mark_read,
+            mark_seen=mark_seen,
+            mark_watched=mark_watched,
+            user=user,
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def unpin_activity(
+        self, activity_id: str, user_id: Optional[str] = None
+    ) -> StreamResponse[UnpinActivityResponse]:
+        response = self.client.unpin_activity(
+            feed_group_id=self.feed_group,
+            feed_id=self.id,
+            activity_id=activity_id,
+            user_id=user_id,
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def pin_activity(
+        self,
+        activity_id: str,
+        user_id: Optional[str] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[PinActivityResponse]:
+        response = self.client.pin_activity(
+            feed_group_id=self.feed_group,
+            feed_id=self.id,
+            activity_id=activity_id,
+            user_id=user_id,
+            user=user,
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def update_feed_members(
+        self,
+        operation: str,
+        limit: Optional[int] = None,
+        next: Optional[str] = None,
+        prev: Optional[str] = None,
+        members: Optional[List[FeedMemberRequest]] = None,
+    ) -> StreamResponse[UpdateFeedMembersResponse]:
+        response = self.client.update_feed_members(
+            feed_group_id=self.feed_group,
+            feed_id=self.id,
+            operation=operation,
+            limit=limit,
+            next=next,
+            prev=prev,
+            members=members,
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def accept_feed_member_invite(
+        self, user_id: Optional[str] = None, user: Optional[UserRequest] = None
+    ) -> StreamResponse[AcceptFeedMemberInviteResponse]:
+        response = self.client.accept_feed_member_invite(
+            feed_group_id=self.feed_group, feed_id=self.id, user_id=user_id, user=user
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def query_feed_members(
+        self,
+        limit: Optional[int] = None,
+        next: Optional[str] = None,
+        prev: Optional[str] = None,
+        sort: Optional[List[SortParamRequest]] = None,
+        filter: Optional[Dict[str, object]] = None,
+    ) -> StreamResponse[QueryFeedMembersResponse]:
+        response = self.client.query_feed_members(
+            feed_group_id=self.feed_group,
+            feed_id=self.id,
+            limit=limit,
+            next=next,
+            prev=prev,
+            sort=sort,
+            filter=filter,
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def reject_feed_member_invite(
+        self, user_id: Optional[str] = None, user: Optional[UserRequest] = None
+    ) -> StreamResponse[RejectFeedMemberInviteResponse]:
+        response = self.client.reject_feed_member_invite(
+            feed_group_id=self.feed_group, feed_id=self.id, user_id=user_id, user=user
+        )
+        self._sync_from_response(response.data)
+        return response
+
+    def get_feed_identifier(self):
+        return self.feed_group + ":" + self.id
+
+    create = get_or_create