cloud client

Author: kevinwieland

runs/lt

@@ -10,6 +10,7 @@
 BASE_TOPIC = "openWB-remote/"
 REMOTE_SUPPORT_TOPIC = BASE_TOPIC + "support"
 REMOTE_PARTNER_TOPIC = BASE_TOPIC + "partner"
+CLOUD_TOPIC = BASE_TOPIC + "cloud"
 support_tunnel: Popen = None
 partner_tunnel: Popen = None
 
@@ -51,6 +52,7 @@ def is_tunnel_closed(tunnel: Popen) -> bool:
 
     global support_tunnel
     global partner_tunnel
+    global cloud_tunnel
     payload = msg.payload.decode("utf-8")
     if len(payload) > 0:
         log.debug("Topic: %s, Message: %s", msg.topic, payload)
@@ -75,7 +77,6 @@ def is_tunnel_closed(tunnel: Popen) -> bool:
                                             f"{port}:localhost:22", f"{user}@remotesupport.openwb.de"])
                     log.info(f"tunnel running with pid {support_tunnel.pid}")
             else:
-                log.info("unknown message: " + payload)
         elif msg.topic == REMOTE_PARTNER_TOPIC:
             if payload == 'stop':
                 if partner_tunnel is None:
@@ -101,6 +102,31 @@ def is_tunnel_closed(tunnel: Popen) -> bool:
                         log.info(f"tunnel running with pid {partner_tunnel.pid}")
             else:
                 log.info("unknown message: " + payload)
+        elif msg.topic == CLOUD_TOPIC:
+            log.info("1")
+            if payload == 'stop':
+                if cloud_tunnel is None:
+                    log.error("received stop cloud message but tunnel is not running")
+                else:
+                    log.info("stop cloud tunnel")
+                    cloud_tunnel.terminate()
+                    cloud_tunnel.wait(timeout=3)
+                    cloud_tunnel = None
+            elif re.match(r'^([^;]+)(?:;([a-zA-Z0-9]+)(?:;([a-zA-Z0-9]+))?)?$', payload):
+            #elif payload != 'stio':
+                if is_tunnel_closed(partner_tunnel):
+                    splitted = payload.split(";")
+                    if len(splitted) != 3:
+                        log.error("invalid number of settings received!")
+                    else:
+                        token = splitted[0]
+                        cloudnode = splitted[1]
+                        user = splitted[2]
+                        log.info("start cloud tunnel" + token + cloudnode)
+                        cloud_tunnel = Popen(["/var/www/html/openWB/runs/lt", "-h", "https://" + cloudnode + ".openwb.de/", "-p", "80", "-s", token])
+                        log.info(f"cloud tunnel running with pid {cloud_tunnel.pid}")
+            else:
+                log.info("unknown message: " + payload)
         # clear topic
         client.publish(msg.topic, "", qos=2, retain=True)