eive/eive-tmtc
eive/eive-tmtc
14
0
Fork 0
Code Issues Pull Requests 1 Projects Releases 99 Wiki Activity

smaller tweaks

Browse Source
This commit is contained in:
Robin Müller 2023-02-17 18:43:51 +01:00
parent aabfcf83ac
commit d97eb7334b
No known key found for this signature in database
GPG Key ID: 71B58F8A3CDFA9AC
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
eive_tmtc/tmtc/tm_store.py
View File

@ -18,7 +18,7 @@ from tmtccmd.tc import service_provider
from tmtccmd.tc.decorator import ServiceProviderParams from tmtccmd.tc.decorator import ServiceProviderParams
from dateutil.parser import parse from dateutil.parser import parse
from spacepackets.ecss import PusService from spacepackets.ecss import PusService # noqa
from spacepackets.ecss.tc import PusTelecommand from spacepackets.ecss.tc import PusTelecommand
from spacepackets.ecss.pus_15_tm_storage import Subservice from spacepackets.ecss.pus_15_tm_storage import Subservice
from tmtccmd.util import ObjectIdU32 from tmtccmd.util import ObjectIdU32
@ -26,12 +26,12 @@ from tmtccmd.util import ObjectIdU32
class OpCode: class OpCode:
DUMP = "dump" DUMP = "dump"
DELETE = "delete" DELETE_UP_TO = "delete_up_to"
class Info: class Info:
DUMP = "Dump Telemetry Packets" DUMP = "Dump Telemetry Packets"
DELETE = "Delete Telemetry Packets" DELETE_UP_TO = "Delete Telemetry Packets"
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
@ -41,13 +41,13 @@ _LOGGER = logging.getLogger(__name__)
def pack_tm_store_commands(p: ServiceProviderParams): def pack_tm_store_commands(p: ServiceProviderParams):
q = p.queue_helper q = p.queue_helper
o = p.op_code o = p.op_code
if o == OpCode.DELETE: if o == OpCode.DELETE_UP_TO:
obj_id, store_string = store_select_prompt() obj_id, store_string = store_select_prompt()
app_data = bytearray(obj_id.as_bytes) app_data = bytearray(obj_id.as_bytes)
delete_up_to_time = time_prompt() delete_up_to_time = time_prompt()
end_stamp = int(math.floor(delete_up_to_time.timestamp())) end_stamp = int(math.floor(delete_up_to_time.timestamp()))
app_data.extend(struct.pack("!I", end_stamp)) app_data.extend(struct.pack("!I", end_stamp))
q.add_log_cmd(Info.DELETE) q.add_log_cmd(Info.DELETE_UP_TO)
q.add_log_cmd(f"Selected Store: {obj_id}") q.add_log_cmd(f"Selected Store: {obj_id}")
q.add_log_cmd(f"Deletion up to time {delete_up_to_time}") q.add_log_cmd(f"Deletion up to time {delete_up_to_time}")
print( print(
@ -64,7 +64,7 @@ def pack_tm_store_commands(p: ServiceProviderParams):
@tmtc_definitions_provider @tmtc_definitions_provider
def add_persistent_tm_store_cmd_defs(defs: TmtcDefinitionWrapper): def add_persistent_tm_store_cmd_defs(defs: TmtcDefinitionWrapper):
oce = OpCodeEntry() oce = OpCodeEntry()
oce.add(keys=OpCode.DELETE, info=Info.DELETE) oce.add(keys=OpCode.DELETE_UP_TO, info=Info.DELETE_UP_TO)
oce.add(keys=OpCode.DUMP, info=Info.DUMP) oce.add(keys=OpCode.DUMP, info=Info.DUMP)
defs.add_service( defs.add_service(
CustomServiceList.TM_STORE, "Persistent TM Store", op_code_entry=oce CustomServiceList.TM_STORE, "Persistent TM Store", op_code_entry=oce