import sys
sys.path.append("..")
from dialin.dg.dialysate_generator import DG
from dialin.dg.uv_reactors import ReactorsStates, ReactorsHealthStatus, ReactorsNames
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(ReactorsStates.UV_REACTOR_STATE_ON.value)
dg.uv_reactors.cmd_start_stop_outlet_uv_reactor(ReactorsStates.UV_REACTOR_STATE_ON.value)

#dg.uv_reactors.cmd_uv_reactors_health_override(ReactorsNames.INLET_UV_REACTOR.value,
#                                               ReactorsHealthStatus.UV_REACTOR_NOT_HEALTHY.value, reset=1)

while True:
    try:
        sleep(1)
        print('Inlet_health, {}, Inlet_state, {}, Outlet_health, {}, Outlet_health, {}'.
              format(dg.uv_reactors.inlet_uv_reactor_state,
                     ReactorsHealthStatus(dg.uv_reactors.inlet_uv_reactor_health).name,
                     dg.uv_reactors.outlet_uv_reactor_state,
                     ReactorsHealthStatus(dg.uv_reactors.outlet_uv_reactor_health).name))

    except KeyboardInterrupt:
        dg.uv_reactors.cmd_start_stop_inlet_uv_reactor(ReactorsStates.UV_REACTOR_STATE_OFF.name)
        dg.uv_reactors.cmd_start_stop_outlet_uv_reactor(ReactorsStates.UV_REACTOR_STATE_OFF.name)
        dg.uv_reactors.cmd_uv_reactors_health_override(ReactorsNames.OUTLET_UV_REACTOR.value,
                                                       ReactorsHealthStatus.UV_REACTOR_NOT_HEALTHY.value, reset=1)
        break