fix: use correct params

Author: javierdfm

lib/stream-chat/channel.rb

@@ -101,8 +101,15 @@ def query(**options)
     # Updates the channel's members attribute with fresh data.
     sig { returns(StreamChat::StreamResponse) }
     def refresh_state
-      state = query_members
-      @members = state['members'] if state['members']
+      url = "channels/#{@channel_type}/#{@id}/query"
+      state = @client.post(url, data: { state: true })
+
+      # Members can be at top level or inside channel object (like Go's updateChannel)
+      if state['members'] && !state['members'].empty?
+        @members = state['members']
+      elsif state['channel'] && state['channel']['members']
+        @members = state['channel']['members']
+      end
       state
     end
 

spec/channel_batch_updater_spec.rb

@@ -109,7 +109,7 @@ def wait_for_task(task_id, timeout_seconds: 120)
       response = @client.update_channels_batch(
         {
           operation: 'addMembers',
-          filter: { cid: { '$in' => [@channel1.cid, @channel2.cid] } },
+          filter: { cids: { '$in' => [@channel1.cid, @channel2.cid] } },
           members: [{ 'user_id' => @random_users[0][:id] }]
         }
       )
@@ -125,7 +125,7 @@ def wait_for_task(task_id, timeout_seconds: 120)
       member_ids = @random_users.map { |u| u[:id] }
       members = member_ids.map { |id| { 'user_id' => id } }
       response = updater.add_members(
-        { cid: { '$in' => [@channel1.cid, @channel2.cid] } },
+        { cids: { '$in' => [@channel1.cid, @channel2.cid] } },
         members
       )
 
@@ -186,7 +186,7 @@ def wait_for_task(task_id, timeout_seconds: 120)
       member_to_remove = members_to_add[0]
 
       response = updater.remove_members(
-        { cid: { '$in' => [@channel1.cid, @channel2.cid] } },
+        { cids: { '$in' => [@channel1.cid, @channel2.cid] } },
         [{ 'user_id' => member_to_remove }]
       )
 
@@ -233,7 +233,7 @@ def wait_for_task(task_id, timeout_seconds: 120)
       member_to_archive = members_to_add[0]
 
       response = updater.archive(
-        { cid: { '$in' => [@channel1.cid, @channel2.cid] } },
+        { cids: { '$in' => [@channel1.cid, @channel2.cid] } },
         [{ 'user_id' => member_to_archive }]
       )