Tlm screen api

demo/config/tools/cmd_tlm_server/cmd_tlm_server.txt

@@ -42,4 +42,4 @@ BACKGROUND_TASK example_background_task.rb
   STOPPED
 BACKGROUND_TASK limits_groups.rb 5 # Initial delay to allow interfaces to connect
 
-COLLECT_METADATA
+#COLLECT_METADATA

demo/procedures/replay_test.rb

@@ -0,0 +1,32 @@
+set_line_delay(0)
+set_replay_mode(true)
+filenames = get_output_logs_filenames()
+replay_select_file(filenames[-1])
+status = 'Analyzing'
+while status =~ /Analyzing/
+  status, playback_delay, filename, file_start, file_current, file_end, file_index, file_max_index = replay_status
+  wait(1)
+end
+100.times do
+  replay_step_forward()
+end
+100.times do
+  replay_step_back()
+end
+replay_move_end()
+replay_move_index(file_max_index / 2)
+replay_move_start()
+replay_set_playback_delay(0.1)
+replay_play()
+wait(2)
+replay_set_playback_delay(0.125)
+wait(5)
+replay_set_playback_delay(-1.0)
+wait(2)
+replay_set_playback_delay(nil)
+wait(4)
+replay_stop()
+replay_reverse_play()
+wait(5)
+cmd_tlm_clear_counters()
+cmd_tlm_reload()

lib/cosmos/gui/qt.rb

@@ -252,6 +252,7 @@ def self.check_log_configuration(packet_log_reader, log_filename)
         end
       end
     end
+    return config_change_success, change_error
   end
 end
 

lib/cosmos/interfaces/protocols/fixed_protocol.rb

@@ -53,7 +53,7 @@ def read_packet(packet)
 
     # Identifies an unknown buffer of data as a Packet. The raw data is
     # returned but the packet that matched is recorded so it can be set in the
-    # post_read_packet callback.
+    # read_packet callback.
     #
     # @return [String|Symbol] The identified packet data or :STOP if more data
     #   is required to build a packet
@@ -82,7 +82,7 @@ def identify_and_finish_packet
               return :STOP if @data.length < identified_packet.defined_length
             end
             # Set some variables so we can update the packet in
-            # post_read_packet
+            # read_packet
             @received_time = Time.now.sys
             @target_name = identified_packet.target_name
             @packet_name = identified_packet.packet_name

lib/cosmos/script/cmd_tlm_server.rb

@@ -196,5 +196,17 @@ def unsubscribe_server_messages(id)
     def get_server_message(id, non_block = false)
       return $cmd_tlm_server.get_server_message(id, non_block)
     end
+
+    def cmd_tlm_reload
+      return $cmd_tlm_server.cmd_tlm_reload
+    end
+
+    def cmd_tlm_clear_counters
+      return $cmd_tlm_server.cmd_tlm_clear_counters
+    end
+
+    def get_output_logs_filenames(filter = '*tlm.bin')
+      return $cmd_tlm_server.get_output_logs_filenames(filter)
+    end    
   end
 end

lib/cosmos/script/replay.rb

@@ -0,0 +1,60 @@
+# encoding: ascii-8bit
+
+# Copyright 2017 Ball Aerospace & Technologies Corp.
+# All Rights Reserved.
+#
+# This program is free software; you can modify and/or redistribute it
+# under the terms of the GNU General Public License
+# as published by the Free Software Foundation; version 3 with
+# attribution addendums as found in the LICENSE.txt
+
+module Cosmos
+
+  module Script
+    private
+
+    def replay_select_file(filename, packet_log_reader = "DEFAULT")
+      $cmd_tlm_server.replay_select_file(filename, packet_log_reader)
+    end
+
+    def replay_status
+      $cmd_tlm_server.replay_status
+    end
+
+    def replay_set_playback_delay(delay)
+      $cmd_tlm_server.replay_set_playback_delay(delay)
+    end
+
+    def replay_play
+      $cmd_tlm_server.replay_play
+    end
+
+    def replay_reverse_play
+      $cmd_tlm_server.replay_reverse_play
+    end
+
+    def replay_stop
+      $cmd_tlm_server.replay_stop
+    end
+
+    def replay_step_forward
+      $cmd_tlm_server.replay_step_forward
+    end
+
+    def replay_step_back
+      $cmd_tlm_server.replay_step_back
+    end
+
+    def replay_move_start
+      $cmd_tlm_server.replay_move_start
+    end
+
+    def replay_move_end
+      $cmd_tlm_server.replay_move_end
+    end
+
+    def replay_move_index(index)
+      $cmd_tlm_server.replay_move_index(index)
+    end    
+  end
+end

lib/cosmos/script/script.rb

@@ -12,6 +12,7 @@
 require 'cosmos/io/json_drb_object'
 require 'cosmos/tools/cmd_tlm_server/cmd_tlm_server'
 require 'cosmos/script/cmd_tlm_server'
+require 'cosmos/script/replay'
 require 'cosmos/script/commands'
 require 'cosmos/script/telemetry'
 require 'cosmos/script/limits'
@@ -20,6 +21,7 @@
 
 $cmd_tlm_server = nil
 $cmd_tlm_disconnect = false
+$cmd_tlm_replay_mode = false
 
 module Cosmos
   class CheckError < RuntimeError; end
@@ -39,6 +41,7 @@ module Script
     # Called when this module is mixed in using "include Cosmos::Script"
     def self.included(base)
       $cmd_tlm_disconnect = false
+      $cmd_tlm_replay_mode = false
       $cmd_tlm_server = nil
       initialize_script_module()
     end
@@ -48,8 +51,12 @@ def initialize_script_module(config_file = CmdTlmServer::DEFAULT_CONFIG_FILE)
         # Start up a standalone CTS in disconnected mode
         $cmd_tlm_server = CmdTlmServer.new(config_file, false, true)
       else
-        # Start a Json connect to the real CTS server
-        $cmd_tlm_server = JsonDRbObject.new(System.connect_hosts['CTS_API'], System.ports['CTS_API'])
+        # Start a Json connect to the real server
+        if $cmd_tlm_replay_mode
+          $cmd_tlm_server = JsonDRbObject.new(System.connect_hosts['REPLAY_API'], System.ports['REPLAY_API'])
+        else
+          $cmd_tlm_server = JsonDRbObject.new(System.connect_hosts['CTS_API'], System.ports['CTS_API'])
+        end
       end
     end
 
@@ -72,5 +79,16 @@ def script_disconnect
       $cmd_tlm_server.disconnect if $cmd_tlm_server && !$cmd_tlm_disconnect
     end
 
+    def set_replay_mode(replay_mode)
+      if replay_mode != $cmd_tlm_replay_mode
+        $cmd_tlm_replay_mode = replay_mode
+        initialize_script_module()
+      end
+    end
+
+    def get_replay_mode
+      $cmd_tlm_replay_mode
+    end
+
   end
 end

lib/cosmos/script/tools.rb

@@ -92,6 +92,20 @@ def show_backtrace(value = true)
       end
     end
 
+    ###########################
+    # Telemetry Screen methods
+    ###########################
+
+    # Get the organized list of available telemetry screens
+    def get_screen_list(config_filename = nil, force_refresh = false)
+      $cmd_tlm_server.get_screen_list(config_filename, force_refresh)
+    end
+
+    # Get a specific screen definition
+    def get_screen_definition(screen_full_name, config_filename = nil, force_refresh = false)
+      $cmd_tlm_server.get_screen_definition(screen_full_name, config_filename, force_refresh)
+    end  
+
   end # module Script
 
 end # module Cosmos