# frozen_string_literal: true

require 'snowplow-tracker'

module Gitlab
  module Tracking
    module Destinations
      class Snowplow < Base
        extend ::Gitlab::Utils::Override

        override :event
        def event(category, action, label: nil, property: nil, value: nil, context: nil)
          return unless enabled?

          tracker.track_struct_event(category, action, label, property, value, context, (Time.now.to_f * 1000).to_i)
        end

        def self_describing_event(schema_url, event_data_json, context: nil)
          return unless enabled?

          event_json = SnowplowTracker::SelfDescribingJson.new(schema_url, event_data_json)
          tracker.track_self_describing_event(event_json, context, (Time.now.to_f * 1000).to_i)
        end

        private

        def enabled?
          Gitlab::CurrentSettings.snowplow_enabled?
        end

        def tracker
          @tracker ||= SnowplowTracker::Tracker.new(
            emitter,
            SnowplowTracker::Subject.new,
            Gitlab::Tracking::SNOWPLOW_NAMESPACE,
            Gitlab::CurrentSettings.snowplow_app_id
          )
        end

        def emitter
          SnowplowTracker::AsyncEmitter.new(
            Gitlab::CurrentSettings.snowplow_collector_hostname,
            protocol: 'https'
          )
        end
      end
    end
  end
end