from ctypes import *
from collections import OrderedDict
from dialin.dg.dialysate_generator import DG
from dialin.ui import crc
from time import sleep
import struct

if __name__ == "__main__":
    # Create an instance of the DG Class
    dg = DG(log_level='DEBUG')

    if dg.cmd_log_in_to_dg() == 0:
        exit(1)
    sleep(2)
    cal = dg.calibration_record

    f = open("DG_Calibration.log", "w")

    status = True

    """
    cal.dg_calibration_record['pumps']['concentrate_1']['step_speed_2_flow_ratio'][1] = 34.2
    cal.dg_calibration_record['pumps']['drain']['cal_time'][1] = 96321
    cal.dg_calibration_record['pumps']['ro']['gain_3_ratio'][1] = 45.69
    cal.dg_calibration_record['volumes']['drain_line']['volume'][1] = 125.8
    cal.dg_calibration_record['volumes']['drain_line']['crc'][1] = 78
    cal.dg_calibration_record['volumes']['pre_ro_purge']['volume'][1] = 125.8
    cal.dg_calibration_record['volumes']['reservoir_1']['max_residual_fluid'][1] = 85.36
    cal.dg_calibration_record['bicarb_concentrates']['bicarb_conc_3']['reserved_space'][1] = 85.36
    cal.dg_calibration_record['fans']['fan_2']['reserved_space_2'][1] = 456.25
    cal.dg_calibration_record['accelerometer_sensor']['accelerometer']['y_offset'][1] = 678.9
    """

    print(cal.dg_calibration_record)

    try:
        if status:
            dara = []
            cal.get_dg_calibration_record()
            while True:

                if cal.cal_data != 0:
                    #f.write(str(cal.service_data) + '\r')
                    #dara.append(cal.service_data)

                    if cal.current_message == cal.total_messages:
                        f.close()
                        break
        else:
            cal.set_dg_calibration_record()

        print(cal.dg_calibration_record)

    except KeyboardInterrupt:
        f.close()