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