###########################################################################
#
#  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 dg_valves_test.py
#
#  @date 20-May-2020
#  @author P. Montazemi
#
#  @brief This development test script exercises the DG valves states in \n
#  single and batch modes
#
############################################################################

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 dg
    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) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VRI) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VRD) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VRO) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VPO) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VBF) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VRC) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VDR) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VPI) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VSP) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VR1) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VR2) + \
                           ",DGValves.VDR," + str(dg.valves.valve_state_VPD)

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

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