Index: leahi_dialin/td/modules/events.py =================================================================== diff -u -r7d9d004527efeccb91958b440abdff08c2c52648 -r18c90a1b2b6c7339bdd192a2d2fac32f2b8a35df --- leahi_dialin/td/modules/events.py (.../events.py) (revision 7d9d004527efeccb91958b440abdff08c2c52648) +++ leahi_dialin/td/modules/events.py (.../events.py) (revision 18c90a1b2b6c7339bdd192a2d2fac32f2b8a35df) @@ -7,21 +7,24 @@ # # @file events.py # -# @author (last) Jonny Paguio -# @date (last) 16-Sep-2025 +# @author (last) Zoltan Miskolci +# @date (last) 08-Jan-2026 # @author (original) Dara Navaei # @date (original) 12-Oct-2021 # ############################################################################ import struct from logging import Logger -from leahi_dialin.common import * +from datetime import datetime +from time import time + +from leahi_dialin.common.td_defs import TDEventList, TDEventDataType, TDOpModes, TDFaultStates, \ + TDServiceStates, TDInitStates, TDStandbyStates, TDTreatmentParamStates, TDPreTreatmentModesStates, \ + TDTreatmentStates, TDPostTreatmentStates, TDNotLegalStates from leahi_dialin.common.msg_defs import MsgIds, MsgFieldPositions from leahi_dialin.protocols.CAN import DenaliChannels from leahi_dialin.utils.base import AbstractSubSystem, publish -from datetime import datetime -from time import time class TDEvents(AbstractSubSystem): @@ -32,10 +35,8 @@ def __init__(self, can_interface, logger: Logger): """ - @param can_interface: Denali CAN Messenger object """ - super().__init__() self.can_interface = can_interface self.logger = logger @@ -90,6 +91,7 @@ self._td_event_data_type[event_data_type] = struct_unpack_type + def get_td_nth_event(self, event_id, event_number=0): """ Returns the nth requested TD event @@ -110,6 +112,7 @@ return event + def clear_td_event_list(self): """ Clears the TD event list @@ -119,6 +122,7 @@ for key in self._td_event_dictionary: self._td_event_dictionary[key].clear() + def get_td_events(self, event_id, number_of_events=1): """ Returns the requested number of a certain TD event ID @@ -146,6 +150,7 @@ return list_of_events + @publish(["msg_id_td_event", "td_events_timestamp", '_td_event_dictionary']) def _handler_events_sync(self, message, timestamp=0.0): """ @@ -285,6 +290,7 @@ self._td_event_dictionary[event_state_name].append(event_tuple) self.td_events_timestamp = timestamp + @publish(["msg_id_td_op_mode_data", "td_event_op_mode_timestamp", "td_event_op_mode", "td_event_sub_mode"]) def _handler_td_op_mode_sync(self, message, timestamp=0.0): """ @@ -302,4 +308,4 @@ self.td_event_op_mode = mode[0] self.td_event_sub_mode = smode[0] - self.td_event_op_mode_timestamp = timestamp \ No newline at end of file + self.td_event_op_mode_timestamp = timestamp