Sha256: 776a17c955e93079216e9357c014b40a94edc1d6ffbbe0187a71e737e9d41792
Contents?: true
Size: 1.51 KB
Versions: 2
Compression:
Stored size: 1.51 KB
Contents
# encoding: ascii-8bit # Copyright 2023 OpenC3, Inc. # All Rights Reserved. # # This program is free software; you can modify and/or redistribute it # under the terms of the GNU Affero General Public License # as published by the Free Software Foundation; version 3 with # attribution addendums as found in the LICENSE.txt # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Affero General Public License for more details. # # This file may also be used under the terms of a commercial license # if purchased from OpenC3, Inc. require 'openc3/topics/telemetry_topic' require 'openc3/system/system' module OpenC3 module InterfaceDecomCommon def handle_inject_tlm(inject_tlm_json) inject_tlm_hash = JSON.parse(inject_tlm_json, allow_nan: true, create_additions: true) target_name = inject_tlm_hash['target_name'] packet_name = inject_tlm_hash['packet_name'] item_hash = inject_tlm_hash['item_hash'] type = inject_tlm_hash['type'].to_s.intern packet = System.telemetry.packet(target_name, packet_name) if item_hash item_hash.each do |name, value| packet.write(name.to_s, value, type) end end topic = "#{@scope}__TELEMETRY__{#{target_name}}__#{packet_name}" packet.received_count += 1 packet.received_time = Time.now.sys TelemetryTopic.write_packet(packet, scope: @scope) end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
openc3-5.6.1 | lib/openc3/microservices/interface_decom_common.rb |
openc3-5.6.0 | lib/openc3/microservices/interface_decom_common.rb |