Sha256: c358455642e9b1c15e412a2de2dc8735aa507fefaeb7e1f88ad6e971e85587dd
Contents?: true
Size: 1.42 KB
Versions: 28
Compression:
Stored size: 1.42 KB
Contents
# frozen_string_literal: true
module SplitIoClient
module Api
class Events < Client
def initialize(api_key)
@api_key = api_key
end
def post(events)
if events.empty?
SplitLogger.log_if_debug('No events to report')
return
end
events.each_slice(SplitIoClient.configuration.events_queue_size) do |events_slice|
response = post_api(
"#{SplitIoClient.configuration.events_uri}/events/bulk",
@api_key,
events_slice.map { |event| formatted_event(event[:e]) },
'SplitSDKMachineIP' => events_slice[0][:m][:i],
'SplitSDKMachineName' => events_slice[0][:m][:n],
'SplitSDKVersion' => events_slice[0][:m][:s]
)
if response.success?
SplitLogger.log_if_debug("Events reported: #{events_slice.size}")
else
SplitLogger.log_error("Unexpected status code while posting events: #{response.status}." \
' - Check your API key and base URI')
raise 'Split SDK failed to connect to backend to post events'
end
end
end
private
def formatted_event(event)
{
key: event[:key],
trafficTypeName: event[:trafficTypeName],
eventTypeId: event[:eventTypeId],
value: event[:value].to_f,
timestamp: event[:timestamp].to_i
}
end
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems