fix: a bug for client list command (#197)

Author: supercaracal

lib/redis_client/cluster/router.rb

@@ -14,7 +14,7 @@ class Cluster
     class Router
       ZERO_CURSOR_FOR_SCAN = '0'
       METHODS_FOR_BLOCKING_CMD = %i[blocking_call_v blocking_call].freeze
-      TSF = ->(b, s) { b.nil? ? s : b.call(s) }.curry
+      TSF = ->(f, x) { f.nil? ? x : f.call(x) }.curry
 
       attr_reader :node
 
@@ -240,7 +240,7 @@ def send_memory_command(method, command, args, &block)
 
       def send_client_command(method, command, args, &block)
         case ::RedisClient::Cluster::NormalizedCmdName.instance.get_by_subcommand(command)
-        when 'list' then @node.call_all(method, command, args).flatten.then(&TSF.call(block))
+        when 'list' then @node.call_all(method, command, args, &block).flatten
         when 'pause', 'reply', 'setname'
           @node.call_all(method, command, args).first.then(&TSF.call(block))
         else assign_node(command).public_send(method, *args, command, &block)

test/redis_client/test_cluster.rb

@@ -241,7 +241,11 @@ def test_dedicated_commands # rubocop:disable Metrics/CyclomaticComplexity, Metr
           { command: %w[ROLE], is_a: Array },
           { command: %w[CONFIG RESETSTAT], want: 'OK' },
           { command: %w[CONFIG GET maxmemory], is_a: TEST_REDIS_MAJOR_VERSION < 6 ? Array : Hash },
-          { command: %w[CLIENT LIST], is_a: Array },
+          {
+            command: %w[CLIENT LIST],
+            blk: ->(r) { r.lines("\n", chomp: true).map(&:split).map { |e| Hash[e.map { |x| x.split('=') }] } },
+            is_a: Array
+          },
           { command: %w[CLIENT PAUSE 100], want: 'OK' },
           { command: %w[CLIENT INFO], is_a: String, supported_redis_version: 6 },
           { command: %w[CLUSTER SET-CONFIG-EPOCH 0], error: ::RedisClient::Cluster::OrchestrationCommandNotSupported },