diff --git a/eive_tmtc/pus_tm/hk_handling.py b/eive_tmtc/pus_tm/hk_handling.py index b9020b0..e149371 100644 --- a/eive_tmtc/pus_tm/hk_handling.py +++ b/eive_tmtc/pus_tm/hk_handling.py @@ -44,6 +44,8 @@ _LOGGER = logging.getLogger(__name__) FORWARD_SENSOR_TEMPS = False +# TODO: Transform this into a CLI argument +HK_OUTPUT_LEVEL = 1 def handle_hk_packet( @@ -70,13 +72,14 @@ def handle_hk_packet( hk_data=hk_data, ) try: - handle_regular_hk_print( - printer=printer, - object_id=named_obj_id, - hk_packet=tm_packet, - tm=tm_packet.pus_tm, - hk_data=hk_data, - ) + if HK_OUTPUT_LEVEL > 0: + handle_regular_hk_print( + printer=printer, + object_id=named_obj_id, + hk_packet=tm_packet, + tm=tm_packet.pus_tm, + hk_data=hk_data, + ) except ValueError as e: _LOGGER.exception( f"{e} error when parsing HK data coming from {named_obj_id}" diff --git a/eive_tmtc/tmtc/core.py b/eive_tmtc/tmtc/core.py index c554aa8..c94f929 100644 --- a/eive_tmtc/tmtc/core.py +++ b/eive_tmtc/tmtc/core.py @@ -157,7 +157,9 @@ def add_core_controller_definitions(defs: TmtcDefinitionWrapper): oce.add(keys=OpCode.XSC_REBOOT_1_0, info="Reboot 1 0") oce.add(keys=OpCode.XSC_REBOOT_1_1, info="Reboot 1 1") oce.add(keys=OpCode.SET_PREF_SD, info=Info.SET_PREF_SD) - oce.add(keys=OpCode.READ_REBOOT_MECHANISM_INFO, info=Info.READ_REBOOT_MECHANISM_INFO) + oce.add( + keys=OpCode.READ_REBOOT_MECHANISM_INFO, info=Info.READ_REBOOT_MECHANISM_INFO + ) oce.add(keys=OpCode.OBSW_UPDATE_FROM_TMP, info=Info.OBSW_UPDATE_FROM_TMP) oce.add(keys=OpCode.OBSW_UPDATE_FROM_SD_0, info=Info.OBSW_UPDATE_FROM_SD_0) oce.add(keys=OpCode.OBSW_UPDATE_FROM_SD_1, info=Info.OBSW_UPDATE_FROM_SD_1) @@ -303,7 +305,7 @@ def pack_core_commands( # noqa C901 q.add_pus_tc( create_action_cmd( object_id=CORE_CONTROLLER_ID, - action_id=ActionId.READ_REBOOT_MECHANISM_INFO + action_id=ActionId.READ_REBOOT_MECHANISM_INFO, ) ) elif op_code == OpCode.DISABLE_REBOOT_FILE_HANDLING: @@ -622,7 +624,7 @@ def handle_core_ctrl_action_replies( handle_list_dir_dump_reply(pw, custom_data) -def handle_reboot_mechanism_info_reply(pw: PrintWrapper, custom_data : bytes): +def handle_reboot_mechanism_info_reply(pw: PrintWrapper, custom_data: bytes): pw.dlog("Received reboot mechansm information") fmt_str = "!BIIIIIBBBBBBBB" inc_len = struct.calcsize(fmt_str) @@ -642,8 +644,8 @@ def handle_reboot_mechanism_info_reply(pw: PrintWrapper, custom_data : bytes): last_chip, last_copy, next_chip, - next_copy - ) = struct.unpack(fmt_str, custom_data[: inc_len]) + next_copy, + ) = struct.unpack(fmt_str, custom_data[:inc_len]) pw.dlog(f"Enabled: {enabled}") pw.dlog(f"Max Count: {max_count}") pw.dlog(f"Count 00: {img00_count}") @@ -660,7 +662,7 @@ def handle_reboot_mechanism_info_reply(pw: PrintWrapper, custom_data : bytes): pw.dlog(f"Next Copy: {next_copy}") -def handle_list_dir_dump_reply(pw: PrintWrapper, custom_data : bytes): +def handle_list_dir_dump_reply(pw: PrintWrapper, custom_data: bytes): if len(custom_data) < 4: _LOGGER.warning("Data unexpectedly small") return @@ -690,9 +692,7 @@ def handle_list_dir_dump_reply(pw: PrintWrapper, custom_data : bytes): else: path = Path("dir_listing.txt") remove_if_exists_and_new(seq_idx, path) - pw.dlog( - f"Compression option: {compressed}. Dumping file into dir_listing.txt" - ) + pw.dlog(f"Compression option: {compressed}. Dumping file into dir_listing.txt") with open(path, "a") as listing_file: listing_file_str = custom_data[file_data_offset:].decode() listing_file.write(listing_file_str)