# encoding: utf-8

require 'rcs-common/heartbeat'
require 'rcs-common/path_utils'

require_release 'rcs-db/db_layer'
require_relative 'dispatcher'

module RCS
  module Connector
    class HeartBeat < RCS::HeartBeat::Base
      component :connector

      def check_all_archive_nodes
        RCS::DB::ArchiveNode.all.each do |node|
          trace(:debug, "Updating status of archive node #{node.address}")
          node.ping!
        end
      end

      def perform
        check_all_archive_nodes

        return system_status_and_message
      end
    end
  end
end