from leahi_dialin.dd.dialysate_delivery import DD
from leahi_dialin.dd.modules.blood_leak import EmbModeCommands
from time import sleep
import os

def get_blood_leak_info():
    info = ('Blood_leak_state, {}, Blood_leak_status, {}, Blood_leak_intensity, {}, Blood_leak_detect, {}, '
            'Blood_leak_int_mv_avg, {}, '
            .format(dd.blood_leak.get_blood_leak_state(), dd.blood_leak.get_blood_leak_status(),
                    dd.blood_leak.blood_leak_intensity, dd.blood_leak.blood_leak_blood_detect,
                    dd.blood_leak.blood_leak_intensity_moving_average))
    return info


if __name__ == "__main__":
    address = os.path.join(os.getcwd(), "leahi_zero.log")
    f = open(address, "w")
    dd = DD()
    dd.cmd_log_in_to_dd()
    sleep(0.1)
    dd.blood_leak.cmd_blood_leak_data_broadcast_interval_override(50)
    var = get_blood_leak_info() + '\r'
    f.write(var)
    print(var)
    sleep(0.1)
    dd.blood_leak.cmd_blood_leak_zero_request()
    #dd.blood_leak.cmd_blood_leak_set_embedded_mode_command(EmbModeCommands.I.value, msg_payload=0)

    while True:
        var = get_blood_leak_info() + '\r'
        sleep(0.05)
        #print("Detect", dd.blood_leak.get_blood_leak_emb_mode_command_response(EmbModeCommands.V.value))
        print(var)
        f.write(var)

    f.close()