added while loop to tube index updater

Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:15:02 +01:00 · 2024-02-17 23:15:02 +01:00 · 74fa0640ff
parent bedbf76b5f
commit 74fa0640ff
1 changed files with 9 additions and 8 deletions
--- a/server/app.py
+++ b/server/app.py
@ -152,14 +152,15 @@ def mqtt_publisher():
            sys.exit()

 def tube_index_updater():
-    mqtt_client = connect_mqtt()
-    cur = db.cursor()
-    cur.execute("SELECT mac_address, universe, dmx_address FROM tubes")
-    TUBE_INDEX = cur.fetchall()
-    cur.close()
-    mqtt_client.publish("pxm/tube_index", str(TUBE_INDEX))
-    print("Updated tube index")
-    time.sleep(1)
+    while True:
+        mqtt_client = connect_mqtt()
+        cur = db.cursor()
+        cur.execute("SELECT mac_address, universe, dmx_address FROM tubes")
+        TUBE_INDEX = cur.fetchall()
+        cur.close()
+        mqtt_client.publish("pxm/tube_index", str(TUBE_INDEX))
+        print("Updated tube index")
+        time.sleep(5)


 if __name__ == "__main__":