revpi/revpicommander
1
0
Fork 0
mirror of https://github.com/naruxde/revpicommander.git synced 2025-11-08 16:43:53 +01:00
Code Issues Packages Releases Wiki Activity

Implement update function of ZeroConf ServiceListener

Browse Source
This commit is contained in:
Sven Sager
2023-01-03 11:07:11 +01:00
parent 03567dfefe
commit 0a7eb43d94
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
revpicommander/avahisearch.py
View File

@@ -20,6 +20,7 @@ class AvahiSearchThread(QtCore.QThread):
"""Search thread for Revolution Pi with installed RevPiPyLoad.""" """Search thread for Revolution Pi with installed RevPiPyLoad."""
added = QtCore.pyqtSignal(str, str, int, str, str) added = QtCore.pyqtSignal(str, str, int, str, str)
removed = QtCore.pyqtSignal(str, str) removed = QtCore.pyqtSignal(str, str)
updated = QtCore.pyqtSignal(str, str, int, str, str)
def __init__(self, parent=None): def __init__(self, parent=None):
super(AvahiSearchThread, self).__init__(parent) super(AvahiSearchThread, self).__init__(parent)
@@ -64,6 +65,16 @@ class AvahiSearchThread(QtCore.QThread):
for ip in info.parsed_addresses(IPVersion.V4Only): for ip in info.parsed_addresses(IPVersion.V4Only):
self.added.emit(name, info.server, info.port, conf_type, ip) self.added.emit(name, info.server, info.port, conf_type, ip)
def update_service(self, zeroconf: Zeroconf, conf_type: str, name: str) -> None:
"""New data of revolution pi"""
pi.logger.debug("AvahiSearchThread.add_service")
info = zeroconf.get_service_info(conf_type, name)
if not info:
return
for ip in info.parsed_addresses(IPVersion.V4Only):
self.updated.emit(name, info.server, info.port, conf_type, ip)
def run(self) -> None: def run(self) -> None:
pi.logger.debug("Started zero conf discovery.") pi.logger.debug("Started zero conf discovery.")
zeroconf = Zeroconf() zeroconf = Zeroconf()
@@ -110,13 +121,14 @@ class AvahiSearch(QtWidgets.QDialog, Ui_diag_search):
helper.settings.endArray() helper.settings.endArray()
def _restart_search(self) -> None: def _restart_search(self) -> None:
"""Clean up an restart search thread.""" """Clean up and restart search thread."""
while self.tb_revpi.rowCount() > 0: while self.tb_revpi.rowCount() > 0:
self.tb_revpi.removeRow(0) self.tb_revpi.removeRow(0)
self.th_zero_conf.requestInterruption() self.th_zero_conf.requestInterruption()
self.th_zero_conf = AvahiSearchThread(self) self.th_zero_conf = AvahiSearchThread(self)
self.th_zero_conf.added.connect(self.on_avahi_added) self.th_zero_conf.added.connect(self.on_avahi_added)
self.th_zero_conf.updated.connect(self.on_avahi_added)
self.th_zero_conf.removed.connect(self.on_avahi_removed) self.th_zero_conf.removed.connect(self.on_avahi_removed)
self.th_zero_conf.start() self.th_zero_conf.start()