Class: Cosmos::RouterTlmHandlerThread

Inherits:

Object

• Object
• Cosmos::RouterTlmHandlerThread

Defined in:

lib/cosmos/microservices/interface_microservice.rb

Instance Method Summary

• #graceful_kill ⇒ Object
• #initialize(router, tlm, scope:) ⇒ RouterTlmHandlerThread constructor

  A new instance of RouterTlmHandlerThread.

• #run ⇒ Object
• #start ⇒ Object
• #stop ⇒ Object

Constructor Details

#initialize(router, tlm, scope:) ⇒ RouterTlmHandlerThread

Returns a new instance of RouterTlmHandlerThread.

# File 'lib/cosmos/microservices/interface_microservice.rb', line 168

def initialize(router, tlm, scope:)
  @router = router
  @tlm = tlm
  @scope = scope
end

Instance Method Details

#graceful_kill ⇒ Object

# File 'lib/cosmos/microservices/interface_microservice.rb', line 187

def graceful_kill
  RouterTopic.shutdown(@router, scope: @scope)
end

#run ⇒ Object

# File 'lib/cosmos/microservices/interface_microservice.rb', line 191

def run
  RouterTopic.receive_telemetry(@router, scope: @scope) do |topic, msg_hash|
    # Check for commands to the router itself
    if /CMD}ROUTER/.match?(topic)
      if msg_hash['shutdown']
        Logger.info "#{@router.name}: Shutdown requested"
        return
      end
      if msg_hash['connect']
        Logger.info "#{@router.name}: Connect requested"
        @tlm.attempting()
      end
      if msg_hash['disconnect']
        Logger.info "#{@router.name}: Disconnect requested"
        @tlm.disconnect(false)
      end
      if msg_hash.key?('log_raw')
        if msg_hash['log_raw'] == 'true'
          Logger.info "#{@router.name}: Enable raw logging"
          @router.start_raw_logging
        else
          Logger.info "#{@router.name}: Disable raw logging"
          @router.stop_raw_logging
        end
      end
      next 'SUCCESS'
    end

    if @router.connected?
      target_name = msg_hash["target_name"]
      packet_name = msg_hash["packet_name"]

      packet = System.telemetry.packet(target_name, packet_name)
      packet.stored = ConfigParser.handle_true_false(msg_hash["stored"])
      packet.received_time = Time.from_nsec_from_epoch(msg_hash["time"].to_i)
      packet.received_count = msg_hash["received_count"].to_i
      packet.buffer = msg_hash["buffer"]

      begin
        @router.write(packet)
        RouterStatusModel.set(@router.as_json, scope: @scope)
        next 'SUCCESS'
      rescue => e
        Logger.error "#{@router.name}: #{e.formatted}"
        next e.message
      end
    end
  end
end

#start ⇒ Object

# File 'lib/cosmos/microservices/interface_microservice.rb', line 174

def start
  @thread = Thread.new do
    run()
  rescue Exception => err
    Logger.error "#{@router.name}: Telemetry handler thread died: #{err.formatted}"
    raise err
  end
end

#stop ⇒ Object

# File 'lib/cosmos/microservices/interface_microservice.rb', line 183

def stop
  Cosmos.kill_thread(self, @thread)
end