# Copyright (c) 2022 Contrast Security, Inc. See https://www.contrastsecurity.com/enduser-terms-0317a for more details.
# frozen_string_literal: true

require 'contrast/agent/worker_thread'
require 'contrast/agent/reporting/report'

module Contrast
  module Agent
    # The ServiceHeartbeat functions to keep the Contrast Service alive and ensure that it maintains this Agent's
    # ApplicationContext.
    class ServiceHeartbeat < WorkerThread
      # Spec recommends 30 seconds, we're going with 15.
      REFRESH_INTERVAL_SEC = 15

      def start_thread!
        return if ::Contrast::CONTRAST_SERVICE.unnecessary?
        return if running?

        @_thread = Contrast::Agent::Thread.new do
          logger.info('Starting heartbeat thread.')
          loop do
            logger.info("Queue Size: #{ Contrast::Agent.messaging_queue.queue&.length }")
            Contrast::Agent.messaging_queue&.send_event_eventually(poll_message)
            clean_properties
            sleep(REFRESH_INTERVAL_SEC)
          end
        end
      end

      def poll_message
        @_poll_message ||= Contrast::Api::Dtm::Poll.new
      end
    end
  end
end