merge "master" into 'feature/snooze_message_reminder'

Author: nijeesh-stream

.github/CODEOWNERS

@@ -1 +1 @@
-* @totalimmersion @akupila @guerinoni @JimmyPettersson85 @shaljam @vishalnarkhede
+* @totalimmersion @akupila @guerinoni @JimmyPettersson85 @shaljam @vishalnarkhede @nijeesh-stream

.rubocop.yml

@@ -35,3 +35,5 @@ Style/FrozenStringLiteralComment:
 
 Gemspec/RequireMFA:
   Enabled: false
+Naming/PredicateMethod:
+  Enabled: false

CHANGELOG.md

@@ -2,6 +2,30 @@
 
 All notable changes to this project will be documented in this file. See [standard-version](https://github.com/conventional-changelog/standard-version) for commit guidelines.
 
+## [3.15.0](https://github.com/GetStream/stream-chat-ruby/compare/v3.14.0...v3.15.0) (2025-06-06)
+
+## [3.14.0](https://github.com/GetStream/stream-chat-ruby/compare/v3.13.0...v3.14.0) (2025-04-07)
+
+## [3.13.0](https://github.com/GetStream/stream-chat-ruby/compare/v3.12.0...v3.13.0) (2025-04-04)
+
+
+### Features
+
+*  deactivate users ([#162](https://github.com/GetStream/stream-chat-ruby/issues/162)) ([12bf4d1](https://github.com/GetStream/stream-chat-ruby/commit/12bf4d19846b5100f1886929b74c7ad05d753be4))
+*  draft messages ([#161](https://github.com/GetStream/stream-chat-ruby/pull/161)) ([1719104](https://github.com/GetStream/stream-chat-ruby/commit/c7bccb3ad30721a20f32fd60eb13ab6d97a08208))
+
+### Other
+
+* added nijeesh to code owners ([#156](https://github.com/GetStream/stream-chat-ruby/issues/156)) ([7cd4e54](https://github.com/GetStream/stream-chat-ruby/commit/7cd4e5443a8f283596b8eadc873030d737cd621c))
+* **release:** v3.12.0 ([#157](https://github.com/GetStream/stream-chat-ruby/issues/157)) ([993b7a3](https://github.com/GetStream/stream-chat-ruby/commit/993b7a30bd2222ee328ca7a862384c7baf7d53e1))
+
+## [3.11.0](https://github.com/GetStream/stream-chat-ruby/compare/v3.9.0...v3.11.0) (2025-03-21)
+
+
+### Other
+
+* **release:** 3.10.0 ([#151](https://github.com/GetStream/stream-chat-ruby/issues/151)) ([ac11fc1](https://github.com/GetStream/stream-chat-ruby/commit/ac11fc122ec97ffd1b2bce820efe55925e96277f))
+
 ## [Unreleased]
 
 ### Features

lib/stream-chat/channel.rb

@@ -360,6 +360,41 @@ def delete_image(url)
       @client.delete("#{self.url}/image", params: { url: url })
     end
 
+    # Creates or updates a draft message for this channel.
+    #
+    # @param [StringKeyHash] message The draft message content
+    # @param [String] user_id The ID of the user creating/updating the draft
+    # @return [StreamChat::StreamResponse]
+    sig { params(message: StringKeyHash, user_id: String).returns(StreamChat::StreamResponse) }
+    def create_draft(message, user_id)
+      payload = { message: add_user_id(message, user_id) }
+      @client.post("#{url}/draft", data: payload)
+    end
+
+    # Deletes a draft message for this channel.
+    #
+    # @param [String] user_id The ID of the user deleting the draft
+    # @param [String] parent_id Optional parent message ID for thread drafts
+    # @return [StreamChat::StreamResponse]
+    sig { params(user_id: String, parent_id: T.nilable(String)).returns(StreamChat::StreamResponse) }
+    def delete_draft(user_id, parent_id: nil)
+      params = { user_id: user_id }
+      params[:parent_id] = parent_id if parent_id
+      @client.delete("#{url}/draft", params: params)
+    end
+
+    # Gets a draft message for this channel.
+    #
+    # @param [String] user_id The ID of the user getting the draft
+    # @param [String] parent_id Optional parent message ID for thread drafts
+    # @return [StreamChat::StreamResponse]
+    sig { params(user_id: String, parent_id: T.nilable(String)).returns(StreamChat::StreamResponse) }
+    def get_draft(user_id, parent_id: nil)
+      params = { user_id: user_id }
+      params[:parent_id] = parent_id if parent_id
+      @client.get("#{url}/draft", params: params)
+    end
+
     private
 
     sig { params(payload: StringKeyHash, user_id: String).returns(StringKeyHash) }

lib/stream-chat/client.rb

@@ -15,6 +15,7 @@
 require 'stream-chat/version'
 require 'stream-chat/util'
 require 'stream-chat/types'
+require 'stream-chat/moderation'
 
 module StreamChat
   DEFAULT_BLOCKLIST = 'profanity_en_2020_v1'
@@ -36,6 +37,9 @@ class Client
     sig { returns(Faraday::Connection) }
     attr_reader :conn
 
+    sig { returns(Moderation) }
+    attr_reader :moderation
+
     # initializes a Stream Chat API Client
     #
     # @param [string] api_key your application api_key
@@ -65,6 +69,7 @@ def initialize(api_key, api_secret, timeout = nil, **options)
         end
       end
       @conn = T.let(conn, Faraday::Connection)
+      @moderation = T.let(Moderation.new(self), Moderation)
     end
 
     # initializes a Stream Chat API Client from STREAM_KEY and STREAM_SECRET
@@ -178,9 +183,9 @@ def review_flag_report(report_id, review_result, user_id, **details)
     end
 
     # Returns a message.
-    sig { params(id: String).returns(StreamChat::StreamResponse) }
-    def get_message(id)
-      get("messages/#{id}")
+    sig { params(id: String, options: T.untyped).returns(StreamChat::StreamResponse) }
+    def get_message(id, **options)
+      get("messages/#{id}", params: options)
     end
 
     # Searches for messages.
@@ -276,6 +281,14 @@ def deactivate_user(user_id, **options)
       post("users/#{user_id}/deactivate", params: options)
     end
 
+    # Deactivates a users
+    sig { params(user_ids: T::Array[String], options: T.untyped).returns(StreamChat::StreamResponse) }
+    def deactivate_users(user_ids, **options)
+      raise ArgumentError, 'user_ids should not be empty' if user_ids.empty?
+
+      post('users/deactivate', data: { user_ids: user_ids, **options })
+    end
+
     # Reactivates a deactivated user. Use deactivate_user to deactivate a user.
     sig { params(user_id: String, options: T.untyped).returns(StreamChat::StreamResponse) }
     def reactivate_user(user_id, **options)
@@ -779,6 +792,22 @@ def create_command(command)
       post('commands', data: command)
     end
 
+    # Queries draft messages for the current user.
+    #
+    # @param [String] user_id The ID of the user to query drafts for
+    # @param [StringKeyHash] filter Optional filter conditions for the query
+    # @param [Array] sort Optional sort parameters
+    # @param [Hash] options Additional query options
+    # @return [StreamChat::StreamResponse]
+    sig { params(user_id: String, filter: T.nilable(StringKeyHash), sort: T.nilable(T::Array[StringKeyHash]), options: T.untyped).returns(StreamChat::StreamResponse) }
+    def query_drafts(user_id, filter: nil, sort: nil, **options)
+      data = { user_id: user_id }
+      data['filter'] = filter if filter
+      data['sort'] = sort if sort
+      data.merge!(options) if options
+      post('drafts/query', data: data)
+    end
+
     # Gets a comamnd.
     sig { params(name: String).returns(StreamChat::StreamResponse) }
     def get_command(name)
@@ -901,6 +930,16 @@ def list_imports(options)
       get('imports', params: options)
     end
 
+    sig { params(filter: StringKeyHash, sort: T.nilable(T::Hash[String, Integer]), options: T.untyped).returns(StreamChat::StreamResponse) }
+    def query_threads(filter, sort: nil, **options)
+      params = {}.merge(options).merge({
+                                         filter: filter,
+                                         sort: StreamChat.get_sort_fields(sort)
+                                       })
+
+      post('threads', data: params)
+    end
+
     # Creates a reminder for a message.
     # @param message_id [String] The ID of the message to create a reminder for
     # @param user_id [String] The ID of the user creating the reminder