Sha256: 463b6ab6b014808cb24c908480eaafea2ccdb28f8cc91aa4d2137e521a4bb0f6

Contents?: true

Size: 1.96 KB

Versions: 22

Compression:

Stored size: 1.96 KB

Contents

# frozen_string_literal: true

module SplitIoClient
  module Cache
    module Senders
      class ImpressionsSender
        def initialize(impressions_repository, api_key)
          @impressions_repository = impressions_repository
          @api_key = api_key
        end

        def call
          if SplitIoClient.configuration.disable_impressions
            SplitIoClient.configuration.logger.info('Disabling impressions service by config')
            return
          end

          if ENV['SPLITCLIENT_ENV'] == 'test'
            post_impressions
          else
            impressions_thread

            if defined?(PhusionPassenger)
              PhusionPassenger.on_event(:starting_worker_process) do |forked|
                impressions_thread if forked
              end
            end
          end
        end

        private

        def impressions_thread
          SplitIoClient.configuration.threads[:impressions_sender] = Thread.new do
            begin
              SplitIoClient.configuration.logger.info('Starting impressions service')

              loop do
                post_impressions(false)

                sleep(SplitIoClient::Utilities.randomize_interval(SplitIoClient.configuration.impressions_refresh_rate))
              end
            rescue SplitIoClient::SDKShutdownException
              post_impressions

              SplitIoClient.configuration.logger.info('Posting impressions due to shutdown')
            end
          end
        end

        def post_impressions(fetch_all_impressions = true)
          formatted_impressions = ImpressionsFormatter.new(@impressions_repository)
            .call(fetch_all_impressions)

          impressions_api.post(formatted_impressions)
        rescue StandardError => error
          SplitIoClient.configuration.log_found_exception(__method__.to_s, error)
        end

        def impressions_api
          @impressions_api ||= SplitIoClient::Api::Impressions.new(@api_key)
        end
      end
    end
  end
end

Version data entries

22 entries across 22 versions & 1 rubygems

Version Path
splitclient-rb-6.4.1-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.1 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.1.pre.rc3-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.1.pre.rc3 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.1.pre.rc2-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.1.pre.rc2 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.1.pre.rc1-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.1.pre.rc1 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.0-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.0 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.0.pre.rc1-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.4.0.pre.rc1 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.3.0-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.3.0 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.3.0.pre.rc1-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.3.0.pre.rc1 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.2.0-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.2.0 lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.2.0.pre.rc2-java lib/splitclient-rb/cache/senders/impressions_sender.rb
splitclient-rb-6.2.0.pre.rc2 lib/splitclient-rb/cache/senders/impressions_sender.rb