Sha256: 25a99b47c0bc594083285711ae3ab79dee22a7b4a98a5043c8a5dd1e9356a0af

Contents?: true

Size: 1.85 KB

Versions: 2

Compression:

Stored size: 1.85 KB

Contents

# 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'
require 'contrast/agent/inventory/dependency_usage_analysis'
require 'contrast/agent/reporting/reporting_events/poll'

module Contrast
  module Agent
    module ReportingWorkers
      # The ReporterHeartbeat will make sure that the process remains marked alive by TeamServer and that we
      # periodically reach out to get the latest settings for this application. It also sends out those
      # messages which do not need to be associated directly with a request,
      # such as Server Activity and Library Observation.
      class ReporterHeartbeat < WorkerThread
        # TeamServer will mark an application offline after 5 minutes. Sending this every one should be more than enough
        # to satisfy our goals.
        REFRESH_INTERVAL_SEC = 60

        def start_thread!
          return if running?

          @_thread = Contrast::Agent::Thread.new do
            logger.info('[Heartbeat] Starting thread.')
            loop do
              polling_events.each do |event|
                Contrast::Agent.reporter&.send_event(event)
              end
              clean_properties
              sleep(REFRESH_INTERVAL_SEC)
            end
          end
        end

        private

        def poll_message
          @_poll_message ||= Contrast::Agent::Reporting::Poll.new
        end

        # Those events which should be sent periodically, rather than on event or request.
        #
        # @return [Array<Contrast::Agent::Reporting::ReportingEvent>]
        def polling_events
          [Contrast::Agent::Inventory::DependencyUsageAnalysis.instance.generate_library_usage, poll_message].compact
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
contrast-agent-6.11.0 lib/contrast/agent/reporting/reporting_workers/reporter_heartbeat.rb
contrast-agent-6.10.0 lib/contrast/agent/reporting/reporting_workers/reporter_heartbeat.rb