Update app.py

app.py

@@ -78,14 +78,17 @@ list_handler.setFormatter(logging.Formatter("%(asctime)s [%(levelname)s] %(messa
 logger.addHandler(list_handler)
 
 # -------------------------------------------------------------------
-# Helper Function: Compose Streaming Message
+# Helper Function: Compose Streaming Message (with extra stats)
 # -------------------------------------------------------------------
 def compose_streaming_message():
-    global live_log_display, error_notification
+    global live_log_display, error_notification, streaming_state, frames_encoded, bytes_sent
+    stats = f"State: {streaming_state} | Uptime: {get_uptime()} | Frames: {frames_encoded} | Bytes: {bytes_sent}\n"
     msg = ""
     if error_notification:
         msg += "<b>ERROR:</b> " + error_notification + "\n\n"
-    msg += "🚀 <b>Streaming in progress!</b>\n\nLive Logs:\n" + live_log_display + "\n\nUse the inline keyboard to control the stream."
+    msg += "🚀 <b>Streaming in progress!</b>\n"
+    msg += stats + "\n"
+    msg += "Live Logs:\n" + live_log_display + "\n\nUse the inline keyboard to control the stream."
     return msg
 
 # -------------------------------------------------------------------
@@ -236,7 +239,7 @@ def handle_setting(chat_id):
     user_inputs = {}
     current_step = conversation_fields[0]
     text = ("⚙️ *Advanced Mode Activated!*\n\n"
-            "Please enter the *input url*:")
+            "Please enter the *input url*:") 
     logging.info(f"/setting command from chat {chat_id} - advanced mode enabled")
     return {
         "method": "sendMessage",
@@ -410,6 +413,7 @@ def start_streaming(chat_id):
         stream_thread.daemon = True
         stream_thread.start()
         logging.info("Streaming thread started.")
+        # Immediately return a message that includes the live log display via compose_streaming_message()
         return {
             "method": "sendMessage",
             "chat_id": chat_id,
@@ -531,15 +535,13 @@ async def telegram_webhook(request: Request):
         else:
             response = send_guide_message(chat_id, "❓ Unknown callback command.")
 
-        # For streaming control callbacks, update the message with the latest live logs
+        # Always update the message text with the latest live logs and keep the inline keyboard
         if callback_data in ["pause", "resume", "abort", "status", "start_stream"]:
             response["method"] = "editMessageText"
             response["message_id"] = message_id
             response["text"] = compose_streaming_message()
             response["parse_mode"] = "HTML"
-            # Always include the inline keyboard if streaming is active.
-            if streaming_state in ["streaming", "paused"]:
-                response["reply_markup"] = get_inline_keyboard_for_stream()
+            response["reply_markup"] = get_inline_keyboard_for_stream()
         return response
 
     return {"status": "ok"}