init

app.py

@@ -0,0 +1,65 @@
+import paho.mqtt.client as mqtt
+import os
+import gradio as gr
+import json
+import time
+
+HOST = os.environ.get("host")
+PORT = int(os.environ.get("port"))
+USERNAME = os.environ.get("username")
+PASSWORD = os.environ.get("password")
+
+client = None
+bed_temp = gr.Number()
+nozzle_temp = gr.Number()
+status = gr.Textbox()
+update_time = gr.Textbox()
+
+def create_client(host, port, username, password):
+    print(host, port, username, password)
+    client = mqtt.Client()
+    client.username_pw_set(username, password)
+    client.tls_set(tls_version=mqtt.ssl.PROTOCOL_TLS)
+    client.on_connect = on_connect
+    client.connect(host, port)
+    client.loop_start()
+    return client
+
+def on_connect(client, userdata, flags, rc):
+    print("Connected with result code "+str(rc))
+    
+def on_message(client, userdata, message):
+    global bed_temp, nozzle_temp, status, update_time
+    data = json.loads(message.payload)
+    bed_temp = data["bed_temperature"]
+    nozzle_temp = data["nozzle_temperature"]
+    status = data["status"]
+    update_time = str(time.time())
+    
+    
+def get_data(serial):
+    global client
+    if client is None:
+        client = create_client(HOST, PORT, USERNAME, PASSWORD)
+    client.publish(f"bambu_a1_mini/request/{serial}", json.dumps("HI"))
+    return
+
+with gr.Blocks() as blocks:
+    serial = gr.Input("text", label="Serial Number")
+    send_button = gr.Button(text="Send")
+    
+    status_text = gr.Textbox(label="Status", interactive=False)
+    bed_temp_text = gr.Textbox(label="Bed Temperature", interactive=False)
+    nozzle_temp_text = gr.Textbox(label="Nozzle Temperature", interactive=False)
+    
+    send_button.click(
+        fn=get_data,
+        # outputs=[status_text, bed_temp_text, nozzle_temp_text],
+    )
+
+    status.change(lambda: status, status_text, status_text)
+    bed_temp.change(lambda: bed_temp, bed_temp_text, bed_temp_text)
+    nozzle_temp.change(lambda: nozzle_temp, nozzle_temp_text, nozzle_temp_text)
+    
+    
+blocks.launch()

requirements.txt

@@ -0,0 +1 @@
+paho_mqtt