Index: .idea/dictionaries/denali.xml
===================================================================
diff -u
--- .idea/dictionaries/denali.xml (revision 0)
+++ .idea/dictionaries/denali.xml (revision 691116a693026e10fdaf825d77107e1587ba66e9)
@@ -0,0 +1,3 @@
+
+
+
\ No newline at end of file
Index: dialin/ui/dd_ui_request_handler.py
===================================================================
diff -u -r1e9de03223eeeec426716c6157ce88ddd60e4d5a -r691116a693026e10fdaf825d77107e1587ba66e9
--- dialin/ui/dd_ui_request_handler.py (.../dd_ui_request_handler.py) (revision 1e9de03223eeeec426716c6157ce88ddd60e4d5a)
+++ dialin/ui/dd_ui_request_handler.py (.../dd_ui_request_handler.py) (revision 691116a693026e10fdaf825d77107e1587ba66e9)
@@ -18,7 +18,7 @@
from . import pressure_ranges as pr
-def ui_post_final_test_result(parent, params):
+def ui_post_final_test_result(parent):
rsp_id = None
rsp_payload = None
parent.demoSelection = 1 # setup event to change Mode
@@ -27,7 +27,7 @@
return rsp_id, rsp_payload
-def ui_confirmation_result_response_99(parent, params):
+def ui_confirmation_result_response_99(parent):
rsp_id = MsgIds.MSG_ID_HD_UI_CONFIRMATION_REQUEST
rsp_payload = integer_to_bytearray(98)
rsp_payload += integer_to_bytearray(0) # TBD use consts
@@ -41,12 +41,12 @@
return rsp_id, rsp_payload
-def ui_confirmation_result_98(parent, params):
+def ui_confirmation_result_98(parent):
rsp_id = MsgIds.MSG_ID_HD_UI_CONFIRMATION_REQUEST
rsp_payload = integer_to_bytearray(98) # TBD! Use const for 99
rsp_payload += integer_to_bytearray(3) # TBD use consts
rsp_payload += integer_to_bytearray(0)
- if params.data_int[1] == EResponse.Accepted: # Reset the Demo
+ if parent.params.data_int[1] == EResponse.Accepted: # Reset the Demo
parent.demoSelection = 1 # setup event to change Mode
parent.demoCount = 0
parent.demoCounter = 1
@@ -63,15 +63,16 @@
return rsp_id, rsp_payload
-def ui_confirmation_result_response_6(parent, params):
+def ui_confirmation_result_response_6(parent):
+ # UI sends this when
rsp_id = MsgIds.MSG_ID_HD_UI_CONFIRMATION_REQUEST
rsp_payload = integer_to_bytearray(6)
- if params.data_int[1] == EResponse.Accepted:
+ if parent.params.data_int[1] == EResponse.Accepted:
rsp_payload += integer_to_bytearray(1)
rsp_payload += integer_to_bytearray(0)
parent.demoSelection = 61 # setup event to change Mode
- elif params.data_int[1] == 0:
+ elif parent.params.data_int[1] == 0:
rsp_payload += integer_to_bytearray(3)
rsp_payload += integer_to_bytearray(0)
@@ -80,43 +81,42 @@
return rsp_id, rsp_payload
-def ui_service_mode_request(parent, params):
- rsp_id = MsgIds.MSG_ID_HD_RESPONSE_SERVICE_MODE_REQUEST
- rsp_payload = integer_to_bytearray(EResponse.Accepted)
- rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
- parent.demoCount = 0 # immediately
+def ui_service_mode_request(parent):
+ rsp_id = MsgIds.MSG_ID_HD_OP_MODE_DATA # 37, 0x2500
+ rsp_payload = integer_to_bytearray(HDOpModes.MODE_SERV.value)
+ rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value) #integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
return rsp_id, rsp_payload
-def ui_initiate_treatment_request(parent, params):
+def ui_initiate_treatment_request(parent):
rsp_id = MsgIds.MSG_ID_HD_OP_MODE_DATA
- if params.data_int[0] == EResponse.Accepted:
+ if parent.params.data_int[0] == EResponse.Accepted:
rsp_payload = integer_to_bytearray(HDOpModes.MODE_TPAR.value)
else:
rsp_payload = integer_to_bytearray(HDOpModes.MODE_STAN.value)
rsp_payload += integer_to_bytearray(0)
return rsp_id, rsp_payload
-def ui_new_treatment_params_request(parent, params):
+def ui_new_treatment_params_request(parent):
rsp_id = MsgIds.MSG_ID_HD_NEW_TREATMENT_PARAMS_RESPONSE
rsp_payload = struct.pack("<" + str(TreatmentParameters.NUM_OF_TREATMENT_PARAMS.value + 1) + "i",
1,
0, 0, 0, 0, 0, 0,
0, 0, 0, 0, 0, 0,
0, 0, 0, 0, 0, 0
)
- parent.demo_treatment_params = deepcopy(params) # keep a complete copy
+ parent.demo_treatment_params = deepcopy(parent.params) # keep a complete copy
# UF Treatment
- parent.treatment_time_sec = params.data_int[TreatmentParameters.TREATMENT_PARAM_TREATMENT_DURATION_MIN.value] * 60
+ parent.treatment_time_sec = parent.params.data_int[TreatmentParameters.TREATMENT_PARAM_TREATMENT_DURATION_MIN.value] * 60
parent.uf_volume_set_l = 0 # TBD not in this message
parent.uf_volume_out_l = 0 # reset status
parent.uf_rate_l_per_sec = 0
parent.salineVolume_ml = 0.0 # status
parent.salineVolCum_ml = 0.0 # status
- parent.dialysate_flow_set_point_ml_per_min = params.data_int[TreatmentParameters.TREATMENT_PARAM_DIALYSATE_FLOW_RATE_ML_MIN.value]
- parent.blood_flow_set_point_ml_per_min = params.data_int[TreatmentParameters.TREATMENT_PARAM_BLOOD_FLOW_RATE_ML_MIN.value]
+ parent.dialysate_flow_set_point_ml_per_min = parent.params.data_int[TreatmentParameters.TREATMENT_PARAM_DIALYSATE_FLOW_RATE_ML_MIN.value]
+ parent.blood_flow_set_point_ml_per_min = parent.params.data_int[TreatmentParameters.TREATMENT_PARAM_BLOOD_FLOW_RATE_ML_MIN.value]
# rsp_id = MsgIds.MSG_ID_HD_PRESSURE_LIMITS_CHANGE_RESPONSE
parent.cmd_send_treatment_adjust_pressures_limit_response( accepted=EResponse.Accepted,
reason=RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value,
@@ -129,14 +129,14 @@
parent.venous_pressure_mmHg = parent.venous_pressure_mid_mmHg + 32 # simulation
# Rinseback
parent.rinseback_volume_set_ml = 80 + 120 # TBD! 80 + should be based on dialyzer blood volume?
- parent.rinsebackVelocity_ml_per_sec = params.data_int[TreatmentParameters.TREATMENT_PARAM_RINSEBACK_FLOW_RATE_ML_MIN.value] / 60.0
+ parent.rinsebackVelocity_ml_per_sec = parent.params.data_int[TreatmentParameters.TREATMENT_PARAM_RINSEBACK_FLOW_RATE_ML_MIN.value] / 60.0
parent.rinseback_volume_out_ml = 0 # reset status
parent.rinseback_volume_all_ml = 0
# Heparin
- parent.heparin_stop_min = params.data_int[TreatmentParameters.TREATMENT_PARAM_HEPARIN_PRESTOP_MIN.value]
- parent.heparin_rate_ml_per_hr = params.data_float[TreatmentParameters.TREATMENT_PARAM_HEPARIN_DISPENSE_RATE_ML_HR.value]
+ parent.heparin_stop_min = parent.params.data_int[TreatmentParameters.TREATMENT_PARAM_HEPARIN_PRESTOP_MIN.value]
+ parent.heparin_rate_ml_per_hr = parent.params.data_float[TreatmentParameters.TREATMENT_PARAM_HEPARIN_DISPENSE_RATE_ML_HR.value]
parent.heparin_rate_ml_per_s = parent.heparin_rate_ml_per_hr / 3600.0
- parent.heparin_bolus_ml = params.data_float[TreatmentParameters.TREATMENT_PARAM_HEPARIN_BOLUS_VOLUME_ML.value]
+ parent.heparin_bolus_ml = parent.params.data_float[TreatmentParameters.TREATMENT_PARAM_HEPARIN_BOLUS_VOLUME_ML.value]
parent.heparin_out_ml = 0 # reset status
parent.heparin_pause = False # setting
parent.heparin_expected_ml = (((parent.treatment_time_sec / 60.0) - parent.heparin_stop_min) / 60.0 *
@@ -151,8 +151,8 @@
return rsp_id, rsp_payload
-def ui_user_confirm_treatment_request(parent, params):
- if params.data_int[0] == EResponse.Accepted:
+def ui_user_confirm_treatment_request(parent):
+ if parent.params.data_int[0] == EResponse.Accepted:
parent.salineVolume_ml = 0.0
parent.salineVolCum_ml = 0.0
rsp_id = MsgIds.MSG_ID_PRE_TREATMENT_STATE_DATA
@@ -181,8 +181,8 @@
return rsp_id, rsp_payload
-def ui_sample_water_result(parent, params):
- if params.data_int[0] == EResponse.Accepted:
+def ui_sample_water_result(parent):
+ if parent.params.data_int[0] == EResponse.Accepted:
## TBD!!! FOLLOWING IS FUTILE ATTEMPT TO SET UF MAX
calc_max_uf_volume = min(int(parent.MAX_UF_RATE_ML_PER_SEC * parent.treatment_time_sec / 100.0) * 100.0,
parent.MAX_UF_ML_PER_TX)
@@ -230,7 +230,7 @@
return rsp_id, rsp_payload
-def ui_consumable_install_confirm_request(parent, params):
+def ui_consumable_install_confirm_request(parent):
rsp_id = None
rsp_payload = None
## TBD!!! Does this work?
@@ -247,7 +247,7 @@
return rsp_id, rsp_payload
-def ui_installation_confirm_request(parent, params):
+def ui_installation_confirm_request(parent):
rsp_id = None
rsp_payload = None
@@ -269,7 +269,7 @@
return rsp_id, rsp_payload
-def ui_start_prime_request(parent, params):
+def ui_start_prime_request(parent):
rsp_id = None
rsp_payload = None
parent.demoSelection = 10 # continue on, picking up from previous state setup by selection 9
@@ -280,7 +280,7 @@
return rsp_id, rsp_payload
-def ui_patient_connection_begin_request(parent, params):
+def ui_patient_connection_begin_request(parent):
rsp_id = None
rsp_payload = None
# TBD!!! Setup UF Range before this
@@ -291,12 +291,12 @@
return rsp_id, rsp_payload
-def ui_set_uf_volume_parameter_request(parent, params):
+def ui_set_uf_volume_parameter_request(parent):
rsp_id = MsgIds.MSG_ID_HD_SET_UF_VOLUME_PARAMETER_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
- rsp_payload += integer_to_bytearray(params.data_int[0]) # echo back setting
- parent.uf_volume_set_l = params.data_float[0] / 1000.0 # TBD!! passed as mL instead
+ rsp_payload += integer_to_bytearray(parent.params.data_int[0]) # echo back setting
+ parent.uf_volume_set_l = parent.params.data_float[0] / 1000.0 # TBD!! passed as mL instead
if (parent.uf_volume_set_l is not None) and (parent.uf_volume_set_l >= 0.0009) and (
parent.uf_stop_time_sec is not None):
@@ -308,15 +308,15 @@
return rsp_id, rsp_payload
-def ui_patient_connection_confirm_request(parent, params):
+def ui_patient_connection_confirm_request(parent):
rsp_id = MsgIds.MSG_ID_HD_PATIENT_CONNECTION_CONFIRM_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
parent.demoSelection = 0 # Wait for user
return rsp_id, rsp_payload
-def ui_start_treatment_request(parent, params):
+def ui_start_treatment_request(parent):
rsp_id = MsgIds.MSG_ID_HD_START_TREATMENT_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
@@ -325,13 +325,13 @@
return rsp_id, rsp_payload
-def ui_user_treatment_time_change_request(parent, params):
+def ui_user_treatment_time_change_request(parent):
rsp_id = MsgIds.MSG_ID_USER_TREATMENT_TIME_CHANGE_RESPONSE
- if params.data_int[0] is not None:
- if params.data_int[0] == 4 * 60 + 30: # 'secret' means to force end if 0 duration is unavailable
- params.data_int[0] = 0
- parent.treatment_time_sec = params.data_int[0] * 60
+ if parent.params.data_int[0] is not None:
+ if parent.params.data_int[0] == 4 * 60 + 30: # 'secret' means to force end if 0 duration is unavailable
+ parent.params.data_int[0] = 0
+ parent.treatment_time_sec = parent.params.data_int[0] * 60
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
else:
@@ -345,106 +345,106 @@
return rsp_id, rsp_payload
-def ui_user_saline_bolus_request(parent, params):
+def ui_user_saline_bolus_request(parent):
rsp_id = MsgIds.MSG_ID_USER_SALINE_BOLUS_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
rsp_payload += integer_to_bytearray(
parent.demo_treatment_params.data_int[TreatmentParameters.TREATMENT_PARAM_SALINE_BOLUS_VOLUME_ML.value])
- if params.data_int[0] == EResponse.Accepted:
+ if parent.params.data_int[0] == EResponse.Accepted:
parent.demoSelection = 31 # Saline Bolus
else:
parent.demoSelection = 33 # Bolus Stop request
return rsp_id, rsp_payload
-def ui_heparin_pause_resume_request(parent, params):
+def ui_heparin_pause_resume_request(parent):
rsp_id = MsgIds.MSG_ID_HD_HEPARIN_PAUSE_RESUME_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
- if params.data_int[0] != EResponse.Accepted:
+ if parent.params.data_int[0] != EResponse.Accepted:
parent.heparin_pause = True # Heparin Pause
else:
parent.heparin_pause = False # Heparin Resume
return rsp_id, rsp_payload
-def ui_pressure_limits_change_request(parent, params):
+def ui_pressure_limits_change_request(parent):
rsp_id = MsgIds.MSG_ID_HD_PRESSURE_LIMITS_CHANGE_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
# apply new settings
parent.demo_treatment_params.data_int[TreatmentParameters.TREATMENT_PARAM_ART_PRES_LIMIT_WINDOW.value] = \
- params.data_int[0]
+ parent.params.data_int[0]
parent.demo_treatment_params.data_int[TreatmentParameters.TREATMENT_PARAM_VEN_PRES_LIMIT_WINDOW.value] = \
- params.data_int[1]
+ parent.params.data_int[1]
parent.demo_treatment_params.data_int[TreatmentParameters.TREATMENT_PARAM_VEN_PRES_LIMIT_ASYMMETRIC.value] = \
- params.data_int[2]
- rsp_payload += integer_to_bytearray(params.data_int[0]) # reply with as set
- rsp_payload += integer_to_bytearray(params.data_int[1])
- rsp_payload += integer_to_bytearray(params.data_int[2])
+ parent.params.data_int[2]
+ rsp_payload += integer_to_bytearray(parent.params.data_int[0]) # reply with as set
+ rsp_payload += integer_to_bytearray(parent.params.data_int[1])
+ rsp_payload += integer_to_bytearray(parent.params.data_int[2])
return rsp_id, rsp_payload
-def ui_user_blood_dial_rate_change_request(parent, params):
+def ui_user_blood_dial_rate_change_request(parent):
rsp_id = MsgIds.MSG_ID_USER_BLOOD_DIAL_RATE_CHANGE_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
# apply new settings
parent.demo_treatment_params.data_int[TreatmentParameters.TREATMENT_PARAM_BLOOD_FLOW_RATE_ML_MIN.value] = \
- params.data_int[0]
+ parent.params.data_int[0]
parent.demo_treatment_params.data_int[TreatmentParameters.TREATMENT_PARAM_DIALYSATE_FLOW_RATE_ML_MIN.value] = \
- params.data_int[1]
- parent.dialysate_flow_set_point_ml_per_min = params.data_int[1]
- parent.blood_flow_set_point_ml_per_min = params.data_int[0]
+ parent.params.data_int[1]
+ parent.dialysate_flow_set_point_ml_per_min = parent.params.data_int[1]
+ parent.blood_flow_set_point_ml_per_min = parent.params.data_int[0]
rsp_payload += integer_to_bytearray(parent.blood_flow_set_point_ml_per_min)
rsp_payload += integer_to_bytearray(parent.dialysate_flow_set_point_ml_per_min) # reply with as set
return rsp_id, rsp_payload
-def ui_rinseback_cmd_request(parent, params):
+def ui_rinseback_cmd_request(parent):
rsp_id = MsgIds.MSG_ID_HD_RINSEBACK_CMD_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
- if params.data_int[0] == 0: # 0 Start Rinseback
+ if parent.params.data_int[0] == 0: # 0 Start Rinseback
parent.rinseback_volume_out_ml = 0 # reset these
parent.demoSelection = 41
- elif params.data_int[0] == 1: # 1 Accelerate ++25 mL/min (R)
+ elif parent.params.data_int[0] == 1: # 1 Accelerate ++25 mL/min (R)
parent.rinsebackVelocity_ml_per_sec = min(parent.rinsebackVelocity_ml_per_sec + 25.0 / 60.0,
parent.rinsebackVelocity_max_ml_per_sec)
- elif params.data_int[0] == 2: # 2 Decelerate --25 mL/min (R)
+ elif parent.params.data_int[0] == 2: # 2 Decelerate --25 mL/min (R)
parent.rinsebackVelocity_ml_per_sec = max(parent.rinsebackVelocity_ml_per_sec - 25.0 / 60.0,
parent.rinsebackVelocity_min_ml_per_sec)
- elif params.data_int[0] == 3: # 3 Pause
+ elif parent.params.data_int[0] == 3: # 3 Pause
parent.demoSelection = 44
- elif params.data_int[0] == 4: # 4 Resume
+ elif parent.params.data_int[0] == 4: # 4 Resume
parent.demoSelection = 41
- elif params.data_int[0] == 5: # 5 = "End" during rinseback
+ elif parent.params.data_int[0] == 5: # 5 = "End" during rinseback
rsp_id = MsgIds.MSG_ID_HD_OP_MODE_DATA
rsp_payload = integer_to_bytearray(HDOpModes.MODE_POST.value)
rsp_payload += integer_to_bytearray(PostTreatmentStates.HD_POST_TREATMENT_DRAIN_RESERVOIRS_STATE.value)
parent.demoSelection = 0 # Complete Treatment
parent.demoCount = 0 # immediately
- elif params.data_int[0] == 6: # TBD!! Additional
+ elif parent.params.data_int[0] == 6: # TBD!! Additional
# TreatmentRinsebackStates.RINSEBACK_RUN_ADDITIONAL_STATE.value
# #TBD!! # 4 Additional rinseback volume (10 mL) state of the rinseback sub-mode state machine
parent.rinseback_volume_set_ml += 10.0 # ++10 mL (R)
parent.demoSelection = 45
- elif params.data_int[0] == 8: # "END" 8 = Disconnect without further rinseback
+ elif parent.params.data_int[0] == 8: # "END" 8 = Disconnect without further rinseback
parent.demoSelection = 60 # Prompt User
parent.demoCount = 0 # immediately
- elif params.data_int[0] == 9: # TBD!! Additional not implemented 9 = return to treatment
+ elif parent.params.data_int[0] == 9: # TBD!! Additional not implemented 9 = return to treatment
rsp_payload = integer_to_bytearray(EResponse.Rejected)
return rsp_id, rsp_payload
-def ui_displosal_removal_confirm_request(parent, params):
+def ui_displosal_removal_confirm_request(parent):
rsp_id = MsgIds.MSG_ID_HD_DISPOSABLE_REMOVAL_CONFIRM_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
@@ -453,7 +453,7 @@
return rsp_id, rsp_payload
-def ui_post_tx_next_request(parent, params):
+def ui_post_tx_next_request(parent):
rsp_id = MsgIds.MSG_ID_HD_POST_TX_NEXT_CMD_RESPONSE
rsp_payload = integer_to_bytearray(EResponse.Accepted)
rsp_payload += integer_to_bytearray(RequestRejectReasons.REQUEST_REJECT_REASON_NONE.value)
Index: dialin/ui/hd_simulator.py
===================================================================
diff -u -r1e9de03223eeeec426716c6157ce88ddd60e4d5a -r691116a693026e10fdaf825d77107e1587ba66e9
--- dialin/ui/hd_simulator.py (.../hd_simulator.py) (revision 1e9de03223eeeec426716c6157ce88ddd60e4d5a)
+++ dialin/ui/hd_simulator.py (.../hd_simulator.py) (revision 691116a693026e10fdaf825d77107e1587ba66e9)
@@ -27,8 +27,8 @@
from math import copysign
import threading as threads_here
from time import time, sleep
-from . import dd_ui_request_handler as uim
-from . import dd_selection_handler as sel
+from . import dd_ui_request_handler as uiHandler
+from . import dd_selection_handler as demoSelctionHandler
from . import pressure_ranges as pr
def catch_exception(f):
@@ -94,6 +94,7 @@
HDSimulator.instance_count = HDSimulator.instance_count + 1
+ self.params = None
self.demoCounter = 0
self.demoCount = 1
self.demoGroupCounter = 0
@@ -111,7 +112,7 @@
self.dialysate_flow_measured_ml_per_min = 229.9 # simulation
self.dialysate_flow_set_point_ml_per_min = 250 # setting
self.arterial_pressure_mmHg = -80.8 # simulation
- self.arterial_pressure_mid_mmHg = -118.9 # setting
+ self.arterial_pressure_mid_mmHg = -118.9 # setting
self.venous_pressure_mmHg = 213.3 # simulation
self.venous_pressure_mid_mmHg = 185.2 # param
self.treatment_time_sec = 60 * 100 # setting
@@ -266,95 +267,94 @@
print(".", end='')
else:
print("generic handler:", MsgIds(msg_id).name, message)
- params = self.get_message_list_data(message) # convert payload data
+ self.params = self.get_message_list_data(message) # convert payload data
# UI RESET --------------------------------------------------------
if msg_id == MsgIds.MSG_ID_UI_POST_FINAL_TEST_RESULT.value:
- rsp_id, rsp_payload = uim.ui_post_final_test_result(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_post_final_test_result(self)
# RESET/JUMP FORWARD DIALOG HANDLER -------------------------------
if (msg_id == MsgIds.MSG_ID_UI_CONFIRMATION_RESULT_RESPONSE.value) and \
- (params.data_int[0] == 99) and \
- (params.data_int[1] == EResponse.Accepted): # TBD! Use const for 99
- rsp_id, rsp_payload = uim.ui_confirmation_result_response_99(self, params)
+ (self.params.data_int[0] == 99) and \
+ (self.params.data_int[1] == EResponse.Accepted): # TBD! Use const for 99
+ rsp_id, rsp_payload = uiHandler.ui_confirmation_result_response_99(self)
elif (msg_id == MsgIds.MSG_ID_UI_CONFIRMATION_RESULT_RESPONSE.value) and \
- (params.data_int[0] == 98):
- rsp_id, rsp_payload = uim.ui_confirmation_result_98(self, params)
+ (self.params.data_int[0] == 98):
+ rsp_id, rsp_payload = uiHandler.ui_confirmation_result_98(self)
elif (msg_id == MsgIds.MSG_ID_UI_CONFIRMATION_RESULT_RESPONSE.value) and \
- (params.data_int[0] == 6):
- rsp_id, rsp_payload = uim.ui_confirmation_result_response_6(self, params)
+ (self.params.data_int[0] == 6):
+ rsp_id, rsp_payload = uiHandler.ui_confirmation_result_response_6(self)
- # SERVICE MODE
elif msg_id == MsgIds.MSG_ID_UI_SERVICE_MODE_REQUEST.value: # 0xB0
- rsp_id, rsp_payload = uim.ui_service_mode_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_service_mode_request(self)
# INITIATE A NEW TREATMENT SETUP ----------------------------------
elif msg_id == MsgIds.MSG_ID_UI_INITIATE_TREATMENT_REQUEST.value:
- rsp_id, rsp_payload = uim.ui_initiate_treatment_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_initiate_treatment_request(self)
elif msg_id == MsgIds.MSG_ID_UI_NEW_TREATMENT_PARAMS_REQUEST.value:
- rsp_id, rsp_payload = uim.ui_new_treatment_params_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_new_treatment_params_request(self)
elif msg_id == MsgIds.MSG_ID_UI_USER_CONFIRM_TREATMENT_PARAMS_REQUEST.value:
- rsp_id, rsp_payload = uim.ui_user_confirm_treatment_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_user_confirm_treatment_request(self)
# WATER SAMPLING --------------------------------------------------
elif msg_id == MsgIds.MSG_ID_UI_SAMPLE_WATER_RESULT.value: # sample water completed, prime filter...
- rsp_id, rsp_payload = uim.ui_sample_water_result(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_sample_water_result(self)
# PRETREATMENT INSTALL AND TESTS ---------------------------------
elif msg_id == MsgIds.MSG_ID_UI_CONSUMABLE_INSTALL_CONFIRM_REQUEST.value:
- rsp_id, rsp_payload = uim.ui_consumable_install_confirm_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_consumable_install_confirm_request(self)
elif msg_id == MsgIds.MSG_ID_UI_INSTALLATION_CONFIRM_REQUEST.value:
- rsp_id, rsp_payload = uim.ui_installation_confirm_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_installation_confirm_request(self)
elif msg_id == MsgIds.MSG_ID_UI_START_PRIME_REQUEST.value: # _60 x3C 'Start Prime'
- rsp_id, rsp_payload = uim.ui_start_prime_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_start_prime_request(self)
# TREATMENT: PATIENT CONNECT --------------------------------------
elif msg_id == MsgIds.MSG_ID_UI_PATIENT_CONNECTION_BEGIN_REQUEST.value: # 100 x64 'Continue' Priming Complete
- rsp_id, rsp_payload = uim.ui_patient_connection_begin_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_patient_connection_begin_request(self)
elif msg_id == MsgIds.MSG_ID_UI_SET_UF_VOLUME_PARAMETER_REQUEST.value: # _79 x4F
- rsp_id, rsp_payload = uim.ui_set_uf_volume_parameter_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_set_uf_volume_parameter_request(self)
elif msg_id == MsgIds.MSG_ID_UI_PATIENT_CONNECTION_CONFIRM_REQUEST.value: # 102 x66
- rsp_id, rsp_payload = uim.ui_patient_connection_confirm_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_patient_connection_confirm_request(self)
elif msg_id == MsgIds.MSG_ID_UI_START_TREATMENT_REQUEST.value: # 113 x71
- rsp_id, rsp_payload = uim.ui_start_treatment_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_start_treatment_request(self)
# DIALYSIS ---------------------------------------------------
elif msg_id == MsgIds.MSG_ID_USER_TREATMENT_TIME_CHANGE_REQUEST.value: # _22 x16
- rsp_id, rsp_payload = uim.ui_user_treatment_time_change_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_user_treatment_time_change_request(self)
elif msg_id == MsgIds.MSG_ID_USER_SALINE_BOLUS_REQUEST.value: # _18 x12
- rsp_id, rsp_payload = uim.ui_user_saline_bolus_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_user_saline_bolus_request(self)
elif msg_id == MsgIds.MSG_ID_UI_HEPARIN_PAUSE_RESUME_REQUEST.value: # _.. x4B
- rsp_id, rsp_payload = uim.ui_heparin_pause_resume_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_heparin_pause_resume_request(self)
elif msg_id == MsgIds.MSG_ID_UI_PRESSURE_LIMITS_CHANGE_REQUEST.value: # _70 x46
- rsp_id, rsp_payload = uim.ui_pressure_limits_change_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_pressure_limits_change_request(self)
elif msg_id == MsgIds.MSG_ID_USER_BLOOD_DIAL_RATE_CHANGE_REQUEST.value: # _70 x46
- rsp_id, rsp_payload = uim.ui_user_blood_dial_rate_change_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_user_blood_dial_rate_change_request(self)
# RINSEBACK -------------------------
elif msg_id == MsgIds.MSG_ID_UI_RINSEBACK_CMD_REQUEST.value: # _82 x52
- rsp_id, rsp_payload = uim.ui_rinseback_cmd_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_rinseback_cmd_request(self)
elif msg_id == MsgIds.MSG_ID_UI_TREATMENT_LOG_DATA_REQUEST.value: # _74 x4A
self._send_treatment_log()
elif msg_id == MsgIds.MSG_ID_UI_DISPOSABLE_REMOVAL_CONFIRM_REQUEST.value: # 115 x73
- rsp_id, rsp_payload = uim.ui_displosal_removal_confirm_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_displosal_removal_confirm_request(self)
elif msg_id == MsgIds.MSG_ID_UI_POST_TX_NEXT_REQUEST.value: # 0x6
- rsp_id, rsp_payload = uim.ui_post_tx_next_request(self, params)
+ rsp_id, rsp_payload = uiHandler.ui_post_tx_next_request(self)
#
# --------------------------------------------------
@@ -405,72 +405,72 @@
self.demoTimedIncValue += 1
# RESET INIT TO STANDBY -------------------------------------------
if self.demoSelection == 1: # TBD Reset to start INIT
- rsp_id, rsp_payload = sel.reset(self)
+ rsp_id, rsp_payload = demoSelctionHandler.reset(self)
elif self.demoSelection == 2: # TBD Auto transit to standby
- rsp_id, rsp_payload = sel.auto_transit_to_standby(self)
+ rsp_id, rsp_payload = demoSelctionHandler.auto_transit_to_standby(self)
# PRETREATMENT ----------------------------------------------------
elif self.demoSelection == 4: # = PreTreatmentConsumableSelfTestStates.CONSUMABLE_SELF_TESTS_COMPLETE_STATE.value:
self.demoSelection = 7 # TBD! setup event to change to
else:
pass # repeat this selection
elif self.demoSelection == 7: # No Cartridge Self Tests
- rsp_id, rsp_payload = sel.cartridge_self_test(self)
+ rsp_id, rsp_payload = demoSelctionHandler.cartridge_self_test(self)
elif self.demoSelection == 8: # Cartridge Installation
- rsp_id, rsp_payload = sel.cartridge_installation(self)
+ rsp_id, rsp_payload = demoSelctionHandler.cartridge_installation(self)
elif self.demoSelection == 9: # Dry Self Tests; init by MSG_ID_UI_INSTALLATION_CONFIRM
- rsp_id, rsp_payload = sel.dry_self_test(self)
+ rsp_id, rsp_payload = demoSelctionHandler.dry_self_test(self)
# DIALYSATE PRIME CIRCUITS ----------------------------------------
elif self.demoSelection == 10: # Prime circuits with dialysate
- rsp_id, rsp_payload = sel.prime_circuits_with_dialysate(self)
+ rsp_id, rsp_payload = demoSelctionHandler.prime_circuits_with_dialysate(self)
elif self.demoSelection == 11: # Recirculate primed circuits
- rsp_id, rsp_payload = sel.recirculate_primed_circuits_1(self)
+ rsp_id, rsp_payload = demoSelctionHandler.recirculate_primed_circuits_1(self)
elif self.demoSelection == 12: # Recirculate primed circuits
- rsp_id, rsp_payload = sel.recirculate_primed_circuits_2(self)
+ rsp_id, rsp_payload = demoSelctionHandler.recirculate_primed_circuits_2(self)
#
## START TREATMENT GROUP -----------------------------------------
elif self.demoSelection == 20: # Start Treatment
- rsp_id, rsp_payload = sel.start_treatment(self)
+ rsp_id, rsp_payload = demoSelctionHandler.start_treatment(self)
elif self.demoSelection == 21: # Blood Prime
- rsp_id, rsp_payload = sel.blood_prime(self)
+ rsp_id, rsp_payload = demoSelctionHandler.blood_prime(self)
## DIALYSIS GROUP -------------------------------------------------
elif self.demoSelection == 22: # Dialysis
- rsp_id, rsp_payload = sel.start_dialysis(self)
+ rsp_id, rsp_payload = demoSelctionHandler.start_dialysis(self)
elif self.demoSelection == 29: # Enter/Return to normal UF Dialysis
- rsp_id, rsp_payload = sel.enter_normal_uf(self)
+ rsp_id, rsp_payload = demoSelctionHandler.enter_normal_uf(self)
elif self.demoSelection >= 30 and self.demoSelection < 40 : # Dialysis Data Update ----------------
- rsp_id, rsp_payload = sel.dialysis_data_update(self)
+ rsp_id, rsp_payload = demoSelctionHandler.dialysis_data_update(self)
## RINSEBACK GROUP -------------------------------------------------
elif (self.demoSelection >= 40) and (self.demoSelection < 50):
- rsp_id, rsp_payload = sel.rinseback(self)
+ rsp_id, rsp_payload = demoSelctionHandler.rinseback(self)
elif self.demoSelection == 60:
- rsp_id, rsp_payload = sel.confirmation_request(self)
+ rsp_id, rsp_payload = demoSelctionHandler.confirmation_request(self)
elif self.demoSelection == 61:
- rsp_id, rsp_payload = sel.op_mode_data(self)
+ rsp_id, rsp_payload = demoSelctionHandler.op_mode_data(self)
elif self.demoSelection == 100:
- rsp_id, rsp_payload = sel.wait_for_disinfect_state(self)
+ rsp_id, rsp_payload = demoSelctionHandler.wait_for_disinfect_state(self)
# x94 MSG_ID_HD_TREATMENT_LOG_PERIODIC_DATA,
# 1, 2,