# frozen_string_literal: true

class EventJob
  include Sidekiq::Worker

  COLUMN_NAMES = Event.column_names - ["id"]

  def perform(*args)
    Thread.current[:bq] ||= BufferQueue.new(max_batch_size: (ENV["MAX_BATCH_SIZE"] || 50).to_i, execution_interval: (ENV["EXECUTION_INTERVAL"] || 5).to_i) do |batch|
      puts "bulk insert #{batch.size} records"
      p batch
      result = Event.insert_all!(batch)
      p result
    end
    params, form, request = args

    if form
      events = form.split("\r\n").map { |x| URI.decode_www_form(x).to_h.merge(params) }
    else
      events = [params]
    end

    events.each do |event|
      tech_info = TechDetector.detect(request["user_agent"]).dup
      next if tech_info.delete(:is_bot)
      meta_path = request["path"].match(/\/(?<uuid>.*?)\/g\/collect/)
      site_uuid = meta_path["uuid"]
      next if site_uuid.nil?
      real_ip = request["x_forwarded_for"] || request["ip"]

      referrer_source = RefererSourceDetector.detect(event["dr"])
      traffic_info = TrafficDetector.detect(event)
      traffic_info[:request_params] = traffic_info[:request_params].to_json
      payload_parser = PayloadParser.new(event)

      result = {}
      result.merge!(traffic_info)
      result.merge!(tech_info)
      result.merge!({
        event_name: event["en"],
        session_id: event["sid"],
        client_id: event["cid"],
        user_id: event["uid"],
        started_at: Time.now,

        session_engagement: event["seg"] == "1",
        engagement_time: event["_et"],
        session_count: event["sct"],
        request_number: event["_s"],

        title: event["dt"],
        user_agent: request["user_agent"],
        ip: real_ip,
        referrer: event["dr"],
        referrer_source: referrer_source,
        screen_resolution: event["sr"],
        user_language: event["ul"],

        user_props: payload_parser.user_props.to_json,
        event_props: payload_parser.event_props.to_json
      })

      if event["_fv"] == "1"
        Thread.current[:bq].push result.merge(event_name: "first_visit")
      end

      if event["_ss"] == "1"
        Thread.current[:bq].push result.merge(event_name: "session_start")
      end

      if event["seg"] == "1"
        Thread.current[:bq].push result.merge(event_name: "user_engagement")
      end

      Thread.current[:bq].push result
    end
  end
end