Method: OpenC3::PacketLogWriter#get_packet_index

Defined in:

lib/openc3/logs/packet_log_writer.rb

#get_packet_index(cmd_or_tlm, target_name, packet_name, entry_type, data) ⇒ Object

# File 'lib/openc3/logs/packet_log_writer.rb', line 161

def get_packet_index(cmd_or_tlm, target_name, packet_name, entry_type, data)
  if cmd_or_tlm == :CMD
    target_table = @cmd_packet_table[target_name]
  else
    target_table = @tlm_packet_table[target_name]
  end
  if target_table
    packet_index = target_table[packet_name]
    return packet_index if packet_index
  else
    # New packet_table entry needed
    target_table = {}
    if cmd_or_tlm == :CMD
      @cmd_packet_table[target_name] = target_table
    else
      @tlm_packet_table[target_name] = target_table
    end
    id = nil
    unless ENV['OPENC3_NO_STORE']
      id = @target_id_cache[target_name]
      unless id
        target = TargetModel.get(name: target_name, scope: @scope)
        id = target["id"] if target
        @target_id_cache[target_name] = id
      end
    end
    write_entry(:TARGET_DECLARATION, cmd_or_tlm, target_name, packet_name, nil, nil, nil, id)
  end

  # New target_table entry needed
  packet_index = @next_packet_index
  if packet_index > OPENC3_MAX_PACKET_INDEX
    raise "Packet Index Overflow"
  end

  target_table[packet_name] = packet_index
  @next_packet_index += 1

  id = nil
  begin
    unless ENV['OPENC3_NO_STORE']
      cache_key = "#{cmd_or_tlm}__#{target_name}__#{packet_name}"
      id = @packet_id_cache[cache_key]
      unless id
        target_model_packet = TargetModel.packet(target_name, packet_name, type: cmd_or_tlm, scope: @scope)
        id = target_model_packet["config_name"] if target_model_packet
        @packet_id_cache[cache_key] = id
      end
    end
  rescue
    # No packet def
  end
  write_entry(:PACKET_DECLARATION, cmd_or_tlm, target_name, packet_name, nil, nil, nil, id)
  if entry_type == :JSON_PACKET
    key_map = @key_map_table[packet_index]
    unless key_map
      parsed = data
      parsed = JSON.parse(data, :allow_nan => true, :create_additions => true) if String === parsed
      keys = parsed.keys
      key_map = {}
      reverse_key_map = {}
      keys.each_with_index do |key, index|
        key_map[index.to_s] = key
        reverse_key_map[key] = index.to_s
      end
      @key_map_table[packet_index] = reverse_key_map
      if @data_format == :CBOR
        write_entry(:KEY_MAP, cmd_or_tlm, target_name, packet_name, nil, nil, key_map.to_cbor, nil)
      else # JSON
        write_entry(:KEY_MAP, cmd_or_tlm, target_name, packet_name, nil, nil, JSON.generate(key_map, :allow_nan => true), nil)
      end
    end
  end
  return packet_index
end