Use redirection handling for pubsub/client/cluster/etc commands

These commands families were falling back to assign_node().public_send(),
but we actually want to invoke the redirection handling logic for them
like any other command.

Author: KJ Tsanaktsidis

lib/redis_client/cluster/router.rb

@@ -257,15 +257,15 @@ def send_config_command(method, command, args, &block)
         case ::RedisClient::Cluster::NormalizedCmdName.instance.get_by_subcommand(command)
         when 'resetstat', 'rewrite', 'set'
           @node.call_all(method, command, args).first.then(&TSF.call(block))
-        else assign_node(command).public_send(method, *args, command, &block)
+        else try_send(assign_node(command), method, command, args, &block)
         end
       end
 
       def send_memory_command(method, command, args, &block)
         case ::RedisClient::Cluster::NormalizedCmdName.instance.get_by_subcommand(command)
         when 'stats' then @node.call_all(method, command, args, &block)
         when 'purge' then @node.call_all(method, command, args).first.then(&TSF.call(block))
-        else assign_node(command).public_send(method, *args, command, &block)
+        else try_send(assign_node(command), method, command, args, &block)
         end
       end
 
@@ -274,7 +274,7 @@ def send_client_command(method, command, args, &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)
+        else try_send(assign_node(command), method, command, args, &block)
         end
       end
 
@@ -287,8 +287,9 @@ def send_cluster_command(method, command, args, &block)
         when 'getkeysinslot'
           raise ArgumentError, command.join(' ') if command.size != 4
 
-          find_node(@node.find_node_key_of_replica(command[2])).public_send(method, *args, command, &block)
-        else assign_node(command).public_send(method, *args, command, &block)
+          node = find_node(@node.find_node_key_of_replica(command[2]))
+          try_send(node, method, command, args, &block)
+        else try_send(assign_node(command), method, command, args, &block)
         end
       end
 
@@ -300,7 +301,7 @@ def send_script_command(method, command, args, &block) # rubocop:disable Metrics
           @node.call_primaries(method, command, args).first.then(&TSF.call(block))
         when 'exists'
           @node.call_all(method, command, args).transpose.map { |arr| arr.any?(&:zero?) ? 0 : 1 }.then(&TSF.call(block))
-        else assign_node(command).public_send(method, *args, command, &block)
+        else try_send(assign_node(command), method, command, args, &block)
         end
       end
 
@@ -318,7 +319,7 @@ def send_pubsub_command(method, command, args, &block) # rubocop:disable Metrics
         when 'shardnumsub'
           @node.call_replicas(method, command, args).reject(&:empty?).map { |e| Hash[*e] }
                .reduce({}) { |a, e| a.merge(e) { |_, v1, v2| v1 + v2 } }.then(&TSF.call(block))
-        else assign_node(command).public_send(method, *args, command, &block)
+        else try_send(assign_node(command), method, command, args, &block)
         end
       end