Update app.py

app.py

@@ -15,8 +15,11 @@ app = FastAPI()
 # -------------------------------------------------------------------
 # Configuration & Global Variables
 # -------------------------------------------------------------------
-# TELEGRAM_BOT_TOKEN = os.getenv("TELEGRAM_BOT_TOKEN")
-# TELEGRAM_API_URL = f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}"
+# We no longer use a global TELEGRAM_API_URL variable.
+# The bot token is obtained on demand via the helper function below.
+TELEGRAM_BOT_TOKEN = os.getenv("TELEGRAM_BOT_TOKEN")
+if not TELEGRAM_BOT_TOKEN:
+    raise ValueError("Please set the TELEGRAM_BOT_TOKEN environment variable.")
 
 # Conversation state
 user_inputs = {}
@@ -37,7 +40,7 @@ default_settings = {
 
 # Streaming state & statistics
 streaming_state = "idle"  # "idle", "streaming", "paused", "stopped"
-stream_chat_id = None  # Chat ID for periodic updates
+stream_chat_id = None     # Chat ID for periodic updates
 stream_start_time = None
 frames_encoded = 0
 bytes_sent = 0
@@ -55,6 +58,27 @@ live_log_thread = None
 live_log_lines = []  # Rolling list (max 50 lines)
 live_log_message_id = None
 
+# -------------------------------------------------------------------
+# Helper: Send Telegram API Request
+# -------------------------------------------------------------------
+def send_telegram_request(method: str, payload: dict):
+    """
+    Helper to send a request to the Telegram API.
+    """
+    bot_token = os.getenv("TELEGRAM_BOT_TOKEN")
+    if not bot_token:
+        logging.error("Missing TELEGRAM_BOT_TOKEN environment variable.")
+        return None
+    url = f"https://api.telegram.org/bot{bot_token}/{method}"
+    try:
+        response = requests.post(url, json=payload)
+        if not response.ok:
+            logging.error(f"Request to {url} failed with {response.text}")
+        return response
+    except Exception as e:
+        logging.error(f"Error sending request to Telegram: {e}")
+        return None
+
 # -------------------------------------------------------------------
 # Enhanced Logging Setup
 # -------------------------------------------------------------------
@@ -84,11 +108,11 @@ logger.addHandler(list_handler)
 # Utility Functions & UI Helpers
 # -------------------------------------------------------------------
 def create_html_message(text: str):
-    # Wrap text in <pre> tags for monospaced output
+    # Wrap text in <pre> tags for monospaced output (HTML parse mode)
     return {"parse_mode": "HTML", "text": f"<pre>{text}</pre>"}
 
 def get_inline_keyboard_for_stream():
-    # Inline keyboard for streaming controls after stream has started
+    # Inline keyboard for streaming controls after the stream has started
     keyboard = {
         "inline_keyboard": [
             [
@@ -163,13 +187,10 @@ def validate_inputs():
 def notify_error(chat_id, error_message):
     payload = {
         "chat_id": chat_id,
-        "text": f"⚠️ *Streaming Error Occurred:*\n\n{error_message}\n\nPlease check logs for details.",
+        "text": f"⚠️ *Streaming Error Occurred:*\n\n{error_message}\n\nPlease check the live logs for details.",
         "parse_mode": "Markdown"
     }
-    try:
-        requests.post(f"{TELEGRAM_API_URL}/sendMessage", json=payload)
-    except Exception as e:
-        logging.error(f"Failed to notify error to user: {e}")
+    send_telegram_request("sendMessage", payload)
 
 # -------------------------------------------------------------------
 # Live Logging Updater (Background Thread)
@@ -183,8 +204,8 @@ def live_log_updater(chat_id):
             "text": "<pre>Live Logs:\nInitializing...</pre>",
             "parse_mode": "HTML"
         }
-        resp = requests.post(f"{TELEGRAM_API_URL}/sendMessage", json=payload)
-        if resp.ok:
+        resp = send_telegram_request("sendMessage", payload)
+        if resp and resp.ok:
             live_log_message_id = resp.json()["result"]["message_id"]
             logging.info(f"Live log message sent with id {live_log_message_id}")
         else:
@@ -201,7 +222,7 @@ def live_log_updater(chat_id):
                 "text": log_text,
                 "parse_mode": "HTML"
             }
-            requests.post(f"{TELEGRAM_API_URL}/editMessageText", json=edit_payload)
+            send_telegram_request("editMessageText", edit_payload)
             time.sleep(1)
     except Exception as e:
         logging.error(f"Error in live log updater: {e}")
@@ -297,7 +318,7 @@ def handle_conversation(chat_id, text):
                 user_inputs.setdefault("quality_settings", default_settings["quality_settings"])
                 user_inputs.setdefault("video_codec", default_settings["video_codec"])
                 user_inputs.setdefault("audio_codec", default_settings["audio_codec"])
-            # Instead of asking user to type "start", send an inline button.
+            # Instead of asking the user to type "start", send an inline button.
             return {
                 "method": "sendMessage",
                 "chat_id": chat_id,
@@ -396,7 +417,7 @@ def stream_to_youtube(input_url, quality_settings, video_codec, audio_codec, out
         error_message = f"An error occurred during streaming: {str(e)}\n\n{traceback.format_exc()}"
         logging.error(error_message)
         streaming_state = "idle"
-        # Notify the user about the error using the logs
+        # Notify the user about the error using the live logs
         notify_error(chat_id, error_message)
 
 def start_streaming(chat_id):
@@ -429,7 +450,7 @@ def start_streaming(chat_id):
         live_log_thread.start()
         logging.info("Live log updater started.")
 
-        # Immediately show the live log (initial update will appear in 1 second)
+        # Immediately inform the user that streaming has started
         return {
             "method": "sendMessage",
             "chat_id": chat_id,