Merge pull request #29 from GetStream/cha-1578_openapi-refactor-codegen

[CHA-1578] refactor: code generated from openapi specs

Author: mogita

lib/getstream_ruby/generated/feed.rb

@@ -122,6 +122,16 @@ def reject_feed_member_invite(reject_feed_member_invite_request)
         @client.feeds.reject_feed_member_invite(@feed_group_id, @feed_id, reject_feed_member_invite_request)
       end
 
+      # Query pinned activities for a feed with filter query
+      #
+      # @param query_pinned_activities_request [QueryPinnedActivitiesRequest]
+      # @return [Models::QueryPinnedActivitiesResponse]
+      def query_pinned_activities(query_pinned_activities_request)
+
+        # Delegate to the FeedsClient
+        @client.feeds.query_pinned_activities(@feed_group_id, @feed_id, query_pinned_activities_request)
+      end
+
     end
   end
 end

lib/getstream_ruby/generated/feeds_client.rb

@@ -46,6 +46,23 @@ def upsert_activities(upsert_activities_request)
         )
       end
 
+      # Updates certain fields of multiple activities in a batch. Use 'set' to update specific fields and 'unset' to remove fields. Activities that fail due to not found, permission denied, or no changes detected are silently skipped and not included in the response. However, validation errors (e.g., updating reserved fields, invalid field values) will fail the entire batch request.Sends events:- feeds.activity.updated
+      #
+      # @param update_activities_partial_batch_request [UpdateActivitiesPartialBatchRequest]
+      # @return [Models::UpdateActivitiesPartialBatchResponse]
+      def update_activities_partial_batch(update_activities_partial_batch_request)
+        path = '/api/v2/feeds/activities/batch/partial'
+        # Build request body
+        body = update_activities_partial_batch_request
+
+        # Make the API request
+        @client.make_request(
+          :patch,
+          path,
+          body: body
+        )
+      end
+
       # Delete one or more activities by their IDs
       #
       # @param delete_activities_request [DeleteActivitiesRequest]
@@ -1036,6 +1053,28 @@ def reject_feed_member_invite(feed_group_id, feed_id, reject_feed_member_invite_
         )
       end
 
+      # Query pinned activities for a feed with filter query
+      #
+      # @param feed_group_id [String]
+      # @param feed_id [String]
+      # @param query_pinned_activities_request [QueryPinnedActivitiesRequest]
+      # @return [Models::QueryPinnedActivitiesResponse]
+      def query_pinned_activities(feed_group_id, feed_id, query_pinned_activities_request)
+        path = '/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/pinned_activities/query'
+        # Replace path parameters
+        path = path.gsub('{feed_group_id}', feed_group_id.to_s)
+        path = path.gsub('{feed_id}', feed_id.to_s)
+        # Build request body
+        body = query_pinned_activities_request
+
+        # Make the API request
+        @client.make_request(
+          :post,
+          path,
+          body: body
+        )
+      end
+
       # Get follow suggestions for a feed group
       #
       # @param feed_group_id [String]

lib/getstream_ruby/generated/models/activity_feedback_event_payload.rb

@@ -10,7 +10,7 @@ class ActivityFeedbackEventPayload < GetStream::BaseModel
 
         # Model attributes
         # @!attribute action
-        #   @return [String] The type of feedback action
+        #   @return [String] The type of feedback action. One of: hide, show_more, show_less
         attr_accessor :action
         # @!attribute activity_id
         #   @return [String] The activity that received feedback

lib/getstream_ruby/generated/models/activity_request.rb

@@ -15,6 +15,9 @@ class ActivityRequest < GetStream::BaseModel
         # @!attribute feeds
         #   @return [Array<String>] List of feeds to add the activity to with a default max limit of 25 feeds
         attr_accessor :feeds
+        # @!attribute copy_custom_to_notification
+        #   @return [Boolean] Whether to copy custom data to the notification activity (only applies when create_notification_activity is true)
+        attr_accessor :copy_custom_to_notification
         # @!attribute create_notification_activity
         #   @return [Boolean] Whether to create notification activities for mentioned users
         attr_accessor :create_notification_activity
@@ -31,7 +34,7 @@ class ActivityRequest < GetStream::BaseModel
         #   @return [String] ID of a poll to attach to activity
         attr_accessor :poll_id
         # @!attribute restrict_replies
-        #   @return [String] Controls who can add comments/replies to this activity. Options: 'everyone' (default - anyone can reply), 'people_i_follow' (only people the activity creator follows can reply), 'nobody' (no one can reply)
+        #   @return [String] Controls who can add comments/replies to this activity. One of: everyone, people_i_follow, nobody
         attr_accessor :restrict_replies
         # @!attribute skip_enrich_url
         #   @return [Boolean] Whether to skip URL enrichment for the activity
@@ -46,7 +49,7 @@ class ActivityRequest < GetStream::BaseModel
         #   @return [String] ID of the user creating the activity
         attr_accessor :user_id
         # @!attribute visibility
-        #   @return [String] Visibility setting for the activity
+        #   @return [String] Visibility setting for the activity. One of: public, private, tag
         attr_accessor :visibility
         # @!attribute visibility_tag
         #   @return [String] If visibility is 'tag', this is the tag name and is required
@@ -81,6 +84,7 @@ def initialize(attributes = {})
           super(attributes)
           @type = attributes[:type] || attributes['type']
           @feeds = attributes[:feeds] || attributes['feeds']
+          @copy_custom_to_notification = attributes[:copy_custom_to_notification] || attributes['copy_custom_to_notification'] || nil
           @create_notification_activity = attributes[:create_notification_activity] || attributes['create_notification_activity'] || nil
           @expires_at = attributes[:expires_at] || attributes['expires_at'] || nil
           @id = attributes[:id] || attributes['id'] || nil
@@ -108,6 +112,7 @@ def self.json_field_mappings
           {
             type: 'type',
             feeds: 'feeds',
+            copy_custom_to_notification: 'copy_custom_to_notification',
             create_notification_activity: 'create_notification_activity',
             expires_at: 'expires_at',
             id: 'id',

lib/getstream_ruby/generated/models/activity_response.rb

@@ -34,7 +34,7 @@ class ActivityResponse < GetStream::BaseModel
         #   @return [Integer] Number of reactions to the activity
         attr_accessor :reaction_count
         # @!attribute restrict_replies
-        #   @return [String] Controls who can reply to this activity. Values: everyone, people_i_follow, nobody
+        #   @return [String] Controls who can add comments/replies to this activity. One of: everyone, people_i_follow, nobody
         attr_accessor :restrict_replies
         # @!attribute score
         #   @return [Float] Ranking score for this activity
@@ -49,7 +49,7 @@ class ActivityResponse < GetStream::BaseModel
         #   @return [DateTime] When the activity was last updated
         attr_accessor :updated_at
         # @!attribute visibility
-        #   @return [String] Visibility setting for the activity
+        #   @return [String] Visibility setting for the activity. One of: public, private, tag
         attr_accessor :visibility
         # @!attribute attachments
         #   @return [Array<Attachment>] Media attachments for the activity
@@ -85,7 +85,7 @@ class ActivityResponse < GetStream::BaseModel
         #   @return [Object] Custom data for the activity
         attr_accessor :custom
         # @!attribute reaction_groups
-        #   @return [Hash<String, ReactionGroupResponse>] Grouped reactions by type
+        #   @return [Hash<String, FeedsReactionGroupResponse>] Grouped reactions by type
         attr_accessor :reaction_groups
         # @!attribute search_data
         #   @return [Object] Data for search indexing
@@ -102,6 +102,9 @@ class ActivityResponse < GetStream::BaseModel
         # @!attribute expires_at
         #   @return [DateTime] When the activity will expire
         attr_accessor :expires_at
+        # @!attribute friend_reaction_count
+        #   @return [Integer] Total count of reactions from friends on this activity
+        attr_accessor :friend_reaction_count
         # @!attribute is_watched
         #   @return [Boolean]
         attr_accessor :is_watched
@@ -117,6 +120,9 @@ class ActivityResponse < GetStream::BaseModel
         # @!attribute visibility_tag
         #   @return [String] If visibility is 'tag', this is the tag name
         attr_accessor :visibility_tag
+        # @!attribute friend_reactions
+        #   @return [Array<FeedsReactionResponse>] Reactions from users the current user follows or has mutual follows with
+        attr_accessor :friend_reactions
         # @!attribute current_feed
         #   @return [FeedResponse]
         attr_accessor :current_feed
@@ -170,11 +176,13 @@ def initialize(attributes = {})
           @deleted_at = attributes[:deleted_at] || attributes['deleted_at'] || nil
           @edited_at = attributes[:edited_at] || attributes['edited_at'] || nil
           @expires_at = attributes[:expires_at] || attributes['expires_at'] || nil
+          @friend_reaction_count = attributes[:friend_reaction_count] || attributes['friend_reaction_count'] || nil
           @is_watched = attributes[:is_watched] || attributes['is_watched'] || nil
           @moderation_action = attributes[:moderation_action] || attributes['moderation_action'] || nil
           @selector_source = attributes[:selector_source] || attributes['selector_source'] || nil
           @text = attributes[:text] || attributes['text'] || nil
           @visibility_tag = attributes[:visibility_tag] || attributes['visibility_tag'] || nil
+          @friend_reactions = attributes[:friend_reactions] || attributes['friend_reactions'] || nil
           @current_feed = attributes[:current_feed] || attributes['current_feed'] || nil
           @location = attributes[:location] || attributes['location'] || nil
           @moderation = attributes[:moderation] || attributes['moderation'] || nil
@@ -217,11 +225,13 @@ def self.json_field_mappings
             deleted_at: 'deleted_at',
             edited_at: 'edited_at',
             expires_at: 'expires_at',
+            friend_reaction_count: 'friend_reaction_count',
             is_watched: 'is_watched',
             moderation_action: 'moderation_action',
             selector_source: 'selector_source',
             text: 'text',
             visibility_tag: 'visibility_tag',
+            friend_reactions: 'friend_reactions',
             current_feed: 'current_feed',
             location: 'location',
             moderation: 'moderation',

lib/getstream_ruby/generated/models/activity_restored_event.rb

@@ -0,0 +1,66 @@
+# frozen_string_literal: true
+
+# Code generated by GetStream internal OpenAPI code generator. DO NOT EDIT.
+
+module GetStream
+  module Generated
+    module Models
+      # Emitted when an activity is restored.
+      class ActivityRestoredEvent < GetStream::BaseModel
+
+        # Model attributes
+        # @!attribute created_at
+        #   @return [DateTime] Date/time of creation
+        attr_accessor :created_at
+        # @!attribute fid
+        #   @return [String]
+        attr_accessor :fid
+        # @!attribute activity
+        #   @return [ActivityResponse]
+        attr_accessor :activity
+        # @!attribute custom
+        #   @return [Object]
+        attr_accessor :custom
+        # @!attribute type
+        #   @return [String] The type of the event
+        attr_accessor :type
+        # @!attribute feed_visibility
+        #   @return [String]
+        attr_accessor :feed_visibility
+        # @!attribute received_at
+        #   @return [DateTime]
+        attr_accessor :received_at
+        # @!attribute user
+        #   @return [UserResponseCommonFields]
+        attr_accessor :user
+
+        # Initialize with attributes
+        def initialize(attributes = {})
+          super(attributes)
+          @created_at = attributes[:created_at] || attributes['created_at']
+          @fid = attributes[:fid] || attributes['fid']
+          @activity = attributes[:activity] || attributes['activity']
+          @custom = attributes[:custom] || attributes['custom']
+          @type = attributes[:type] || attributes['type'] || "feeds.activity.restored"
+          @feed_visibility = attributes[:feed_visibility] || attributes['feed_visibility'] || nil
+          @received_at = attributes[:received_at] || attributes['received_at'] || nil
+          @user = attributes[:user] || attributes['user'] || nil
+        end
+
+        # Override field mappings for JSON serialization
+        def self.json_field_mappings
+          {
+            created_at: 'created_at',
+            fid: 'fid',
+            activity: 'activity',
+            custom: 'custom',
+            type: 'type',
+            feed_visibility: 'feed_visibility',
+            received_at: 'received_at',
+            user: 'user'
+          }
+        end
+      end
+    end
+  end
+end

lib/getstream_ruby/generated/models/activity_selector_config.rb

@@ -10,7 +10,7 @@ class ActivitySelectorConfig < GetStream::BaseModel
 
         # Model attributes
         # @!attribute type
-        #   @return [String] Type of selector
+        #   @return [String] Type of selector. One of: popular, proximity, following, current_feed, query, interest, follow_suggestion
         attr_accessor :type
         # @!attribute cutoff_time
         #   @return [String] Time threshold for activity selection (string). Expected RFC3339 format (e.g., 2006-01-02T15:04:05Z07:00). Cannot be used together with cutoff_window

lib/getstream_ruby/generated/models/add_activity_request.rb

@@ -15,6 +15,9 @@ class AddActivityRequest < GetStream::BaseModel
         # @!attribute feeds
         #   @return [Array<String>] List of feeds to add the activity to with a default max limit of 25 feeds
         attr_accessor :feeds
+        # @!attribute copy_custom_to_notification
+        #   @return [Boolean] Whether to copy custom data to the notification activity (only applies when create_notification_activity is true)
+        attr_accessor :copy_custom_to_notification
         # @!attribute create_notification_activity
         #   @return [Boolean] Whether to create notification activities for mentioned users
         attr_accessor :create_notification_activity
@@ -31,7 +34,7 @@ class AddActivityRequest < GetStream::BaseModel
         #   @return [String] ID of a poll to attach to activity
         attr_accessor :poll_id
         # @!attribute restrict_replies
-        #   @return [String] Controls who can add comments/replies to this activity. Options: 'everyone' (default - anyone can reply), 'people_i_follow' (only people the activity creator follows can reply), 'nobody' (no one can reply)
+        #   @return [String] Controls who can add comments/replies to this activity. One of: everyone, people_i_follow, nobody
         attr_accessor :restrict_replies
         # @!attribute skip_enrich_url
         #   @return [Boolean] Whether to skip URL enrichment for the activity
@@ -46,7 +49,7 @@ class AddActivityRequest < GetStream::BaseModel
         #   @return [String] ID of the user creating the activity
         attr_accessor :user_id
         # @!attribute visibility
-        #   @return [String] Visibility setting for the activity
+        #   @return [String] Visibility setting for the activity. One of: public, private, tag
         attr_accessor :visibility
         # @!attribute visibility_tag
         #   @return [String] If visibility is 'tag', this is the tag name and is required
@@ -81,6 +84,7 @@ def initialize(attributes = {})
           super(attributes)
           @type = attributes[:type] || attributes['type']
           @feeds = attributes[:feeds] || attributes['feeds']
+          @copy_custom_to_notification = attributes[:copy_custom_to_notification] || attributes['copy_custom_to_notification'] || nil
           @create_notification_activity = attributes[:create_notification_activity] || attributes['create_notification_activity'] || nil
           @expires_at = attributes[:expires_at] || attributes['expires_at'] || nil
           @id = attributes[:id] || attributes['id'] || nil
@@ -108,6 +112,7 @@ def self.json_field_mappings
           {
             type: 'type',
             feeds: 'feeds',
+            copy_custom_to_notification: 'copy_custom_to_notification',
             create_notification_activity: 'create_notification_activity',
             expires_at: 'expires_at',
             id: 'id',

lib/getstream_ruby/generated/models/add_comment_reaction_request.rb

@@ -12,6 +12,9 @@ class AddCommentReactionRequest < GetStream::BaseModel
         # @!attribute type
         #   @return [String] The type of reaction, eg upvote, like, ...
         attr_accessor :type
+        # @!attribute copy_custom_to_notification
+        #   @return [Boolean] Whether to copy custom data to the notification activity (only applies when create_notification_activity is true)
+        attr_accessor :copy_custom_to_notification
         # @!attribute create_notification_activity
         #   @return [Boolean] Whether to create a notification activity for this reaction
         attr_accessor :create_notification_activity
@@ -35,6 +38,7 @@ class AddCommentReactionRequest < GetStream::BaseModel
         def initialize(attributes = {})
           super(attributes)
           @type = attributes[:type] || attributes['type']
+          @copy_custom_to_notification = attributes[:copy_custom_to_notification] || attributes['copy_custom_to_notification'] || nil
           @create_notification_activity = attributes[:create_notification_activity] || attributes['create_notification_activity'] || nil
           @enforce_unique = attributes[:enforce_unique] || attributes['enforce_unique'] || nil
           @skip_push = attributes[:skip_push] || attributes['skip_push'] || nil
@@ -47,6 +51,7 @@ def initialize(attributes = {})
         def self.json_field_mappings
           {
             type: 'type',
+            copy_custom_to_notification: 'copy_custom_to_notification',
             create_notification_activity: 'create_notification_activity',
             enforce_unique: 'enforce_unique',
             skip_push: 'skip_push',

lib/getstream_ruby/generated/models/add_comment_request.rb

@@ -12,6 +12,9 @@ class AddCommentRequest < GetStream::BaseModel
         # @!attribute comment
         #   @return [String] Text content of the comment
         attr_accessor :comment
+        # @!attribute copy_custom_to_notification
+        #   @return [Boolean] Whether to copy custom data to the notification activity (only applies when create_notification_activity is true)
+        attr_accessor :copy_custom_to_notification
         # @!attribute create_notification_activity
         #   @return [Boolean] Whether to create a notification activity for this comment
         attr_accessor :create_notification_activity
@@ -53,6 +56,7 @@ class AddCommentRequest < GetStream::BaseModel
         def initialize(attributes = {})
           super(attributes)
           @comment = attributes[:comment] || attributes['comment'] || nil
+          @copy_custom_to_notification = attributes[:copy_custom_to_notification] || attributes['copy_custom_to_notification'] || nil
           @create_notification_activity = attributes[:create_notification_activity] || attributes['create_notification_activity'] || nil
           @id = attributes[:id] || attributes['id'] || nil
           @object_id = attributes[:object_id] || attributes['object_id'] || nil
@@ -71,6 +75,7 @@ def initialize(attributes = {})
         def self.json_field_mappings
           {
             comment: 'comment',
+            copy_custom_to_notification: 'copy_custom_to_notification',
             create_notification_activity: 'create_notification_activity',
             id: 'id',
             object_id: 'object_id',