Add query members (#33)

Author: ferhatelmas

lib/stream-chat/channel.rb

@@ -1,12 +1,14 @@
 # frozen_string_literal: true
 
 require 'stream-chat/errors'
+require 'stream-chat/util'
 
 module StreamChat
   class Channel # rubocop:todo Metrics/ClassLength # rubocop:todo Style/Documentation
     attr_reader :id
     attr_reader :channel_type
     attr_reader :custom_data
+    attr_reader :members
 
     def initialize(client, channel_type, channel_id = nil, custom_data = nil)
       @channel_type = channel_type
@@ -59,6 +61,24 @@ def query(**options)
       state
     end
 
+    def query_members(filter_conditions: {}, sort: nil, **options)
+      params = {}.merge(options).merge({
+                                         id: @id,
+                                         type: @channel_type,
+                                         filter_conditions: filter_conditions,
+                                         sort: get_sort_fields(sort)
+                                       })
+
+      if @id == '' && @members.length.positive?
+        params['members'] = []
+        @members&.each do |m|
+          params['members'] << m['user'].nil? ? m['user_id'] : m['user']['id']
+        end
+      end
+
+      @client.get('members', params: { payload: params.to_json })
+    end
+
     def update(channel_data, update_message = nil)
       payload = { "data": channel_data, "message": update_message }
       @client.post(url, data: payload)

lib/stream-chat/util.rb

@@ -0,0 +1,11 @@
+# frozen_string_literal: true
+
+# lib/util.rb
+
+def get_sort_fields(sort)
+  sort_fields = []
+  sort&.each do |k, v|
+    sort_fields << { field: k, direction: v }
+  end
+  sort_fields
+end

spec/channel_spec.rb

@@ -9,7 +9,7 @@
   end
 
   before(:each) do
-    @random_users = [{ id: SecureRandom.uuid }, { id: SecureRandom.uuid }]
+    @random_users = [{ id: SecureRandom.uuid, name: 'b' }, { id: SecureRandom.uuid, name: 'a' }]
     @client.update_users(@random_users)
 
     @random_user = { id: SecureRandom.uuid }
@@ -57,7 +57,7 @@
     expect(response['channel']['motd']).to eq 'one apple a day...'
   end
 
-  it 'can delete ' do
+  it 'can delete' do
     response = @channel.delete
     expect(response).to include 'channel'
     expect(response['channel'].fetch('deleted_at')).not_to eq nil
@@ -159,4 +159,27 @@
   it 'delete image' do
     @channel.delete_image(image)
   end
+
+  it 'query members' do
+    response = @channel.query_members
+    expect(response['members'].length).to eq 0
+
+    members = []
+    @random_users&.each do |u|
+      members << u[:id]
+    end
+    @channel.add_members(members)
+
+    response = @channel.query_members(sort: { name: 1 })
+    expect(response['members'].length).to eq 2
+
+    got_members = []
+    response['members']&.each do |m|
+      got_members << m['user']['id']
+    end
+    expect(got_members).to eq members.reverse
+
+    response = @channel.query_members(limit: 1)
+    expect(response['members'].length).to eq 1
+  end
 end