import struct
from ..common.msg_defs import MsgIds
from ..protocols.CAN import (DenaliMessage, DenaliChannels)
from ..utils.base import _AbstractSubSystem, _publish
from logging import Logger


class DGCalibration(_AbstractSubSystem):

    """

    Dialysate Generator (DG) Dialin API sub-class for calibration commands.
    """

    def __init__(self, can_interface, logger: Logger):
        """

        @param can_interface: Denali CAN Messenger object
        """

        super().__init__()

        self.can_interface = can_interface
        self.logger = logger

        if self.can_interface is not None:

            channel_id = DenaliChannels.dg_sync_broadcast_ch_id

    def set_dg_calibration_data(self, data):

        #test = {'sensors': {'ppi': {'gain': ['<f', 12.1], 'offset': ['<f', 2.2], 'cal_time': ['<i', 12345]}}}

        gain = struct.pack(data['sensors']['ppi']['gain'][0], data['sensors']['ppi']['gain'][1])
        offset = struct.pack(data['sensors']['ppi']['offset'][0], data['sensors']['ppi']['offset'][1])
        cal_time = struct.pack(data['sensors']['ppi']['cal_time'][0], data['sensors']['ppi']['cal_time'][1])
        payload = gain + offset + cal_time

        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_dg_ch_id,
                                              message_id=MsgIds.MSG_ID_DG_SET_CALIBRATION_DATA.value,
                                              payload=payload)

        self.logger.debug('DG calibration started')

        received_message = self.can_interface.send(message)

        # If there is content...
        if received_message is not None:
            # response payload is OK or not OK
            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
        else:
            self.logger.debug("Timeout!!!!")
            return False