Sha256: 476c31358662625415a43fc8a1a983b539de0401e13d31687c2fb7a8a7178c05
Contents?: true
Size: 1.64 KB
Versions: 10
Compression:
Stored size: 1.64 KB
Contents
# frozen_string_literal: true
module SplitIoClient
module Cache
module Senders
class EventsSender
def initialize(events_repository, api_key)
@events_repository = events_repository
@api_key = api_key
end
def call
if ENV['SPLITCLIENT_ENV'] == 'test'
post_events
else
events_thread
if defined?(PhusionPassenger)
PhusionPassenger.on_event(:starting_worker_process) do |forked|
events_thread if forked
end
end
end
end
private
def events_thread
SplitIoClient.configuration.threads[:events_sender] = Thread.new do
begin
SplitIoClient.configuration.logger.info('Starting events service')
loop do
post_events(false)
sleep(SplitIoClient::Utilities.randomize_interval(SplitIoClient.configuration.events_push_rate))
end
rescue SplitIoClient::SDKShutdownException
post_events
SplitIoClient.configuration.logger.info('Posting events due to shutdown')
end
end
end
def post_events(fetch_all_events = true)
events = fetch_all_events ? @events_repository.clear : @events_repository.batch
events_api.post(events)
rescue StandardError => error
SplitIoClient.configuration.log_found_exception(__method__.to_s, error)
end
def events_api
@events_api ||= SplitIoClient::Api::Events.new(@api_key)
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems