Contents

module SplitIoClient
  module Cache
    module Stores
      class SegmentStore
        attr_reader :segments_repository

        def initialize(segments_repository, config, api_key, metrics, sdk_blocker = nil)
          @segments_repository = segments_repository
          @config = config
          @api_key = api_key
          @metrics = metrics
          @sdk_blocker = sdk_blocker
        end

        def call
          if ENV['SPLITCLIENT_ENV'] == 'test'
            store_segments
          else
            @sdk_blocker.segments_thread = Thread.new do
              @config.block_until_ready ? blocked_store : unblocked_store
            end
          end
        end

        private

        def blocked_store
          loop do
            next unless @sdk_blocker.splits_ready

            store_segments
            @config.logger.debug("Segment names: #{@segments_repository.used_segment_names.to_a}") if @config.debug_enabled

            unless @sdk_blocker.ready?
              @sdk_blocker.segments_ready!
              @config.logger.info('segments are ready')
            end

            sleep_for = random_interval(@config.segments_refresh_rate)
            @config.logger.debug("Segments store is sleeping for: #{sleep_for} seconds") if @config.debug_enabled
            sleep(sleep_for)
          end
        end

        def unblocked_store
          loop do
            store_segments

            sleep(random_interval(@config.segments_refresh_rate))
          end
        end

        def store_segments
          segments_api.store_segments_by_names(@segments_repository.used_segment_names)
        rescue StandardError => error
          @config.log_found_exception(__method__.to_s, error)
        end

        def random_interval(interval)
          random_factor = Random.new.rand(50..100) / 100.0

          interval * random_factor
        end

        def segments_api
          SplitIoClient::Api::Segments.new(@api_key, @config, @metrics, @segments_repository)
        end
      end
    end
  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version	Path
splitclient-rb-3.1.2	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.1	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc12	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc11	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc10	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc9	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc8	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc7	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc6	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc5	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc4	lib/cache/stores/segment_store.rb
splitclient-rb-3.1.0.pre.rc2	lib/cache/stores/segment_store.rb
splitclient-rb-3.0.3	lib/cache/stores/segment_store.rb
splitclient-rb-3.0.3.pre.rc2	lib/cache/stores/segment_store.rb
splitclient-rb-3.0.3.pre.rc1	lib/cache/stores/segment_store.rb
splitclient-rb-3.0.2	lib/cache/stores/segment_store.rb