Sha256: cb3fb40a7bea7e569acf664f65bc862536182962a077cacaf73dfb06cfd6785e

Contents?: true

Size: 1.66 KB

Versions: 7

Compression:

Stored size: 1.66 KB

Contents

module Katello
  module EventDaemon
    module Services
      class AgentEventReceiver
        STATUS_CACHE_KEY = 'katello_agent_events'.freeze

        class Handler
          attr_accessor :processed, :failed

          def initialize
            @processed = 0
            @failed = 0
          end

          def handle(message)
            ::Katello::Util::Support.with_db_connection do
              ::Katello::Agent::ClientMessageHandler.new(message).handle
              @processed += 1
            rescue => e
              @failed += 1
              Rails.logger.error("Error handling Katello Agent client message")
              Rails.logger.error(e.message)
              Rails.logger.error(e.backtrace.join("\n"))
            end
          end
        end

        def self.logger
          ::Foreman::Logging.logger('katello/agent')
        end

        def self.run
          fail("Katello agent event receiver already started") if running?

          @thread = Thread.new do
            @handler = Handler.new
            @agent_connection = ::Katello::Agent::Connection.new
            @agent_connection.fetch_agent_messages(@handler)
          end
        end

        def self.close
          @agent_connection&.close
          @thread&.join
        end

        def self.running?
          @agent_connection&.open? && @thread&.status.present?
        end

        def self.status(refresh: true)
          Rails.cache.fetch(STATUS_CACHE_KEY, force: refresh) do
            {
              running: running?,
              processed_count: @handler&.processed || 0,
              failed_count: @handler&.failed || 0
            }
          end
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
katello-4.1.0.rc2.2 app/lib/katello/event_daemon/services/agent_event_receiver.rb
katello-4.1.0.rc2.1 app/lib/katello/event_daemon/services/agent_event_receiver.rb
katello-4.1.0.rc2 app/lib/katello/event_daemon/services/agent_event_receiver.rb
katello-4.1.0.rc1.1 app/lib/katello/event_daemon/services/agent_event_receiver.rb
katello-4.1.0.rc1 app/lib/katello/event_daemon/services/agent_event_receiver.rb
katello-4.0.0 app/lib/katello/event_daemon/services/agent_event_receiver.rb
katello-4.0.0.rc3.1 app/lib/katello/event_daemon/services/agent_event_receiver.rb