From e35f6951a1927bd14821cd5667b684e00c2f45cc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Daniele=20Vigan=C3=B2?= <daniele@vigano.me>
Date: Sat, 18 Dec 2021 01:06:04 +0100
Subject: [PATCH] First mqtt e2e stub

---
 dcc/driver/.connector.py.swp | Bin 12288 -> 12288 bytes
 dcc/driver/connector.py      |   9 +++++++++
 deamons/serial.py            |   9 +++++----
 3 files changed, 14 insertions(+), 4 deletions(-)

diff --git a/dcc/driver/.connector.py.swp b/dcc/driver/.connector.py.swp
index 8fc1fade6e65bb6738ac9c97f26ff082ba2cc2b4..99954e9840e46d58ee1eba31b5bcb2385766b9f9 100644
GIT binary patch
delta 525
zcmZXPziSg=7{@=wF6O;^-?|hXq^|)X!g0COf<cK(79GmP=CE$|?cLc1?sBp3Rj5ll
zD~Qrb6m;nyP%=BXIO)I8x;hJj4kEc21%0-M@9%?+gN?<_;O^~J-S(FO7U06=cV_A0
z@!}6P=Z()Td{z7X8Z3z^>P=X{X9cGUP857naIE09f>#QjDA-aEDhL#Om+)S~k%VUw
z9!uDh5K3rC2qgS;;fo7zTre*5U8uS6!J*5M11}tS?!c}C>kiy-VBUdm0!{^-2>2-A
zrGTdb?g>~Ia8pdmkLTulwX=G5hko<?c*T2kW<Smb>9F*ZfsKpdFpbN`6=tm8*l2e%
z8`$keJ&EIHT;#bKCbsVBk=e@%lXUXbTC<h@r<)ntG<)E$-if07x59qp>A!z3ytEem
ztJ58wKP*eXTQzGOzHNrdq*3M23)dpu(XDp-YE|=(t?uZ0Yx$ZV_<`T56KBR+-JMP<
ZcCG`1d{pd|dStc>zY3Vn)5cbL`~uJwd&K|%

delta 246
zcmXBOu}cDB7=ZETC}_C%``(k}a%d24tj=oDYK#UUA@IsAG-(qB6&rI5M3)1nCjW!D
zEof?LY_8UZh8)~<iMaXs4bQMXtot|nSLI5+6dnS2P|LkEem0-{r8+^9@fLdDcVS!7
z8vH9@uJEhyrSPmUQy3}SDGU_O6+(qQg_VVG3y&7AEnHaGu<&YNW?*7qY@ll(GEg$$
z7+45=3IQJiZvs<+2Z2k0NZ>@$v798%dew~&!mapyHya;?UQ*l{ti`p$S*F=)^m_Tz
NPP={E?034y`~h}>E=B+V

diff --git a/dcc/driver/connector.py b/dcc/driver/connector.py
index 48e03c0..2819b17 100644
--- a/dcc/driver/connector.py
+++ b/dcc/driver/connector.py
@@ -1,8 +1,17 @@
+import paho.mqtt.client as mqtt
+
+
 class Connector:
+    MQTT_HOST = "127.0.0.1"
+    MQTT_PORT = 1883
 
     @classmethod
     def __mqtt_pub(self, message):
         # to be encoded
+        client = mqtt.Client()
+        client.connect(self.MQTT_HOST, self.MQTT_PORT)
+        client.publish("dcc/commands", payload=message)
+        client.disconnect()
         print(message)
         return True
 
diff --git a/deamons/serial.py b/deamons/serial.py
index df7168e..644e42f 100644
--- a/deamons/serial.py
+++ b/deamons/serial.py
@@ -16,13 +16,14 @@ async def mqtt_broker(ser):
         async with client.unfiltered_messages() as messages:
             async for message in messages:
                 print(message.payload.decode())
-                ser.write(message.payload)
+                # ser.write(message.payload)
 
 
 def main():
     client = mqtt.Client()
-    ser = serial.Serial('/dev/pts/7')
-    ser.baudrate = 9600
+    # ser = serial.Serial('/dev/pts/7')
+    # ser.baudrate = 9600
+    ser = None  # remove me
     while True:
         try:
             client.connect(MQTT_HOST, MQTT_PORT)
@@ -34,7 +35,7 @@ def main():
     logging.info('Broker subscribed')
     client.disconnect()
     asyncio.run(mqtt_broker(ser))
-    ser.close()
+    # ser.close()
 
 
 if __name__ == "__main__":