Merge branch 'v6.0.0-dev' into add-supv-latchup-report

Reviewed-on: #271

CHANGELOG.md

@@ -10,6 +10,21 @@ list yields a list of all related PRs for each release.
 
 # [unreleased]
 
+# [v6.0.0] 2024-01-31
+
+## Changed
+
+- Bumped `tmccmd` to `v8.0.0rc1` to introduce new command tree handling.
+- Added new PLOC SUPV commands to test sets, cleaned up PLOC SUPV commanding.
+
+# [v5.13.0] 2024-01-30
+
+## Added
+
+- First variant of TM handling with a DB which might serve as a foundation for better TM
+  handling with an ORM in the future.
+- Added new parameter commands for PLOC MPSoC to skip SUPV commanding.
+
 # [v5.12.1] 2023-12-13
 
 ## Added

eive_tmtc/config/events.csv

@@ -88,7 +88,7 @@ Event ID (dec); Event ID (hex); Name; Severity; Description; File Path
 10804;0x2a34;FILENAME_TOO_LARGE_ERROR;LOW;P1: Transaction step ID, P2: 0 for source file name, 1 for dest file name;fsfw/src/fsfw/cfdp/handler/defs.h
 10805;0x2a35;HANDLING_CFDP_REQUEST_FAILED;LOW;CFDP request handling failed. P2: Returncode.;fsfw/src/fsfw/cfdp/handler/defs.h
 11200;0x2bc0;SAFE_RATE_VIOLATION;MEDIUM;The limits for the rotation in safe mode were violated.;mission/acs/defs.h
-11201;0x2bc1;SAFE_RATE_RECOVERY;MEDIUM;The system has recovered from a safe rate rotation violation.;mission/acs/defs.h
+11201;0x2bc1;RATE_RECOVERY;MEDIUM;The system has recovered from a rate rotation violation.;mission/acs/defs.h
 11202;0x2bc2;MULTIPLE_RW_INVALID;HIGH;Multiple RWs are invalid, uncommandable and therefore higher ACS modes cannot be maintained.;mission/acs/defs.h
 11203;0x2bc3;MEKF_INVALID_INFO;INFO;MEKF was not able to compute a solution. P1: MEKF state on exit;mission/acs/defs.h
 11204;0x2bc4;MEKF_RECOVERY;INFO;MEKF is able to compute a solution again.;mission/acs/defs.h
@@ -97,6 +97,7 @@ Event ID (dec); Event ID (hex); Name; Severity; Description; File Path
 11207;0x2bc7;SAFE_MODE_CONTROLLER_FAILURE;HIGH;The ACS safe mode controller was not able to compute a solution and has failed. P1: Missing information about magnetic field, P2: Missing information about rotational rate;mission/acs/defs.h
 11208;0x2bc8;TLE_TOO_OLD;INFO;The TLE for the SGP4 Propagator has become too old.;mission/acs/defs.h
 11209;0x2bc9;TLE_FILE_READ_FAILED;LOW;The TLE could not be read from the filesystem.;mission/acs/defs.h
+11210;0x2bca;PTG_RATE_VIOLATION;MEDIUM;The limits for the rotation in pointing mode were violated.;mission/acs/defs.h
 11300;0x2c24;SWITCH_CMD_SENT;INFO;Indicates that a FSFW object requested setting a switch P1: 1 if on was requested, 0 for off | P2: Switch Index;mission/power/defs.h
 11301;0x2c25;SWITCH_HAS_CHANGED;INFO;Indicated that a switch state has changed P1: New switch state, 1 for on, 0 for off | P2: Switch Index;mission/power/defs.h
 11302;0x2c26;SWITCHING_Q7S_DENIED;MEDIUM;No description;mission/power/defs.h

eive_tmtc/config/returnvalues.csv

@@ -454,6 +454,12 @@ Full ID (hex); Name; Description; Unique ID; Subsytem Name; File Path
 0x5208;IMTQ_CmdErrUnknown;No description;8;IMTQ_HANDLER;mission/acs/imtqHelpers.h
 0x5209;IMTQ_StartupCfgError;No description;9;IMTQ_HANDLER;mission/acs/imtqHelpers.h
 0x520a;IMTQ_UnexpectedSelfTestReply;The status reply to a self test command was received but no self test command has been sent. This should normally never happen.;10;IMTQ_HANDLER;mission/acs/imtqHelpers.h
+0x53a0;RWHA_InvalidSpeed;Action Message with invalid speed was received. Valid speeds must be in the range of [-65000, 1000] or [1000, 65000];160;RW_HANDLER;mission/acs/RwHandler.h
+0x53a1;RWHA_InvalidRampTime;Action Message with invalid ramp time was received.;161;RW_HANDLER;mission/acs/RwHandler.h
+0x53a2;RWHA_SetSpeedCommandInvalidLength;Received set speed command has invalid length. Should be 6.;162;RW_HANDLER;mission/acs/RwHandler.h
+0x53a3;RWHA_ExecutionFailed;Command execution failed;163;RW_HANDLER;mission/acs/RwHandler.h
+0x53a4;RWHA_CrcError;Reaction wheel reply has invalid crc;164;RW_HANDLER;mission/acs/RwHandler.h
+0x53a5;RWHA_ValueNotRead;No description;165;RW_HANDLER;mission/acs/RwHandler.h
 0x53b0;RWHA_SpiWriteFailure;No description;176;RW_HANDLER;mission/acs/rwHelpers.h
 0x53b1;RWHA_SpiReadFailure;Used by the spi send function to tell a failing read call;177;RW_HANDLER;mission/acs/rwHelpers.h
 0x53b2;RWHA_MissingStartSign;Can be used by the HDLC decoding mechanism to inform about a missing start sign 0x7E;178;RW_HANDLER;mission/acs/rwHelpers.h
@@ -499,12 +505,8 @@ Full ID (hex); Name; Description; Unique ID; Subsytem Name; File Path
 0x58a1;PLSPVhLP_ProcessTerminated;Process has been terminated by command;161;PLOC_SUPV_HELPER;linux/payload/PlocSupvUartMan.h
 0x58a2;PLSPVhLP_PathNotExists;Received command with invalid pathname;162;PLOC_SUPV_HELPER;linux/payload/PlocSupvUartMan.h
 0x58a3;PLSPVhLP_EventBufferReplyInvalidApid;Expected event buffer TM but received space packet with other APID;163;PLOC_SUPV_HELPER;linux/payload/PlocSupvUartMan.h
-0x59a0;SUSS_InvalidSpeed;Action Message with invalid speed was received. Valid speeds must be in the range of [-65000, 1000] or [1000, 65000];160;SUS_HANDLER;mission/acs/RwHandler.h
-0x59a1;SUSS_InvalidRampTime;Action Message with invalid ramp time was received.;161;SUS_HANDLER;mission/acs/RwHandler.h
-0x59a2;SUSS_SetSpeedCommandInvalidLength;Received set speed command has invalid length. Should be 6.;162;SUS_HANDLER;mission/acs/RwHandler.h
-0x59a3;SUSS_ExecutionFailed;Command execution failed;163;SUS_HANDLER;mission/acs/RwHandler.h
-0x59a4;SUSS_CrcError;Reaction wheel reply has invalid crc;164;SUS_HANDLER;mission/acs/RwHandler.h
-0x59a5;SUSS_ValueNotRead;No description;165;SUS_HANDLER;mission/acs/RwHandler.h
+0x59a0;SUSS_ErrorUnlockMutex;No description;160;SUS_HANDLER;mission/acs/archive/LegacySusHandler.h
+0x59a1;SUSS_ErrorLockMutex;No description;161;SUS_HANDLER;mission/acs/archive/LegacySusHandler.h
 0x5aa0;IPCI_PapbBusy;No description;160;CCSDS_IP_CORE_BRIDGE;linux/ipcore/PapbVcInterface.h
 0x5ba0;PTME_UnknownVcId;No description;160;PTME;linux/ipcore/Ptme.h
 0x5d01;STRHLP_SdNotMounted;SD card specified in path string not mounted;1;STR_HELPER;linux/acs/StrComHandler.h
@@ -593,9 +595,11 @@ Full ID (hex); Name; Description; Unique ID; Subsytem Name; File Path
 0x69b5;SPVRTVIF_SupvHelperExecuting;Supervisor helper task ist currently executing a command (wait until helper tas has finished or interrupt by sending the terminate command);181;SUPV_RETURN_VALUES_IF;linux/payload/plocSupvDefs.h
 0x69c0;SPVRTVIF_BufTooSmall;No description;192;SUPV_RETURN_VALUES_IF;linux/payload/plocSupvDefs.h
 0x69c1;SPVRTVIF_NoReplyTimeout;No description;193;SUPV_RETURN_VALUES_IF;linux/payload/plocSupvDefs.h
-0x6a00;ACSCTRL_FileDeletionFailed;File deletion failed and at least one file is still existent.;0;ACS_CTRL;mission/controller/AcsController.h
-0x6a01;ACSCTRL_WriteFileFailed;Writing the TLE to the file has failed.;1;ACS_CTRL;mission/controller/AcsController.h
-0x6a02;ACSCTRL_ReadFileFailed;Reading the TLE to the file has failed.;2;ACS_CTRL;mission/controller/AcsController.h
+0x6aa0;ACSCTRL_FileDeletionFailed;File deletion failed and at least one file is still existent.;160;ACS_CTRL;mission/controller/controllerdefinitions/AcsCtrlDefinitions.h
+0x6aa1;ACSCTRL_WriteFileFailed;Writing the TLE to the file has failed.;161;ACS_CTRL;mission/controller/controllerdefinitions/AcsCtrlDefinitions.h
+0x6aa2;ACSCTRL_ReadFileFailed;Reading the TLE to the file has failed.;162;ACS_CTRL;mission/controller/controllerdefinitions/AcsCtrlDefinitions.h
+0x6aa3;ACSCTRL_SingleRwUnavailable;A single RW has failed.;163;ACS_CTRL;mission/controller/controllerdefinitions/AcsCtrlDefinitions.h
+0x6aa4;ACSCTRL_MultipleRwUnavailable;Multiple RWs have failed.;164;ACS_CTRL;mission/controller/controllerdefinitions/AcsCtrlDefinitions.h
 0x6b02;ACSMEKF_MekfUninitialized;No description;2;ACS_MEKF;mission/controller/acs/MultiplicativeKalmanFilter.h
 0x6b03;ACSMEKF_MekfNoGyrData;No description;3;ACS_MEKF;mission/controller/acs/MultiplicativeKalmanFilter.h
 0x6b04;ACSMEKF_MekfNoModelVectors;No description;4;ACS_MEKF;mission/controller/acs/MultiplicativeKalmanFilter.h

eive_tmtc/pus_tc/tc_handler.py

@@ -124,40 +124,38 @@ class TcHandler(TcHandlerBase):
                 _LOGGER.info(
                     f"CFDP: Starting file put request with parameters:\n{put_req}"
                 )
+                assert put_req is not None
                 self.cfdp_in_ccsds_handler.cfdp_handler.put_request(put_req)
                 self.cfdp_handler_started = True
 
-                for source_pair, dest_pair in self.cfdp_in_ccsds_handler:
-                    pdu, sp = source_pair
-                    pdu = cast(PduHolder, pdu)
-                    if pdu.is_file_directive:
-                        if pdu.pdu_directive_type == DirectiveType.METADATA_PDU:
-                            metadata = pdu.to_metadata_pdu()
+                for source_pair, _ in self.cfdp_in_ccsds_handler:
+                    if source_pair is not None:
+                        pdu, sp = source_pair
+                        pdu = cast(PduHolder, pdu)
+                        if pdu.is_file_directive:
+                            if pdu.pdu_directive_type == DirectiveType.METADATA_PDU:
+                                metadata = pdu.to_metadata_pdu()
+                                self.queue_helper.add_log_cmd(
+                                    "CFDP Source: Sending Metadata PDU for file with size "
+                                    f"{metadata.file_size}"
+                                )
+                            elif pdu.pdu_directive_type == DirectiveType.EOF_PDU:
+                                self.queue_helper.add_log_cmd(
+                                    "CFDP Source: Sending EOF PDU"
+                                )
+                        else:
+                            fd_pdu = pdu.to_file_data_pdu()
                             self.queue_helper.add_log_cmd(
-                                "CFDP Source: Sending Metadata PDU for file with size "
-                                f"{metadata.file_size}"
+                                "CFDP Source: Sending File Data PDU for segment at offset "
+                                f"{fd_pdu.offset} with length {len(fd_pdu.file_data)}"
                             )
-                        elif pdu.pdu_directive_type == DirectiveType.EOF_PDU:
-                            self.queue_helper.add_log_cmd(
-                                "CFDP Source: Sending EOF PDU"
-                            )
-                    else:
-                        fd_pdu = pdu.to_file_data_pdu()
-                        self.queue_helper.add_log_cmd(
-                            "CFDP Source: Sending File Data PDU for segment at offset "
-                            f"{fd_pdu.offset} with length {len(fd_pdu.file_data)}"
-                        )
-                    self.queue_helper.add_ccsds_tc(sp)
-                    self.cfdp_in_ccsds_handler.confirm_source_packet_sent()
+                        self.queue_helper.add_ccsds_tc(sp)
                 self.cfdp_in_ccsds_handler.source_handler.state_machine()
 
     def queue_finished_cb(self, info: ProcedureWrapper):
         if info is not None:
             if info.proc_type == TcQueueEntryType.PUS_TC:
                 def_proc = info.to_def_procedure()
-                _LOGGER.info(
-                    f"Finished queue for service {def_proc.service} and op code"
-                    f" {def_proc.op_code}"
-                )
+                _LOGGER.info(f"Finished queue for command {def_proc.cmd_path}")
             elif info.proc_type == TcProcedureType.CFDP:
                 _LOGGER.info("Finished CFDP queue")

eive_tmtc/pus_tm/hk_handler.py

@@ -1,6 +1,7 @@
 """HK Handling for EIVE OBSW"""
 import dataclasses
 import logging
+import base64  # noqa
 import sqlite3
 from typing import List, cast
 from uuid import UUID
@@ -73,11 +74,12 @@ def handle_hk_packet(
         hk_data = tm_packet.tm_data[8:]
 
         if named_obj_id in hk_filter.object_ids:
+            # print(f"PUS TM Base64: {base64.b64encode(raw_tm)}")
             handle_regular_hk_print(
                 printer=printer,
+                packet_uuid=packet_uuid,
                 object_id=named_obj_id,
                 hk_packet=tm_packet,
-                tm_packet=tm_packet.pus_tm,
                 hk_data=hk_data,
                 db=db_con,
             )

eive_tmtc/tmtc/payload/ploc_supervisor.py

@@ -6,6 +6,7 @@
 @author J. Meier
 @date   10.07.2021
 """
+from datetime import datetime
 import enum
 import logging
 import struct
@@ -129,19 +130,20 @@ class OpCode:
     ON = "on"
     NORMAL = "nml"
     HK_TO_OBC = "hk_to_obc"
-    REQUEST_HK_SET_FROM_DEV = "req_hk_from_dev"
-    REQUEST_HK_SET = "req_hk"
+    REQUEST_GENERIC_HK_SET = "req_generic_hk"
     START_MPSOC = "start_mpsoc"
     SHUTDOWN_MPSOC = "stop_mpsoc"
     SEL_NVM = "sel_nvm"
     SET_TIME_REF = "set_time_ref"
     FACTORY_FLASH = "factory_flash"
-    REQ_BOOT_STATUS_REPORT = "boot_report"
     START_UPDATE = "start_update"
     PERFORM_UPDATE = "update"
     FACTORY_RESET = "factory_reset"
     MEM_CHECK = "mem_check"
     RESET_MPSOC = "reset_mpsoc"
+    SET_GPIO = "set_gpio"
+    READ_GPIO = "read_gpio"
+    READ_STATUS_REPORT = "read_status_report"
 
 
 class Info(str, enum.Enum):
@@ -149,19 +151,20 @@ class Info(str, enum.Enum):
     ON = "Switch On"
     NORMAL = "Switch Normal"
     HK_TO_OBC = "Request  HK from PLOC SUPV"
+    REQUEST_GENERIC_HK_SET = "Request prompted HK set from PLOC Handler"
     START_MPSOC = "Start MPSoC"
     SHUTDOWN_MPSOC = "Shutdown MPSoC"
-    REQUEST_HK_SET_FROM_DEV = "Request HK set from the device to the PLOC Handler"
-    REQUEST_HK_SET = "Request HK set from PLOC Handler"
     SET_TIME_REF = "Set time reference"
     FACTORY_FLASH = "Factory Flash Mode"
     PERFORM_UPDATE = "Start or continue MPSoC SW update at starting bytes"
     START_UPDATE = "Start new MPSoC SW update"
     FACTORY_RESET = "Factory Reset of loggers"
-    REQ_BOOT_STATUS_REPORT = "Request boot status report and HK"
     MEM_CHECK = "Memory Check"
     SEL_NVM = "Select NVM"
     RESET_MPSOC = "Reset MPSoC"
+    SET_GPIO = "Set GPIO"
+    READ_GPIO = "Read GPIO"
+    READ_STATUS_REPORT = "Read HK status report"
 
 
 def create_ploc_supv_node() -> CmdTreeNode:
@@ -198,7 +201,7 @@ def pack_ploc_supv_commands(q: DefaultPusQueueHelper, cmd_str: str):  # noqa C90
         q.add_log_cmd(f"{prefix}: {Info.HK_TO_OBC}")
         command = obyt + struct.pack("!I", SupvActionId.REQUEST_HK_REPORT)
         q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    elif cmd_str == OpCode.START_MPSOC:
+    if cmd_str == OpCode.START_MPSOC:
         q.add_log_cmd("PLOC Supervisor: Start MPSoC")
         command = obyt + struct.pack("!I", SupvActionId.START_MPSOC)
         q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
@@ -206,15 +209,11 @@ def pack_ploc_supv_commands(q: DefaultPusQueueHelper, cmd_str: str):  # noqa C90
         q.add_log_cmd("PLOC Supervisor: Shutdown MPSoC")
         command = object_id.as_bytes + struct.pack("!I", SupvActionId.SHUTWOWN_MPSOC)
         q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == OpCode.REQUEST_HK_SET:
-        q.add_log_cmd(f"{prefix}: {Info.REQUEST_HK_SET}")
-        sid = make_sid(object_id.as_bytes, prompt_set_id())
-        cmd = generate_one_hk_command(sid)
-        q.add_pus_tc(cmd)
-    if cmd_str == OpCode.REQUEST_HK_SET_FROM_DEV:
-        q.add_log_cmd(f"{prefix}: {Info.REQUEST_HK_SET_FROM_DEV}")
+    if cmd_str == OpCode.READ_STATUS_REPORT:
+        q.add_log_cmd(f"{prefix}: {Info.READ_STATUS_REPORT}")
         set_id = prompt_set_id()
         action_cmd = None
+        # First read the set from the device.
         if set_id == SetId.HK_REPORT:
             action_cmd = create_action_cmd(PLOC_SUPV_ID, SupvActionId.REQUEST_HK_REPORT)
         if set_id == SetId.ADC_REPORT:
@@ -225,8 +224,24 @@ def pack_ploc_supv_commands(q: DefaultPusQueueHelper, cmd_str: str):  # noqa C90
             action_cmd = create_action_cmd(
                 PLOC_SUPV_ID, SupvActionId.REQUEST_LOGGING_COUNTERS
             )
-        assert action_cmd is not None
+        if set_id == SetId.LATCHUP_REPORT:
+            action_cmd = create_action_cmd(
+                PLOC_SUPV_ID, SupvActionId.GET_LATCHUP_STATUS_REPORT
+            )
+        if set_id == SetId.BOOT_STATUS_REPORT:
+            action_cmd = create_action_cmd(
+                PLOC_SUPV_ID, SupvActionId.GET_BOOT_STATUS_REPORT
+            )
+        if action_cmd is None:
+            _LOGGER.warning(f"invalid set ID {set_id!r} for PLOC SUPV")
+            return
+        # Now dump the HK set.
+        sid = make_sid(object_id.as_bytes, set_id)
+        req_hk = generate_one_hk_command(sid)
         q.add_pus_tc(action_cmd)
+        q.add_wait_seconds(2.0)
+        q.add_pus_tc(req_hk)
+        assert action_cmd is not None
     elif cmd_str == OpCode.START_MPSOC:
         q.add_log_cmd("PLOC Supervisor: Start MPSoC")
         command = obyt + struct.pack("!I", SupvActionId.START_MPSOC)
@@ -286,32 +301,6 @@ def pack_ploc_supv_commands(q: DefaultPusQueueHelper, cmd_str: str):  # noqa C90
             + struct.pack("!I", boot_timeout)
         )
         q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "12":
-        q.add_log_cmd("PLOC Supervisor: Disable HK")
-        command = object_id.as_bytes + struct.pack("!I", SupvActionId.DISABLE_HK)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str in OpCode.REQ_BOOT_STATUS_REPORT:
-        q.add_log_cmd(f"{prefix}:  {Info.REQ_BOOT_STATUS_REPORT}")
-        command = object_id.as_bytes + struct.pack(
-            "!I", SupvActionId.GET_BOOT_STATUS_REPORT
-        )
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-        q.add_wait_seconds(2.0)
-        sid = make_sid(object_id.as_bytes, SetId.BOOT_STATUS_REPORT)
-        req_hk = generate_one_hk_command(sid)
-        q.add_pus_tc(req_hk)
-    if cmd_str == "17":
-        q.add_log_cmd("PLOC Supervisor: Enable latchup alert")
-        command = pack_lachtup_alert_cmd(object_id.as_bytes, True)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "18":
-        q.add_log_cmd("PLOC Supervisor: Disable latchup alert")
-        command = pack_lachtup_alert_cmd(object_id.as_bytes, False)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "20":
-        q.add_log_cmd("PLOC Supervisor: Set alert limit")
-        command = pack_set_alert_limit_cmd(object_id.as_bytes)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
     if cmd_str == "23":
         q.add_log_cmd("PLOC Supervisor: Set ADC enabled channels")
         command = pack_set_adc_enabled_channels_cmd(object_id.as_bytes)
@@ -324,31 +313,11 @@ def pack_ploc_supv_commands(q: DefaultPusQueueHelper, cmd_str: str):  # noqa C90
         q.add_log_cmd("PLOC Supervisor: Set ADC threshold")
         command = pack_set_adc_threshold_cmd(object_id.as_bytes)
         q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "26":
-        q.add_log_cmd("PLOC Supervisor: Request latchup status report")
-        command = object_id.as_bytes + struct.pack(
-            "!I", SupvActionId.GET_LATCHUP_STATUS_REPORT
-        )
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "27":
-        q.add_log_cmd("PLOC Supervisor: Copy ADC data to MRAM")
-        command = object_id.as_bytes + struct.pack(
-            "!I", SupvActionId.COPY_ADC_DATA_TO_MRAM
-        )
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "30":
-        q.add_log_cmd("PLOC Supervisor: Run auto EM tests")
-        command = pack_auto_em_tests_cmd(object_id.as_bytes)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "31":
-        q.add_log_cmd("PLOC Supervisor: Wipe MRAM")
-        command = pack_mram_wipe_cmd(object_id.as_bytes)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "35":
+    if cmd_str == OpCode.SET_GPIO:
         q.add_log_cmd("PLOC Supervisor: Set GPIO command")
         command = pack_set_gpio_cmd(object_id.as_bytes)
         q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "36":
+    if cmd_str == OpCode.READ_GPIO:
         q.add_log_cmd("PLOC Supervisor: Read GPIO command")
         command = pack_read_gpio_cmd(object_id.as_bytes)
         q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
@@ -384,40 +353,6 @@ def pack_ploc_supv_commands(q: DefaultPusQueueHelper, cmd_str: str):  # noqa C90
         q.add_log_cmd(f"{prefix}: {Info.FACTORY_FLASH}")
         command = object_id.as_bytes + struct.pack("!I", SupvActionId.FACTORY_FLASH)
         q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "47":
-        q.add_log_cmd("PLOC Supervisor: Enable auto TM")
-        command = object_id.as_bytes + struct.pack("!I", SupvActionId.ENABLE_AUTO_TM)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "48":
-        q.add_log_cmd("PLOC Supervisor: Disable auto TM")
-        command = object_id.as_bytes + struct.pack("!I", SupvActionId.DISABLE_AUTO_TM)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "51":
-        q.add_log_cmd("PLOC Supervisor: Logging request event buffers")
-        command = pack_logging_buffer_request(object_id.as_bytes)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "52":
-        q.add_log_cmd("PLOC Supervisor: Logging clear counters")
-        command = object_id.as_bytes + struct.pack(
-            "!I", SupvActionId.LOGGING_CLEAR_COUNTERS
-        )
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "53":
-        q.add_log_cmd("PLOC Supervisor: Logging set topic")
-        command = pack_logging_set_topic(object_id.as_bytes)
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "54":
-        q.add_log_cmd("PLOC Supervisor: Logging request counters")
-        command = object_id.as_bytes + struct.pack(
-            "!I", SupvActionId.REQUEST_LOGGING_COUNTERS
-        )
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
-    if cmd_str == "55":
-        q.add_log_cmd("PLOC Supervisor: Request ADC report")
-        command = object_id.as_bytes + struct.pack(
-            "!I", SupvActionId.REQUEST_ADC_REPORT
-        )
-        q.add_pus_tc(PusTelecommand(service=8, subservice=128, app_data=command))
     if cmd_str == "56":
         q.add_log_cmd("PLOC Supervisor: Reset PL")
         command = object_id.as_bytes + struct.pack("!I", SupvActionId.RESET_PL)
@@ -728,6 +663,8 @@ def handle_supv_hk_data(set_id: int, hk_data: bytes, pw: PrintWrapper):
         handle_adc_report(hk_data)
     elif set_id == SetId.COUNTERS_REPORT:
         handle_counters_report(hk_data)
+    elif set_id == SetId.LATCHUP_REPORT:
+        handle_latchup_status_report(hk_data)
     else:
         pw.dlog(f"PLOC SUPV: HK handling not implemented for set ID {set_id}")
         pw.dlog(f"Raw Data: 0x[{hk_data.hex(sep=',')}]")
@@ -869,3 +806,53 @@ def handle_counters_report(hk_data: bytes):
     print(f"MM task lost: {mm_task_lost}")
     print(f"HK task lost: {hk_task_lost}")
     print(f"DL task lost: {dl_task_lost}")
+
+
+def handle_latchup_status_report(hk_data: bytes):
+    # 1 byte ID, 7 times 2 bytes of counts, and 8 bytes of time and 1 byte sync status.
+    if len(hk_data) < 24:
+        raise ValueError("Latchup status report smaller than expected")
+    current_idx = 0
+    id = hk_data[current_idx]
+    current_idx += 1
+    counts_of_alerts = []
+    for _ in range(7):
+        counts_of_alerts.append(
+            struct.unpack("!H", hk_data[current_idx : current_idx + 2])[0]
+        )
+        current_idx += 2
+    print(f"ID: {id}")
+    print(f"Counts of alerts: {counts_of_alerts}")
+    time_ms = struct.unpack("!H", hk_data[current_idx : current_idx + 2])[0]
+    current_idx += 2
+    time_seconds = hk_data[current_idx]
+    current_idx += 1
+    time_minutes = hk_data[current_idx]
+    current_idx += 1
+    time_hour = hk_data[current_idx]
+    current_idx += 1
+    time_day = hk_data[current_idx]
+    current_idx += 1
+    time_month = hk_data[current_idx]
+    current_idx += 1
+    # Is stored as years since 1900.
+    time_year = 1900 + hk_data[current_idx]
+    current_idx += 1
+    is_synced = hk_data[current_idx]
+    print(f"Time Sync Status: {is_synced}")
+    try:
+        dt = datetime(
+            year=time_year,
+            month=time_month,
+            day=time_day,
+            hour=time_hour,
+            minute=time_minutes,
+            second=time_seconds,
+            microsecond=time_ms * 1000,
+        )
+        print(f"Time Now: {dt}")
+    except ValueError:
+        print(
+            f"Time: {time_day}.{time_month}.{time_year}T"
+            f"{time_hour}:{time_minutes}:{time_seconds}.{time_ms}"
+        )

pyproject.toml

@@ -6,7 +6,7 @@ build-backend = "setuptools.build_meta"
 name = "eive-tmtc"
 description = "TMTC Commander EIVE"
 readme = "README.md"
-version = "5.12.1"
+version = "5.13.0"
 requires-python = ">=3.10"
 license = {text = "Apache-2.0"}
 authors = [

tmtcc.py

@@ -7,19 +7,20 @@ from pathlib import Path
 from typing import Tuple
 
 import tmtccmd
-from spacepackets.cfdp import (
-    ChecksumType,
-    TransmissionMode,
-)
-from spacepackets.ecss import PusVerificator
-from spacepackets.version import get_version as get_sp_version
-from tmtccmd import BackendBase
 from cfdppy.handler import RemoteEntityCfgTable
 from cfdppy.mib import (
     IndicationCfg,
     LocalEntityCfg,
     RemoteEntityCfg,
 )
+from spacepackets.cfdp import (
+    ChecksumType,
+    TransmissionMode,
+)
+from spacepackets.ecss import PusVerificator
+from spacepackets.seqcount import FileSeqCountProvider, PusFileSeqCountProvider
+from spacepackets.version import get_version as get_sp_version
+from tmtccmd import BackendBase
 from tmtccmd.config import (
     SetupWrapper,
     default_json_path,
@@ -41,10 +42,8 @@ from tmtccmd.logging.pus import (
 )
 from tmtccmd.pus import VerificationWrapper
 from tmtccmd.tmtc import CcsdsTmHandler
-from spacepackets.seqcount import FileSeqCountProvider, PusFileSeqCountProvider
 
 from eive_tmtc import APP_LOGGER
-from eive_tmtc.pus_tm.pus_handler import PusHandler, UnknownApidHandler
 from eive_tmtc.cfdp.fault_handler import EiveCfdpFaultHandler
 from eive_tmtc.cfdp.handler import CfdpInCcsdsHandler
 from eive_tmtc.cfdp.tm import CfdpInCcsdsWrapper
@@ -57,6 +56,7 @@ from eive_tmtc.config.definitions import (
 )
 from eive_tmtc.config.hook import EiveHookObject
 from eive_tmtc.pus_tc.tc_handler import TcHandler
+from eive_tmtc.pus_tm.pus_handler import PusHandler, UnknownApidHandler
 
 _LOGGER = APP_LOGGER
 _LOG_LEVEL = logging.INFO
@@ -172,6 +172,7 @@ def setup_tmtc_handlers(
     ccsds_handler.add_apid_handler(pus_handler)
     ccsds_handler.add_apid_handler(cfdp_in_ccsds_wrapper)
     seq_count_provider = PusFileSeqCountProvider()
+    assert printer.file_logger is not None
     tc_handler = TcHandler(
         seq_count_provider=seq_count_provider,
         pus_verificator=verificator,