Upload folder using huggingface_hub

Dockerfile

@@ -0,0 +1,21 @@
+FROM python:3.10-slim
+
+# Cài đặt ffmpeg và các công cụ cần thiết
+RUN apt-get update && \
+    apt-get install -y --no-install-recommends ffmpeg curl procps && \
+    apt-get clean && \
+    rm -rf /var/lib/apt/lists/*
+
+WORKDIR /app
+
+# Cài đặt python dependencies
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+# Copy toàn bộ mã nguồn và video
+COPY . .
+
+# Mở cổng 7860 (cổng mặc định của Hugging Face Spaces)
+EXPOSE 7860
+
+CMD ["python", "app.py"]

README.md

@@ -1,12 +1,14 @@
 ---
-title: Webui
-emoji: 💻
-colorFrom: green
-colorTo: indigo
+title: YouTube 24/7 Live Streamer
+emoji: 🔴
+colorFrom: red
+colorTo: gray
 sdk: gradio
-sdk_version: 5.9.1
+sdk_version: 4.26.0
 app_file: app.py
 pinned: false
 ---
 
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+# YouTube 24/7 Live Stream Space - Album Đông A Tiêu Dao Lục
+
+Live stream 24/7 10 MV TriLyric 1080p theo chuẩn `livestream-ops-master`.

README.md.bak

@@ -0,0 +1,18 @@
+---
+title: YouTube 24/7 Live Streamer
+emoji: 🔴
+colorFrom: red
+colorTo: gray
+sdk: docker
+pinned: false
+---
+
+# YouTube 24/7 Live Stream Space
+
+Hệ thống phát Live Stream YouTube 24/7 vận hành theo chuẩn `livestream-ops-master`.
+
+### Cách sử dụng:
+1. Vào mục **Settings** của Space này -> **Variables and secrets**.
+2. Thêm Secret: `YOUTUBE_STREAM_KEY` = Mã khóa luồng YouTube của bạn.
+3. Space sẽ tự động kết nối và phát live liên tục 24/7.
+4. Dùng **UptimeRobot** ping vào URL của Space để giữ online vĩnh viễn không bị sleep.

app.py

@@ -1,4 +1,227 @@
-# import subprocess
+import os
+import sys
+import time
+import psutil
+import subprocess
+import threading
+import gradio as gr
+import gdown
 
-# Start Open WebUI server
-subprocess.run(["open-webui", "serve"])
+STREAM_PROCESS = None
+STREAM_LOGS = []
+IS_STREAMING = False
+IS_DOWNLOADING = False
+START_TIME = None
+
+DEFAULT_KEY = os.getenv("YOUTUBE_STREAM_KEY", "sztg-vq5m-7855-t6hz-69zu")
+READY_DIR = "ready_mvs"
+PLAYLIST_FILE = "playlist.txt"
+
+MVS = [
+    {"id": "1ghqyGINCZbfA7KajlwNpetVq5xclTzQW", "name": "ready_01_MV_TieuNgaoDongA_full_v4_trilyric.mp4", "title": "MV 01: Tiếu Ngạo Đông A"},
+    {"id": "1g2-fyGwxpmCglhg3_DT8u7Ugno88UG8D", "name": "ready_02_MV_LaughterBlueSea_Full_TriLyric_1080p.mp4", "title": "MV 02: Laughter in the Blue Sea"},
+    {"id": "14md9igmn_JYHgNDAsKbRbE78ZFQfufyr", "name": "ready_03_MV_CamKiemGiangHo_Full_TriLyric_1080p.mp4", "title": "MV 03: Cầm Kiếm Giang Hồ"},
+    {"id": "1FNXyQA2El-Ikjep-VVmKLFnh9N0BVIbH", "name": "ready_04_MV_DrinkingAloneLucDau_Full_TriLyric_1080p.mp4", "title": "MV 04: Độc Ẩm Lục Đầu Giang"},
+    {"id": "1FXoOUAlkqdvMZLGAtsDBhP3Gzula7s-v", "name": "ready_05_MV_WindPhuVanPeak_Full_TriLyric_1080p.mp4", "title": "MV 05: Gió Đỉnh Phù Vân"},
+    {"id": "1AzRqFArjLqKtbQdJXx000FUKse87Edar", "name": "ready_06_MV_BenVangCanChen_Full_TriLyric_1080p.mp4", "title": "MV 06: Bến Vắng Cạn Chén"},
+    {"id": "1QeCXltTbGW5GSXrrN8t4gJnQnmrQrbho", "name": "ready_07_MV_ThaoThaoBachDang_Full_TriLyric_1080p.mp4", "title": "MV 07: Thao Thao Bạch Đằng"},
+    {"id": "1BwC1CyvYD_r5Ar75JgfHIW6pu8IOGX5-", "name": "ready_08_MV_CarefreeLaughter_Full_TriLyric_1080p.mp4", "title": "MV 08: Tiếu Ngạo Nhân Sinh"},
+    {"id": "1E-A2_0am9x0NCBOneFKZf_ty_OYUNgd6", "name": "ready_09_MV_GacKiemLoGom_Full_TriLyric_1080p.mp4", "title": "MV 09: Gác Kiếm Lò Gốm"},
+    {"id": "1f19iqmUGPH31aDNT6DLy8lTA9pGw9Pqv", "name": "ready_10_MV_VanDamKhaiHoan_Full_TriLyric_1080p.mp4", "title": "MV 10: Vạn Dặm Khải Hoàn"}
+]
+
+def append_log(msg):
+    timestamp = time.strftime("%Y-%m-%d %H:%M:%S")
+    log_line = f"[{timestamp}] {msg}"
+    print(log_line)
+    STREAM_LOGS.append(log_line)
+    if len(STREAM_LOGS) > 150:
+        STREAM_LOGS.pop(0)
+
+def ensure_all_mvs_ready():
+    global IS_DOWNLOADING
+    os.makedirs(READY_DIR, exist_ok=True)
+    missing = [mv for mv in MVS if not (os.path.exists(os.path.join(READY_DIR, mv["name"])) and os.path.getsize(os.path.join(READY_DIR, mv["name"])) > 1024*1024)]
+    
+    if not missing:
+        append_log("[OK] Tất cả 10 MV đã sẵn sàng trong thư mục ready_mvs.")
+        generate_playlist()
+        return True
+
+    IS_DOWNLOADING = True
+    append_log(f"Đang tải {len(missing)} MV từ Google Drive vào hệ thống...")
+
+    for idx, mv in enumerate(missing, 1):
+        target = os.path.join(READY_DIR, mv["name"])
+        url = f"https://drive.google.com/uc?id={mv['id']}"
+        append_log(f"[{idx}/{len(missing)}] Đang tải: {mv['title']}...")
+        try:
+            gdown.download(url, target, quiet=True)
+            if os.path.exists(target) and os.path.getsize(target) > 1024*1024:
+                append_log(f"-> Hoàn tất: {mv['name']} ({os.path.getsize(target)/(1024*1024):.1f} MB)")
+            else:
+                append_log(f"[CẢNH BÁO] File {mv['name']} tải không thành công.")
+        except Exception as e:
+            append_log(f"[LỖI TẢI] {mv['title']}: {str(e)}")
+
+    IS_DOWNLOADING = False
+    generate_playlist()
+    return True
+
+def generate_playlist():
+    os.makedirs(READY_DIR, exist_ok=True)
+    lines = []
+    for mv in MVS:
+        fpath = os.path.join(READY_DIR, mv["name"])
+        if os.path.exists(fpath) and os.path.getsize(fpath) > 1024*1024:
+            lines.append(f"file '{fpath.replace(chr(92), '/')}'")
+
+    if lines:
+        with open(PLAYLIST_FILE, "w", encoding="utf-8") as f:
+            f.write("\n".join(lines) + "\n")
+        append_log(f"Đã cập nhật playlist {PLAYLIST_FILE} ({len(lines)} MV).")
+        return True
+    return False
+
+def stream_worker(key: str):
+    global STREAM_PROCESS, IS_STREAMING, START_TIME
+    ensure_all_mvs_ready()
+    
+    if not os.path.exists(PLAYLIST_FILE) or os.path.getsize(PLAYLIST_FILE) == 0:
+        append_log("[LỖI] Playlist trống! Không thể phát Live.")
+        IS_STREAMING = False
+        return
+
+    IS_STREAMING = True
+    START_TIME = time.time()
+    rtmp_url = f"rtmp://a.rtmp.youtube.com/live2/{key}"
+
+    append_log(f"Bắt đầu đẩy luồng RTMP lên YouTube Live (-c:v copy pass-through)...")
+
+    cmd = [
+        "ffmpeg",
+        "-re",
+        "-f", "concat",
+        "-safe", "0",
+        "-stream_loop", "-1",
+        "-i", PLAYLIST_FILE,
+        "-c:v", "copy",
+        "-c:a", "aac",
+        "-b:a", "128k",
+        "-ar", "48000",
+        "-f", "flv",
+        rtmp_url
+    ]
+
+    while IS_STREAMING:
+        try:
+            append_log("Khởi động FFmpeg Stream Engine...")
+            STREAM_PROCESS = subprocess.Popen(
+                cmd,
+                stdout=subprocess.PIPE,
+                stderr=subprocess.STDOUT,
+                universal_newlines=True
+            )
+            for line in STREAM_PROCESS.stdout:
+                if not IS_STREAMING:
+                    break
+                if "frame=" in line or "bitrate=" in line or "fps=" in line:
+                    if len(STREAM_LOGS) > 0 and ("frame=" in STREAM_LOGS[-1] or "bitrate=" in STREAM_LOGS[-1]):
+                        STREAM_LOGS[-1] = f"[{time.strftime('%H:%M:%S')}] {line.strip()}"
+                    else:
+                        append_log(line.strip())
+                elif any(kw in line.lower() for kw in ["error", "warning", "opening"]):
+                    append_log(line.strip())
+
+            STREAM_PROCESS.wait()
+            if IS_STREAMING:
+                append_log("[CẢNH BÁO] Luồng ngắt quãng. Tự động kết nối lại sau 10s...")
+                time.sleep(10)
+        except Exception as e:
+            append_log(f"[LỖI ENGINE] {str(e)}")
+            time.sleep(10)
+
+def start_stream(key):
+    global IS_STREAMING
+    if not key or not key.strip():
+        return "Vui lòng nhập YouTube Stream Key!"
+    if IS_STREAMING:
+        return "Luồng Live đã đang chạy!"
+    
+    t = threading.Thread(target=stream_worker, args=(key.strip(),), daemon=True)
+    t.start()
+    return "Đã kích hoạt lệnh phát Live 24/7!"
+
+def stop_stream():
+    global IS_STREAMING, STREAM_PROCESS
+    IS_STREAMING = False
+    if STREAM_PROCESS:
+        STREAM_PROCESS.terminate()
+    append_log("Đã gửi lệnh dừng live.")
+    return "Đã dừng Live."
+
+def get_status():
+    uptime_str = "Chưa phát"
+    if IS_STREAMING and START_TIME:
+        elapsed = int(time.time() - START_TIME)
+        h, rem = divmod(elapsed, 3600)
+        m, s = divmod(rem, 60)
+        uptime_str = f"{h}h {m}m {s}s"
+
+    status_txt = "🔴 ĐANG LIVE 24/7" if IS_STREAMING else "⚪ ĐÃ DỪNG"
+    if IS_DOWNLOADING:
+        status_txt += " (Đang tải MV...)"
+
+    cpu = f"{psutil.cpu_percent()}%"
+    ram = f"{psutil.virtual_memory().percent}%"
+    
+    mv_data = []
+    for idx, mv in enumerate(MVS, 1):
+        fpath = os.path.join(READY_DIR, mv["name"])
+        exists = os.path.exists(fpath) and os.path.getsize(fpath) > 1024*1024
+        sz = f"{os.path.getsize(fpath)/(1024*1024):.1f} MB" if exists else "Chưa có"
+        st = "✅ Sẵn sàng" if exists else "⏳ Chờ tải"
+        mv_data.append([idx, mv["title"], sz, st])
+
+    logs_txt = "\n".join(STREAM_LOGS[-30:])
+    return status_txt, uptime_str, cpu, ram, mv_data, logs_txt
+
+# Tự động tải nền và start nếu có stream key
+threading.Thread(target=ensure_all_mvs_ready, daemon=True).start()
+if DEFAULT_KEY:
+    threading.Thread(target=stream_worker, args=(DEFAULT_KEY,), daemon=True).start()
+
+with gr.Blocks(title="YouTube 24/7 Live Streamer") as demo:
+    gr.Markdown("# 🎬 Đông A Tiêu Dao Lục - YouTube Live Stream 24/7 Controller")
+    gr.Markdown("Vận hành theo chuẩn **`livestream-ops-master`** (Concat Demuxer, GOP 2s, 0 Drop frames).")
+
+    with gr.Row():
+        status_box = gr.Textbox(label="Trạng thái", value="Đang khởi tạo...", interactive=False)
+        uptime_box = gr.Textbox(label="Thời gian Live", value="0s", interactive=False)
+        cpu_box = gr.Textbox(label="CPU", value="0%", interactive=False)
+        ram_box = gr.Textbox(label="RAM", value="0%", interactive=False)
+
+    with gr.Row():
+        key_input = gr.Textbox(label="YouTube Stream Key", value=DEFAULT_KEY, type="password", scale=3)
+        start_btn = gr.Button("▶️ Bắt Đầu Live", variant="primary", scale=1)
+        stop_btn = gr.Button("⏹️ Dừng Live", variant="stop", scale=1)
+
+    gr.Markdown("### 📂 Danh mục 10 MV TriLyric 1080p (Playlist Loop)")
+    mv_table = gr.Dataframe(
+        headers=["#", "Tên MV", "Dung lượng", "Trạng thái"],
+        datatype=["number", "str", "str", "str"],
+        value=[]
+    )
+
+    gr.Markdown("### 📜 Nhật ký phát sóng (Live Logs)")
+    logs_box = gr.TextArea(label="FFmpeg Logs", lines=10, interactive=False)
+
+    start_btn.click(fn=start_stream, inputs=[key_input], outputs=[status_box])
+    stop_btn.click(fn=stop_stream, inputs=[], outputs=[status_box])
+
+    # Tự động cập nhật mỗi 5 giây
+    timer = gr.Timer(value=5)
+    timer.tick(fn=get_status, outputs=[status_box, uptime_box, cpu_box, ram_box, mv_table, logs_box])
+
+if __name__ == "__main__":
+    demo.launch(server_name="0.0.0.0", server_port=7860)

app.py.bak

@@ -0,0 +1,207 @@
+import os
+import sys
+import time
+import psutil
+import subprocess
+import threading
+from fastapi import FastAPI, Request, Form
+from fastapi.responses import HTMLResponse, JSONResponse
+import uvicorn
+
+app = FastAPI(title="YouTube 24/7 Live Streamer")
+
+STREAM_PROCESS = None
+STREAM_LOGS = []
+IS_STREAMING = False
+START_TIME = None
+
+VIDEO_PATH = os.getenv("VIDEO_PATH", "stream_video.mp4")
+STREAM_KEY = os.getenv("YOUTUBE_STREAM_KEY", "")
+
+def append_log(msg):
+    timestamp = time.strftime("%Y-%m-%d %H:%M:%S")
+    log_line = f"[{timestamp}] {msg}"
+    print(log_line)
+    STREAM_LOGS.append(log_line)
+    if len(STREAM_LOGS) > 100:
+        STREAM_LOGS.pop(0)
+
+def stream_worker(key: str):
+    global STREAM_PROCESS, IS_STREAMING, START_TIME
+    IS_STREAMING = True
+    START_TIME = time.time()
+    rtmp_url = f"rtmp://a.rtmp.youtube.com/live2/{key}"
+
+    append_log(f"Bắt đầu luồng phát Live Stream tới YouTube...")
+    
+    # Check if video exists
+    target_video = VIDEO_PATH
+    if not os.path.exists(target_video):
+        # find first mp4 file
+        mp4_files = [f for f in os.listdir(".") if f.endswith(".mp4")]
+        if mp4_files:
+            target_video = mp4_files[0]
+            append_log(f"Sử dụng file video tìm thấy: {target_video}")
+        else:
+            append_log(f"[ERROR] Không tìm thấy file video .mp4 nào trong thư mục!")
+            IS_STREAMING = False
+            return
+
+    cmd = [
+        "ffmpeg",
+        "-re",
+        "-stream_loop", "-1",
+        "-i", target_video,
+        "-c:v", "copy",
+        "-c:a", "aac",
+        "-b:a", "128k",
+        "-ar", "48000",
+        "-f", "flv",
+        rtmp_url
+    ]
+
+    while IS_STREAMING:
+        try:
+            append_log("Khởi chạy tiến trình FFmpeg...")
+            STREAM_PROCESS = subprocess.Popen(
+                cmd,
+                stdout=subprocess.PIPE,
+                stderr=subprocess.STDOUT,
+                universal_newlines=True
+            )
+            for line in STREAM_PROCESS.stdout:
+                if not IS_STREAMING:
+                    break
+                if "frame=" in line or "bitrate=" in line:
+                    if len(STREAM_LOGS) > 0 and ("frame=" in STREAM_LOGS[-1] or "bitrate=" in STREAM_LOGS[-1]):
+                        STREAM_LOGS[-1] = f"[{time.strftime('%H:%M:%S')}] {line.strip()}"
+                    else:
+                        append_log(line.strip())
+                elif "error" in line.lower() or "warning" in line.lower():
+                    append_log(line.strip())
+
+            STREAM_PROCESS.wait()
+            if IS_STREAMING:
+                append_log("[CẢNH BÁO] Luồng FFmpeg bị gián đoạn. Tự động khởi động lại sau 10 giây...")
+                time.sleep(10)
+        except Exception as e:
+            append_log(f"[LỖI] {str(e)}")
+            time.sleep(10)
+
+def start_background_stream(key: str):
+    t = threading.Thread(target=stream_worker, args=(key,), daemon=True)
+    t.start()
+
+@app.on_event("startup")
+def on_startup():
+    append_log("Hệ thống khởi động thành công.")
+    if STREAM_KEY:
+        append_log("Phát hiện Stream Key từ Environment/Secrets. Tự động bắt đầu live...")
+        start_background_stream(STREAM_KEY)
+
+@app.get("/health")
+@app.get("/ping")
+def health_check():
+    return {
+        "status": "healthy",
+        "streaming": IS_STREAMING,
+        "uptime": f"{int(time.time() - START_TIME)}s" if START_TIME else "0s"
+    }
+
+@app.get("/", response_class=HTMLResponse)
+def index():
+    uptime_str = "Chưa phát"
+    if IS_STREAMING and START_TIME:
+        elapsed = int(time.time() - START_TIME)
+        hours, remainder = divmod(elapsed, 3600)
+        minutes, seconds = divmod(remainder, 60)
+        uptime_str = f"{hours}h {minutes}m {seconds}s"
+
+    cpu_usage = psutil.cpu_percent()
+    ram_usage = psutil.virtual_memory().percent
+
+    log_html = "<br>".join(STREAM_LOGS[-25:])
+
+    status_badge = '<span style="background:#28a745;color:white;padding:4px 10px;border-radius:15px;font-weight:bold;">Đang Phát Live 24/7</span>' if IS_STREAMING else '<span style="background:#dc3545;color:white;padding:4px 10px;border-radius:15px;font-weight:bold;">Đang Dừng</span>'
+
+    html = f"""
+    <!DOCTYPE html>
+    <html lang="vi">
+    <head>
+        <meta charset="UTF-8">
+        <meta name="viewport" content="width=device-width, initial-scale=1.0">
+        <title>YouTube Live Stream Controller</title>
+        <meta http-equiv="refresh" content="10">
+        <style>
+            body {{ font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, sans-serif; background: #0f172a; color: #f8fafc; margin: 0; padding: 20px; }}
+            .container {{ max-width: 900px; margin: auto; background: #1e293b; padding: 25px; border-radius: 12px; box-shadow: 0 10px 25px rgba(0,0,0,0.5); }}
+            h1 {{ color: #38bdf8; margin-top: 0; display: flex; align-items: center; justify-content: space-between; }}
+            .stats {{ display: grid; grid-template-columns: repeat(auto-fit, minmax(200px, 1fr)); gap: 15px; margin: 20px 0; }}
+            .card {{ background: #0f172a; padding: 15px; border-radius: 8px; border: 1px solid #334155; }}
+            .card h3 {{ margin: 0 0 5px 0; font-size: 14px; color: #94a3b8; }}
+            .card p {{ margin: 0; font-size: 20px; font-weight: bold; color: #f1f5f9; }}
+            .logs {{ background: #020617; padding: 15px; border-radius: 8px; font-family: monospace; font-size: 12px; max-height: 300px; overflow-y: auto; color: #a3e635; border: 1px solid #1e293b; }}
+            .btn {{ background: #0284c7; color: white; border: none; padding: 10px 20px; border-radius: 6px; cursor: pointer; font-weight: bold; font-size: 14px; }}
+            .btn-danger {{ background: #e11d48; }}
+            input[type="password"], input[type="text"] {{ width: 70%; padding: 10px; border-radius: 6px; border: 1px solid #475569; background: #0f172a; color: white; box-sizing: border-box; }}
+            .form-group {{ margin: 15px 0; }}
+            .tip {{ font-size: 13px; color: #94a3b8; margin-top: 15px; }}
+        </style>
+    </head>
+    <body>
+        <div class="container">
+            <h1>YouTube 24/7 Live Controller {status_badge}</h1>
+            <div class="stats">
+                <div class="card">
+                    <h3>Thời gian live</h3>
+                    <p>{uptime_str}</p>
+                </div>
+                <div class="card">
+                    <h3>CPU Sử dụng</h3>
+                    <p>{cpu_usage}%</p>
+                </div>
+                <div class="card">
+                    <h3>RAM Sử dụng</h3>
+                    <p>{ram_usage}%</p>
+                </div>
+            </div>
+
+            <div class="form-group">
+                <form action="/action" method="post" style="display:flex; gap:10px;">
+                    <input type="password" name="key" placeholder="Nhập YouTube Stream Key (nếu chưa cấu hình Secret)..." value="{STREAM_KEY}">
+                    {'<button type="submit" name="action" value="stop" class="btn btn-danger">Dừng Live</button>' if IS_STREAMING else '<button type="submit" name="action" value="start" class="btn">Bắt Đầu Live</button>'}
+                </form>
+            </div>
+
+            <h3>Nhật ký hoạt động (Logs)</h3>
+            <div class="logs">
+                {log_html if log_html else 'Chưa có nhật ký nào...'}
+            </div>
+
+            <p class="tip">💡 <b>Mẹo giữ 24/7:</b> Dán đường link URL của Space này vào <a href="https://uptimerobot.com" target="_blank" style="color:#38bdf8;">UptimeRobot.com</a> để tự động ping mỗi 5 phút.</p>
+        </div>
+    </body>
+    </html>
+    """
+    return html
+
+@app.post("/action")
+def control_action(action: str = Form(...), key: str = Form(None)):
+    global IS_STREAMING, STREAM_PROCESS
+    if action == "start":
+        use_key = key.strip() if key else STREAM_KEY
+        if use_key:
+            if not IS_STREAMING:
+                start_background_stream(use_key)
+        else:
+            append_log("[LỖI] Không có Stream Key để bắt đầu.")
+    elif action == "stop":
+        IS_STREAMING = False
+        if STREAM_PROCESS:
+            STREAM_PROCESS.terminate()
+            append_log("Đã gửi lệnh dừng tiến trình FFmpeg.")
+
+    return HTMLResponse('<script>window.location.href="/";</script>')
+
+if __name__ == "__main__":
+    uvicorn.run(app, host="0.0.0.0", port=7860)

packages.txt

@@ -0,0 +1 @@
+ffmpeg

requirements.txt

@@ -0,0 +1,4 @@
+gradio>=4.26.0
+gdown>=5.1.0
+psutil>=5.9.8
+requests>=2.31.0

requirements.txt.bak

@@ -0,0 +1,4 @@
+fastapi>=0.110.0
+uvicorn>=0.28.0
+psutil>=5.9.8
+jinja2>=3.1.3