Sha256: 98bf83c7a5be649063fc0f65e75cc63b92fb73d2cb0cb04fd0dc3b72bd7c7b4f

Contents?: true

Size: 1.55 KB

Versions: 142

Compression:

Stored size: 1.55 KB

Contents

# frozen_string_literal: true

module SplitIoClient
  module Cache
    module Repositories
      module Impressions
        class RedisRepository < ImpressionsRepository
          EXPIRE_SECONDS = 3600

          def initialize(config)
            @config = config
            @adapter = @config.impressions_adapter
          end

          def add_bulk(impressions)
            impressions_json = impressions.map do |impression|
              impression.to_json
            end

            impressions_list_size = @adapter.add_to_queue(key, impressions_json)

            # Synchronizer might not be running
            @adapter.expire(key, EXPIRE_SECONDS) if impressions_json.size == impressions_list_size
            0
          rescue StandardError => e
            @config.logger.error("Exception while add_bulk: #{e}")
            0
          end

          def get_impressions(number_of_impressions = 0)
            @adapter.get_from_queue(key, number_of_impressions).map do |e|
              impression = JSON.parse(e, symbolize_names: true)
              impression[:i][:f] = impression[:i][:f].to_sym
              impression
            end
          rescue StandardError => e
            @config.logger.error("Exception while clearing impressions cache: #{e}")
            []
          end

          def batch
            get_impressions(@config.impressions_bulk_size)
          end

          def clear
            get_impressions
          end

          def key
            @key ||= namespace_key('.impressions')
          end
        end
      end
    end
  end
end

Version data entries

142 entries across 142 versions & 1 rubygems

Version Path
splitclient-rb-8.5.0-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.5.0 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.5.0.pre.rc1-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.5.0.pre.rc1 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.4.1.pre.rc1-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.4.1.pre.rc1 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.4.0-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.4.0 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.4.0.pre.rc1-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.4.0.pre.rc1 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.4.0.rc.1-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.4.0.rc.1 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.3.2.pre.rc2-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.3.2.pre.rc2 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.3.2.pre.rc1-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.3.2.pre.rc1 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.3.1-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.3.1 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.3.1.pre.rc1-java lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb
splitclient-rb-8.3.1.pre.rc1 lib/splitclient-rb/cache/repositories/impressions/redis_repository.rb