Update app.py
Browse files
app.py
CHANGED
|
@@ -400,15 +400,14 @@ def _build_live_view_text(chat_id: int, mode: str = "status") -> str:
|
|
| 400 |
else:
|
| 401 |
status = compose_status_message(chat_id, include_config=False, include_logs=False)
|
| 402 |
logs = session.get('live_log_lines_user', [])
|
| 403 |
-
log_tail = "\n".join(logs[-
|
| 404 |
-
pause_note = "
|
| 405 |
|
| 406 |
# Only show log tail while actively streaming
|
| 407 |
if state in ("streaming", "starting", "paused", "reconnecting"):
|
| 408 |
return (
|
| 409 |
-
f"{status}
|
| 410 |
-
f"π <b>Recent Logs:</b>\n<pre>{esc(log_tail)}</pre>"
|
| 411 |
-
f"{pause_note}"
|
| 412 |
)
|
| 413 |
else:
|
| 414 |
return status + pause_note
|
|
@@ -880,11 +879,20 @@ def compose_status_message(chat_id: int, include_config: bool = False, include_l
|
|
| 880 |
loop_total = "β" if loop == -1 else str(max(loop, 1))
|
| 881 |
reconnect_att = session.get('reconnect_attempt', 0)
|
| 882 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 883 |
lines += [
|
| 884 |
-
|
| 885 |
-
f"β± <b>Uptime:</b> <code>{get_uptime(session.get('stream_start_time'))}</code>",
|
| 886 |
-
f"π <b>Frames:</b> <code>{session.get('frames_encoded', 0):,}</code>",
|
| 887 |
-
f"π€ <b>Sent:</b> <code>{session.get('bytes_sent', 0) / (1024*1024):.2f} MB</code>",
|
| 888 |
f"π¬ <b>Input:</b> <code>{esc(cur_url)}</code> ({idx+1}/{len(playlist)})",
|
| 889 |
f"π <b>Loop:</b> <code>{session.get('current_loop_iteration', 0)+1}/{loop_total}</code>",
|
| 890 |
]
|
|
@@ -896,8 +904,8 @@ def compose_status_message(chat_id: int, include_config: bool = False, include_l
|
|
| 896 |
|
| 897 |
if include_logs and state in ("streaming", "paused", "starting", "reconnecting"):
|
| 898 |
user_logs = session.get('live_log_lines_user', [])
|
| 899 |
-
last_logs = "\n".join(user_logs[-
|
| 900 |
-
lines += ["
|
| 901 |
|
| 902 |
return "\n".join(lines)
|
| 903 |
|
|
|
|
| 400 |
else:
|
| 401 |
status = compose_status_message(chat_id, include_config=False, include_logs=False)
|
| 402 |
logs = session.get('live_log_lines_user', [])
|
| 403 |
+
log_tail = "\n".join(logs[-4:]) if logs else "No logs yet."
|
| 404 |
+
pause_note = " <i>βΈ paused</i>" if is_paused else ""
|
| 405 |
|
| 406 |
# Only show log tail while actively streaming
|
| 407 |
if state in ("streaming", "starting", "paused", "reconnecting"):
|
| 408 |
return (
|
| 409 |
+
f"{status}"
|
| 410 |
+
f"\nπ <b>Recent Logs:</b>{pause_note}\n<pre>{esc(log_tail)}</pre>"
|
|
|
|
| 411 |
)
|
| 412 |
else:
|
| 413 |
return status + pause_note
|
|
|
|
| 879 |
loop_total = "β" if loop == -1 else str(max(loop, 1))
|
| 880 |
reconnect_att = session.get('reconnect_attempt', 0)
|
| 881 |
|
| 882 |
+
frames = session.get('frames_encoded', 0)
|
| 883 |
+
bytes_s = session.get('bytes_sent', 0)
|
| 884 |
+
stats_ready = frames > 0 or bytes_s > 0
|
| 885 |
+
|
| 886 |
+
stats_lines = []
|
| 887 |
+
if stats_ready:
|
| 888 |
+
stats_lines += [
|
| 889 |
+
f"β± <b>Uptime:</b> <code>{get_uptime(session.get('stream_start_time'))}</code>",
|
| 890 |
+
f"π <b>Frames:</b> <code>{frames:,}</code>",
|
| 891 |
+
f"π€ <b>Sent:</b> <code>{bytes_s / (1024*1024):.2f} MB</code>",
|
| 892 |
+
]
|
| 893 |
+
|
| 894 |
lines += [
|
| 895 |
+
*stats_lines,
|
|
|
|
|
|
|
|
|
|
| 896 |
f"π¬ <b>Input:</b> <code>{esc(cur_url)}</code> ({idx+1}/{len(playlist)})",
|
| 897 |
f"π <b>Loop:</b> <code>{session.get('current_loop_iteration', 0)+1}/{loop_total}</code>",
|
| 898 |
]
|
|
|
|
| 904 |
|
| 905 |
if include_logs and state in ("streaming", "paused", "starting", "reconnecting"):
|
| 906 |
user_logs = session.get('live_log_lines_user', [])
|
| 907 |
+
last_logs = "\n".join(user_logs[-4:]) if user_logs else "No logs yet."
|
| 908 |
+
lines += [f"\nπ <b>Recent Logs:</b>\n<pre>{esc(last_logs)}</pre>"]
|
| 909 |
|
| 910 |
return "\n".join(lines)
|
| 911 |
|