Update app.py

app.py

@@ -83,8 +83,9 @@ logger.addHandler(list_handler)
 # -------------------------------------------------------------------
 # Utility Functions & UI Helpers
 # -------------------------------------------------------------------
-def create_markdown_message(text: str):
-    return {"parse_mode": "Markdown", "text": text}
+def create_html_message(text: str):
+    # Wrap text in <pre> tags for monospaced output
+    return {"parse_mode": "HTML", "text": f"<pre>{text}</pre>"}
 
 def get_inline_keyboard_for_stream():
     # Inline keyboard for streaming controls after stream has started
@@ -161,11 +162,11 @@ def validate_inputs():
 def live_log_updater(chat_id):
     global live_log_message_id, streaming_state
     try:
-        # Send initial live log message immediately upon starting the stream
+        # Send initial live log message in HTML format
         payload = {
             "chat_id": chat_id,
-            "text": "*Live Logs:*\n_(Initializing real-time logs...)_",
-            "parse_mode": "Markdown"
+            "text": "<pre>Live Logs:\nInitializing...</pre>",
+            "parse_mode": "HTML"
         }
         resp = requests.post(f"{TELEGRAM_API_URL}/sendMessage", json=payload)
         if resp.ok:
@@ -175,17 +176,18 @@ def live_log_updater(chat_id):
             logging.error("Failed to send live log message.")
             return
 
-        # Update live log every 5 seconds until streaming stops
+        # Update live log every 1 second until streaming stops
         while streaming_state in ["streaming", "paused"]:
-            log_text = "*Live Logs:*\n\n" + "\n".join(live_log_lines[-15:])  # show last 15 lines
+            # Show the last 15 log lines in HTML format
+            log_text = "<pre>" + "\n".join(live_log_lines[-15:]) + "</pre>"
             edit_payload = {
                 "chat_id": chat_id,
                 "message_id": live_log_message_id,
                 "text": log_text,
-                "parse_mode": "Markdown"
+                "parse_mode": "HTML"
             }
             requests.post(f"{TELEGRAM_API_URL}/editMessageText", json=edit_payload)
-            time.sleep(5)
+            time.sleep(1)
     except Exception as e:
         logging.error(f"Error in live log updater: {e}")
 
@@ -392,7 +394,7 @@ def start_streaming(chat_id):
         stream_thread.start()
         logging.info("Streaming thread started.")
 
-        # Start the live log updater thread (updates every 5 seconds for real-time logs)
+        # Start the live log updater thread (updates every 1 second in HTML format)
         live_log_thread = threading.Thread(target=live_log_updater, args=(chat_id,))
         live_log_thread.daemon = True
         live_log_thread.start()