From 9291160798a392ad843ebdfd27a2b9db438f70b6 Mon Sep 17 00:00:00 2001 From: atse Date: Mon, 31 Jul 2023 16:36:48 +0800 Subject: [PATCH] Change name of tec_client --- pytec/tec_qt.py | 42 +++++++++++++++++++++--------------------- 1 file changed, 21 insertions(+), 21 deletions(-) diff --git a/pytec/tec_qt.py b/pytec/tec_qt.py index f9eb7b1..5dc718e 100644 --- a/pytec/tec_qt.py +++ b/pytec/tec_qt.py @@ -171,8 +171,8 @@ class MainWindow(QtWidgets.QMainWindow, Ui_MainWindow): self.hw_rev_data = None - self.tec_client = Client() - self.client_watcher = ClientWatcher(self, self.tec_client, self.report_refresh_spin.value()) + self.client = Client() + self.client_watcher = ClientWatcher(self, self.client, self.report_refresh_spin.value()) self.client_watcher.fan_update.connect(self.fan_update) self.client_watcher.report_update.connect(self.plot) self.client_watcher.report_update.connect(self.update_report) @@ -312,7 +312,7 @@ class MainWindow(QtWidgets.QMainWindow, Ui_MainWindow): @asyncSlot(bool) async def reset_thermostat(_): await self._on_connection_changed(False) - await self.tec_client.reset() + await self.client.reset() await asyncio.sleep(0.1) # Wait for the reset to start self.connect_btn.click() # Reconnect @@ -425,8 +425,8 @@ class MainWindow(QtWidgets.QMainWindow, Ui_MainWindow): self.connect_btn.setText("Disconnect" if result else "Connect") if result: self.client_watcher.start_watching() - self._status(await self.tec_client.hw_rev()) - self.fan_update(await self.tec_client.fan()) + self._status(await self.client.hw_rev()) + self.fan_update(await self.client.fan()) else: self.status_lbl.setText("Disconnected") self.fan_pwm_warning.setPixmap(QtGui.QPixmap()) @@ -466,24 +466,24 @@ class MainWindow(QtWidgets.QMainWindow, Ui_MainWindow): @asyncSlot(int) async def fan_set(self, value): - if not self.tec_client.is_connected(): + if not self.client.is_connected(): return if self.fan_auto_box.isChecked(): with QSignalBlocker(self.fan_auto_box): self.fan_auto_box.setChecked(False) - await self.tec_client.set_param("fan", value) + await self.client.set_param("fan", value) if not self.hw_rev_data["settings"]["fan_pwm_recommended"]: self._set_fan_pwm_warning() @asyncSlot(int) async def fan_auto_set(self, enabled): - if not self.tec_client.is_connected(): + if not self.client.is_connected(): return if enabled: - await self.tec_client.set_param("fan", "auto") - self.fan_update(await self.tec_client.fan()) + await self.client.set_param("fan", "auto") + self.fan_update(await self.client.fan()) else: - await self.tec_client.set_param("fan", self.fan_power_slider.value()) + await self.client.set_param("fan", self.fan_power_slider.value()) @asyncSlot(int) async def on_report_box_stateChanged(self, enabled): @@ -491,48 +491,48 @@ class MainWindow(QtWidgets.QMainWindow, Ui_MainWindow): if enabled: self.report_mode_task = asyncio.create_task(self.report_mode()) else: - self.tec_client.stop_report_mode() + self.client.stop_report_mode() await self.report_mode_task self.report_mode_task = None async def report_mode(self): - async for report in self.tec_client.report_mode(): + async for report in self.client.report_mode(): self.client_watcher.report_update.emit(report) async def stop_report_mode(self): if self.report_mode_task is not None: - self.tec_client.stop_report_mode() + self.client.stop_report_mode() await self.report_mode_task self.report_mode_task = None @asyncClose async def closeEvent(self, event): await self._on_connection_changed(False) - await self.tec_client.disconnect() + await self.client.disconnect() @asyncSlot() async def on_connect_btn_clicked(self): ip, port = self.host_set_line.text(), self.port_set_spin.value() try: - if not (self.tec_client.is_connecting() or self.tec_client.is_connected()): + if not (self.client.is_connecting() or self.client.is_connected()): self.status_lbl.setText("Connecting...") self.connect_btn.setText("Stop") self.host_set_line.setEnabled(False) self.port_set_spin.setEnabled(False) try: - await self.tec_client.connect(host=ip, port=port, timeout=30) + await self.client.connect(host=ip, port=port, timeout=30) except StoppedConnecting: return await self._on_connection_changed(True) else: await self._on_connection_changed(False) - await self.tec_client.disconnect() + await self.client.disconnect() except (OSError, TimeoutError, asyncio.TimeoutError) as e: # TODO: Remove asyncio.TimeoutError in Python 3.11 logging.error(f"Failed communicating to {ip}:{port}: {e}") await self._on_connection_changed(False) - await self.tec_client.disconnect() + await self.client.disconnect() @pyqtSlot(list) def plot(self, report): @@ -550,7 +550,7 @@ class MainWindow(QtWidgets.QMainWindow, Ui_MainWindow): for param, change, data in changes: if param.name() == 'Temperature PID' and not data: ch = param.opts["payload"] - await self.tec_client.set_param('pwm', ch, 'i_set', params[ch].child('Constant Current').value()) + await self.client.set_param('pwm', ch, 'i_set', params[ch].child('Constant Current').value()) line = getattr(self, f'ch{ch}_t_line') line.setVisible(False) elif param.opts.get("commands", None) is not None: @@ -558,7 +558,7 @@ class MainWindow(QtWidgets.QMainWindow, Ui_MainWindow): getattr(self, f'ch{param.opts["payload"]}_t_line').setVisible(True) elif param.name() == 'Set Temperature': getattr(self, f'ch{param.opts["payload"]}_t_line').setValue(data) - await asyncio.gather(*[self.tec_client._command(x.format(value=data)) for x in param.opts["commands"]]) + await asyncio.gather(*[self.client._command(x.format(value=data)) for x in param.opts["commands"]]) def _set_param_tree(self): for i, tree in enumerate((self.ch0_tree, self.ch1_tree)):