Method: OpenC3::TargetModel#handle_config

Defined in:

lib/openc3/models/target_model.rb

#handle_config(parser, keyword, parameters) ⇒ Object

Handles Target specific configuration keywords

# File 'lib/openc3/models/target_model.rb', line 474

def handle_config(parser, keyword, parameters)
  case keyword
  when 'CMD_BUFFER_DEPTH'
    parser.verify_num_parameters(1, 1, "#{keyword} <Number of commands to buffer to ensure logged in order>")
    @cmd_buffer_depth = parameters[0].to_i
  when 'CMD_LOG_CYCLE_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Maximum time between files in seconds>")
    @cmd_log_cycle_time = parameters[0].to_i
  when 'CMD_LOG_CYCLE_SIZE'
    parser.verify_num_parameters(1, 1, "#{keyword} <Maximum file size in bytes>")
    @cmd_log_cycle_size = parameters[0].to_i
  when 'CMD_LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for cmd log files in seconds - nil = Forever>")
    @cmd_log_retain_time = ConfigParser.handle_nil(parameters[0])
    @cmd_log_retain_time = @cmd_log_retain_time.to_i if @cmd_log_retain_time
  when 'CMD_DECOM_LOG_CYCLE_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Maximum time between files in seconds>")
    @cmd_decom_log_cycle_time = parameters[0].to_i
  when 'CMD_DECOM_LOG_CYCLE_SIZE'
    parser.verify_num_parameters(1, 1, "#{keyword} <Maximum file size in bytes>")
    @cmd_decom_log_cycle_size = parameters[0].to_i
  when 'CMD_DECOM_LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for cmd decom log files in seconds - nil = Forever>")
    @cmd_decom_log_retain_time = ConfigParser.handle_nil(parameters[0])
    @cmd_decom_log_retain_time = @cmd_decom_log_retain_time.to_i if @cmd_decom_log_retain_time
  when 'TLM_BUFFER_DEPTH'
    parser.verify_num_parameters(1, 1, "#{keyword} <Number of telemetry packets to buffer to ensure logged in order>")
    @tlm_buffer_depth = parameters[0].to_i
  when 'TLM_LOG_CYCLE_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Maximum time between files in seconds>")
    @tlm_log_cycle_time = parameters[0].to_i
  when 'TLM_LOG_CYCLE_SIZE'
    parser.verify_num_parameters(1, 1, "#{keyword} <Maximum file size in bytes>")
    @tlm_log_cycle_size = parameters[0].to_i
  when 'TLM_LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for tlm log files in seconds - nil = Forever>")
    @tlm_log_retain_time = ConfigParser.handle_nil(parameters[0])
    @tlm_log_retain_time = @tlm_log_retain_time.to_i if @tlm_log_retain_time
  when 'TLM_DECOM_LOG_CYCLE_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Maximum time between files in seconds>")
    @tlm_decom_log_cycle_time = parameters[0].to_i
  when 'TLM_DECOM_LOG_CYCLE_SIZE'
    parser.verify_num_parameters(1, 1, "#{keyword} <Maximum file size in bytes>")
    @tlm_decom_log_cycle_size = parameters[0].to_i
  when 'TLM_DECOM_LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for tlm decom log files in seconds - nil = Forever>")
    @tlm_decom_log_retain_time = ConfigParser.handle_nil(parameters[0])
    @tlm_decom_log_retain_time = @tlm_decom_log_retain_time.to_i if @tlm_decom_log_retain_time
  when 'REDUCED_MINUTE_LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for reduced minute log files in seconds - nil = Forever>")
    @reduced_minute_log_retain_time = ConfigParser.handle_nil(parameters[0])
    @reduced_minute_log_retain_time = @reduced_minute_log_retain_time.to_i if @reduced_minute_log_retain_time
  when 'REDUCED_HOUR_LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for reduced hour log files in seconds - nil = Forever>")
    @reduced_hour_log_retain_time = ConfigParser.handle_nil(parameters[0])
    @reduced_hour_log_retain_time = @reduced_hour_log_retain_time.to_i if @reduced_hour_log_retain_time
  when 'REDUCED_DAY_LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for reduced day log files in seconds - nil = Forever>")
    @reduced_day_log_retain_time = ConfigParser.handle_nil(parameters[0])
    @reduced_day_log_retain_time = @reduced_day_log_retain_time.to_i if @reduced_day_log_retain_time
  when 'LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for all log files in seconds - nil = Forever>")
    log_retain_time = ConfigParser.handle_nil(parameters[0])
    if log_retain_time
      @cmd_log_retain_time = log_retain_time.to_i
      @cmd_decom_log_retain_time = log_retain_time.to_i
      @tlm_log_retain_time = log_retain_time.to_i
      @tlm_decom_log_retain_time = log_retain_time.to_i
    end
  when 'REDUCED_LOG_RETAIN_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for all reduced log files in seconds - nil = Forever>")
    reduced_log_retain_time = ConfigParser.handle_nil(parameters[0])
    if reduced_log_retain_time
      @reduced_minute_log_retain_time = reduced_log_retain_time.to_i
      @reduced_hour_log_retain_time = reduced_log_retain_time.to_i
      @reduced_day_log_retain_time = reduced_log_retain_time.to_i
    end
  when 'REDUCER_DISABLE', 'REDUCER_DISABLED' # Handle typos
    @reducer_disable = true
  when 'REDUCER_MAX_CPU_UTILIZATION', 'REDUCED_MAX_CPU_UTILIZATION' # Handle typos
    parser.verify_num_parameters(1, 1, "#{keyword} <Max cpu utilization to allocate to the reducer microservice - 0.0 to 100.0>")
    @reducer_max_cpu_utilization = Float(parameters[0])
  when 'CLEANUP_POLL_TIME'
    parser.verify_num_parameters(1, 1, "#{keyword} <Cleanup polling period in seconds>")
    @cleanup_poll_time = parameters[0].to_i
  when 'TARGET_MICROSERVICE'
    parser.verify_num_parameters(1, 1, "#{keyword} <Type: DECOM COMMANDLOG DECOMCMDLOG PACKETLOG DECOMLOG REDUCER CLEANUP>")
    type = parameters[0].to_s.upcase
    unless %w(DECOM COMMANDLOG DECOMCMDLOG PACKETLOG DECOMLOG REDUCER CLEANUP).include?(type)
      raise "Unknown TARGET_MICROSERVICE #{type}"
    end
    @target_microservices[type] ||= []
    @target_microservices[type] << []
    @current_target_microservice = type
  when 'PACKET'
    if @current_target_microservice
      parser.verify_num_parameters(1, 1, "#{keyword} <Packet Name>")
      if @current_target_microservice == 'REDUCER' or @current_target_microservice == 'CLEANUP'
        raise ConfigParser::Error.new(parser, "PACKET cannot be used with target microservice #{@current_target_microservice}")
      end
      @target_microservices[@current_target_microservice][-1] << parameters[0].to_s.upcase
    else
      raise ConfigParser::Error.new(parser, "PACKET cannot be used without a TARGET_MICROSERVICE")
    end
  when 'DISABLE_ERB'
    # 0 to unlimited parameters
    @disable_erb ||= []
    if parameters
      @disable_erb.concat(parameters)
    end
  when 'SHARD'
    parser.verify_num_parameters(1, 1, "#{keyword} <Shard Number Starting from 0>")
    @shard = Integer(parameters[0])

  else
    raise ConfigParser::Error.new(parser, "Unknown keyword and parameters for Target: #{keyword} #{parameters.join(" ")}")
  end
  return nil
end