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

Version Path
splitclient-rb-6.4.1-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.1 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.1.pre.rc3-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.1.pre.rc3 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.1.pre.rc2-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.1.pre.rc2 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.1.pre.rc1-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.1.pre.rc1 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.0-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.0 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.0.pre.rc1-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.4.0.pre.rc1 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.3.0-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.3.0 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.3.0.pre.rc1-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.3.0.pre.rc1 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.2.0-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.2.0 lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.2.0.pre.rc2-java lib/splitclient-rb/engine/api/events.rb
splitclient-rb-6.2.0.pre.rc2 lib/splitclient-rb/engine/api/events.rb