Update app.py

app.py

@@ -157,6 +157,20 @@ def validate_inputs():
         return False, f"Missing fields: {', '.join(missing)}"
     return True, ""
 
+# -------------------------------------------------------------------
+# Notify Error Helper
+# -------------------------------------------------------------------
+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.",
+        "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}")
+
 # -------------------------------------------------------------------
 # Live Logging Updater (Background Thread)
 # -------------------------------------------------------------------
@@ -379,10 +393,11 @@ def stream_to_youtube(input_url, quality_settings, video_codec, audio_codec, out
         logging.info("Streaming complete, resources cleaned up.")
         streaming_state = "idle"
     except Exception as e:
-        error_message = f"An error occurred during streaming: {str(e)}"
+        error_message = f"An error occurred during streaming: {str(e)}\n\n{traceback.format_exc()}"
         logging.error(error_message)
-        logging.error(traceback.format_exc())
         streaming_state = "idle"
+        # Notify the user about the error using the logs
+        notify_error(chat_id, error_message)
 
 def start_streaming(chat_id):
     global stream_thread, live_log_thread, stream_chat_id
@@ -414,16 +429,18 @@ 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)
         return {
             "method": "sendMessage",
             "chat_id": chat_id,
-            "text": "🚀 *Streaming initiated!* Use the inline keyboard to control the stream.",
+            "text": "🚀 *Streaming initiated!* Live logs are now updating below. Use the inline keyboard to control the stream.",
             "reply_markup": get_inline_keyboard_for_stream(),
             "parse_mode": "Markdown"
         }
     except Exception as e:
         error_message = f"Failed to start streaming: {str(e)}"
         logging.error(error_message)
+        notify_error(chat_id, error_message)
         return send_guide_message(chat_id, error_message)
 
 # -------------------------------------------------------------------