Sha256: 3c23cdc4d78f6d603e5178dafdfe89a4173cf38d73e885cbd2dc9bc92d2e4618
Contents?: true
Size: 1.81 KB
Versions: 10
Compression:
Stored size: 1.81 KB
Contents
# frozen_string_literal: true
module SplitIoClient
module Engine
class PushManager
def initialize(config, sse_handler, api_key)
@config = config
@sse_handler = sse_handler
@auth_api_client = AuthApiClient.new(@config)
@api_key = api_key
@back_off = SplitIoClient::SSE::EventSource::BackOff.new(@config.auth_retry_back_off_base, 1)
end
def start_sse
response = @auth_api_client.authenticate(@api_key)
@config.logger.debug("Auth service response push_enabled: #{response[:push_enabled]}") if @config.debug_enabled
if response[:push_enabled] && @sse_handler.start(response[:token], response[:channels])
schedule_next_token_refresh(response[:exp])
@back_off.reset
return
end
stop_sse
schedule_next_token_refresh(@back_off.interval) if response[:retry]
rescue StandardError => e
@config.logger.error("start_sse: #{e.inspect}")
end
def stop_sse
@sse_handler.process_disconnect if @sse_handler.sse_client.nil?
@sse_handler.stop
SplitIoClient::Helpers::ThreadHelper.stop(:schedule_next_token_refresh, @config)
end
private
def schedule_next_token_refresh(time)
@config.threads[:schedule_next_token_refresh] = Thread.new do
begin
@config.logger.debug("schedule_next_token_refresh refresh in #{time} seconds.") if @config.debug_enabled
sleep(time)
@config.logger.debug('schedule_next_token_refresh starting ...') if @config.debug_enabled
@sse_handler.stop
start_sse
rescue StandardError => e
@config.logger.debug("schedule_next_token_refresh error: #{e.inspect}") if @config.debug_enabled
end
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems