Make call query threads directly

Author: adityaalifn

lib/stream-chat/client.rb

@@ -15,7 +15,6 @@
 require 'stream-chat/util'
 require 'stream-chat/types'
 require 'stream-chat/moderation'
-require 'stream-chat/thread'
 
 module StreamChat
   DEFAULT_BLOCKLIST = 'profanity_en_2020_v1'
@@ -40,9 +39,6 @@ class Client
     sig { returns(Moderation) }
     attr_reader :moderation
 
-    sig { returns(Thread) }
-    attr_reader :thread
-
     # initializes a Stream Chat API Client
     #
     # @param [string] api_key your application api_key
@@ -73,7 +69,6 @@ def initialize(api_key, api_secret, timeout = nil, **options)
       end
       @conn = T.let(conn, Faraday::Connection)
       @moderation = T.let(Moderation.new(self), Moderation)
-      @thread = T.let(Thread.new(self), Thread)
     end
 
     # initializes a Stream Chat API Client from STREAM_KEY and STREAM_SECRET
@@ -935,8 +930,13 @@ def list_imports(options)
     end
 
     sig { params(filter: StringKeyHash, sort: T.nilable(T::Hash[String, Integer]), options: T.untyped).returns(StreamChat::StreamResponse) }
-    def query_threads(filter, sort, **options)
-      @thread.query_threads(filter, sort: sort, **options)
+    def query_threads(filter, sort: nil, **options)
+      params = {}.merge(options).merge({
+                                         filter: filter,
+                                         sort: StreamChat.get_sort_fields(sort)
+                                       })
+
+      post('threads', data: params)
     end
 
     private

lib/stream-chat/thread.rb

@@ -966,4 +966,88 @@ def loop_times(times)
       end
     end
   end
+
+  describe '#query_threads' do
+    it 'queries threads with filter' do
+      # Create a channel and send a message to create a thread
+      channel = @client.channel('messaging', channel_id: SecureRandom.uuid, data: { test: true })
+      channel.create(@random_user[:id])
+
+      # Send a message to create a thread
+      message = channel.send_message({ text: 'Thread parent message' }, @random_user[:id])
+
+      # Send a reply to create a thread
+      channel.send_message({ text: 'Thread reply', parent_id: message['message']['id'] }, @random_user[:id])
+
+      # Query threads with filter
+      filter = {
+        'created_by_user_id' => { '$eq' => @random_user[:id] }
+      }
+
+      response = @client.query_threads(filter, user_id: @random_user[:id])
+
+      # Verify the response
+      expect(response).to include 'threads'
+      expect(response['threads'].length).to be >= 1
+
+      # Clean up
+      channel.delete
+    end
+
+    it 'queries threads with sort' do
+      # Create a channel and send a message to create a thread
+      channel = @client.channel('messaging', channel_id: SecureRandom.uuid, data: { test: true })
+      channel.create(@random_user[:id])
+
+      # Send a message to create a thread
+      message = channel.send_message({ text: 'Thread parent message' }, @random_user[:id])
+
+      # Send a reply to create a thread
+      channel.send_message({ text: 'Thread reply', parent_id: message['message']['id'] }, @random_user[:id])
+
+      # Query threads with sort
+      sort = {
+        'created_at' => -1
+      }
+
+      response = @client.query_threads(sort: sort, user_id: @random_user[:id])
+
+      # Verify the response
+      expect(response).to include 'threads'
+      expect(response['threads'].length).to be >= 1
+
+      # Clean up
+      channel.delete
+    end
+
+    it 'queries threads with both filter and sort' do
+      # Create a channel and send a message to create a thread
+      channel = @client.channel('messaging', channel_id: SecureRandom.uuid, data: { test: true })
+      channel.create(@random_user[:id])
+
+      # Send a message to create a thread
+      message = channel.send_message({ text: 'Thread parent message' }, @random_user[:id])
+
+      # Send a reply to create a thread
+      channel.send_message({ text: 'Thread reply', parent_id: message['message']['id'] }, @random_user[:id])
+
+      # Query threads with both filter and sort
+      filter = {
+        'created_by_user_id' => { '$eq' => @random_user[:id] }
+      }
+
+      sort = {
+        'created_at' => -1
+      }
+
+      response = @client.query_threads(filter, sort: sort, user_id: @random_user[:id])
+
+      # Verify the response
+      expect(response).to include 'threads'
+      expect(response['threads'].length).to be >= 1
+
+      # Clean up
+      channel.delete
+    end
+  end
 end