Merge pull request #453 from splitio/redis-unique-keys

Removed pipeline

Author: sanzmauro

lib/splitclient-rb/cache/senders/impressions_adapter/redis_sender.rb

@@ -12,13 +12,9 @@ def initialize(config)
         end
 
         def record_uniques_key(uniques)
-          return if uniques.nil? || uniques == {}
+          return if uniques.nil? || uniques.empty?
 
-          size = @adapter.redis.pipelined do |pipeline|
-            uniques.each do |key, value|
-              pipeline.rpush(unique_keys_key, { f: key, ks: value.to_a }.to_json)
-            end
-          end
+          size = @adapter.add_to_queue(unique_keys_key, uniques_formatter(uniques))
 
           @adapter.expire(unique_keys_key, EXPIRE_SECONDS) if uniques.length == size.last
         rescue StandardError => e
@@ -48,6 +44,18 @@ def expire_impressions_count_key(impressions_count, pipeline_result)
           @adapter.expire(impressions_count_key, EXPIRE_SECONDS) if impressions_count.size == hlen && (pipeline_result.sum - hlen) == total_count
         end
 
+        def uniques_formatter(uniques)
+          to_return = []
+          uniques.each do |key, value|
+            to_return << {
+              f: key,
+              ks: value.to_a
+            }.to_json
+          end
+
+          to_return
+        end
+
         def impressions_count_key
           "#{@config.redis_namespace}.impressions.count"
         end