Class: OpenC3::JsonPacket

Inherits:
Object show all
Defined in:
lib/openc3/packets/json_packet.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(cmd_or_tlm, target_name, packet_name, time_nsec_since_epoch, stored, json_data, key_map = nil, received_time_nsec_since_epoch: nil, extra: nil) ⇒ JsonPacket

Returns a new instance of JsonPacket.



38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/openc3/packets/json_packet.rb', line 38

def initialize(cmd_or_tlm, target_name, packet_name, time_nsec_since_epoch, stored, json_data, key_map = nil, received_time_nsec_since_epoch: nil, extra: nil)
  @cmd_or_tlm = cmd_or_tlm.intern
  @target_name = target_name
  @packet_name = packet_name
  @packet_time = ::Time.from_nsec_from_epoch(time_nsec_since_epoch)
  @stored = ConfigParser.handle_true_false(stored)
  if received_time_nsec_since_epoch
    @received_time = ::Time.from_nsec_from_epoch(received_time_nsec_since_epoch)
  else
    @received_time = @packet_time
  end
  @extra = extra
  @json_hash = json_data
  @json_hash = JSON.parse(json_data, :allow_nan => true, :create_additions => true) if String === json_data
  if key_map
    uncompressed = {}
    @json_hash.each do |key, value|
      uncompressed_key = key_map[key]
      uncompressed_key = key unless uncompressed_key
      uncompressed[uncompressed_key] = value
    end
    @json_hash = uncompressed
  end
end

Instance Attribute Details

#cmd_or_tlm ⇒ Object

Returns the value of attribute cmd_or_tlm.



29
30
31
 
# File 'lib/openc3/packets/json_packet.rb', line 29

def cmd_or_tlm
  @cmd_or_tlm
end

#extra ⇒ Object

Returns the value of attribute extra.



36
37
38
 
# File 'lib/openc3/packets/json_packet.rb', line 36

def extra
  @extra
end

#json_hash ⇒ Object

Returns the value of attribute json_hash.



34
35
36
 
# File 'lib/openc3/packets/json_packet.rb', line 34

def json_hash
  @json_hash
end

#packet_name ⇒ Object

Returns the value of attribute packet_name.



31
32
33
 
# File 'lib/openc3/packets/json_packet.rb', line 31

def packet_name
  @packet_name
end

#packet_time ⇒ Object

Returns the value of attribute packet_time.



32
33
34
 
# File 'lib/openc3/packets/json_packet.rb', line 32

def packet_time
  @packet_time
end

#received_time ⇒ Object

Returns the value of attribute received_time.



35
36
37
 
# File 'lib/openc3/packets/json_packet.rb', line 35

def received_time
  @received_time
end

#stored ⇒ Object

Returns the value of attribute stored.



33
34
35
 
# File 'lib/openc3/packets/json_packet.rb', line 33

def stored
  @stored
end

#target_name ⇒ Object

Returns the value of attribute target_name.



30
31
32
 
# File 'lib/openc3/packets/json_packet.rb', line 30

def target_name
  @target_name
end

Instance Method Details

#formatted(value_type = :CONVERTED, reduced_type = nil, names = nil, indent = 0) ⇒ Object

Create a string that shows the name and value of each item in the packet

Parameters:

  • indent (Integer) (defaults to: 0) —

    Amount to indent before printing the item name



198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
 
# File 'lib/openc3/packets/json_packet.rb', line 198

def formatted(value_type = :CONVERTED, reduced_type = nil, names = nil, indent = 0)
  names = read_all_names() unless names
  indent_string = ' ' * indent
  string = ''
  names.each do |name|
    value = read(name, value_type, reduced_type)
    if String === value and value =~ File::NON_ASCII_PRINTABLE
      string << "#{indent_string}#{name}:\n"
      string << value.formatted(1, 16, ' ', indent + 2)
    else
      string << "#{indent_string}#{name}: #{value}\n"
    end
  end
  return string
end

#read(name, value_type = :CONVERTED, reduced_type = nil) ⇒ Object

Read an item in the packet by name

Parameters:

  • name (String) —

    Name of the item to read - Should already by upcase



67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
 
# File 'lib/openc3/packets/json_packet.rb', line 67

def read(name, value_type = :CONVERTED, reduced_type = nil)
  if reduced_type
    raise "Reduced types only support RAW or CONVERTED value types: #{value_type} unsupported" if value_type == :WITH_UNITS or value_type == :FORMATTED
    if value_type == :CONVERTED
      case reduced_type
      when :AVG
        value = @json_hash["#{name}__CA"]
        return value if value
      when :STDDEV
        value = @json_hash["#{name}__CS"]
        return value if value
      when :MIN
        value = @json_hash["#{name}__CN"]
        return value if value
      when :MAX
        value = @json_hash["#{name}__CX"]
        return value if value
      end
    end
    case reduced_type
    when :AVG
      value = @json_hash["#{name}__A"]
      return value if value
    when :STDDEV
      value = @json_hash["#{name}__S"]
      return value if value
    when :MIN
      value = @json_hash["#{name}__N"]
      return value if value
    when :MAX
      value = @json_hash["#{name}__X"]
      return value if value
    end
  end
  if value_type == :WITH_UNITS
    value = @json_hash["#{name}__U"]
    return value if value
  end
  if value_type == :WITH_UNITS or value_type == :FORMATTED
    value = @json_hash["#{name}__F"]
    return value if value

    value = @json_hash["#{name}__C"]
    return value.to_s if value

    value = @json_hash[name]
    return value.to_s if value

    return nil
  end
  if value_type == :CONVERTED
    value = @json_hash["#{name}__C"]
    return value if value
  end
  return @json_hash[name]
end

#read_all(value_type = :CONVERTED, reduced_type = nil, names = nil) ⇒ Object

Read all items in the packet into an array of arrays

[[item name, item value], ...]



135
136
137
138
139
140
141
142
 
# File 'lib/openc3/packets/json_packet.rb', line 135

def read_all(value_type = :CONVERTED, reduced_type = nil, names = nil)
  result = {}
  names = read_all_names() unless names
  names.each do |name|
    result[name] = read(name, value_type, reduced_type)
  end
  return result
end

#read_all_names(value_type = nil, reduced_type = nil) ⇒ Object

Read all the names of items in the packet Note: This is not very efficient, ideally only call once for discovery purposes



159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
 
# File 'lib/openc3/packets/json_packet.rb', line 159

def read_all_names(value_type = nil, reduced_type = nil)
  result = {}
  if value_type
    case value_type
    when :RAW
      postfix = ''
    when :CONVERTED
      postfix = 'C'
    when :FORMATTED
      postfix = 'F'
    when :WITH_UNITS
      postfix = 'U'
    end
    case reduced_type
    when :MIN
      postfix << 'N'
    when :MAX
      postfix << 'X'
    when :AVG
      postfix << 'A'
    when :STDDEV
      postfix << 'S'
    else
      postfix = nil if value_type == :RAW
    end
    @json_hash.each do |key, value|
      key_split = key.split("__")
      result[key_split[0]] = true if key_split[1] == postfix
    end
  else
    @json_hash.each { |key, value| result[key.split("__")[0]] = true }
  end
  return result.keys
end

#read_all_with_limits_states(value_type = :CONVERTED, reduced_type = nil, names = nil) ⇒ Object

Read all items in the packet into an array of arrays

[[item name, item value], [item limits state], ...]



148
149
150
151
152
153
154
155
 
# File 'lib/openc3/packets/json_packet.rb', line 148

def read_all_with_limits_states(value_type = :CONVERTED, reduced_type = nil, names = nil)
  result = {}
  names = read_all_names() unless names
  names.each do |name|
    result[name] = read_with_limits_state(name, value_type, reduced_type)
  end
  return result
end

#read_with_limits_state(name, value_type = :CONVERTED, reduced_type = nil) ⇒ Object 



124
125
126
127
128
129
 
# File 'lib/openc3/packets/json_packet.rb', line 124

def read_with_limits_state(name, value_type = :CONVERTED, reduced_type = nil)
  value = read(name, value_type, reduced_type)
  limits_state = @json_hash["#{name}__L"]
  limits_state.intern if limits_state
  return [value, limits_state]
end