Update app.py

app.py

@@ -1,4 +1,3 @@
-import os
 import logging
 import threading
 import time
@@ -14,7 +13,7 @@ app = FastAPI()
 # -------------------------------------------------------------------
 # Configuration & Global Variables
 # -------------------------------------------------------------------
-# (No token or outgoing calls are used in this version.)
+# (No token or outgoing HTTP calls are used in this version.)
 # Conversation state
 user_inputs = {}
 # The conversation fields will depend on the mode.
@@ -49,9 +48,9 @@ stream_thread = None
 live_log_thread = None
 
 # Live logging globals
-live_log_lines = []         # Rolling list (max 50 lines)
-live_log_display = ""       # Global variable updated every second by live_log_updater
-error_notification = ""     # Global variable to hold any error notification message
+live_log_lines = []     # Rolling list (max 50 log lines)
+live_log_display = ""   # Global variable updated every second by live_log_updater
+error_notification = "" # Global variable to hold error details if any
 
 # -------------------------------------------------------------------
 # Enhanced Logging Setup
@@ -118,7 +117,7 @@ def help_text():
         "*/start* - Begin setup for streaming (simple mode: only Input & Output URL)\n"
         "*/setting* - Enter advanced settings (Input URL, Quality Settings, Video Codec, Audio Codec, Output URL)\n"
         "*/help* - Display this help text\n"
-        "*/logs* - Show the log history\n\n"
+        "*/logs* - Show the log history (live log display)\n\n"
         "After inputs are collected, press the inline *Start Streaming* button.\n\n"
         "While streaming, you can use inline buttons or commands:\n"
         "*/pause* - Pause the stream\n"
@@ -128,7 +127,7 @@ def help_text():
     )
 
 def send_guide_message(chat_id, message):
-    # Return a response dictionary (to be sent as the webhook response)
+    # Return a response dictionary to be sent as the webhook reply
     logging.info(f"Sending message to chat {chat_id}: {message}")
     return {
         "method": "sendMessage",
@@ -162,8 +161,7 @@ def validate_inputs():
 def notify_error(chat_id, error_message):
     global error_notification
     error_notification = error_message
-    # (This error will be available for the next webhook update; no outgoing call is made.)
-    logging.error(f"Error notified to user in chat {chat_id}: {error_message}")
+    logging.error(f"Error for chat {chat_id}: {error_message}")
 
 # -------------------------------------------------------------------
 # Live Log Updater (Background Thread)
@@ -172,7 +170,7 @@ def live_log_updater():
     global live_log_display, streaming_state
     try:
         while streaming_state in ["streaming", "paused"]:
-            # Update the live log display variable with the last 15 log lines in HTML format
+            # Update the global live_log_display with the last 15 log lines in HTML format
             live_log_display = "<pre>" + "\n".join(live_log_lines[-15:]) + "</pre>"
             time.sleep(1)
     except Exception as e:
@@ -182,12 +180,16 @@ def live_log_updater():
 # Logs History Handler (/logs)
 # -------------------------------------------------------------------
 def logs_history(chat_id):
-    # Return the last 50 log lines (if available) in HTML format
-    log_text = "<pre>" + "\n".join(live_log_lines[-50:]) + "</pre>"
-    # If an error notification exists, prepend it to the log text.
-    global error_notification
+    global live_log_display, error_notification
+    # Use the global live_log_display if available; otherwise, show a default message.
+    log_text = live_log_display if live_log_display else "<pre>No logs available yet.</pre>"
+    # If an error occurred, prepend the error notification.
     if error_notification:
-        log_text = f"<pre>ERROR: {error_notification}\n\n" + log_text[5:]
+        # Remove any opening <pre> tag from log_text and prepend error message
+        if log_text.startswith("<pre>"):
+            log_text = f"<pre>ERROR: {error_notification}\n\n" + log_text[5:]
+        else:
+            log_text = f"<pre>ERROR: {error_notification}\n\n{log_text}</pre>"
     return {
          "method": "sendMessage",
          "chat_id": chat_id,
@@ -200,7 +202,7 @@ def logs_history(chat_id):
 # -------------------------------------------------------------------
 def handle_start(chat_id):
     global current_step, user_inputs, conversation_fields, advanced_mode
-    # By default, simple mode (unless advanced_mode was set via /setting)
+    # By default, use simple mode unless advanced_mode is set via /setting
     user_inputs = {}
     if not advanced_mode:
         conversation_fields = ["input_url", "output_url"]
@@ -323,12 +325,13 @@ def stream_to_youtube(input_url, quality_settings, video_codec, audio_codec, out
 
         logging.info("Streaming started successfully.")
 
-        # Start the live log updater in a background thread
+        # Start the live log updater in a background thread if not already running.
         global live_log_thread
-        live_log_thread = threading.Thread(target=live_log_updater)
-        live_log_thread.daemon = True
-        live_log_thread.start()
-        logging.info("Live log updater thread started.")
+        if live_log_thread is None or not live_log_thread.is_alive():
+            live_log_thread = threading.Thread(target=live_log_updater)
+            live_log_thread.daemon = True
+            live_log_thread.start()
+            logging.info("Live log updater thread started.")
 
         # Stream loop: process packets until state changes
         while streaming_state in ["streaming", "paused"]:
@@ -407,7 +410,7 @@ def start_streaming(chat_id):
         logging.info("Streaming thread started.")
 
         # Immediately inform the user that streaming has started;
-        # live log updates will be available via the global variable and /logs command.
+        # live log updates are available via the global variable and the /logs command.
         return {
             "method": "sendMessage",
             "chat_id": chat_id,