Index: dialin/dg/alarms.py
===================================================================
diff -u
--- dialin/dg/alarms.py	(revision 0)
+++ dialin/dg/alarms.py	(revision d490b41a0158d5d0f97b3c1c646c7045bfc4db27)
@@ -0,0 +1,150 @@
+###########################################################################
+#
+# Copyright (c) 2019-2020 Diality Inc. - All Rights Reserved.
+#
+# THIS CODE MAY NOT BE COPIED OR REPRODUCED IN ANY FORM, IN PART OR IN
+# WHOLE, WITHOUT THE EXPLICIT PERMISSION OF THE COPYRIGHT OWNER.
+#
+# @file alarms.py
+#
+# @author (last) Quang Nguyen
+# @date (last) 02-Sep-2020
+# @author (original) Quang Nguyen
+# @date (original) 02-Sep-2020
+#
+############################################################################
+from ..protocols.CAN import (DenaliMessage,
+                             DenaliChannels)
+from ..utils.conversions import integer_to_bytearray
+from ..utils.base import _AbstractSubSystem, _publish
+from .constants import RESET, NO_RESET
+from collections import OrderedDict
+import struct
+from logging import Logger
+from ..common.alarm_defs import AlarmList
+
+
+class DGAlarms(_AbstractSubSystem):
+    """
+    DG interface containing alarm related commands.
+    """
+
+    # alarms message IDs
+    MSG_ID_ALARM_ACTIVATE = 0x0003
+    MSG_ID_ALARM_CLEAR = 0x0004
+    MSG_ID_DG_ALARM_STATE_OVERRIDE = 0xA001
+
+    START_POS_ALARM_ID = DenaliMessage.PAYLOAD_START_INDEX
+    END_POS_ALARM_ID = START_POS_ALARM_ID + 2
+
+    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_alarm_broadcast_ch_id
+            msg_id = self.MSG_ID_ALARM_ACTIVATE
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id, self._handler_alarm_activate)
+
+            channel_id = DenaliChannels.dg_alarm_broadcast_ch_id
+            msg_id = self.MSG_ID_ALARM_CLEAR
+            self.can_interface.register_receiving_publication_function(channel_id, msg_id, self._handler_alarm_clear)
+
+        # alarm states based on received DG alarm activation and alarm clear messages
+        self.alarm_states = [False] * 500
+
+        self.ids = OrderedDict()
+        for attr in dir(AlarmList):
+            if not callable(getattr(AlarmList, attr)) and attr.startswith("ALARM_ID"):
+                self.ids[attr] = getattr(AlarmList, attr)
+        self.ids = OrderedDict(sorted(self.ids.items(), key=lambda key: key[1].value))
+
+    def get_alarm_states(self):
+        """
+        Gets all states for all alarms
+
+        @return: List of booleans of size 500
+        """
+        return self.alarm_states
+
+    def get_alarm_state(self, alarm_id):
+        """
+        Gets alarm state for given alarm
+
+        @return: Alarm state
+        """
+        return self.alarm_states[alarm_id]
+
+    def get_alarm_ids(self):
+        """
+        Returns a dictionary of the alarm short name and the corresponding id
+
+        @return: OrderedDict of the alarm ids
+        """
+        return self.ids
+
+    @_publish(["alarm_states"])
+    def _handler_alarm_activate(self, message):
+        """
+        Handles published DG alarm activation messages.
+
+        @param message:  published DG alarm activation message
+        @return: none
+        """
+
+        alarm_id = struct.unpack('<H', bytearray(message['message'][self.START_POS_ALARM_ID:self.END_POS_ALARM_ID]))
+        self.alarm_states[alarm_id[0]] = True
+
+    @_publish(["alarm_states"])
+    def _handler_alarm_clear(self, message):
+        """
+        Handles published DG alarm clear messages.
+
+        @param message:  published DG alarm clear message
+        @return: none
+        """
+
+        alarm_id = struct.unpack('<H', bytearray(message['message'][self.START_POS_ALARM_ID:self.END_POS_ALARM_ID]))
+        self.alarm_states[alarm_id[0]] = False
+
+    def cmd_alarm_state_override(self, state, alarm, reset=NO_RESET):
+        """
+        Constructs and sends the alarm state override command
+        Constraints:
+            Must be logged into DG.
+            Given alarm must be valid.
+            If inactivating alarm, given alarm must be recoverable (clearable).
+
+        @param state:  integer - 1 for alarm active, 0 for alarm inactive
+        @param alarm:  integer - ID of alarm to override
+        @param reset:  integer - 1 to reset a previous override, 0 to override
+        @return: 1 if successful, zero otherwise
+        """
+
+        rst = integer_to_bytearray(reset)
+        sta = integer_to_bytearray(state)
+        alm = integer_to_bytearray(alarm)
+        payload = rst + sta + alm
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_dg_ch_id,
+                                              message_id=self.MSG_ID_DG_ALARM_STATE_OVERRIDE,
+                                              payload=payload)
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        # If there is content...
+        if received_message is not None:
+            # self.logger.debug(received_message)
+            if reset == RESET:
+                str_res = "reset back to normal"
+            else:
+                str_res = ("active" if state != 0 else "inactive")
+            # response payload is OK or not OK
+            return 1 == received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        return False
+
Index: dialin/dg/dialysate_generator.py
===================================================================
diff -u -r8ea13ae6dd10732bfcc456798f4785c4d88c95d3 -rd490b41a0158d5d0f97b3c1c646c7045bfc4db27
--- dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision 8ea13ae6dd10732bfcc456798f4785c4d88c95d3)
+++ dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision d490b41a0158d5d0f97b3c1c646c7045bfc4db27)
@@ -14,6 +14,7 @@
 #
 ############################################################################
 import struct
+from .alarms import DGAlarms
 from .drain_pump import DGDrainPump
 from .hd_proxy import DGHDProxy
 from .load_cells import DGLoadCells
@@ -148,6 +149,7 @@
         self.heaters = Heaters(self.can_interface, self.logger)
         self.temperature_sensors = TemperatureSensors(self.can_interface, self.logger)
         self.conductivity_sensors = ConductivitySensors(self.can_interface, self.logger)
+        self.alarms = DGAlarms(self.can_interface, self.logger)
 
     def get_version(self):
         """