Index: leahi_dialin/dd/proxies/ro_proxy.py =================================================================== diff -u -r18c90a1b2b6c7339bdd192a2d2fac32f2b8a35df -re45b20cdc5d4c5dcff8cef530b173ca94cb2e422 --- leahi_dialin/dd/proxies/ro_proxy.py (.../ro_proxy.py) (revision 18c90a1b2b6c7339bdd192a2d2fac32f2b8a35df) +++ leahi_dialin/dd/proxies/ro_proxy.py (.../ro_proxy.py) (revision e45b20cdc5d4c5dcff8cef530b173ca94cb2e422) @@ -8,17 +8,20 @@ # @file ro_proxy.py # # @author (last) Zoltan Miskolci -# @date (last) 08-Jan-2026 +# @date (last) 04-May-2026 # @author (original) Peter Lucia # @date (original) 02-Apr-2020 # ############################################################################ +# Module imports from logging import Logger -from leahi_dialin.common.msg_defs import MsgIds -from leahi_dialin.protocols.CAN import DenaliMessage, DenaliCanMessenger, DenaliChannels -from leahi_dialin.utils.base import AbstractSubSystem +# Project imports +from leahi_dialin.common.msg_ids import MsgIds +from leahi_dialin.common.override_templates import cmd_generic_override +from leahi_dialin.protocols.CAN import CanMessenger, CanChannels +from leahi_dialin.utils.abstract_classes import AbstractSubSystem from leahi_dialin.utils.conversions import integer_to_bytearray, float_to_bytearray @@ -27,11 +30,11 @@ Dialysate Delivery (DD) Dialin API sub-class for RO proxy ( injection ) related commands. """ - def __init__(self, can_interface: DenaliCanMessenger, logger: Logger): + def __init__(self, can_interface: CanMessenger, logger: Logger): """ ROProxy constructor - @param can_interface: the Denali CAN interface object + @param can_interface: the CAN interface object """ super().__init__() self.can_interface = can_interface @@ -53,9 +56,12 @@ stt = integer_to_bytearray(start) rtt = float_to_bytearray(ro_rate) payload = cmd + stt + rtt - message = DenaliMessage.build_message(channel_id=DenaliChannels.dd_to_ro_ch_id, - message_id=MsgIds.MSG_ID_DD_FP_START_STOP_CMD_REQUEST.value, - payload=payload) - self.logger.debug("Sending DD start stop request to RO.") - self.can_interface.send(message, 0) + cmd_generic_override(payload = payload, + reset = None, + channel_id = CanChannels.dd_to_ro_ch_id, + msg_id = MsgIds.MSG_ID_DD_FP_START_STOP_CMD_REQUEST, + entity_name = 'DD Start Stop Request to RO', + override_text = 'N/A', + logger = self.logger, + can_interface = self.can_interface)