Class: OpenC3::TargetModel
- Defined in:
- lib/openc3/models/target_model.rb
Overview
Manages the target in Redis. It stores the target itself under the
Constant Summary collapse
- PRIMARY_KEY =
'openc3_targets'- VALID_TYPES =
%i(CMD TLM)
- ERB_EXTENSIONS =
%w(.txt .rb .py .json .yaml .yml)
- ITEM_MAP_CACHE_TIMEOUT =
10.0- PACKET_CACHE_TIMEOUT =
10.0- @@item_map_cache =
{}
- @@packet_cache =
{}
- @@packet_cache_mutex =
Mutex.new
- @@sync_packet_count_data =
{}
- @@sync_packet_count_time =
nil- @@sync_packet_count_delay_seconds =
Sync packet counts every second
1.0- @@stale_packet_keys_warned =
Track stale keys already warned about
Set.new
Instance Attribute Summary collapse
-
#children ⇒ Object
Returns the value of attribute children.
-
#cleanup_poll_time ⇒ Object
Returns the value of attribute cleanup_poll_time.
-
#cmd_buffer_depth ⇒ Object
Returns the value of attribute cmd_buffer_depth.
-
#cmd_decom_retain_time ⇒ Object
Returns the value of attribute cmd_decom_retain_time.
-
#cmd_log_cycle_size ⇒ Object
Returns the value of attribute cmd_log_cycle_size.
-
#cmd_log_cycle_time ⇒ Object
Returns the value of attribute cmd_log_cycle_time.
-
#cmd_log_retain_time ⇒ Object
Returns the value of attribute cmd_log_retain_time.
-
#cmd_tlm_files ⇒ Object
Returns the value of attribute cmd_tlm_files.
-
#db_shard ⇒ Object
Returns the value of attribute db_shard.
-
#disable_erb ⇒ Object
Returns the value of attribute disable_erb.
-
#folder_name ⇒ Object
Returns the value of attribute folder_name.
-
#id ⇒ Object
Returns the value of attribute id.
-
#ignored_items ⇒ Object
Returns the value of attribute ignored_items.
-
#ignored_parameters ⇒ Object
Returns the value of attribute ignored_parameters.
-
#limits_groups ⇒ Object
Returns the value of attribute limits_groups.
-
#needs_dependencies ⇒ Object
Returns the value of attribute needs_dependencies.
-
#requires ⇒ Object
Returns the value of attribute requires.
-
#shard ⇒ Object
Returns the value of attribute shard.
-
#stored_limits_mode ⇒ Object
Returns the value of attribute stored_limits_mode.
-
#target_microservices ⇒ Object
Returns the value of attribute target_microservices.
-
#tlm_buffer_depth ⇒ Object
Returns the value of attribute tlm_buffer_depth.
-
#tlm_decom_retain_time ⇒ Object
Returns the value of attribute tlm_decom_retain_time.
-
#tlm_log_cycle_size ⇒ Object
Returns the value of attribute tlm_log_cycle_size.
-
#tlm_log_cycle_time ⇒ Object
Returns the value of attribute tlm_log_cycle_time.
-
#tlm_log_retain_time ⇒ Object
Returns the value of attribute tlm_log_retain_time.
Attributes inherited from Model
#name, #plugin, #scope, #updated_at
Class Method Summary collapse
- .add_to_target_allitems_list(target_name, item_name, scope:) ⇒ Object
- .all(scope:) ⇒ Object
-
.all_item_names(target_name, type: :TLM, scope:) ⇒ Array<String>
All the item names for every packet in a target.
-
.all_modified(scope:) ⇒ Object
All targets with indication of modified targets.
-
.all_packet_name_descriptions(target_name, type: :TLM, scope:) ⇒ Array<Hash>
All packet hashes under the target_name.
- .build_item_to_packet_map(target_name, scope:) ⇒ Object
- .clear_packet_cache ⇒ Object
- .delete_modified(target_name, scope:) ⇒ Object
- .download(target_name, scope:) ⇒ Object
-
.get(name:, scope:) ⇒ Object
NOTE: The following three class methods are used by the ModelController and are reimplemented to enable various Model class methods to work.
- .get_all_command_counts(target_name, scope:) ⇒ Object
- .get_all_telemetry_counts(target_name, scope:) ⇒ Object
- .get_command_count(target_name, packet_name, scope:) ⇒ Object
- .get_command_counts(target_packets, scope:) ⇒ Object
- .get_item_to_packet_map(target_name, scope:) ⇒ Object
- .get_telemetry_count(target_name, packet_name, scope:) ⇒ Object
- .get_telemetry_counts(target_packets, scope:) ⇒ Object
-
.handle_config(parser, keyword, parameters, plugin: nil, needs_dependencies: false, scope:) ⇒ Object
Called by the PluginModel to allow this class to validate it's top-level keyword: "TARGET".
- .increment_command_count(target_name, packet_name, count, scope:) ⇒ Object
- .increment_telemetry_count(target_name, packet_name, count, scope:) ⇒ Object
- .init_tlm_packet_counts(tlm_target_names, scope:) ⇒ Object
- .limits_groups(scope:) ⇒ Hash{String => Array<Array<String, String, String>>}
-
.modified_files(target_name, scope:) ⇒ Object
Given target's modified file list.
- .names(scope:) ⇒ Object
-
.packet(target_name, packet_name, type: :TLM, scope:) ⇒ Hash
Packet hash or raises an exception.
-
.packet_item(target_name, packet_name, item_name, type: :TLM, scope:) ⇒ Hash
Item hash or raises an exception.
-
.packet_items(target_name, packet_name, items, type: :TLM, scope:) ⇒ Array<Hash>
Item hash array or raises an exception.
-
.packets(target_name, type: :TLM, scope:) ⇒ Array<Hash>
All packet hashes under the target_name.
- .rebuild_target_allitems_list(target_name, type: :TLM, scope:) ⇒ Object
- .set_packet(target_name, packet_name, packet, type: :TLM, scope:) ⇒ Object
-
.store_for_target(target_name, scope:) ⇒ Object
Get a Store instance routed to the correct db_shard for a target.
- .sync_packet_count_delay_seconds=(value) ⇒ Object
- .sync_tlm_packet_counts(packet, tlm_target_names, scope:) ⇒ Object
Instance Method Summary collapse
- #add_topics_to_microservice(microservice_name, topics) ⇒ Object
- #as_json(*_a) ⇒ Object
- #build_target_archive(temp_dir, target_folder) ⇒ Object
- #deploy(gem_path, variables, validate_only: false) ⇒ Object
- #deploy_cleanup_microservice(gem_path, variables, instance = nil, parent = nil) ⇒ Object
- #deploy_commmandlog_microservice(gem_path, variables, topics, instance = nil, parent = nil) ⇒ Object
- #deploy_decom_microservice(target, gem_path, variables, topics, instance = nil, parent = nil) ⇒ Object
- #deploy_microservices(gem_path, variables, system) ⇒ Object
- #deploy_multi_microservice(gem_path, variables, instance = nil) ⇒ Object
- #deploy_packetlog_microservice(gem_path, variables, topics, instance = nil, parent = nil) ⇒ Object
- #deploy_target_microservices(type, base_topic_list, topic_prefix) ⇒ Object
- #deploy_tsdb_microservice(gem_path, variables, topics, instance = nil, parent = nil) ⇒ Object
-
#dynamic_update(packets, cmd_or_tlm = :TELEMETRY, filename = "dynamic_tlm.txt") ⇒ Object
NOTE: If you call dynamic_update multiple times you should specify a different filename parameter or the last one will be overwritten.
-
#handle_config(parser, keyword, parameters) ⇒ Object
Handles Target specific configuration keywords.
-
#initialize(name:, folder_name: nil, requires: [], ignored_parameters: [], ignored_items: [], limits_groups: [], stored_limits_mode: 'PROCESS', cmd_tlm_files: [], id: nil, updated_at: nil, plugin: nil, cmd_buffer_depth: 5, cmd_log_cycle_time: 600, cmd_log_cycle_size: 50_000_000, cmd_log_retain_time: nil, tlm_buffer_depth: 60, tlm_log_cycle_time: 600, tlm_log_cycle_size: 50_000_000, tlm_log_retain_time: nil, cmd_decom_retain_time: nil, tlm_decom_retain_time: nil, cleanup_poll_time: 3600, needs_dependencies: false, target_microservices: {}, disable_erb: nil, shard: 0, db_shard: 0, scope:) ⇒ TargetModel
constructor
Make sure to update target_model.py if you add additional parameters.
-
#render(template_name, options = {}) ⇒ Object
Called by the ERB template to render a partial.
- #undeploy ⇒ Object
- #update_store(system, clear_old: true) ⇒ Object
- #update_store_commands(packet_hash, clear_old: true) ⇒ Object
- #update_store_item_map ⇒ Object
- #update_store_limits_groups(system) ⇒ Object
- #update_store_limits_sets(system) ⇒ Object
- #update_store_telemetry(packet_hash, clear_old: true) ⇒ Object
- #update_target_model(system) ⇒ Object
Methods inherited from Model
#check_disable_erb, #create, #destroy, #destroyed?, #diff, filter, find_all_by_plugin, from_json, get_all_models, get_model, set, store, store_queued, #update
Constructor Details
#initialize(name:, folder_name: nil, requires: [], ignored_parameters: [], ignored_items: [], limits_groups: [], stored_limits_mode: 'PROCESS', cmd_tlm_files: [], id: nil, updated_at: nil, plugin: nil, cmd_buffer_depth: 5, cmd_log_cycle_time: 600, cmd_log_cycle_size: 50_000_000, cmd_log_retain_time: nil, tlm_buffer_depth: 60, tlm_log_cycle_time: 600, tlm_log_cycle_size: 50_000_000, tlm_log_retain_time: nil, cmd_decom_retain_time: nil, tlm_decom_retain_time: nil, cleanup_poll_time: 3600, needs_dependencies: false, target_microservices: {}, disable_erb: nil, shard: 0, db_shard: 0, scope:) ⇒ TargetModel
Make sure to update target_model.py if you add additional parameters
381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 |
# File 'lib/openc3/models/target_model.rb', line 381 def initialize( name:, folder_name: nil, requires: [], ignored_parameters: [], ignored_items: [], limits_groups: [], stored_limits_mode: 'PROCESS', cmd_tlm_files: [], id: nil, updated_at: nil, plugin: nil, cmd_buffer_depth: 5, cmd_log_cycle_time: 600, cmd_log_cycle_size: 50_000_000, cmd_log_retain_time: nil, tlm_buffer_depth: 60, tlm_log_cycle_time: 600, tlm_log_cycle_size: 50_000_000, tlm_log_retain_time: nil, cmd_decom_retain_time: nil, tlm_decom_retain_time: nil, cleanup_poll_time: 3600, needs_dependencies: false, target_microservices: {}, disable_erb: nil, shard: 0, db_shard: 0, scope: ) super("#{scope}__#{PRIMARY_KEY}", name: name, plugin: plugin, updated_at: updated_at, scope: scope) @folder_name = folder_name @requires = requires @ignored_parameters = ignored_parameters @ignored_items = ignored_items @limits_groups = limits_groups @stored_limits_mode = stored_limits_mode.to_s.upcase @stored_limits_mode = 'PROCESS' unless %w(PROCESS LOG DISABLE).include?(@stored_limits_mode) @cmd_tlm_files = cmd_tlm_files @id = id @cmd_buffer_depth = cmd_buffer_depth @cmd_log_cycle_time = cmd_log_cycle_time @cmd_log_cycle_size = cmd_log_cycle_size @cmd_log_retain_time = cmd_log_retain_time @tlm_buffer_depth = tlm_buffer_depth @tlm_log_cycle_time = tlm_log_cycle_time @tlm_log_cycle_size = tlm_log_cycle_size @tlm_log_retain_time = tlm_log_retain_time @cmd_decom_retain_time = cmd_decom_retain_time @tlm_decom_retain_time = tlm_decom_retain_time @cleanup_poll_time = cleanup_poll_time @needs_dependencies = needs_dependencies @target_microservices = target_microservices @disable_erb = disable_erb @shard = shard.to_i # to_i to handle nil @db_shard = db_shard.to_i # to_i to handle nil @bucket = Bucket.getClient() @children = [] end |
Instance Attribute Details
#children ⇒ Object
Returns the value of attribute children.
82 83 84 |
# File 'lib/openc3/models/target_model.rb', line 82 def children @children end |
#cleanup_poll_time ⇒ Object
Returns the value of attribute cleanup_poll_time.
79 80 81 |
# File 'lib/openc3/models/target_model.rb', line 79 def cleanup_poll_time @cleanup_poll_time end |
#cmd_buffer_depth ⇒ Object
Returns the value of attribute cmd_buffer_depth.
69 70 71 |
# File 'lib/openc3/models/target_model.rb', line 69 def cmd_buffer_depth @cmd_buffer_depth end |
#cmd_decom_retain_time ⇒ Object
Returns the value of attribute cmd_decom_retain_time.
77 78 79 |
# File 'lib/openc3/models/target_model.rb', line 77 def cmd_decom_retain_time @cmd_decom_retain_time end |
#cmd_log_cycle_size ⇒ Object
Returns the value of attribute cmd_log_cycle_size.
71 72 73 |
# File 'lib/openc3/models/target_model.rb', line 71 def cmd_log_cycle_size @cmd_log_cycle_size end |
#cmd_log_cycle_time ⇒ Object
Returns the value of attribute cmd_log_cycle_time.
70 71 72 |
# File 'lib/openc3/models/target_model.rb', line 70 def cmd_log_cycle_time @cmd_log_cycle_time end |
#cmd_log_retain_time ⇒ Object
Returns the value of attribute cmd_log_retain_time.
72 73 74 |
# File 'lib/openc3/models/target_model.rb', line 72 def cmd_log_retain_time @cmd_log_retain_time end |
#cmd_tlm_files ⇒ Object
Returns the value of attribute cmd_tlm_files.
67 68 69 |
# File 'lib/openc3/models/target_model.rb', line 67 def cmd_tlm_files @cmd_tlm_files end |
#db_shard ⇒ Object
Returns the value of attribute db_shard.
85 86 87 |
# File 'lib/openc3/models/target_model.rb', line 85 def db_shard @db_shard end |
#disable_erb ⇒ Object
Returns the value of attribute disable_erb.
83 84 85 |
# File 'lib/openc3/models/target_model.rb', line 83 def disable_erb @disable_erb end |
#folder_name ⇒ Object
Returns the value of attribute folder_name.
61 62 63 |
# File 'lib/openc3/models/target_model.rb', line 61 def folder_name @folder_name end |
#id ⇒ Object
Returns the value of attribute id.
68 69 70 |
# File 'lib/openc3/models/target_model.rb', line 68 def id @id end |
#ignored_items ⇒ Object
Returns the value of attribute ignored_items.
64 65 66 |
# File 'lib/openc3/models/target_model.rb', line 64 def ignored_items @ignored_items end |
#ignored_parameters ⇒ Object
Returns the value of attribute ignored_parameters.
63 64 65 |
# File 'lib/openc3/models/target_model.rb', line 63 def ignored_parameters @ignored_parameters end |
#limits_groups ⇒ Object
Returns the value of attribute limits_groups.
65 66 67 |
# File 'lib/openc3/models/target_model.rb', line 65 def limits_groups @limits_groups end |
#needs_dependencies ⇒ Object
Returns the value of attribute needs_dependencies.
80 81 82 |
# File 'lib/openc3/models/target_model.rb', line 80 def needs_dependencies @needs_dependencies end |
#requires ⇒ Object
Returns the value of attribute requires.
62 63 64 |
# File 'lib/openc3/models/target_model.rb', line 62 def requires @requires end |
#shard ⇒ Object
Returns the value of attribute shard.
84 85 86 |
# File 'lib/openc3/models/target_model.rb', line 84 def shard @shard end |
#stored_limits_mode ⇒ Object
Returns the value of attribute stored_limits_mode.
66 67 68 |
# File 'lib/openc3/models/target_model.rb', line 66 def stored_limits_mode @stored_limits_mode end |
#target_microservices ⇒ Object
Returns the value of attribute target_microservices.
81 82 83 |
# File 'lib/openc3/models/target_model.rb', line 81 def target_microservices @target_microservices end |
#tlm_buffer_depth ⇒ Object
Returns the value of attribute tlm_buffer_depth.
73 74 75 |
# File 'lib/openc3/models/target_model.rb', line 73 def tlm_buffer_depth @tlm_buffer_depth end |
#tlm_decom_retain_time ⇒ Object
Returns the value of attribute tlm_decom_retain_time.
78 79 80 |
# File 'lib/openc3/models/target_model.rb', line 78 def tlm_decom_retain_time @tlm_decom_retain_time end |
#tlm_log_cycle_size ⇒ Object
Returns the value of attribute tlm_log_cycle_size.
75 76 77 |
# File 'lib/openc3/models/target_model.rb', line 75 def tlm_log_cycle_size @tlm_log_cycle_size end |
#tlm_log_cycle_time ⇒ Object
Returns the value of attribute tlm_log_cycle_time.
74 75 76 |
# File 'lib/openc3/models/target_model.rb', line 74 def tlm_log_cycle_time @tlm_log_cycle_time end |
#tlm_log_retain_time ⇒ Object
Returns the value of attribute tlm_log_retain_time.
76 77 78 |
# File 'lib/openc3/models/target_model.rb', line 76 def tlm_log_retain_time @tlm_log_retain_time end |
Class Method Details
.add_to_target_allitems_list(target_name, item_name, scope:) ⇒ Object
321 322 323 324 |
# File 'lib/openc3/models/target_model.rb', line 321 def self.add_to_target_allitems_list(target_name, item_name, scope:) score = 0 # https://redis.io/docs/latest/develop/data-types/sorted-sets/#lexicographical-scores store_for_target(target_name, scope: scope).zadd("#{scope}__openc3tlm__#{target_name}__allitems", score, item_name) end |
.all(scope:) ⇒ Object
97 98 99 |
# File 'lib/openc3/models/target_model.rb', line 97 def self.all(scope:) super("#{scope}__#{PRIMARY_KEY}") end |
.all_item_names(target_name, type: :TLM, scope:) ⇒ Array<String>
Returns All the item names for every packet in a target.
305 306 307 308 309 |
# File 'lib/openc3/models/target_model.rb', line 305 def self.all_item_names(target_name, type: :TLM, scope:) items = store_for_target(target_name, scope: scope).zrange("#{scope}__openc3tlm__#{target_name}__allitems", 0, -1) items = rebuild_target_allitems_list(target_name, type: type, scope: scope) if items.empty? items end |
.all_modified(scope:) ⇒ Object
All targets with indication of modified targets
102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 |
# File 'lib/openc3/models/target_model.rb', line 102 def self.all_modified(scope:) targets = self.all(scope: scope) targets.each { |_target_name, target| target['modified'] = false } if ENV['OPENC3_LOCAL_MODE'] modified_targets = OpenC3::LocalMode.modified_targets(scope: scope) modified_targets.each do |target_name| targets[target_name]['modified'] = true if targets[target_name] end else modified_targets = Bucket.getClient().list_files(bucket: ENV['OPENC3_CONFIG_BUCKET'], path: "DEFAULT/targets_modified/", only_directories: true) modified_targets.each do |target_name| # A target could have been deleted without removing the modified files # Thus we have to check for the existence of the target_name key if targets.has_key?(target_name) targets[target_name]['modified'] = true end end end # Sort (which turns hash to array) and return hash # This enables a consistent listing of the targets targets.sort.to_h end |
.all_packet_name_descriptions(target_name, type: :TLM, scope:) ⇒ Array<Hash>
Returns All packet hashes under the target_name.
259 260 261 |
# File 'lib/openc3/models/target_model.rb', line 259 def self.all_packet_name_descriptions(target_name, type: :TLM, scope:) self.packets(target_name, type: type, scope: scope).map! { |hash| hash.slice("packet_name", "description") } end |
.build_item_to_packet_map(target_name, scope:) ⇒ Object
353 354 355 356 357 358 359 360 361 362 363 364 365 |
# File 'lib/openc3/models/target_model.rb', line 353 def self.build_item_to_packet_map(target_name, scope:) item_map = {} packets = packets(target_name, scope: scope) packets.each do |packet| items = packet['items'] items.each do |item| item_name = item['name'] item_map[item_name] ||= [] item_map[item_name] << packet['packet_name'] end end return item_map end |
.clear_packet_cache ⇒ Object
239 240 241 242 243 |
# File 'lib/openc3/models/target_model.rb', line 239 def self.clear_packet_cache @@packet_cache_mutex.synchronize do @@packet_cache.clear end end |
.delete_modified(target_name, scope:) ⇒ Object
148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 |
# File 'lib/openc3/models/target_model.rb', line 148 def self.delete_modified(target_name, scope:) if ENV['OPENC3_LOCAL_MODE'] OpenC3::LocalMode.delete_modified(target_name, scope: scope) end bucket = Bucket.getClient() # Delete the remote files as well resp = bucket.list_objects( bucket: ENV['OPENC3_CONFIG_BUCKET'], # The trailing slash is important! prefix: "#{scope}/targets_modified/#{target_name}/", ) resp.each do |item| bucket.delete_object(bucket: ENV['OPENC3_CONFIG_BUCKET'], key: item.key) end end |
.download(target_name, scope:) ⇒ Object
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 193 194 195 196 197 198 199 200 201 202 203 204 205 |
# File 'lib/openc3/models/target_model.rb', line 164 def self.download(target_name, scope:) # Validate target_name to not allow directory traversal if target_name.include?('..') || target_name.include?('/') || target_name.include?('\\') raise ArgumentError, "Invalid target_name: #{target_name.inspect}" end temp_dir = Dir.mktmpdir begin zip_filename = OpenC3.sanitize_path(File.join(temp_dir, "#{target_name}.zip")) Zip.continue_on_exists_proc = true zip = Zip::File.open(zip_filename, create: true) if ENV['OPENC3_LOCAL_MODE'] OpenC3::LocalMode.zip_target(target_name, zip, scope: scope) else bucket = Bucket.getClient() # The trailing slash is important! prefix = "#{scope}/targets_modified/#{target_name}/" resp = bucket.list_objects( bucket: ENV['OPENC3_CONFIG_BUCKET'], prefix: prefix, ) resp.each do |item| # item.key looks like DEFAULT/targets_modified/INST/screens/blah.txt base_path = item.key.sub(prefix, '') # remove prefix local_path = File.join(temp_dir, base_path) # Ensure dir structure exists, get_object fails if not FileUtils.mkdir_p(File.dirname(local_path)) bucket.get_object(bucket: ENV['OPENC3_CONFIG_BUCKET'], key: item.key, path: local_path) zip.add(base_path, local_path) end end zip.close result = OpenStruct.new result.filename = File.basename(zip_filename) result.contents = File.read(zip_filename, mode: 'rb') ensure FileUtils.remove_entry_secure(temp_dir, true) end return result end |
.get(name:, scope:) ⇒ Object
NOTE: The following three class methods are used by the ModelController and are reimplemented to enable various Model class methods to work
89 90 91 |
# File 'lib/openc3/models/target_model.rb', line 89 def self.get(name:, scope:) super("#{scope}__#{PRIMARY_KEY}", name: name) end |
.get_all_command_counts(target_name, scope:) ⇒ Object
1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 |
# File 'lib/openc3/models/target_model.rb', line 1379 def self.get_all_command_counts(target_name, scope:) result = {} get_all = store_for_target(target_name, scope: scope).hgetall("#{scope}__COMMANDCNTS__{#{target_name}}") if Hash === get_all get_all.each do |key, value| result[key] = value.to_i end else return result end end |
.get_all_telemetry_counts(target_name, scope:) ⇒ Object
1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 |
# File 'lib/openc3/models/target_model.rb', line 1223 def self.get_all_telemetry_counts(target_name, scope:) result = {} get_all = store_for_target(target_name, scope: scope).hgetall("#{scope}__TELEMETRYCNTS__{#{target_name}}") if Hash === get_all get_all.each do |key, value| result[key] = value.to_i end else return result end end |
.get_command_count(target_name, packet_name, scope:) ⇒ Object
1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 |
# File 'lib/openc3/models/target_model.rb', line 1391 def self.get_command_count(target_name, packet_name, scope:) value = store_for_target(target_name, scope: scope).hget("#{scope}__COMMANDCNTS__{#{target_name}}", packet_name) if String === value return value.to_i elsif value.nil? return 0 # Return 0 if the key doesn't exist else return value end end |
.get_command_counts(target_packets, scope:) ⇒ Object
1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 |
# File 'lib/openc3/models/target_model.rb', line 1402 def self.get_command_counts(target_packets, scope:) # Group by db_shard, preserving original index db_shard_groups = {} # db_shard => [{index:, target_name:, packet_name:}] target_packets.each_with_index do |(target_name, packet_name), idx| target_name = target_name.upcase packet_name = packet_name.upcase db_shard = Store.db_shard_for_target(target_name, scope: scope) db_shard_groups[db_shard] ||= [] db_shard_groups[db_shard] << { index: idx, target_name: target_name, packet_name: packet_name } end counts = Array.new(target_packets.length, 0) db_shard_groups.each do |db_shard, entries| store = Store.instance(db_shard: db_shard) result = store.redis_pool.pipelined do entries.each do |entry| store.hget("#{scope}__COMMANDCNTS__{#{entry[:target_name]}}", entry[:packet_name]) end end entries.each_with_index do |entry, i| counts[entry[:index]] = result[i] ? result[i].to_i : 0 end end return counts end |
.get_item_to_packet_map(target_name, scope:) ⇒ Object
336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 |
# File 'lib/openc3/models/target_model.rb', line 336 def self.get_item_to_packet_map(target_name, scope:) cache_time, item_map = @@item_map_cache[target_name] return item_map if item_map and (Time.now - cache_time) < ITEM_MAP_CACHE_TIMEOUT item_map_key = "#{scope}__#{target_name}__item_to_packet_map" target_name = target_name.upcase store = store_for_target(target_name, scope: scope) json_data = store.get(item_map_key) if json_data item_map = JSON.parse(json_data, allow_nan: true, create_additions: true) else item_map = build_item_to_packet_map(target_name, scope: scope) store.set(item_map_key, JSON.generate(item_map, allow_nan: true)) end @@item_map_cache[target_name] = [Time.now, item_map] return item_map end |
.get_telemetry_count(target_name, packet_name, scope:) ⇒ Object
1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 |
# File 'lib/openc3/models/target_model.rb', line 1235 def self.get_telemetry_count(target_name, packet_name, scope:) value = store_for_target(target_name, scope: scope).hget("#{scope}__TELEMETRYCNTS__{#{target_name}}", packet_name) if String === value return value.to_i elsif value.nil? return 0 # Return 0 if the key doesn't exist else return value end end |
.get_telemetry_counts(target_packets, scope:) ⇒ Object
1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 |
# File 'lib/openc3/models/target_model.rb', line 1246 def self.get_telemetry_counts(target_packets, scope:) # Group by db_shard, preserving original index db_shard_groups = {} # db_shard => [{index:, target_name:, packet_name:}] target_packets.each_with_index do |(target_name, packet_name), idx| target_name = target_name.upcase packet_name = packet_name.upcase db_shard = Store.db_shard_for_target(target_name, scope: scope) db_shard_groups[db_shard] ||= [] db_shard_groups[db_shard] << { index: idx, target_name: target_name, packet_name: packet_name } end counts = Array.new(target_packets.length, 0) db_shard_groups.each do |db_shard, entries| store = Store.instance(db_shard: db_shard) result = store.redis_pool.pipelined do entries.each do |entry| store.hget("#{scope}__TELEMETRYCNTS__{#{entry[:target_name]}}", entry[:packet_name]) end end entries.each_with_index do |entry, i| counts[entry[:index]] = result[i] ? result[i].to_i : 0 end end return counts end |
.handle_config(parser, keyword, parameters, plugin: nil, needs_dependencies: false, scope:) ⇒ Object
Called by the PluginModel to allow this class to validate it's top-level keyword: "TARGET"
368 369 370 371 372 373 374 375 376 377 378 |
# File 'lib/openc3/models/target_model.rb', line 368 def self.handle_config(parser, keyword, parameters, plugin: nil, needs_dependencies: false, scope:) case keyword when 'TARGET' usage = "#{keyword} <TARGET FOLDER NAME> <TARGET NAME>" parser.verify_num_parameters(2, 2, usage) parser.verify_parameter_naming(2) # Target name is the 2nd parameter return self.new(name: parameters[1].to_s.upcase, folder_name: parameters[0].to_s.upcase, plugin: plugin, needs_dependencies: needs_dependencies, scope: scope) else raise ConfigParser::Error.new(parser, "Unknown keyword and parameters for Target: #{keyword} #{parameters.join(" ")}") end end |
.increment_command_count(target_name, packet_name, count, scope:) ⇒ Object
1370 1371 1372 1373 1374 1375 1376 1377 |
# File 'lib/openc3/models/target_model.rb', line 1370 def self.increment_command_count(target_name, packet_name, count, scope:) result = store_for_target(target_name, scope: scope).hincrby("#{scope}__COMMANDCNTS__{#{target_name}}", packet_name, count) if String === result return result.to_i else return result end end |
.increment_telemetry_count(target_name, packet_name, count, scope:) ⇒ Object
1214 1215 1216 1217 1218 1219 1220 1221 |
# File 'lib/openc3/models/target_model.rb', line 1214 def self.increment_telemetry_count(target_name, packet_name, count, scope:) result = store_for_target(target_name, scope: scope).hincrby("#{scope}__TELEMETRYCNTS__{#{target_name}}", packet_name, count) if String === result return result.to_i else return result end end |
.init_tlm_packet_counts(tlm_target_names, scope:) ⇒ Object
1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 |
# File 'lib/openc3/models/target_model.rb', line 1276 def self.init_tlm_packet_counts(tlm_target_names, scope:) @@sync_packet_count_time = Time.now @@stale_packet_keys_warned = Set.new # Get all the packet counts with the global counters tlm_target_names.each do |target_name| get_all_telemetry_counts(target_name, scope: scope).each do |packet_name, count| begin update_packet = System.telemetry.packet(target_name, packet_name) update_packet.received_count = count.to_i rescue RuntimeError key = "#{target_name} #{packet_name}" unless @@stale_packet_keys_warned.include?(key) @@stale_packet_keys_warned.add(key) Logger.warn("Stale tlmcnt Redis key detected for unknown packet #{key} - ignoring") end end end end get_all_telemetry_counts('UNKNOWN', scope: scope).each do |packet_name, count| begin update_packet = System.telemetry.packet('UNKNOWN', packet_name) update_packet.received_count = count.to_i rescue RuntimeError key = "UNKNOWN #{packet_name}" unless @@stale_packet_keys_warned.include?(key) @@stale_packet_keys_warned.add(key) Logger.warn("Stale tlmcnt Redis key detected for unknown packet #{key} - ignoring") end end end end |
.limits_groups(scope:) ⇒ Hash{String => Array<Array<String, String, String>>}
327 328 329 330 331 332 333 334 |
# File 'lib/openc3/models/target_model.rb', line 327 def self.limits_groups(scope:) groups = Store.hgetall("#{scope}__limits_groups") if groups groups.map { |group, items| [group, JSON.parse(items, allow_nan: true, create_additions: true)] }.to_h else {} end end |
.modified_files(target_name, scope:) ⇒ Object
Given target's modified file list
127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 |
# File 'lib/openc3/models/target_model.rb', line 127 def self.modified_files(target_name, scope:) modified = [] if ENV['OPENC3_LOCAL_MODE'] modified = OpenC3::LocalMode.modified_files(target_name, scope: scope) else resp = Bucket.getClient().list_objects( bucket: ENV['OPENC3_CONFIG_BUCKET'], # The trailing slash is important! prefix: "#{scope}/targets_modified/#{target_name}/", ) resp.each do |item| # Results look like DEFAULT/targets_modified/INST/procedures/new.rb # so split on '/' and ignore the first two values modified << item.key.split('/')[2..-1].join('/') end end # Sort to enable a consistent listing of the modified files modified.sort end |
.names(scope:) ⇒ Object
93 94 95 |
# File 'lib/openc3/models/target_model.rb', line 93 def self.names(scope:) super("#{scope}__#{PRIMARY_KEY}") end |
.packet(target_name, packet_name, type: :TLM, scope:) ⇒ Hash
Returns Packet hash or raises an exception.
213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 |
# File 'lib/openc3/models/target_model.rb', line 213 def self.packet(target_name, packet_name, type: :TLM, scope:) raise "Unknown type #{type} for #{target_name} #{packet_name}" unless VALID_TYPES.include?(type) # Check cache first cache_key = "#{scope}__#{type}__#{target_name}__#{packet_name}" @@packet_cache_mutex.synchronize do cached = @@packet_cache[cache_key] if cached && (Time.now - cached[:time]) < PACKET_CACHE_TIMEOUT return cached[:packet] end end # Assume it exists and just try to get it to avoid an extra call to Store.exist? json = store_for_target(target_name, scope: scope).hget("#{scope}__openc3#{type.to_s.downcase}__#{target_name}", packet_name) raise "Packet '#{target_name} #{packet_name}' does not exist" if json.nil? packet = JSON.parse(json, allow_nan: true, create_additions: true) # Store in cache @@packet_cache_mutex.synchronize do @@packet_cache[cache_key] = { packet: packet, time: Time.now } end packet end |
.packet_item(target_name, packet_name, item_name, type: :TLM, scope:) ⇒ Hash
Returns Item hash or raises an exception.
281 282 283 284 285 286 |
# File 'lib/openc3/models/target_model.rb', line 281 def self.packet_item(target_name, packet_name, item_name, type: :TLM, scope:) packet = packet(target_name, packet_name, type: type, scope: scope) item = packet['items'].find { |item| item['name'] == item_name.to_s } raise "Item '#{packet['target_name']} #{packet['packet_name']} #{item_name}' does not exist" unless item item end |
.packet_items(target_name, packet_name, items, type: :TLM, scope:) ⇒ Array<Hash>
Returns Item hash array or raises an exception.
289 290 291 292 293 294 295 296 297 298 299 300 301 302 |
# File 'lib/openc3/models/target_model.rb', line 289 def self.packet_items(target_name, packet_name, items, type: :TLM, scope:) packet = packet(target_name, packet_name, type: type, scope: scope) found = packet['items'].find_all { |item| items.map(&:to_s).include?(item['name']) } if found.length != items.length # we didn't find them all found_items = found.collect { |item| item['name'] } not_found = [] (items - found_items).each do |item| not_found << "'#{target_name} #{packet_name} #{item}'" end # 'does not exist' not grammatically correct but we use it in every other exception raise "Item(s) #{not_found.join(', ')} does not exist" end found end |
.packets(target_name, type: :TLM, scope:) ⇒ Array<Hash>
Returns All packet hashes under the target_name.
246 247 248 249 250 251 252 253 254 255 256 |
# File 'lib/openc3/models/target_model.rb', line 246 def self.packets(target_name, type: :TLM, scope:) raise "Unknown type #{type} for #{target_name}" unless VALID_TYPES.include?(type) raise "Target '#{target_name}' does not exist for scope: #{scope}" unless get(name: target_name, scope: scope) result = [] packets = store_for_target(target_name, scope: scope).hgetall("#{scope}__openc3#{type.to_s.downcase}__#{target_name}") packets.sort.each do |_packet_name, packet_json| result << JSON.parse(packet_json, allow_nan: true, create_additions: true) end result end |
.rebuild_target_allitems_list(target_name, type: :TLM, scope:) ⇒ Object
311 312 313 314 315 316 317 318 319 |
# File 'lib/openc3/models/target_model.rb', line 311 def self.rebuild_target_allitems_list(target_name, type: :TLM, scope:) packets = packets(target_name, type: type, scope: scope) packets.each do |packet| packet['items'].each do |item| TargetModel.add_to_target_allitems_list(target_name, item['name'], scope: scope) end end store_for_target(target_name, scope: scope).zrange("#{scope}__openc3tlm__#{target_name}__allitems", 0, -1) # return the new sorted set to let redis do the sorting end |
.set_packet(target_name, packet_name, packet, type: :TLM, scope:) ⇒ Object
263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 |
# File 'lib/openc3/models/target_model.rb', line 263 def self.set_packet(target_name, packet_name, packet, type: :TLM, scope:) raise "Unknown type #{type} for #{target_name} #{packet_name}" unless VALID_TYPES.include?(type) # Invalidate cache entry cache_key = "#{scope}__#{type}__#{target_name}__#{packet_name}" @@packet_cache_mutex.synchronize do @@packet_cache.delete(cache_key) end begin store_for_target(target_name, scope: scope).hset("#{scope}__openc3#{type.to_s.downcase}__#{target_name}", packet_name, JSON.generate(packet.as_json, allow_nan: true)) rescue JSON::GeneratorError => e Logger.error("Invalid text present in #{target_name} #{packet_name} #{type.to_s.downcase} packet") raise e end end |
.store_for_target(target_name, scope:) ⇒ Object
Get a Store instance routed to the correct db_shard for a target
208 209 210 |
# File 'lib/openc3/models/target_model.rb', line 208 def self.store_for_target(target_name, scope:) Store.instance(db_shard: Store.db_shard_for_target(target_name, scope: scope)) end |
.sync_packet_count_delay_seconds=(value) ⇒ Object
1272 1273 1274 |
# File 'lib/openc3/models/target_model.rb', line 1272 def self.sync_packet_count_delay_seconds=(value) @@sync_packet_count_delay_seconds = value end |
.sync_tlm_packet_counts(packet, tlm_target_names, scope:) ⇒ Object
1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 |
# File 'lib/openc3/models/target_model.rb', line 1309 def self.sync_tlm_packet_counts(packet, tlm_target_names, scope:) if @@sync_packet_count_delay_seconds <= 0 # Perfect but slow method packet.received_count = increment_telemetry_count(packet.target_name, packet.packet_name, 1, scope: scope) else # Eventually consistent method # Only sync every period (default 1 second) to avoid hammering Redis # This is a trade off between speed and accuracy # The packet count is eventually consistent @@sync_packet_count_data[packet.target_name] ||= {} @@sync_packet_count_data[packet.target_name][packet.packet_name] ||= 0 @@sync_packet_count_data[packet.target_name][packet.packet_name] += 1 # Ensures counters change between syncs update_packet = System.telemetry.packet(packet.target_name, packet.packet_name) update_packet.received_count += 1 packet.received_count = update_packet.received_count # Check if we need to sync the packet counts if @@sync_packet_count_time.nil? or (Time.now - @@sync_packet_count_time) > @@sync_packet_count_delay_seconds @@sync_packet_count_time = Time.now # Increment global counters for packets received @@sync_packet_count_data.each do |target_name, packet_data| packet_data.each do |packet_name, count| increment_telemetry_count(target_name, packet_name, count, scope: scope) end end @@sync_packet_count_data = {} # Get all the packet counts with the global counters tlm_target_names.each do |target_name| get_all_telemetry_counts(target_name, scope: scope).each do |packet_name, count| begin update_packet = System.telemetry.packet(target_name, packet_name) update_packet.received_count = count.to_i rescue RuntimeError key = "#{target_name} #{packet_name}" unless @@stale_packet_keys_warned.include?(key) @@stale_packet_keys_warned.add(key) Logger.warn("Stale tlmcnt Redis key detected for unknown packet #{key} - ignoring") end end end end get_all_telemetry_counts('UNKNOWN', scope: scope).each do |packet_name, count| begin update_packet = System.telemetry.packet('UNKNOWN', packet_name) update_packet.received_count = count.to_i rescue RuntimeError key = "UNKNOWN #{packet_name}" unless @@stale_packet_keys_warned.include?(key) @@stale_packet_keys_warned.add(key) Logger.warn("Stale tlmcnt Redis key detected for unknown packet #{key} - ignoring") end end end end end end |
Instance Method Details
#add_topics_to_microservice(microservice_name, topics) ⇒ Object
933 934 935 936 937 938 939 |
# File 'lib/openc3/models/target_model.rb', line 933 def add_topics_to_microservice(microservice_name, topics) model = MicroserviceModel.get_model(name: microservice_name, scope: @scope) model.topics.concat(topics) model.topics.uniq! model.ignore_changes = true # Don't restart the microservice right now model.update end |
#as_json(*_a) ⇒ Object
441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 |
# File 'lib/openc3/models/target_model.rb', line 441 def as_json(*_a) { 'name' => @name, 'folder_name' => @folder_name, 'requires' => @requires, 'ignored_parameters' => @ignored_parameters, 'ignored_items' => @ignored_items, 'limits_groups' => @limits_groups, 'stored_limits_mode' => @stored_limits_mode, 'cmd_tlm_files' => @cmd_tlm_files, 'id' => @id, 'updated_at' => @updated_at, 'plugin' => @plugin, 'cmd_buffer_depth' => @cmd_buffer_depth, 'cmd_log_cycle_time' => @cmd_log_cycle_time, 'cmd_log_cycle_size' => @cmd_log_cycle_size, 'cmd_log_retain_time' => @cmd_log_retain_time, 'tlm_buffer_depth' => @tlm_buffer_depth, 'tlm_log_cycle_time' => @tlm_log_cycle_time, 'tlm_log_cycle_size' => @tlm_log_cycle_size, 'tlm_log_retain_time' => @tlm_log_retain_time, 'cmd_decom_retain_time' => @cmd_decom_retain_time, 'tlm_decom_retain_time' => @tlm_decom_retain_time, 'cleanup_poll_time' => @cleanup_poll_time, 'needs_dependencies' => @needs_dependencies, 'target_microservices' => @target_microservices.as_json(), 'disable_erb' => @disable_erb, 'shard' => @shard, 'db_shard' => @db_shard, } end |
#build_target_archive(temp_dir, target_folder) ⇒ Object
735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 |
# File 'lib/openc3/models/target_model.rb', line 735 def build_target_archive(temp_dir, target_folder) target_files = [] Find.find(target_folder) { |file| target_files << file } target_files.sort! @id = OpenC3.hash_files(target_files, nil, 'SHA256').hexdigest File.open(File.join(target_folder, 'target_id.txt'), 'wb') { |file| file.write(@id) } key = "#{@scope}/targets/#{@name}/target_id.txt" @bucket.put_object(bucket: ENV['OPENC3_CONFIG_BUCKET'], key: key, body: @id) # Create target archive zip file prefix = File.dirname(target_folder) + '/' output_file = File.join(temp_dir, @name + '_' + @id + '.zip') Zip.continue_on_exists_proc = true Zip::File.open(output_file, create: true) do |zipfile| target_files.each do |target_file| zip_file_path = target_file.delete_prefix(prefix) if File.directory?(target_file) zipfile.mkdir(zip_file_path) else zipfile.add(zip_file_path, target_file) end end end # Write Target Archive to bucket File.open(output_file, 'rb') do |file| bucket_key = key = "#{@scope}/target_archives/#{@name}/#{@name}_current.zip" @bucket.put_object(bucket: ENV['OPENC3_CONFIG_BUCKET'], key: bucket_key, body: file) end File.open(output_file, 'rb') do |file| bucket_key = key = "#{@scope}/target_archives/#{@name}/#{@name}_#{@id}.zip" @bucket.put_object(bucket: ENV['OPENC3_CONFIG_BUCKET'], key: bucket_key, body: file) end end |
#deploy(gem_path, variables, validate_only: false) ⇒ Object
579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 |
# File 'lib/openc3/models/target_model.rb', line 579 def deploy(gem_path, variables, validate_only: false) variables["target_name"] = @name start_path = "/targets/#{@folder_name}/" temp_dir = Dir.mktmpdir found = false begin target_path = gem_path + start_path + "**/*" Dir.glob(target_path) do |filename| next if filename == '.' or filename == '..' or File.directory?(filename) path = filename.split(gem_path)[-1] target_folder_path = path.split(start_path)[-1] key = "#{@scope}/targets/#{@name}/#{target_folder_path}" # Load target files @filename = filename # For render data = File.read(filename, mode: "rb") erb_disabled = check_disable_erb(filename) begin unless erb_disabled OpenC3.set_working_dir(File.dirname(filename)) do if ERB_EXTENSIONS.include?(File.extname(filename).downcase) and File.basename(filename)[0] != '_' data = ERB.new(data.force_encoding("UTF-8").comment_erb(), trim_mode: "-").result(binding.set_variables(variables)) end end end rescue => e # ERB error parsing a screen is just a logger error because life can go on # With cmd/tlm or scripts this is a serious error and we raise if (filename.include?('/screens/')) Logger.error("ERB error parsing #{key} due to #{e.}") else raise "ERB error parsing #{key} due to #{e.}" end end local_path = File.join(temp_dir, @name, target_folder_path) FileUtils.mkdir_p(File.dirname(local_path)) File.open(local_path, 'wb') { |file| file.write(data) } found = true @bucket.put_object(bucket: ENV['OPENC3_CONFIG_BUCKET'], key: key, body: data) unless validate_only end raise "No target files found at #{target_path}" unless found target_folder = File.join(temp_dir, @name) # Build a System for just this target system = System.new([@name], temp_dir) if variables["xtce_output"] puts "Converting target #{@name} to .xtce files in #{variables["xtce_output"]}/#{@name}" puts " Using mnemonic '#{variables['time_association_name']}' as the packet time item." system.packet_config.to_xtce(variables["xtce_output"], variables['time_association_name']) end unless validate_only build_target_archive(temp_dir, target_folder) system = update_store(system) deploy_microservices(gem_path, variables, system) ConfigTopic.write({ kind: 'created', type: 'target', name: @name, plugin: @plugin }, scope: @scope) end ensure FileUtils.remove_entry_secure(temp_dir, true) end end |
#deploy_cleanup_microservice(gem_path, variables, instance = nil, parent = nil) ⇒ Object
1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 |
# File 'lib/openc3/models/target_model.rb', line 1054 def deploy_cleanup_microservice(gem_path, variables, instance = nil, parent = nil) microservice_name = "#{@scope}__CLEANUP#{instance}__#{@name}" microservice = MicroserviceModel.new( name: microservice_name, cmd: ["ruby", "cleanup_microservice.rb", microservice_name], work_dir: '/openc3/lib/openc3/microservices', plugin: @plugin, parent: parent, shard: @shard, db_shard: @db_shard, scope: @scope ) microservice.create microservice.deploy(gem_path, variables) @children << microservice_name if parent Logger.info "Configured microservice #{microservice_name}" end |
#deploy_commmandlog_microservice(gem_path, variables, topics, instance = nil, parent = nil) ⇒ Object
941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 |
# File 'lib/openc3/models/target_model.rb', line 941 def deploy_commmandlog_microservice(gem_path, variables, topics, instance = nil, parent = nil) microservice_name = "#{@scope}__COMMANDLOG#{instance}__#{@name}" microservice = MicroserviceModel.new( name: microservice_name, folder_name: @folder_name, cmd: ["ruby", "log_microservice.rb", microservice_name], work_dir: '/openc3/lib/openc3/microservices', options: [ ["RAW_OR_DECOM", "RAW"], ["CMD_OR_TLM", "CMD"], ["CYCLE_TIME", @cmd_log_cycle_time], ["CYCLE_SIZE", @cmd_log_cycle_size], ["BUFFER_DEPTH", @cmd_buffer_depth] ], topics: topics, plugin: @plugin, parent: parent, needs_dependencies: @needs_dependencies, shard: @shard, db_shard: @db_shard, scope: @scope ) microservice.create microservice.deploy(gem_path, variables) @children << microservice_name if parent Logger.info "Configured microservice #{microservice_name}" end |
#deploy_decom_microservice(target, gem_path, variables, topics, instance = nil, parent = nil) ⇒ Object
997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 |
# File 'lib/openc3/models/target_model.rb', line 997 def deploy_decom_microservice(target, gem_path, variables, topics, instance = nil, parent = nil) microservice_name = "#{@scope}__DECOM#{instance}__#{@name}" # Assume Ruby initially filename = 'decom_microservice.rb' work_dir = '/openc3/lib/openc3/microservices' language_cmd = target.language if target.language == 'python' filename = 'decom_microservice.py' work_dir.sub!('openc3/lib', 'openc3/python') parent = nil # Use venv Python to ensure editable packages are found language_cmd = ENV['OPENC3_PYTHON_BIN'] || '/openc3/python/.venv/bin/python' end microservice = MicroserviceModel.new( name: microservice_name, folder_name: @folder_name, cmd: [language_cmd, filename, microservice_name], work_dir: work_dir, topics: topics, target_names: [@name], plugin: @plugin, parent: parent, needs_dependencies: @needs_dependencies, shard: @shard, db_shard: @db_shard, scope: @scope ) microservice.create microservice.deploy(gem_path, variables) @children << microservice_name if parent Logger.info "Configured microservice #{microservice_name}" end |
#deploy_microservices(gem_path, variables, system) ⇒ Object
1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 |
# File 'lib/openc3/models/target_model.rb', line 1136 def deploy_microservices(gem_path, variables, system) command_topic_list = [] decom_command_topic_list = [] packet_topic_list = [] decom_topic_list = [] begin system.commands.packets(@name).each do |packet_name, _packet| command_topic_list << "#{@scope}__COMMAND__{#{@name}}__#{packet_name}" decom_command_topic_list << "#{@scope}__DECOMCMD__{#{@name}}__#{packet_name}" end rescue # No command packets for this target end begin system.telemetry.packets(@name).each do |packet_name, _packet| packet_topic_list << "#{@scope}__TELEMETRY__{#{@name}}__#{packet_name}" decom_topic_list << "#{@scope}__DECOM__{#{@name}}__#{packet_name}" end rescue # No telemetry packets for this target end @parent = nil %w(DECOM COMMANDLOG PACKETLOG CLEANUP).each do |type| unless @target_microservices[type] @parent = "#{@scope}__MULTI__#{@name}" break end end unless command_topic_list.empty? # CommandLog Microservice deploy_target_microservices('COMMANDLOG', command_topic_list, "#{@scope}__COMMAND__{#{@name}}") do |topics, instance, parent| deploy_commmandlog_microservice(gem_path, variables, topics, instance, parent) end end unless packet_topic_list.empty? # PacketLog Microservice deploy_target_microservices('PACKETLOG', packet_topic_list, "#{@scope}__TELEMETRY__{#{@name}}") do |topics, instance, parent| deploy_packetlog_microservice(gem_path, variables, topics, instance, parent) end end # Decommutation Microservice - also handles build_cmd / inject_tlm / # get_tlm_buffer via the DECOMINTERFACE topic, so deploy whenever the # target has commands or telemetry, not just telemetry. if packet_topic_list.any? deploy_target_microservices('DECOM', packet_topic_list, "#{@scope}__TELEMETRY__{#{@name}}") do |topics, instance, parent| deploy_decom_microservice(system.targets[@name], gem_path, variables, topics, instance, parent) end elsif command_topic_list.any? # Cmd-only target: deploy DECOM with no tlm topics so build_cmd works. # DecomMicroservice subscribes to DECOMINTERFACE in its initializer. deploy_decom_microservice(system.targets[@name], gem_path, variables, [], nil, @parent) end # TSDB Microservice - subscribes to both decommutated telemetry and commands tsdb_topic_list = decom_topic_list + decom_command_topic_list if !tsdb_topic_list.empty? and ENV['OPENC3_TSDB_HOSTNAME'] and ENV['OPENC3_TSDB_QUERY_PORT'] and ENV['OPENC3_TSDB_INGEST_PORT'] and ENV['OPENC3_TSDB_USERNAME'] and ENV['OPENC3_TSDB_PASSWORD'] deploy_target_microservices('TSDB', tsdb_topic_list, "#{@scope}__DECOM") do |topics, instance, parent| deploy_tsdb_microservice(gem_path, variables, topics, instance, parent) end end if @cmd_log_retain_time or @tlm_log_retain_time # Cleanup Microservice deploy_target_microservices('CLEANUP', nil, nil) do |_, instance, parent| deploy_cleanup_microservice(gem_path, variables, instance, parent) end end if @parent # Multi Microservice to parent other target microservices deploy_multi_microservice(gem_path, variables) end end |
#deploy_multi_microservice(gem_path, variables, instance = nil) ⇒ Object
1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 |
# File 'lib/openc3/models/target_model.rb', line 1072 def deploy_multi_microservice(gem_path, variables, instance = nil) if @children.length > 0 microservice_name = "#{@scope}__MULTI#{instance}__#{@name}" microservice = MicroserviceModel.new( name: microservice_name, cmd: ["ruby", "multi_microservice.rb", *@children], work_dir: '/openc3/lib/openc3/microservices', plugin: @plugin, needs_dependencies: @needs_dependencies, shard: @shard, db_shard: @db_shard, scope: @scope ) microservice.create microservice.deploy(gem_path, variables) Logger.info "Configured microservice #{microservice_name}" end end |
#deploy_packetlog_microservice(gem_path, variables, topics, instance = nil, parent = nil) ⇒ Object
969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 |
# File 'lib/openc3/models/target_model.rb', line 969 def deploy_packetlog_microservice(gem_path, variables, topics, instance = nil, parent = nil) microservice_name = "#{@scope}__PACKETLOG#{instance}__#{@name}" microservice = MicroserviceModel.new( name: microservice_name, folder_name: @folder_name, cmd: ["ruby", "log_microservice.rb", microservice_name], work_dir: '/openc3/lib/openc3/microservices', options: [ ["RAW_OR_DECOM", "RAW"], ["CMD_OR_TLM", "TLM"], ["CYCLE_TIME", @tlm_log_cycle_time], ["CYCLE_SIZE", @tlm_log_cycle_size], ["BUFFER_DEPTH", @tlm_buffer_depth] ], topics: topics, plugin: @plugin, parent: parent, needs_dependencies: @needs_dependencies, shard: @shard, db_shard: @db_shard, scope: @scope ) microservice.create microservice.deploy(gem_path, variables) @children << microservice_name if parent Logger.info "Configured microservice #{microservice_name}" end |
#deploy_target_microservices(type, base_topic_list, topic_prefix) ⇒ Object
1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 |
# File 'lib/openc3/models/target_model.rb', line 1091 def deploy_target_microservices(type, base_topic_list, topic_prefix) target_microservices = @target_microservices[type] if target_microservices # These are stand alone microservice(s) ... not part of MULTI if base_topic_list # Only create the microservice if there are topics # This prevents creation of DECOM with no TLM Packets (for example) deploy_count = 0 all_topics = base_topic_list.dup # Figure out if there are individual packets assigned to this microservice target_microservices.sort! {|a, b| a.length <=> b.length} target_microservices.each_with_index do |packet_names, _index| topics = [] packet_names.each do |packet_name| topics << "#{topic_prefix}__#{packet_name}" end topics = all_topics.dup if topics.length <= 0 if topics.length > 0 instance = nil instance = deploy_count unless deploy_count == 0 yield topics, instance, nil deploy_count += 1 topics.each do |topic| all_topics.delete(topic) end end end # If there are any topics (packets) left over that haven't been # explicitly handled above, spawn another microservice if all_topics.length > 0 instance = nil instance = deploy_count unless deploy_count == 0 yield all_topics, instance, nil end else # Do not spawn the microservice yield nil, nil, nil end else # Not a stand alone microservice ... part of MULTI yield base_topic_list, nil, @parent if not base_topic_list or base_topic_list.length > 0 end end |
#deploy_tsdb_microservice(gem_path, variables, topics, instance = nil, parent = nil) ⇒ Object
1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 |
# File 'lib/openc3/models/target_model.rb', line 1030 def deploy_tsdb_microservice(gem_path, variables, topics, instance = nil, parent = nil) microservice_name = "#{@scope}__TSDB#{instance}__#{@name}" = [] << ["CMD_DECOM_RETAIN_TIME", @cmd_decom_retain_time] if @cmd_decom_retain_time << ["TLM_DECOM_RETAIN_TIME", @tlm_decom_retain_time] if @tlm_decom_retain_time microservice = MicroserviceModel.new( name: microservice_name, folder_name: @folder_name, cmd: [ENV['OPENC3_PYTHON_BIN'] || '/openc3/python/.venv/bin/python', "tsdb_microservice.py", microservice_name], work_dir: "/openc3/python/openc3/microservices", options: , topics: topics, plugin: @plugin, parent: nil, needs_dependencies: @needs_dependencies, shard: @shard, db_shard: @db_shard, scope: @scope ) microservice.create microservice.deploy(gem_path, variables) Logger.info "Configured microservice #{microservice_name}" end |
#dynamic_update(packets, cmd_or_tlm = :TELEMETRY, filename = "dynamic_tlm.txt") ⇒ Object
NOTE: If you call dynamic_update multiple times you should specify a different filename parameter or the last one will be overwritten
867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 |
# File 'lib/openc3/models/target_model.rb', line 867 def dynamic_update(packets, cmd_or_tlm = :TELEMETRY, filename = "dynamic_tlm.txt") # Build hash of targets/packets packet_hash = {} packets.each do |packet| target_name = packet.target_name.upcase packet_hash[target_name] ||= {} packet_name = packet.packet_name.upcase packet_hash[target_name][packet_name] = packet end # Update Redis if cmd_or_tlm == :TELEMETRY update_store_telemetry(packet_hash, clear_old: false) update_store_item_map() else update_store_commands(packet_hash, clear_old: false) end # Build dynamic file for cmd_tlm configs = {} packets.each do |packet| target_name = packet.target_name.upcase configs[target_name] ||= "" config = configs[target_name] config << packet.to_config(cmd_or_tlm) config << "\n" end configs.each do |target_name, config| bucket_key = "#{@scope}/targets_modified/#{target_name}/cmd_tlm/#{filename}" client = Bucket.getClient() client.put_object( # Use targets_modified to save modifications # This keeps the original target clean (read-only) bucket: ENV['OPENC3_CONFIG_BUCKET'], key: bucket_key, body: config ) end # Inform microservices of new topics # Need to tell loggers to log, and decom to decom # We do this for no downtime raw_topics = [] decom_topics = [] packets.each do |packet| if cmd_or_tlm == :TELEMETRY raw_topics << "#{@scope}__TELEMETRY__{#{@name}}__#{packet.packet_name.upcase}" decom_topics << "#{@scope}__DECOM__{#{@name}}__#{packet.packet_name.upcase}" else raw_topics << "#{@scope}__COMMAND__{#{@name}}__#{packet.packet_name.upcase}" decom_topics << "#{@scope}__DECOMCMD__{#{@name}}__#{packet.packet_name.upcase}" end end if cmd_or_tlm == :TELEMETRY Topic.write_topic("MICROSERVICE__#{@scope}__PACKETLOG__#{@name}", {'command' => 'ADD_TOPICS', 'topics' => raw_topics.as_json.to_json}, db_shard: @db_shard) add_topics_to_microservice("#{@scope}__PACKETLOG__#{@name}", raw_topics) Topic.write_topic("MICROSERVICE__#{@scope}__DECOM__#{@name}", {'command' => 'ADD_TOPICS', 'topics' => raw_topics.as_json.to_json}, db_shard: @db_shard) add_topics_to_microservice("#{@scope}__DECOM__#{@name}", raw_topics) else Topic.write_topic("MICROSERVICE__#{@scope}__COMMANDLOG__#{@name}", {'command' => 'ADD_TOPICS', 'topics' => raw_topics.as_json.to_json}, db_shard: @db_shard) add_topics_to_microservice("#{@scope}__COMMANDLOG__#{@name}", raw_topics) end Topic.write_topic("MICROSERVICE__#{@scope}__TSDB__#{@name}", {'command' => 'ADD_TOPICS', 'topics' => decom_topics.as_json.to_json}, db_shard: @db_shard) add_topics_to_microservice("#{@scope}__TSDB__#{@name}", decom_topics) end |
#handle_config(parser, keyword, parameters) ⇒ Object
Handles Target specific configuration keywords
474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 |
# 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 raw 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', 'CMD_DECOM_LOG_CYCLE_SIZE', 'CMD_DECOM_LOG_RETAIN_TIME' # DEPRECATED keywords - do nothing 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 raw 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', 'TLM_DECOM_LOG_CYCLE_SIZE', 'TLM_DECOM_LOG_RETAIN_TIME' # DEPRECATED keywords - do nothing when 'CMD_DECOM_RETAIN_TIME' parser.verify_num_parameters(1, 1, "#{keyword} <Retention time with unit (e.g., 30d, 1y) - nil = Forever>") @cmd_decom_retain_time = ConfigParser.handle_nil(parameters[0]) if @cmd_decom_retain_time and !@cmd_decom_retain_time.match?(/^\d+[hdwMy]$/) raise ConfigParser::Error.new(parser, "CMD_DECOM_RETAIN_TIME must be a number followed by h, d, w, M, or y (e.g., 24h, 7d, 1y)") end when 'TLM_DECOM_RETAIN_TIME' parser.verify_num_parameters(1, 1, "#{keyword} <Retention time with unit (e.g., 30d, 1y) - nil = Forever>") @tlm_decom_retain_time = ConfigParser.handle_nil(parameters[0]) if @tlm_decom_retain_time and !@tlm_decom_retain_time.match?(/^\d+[hdwMy]$/) raise ConfigParser::Error.new(parser, "TLM_DECOM_RETAIN_TIME must be a number followed by h, d, w, M, or y (e.g., 24h, 7d, 1y)") end when 'REDUCED_MINUTE_LOG_RETAIN_TIME', 'REDUCED_HOUR_LOG_RETAIN_TIME', 'REDUCED_DAY_LOG_RETAIN_TIME', 'REDUCED_LOG_RETAIN_TIME' # DEPRECATED when 'REDUCER_DISABLE', 'REDUCER_DISABLED', 'REDUCER_MAX_CPU_UTILIZATION', 'REDUCED_MAX_CPU_UTILIZATION' # DEPRECATED when 'LOG_RETAIN_TIME' parser.verify_num_parameters(1, 1, "#{keyword} <Retention time for all raw 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 @tlm_log_retain_time = log_retain_time.to_i end 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 PACKETLOG CLEANUP>") type = parameters[0].to_s.upcase unless %w(DECOM COMMANDLOG PACKETLOG 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 == '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]) when 'DB_SHARD' parser.verify_num_parameters(1, 1, "#{keyword} <Shard Number Starting from 0>") @db_shard = Integer(parameters[0]) when 'STORED_LIMITS_MODE' parser.verify_num_parameters(1, 1, "#{keyword} <PROCESS, LOG, or DISABLE>") mode = parameters[0].to_s.upcase unless %w(PROCESS LOG DISABLE).include?(mode) raise ConfigParser::Error.new(parser, "STORED_LIMITS_MODE must be one of PROCESS, LOG, or DISABLE") end @stored_limits_mode = mode else raise ConfigParser::Error.new(parser, "Unknown keyword and parameters for Target: #{keyword} #{parameters.join(" ")}") end return nil end |
#render(template_name, options = {}) ⇒ Object
Called by the ERB template to render a partial
704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 |
# File 'lib/openc3/models/target_model.rb', line 704 def render(template_name, = {}) raise "Partial name '#{template_name}' must begin with an underscore." if File.basename(template_name)[0] != '_' b = binding b.local_variable_set(:target_name, @name) if [:locals] [:locals].each { |key, value| b.local_variable_set(key, value) } end # Assume the file is there. If not we raise a pretty obvious error if File.(template_name) == template_name # absolute path path = template_name else # relative to the current @filename path = File.join(File.dirname(@filename), template_name) end data = File.read(path, mode: "rb") erb_disabled = check_disable_erb(path) begin if erb_disabled return data else OpenC3.set_working_dir(File.dirname(path)) do return ERB.new(data.force_encoding("UTF-8").comment_erb(), trim_mode: "-").result(b) end end rescue => e raise "ERB error parsing: #{path}: #{e.formatted}" end end |
#undeploy ⇒ Object
641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 |
# File 'lib/openc3/models/target_model.rb', line 641 def undeploy prefix = "#{@scope}/targets/#{@name}/" objects = @bucket.list_objects(bucket: ENV['OPENC3_CONFIG_BUCKET'], prefix: prefix) keys = objects.map(&:key) if keys.length > 0 # Batch delete in chunks of 1000 (S3 limit) keys.each_slice(1000) do |key_batch| @bucket.delete_objects(bucket: ENV['OPENC3_CONFIG_BUCKET'], keys: key_batch) end end self.class.get_model(name: @name, scope: @scope).limits_groups.each do |group| Store.hdel("#{@scope}__limits_groups", group) end self.class.packets(@name, type: :CMD, scope: @scope).each do |packet| Topic.del("#{@scope}__COMMAND__{#{@name}}__#{packet['packet_name']}", db_shard: @db_shard) Topic.del("#{@scope}__DECOMCMD__{#{@name}}__#{packet['packet_name']}", db_shard: @db_shard) end self.class.packets(@name, scope: @scope).each do |packet| Topic.del("#{@scope}__TELEMETRY__{#{@name}}__#{packet['packet_name']}", db_shard: @db_shard) Topic.del("#{@scope}__DECOM__{#{@name}}__#{packet['packet_name']}", db_shard: @db_shard) CvtModel.del(target_name: @name, packet_name: packet['packet_name'], scope: @scope) end LimitsEventTopic.delete(@name, scope: @scope) db_shard_store = Store.instance(db_shard: @db_shard) db_shard_store.del("#{@scope}__openc3tlm__#{@name}") db_shard_store.del("#{@scope}__openc3cmd__#{@name}") db_shard_store.del("#{@scope}__TELEMETRYCNTS__{#{@name}}") db_shard_store.del("#{@scope}__COMMANDCNTS__{#{@name}}") # Note: these match the names of the services in deploy_microservices %w(MULTI DECOM COMMANDLOG PACKETLOG CLEANUP).each do |type| target_microservices = @target_microservices[type] if target_microservices max_instances = target_microservices.length + 1 else max_instances = 1 end max_instances.times do |index| instance = nil instance = index unless index == 0 model = MicroserviceModel.get_model(name: "#{@scope}__#{type}#{instance}__#{@name}", scope: @scope) model.destroy if model end end # Delete item_map item_map_key = "#{@scope}__#{@name}__item_to_packet_map" db_shard_store.del(item_map_key) @@item_map_cache[@name] = nil topic = { kind: 'deleted', type: 'target', name: @name } # The UNKNOWN target doesn't have an associated plugin topic[:plugin] = @plugin if @plugin ConfigTopic.write(topic, scope: @scope) rescue Exception => e Logger.error("Error undeploying target model #{@name} in scope #{@scope} due to #{e}") end |
#update_store(system, clear_old: true) ⇒ Object
855 856 857 858 859 860 861 862 863 |
# File 'lib/openc3/models/target_model.rb', line 855 def update_store(system, clear_old: true) update_target_model(system) update_store_telemetry(system.telemetry.all, clear_old: clear_old) update_store_commands(system.commands.all, clear_old: clear_old) update_store_limits_groups(system) update_store_limits_sets(system) update_store_item_map() return system end |
#update_store_commands(packet_hash, clear_old: true) ⇒ Object
808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 |
# File 'lib/openc3/models/target_model.rb', line 808 def update_store_commands(packet_hash, clear_old: true) db_shard_store = Store.instance(db_shard: @db_shard) packet_hash.each do |target_name, packets| if clear_old db_shard_store.del("#{@scope}__openc3cmd__#{target_name}") db_shard_store.del("#{@scope}__COMMANDCNTS__{#{target_name}}") end packets.each do |packet_name, packet| Logger.debug "Configuring cmd packet: #{target_name} #{packet_name}" begin db_shard_store.hset("#{@scope}__openc3cmd__#{target_name}", packet_name, JSON.generate(packet.as_json, allow_nan: true)) rescue JSON::GeneratorError => e Logger.error("Invalid text present in #{target_name} #{packet_name} cmd packet") raise e end end end end |
#update_store_item_map ⇒ Object
847 848 849 850 851 852 853 |
# File 'lib/openc3/models/target_model.rb', line 847 def update_store_item_map # Create item_map item_map_key = "#{@scope}__#{@name}__item_to_packet_map" item_map = self.class.build_item_to_packet_map(@name, scope: @scope) Store.instance(db_shard: @db_shard).set(item_map_key, JSON.generate(item_map, allow_nan: true)) @@item_map_cache[@name] = [Time.now, item_map] end |
#update_store_limits_groups(system) ⇒ Object
827 828 829 830 831 832 833 834 835 836 |
# File 'lib/openc3/models/target_model.rb', line 827 def update_store_limits_groups(system) system.limits.groups.each do |group, items| begin Store.hset("#{@scope}__limits_groups", group, JSON.generate(items, allow_nan: true)) rescue JSON::GeneratorError => e Logger.error("Invalid text present in #{group} limits group") raise e end end end |
#update_store_limits_sets(system) ⇒ Object
838 839 840 841 842 843 844 845 |
# File 'lib/openc3/models/target_model.rb', line 838 def update_store_limits_sets(system) sets = Store.hgetall("#{@scope}__limits_sets") sets ||= {} system.limits.sets.each do |set| sets[set.to_s] = "false" unless sets.key?(set.to_s) end Store.hmset("#{@scope}__limits_sets", *sets) end |
#update_store_telemetry(packet_hash, clear_old: true) ⇒ Object
782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 |
# File 'lib/openc3/models/target_model.rb', line 782 def update_store_telemetry(packet_hash, clear_old: true) db_shard_store = Store.instance(db_shard: @db_shard) packet_hash.each do |target_name, packets| if clear_old db_shard_store.del("#{@scope}__openc3tlm__#{target_name}") db_shard_store.del("#{@scope}__openc3tlm__#{target_name}__allitems") db_shard_store.del("#{@scope}__TELEMETRYCNTS__{#{target_name}}") end packets.each do |packet_name, packet| Logger.debug "Configuring tlm packet: #{target_name} #{packet_name}" begin db_shard_store.hset("#{@scope}__openc3tlm__#{target_name}", packet_name, JSON.generate(packet.as_json, allow_nan: true)) rescue JSON::GeneratorError => e Logger.error("Invalid text present in #{target_name} #{packet_name} tlm packet") raise e end json_hash = {} packet.sorted_items.each do |item| json_hash[item.name] = nil TargetModel.add_to_target_allitems_list(target_name, item.name, scope: @scope) end CvtModel.set(json_hash, target_name: packet.target_name, packet_name: packet.packet_name, scope: @scope) end end end |
#update_target_model(system) ⇒ Object
770 771 772 773 774 775 776 777 778 779 780 |
# File 'lib/openc3/models/target_model.rb', line 770 def update_target_model(system) target = system.targets[@name] # Add in the information from the target and update @requires = target.requires @ignored_parameters = target.ignored_parameters @ignored_items = target.ignored_items @cmd_tlm_files = target.cmd_tlm_files @limits_groups = system.limits.groups.keys update() end |