###########################################################################
#
# Copyright (c) 2020-2024 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    dg_valves_test.py
#
# @author  (last)      Dara Navaei
# @date    (last)      01-Apr-2021
# @author  (original)  Peman Montazemi
# @date    (original)  20-May-2020
#
############################################################################

import sys
sys.path.append("..")
from dialin.dg.dialysate_generator import DG
from time import sleep

if __name__ == "__main__":
    # Create an instance of the DG Class called hd
    dg = DG()
    sleep(2)

    # Log in to DG as tester
    if dg.cmd_log_in_to_dg() == 0:
        print("DG login failed.")
        exit(1)
    sleep(1)

    # Create log file
    with open("DG_valves_test.log", "w") as f:
        # Collect DG valves states
        while True:
            sleep(1)
            valvesStates = "DGValves.VBF," + str(dg.valves.valve_state_VRF.get("state", None)) + \
                           ",DGValves.VRI," + str(dg.valves.valve_state_VRI.get("state", None)) + \
                           ",DGValves.VRD," + str(dg.valves.valve_state_VRD.get("state", None)) + \
                           ",DGValves.VRO," + str(dg.valves.valve_state_VRO.get("state", None)) + \
                           ",DGValves.VPO," + str(dg.valves.valve_state_VPO.get("state", None)) + \
                           ",DGValves.VBF," + str(dg.valves.valve_state_VBF.get("state", None)) + \
                           ",DGValves.VRC," + str(dg.valves.valve_state_VRC.get("state", None)) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VDR.get("state", None)) + \
                           ",DGValves.VPI," + str(dg.valves.valve_state_VPI.get("state", None)) + \
                           ",DGValves.VSP," + str(dg.valves.valve_state_VSP.get("state", None)) + \
                           ",DGValves.VR1," + str(dg.valves.valve_state_VR1.get("state", None)) + \
                           ",DGValves.VR2," + str(dg.valves.valve_state_VR2.get("state", None)) + \
                           ",DGValves.VPD," + str(dg.valves.valve_state_VPD.get("state", None))

            # Log data
            f.write(valvesStates)
            f.write("\n")

            # Print to console
            print("DG Valves States: "+valvesStates)