merged "master" into "feature/snooze_message_reminder"

Author: nijeesh-stream

CHANGELOG.md

@@ -26,16 +26,6 @@ All notable changes to this project will be documented in this file. See [standa
 
 * **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
-
-* Added support for message reminders:
-  * `create_reminder`: Create a reminder for a message
-  * `update_reminder`: Update an existing reminder
-  * `delete_reminder`: Delete a reminder
-  * `query_reminders`: Query reminders with filtering options
-
 ## [3.10.0](https://github.com/GetStream/stream-chat-ruby/compare/v3.9.0...v3.10.0) (2025-02-24)
 
 ## [3.9.0](https://github.com/GetStream/stream-chat-ruby/compare/v3.7.0...v3.9.0) (2025-02-11)
@@ -360,4 +350,4 @@ before continuing with v3.0.0 of this library.
 - Added `client.search`
 - Added `client.update_users_partial`
 - Added `client.update_user_partial`
-- Added `client.reactivate_user`
+- Added `client.reactivate_user`

lib/stream-chat/client.rb

@@ -940,6 +940,16 @@ def query_threads(filter, sort: nil, **options)
       post('threads', data: params)
     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

spec/client_spec.rb

@@ -1021,6 +1021,66 @@ def loop_times(times)
     end
   end
 
+  describe '#query_threads' do
+    before(:all) do
+      # Create a dedicated random user for this block
+      @thread_test_user = { id: SecureRandom.uuid }
+      @client.upsert_users([@thread_test_user])
+
+      # Create a channel and send a message to create a thread
+      @thread_channel = @client.channel('messaging', channel_id: SecureRandom.uuid, data: { test: true })
+      @thread_channel.create(@thread_test_user[:id])
+
+      # Send a message to create a thread
+      @thread_message = @thread_channel.send_message({ text: 'Thread parent message' }, @thread_test_user[:id])
+
+      # Send a reply to create a thread
+      @thread_channel.send_message({ text: 'Thread reply', parent_id: @thread_message['message']['id'] }, @thread_test_user[:id])
+    end
+
+    after(:all) do
+      @thread_channel.delete
+      @client.delete_user(@thread_test_user[:id])
+    end
+
+    it 'queries threads with filter' do
+      filter = {
+        'created_by_user_id' => { '$eq' => @thread_test_user[:id] }
+      }
+
+      response = @client.query_threads(filter, user_id: @thread_test_user[:id])
+
+      expect(response).to include 'threads'
+      expect(response['threads'].length).to be >= 1
+    end
+
+    it 'queries threads with sort' do
+      sort = {
+        'created_at' => -1
+      }
+
+      response = @client.query_threads({}, sort: sort, user_id: @thread_test_user[:id])
+
+      expect(response).to include 'threads'
+      expect(response['threads'].length).to be >= 1
+    end
+
+    it 'queries threads with both filter and sort' do
+      filter = {
+        'created_by_user_id' => { '$eq' => @thread_test_user[:id] }
+      }
+
+      sort = {
+        'created_at' => -1
+      }
+
+      response = @client.query_threads(filter, sort: sort, user_id: @thread_test_user[:id])
+
+      expect(response).to include 'threads'
+      expect(response['threads'].length).to be >= 1
+    end
+  end
+
   describe 'reminders' do
     before do
       @client = StreamChat::Client.from_env