Index: dialin/dg/uv_reactors.py =================================================================== diff -u -rf053467ac7cfb9fe349e394342d3a9253a377403 -r56f06b55eb8ab96bd69d12eb9d9d5c71241755ad --- dialin/dg/uv_reactors.py (.../uv_reactors.py) (revision f053467ac7cfb9fe349e394342d3a9253a377403) +++ dialin/dg/uv_reactors.py (.../uv_reactors.py) (revision 56f06b55eb8ab96bd69d12eb9d9d5c71241755ad) @@ -92,13 +92,13 @@ @param message: published thermistors message @return: none """ - inlet_health = struct.unpack('f', bytearray( + inlet_health = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_1:MsgFieldPositions.END_POS_FIELD_1]))[0] - outlet_health = struct.unpack('f', bytearray( + outlet_health = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_2:MsgFieldPositions.END_POS_FIELD_2]))[0] - inlet_state = struct.unpack('f', bytearray( + inlet_state = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_3:MsgFieldPositions.END_POS_FIELD_3]))[0] - outlet_state = struct.unpack('f', bytearray( + outlet_state = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_4:MsgFieldPositions.END_POS_FIELD_4]))[0] self.inlet_uv_reactor_health = inlet_health @@ -188,11 +188,13 @@ @param: state: (int) the state of the inlet UV reactor. 0 for Off and 1 for On. @return: 1 if successful, zero otherwise """ + rst = integer_to_bytearray(0) + inlet_uv_reactor_index = integer_to_bytearray(0) if state == ReactorsStates.UV_REACTOR_STATE_ON.name: - payload = integer_to_bytearray(1) + payload = rst + integer_to_bytearray(1) + inlet_uv_reactor_index operation = 'Turning on ' else: - payload = integer_to_bytearray(0) + payload = rst + integer_to_bytearray(0) + inlet_uv_reactor_index operation = 'Turning off ' message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_dg_ch_id, Index: tests/test_uv_reactors.py =================================================================== diff -u --- tests/test_uv_reactors.py (revision 0) +++ tests/test_uv_reactors.py (revision 56f06b55eb8ab96bd69d12eb9d9d5c71241755ad) @@ -0,0 +1,17 @@ + +import sys +sys.path.append("..") +from dialin.dg.dialysate_generator import DG +from dialin.dg.uv_reactors import ReactorsStates +from time import sleep + +dg = DG(log_level='DEBUG') +dg.cmd_log_in_to_dg() +sleep(1) + +dg.uv_reactors.cmd_start_stop_inlet_uv_reactor(state=ReactorsStates.UV_REACTOR_STATE_ON.name) + +while True: + + sleep(1) + print(dg.uv_reactors.inlet_uv_reactor_state, dg.uv_reactors.inlet_uv_reactor_health)