From 84b9ddcc2905f5d8667cfef1359b724c23d27365 Mon Sep 17 00:00:00 2001
From: xengineering <mail2xengineering@protonmail.com>
Date: Thu, 29 Oct 2020 12:11:32 +0100
Subject: Setup basic Systemd Units

---
 iot_barcode/mqtt.py | 26 ++++++++++++++++++++++++++
 1 file changed, 26 insertions(+)
 create mode 100644 iot_barcode/mqtt.py

(limited to 'iot_barcode/mqtt.py')

diff --git a/iot_barcode/mqtt.py b/iot_barcode/mqtt.py
new file mode 100644
index 0000000..2b0ece1
--- /dev/null
+++ b/iot_barcode/mqtt.py
@@ -0,0 +1,26 @@
+
+
+"""Provide MQTT Functionality for the Package"""
+
+
+import paho.mqtt.client as mqtt
+
+
+class MqttService():
+    """Bundle for MQTT Functionality"""
+
+    def __init__(self, config):
+        self.config = config
+        self.client = mqtt.Client()
+        self.client.on_connect = self.on_connect
+
+    def run(self):
+        self.client.connect(
+            self.config["mqtt"]["broker"],
+            self.config["mqtt"]["port"],
+            60
+        )
+        self.client.loop_start()
+
+    def on_connect(self, client, userdata, flags, rc):
+        client.subscribe(self.config["mqtt"]["topic"])
-- 
cgit v1.2.3-70-g09d2