fix: use monkey patch instead of calling Object#send and Object#instance_variable_get (#170)

Author: supercaracal

Rakefile

@@ -1,6 +1,9 @@
 # frozen_string_literal: true
 
 require 'rake/testtask'
+require 'rubocop/rake_task'
+
+RuboCop::RakeTask.new
 
 SLUGGISH_TEST_TYPES = %w[broken scale state].freeze
 

lib/redis_client/cluster/node/latency_replica.rb

@@ -48,7 +48,7 @@ def measure_latencies(clients) # rubocop:disable Metrics/AbcSize
                 min = DUMMY_LATENCY_NSEC
                 MEASURE_ATTEMPT_COUNT.times do
                   starting = Process.clock_gettime(Process::CLOCK_MONOTONIC, :microsecond)
-                  client.send(:call_once, 'PING')
+                  client.call_once('PING')
                   duration = Process.clock_gettime(Process::CLOCK_MONOTONIC, :microsecond) - starting
                   min = duration if duration < min
                 end

lib/redis_client/cluster/pipeline.rb

@@ -81,6 +81,14 @@ def call_pipelined_aware_of_redirection(commands, timeouts) # rubocop:disable Me
         end
       end
 
+      ::RedisClient.class_eval do
+        attr_reader :middlewares
+
+        def ensure_connected_cluster_scoped(retryable: true, &block)
+          ensure_connected(retryable: retryable, &block)
+        end
+      end
+
       ReplySizeError = Class.new(::RedisClient::Error)
 
       class RedirectionNeeded < ::RedisClient::Error
@@ -198,9 +206,9 @@ def do_pipelining(client, pipeline)
       end
 
       def send_pipeline(client, pipeline)
-        results = client.send(:ensure_connected, retryable: pipeline._retryable?) do |connection|
+        results = client.ensure_connected_cluster_scoped(retryable: pipeline._retryable?) do |connection|
           commands = pipeline._commands
-          client.instance_variable_get(:@middlewares).call_pipelined(commands, client.config) do
+          client.middlewares.call_pipelined(commands, client.config) do
             connection.call_pipelined_aware_of_redirection(commands, pipeline._timeouts)
           end
         end