Revize 4dc54176

Re #8489 - wip connect subscriber with window

aswi2021vochomurka/view/main_view.py

@@ -1 @@
-from PyQt5.QtCore import QSize
+from PyQt5.QtCore import QSize, QObject, pyqtSignal, QThread
 from PyQt5.QtWidgets import QMainWindow, QPlainTextEdit
+import paho.mqtt.client as mqtt
+
+
+class Worker(QObject):
+    connected = pyqtSignal()
+    newMessage = pyqtSignal(str)
+
+    def on_connect(self, client, userdata, flags, rc, properties=None):
+        print("Connected with result code " + str(rc))
+        self.connected.emit()
+        # Subscribing in on_connect() means that if we lose the connection and
+        # reconnect then subscriptions will be renewed.
+        client.subscribe("#")
+
+    # The callback for when a PUBLISH message is received from the server.
+    def on_message(self, client, userdata, message):
+        print(message.topic + " " + str(message.payload.decode("utf-8")))
+        self.newMessage.emit(message.topic + " " + str(message.payload.decode("utf-8")))
+
+    def start(self):
+        client = mqtt.Client()
+        client.on_connect = self.on_connect
+        client.on_message = self.on_message
+
+        client.connect("localhost", 1883, 60)
+
+        # Blocking call that processes network traffic, dispatches callbacks and
+        # handles reconnecting.
+        # Other loop*() functions are available that give a threaded interface and a
+        # manual interface.
+        client.loop_forever()
 
 
 class MainView(QMainWindow):
@@ -15 +46 @@
         self.b.insertPlainText("App started...\n")
         self.b.move(10, 10)
         self.b.resize(400, 200)
+
+        self.thread = QThread()
+        self.worker = Worker()
+        self.worker.moveToThread(self.thread)
+        self.thread.started.connect(self.worker.start)
+        self.worker.newMessage.connect(
+            lambda message: self.b.insertPlainText(message + "\n")
+        )
+
+        self.thread.start()