'backup'

.gitignore

@@ -10,7 +10,7 @@ __pycache__/
 .Python
 build/
 develop-eggs/
-# dist/
+dist/
 downloads/
 eggs/
 .eggs/

audio

@@ -1,30 +0,0 @@
-gpt的
-"-af",
-"arnndn=m=./arnndn-models/cb.rnnn:mix=0.88,"    # 人声增强
-"afftdn=nf=-24:tn=1,"                                         # FFT 降噪，抹平音乐中频
-"highpass=f=110,lowpass=f=4800,"                               # 切掉低音鼓/高频镲
-"equalizer=f=250:width_type=o:width=2:g=-9,"                   # 衰减低中频，音乐基础弱化
-"equalizer=f=800:width_type=o:width=1.5:g=-6,"                 # 再衰减中频，人声外区域
-"atempo=1.03,"                                                 # 轻微加速 3%，节奏轻微错位
-"asetrate=48000*1.02,aresample=48000,"                         # 音高上移 ~1/2 半音
-"afreqshift=shift=20,"                                         # 整体频率偏移 20Hz，破坏指纹
-"acompressor=threshold=-28dB:ratio=5:attack=8:release=80:makeup=5," # 压缩动态，音乐更“扁”
-"volume=1.15,"                                                 # 补偿整体音量
-"aresample=async=1:first_pts=0"                                # 保证音视频同步
-
-
-
-grok的
-"-af", "arnndn=m=./arnndn-models/cb.rnnn:mix=0.88,"
-"afftdn=nf=-24:tn=1,"  # 强FFT降噪，进一步抹平音乐中频
-"highpass=f=110,lowpass=f=4800,"  # 切掉低音鼓/高频镲，音乐能量大减
-"equalizer=f=250:width_type=o:width=2:g=-9,"  # 衰减低中频（很多音乐基础）
-"equalizer=f=800:width_type=o:width=1.5:g=-6,"  # 再衰减中频人声外区域
-"atempo=1.06,"  # 轻微加速6%，节奏错位
-"asetrate=48000*1.04,aresample=48000,"  # 音高上移约3/4半音
-"aphaser=type=t:decay=0.5:speed=0.4:delay=2,"  # 相位扫，谱图模糊
-"flanger=delay=4:depth=3:regen=35:width=60:speed=0.35,"  # 轻法兰杰，增加金属/扫频感
-"afreqshift=shift=45,"  # 整体频率偏移45Hz，进一步乱指纹
-"acompressor=threshold=-28dB:ratio=5:attack=8:release=80:makeup=5,"  # 压缩动态，让音乐更“扁”
-"volume=1.15,"  # 补偿整体音量损失
-"aresample=async=1:first_pts=0"

config/URL_config.ini

@@ -31,11 +31,5 @@ https://live.douyin.com/469980190666,主播: 茜茜柠檬茶(小米茶档_)
 https://live.douyin.com/388066418744,主播: 加速姐的摆摊日记
 https://live.douyin.com/661694696687,主播: 小米摆摊记
 https://live.douyin.com/228132412943,主播: 00后摆摊小可爱
-https://live.douyin.com/876677865786,主播: 牛哄哄
-https://live.douyin.com/573735790640,主播: 小董卤串(餐饮)
-https://live.douyin.com/260608582882,主播: 阿伟在炒饭(90後炒饭)
-https://live.douyin.com/210443559964,主播: 小小诺
-https://live.douyin.com/305363702471,主播: 嘉嘉在摆摊
-https://live.douyin.com/737395543665,主播: 西施天馋土豆(努力摆摊)
-https://live.douyin.com/109205360966,主播: 郸城胖小胖荷叶馍炸串
-https://live.douyin.com/783406789448,主播: 摆摊小天才
+https://live.douyin.com/876677865786
+https://live.douyin.com/573735790640

config/youtube.ini

@@ -1,3 +0,0 @@
-[youtube]
-# 只写 stream key（推荐方式）
-key = qxvb-r47b-r5ju-6ud3-6k7z

douyin_srs_ffplay.py

@@ -0,0 +1,230 @@
+# douyin_srs_ffplay.py
+
+import queue
+import unicodedata
+import traceback
+import subprocess
+import threading
+import re
+import time
+import datetime
+
+class StreamEnded(Exception):
+    pass
+
+def sanitize_title(text: str, max_len: int = 120) -> str:
+    if not text:
+        return ""
+    text = unicodedata.normalize("NFKC", text)
+    text = ''.join(ch for ch in text if unicodedata.category(ch)[0] != 'C')
+    text = ''.join(ch for ch in text if ord(ch) <= 0xFFFF)
+    return text.strip()[:max_len]
+
+def _stderr_reader_thread(proc, q):
+    try:
+        while True:
+            line = proc.stderr.readline()
+            if not line:
+                break
+            q.put(line)
+    except:
+        pass
+    finally:
+        try:
+            q.put(None)
+        except:
+            pass
+
+def cleanup_proc(proc, name="进程"):
+    if proc and proc.poll() is None:
+        try:
+            proc.terminate()
+            proc.wait(timeout=8)
+        except subprocess.TimeoutExpired:
+            proc.kill()
+        except:
+            proc.kill()
+        print(f"[INFO] 已强制终止 {name}")
+
+def start_douyin_srs_ffplay(
+    title,
+    anchor_name,
+    real_url,
+    rec_info,
+    record_name,
+    recording,
+    recording_time_list,
+    running_list,
+    monitoring,
+    clear_record_info,
+    color_obj
+):
+    # ====================== 配置参数 ======================
+    SRS_RTMP_URL = "rtmp://127.0.0.1/live/douyin"
+    SRS_PLAY_URL = "http://127.0.0.1:8080/live/douyin.flv"
+
+    MAX_RETRY_DELAY = 120
+    INITIAL_RETRY_DELAY = 3
+    NO_FRAME_TIMEOUT = 180
+    STALE_OUTPUT_SECONDS = 180
+    FFPLAY_RESTART_INTERVAL = 3600 * 6
+
+    END_KEYWORDS = [
+        "connection reset by peer", "failed to write trailer", "invalid data found",
+        "server returned 403", "server returned 404", "ingestion error",
+        "access denied", "packet too short", "client disconnected",
+        "live has ended", "no route to host", "connection timed out",
+    ]
+
+    timestamp_str = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
+    _clean_title = sanitize_title(title)
+    stream_title = sanitize_title(f"{anchor_name}{('_' + _clean_title) if _clean_title else ''}_{timestamp_str}")
+    print(f"[INFO] {rec_info} 启动 SRS → ffplay HDMI 转播（低CPU原画版）: {stream_title}")
+
+    douyin_headers = (
+        "User-Agent: Mozilla/5.0 (iPhone; CPU iPhone OS 18_1 like Mac OS X) AppleWebKit/605.1.15\r\n"
+        "Referer: https://live.douyin.com/\r\n"
+        "Origin: https://live.douyin.com\r\n"
+    )
+
+    # ====================== FFmpeg 推流到 SRS（直抄原画，低CPU） ======================
+    ffmpeg_command = [
+        "ffmpeg", "-y", "-loglevel", "info", "-nostdin",
+        "-headers", douyin_headers,
+        "-rw_timeout", "30000000",
+        "-reconnect", "1", "-reconnect_at_eof", "1", "-reconnect_streamed", "1",
+        "-reconnect_delay_max", "7",
+        "-fflags", "+genpts+discardcorrupt+igndts",
+        "-err_detect", "ignore_err",
+        "-i", real_url,
+        "-c:v", "copy",
+        "-c:a", "copy",
+        "-f", "flv", SRS_RTMP_URL
+    ]
+
+    # ====================== ffplay 最佳参数（低CPU + 零漂移 + 全屏） ======================
+    ffplay_cmd = [
+        "ffplay",
+        "-fflags", "nobuffer+genpts",
+        "-flags", "low_delay",
+        "-framedrop",
+        "-sync", "ext",
+        "-vf", "transpose=2",
+        "-autoexit",
+        "-fs",
+        "-loglevel", "quiet",
+        "-i", SRS_PLAY_URL
+    ]
+
+    ffmpeg_proc = None
+    ffplay_proc = None
+    stderr_q = queue.Queue()
+    reader_t = None
+    retry_delay = INITIAL_RETRY_DELAY
+    last_ffplay_restart = time.time()
+
+    try:
+        while True:
+            current_time = time.time()
+
+            if ffplay_proc and (current_time - last_ffplay_restart > FFPLAY_RESTART_INTERVAL):
+                print("[SCHEDULE] 6小时预防性重启 ffplay")
+                cleanup_proc(ffplay_proc, "ffplay")
+                ffplay_proc = None
+
+            if ffplay_proc is None or ffplay_proc.poll() is not None:
+                if ffplay_proc is not None:
+                    print("[WARN] ffplay 退出，重启中...")
+
+                print(f"[INFO][{datetime.datetime.now():%H:%M:%S}] 启动 ffplay 播放 SRS 原画流")
+                ffplay_proc = subprocess.Popen(
+                    ffplay_cmd,
+                    stdin=subprocess.DEVNULL,
+                    stdout=subprocess.DEVNULL,
+                    stderr=subprocess.PIPE,
+                    text=True
+                )
+                time.sleep(2)
+                last_ffplay_restart = time.time()
+
+            if retry_delay > INITIAL_RETRY_DELAY:
+                print(f"[WARN] 等待 {retry_delay}s 后重连抖音源...")
+            time.sleep(retry_delay)
+            retry_delay = min(retry_delay * 2, MAX_RETRY_DELAY)
+
+            cleanup_proc(ffmpeg_proc, "FFmpeg")
+
+            print(f"[INFO][{datetime.datetime.now():%H:%M:%S}] 启动 FFmpeg 直抄推流到 SRS")
+            ffmpeg_proc = subprocess.Popen(
+                ffmpeg_command,
+                stdin=subprocess.DEVNULL,
+                stdout=subprocess.DEVNULL,
+                stderr=subprocess.PIPE,
+                text=True,
+                bufsize=1,
+                universal_newlines=True
+            )
+            ffmpeg_proc.last_out_ts = time.time()
+
+            stderr_q = queue.Queue()
+            reader_t = threading.Thread(target=_stderr_reader_thread, args=(ffmpeg_proc, stderr_q))
+            reader_t.daemon = True
+            reader_t.start()
+
+            last_frame_time = time.time()
+
+            while True:
+                try:
+                    line = stderr_q.get(timeout=1.5)
+                except queue.Empty:
+                    if time.time() - ffmpeg_proc.last_out_ts > STALE_OUTPUT_SECONDS:
+                        print("[WARN] FFmpeg 僵死，重启")
+                        break
+                    continue
+
+                if line is None:
+                    break
+
+                line = line.strip()
+                if not line:
+                    continue
+
+                ffmpeg_proc.last_out_ts = time.time()
+                print(f"[FFmpeg] {line}")
+                line_lower = line.lower()
+
+                if any(kw in line_lower for kw in END_KEYWORDS):
+                    print("[INFO] 检测到下播关键字，停止转播")
+                    raise StreamEnded()
+
+                if re.search(r'frame=\s*\d+', line_lower):
+                    last_frame_time = time.time()
+                    retry_delay = INITIAL_RETRY_DELAY
+
+                if time.time() - last_frame_time > NO_FRAME_TIMEOUT:
+                    print(f"[INFO] {NO_FRAME_TIMEOUT}s 无新帧，判定下播")
+                    raise StreamEnded()
+
+    except StreamEnded:
+        print(f"[INFO] 主播已下播，停止 SRS → ffplay HDMI 转播 → {record_name}")
+    except KeyboardInterrupt:
+        print("[INFO] 用户手动中断")
+    except Exception as e:
+        print(f"[FATAL] 未知异常: {e}")
+        traceback.print_exc()
+        time.sleep(10)
+    finally:
+        cleanup_proc(ffmpeg_proc, "FFmpeg")
+        cleanup_proc(ffplay_proc, "ffplay")
+        try:
+            recording.discard(record_name)
+            recording_time_list.pop(record_name, None)
+            if record_name in running_list:
+                running_list.remove(record_name)
+            # global monitoring
+            # monitoring = max(0, monitoring - 1)
+            monitoring[0] = max(0, monitoring[0] - 1)  # 修改为列表元素
+            clear_record_info(record_name, real_url)
+        except:
+            pass
+        color_obj.print_colored(f"[{record_name}] SRS → ffplay HDMI 转播已彻底停止并清理完毕\n", color_obj.GREEN)

douyin_youtube_ffplay.py

@@ -1,476 +0,0 @@
-# douyin_youtube_ffplay.py
-import queue
-import unicodedata
-import platform
-import traceback
-import time
-import datetime
-import subprocess
-import threading
-import re
-import os
-import configparser
-
-
-class StreamEnded(Exception):
-    """主播真实下播的专用异常"""
-    pass
-
-
-def sanitize_title(text: str, max_len: int = 120) -> str:
-    if not text:
-        return ""
-    text = unicodedata.normalize("NFKC", text)
-    text = ''.join(ch for ch in text if unicodedata.category(ch)[0] != 'C')
-    text = ''.join(ch for ch in text if ord(ch) <= 0xFFFF)
-    return text.strip()[:max_len]
-
-
-def _stderr_reader_thread(proc, q):
-    try:
-        while True:
-            line = proc.stderr.readline()
-            if not line:
-                break
-            q.put(line)
-    except Exception as e:
-        try:
-            q.put(f"__ERR__READER__:{e}")
-        except Exception:
-            pass
-    finally:
-        try:
-            q.put(None)
-        except Exception:
-            pass
-
-
-def cleanup_proc(proc):
-    try:
-        if proc and proc.poll() is None:
-            try:
-                proc.terminate()
-                proc.wait(timeout=5)
-            except Exception:
-                if proc.poll() is None:
-                    try:
-                        proc.kill()
-                    except Exception:
-                        pass
-    except Exception:
-        pass
-
-
-def start_douyin_youtube_ffplay(
-    title: str,
-    anchor_name: str,
-    real_url: str,
-    rec_info: str,
-    record_name: str,
-    recording: set,
-    recording_time_list: dict,
-    running_list: list,
-    monitoring: list,
-    clear_record_info,
-    color_obj,
-):
-    """
-    抖音 → YouTube 推流主函数（单路推流）
-    只从 config/youtube.ini 读取一个 stream key（取第一个有效值）
-    """
-
-    # ====================== 读取 YouTube stream key 配置 ======================
-    config_file = "config/youtube.ini"
-    rtmp_base = "rtmp://a.rtmp.youtube.com/live2/"
-    default_key = "qxvb-r47b-r5ju-6ud3-6k7z"  # 备用默认 key
-    youtube_rtmp = rtmp_base + default_key  # 默认值
-
-    if os.path.exists(config_file):
-        config = configparser.ConfigParser()
-        config.read(config_file, encoding="utf-8")
-        if config.has_section("youtube"):
-            for key_name, value in config.items("youtube"):
-                value = value.strip()
-                if value:
-                    if value.startswith("rtmp://"):
-                        youtube_rtmp = value
-                    else:
-                        youtube_rtmp = rtmp_base + value
-                    print(f"[INFO] 从 {config_file} 读取 YouTube stream key: {youtube_rtmp}")
-                    break  # 只取第一个有效 key，保持单路推流（不加多路逻辑）
-
-    # ====================== 常量配置 ======================
-    MAX_RETRY_DELAY = 90
-    INITIAL_RETRY_DELAY = 3
-    STDERR_QUEUE_TIMEOUT = 1.0
-    NO_FRAME_TIMEOUT = 120
-    START_CHECK_AFTER = 25
-    STALE_OUTPUT_SECONDS = 40
-
-    END_KEYWORDS = [
-        "connection reset by peer",
-        "failed to write trailer",
-        "invalid data found",
-        "server returned 403",
-        "server returned 404",
-        "ingestion error",
-        "access denied",
-        "packet too short",
-        "client disconnected",
-        "live has ended",
-        "no route to host",
-        "connection timed out",
-    ]
-
-    douyin_headers = (
-        "User-Agent: Mozilla/5.0 (iPhone; CPU iPhone OS 18_1 like Mac OS X) AppleWebKit/605.1.15\r\n"
-        "Referer: https://live.douyin.com/\r\n"
-        "Origin: https://live.douyin.com\r\n"
-    )
-
-    # ====================== 标题处理 ======================
-    timestamp_str = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
-    clean_title = sanitize_title(title)
-    stream_title = sanitize_title(f"{anchor_name}{('_' + clean_title) if clean_title else ''}_{timestamp_str}")
-    print(f"[INFO] {rec_info} 开始推流到 YouTube: {stream_title}")
-
-    # ====================== NVENC 检测 ======================
-    codec_v = "libx264"
-    preset_v = "veryfast"
-    tune_param = ["-tune", "zerolatency"]
-    try:
-        if platform.system().lower() in ["windows", "linux"]:
-            check = subprocess.run(["nvidia-smi"], capture_output=True, timeout=5)
-            if check.returncode == 0:
-                enc = subprocess.run(["ffmpeg", "-hide_banner", "-encoders"], capture_output=True, text=True, timeout=5)
-                if "h264_nvenc" in (enc.stdout or ""):
-                    codec_v = "h264_nvenc"
-                    preset_v = "p5"
-                    tune_param = ["-tune", "ll", "-rc", "vbr", "-cq", "21", "-b:v", "2500k"]
-                    print("[INFO] 检测到 NVIDIA GPU → 使用 NVENC 硬件加速")
-    except Exception as e:
-        print(f"[WARN] NVENC 检测失败，回退软件编码: {e}")
-
-    # 720p (最原始)
-    ffmpeg_command = [
-        "ffmpeg", "-y", "-loglevel", "info", "-nostdin", "-re",
-        "-stats", "-stats_period", "1",
-        "-rw_timeout", "30000000",
-        "-reconnect", "1", "-reconnect_at_eof", "1", "-reconnect_streamed", "1",
-        "-reconnect_delay_max", "5",
-        "-fflags", "+genpts+discardcorrupt+nobuffer+flush_packets",
-        "-flags", "low_delay",
-        "-err_detect", "ignore_err",
-        "-max_delay", "80000",
-        "-thread_queue_size", "2048",
-
-        "-headers", douyin_headers,
-        "-i", real_url,
-        # 720p
-        "-vf", "fps=30,scale=720:1280:force_original_aspect_ratio=decrease:flags=lanczos,pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
-        "-c:v", "libx264",
-        "-preset", "fast",
-        # "-tune", "zerolatency",
-        "-profile:v", "high",
-        # 720p
-        # "-minrate", "3200k","-b:v", "3200k", "-maxrate", "3200k", "-bufsize", "6400k",   # bufsize = 2× bitrate，保持真 CBR
-        "-b:v", "2600k","-maxrate", "3000k","-bufsize", "5200k",
-        "-vsync", "cfr",
-        "-g", "60", "-keyint_min", "60",
-        "-r", "30",
-        "-bf", "0",
-        "-sc_threshold", "0",
-        # "-nal-hrd", "cbr",                                          # 改2：强制 CBR
-        # 720p
-        # "-x264-params", "nal-hrd=cbr:force-cfr=1:scenecut=0:filler=1",       # 改3：简化 params，锁死 CBR
-        "-x264-params", "force-cfr=1:scenecut=0:open_gop=0:sync-lookahead=0",
-        "-pix_fmt", "yuv420p",
-        "-c:a", "aac", "-b:a", "128k", "-ar", "48000", "-ac", "2",  # 改4：1080p可音频上 128k（YouTube 推荐）
-        "-af", "aresample=async=1:first_pts=0",
-
-        "-flags", "+global_header",
-        "-flvflags", "no_duration_filesize",
-        "-f", "flv", youtube_rtmp
-    ]
-
-
-  
-
-        # "arnndn=m=./arnndn-models/cb.rnnn:mix=0.85,"      # 人声增强
-# 720p-低CPU + 背景音乐处理 + 防ContentID
-    # ffmpeg_command = [
-    #     "ffmpeg", "-y", "-loglevel", "info", "-nostdin", "-re",
-    #     "-stats", "-stats_period", "1",
-    #     "-rw_timeout", "30000000",
-    #     "-reconnect", "1", "-reconnect_at_eof", "1", "-reconnect_streamed", "1",
-    #     "-reconnect_delay_max", "5",
-    #     "-fflags", "+genpts+discardcorrupt+nobuffer+flush_packets",
-    #     "-flags", "low_delay",
-    #     "-err_detect", "ignore_err",
-    #     "-max_delay", "80000",
-    #     "-thread_queue_size", "2048",
-
-    #     "-headers", douyin_headers,
-    #     "-i", real_url,
-
-    #     # 视频处理 720p
-    #     "-vf",
-    #     "fps=25,scale=720:1280:force_original_aspect_ratio=decrease:flags=bicubic,"
-    #     "pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
-
-    #     "-c:v", "libx264",
-    #     "-preset", "veryfast",               # 降低CPU
-    #     "-profile:v", "high",
-    #     "-b:v", "2600k", "-maxrate", "3000k", "-bufsize", "5200k",
-    #     "-vsync", "cfr",
-    #     "-g", "50", "-keyint_min", "50",     # 与fps=25匹配
-    #     "-r", "25",
-    #     "-bf", "0",
-    #     "-sc_threshold", "0",
-    #     "-x264-params", "force-cfr=1:scenecut=0:open_gop=0:sync-lookahead=0",
-    #     "-pix_fmt", "yuv420p",
-
-    #     # 音频处理（轻量 + 背景音乐弱化 + 防Content ID）
-    #     "-c:a", "aac", "-b:a", "128k", "-ar", "48000", "-ac", "2",
-    #     "-af",
-    #     "afftdn=nf=-28:tn=1,"                             # 轻 FFT 降噪，背景弱化
-    #     "highpass=f=120,lowpass=f=4800,"                  # 切低频鼓 & 高频镲
-    #     "equalizer=f=250:width_type=o:width=2:g=-8,"      # 衰减低中频
-    #     "equalizer=f=800:width_type=o:width=1.5:g=-5,"    # 衰减中频
-    #     "acompressor=threshold=-30dB:ratio=4:attack=10:release=100:makeup=4," # 压动态
-    #     "asetrate=48000*1.02,aresample=48000,"           # 音高微升
-    #     "afreqshift=shift=15,"                            # 小幅频率偏移
-    #     "volume=1.1,"                                     # 音量补偿
-    #     "aresample=async=1:first_pts=0",                 # 音视频同步
-
-    #     # 推流参数
-    #     "-flvflags", "no_duration_filesize",
-    #     "-f", "flv", youtube_rtmp
-    # ]
-
-
-
-
-
-
-    # ffmpeg_command = [
-    #     "ffmpeg", "-y", "-loglevel", "info", "-nostdin", "-re",
-    #     "-stats", "-stats_period", "1",
-    #     "-rw_timeout", "30000000",
-    #     "-reconnect", "1", "-reconnect_at_eof", "1", "-reconnect_streamed", "1",
-    #     "-reconnect_delay_max", "5",
-    #     "-fflags", "+genpts+discardcorrupt+nobuffer+flush_packets",
-    #     "-flags", "low_delay",
-    #     "-err_detect", "ignore_err",
-    #     "-max_delay", "50000",
-    #     "-thread_queue_size", "4096",
-
-    #     "-headers", douyin_headers,
-    #     "-i", real_url,
-
-    #     # 视频处理：1080p 纵屏优化，黑边填充
-    #     "-vf",
-    #     "fps=25,scale=1080:1920:force_original_aspect_ratio=decrease:flags=bicubic,"
-    #     "pad=1080:1920:(ow-iw)/2:(oh-ih)/2:black",
-
-    #     "-c:v", "libx264",
-    #     "-preset", "medium",               # Ubuntu server CPU通常能承受，质量比faster好很多；若掉帧可回退到faster或veryfast
-    #     "-tune", "zerolatency",
-    #     "-profile:v", "high",
-    #     "-level", "4.2",                   # 支持1080p@25fps
-    #     # "-b:v", "8500k", "-maxrate", "10000k", "-bufsize", "20000k",
-    #     "-b:v", "4500k", "-maxrate", "5500k", "-bufsize", "9000k",
-    #     "-vsync", "cfr",
-    #     "-g", "50", "-keyint_min", "50",
-    #     "-r", "25",
-    #     "-bf", "0",
-    #     "-sc_threshold", "0",
-    #     "-x264-params", "force-cfr=1:scenecut=0:open_gop=0:sync-lookahead=0:rc-lookahead=0",
-    #     "-pix_fmt", "yuv420p",
-
-    #     # 音频处理 - 防Content ID 强化版（多维度修改音频指纹）
-    #     "-c:a", "aac", "-b:a", "192k", "-ar", "48000", "-ac", "2",
-    #     "-af",
-    #     "arnndn=m=./arnndn-models/cb.rnnn:mix=0.85,"
-    #     "afftdn=nf=-24:tn=1,"                              # 中等降噪，保留人声清晰度
-    #     "highpass=f=100,lowpass=f=5200,"                   # 切除低频鼓/贝斯 & 高频镲/噪音，聚焦人声区
-    #     "equalizer=f=180:width_type=o:width=2.2:g=-12,"    # 强衰减低频（背景音乐基础层）
-    #     "equalizer=f=350:width_type=o:width=1.8:g=-9,"     # 衰减低中频（常见旋律区）
-    #     "equalizer=f=750:width_type=o:width=1.6:g=-7,"     # 中频衰减，破坏音乐结构
-    #     "equalizer=f=2800:width_type=o:width=1.2:g=-5,"    # 高中频轻衰减，保持人声自然
-    #     "acompressor=threshold=-26dB:ratio=5.5:attack=7:release=90:makeup=6,"  # 强压缩，改变动态指纹
-    #     "asetrate=48000*1.05,atempo=1.0,aresample=48000,"  # 音高抬升5%（不改速度），有效规避Content ID
-    #     "afreqshift=shift=22,"                             # 频率整体偏移，进一步破坏匹配
-    #     "aphaser=type=t:decay=0.35:delay=3.0:speed=0.5,"   # 正确参数：轻微相位扰动（triangular类型），防检测
-    #     # "anlmdn=s=0.00012:p=0.0008:r=0.002,"               # 轻量非线性噪门，清理残余背景音乐
-    #     "volume=1.08,"                                     # 补偿音量衰减
-    #     "aresample=async=1:first_pts=0:min_hard_comp=0.100000:first_pts=0",  # 强制音视频同步
-
-    #     # 推流优化（FLV适合YouTube RTMP/RTMPS）
-    #     "-flvflags", "no_duration_filesize",
-    #     "-f", "flv", youtube_rtmp
-    # ]
-
-
-
-    # ====================== 主重试循环（原样保留） ======================
-    # ffmpeg_command = [
-    # "ffmpeg","-y","-loglevel","info","-nostdin","-re",
-    # "-stats","-stats_period","1",
-
-    # # 输入稳定
-    # "-rw_timeout","30000000",
-    # "-reconnect","1","-reconnect_at_eof","1","-reconnect_streamed","1",
-    # "-reconnect_delay_max","5",
-
-    # # 关键：删除低延迟杀手参数
-    # "-fflags","+genpts+discardcorrupt",
-    # "-err_detect","ignore_err",
-    # "-max_delay","500000",
-    # "-thread_queue_size","512",
-
-    # # 抖音源
-    # "-headers", douyin_headers,
-    # "-i", real_url,
-
-    # # 视频处理
-    # "-vf","fps=25,scale=1080:1920:force_original_aspect_ratio=decrease,pad=1080:1920:(ow-iw)/2:(oh-ih)/2:black",
-
-    # # 编码
-    # "-c:v","libx264",
-    # "-preset","veryfast",
-    # "-profile:v","high",
-    # "-level","4.2",
-    # "-b:v","4500k","-maxrate","4500k","-bufsize","9000k",
-    # "-g","50","-keyint_min","50",
-    # "-r","25",
-    # "-pix_fmt","yuv420p",
-    # "-bf","0",
-    # "-sc_threshold","0",
-    # "-x264-params","force-cfr=1:scenecut=0:open_gop=0",
-
-    # # 音频（强烈建议简化）
-    # "-c:a","aac","-b:a","128k","-ar","44100","-ac","2",
-    # "-af","aresample=async=1,volume=1.05",
-
-    # # 推流
-    # "-flvflags","no_duration_filesize",
-    # "-f","flv", youtube_rtmp
-    # ]
-
-
-
-    
-
-  
-    proc = None
-    stderr_q = None
-    reader_t = None
-    retry_delay = INITIAL_RETRY_DELAY
-
-    try:
-        while True:
-            try:
-                if retry_delay > INITIAL_RETRY_DELAY:
-                    print(f"[WARN] 防风控等待 {retry_delay}s 后重新连接抖音源...")
-                time.sleep(retry_delay)
-
-                cleanup_proc(proc)
-                stderr_q = queue.Queue()
-
-                print(f"[INFO][{datetime.datetime.now():%H:%M:%S}] 启动 YouTube 推流 → {stream_title}")
-                proc = subprocess.Popen(
-                    ffmpeg_command,
-                    stdin=subprocess.DEVNULL,
-                    stdout=subprocess.DEVNULL,
-                    stderr=subprocess.PIPE,
-                    text=True,
-                    bufsize=1,
-                    universal_newlines=True
-                )
-                proc.last_out_ts = time.time()
-
-                reader_t = threading.Thread(target=_stderr_reader_thread, args=(proc, stderr_q))
-                reader_t.daemon = True
-                reader_t.start()
-
-                start_time = last_frame_time = time.time()
-
-                while True:
-                    try:
-                        try:
-                            line = stderr_q.get(timeout=STDERR_QUEUE_TIMEOUT)
-                        except queue.Empty:
-                            if time.time() - getattr(proc, "last_out_ts", time.time()) > STALE_OUTPUT_SECONDS:
-                                print("[WARN] 长时间无任何日志，强制重启进程")
-                                cleanup_proc(proc)
-                                break
-                            continue
-
-                        if line is None:
-                            if proc.poll() is not None:
-                                break
-                            continue
-
-                        line = line.strip()
-                        if line.startswith("__ERR__READER__"):
-                            print(f"[ERROR] stderr reader 异常: {line}")
-                            continue
-
-                        if line:
-                            proc.last_out_ts = time.time()
-                            print(f"[FFmpeg] {line}")
-                            line_lower = line.lower()
-
-                            if any(kw in line_lower for kw in END_KEYWORDS):
-                                print("[ERROR] 检测到主播真下播或被明确拒绝，停止推流")
-                                cleanup_proc(proc)
-                                raise StreamEnded()
-
-                            if re.search(r'frame=\s*\d+', line_lower) or "fps=" in line_lower:
-                                last_frame_time = time.time()
-
-                            if time.time() - start_time > START_CHECK_AFTER:
-                                if time.time() - last_frame_time > NO_FRAME_TIMEOUT:
-                                    print(f"[WARN] 连续 {NO_FRAME_TIMEOUT}s 无新帧，判定主播已下播")
-                                    cleanup_proc(proc)
-                                    raise StreamEnded()
-
-                    except StreamEnded:
-                        raise
-                    except Exception as e:
-                        print(f"[ERROR] 内层异常: {e}")
-                        traceback.print_exc()
-                        cleanup_proc(proc)
-                        retry_delay = min(retry_delay * 2, MAX_RETRY_DELAY)
-                        break
-
-                continue
-
-            except StreamEnded:
-                print(f"[INFO] 主播已下播，停止 YouTube 转推 → {record_name}")
-                break
-
-            except Exception as e:
-                print(f"[ERROR] 外层异常: {e}")
-                traceback.print_exc()
-                retry_delay = min(retry_delay * 2, MAX_RETRY_DELAY)
-                continue
-
-    except Exception as e:
-        print(f"[FATAL] YouTube 推流最外层异常: {e}")
-        traceback.print_exc()
-    finally:
-        cleanup_proc(proc)
-
-        try:
-            recording.discard(record_name)
-            recording_time_list.pop(record_name, None)
-            if real_url in running_list:
-                running_list.remove(real_url)
-            monitoring[0] = max(0, monitoring[0] - 1)
-            clear_record_info(record_name, real_url)
-        except Exception:
-            pass
-
-        color_obj.print_colored(f"[{record_name}] YouTube 推流已彻底停止并清理完毕\n", color_obj.GREEN)

index.html

@@ -1,265 +1,215 @@
+<!--
+    Project: DouyinLiveRecorder
+    Author: Hmily
+    Build: 2023.08.14 - 20:24:05
+    GitHub Project URL: https://github.com/ihmily/DouyinLiveRecorder
+-->
 <!DOCTYPE html>
-<html lang="zh">
+<html lang="en">
 <head>
-<meta charset="UTF-8">
-<meta name="viewport" content="width=device-width,initial-scale=1">
-<title>多进程录制控制台</title>
-<style>
-:root{--bg:#1a237e;--accent:#283593;--text:#fff;--card:#fff;--card-text:#000}
-@media(prefers-color-scheme:dark){:root{--card:#1e1e1e;--card-text:#fff}}
-body{margin:0;font-family:system-ui,-apple-system,sans-serif;background:linear-gradient(135deg,var(--bg),#283593,#4a148c);color:var(--text);min-height:100vh;display:flex;justify-content:center;padding:20px;box-sizing:border-box}
-.container{max-width:720px;width:100%;background:var(--card);color:var(--card-text);border-radius:12px;padding:24px;box-shadow:0 8px 32px rgba(0,0,0,.4)}
-h1{margin:0 0 24px;font-size:1.6em;display:flex;align-items:center;gap:12px}
-#processSelect{padding:8px;border-radius:8px;border:1px solid #ddd;font-size:1em}
-#statusIndicator{font-size:1.2em;font-weight:600}
-h2{margin:24px 0 12px;font-size:1.4em}
-h3{margin:16px 0 8px;font-size:1.2em}
-input,button,textarea{width:100%;padding:12px;margin:8px 0;border-radius:8px;border:none;box-sizing:border-box;font-size:1em}
-input,textarea{background:#f5f5f5;color:#000;border:1px solid #ddd;font-family:monospace;overflow:hidden;resize:none;min-height:100px}
-button{background:var(--accent);color:#fff;cursor:pointer;font-weight:600;transition:.2s}
-button:hover{background:#1a237e}
-button.loading{opacity:.7;pointer-events:none}
-button.loading::after{content:" ⏳";animation:spin 1s linear infinite}
-#pm2Buttons{display:grid;grid-template-columns:repeat(auto-fit,minmax(100px,1fr));gap:8px;margin:12px 0}
-#pm2Log{background:#000;color:#0f0;padding:12px;height:320px;overflow-y:auto;font-family:monospace;font-size:.9em;border-radius:8px;white-space:pre-wrap;word-break:break-all}
-.configButtons{display:grid;grid-template-columns:repeat(auto-fit,minmax(120px,1fr));gap:8px;margin:12px 0}
-.configStatus{color:#0f0;margin-top:8px;font-family:monospace;font-size:0.9em}
-#obsAddress{background:#f0f0f0;padding:12px;border-radius:8px;font-family:monospace;font-size:1.1em;margin:8px 0;word-break:break-all}
-@keyframes spin{to{transform:rotate(360deg)}}
-</style>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <meta name="referrer" content="never"> 
+    <title>M3U8 视频播放器</title>
+    <link rel="preconnect" href="https://fonts.googleapis.com">
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
+    <link href="https://fonts.googleapis.com/css2?family=Roboto:wght@400;700&amp;display=swap" rel="stylesheet">
+    <script src="https://cdn.jsdelivr.net/npm/hls.js@latest/dist/hls.min.js"></script>
+    <script src="https://cdn.jsdelivr.net/npm/flv.js@1.6.2/dist/flv.min.js"></script>
+
+    <style>
+        body {
+            font-family: 'Roboto', Arial, sans-serif;
+            background-color: #1a237e;
+            display: flex;
+            justify-content: center;
+            align-items: center;
+            height: 100vh;
+            margin: 0;
+            padding: 0;
+            color: #ffffff;
+            background-image: linear-gradient(120deg, #1a237e 0%, #283593 50%, #4a148c 100%);
+        }
+
+
+        .container {
+            max-width: 640px;
+            width: 80%;
+            padding: 20px;
+            background-color: #ffffff;
+            border-radius: 10px;
+            box-shadow: 0px 0px 5px 0px rgba(0,0,0,0.15);
+        }
+
+        #videoPlayer {
+            width: 100%;
+            height: 0;
+            padding-bottom: 56.25%;
+            position: relative;
+            background-color: #000;
+            border-radius: 5px;
+            box-shadow: 0px 0px 10px 0px rgba(0,0,0,0.15);
+            display: none;
+        }
+
+        video {
+            position: absolute;
+            top: 0;
+            left: 0;
+            width: 100%;
+            height: 100%;
+        }
+
+        #videoUrlInput{
+        	display: block;
+        	width: 100%;
+        	margin: 10px 0;
+        	padding: 8px;
+        	border-radius: 5px;
+        	border: 1px solid #ccc;
+            box-sizing: border-box;
+        }
+
+        #playButton {
+            display: block;
+            width: 100%;
+            padding: 10px;
+            background-color: #283593;
+            color: white;
+            font-weight: bold;
+            border-radius: 5px;
+            border: none;
+            cursor: pointer;
+            transition: background-color 0.3s;
+            margin: 0 0 10px 0;
+            box-shadow: 0px 2px 4px 0px rgba(0,0,0,0.15);
+        }
+
+        #playButton:hover {
+            background-color: #1a237e;
+        }
+
+        .description {
+            margin-top: 20px;
+            line-height: 1.4;
+            font-size: 14px;
+            text-align: left;
+            background-color: #f8f9fa;
+            padding: 15px;
+            border-radius: 5px;
+            
+            box-shadow: 0px 0px 5px 0px rgba(0,0,0,0.15);
+            display: block;
+        }
+        .footer {
+          margin-top: 30px;
+          text-align: center;
+          font-size: 14px;
+          color: white;
+        }
+
+        p{
+            color: black;
+        }
+        
+        a.no_style {
+            color: inherit;
+            text-decoration: none;
+        }
+        @media screen and (max-width: 768px) {
+            .container {
+                width: 90%;
+                border-radius: 0;
+                box-shadow: none;
+                margin-top:30px;
+            }
+            body {
+                overflow-y: scroll;
+            }
+            #videoUrlInput{
+                
+            	margin-top: 30px;
+            	margin-bottom: 10px;
+            }
+        
+        }
+
+    </style>
 </head>
 <body>
-<div class="container">
-    <h1>
-        进程:
-        <select id="processSelect">
-            <option value="tiktok">tiktok</option>
-            <option value="youtube">youtube</option>
-            <option value="obs">obs</option>
-        </select>
-        <span id="statusIndicator">⚪ 加载中...</span>
-    </h1>
-
-    <!-- YouTube 专属配置（仅 youtube 时显示） -->
-    <div id="youtubeOnlySection" style="display:none;">
-        <h2>YouTube 配置编辑 (youtube.ini)</h2>
-        <div class="configEditor">
-            <h3>youtube.ini</h3>
-            <textarea id="youtubeConfig"></textarea>
-            <div class="configButtons">
-                <button id="loadYoutubeBtn">加载配置</button>
-                <button id="saveYoutubeBtn">保存配置</button>
-            </div>
-            <pre class="configStatus" id="youtubeStatus">就绪</pre>
+	<div class="container">
+	    <input type="text" id="videoUrlInput" placeholder="请输入 M3U8或者FLV 视频链接">
+	    <button id="playButton">播放视频</button>
+	    <div id="videoPlayer">
+	        <video controls></video>
+	    </div>
+	    <div class="description">
+            <p><strong>说明</strong><p>
+            <p>M3U8文件格式</p>
+            <p>M3U8文件是采用UTF-8编码格式的M3U文件。M3U文件本身是一个纯文本索引文件，其核心功能是记录多媒体文件链接。当用户打开此类文件时，播放软件会根据索引查找相应的音视频文件网络地址，然后进行在线播放。</p>
+            <p>M3U最初设计用于播放音频文件，例如MP3。但随着时间推移，更多的播放器和软件开始使用M3U来播放视频文件列表，同时也支持在线流媒体音频源的指定。目前，许多播放器和软件都兼容M3U文件格式。</p>
+            <p>FLV文件格式（Flash Video Format）是Adobe公司开发的一种专门用于网页视频播放的文件格式。FLV格式的视频文件通常用于播放短视频和在线流媒体，可以嵌入到网页中供用户观看。FLV视频通常由Adobe Flash Player播放器播放，而其他第三方播放器也支持此格式。</p>
         </div>
-    </div>
-
-    <!-- URL_config.ini 共享配置（youtube 或 tiktok 时显示） -->
-    <div id="urlConfigSection" style="display:none;">
-        <h2>URL 配置编辑 (URL_config.ini)</h2>
-        <div class="configEditor">
-            <h3>URL_config.ini</h3>
-            <textarea id="urlConfig"></textarea>
-            <div class="configButtons">
-                <button id="loadUrlBtn">加载配置</button>
-                <button id="saveUrlBtn">保存配置</button>
-            </div>
-            <pre class="configStatus" id="urlStatus">就绪</pre>
+        <div class="footer">
+          <p>&copy; 2023 <a href='https://github.com/ihmily/DouyinLiveRecorder' class="no_style" target="_blank">Hmily</a>. All rights reserved.</p>
         </div>
-    </div>
-
-    <!-- OBS 推流地址区（仅 obs 时显示） -->
-    <div id="obsSection" style="display:none;">
-        <h2>OBS 直播推流地址</h2>
-        <p>请在 OBS → 设置 → 推流 → 服务选择“自定义”，服务器填写以下地址：</p>
-        <div id="obsAddress">srt://live.local:10080/live/obs</div>
-        <p>密钥（Stream Key）留空即可。</p>
-    </div>
-
-    <h2>PM2 进程控制</h2>
-    <div id="pm2Buttons">
-        <button data-action="start">启动</button>
-        <button data-action="stop">停止</button>
-        <button data-action="restart">重启</button>
-        <button data-action="status">手动刷新</button>
-    </div>
-    <h2>实时日志（自动每秒刷新）</h2>
-    <pre id="pm2Log">正在加载状态与日志...</pre>
-</div>
-<script>
-const logEl = document.getElementById('pm2Log');
-const statusIndicator = document.getElementById('statusIndicator');
-const processSelect = document.getElementById('processSelect');
-let currentProcess = 'tiktok';
-
-// 各专属区域
-const youtubeOnlySection = document.getElementById('youtubeOnlySection');
-const urlConfigSection = document.getElementById('urlConfigSection');
-const obsSection = document.getElementById('obsSection');
-
-// youtube.ini 编辑（youtube 专属）
-const youtubeConfig = document.getElementById('youtubeConfig');
-const loadYoutubeBtn = document.getElementById('loadYoutubeBtn');
-const saveYoutubeBtn = document.getElementById('saveYoutubeBtn');
-const youtubeStatus = document.getElementById('youtubeStatus');
-
-// URL_config.ini 编辑（youtube 和 tiktok 共享）
-const urlConfig = document.getElementById('urlConfig');
-const loadUrlBtn = document.getElementById('loadUrlBtn');
-const saveUrlBtn = document.getElementById('saveUrlBtn');
-const urlStatus = document.getElementById('urlStatus');
-
-processSelect.addEventListener('change', () => {
-    currentProcess = processSelect.value;
-    fetchStatus();
-    updateSectionsVisibility();
-});
-
-function updateSectionsVisibility() {
-    youtubeOnlySection.style.display = currentProcess === 'youtube' ? 'block' : 'none';
-    urlConfigSection.style.display = (currentProcess === 'youtube' || currentProcess === 'tiktok') ? 'block' : 'none';
-    obsSection.style.display = currentProcess === 'obs' ? 'block' : 'none';
-    
-    if (currentProcess === 'youtube') {
-        loadYoutubeConfig();
-    }
-    if (currentProcess === 'youtube' || currentProcess === 'tiktok') {
-        loadUrlConfig();
-    }
-}
-
-// textarea 高度自适应
-function autoResize(textarea) {
-    textarea.style.height = 'auto';
-    textarea.style.height = (textarea.scrollHeight) + 'px';
-}
-[youtubeConfig, urlConfig].forEach(ta => {
-    ta.addEventListener('input', () => autoResize(ta));
-    autoResize(ta);
-});
-
-// 通用加载/保存
-async function loadConfig(endpoint, textarea, statusEl) {
-    statusEl.textContent = '加载中...';
-    try {
-        const res = await fetch(`${endpoint}?process=${currentProcess}`);
-        if (!res.ok) throw new Error(`HTTP ${res.status}`);
-        const data = await res.json();
-        textarea.value = data.content || '';
-        autoResize(textarea);
-        statusEl.textContent = '加载成功';
-    } catch (err) {
-        statusEl.textContent = `加载失败: ${err.message}`;
-    }
-}
-
-async function saveConfig(endpoint, textarea, statusEl, saveBtn) {
-    statusEl.textContent = '保存中...';
-    const content = textarea.value;
-    try {
-        const res = await fetch(`${endpoint}?process=${currentProcess}`, {
-            method: 'POST',
-            headers: {'Content-Type': 'application/json'},
-            body: JSON.stringify({content})
-        });
-        if (!res.ok) throw new Error(`HTTP ${res.status}`);
-        const data = await res.json();
-        statusEl.textContent = data.message || '保存成功';
-    } catch (err) {
-        statusEl.textContent = `保存失败: ${err.message}`;
-    } finally {
-        if (saveBtn) saveBtn.classList.remove('loading');
-    }
-}
-
-// youtube.ini（仅 youtube）
-function loadYoutubeConfig() { loadConfig('/get_config', youtubeConfig, youtubeStatus); }
-function saveYoutubeConfig() {
-    saveYoutubeBtn.classList.add('loading');
-    saveConfig('/save_config', youtubeConfig, youtubeStatus, saveYoutubeBtn);
-}
-loadYoutubeBtn.onclick = loadYoutubeConfig;
-saveYoutubeBtn.onclick = saveYoutubeConfig;
-
-// URL_config.ini（youtube 和 tiktok 共享）
-function loadUrlConfig() { loadConfig('/get_url_config', urlConfig, urlStatus); }
-function saveUrlConfig() {
-    saveUrlBtn.classList.add('loading');
-    saveConfig('/save_url_config', urlConfig, urlStatus, saveUrlBtn);
-}
-loadUrlBtn.onclick = loadUrlConfig;
-saveUrlBtn.onclick = saveUrlConfig;
-
-function scrollLog(){logEl.scrollTop = logEl.scrollHeight}
-
-function updateStatus(process_status){
-    let emoji = '⚪', text = '未知';
-    if(process_status === 'online'){ emoji = '🟢'; text = '运行中'; }
-    else if(process_status === 'stopped'){ emoji = '🔴'; text = '已停止'; }
-    else if(process_status === 'errored'){ emoji = '🔴'; text = '错误'; }
-    else if(process_status === 'launching' || process_status === 'starting'){ emoji = '🟡'; text = '启动中'; }
-    else if(process_status === 'waiting restart'){ emoji = '🟡'; text = '等待重启'; }
-    else if(process_status === 'not_found'){ emoji = '❌'; text = '未注册到 PM2'; }
-    statusIndicator.innerHTML = `${emoji} ${text}`;
-}
-
-async function pm2Action(action){
-    const btn = document.querySelector(`[data-action="${action}"]`);
-    if(btn) btn.classList.add('loading');
-    const url = `/${action}?process=${currentProcess}`;
-    try{
-        const res = await fetch(url);
-        if(!res.ok) throw new Error('网络错误');
-        const data = await res.json();
-        if(action === 'status'){
-            updateStatus(data.process_status);
-            let logText = `【PM2 全状态表格】（${new Date().toLocaleTimeString()}）\n${data.raw_status}\n\n`;
-            if(data.process_status === 'not_found'){
-                logText += `【提示】进程 "${currentProcess}" 未注册到 PM2（可能被 pm2 delete 删除）\n`;
-            }else{
-                logText += `【实时输出日志】`;
-                if(data.recent_log.includes('不存在') || data.recent_log.includes('无日志路径')){
-                    logText += `\n${data.recent_log}`;
-                }else{
-                    logText += `（最近 ${data.recent_log.trim().split('\n').length} 行）\n${data.recent_log || '无新输出'}`;
-                }
-                logText += `\n\n【实时错误日志】`;
-                if(data.recent_error.includes('不存在') || data.recent_error.includes('无日志路径')){
-                    logText += `\n${data.recent_error}`;
-                }else{
-                    logText += `（最近 ${data.recent_error.trim().split('\n').length} 行）\n${data.recent_error || '无错误'}`;
-                }
+	    <script>
+    	    function httpToHttps(url) {
+              if (url.startsWith("http://")) {
+                return url.replace("http://", "https://");
+              }
+              return url;
+            }
+	        function playVideo() {
+            let videoUrl = document.getElementById('videoUrlInput').value;
+            const video = document.querySelector('#videoPlayer video');
+            const description = document.querySelector('.description');
+            if (videoUrl == ''){
+                alert('请输入视频链接');
+                return;
+            }
+            videoUrl = httpToHttps(videoUrl);
+            if (videoUrl.includes('.m3u8')) {
+                videoPlayer.style.display = 'block';
+                description.style.display = 'none';
+                if (Hls.isSupported()) {
+                    const hls = new Hls();
+                    hls.attachMedia(video);
+                    hls.on(Hls.Events.MEDIA_ATTACHED, () => {
+                        hls.loadSource(videoUrl);
+                    });
+                } else if (video.canPlayType('application/vnd.apple.mpegurl')) {
+                    video.src = videoUrl;
+                } else {
+                    alert('M3U8 格式不受您的浏览器支持。');
+                    console.error('M3U8 格式不受您的浏览器支持。');
+                    return;
+                }
+            } else if (videoUrl.includes('.flv')) {
+                if (flvjs.isSupported()) {
+                    const flvPlayer = flvjs.createPlayer({
+                        type: 'flv',
+                        url: videoUrl
+                    });
+                    flvPlayer.attachMediaElement(video);
+                    flvPlayer.load();
+                    flvPlayer.play();
+                } else {
+                    alert('FLV 格式不受您的浏览器支持。');
+                    console.error('FLV 格式不受您的浏览器支持。');
+                    return;
+                }
+
+                videoPlayer.style.display = 'block';
+                description.style.display = 'none';
+            } else {
+                console.error('不支持播放该视频格式。');
+                alert('不支持播放该视频格式。');
             }
-            logEl.textContent = logText;
-            scrollLog();
-        }else{
-            logEl.textContent = `操作: ${action} ${currentProcess}\n${data.output || '成功'}\n\n正在刷新状态...`;
-            scrollLog();
-            setTimeout(fetchStatus, 1500);
         }
-    }catch(err){
-        logEl.textContent = `请求失败: ${err.message}`;
-        scrollLog();
-        updateStatus('unknown');
-    }finally{
-        if(btn) btn.classList.remove('loading');
-    }
-}
 
-async function fetchStatus(){ pm2Action('status'); }
-
-// 按钮事件委托
-document.getElementById('pm2Buttons').addEventListener('click', e=>{
-    const btn = e.target.closest('button');
-    if(!btn) return;
-    const action = btn.dataset.action;
-    if(action && action !== 'status') pm2Action(action);
-});
-
-// 自动刷新 + 初始
-setInterval(fetchStatus, 1000);
-fetchStatus();
-updateSectionsVisibility();
-</script>
+        document.getElementById('playButton').addEventListener('click', playVideo);
+	    </script>
+	</div>
 </body>
 </html>

indexOrigin.html

@@ -1,215 +0,0 @@
-<!--
-    Project: DouyinLiveRecorder
-    Author: Hmily
-    Build: 2023.08.14 - 20:24:05
-    GitHub Project URL: https://github.com/ihmily/DouyinLiveRecorder
--->
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <meta name="referrer" content="never"> 
-    <title>M3U8 视频播放器</title>
-    <link rel="preconnect" href="https://fonts.googleapis.com">
-    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
-    <link href="https://fonts.googleapis.com/css2?family=Roboto:wght@400;700&amp;display=swap" rel="stylesheet">
-    <script src="https://cdn.jsdelivr.net/npm/hls.js@latest/dist/hls.min.js"></script>
-    <script src="https://cdn.jsdelivr.net/npm/flv.js@1.6.2/dist/flv.min.js"></script>
-
-    <style>
-        body {
-            font-family: 'Roboto', Arial, sans-serif;
-            background-color: #1a237e;
-            display: flex;
-            justify-content: center;
-            align-items: center;
-            height: 100vh;
-            margin: 0;
-            padding: 0;
-            color: #ffffff;
-            background-image: linear-gradient(120deg, #1a237e 0%, #283593 50%, #4a148c 100%);
-        }
-
-
-        .container {
-            max-width: 640px;
-            width: 80%;
-            padding: 20px;
-            background-color: #ffffff;
-            border-radius: 10px;
-            box-shadow: 0px 0px 5px 0px rgba(0,0,0,0.15);
-        }
-
-        #videoPlayer {
-            width: 100%;
-            height: 0;
-            padding-bottom: 56.25%;
-            position: relative;
-            background-color: #000;
-            border-radius: 5px;
-            box-shadow: 0px 0px 10px 0px rgba(0,0,0,0.15);
-            display: none;
-        }
-
-        video {
-            position: absolute;
-            top: 0;
-            left: 0;
-            width: 100%;
-            height: 100%;
-        }
-
-        #videoUrlInput{
-        	display: block;
-        	width: 100%;
-        	margin: 10px 0;
-        	padding: 8px;
-        	border-radius: 5px;
-        	border: 1px solid #ccc;
-            box-sizing: border-box;
-        }
-
-        #playButton {
-            display: block;
-            width: 100%;
-            padding: 10px;
-            background-color: #283593;
-            color: white;
-            font-weight: bold;
-            border-radius: 5px;
-            border: none;
-            cursor: pointer;
-            transition: background-color 0.3s;
-            margin: 0 0 10px 0;
-            box-shadow: 0px 2px 4px 0px rgba(0,0,0,0.15);
-        }
-
-        #playButton:hover {
-            background-color: #1a237e;
-        }
-
-        .description {
-            margin-top: 20px;
-            line-height: 1.4;
-            font-size: 14px;
-            text-align: left;
-            background-color: #f8f9fa;
-            padding: 15px;
-            border-radius: 5px;
-            
-            box-shadow: 0px 0px 5px 0px rgba(0,0,0,0.15);
-            display: block;
-        }
-        .footer {
-          margin-top: 30px;
-          text-align: center;
-          font-size: 14px;
-          color: white;
-        }
-
-        p{
-            color: black;
-        }
-        
-        a.no_style {
-            color: inherit;
-            text-decoration: none;
-        }
-        @media screen and (max-width: 768px) {
-            .container {
-                width: 90%;
-                border-radius: 0;
-                box-shadow: none;
-                margin-top:30px;
-            }
-            body {
-                overflow-y: scroll;
-            }
-            #videoUrlInput{
-                
-            	margin-top: 30px;
-            	margin-bottom: 10px;
-            }
-        
-        }
-
-    </style>
-</head>
-<body>
-	<div class="container">
-	    <input type="text" id="videoUrlInput" placeholder="请输入 M3U8或者FLV 视频链接">
-	    <button id="playButton">播放视频</button>
-	    <div id="videoPlayer">
-	        <video controls></video>
-	    </div>
-	    <div class="description">
-            <p><strong>说明</strong><p>
-            <p>M3U8文件格式</p>
-            <p>M3U8文件是采用UTF-8编码格式的M3U文件。M3U文件本身是一个纯文本索引文件，其核心功能是记录多媒体文件链接。当用户打开此类文件时，播放软件会根据索引查找相应的音视频文件网络地址，然后进行在线播放。</p>
-            <p>M3U最初设计用于播放音频文件，例如MP3。但随着时间推移，更多的播放器和软件开始使用M3U来播放视频文件列表，同时也支持在线流媒体音频源的指定。目前，许多播放器和软件都兼容M3U文件格式。</p>
-            <p>FLV文件格式（Flash Video Format）是Adobe公司开发的一种专门用于网页视频播放的文件格式。FLV格式的视频文件通常用于播放短视频和在线流媒体，可以嵌入到网页中供用户观看。FLV视频通常由Adobe Flash Player播放器播放，而其他第三方播放器也支持此格式。</p>
-        </div>
-        <div class="footer">
-          <p>&copy; 2023 <a href='https://github.com/ihmily/DouyinLiveRecorder' class="no_style" target="_blank">Hmily</a>. All rights reserved.</p>
-        </div>
-	    <script>
-    	    function httpToHttps(url) {
-              if (url.startsWith("http://")) {
-                return url.replace("http://", "https://");
-              }
-              return url;
-            }
-	        function playVideo() {
-            let videoUrl = document.getElementById('videoUrlInput').value;
-            const video = document.querySelector('#videoPlayer video');
-            const description = document.querySelector('.description');
-            if (videoUrl == ''){
-                alert('请输入视频链接');
-                return;
-            }
-            videoUrl = httpToHttps(videoUrl);
-            if (videoUrl.includes('.m3u8')) {
-                videoPlayer.style.display = 'block';
-                description.style.display = 'none';
-                if (Hls.isSupported()) {
-                    const hls = new Hls();
-                    hls.attachMedia(video);
-                    hls.on(Hls.Events.MEDIA_ATTACHED, () => {
-                        hls.loadSource(videoUrl);
-                    });
-                } else if (video.canPlayType('application/vnd.apple.mpegurl')) {
-                    video.src = videoUrl;
-                } else {
-                    alert('M3U8 格式不受您的浏览器支持。');
-                    console.error('M3U8 格式不受您的浏览器支持。');
-                    return;
-                }
-            } else if (videoUrl.includes('.flv')) {
-                if (flvjs.isSupported()) {
-                    const flvPlayer = flvjs.createPlayer({
-                        type: 'flv',
-                        url: videoUrl
-                    });
-                    flvPlayer.attachMediaElement(video);
-                    flvPlayer.load();
-                    flvPlayer.play();
-                } else {
-                    alert('FLV 格式不受您的浏览器支持。');
-                    console.error('FLV 格式不受您的浏览器支持。');
-                    return;
-                }
-
-                videoPlayer.style.display = 'block';
-                description.style.display = 'none';
-            } else {
-                console.error('不支持播放该视频格式。');
-                alert('不支持播放该视频格式。');
-            }
-        }
-
-        document.getElementById('playButton').addEventListener('click', playVideo);
-	    </script>
-	</div>
-</body>
-</html>

main.py

@@ -1164,9 +1164,11 @@ def start_record(url_data: tuple, count_variable: int = -1) -> None:
                         push_at = datetime.datetime.today().strftime('%Y-%m-%d %H:%M:%S')
                         if port_info['is_live'] is False:
                             print(f"\r{record_name} 等待直播... ")
+
                             # 直接退出线程eric
-                            # continue # 继续循环
-                            return  # 线程彻底退出
+                            # return 
+                             # 继续循环
+                            continue
 
                             if start_pushed:
                                 if over_show_push:
@@ -1618,33 +1620,388 @@ def start_record(url_data: tuple, count_variable: int = -1) -> None:
                                         with max_request_lock:
                                             error_count += 1
                                             error_window.append(1)
-                                
+
                                 else:
-                                    import sys
-                                    sys.path.insert(0, './dist')
-                                    from douyin_srs_ffplay import start_douyin_srs_ffplay
-                                    # 调用
-                                    start_douyin_srs_ffplay(
-                                        title=title_in_name,
-                                        anchor_name=anchor_name,
-                                        real_url=real_url,
-                                        rec_info=rec_info,
-                                        record_name=record_name,
-                                        recording=recording,
-                                        recording_time_list=recording_time_list,
-                                        running_list=running_list,
-                                        monitoring=monitoring,
-                                        clear_record_info=clear_record_info,
-                                        color_obj=color_obj
+                                    
+
+                                    # ====================== 抖音→YouTube 2025（重构：单层重试 + 统一清理） ======================
+                                    import queue, unicodedata, platform, traceback
+
+                                    class StreamEnded(Exception):
+                                        pass
+
+                                    def sanitize_title(text: str, max_len: int = 120) -> str:
+                                        if not text: return ""
+                                        text = unicodedata.normalize("NFKC", text)
+                                        text = ''.join(ch for ch in text if unicodedata.category(ch)[0] != 'C')
+                                        text = ''.join(ch for ch in text if ord(ch) <= 0xFFFF)
+                                        return text.strip()[:max_len]
+
+                                    def _stderr_reader_thread(proc, q):
+                                        try:
+                                            while True:
+                                                line = proc.stderr.readline()
+                                                if not line:
+                                                    break
+                                                q.put(line)
+                                        except Exception as e:
+                                            try:
+                                                q.put(f"__ERR__READER__:{e}")
+                                            except Exception:
+                                                pass
+                                        finally:
+                                            try:
+                                                q.put(None)
+                                            except Exception:
+                                                pass
+
+                                    def cleanup_proc(proc):
+                                        try:
+                                            if proc and proc.poll() is None:
+                                                try:
+                                                    proc.terminate()
+                                                    proc.wait(timeout=5)
+                                                except Exception:
+                                                    if proc.poll() is None:
+                                                        try:
+                                                            proc.kill()
+                                                        except Exception:
+                                                            pass
+                                        except Exception:
+                                            pass
+
+                                    # ========== 参数配置（保留你原始配置） ==========
+                                    # YT_STREAM_KEY = "qxvb-r47b-r5ju-6ud3-6k7z"
+                                    youtube_rtmp = f"rtmp://a.rtmp.youtube.com/live2/qxvb-r47b-r5ju-6ud3-6k7z"
+                                    # youtube_rtmp="rtmp://192.168.31.184/live/douyin"
+
+                                    # # ←←←← 在这块代码的上方先定义你要推的多个地址 ←←←←
+                                    # rtmp_targets = [
+                                    #     "rtmp://a.rtmp.youtube.com/live2/qxvb-r47b-r5ju-6ud3-6k7z",   # 主频道
+                                    #     "rtmp://192.168.31.184/live/douyin",   # 备用频道（换成你的第二个 YouTube 密钥）
+                                    # ]
+
+                                    # # 用 | 拼接所有地址（任何一个断开都不会影响其他）
+                                    # tee_outputs = "|".join([f"[f=flv]{url}" for url in rtmp_targets])
+
+
+
+                                    MAX_RETRY_DELAY = 90
+                                    INITIAL_RETRY_DELAY = 3
+                                    STDERR_QUEUE_TIMEOUT = 1.0
+
+
+                                    NO_FRAME_TIMEOUT = 120
+                                    START_CHECK_AFTER = 25  
+                                    STALE_OUTPUT_SECONDS = 40  #120 
+
+
+
+                                    END_KEYWORDS = [
+                                        "connection reset by peer",
+                                        "failed to write trailer",
+                                        "invalid data found",
+                                        "server returned 403",
+                                        "server returned 404",
+                                        "ingestion error",
+                                        "access denied",
+                                        "packet too short",
+                                        "client disconnected",
+                                        "live has ended",
+                                        "no route to host",
+                                        "connection timed out",
+                                    ]
+
+                                    timestamp_str = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
+                                    _clean_title_in_name = sanitize_title(title_in_name)
+                                    stream_title = sanitize_title(f"{anchor_name}{('_' + _clean_title_in_name) if _clean_title_in_name else ''}_{timestamp_str}")
+                                    print(f"[INFO] {rec_info} 开始推流到 YouTube: {stream_title}")
+
+                                    # NVENC 检测（原样保留）
+                                    codec_v, preset_v, tune_param = "libx264", "veryfast", ["-tune", "zerolatency"]
+                                    try:
+                                        if platform.system().lower() in ["windows", "linux"]:
+                                            check = subprocess.run(["nvidia-smi"], capture_output=True, timeout=5)
+                                            if check.returncode == 0:
+                                                enc = subprocess.run(["ffmpeg", "-hide_banner", "-encoders"], capture_output=True, text=True, timeout=5)
+                                                if "h264_nvenc" in (enc.stdout or ""):
+                                                    codec_v, preset_v, tune_param = "h264_nvenc", "p5", ["-tune", "ll", "-rc", "vbr", "-cq", "21", "-b:v", "2500k"]
+                                                    print("[INFO] 检测到 NVIDIA GPU → 使用 NVENC 硬件加速")
+                                    except Exception as e:
+                                        print(f"[WARN] NVENC 检测失败，回退软件编码: {e}")
+
+                                    # headers & ffmpeg command（保持原来参数）
+                                    douyin_headers = (
+                                        "User-Agent: Mozilla/5.0 (iPhone; CPU iPhone OS 18_1 like Mac OS X) AppleWebKit/605.1.15\r\n"
+                                        "Referer: https://live.douyin.com/\r\n"
+                                        "Origin: https://live.douyin.com\r\n"
                                     )
+
+                                    
+                                    # 720p
+                                    # ffmpeg_command = [
+                                    #     "ffmpeg", "-y", "-loglevel", "info", "-nostdin", "-re",
+                                    #     "-stats", "-stats_period", "1",
+                                    #     "-rw_timeout", "30000000",
+                                    #     "-reconnect", "1", "-reconnect_at_eof", "1", "-reconnect_streamed", "1",
+                                    #     "-reconnect_delay_max", "5",
+                                    #     "-fflags", "+genpts+discardcorrupt+nobuffer+flush_packets",
+                                    #     "-flags", "low_delay",
+                                    #     "-err_detect", "ignore_err",
+                                    #     "-max_delay", "80000",
+                                    #     "-thread_queue_size", "2048",
+
+                                    #     "-headers", douyin_headers,
+                                    #     "-i", real_url,
+                                    #     # 720p
+                                    #     "-vf", "fps=30,scale=720:1280:force_original_aspect_ratio=decrease:flags=lanczos,pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
+                                    #     "-c:v", "libx264",
+                                    #     "-preset", "fast",
+                                    #     # "-tune", "zerolatency",
+                                    #     "-profile:v", "high",
+                                    #     # 720p
+                                    #     # "-minrate", "3200k","-b:v", "3200k", "-maxrate", "3200k", "-bufsize", "6400k",   # bufsize = 2× bitrate，保持真 CBR
+                                    #     "-b:v", "2600k","-maxrate", "3000k","-bufsize", "5200k",
+                                    #     "-vsync", "cfr",
+                                    #     "-g", "60", "-keyint_min", "60",
+                                    #     "-r", "30",
+                                    #     "-bf", "0",
+                                    #     "-sc_threshold", "0",
+                                    #     # "-nal-hrd", "cbr",                                          # 改2：强制 CBR
+                                    #     # 720p
+                                    #     # "-x264-params", "nal-hrd=cbr:force-cfr=1:scenecut=0:filler=1",       # 改3：简化 params，锁死 CBR
+                                    #     "-x264-params", "force-cfr=1:scenecut=0:open_gop=0:sync-lookahead=0",
+                                    #     "-pix_fmt", "yuv420p",
+                                    #     "-c:a", "aac", "-b:a", "128k", "-ar", "48000", "-ac", "2",  # 改4：1080p可音频上 128k（YouTube 推荐）
+                                    #     "-af", "aresample=async=1:first_pts=0",
+
+                                    #     "-flags", "+global_header",
+                                    #     "-flvflags", "no_duration_filesize",
+                                    #     "-f", "flv", youtube_rtmp
+                                    # ]
+
+
+                                    # 1080p
+                                    ffmpeg_command = [
+                                        "ffmpeg", "-y", "-loglevel", "info", "-nostdin", "-re",
+                                        "-stats", "-stats_period", "1",
+                                        "-rw_timeout", "30000000",
+                                        "-reconnect", "1", "-reconnect_at_eof", "1", "-reconnect_streamed", "1",
+                                        "-reconnect_delay_max", "5",
+                                        "-fflags", "+genpts+discardcorrupt+nobuffer+flush_packets",
+                                        "-flags", "low_delay",
+                                        "-err_detect", "ignore_err",
+                                        "-max_delay", "80000",
+                                        "-thread_queue_size", "2048",
+
+                                        "-headers", douyin_headers,
+                                        "-i", real_url,
+                                        # 1080p
+                                        "-vf","fps=30,scale=1080:1920:force_original_aspect_ratio=decrease:flags=lanczos,pad=1080:1920:(ow-iw)/2:(oh-ih)/2:black",
+                                        "-c:v", "libx264",
+                                        "-preset", "veryfast",
+                                        "-tune", "zerolatency",
+                                        "-profile:v", "high",
+                                        # 1080p
+                                        "-b:v", "5200k", "-maxrate", "5800k", "-bufsize", "10400k",   # 改1：2× bufsize，真 CBR
+                                        "-vsync", "cfr",
+                                        "-g", "60", "-keyint_min", "60",
+                                        "-r", "30",
+                                        "-bf", "0",
+                                        "-sc_threshold", "0",
+                                        # "-nal-hrd", "cbr",                                          # 改2：强制 CBR
+                                        # 1080p
+                                        "-x264-params","force-cfr=1:scenecut=0:open_gop=0:sync-lookahead=0",
+                                        "-pix_fmt", "yuv420p",
+                                        "-c:a", "aac", "-b:a", "128k", "-ar", "44100", "-ac", "2", 
+                                        "-af", "aresample=async=1:first_pts=0",
+
+                                        "-flags", "+global_header",
+                                        "-flvflags", "no_duration_filesize",
+                                        "-f", "flv", youtube_rtmp
+                                    ]
+
+
+                                    # srs内网配置
+                                    # ffmpeg_command = [
+                                    #    "ffmpeg",
+                                    #     "-loglevel", "info", 
+                                    #     "-err_detect", "ignore_err+explode",
+                                    #     "-fflags", "+genpts+discardcorrupt+igndts",
+                                    #     "-reconnect", "1",
+                                    #     "-reconnect_at_eof", "1",
+                                    #     "-reconnect_streamed", "1",
+                                    #     "-reconnect_delay_max", "7",
+                                    #     "-rw_timeout", "30000000",
+                                    #     "-headers", douyin_headers,
+
+                                    #     # ===== 输入源 =====
+                                    #     "-i", real_url,
+                                    #     "-c:v", "copy",
+                                    #     "-c:a", "copy",
+                                    #     "-max_muxing_queue_size", "9999",
+                                    #     "-f", "flv", srs_rtmp
+                                    # ]
+
+                                    # ---- 单层重试循环（清晰可控） ----
+                                    proc = None
+                                    stderr_q = None
+                                    reader_t = None
+                                    retry_delay = INITIAL_RETRY_DELAY
+
+                                    try:
+                                        while True:
+                                            try:
+                                                if retry_delay > INITIAL_RETRY_DELAY:
+                                                    print(f"[WARN] 防风控等待 {retry_delay}s 后重新连接抖音源...")
+                                                time.sleep(retry_delay)
+
+                                                # 每次重连前先清理上一次的进程/线程
+                                                try:
+                                                    cleanup_proc(proc)
+                                                except Exception:
+                                                    pass
+                                                if stderr_q:
+                                                    # 垃圾化旧队列以便 GC
+                                                    stderr_q = None
+                                                stderr_q = queue.Queue()
+
+                                                print(f"[INFO][{datetime.datetime.now():%H:%M:%S}] 启动 YouTube 推流 → {stream_title}")
+                                                proc = subprocess.Popen(
+                                                    ffmpeg_command,
+                                                    stdin=subprocess.DEVNULL,
+                                                    stdout=subprocess.DEVNULL,
+                                                    stderr=subprocess.PIPE,
+                                                    text=True,
+                                                    bufsize=1,
+                                                    universal_newlines=True
+                                                )
+                                                proc.last_out_ts = time.time()
+
+                                                # 启动 stderr reader
+                                                reader_t = threading.Thread(target=_stderr_reader_thread, args=(proc, stderr_q))
+                                                reader_t.daemon = True
+                                                reader_t.start()
+
+                                                start_time = last_frame_time = time.time()
+
+                                                # ---- 监控循环（单一职责：处理 stderr 日志并决定是否结束/重连） ----
+                                                while True:
+                                                    try:
+                                                        try:
+                                                            line = stderr_q.get(timeout=STDERR_QUEUE_TIMEOUT)
+                                                        except queue.Empty:
+                                                            # 超时检查：如果太久没有任何日志，判为僵死，重启 proc（跳出内层，进行重试）
+                                                            if time.time() - getattr(proc, "last_out_ts", time.time()) > STALE_OUTPUT_SECONDS:
+                                                                print("[WARN] 长时间无任何日志，强制重启进程")
+                                                                cleanup_proc(proc)
+                                                                break
+                                                            continue
+
+                                                        if line is None:
+                                                            # reader 线程结束；如果 proc 已退出，跳出去重试
+                                                            if proc.poll() is not None:
+                                                                break
+                                                            else:
+                                                                continue
+
+                                                        line = line.strip()
+                                                        if line.startswith("__ERR__READER__"):
+                                                            print(f"[ERROR] stderr reader 异常: {line}")
+                                                            continue
+
+                                                        if line:
+                                                            proc.last_out_ts = time.time()
+                                                            print(f"[FFmpeg] {line}")
+                                                            line_lower = line.lower()
+
+                                                            # 检测到明确下播关键字 -> 认为主播真下播，立即退出（不再重试）
+                                                            if any(kw in line_lower for kw in END_KEYWORDS):
+                                                                print("[ERROR] 检测到主播真下播或被明确拒绝，停止推流")
+                                                                cleanup_proc(proc)
+                                                                raise StreamEnded()
+
+                                                            # 帧检测：更新 frame 时间戳
+                                                            if re.search(r'frame=\s*\d+', line_lower) or "fps=" in line_lower:
+                                                                last_frame_time = time.time()
+
+                                                            # 超时无新帧 => 认为下播
+                                                            if time.time() - start_time > START_CHECK_AFTER:
+                                                                if time.time() - last_frame_time > NO_FRAME_TIMEOUT:
+                                                                    print(f"[WARN] 连续 {NO_FRAME_TIMEOUT}s 无新帧，判定主播已下播")
+                                                                    cleanup_proc(proc)
+                                                                    raise StreamEnded()
+
+                                                    except StreamEnded:
+                                                        # 真实下播，抛到外层处理（最终会退出函数）
+                                                        raise
+                                                    except Exception as e:
+                                                        # 内层非致命异常：打印、回退重试间隔，退出监控循环以在外层重试
+                                                        print(f"[ERROR] 内层异常: {e}")
+                                                        traceback.print_exc()
+                                                        cleanup_proc(proc)
+                                                        retry_delay = min(retry_delay * 2, MAX_RETRY_DELAY)
+                                                        break  # 跳出监控循环 -> 外层 while 会继续并重试
+
+                                                # 如果监控循环走到这里并不是因为 StreamEnded（例如 break），则重试连接（loop continue）
+                                                # 将在 while True 的下一次循环中进行等待并重连
+                                                continue
+
+                                            except StreamEnded:
+                                                # 真实的主播下播，停止并彻底退出本录制线程
+                                                print(f"[INFO] 主播已下播，停止 YouTube 转推 → {record_name}")
+                                                break
+
+                                            except Exception as e:
+                                                # 外层致命异常：打印并退出循环（会在 finally 里做统一清理）
+                                                print(f"[ERROR] 外层异常: {e}")
+                                                traceback.print_exc()
+                                                retry_delay = min(retry_delay * 2, MAX_RETRY_DELAY)
+                                                # 等待并尝试重连（除非你希望直接退出，这里保留重试策略）
+                                                continue
+
+                                        # ============ 正常或 StreamEnded 后的统一清理（在这里 break 到这里） ============
+                                        cleanup_proc(proc)
+
+                                        # 以下清理放在 try/except 里以防止清理过程出错导致漏逻辑
+                                        try:
+                                            recording.discard(record_name)
+                                            recording_time_list.pop(record_name, None)
+                                            if record_url in running_list:
+                                                running_list.remove(record_url)
+                                            global monitoring
+                                            monitoring = max(0, monitoring - 1)
+                                            clear_record_info(record_name, record_url)
+                                        except Exception:
+                                            pass
+
+                                        color_obj.print_colored(f"[{record_name}] YouTube 推流已彻底停止并清理完毕\n", color_obj.GREEN)
+                                        return
+
+                                    except Exception as e:
+                                        # 最外层异常也要统一清理（保证不会留下僵尸状态）
+                                        print(f"[FATAL] YouTube 推流最外层异常: {e}")
+                                        traceback.print_exc()
+                                        try:
+                                            cleanup_proc(proc)
+                                        except Exception:
+                                            pass
+                                        try:
+                                            recording.discard(record_name)
+                                            recording_time_list.pop(record_name, None)
+                                            if record_url in running_list:
+                                                running_list.remove(record_url)
+                                            # global monitoring
+                                            monitoring = max(0, monitoring - 1)
+                                            clear_record_info(record_name, record_url)
+                                        except Exception:
+                                            pass
+                                        color_obj.print_colored(f"[{record_name}] YouTube 推流异常退出但已清理\n", color_obj.RED)
+                                        return
+
                                 count_time = time.time()
 
 
-
-
-
-
-
                 except Exception as e:
                     logger.error(f"错误信息: {e} 发生错误的行数: {e.__traceback__.tb_lineno}")
                     with max_request_lock:

obs.sh

@@ -1,5 +0,0 @@
-export DISPLAY=:0
-ffplay -fflags nobuffer -flags low_delay -framedrop \
--probesize 32 -analyzeduration 0 -sync ext -infbuf \
--vf "setpts=PTS-STARTPTS" \
-'srt://127.0.0.1:10080?streamid=#!::r=live/livestream,m=request&latency=10'

tiktok/index.html

@@ -1,175 +0,0 @@
-<!DOCTYPE html>
-<html lang="zh">
-<head>
-<meta charset="UTF-8">
-<meta name="viewport" content="width=device-width,initial-scale=1">
-<title>HDMI 录制控制台</title>
-<script src="https://cdn.jsdelivr.net/npm/hls.js@latest"></script>
-<style>
-:root{--bg:#1a237e;--accent:#283593;--text:#fff;--card:#fff;--card-text:#000}
-@media(prefers-color-scheme:dark){:root{--card:#1e1e1e;--card-text:#fff}}
-body{margin:0;font-family:system-ui,-apple-system,sans-serif;background:linear-gradient(135deg,var(--bg),#283593,#4a148c);color:var(--text);min-height:100vh;display:flex;justify-content:center;padding:20px;box-sizing:border-box}
-.container{max-width:720px;width:100%;background:var(--card);color:var(--card-text);border-radius:12px;padding:24px;box-shadow:0 8px 32px rgba(0,0,0,.4)}
-h1{margin:0 0 24px;font-size:1.6em;display:flex;align-items:center;gap:12px}
-#statusIndicator{font-size:1.2em;font-weight:600}
-h2{margin:24px 0 12px;font-size:1.4em}
-input,button{width:100%;padding:12px;margin:8px 0;border-radius:8px;border:none;box-sizing:border-box;font-size:1em}
-input{background:#f5f5f5;color:#000;border:1px solid #ddd}
-button{background:var(--accent);color:#fff;cursor:pointer;font-weight:600;transition:.2s}
-button:hover{background:#1a237e}
-button.loading{opacity:.7;pointer-events:none}
-button.loading::after{content:" ⏳";animation:spin 1s linear infinite}
-#pm2Buttons{display:grid;grid-template-columns:repeat(auto-fit,minmax(100px,1fr));gap:8px;margin:12px 0}
-#videoPlayer{position:relative;width:100%;padding-bottom:56.25%;background:#000;border-radius:8px;overflow:hidden;margin:16px 0;display:none}
-video{position:absolute;inset:0;width:100%;height:100%}
-#loading{position:absolute;inset:0;display:flex;align-items:center;justify-content:center;color:#fff;font-size:1.8em;pointer-events:none;background:rgba(0,0,0,.5);opacity:0;transition:opacity .3s;border-radius:8px}
-#pm2Log{background:#000;color:#0f0;padding:12px;height:320px;overflow-y:auto;font-family:monospace;font-size:.9em;border-radius:8px;white-space:pre-wrap;word-break:break-all}
-@keyframes spin{to{transform:rotate(360deg)}}
-</style>
-</head>
-<body>
-<div class="container">
-    <h1>进程: hdmi <span id="statusIndicator">⚪ 加载中...</span></h1>
-
-    <h2>视频播放器（M3U8 / FLV）</h2>
-    <input type="text" id="videoUrlInput" placeholder="请输入视频链接">
-    <button id="playButton">播放</button>
-    <div id="videoPlayer">
-        <video controls autoplay playsinline></video>
-        <div id="loading">加载中...</div>
-    </div>
-
-    <h2>PM2 进程控制</h2>
-    <div id="pm2Buttons">
-        <button data-action="start">启动</button>
-        <button data-action="stop">停止</button>
-        <button data-action="restart">重启</button>
-        <button data-action="status">手动刷新</button>
-    </div>
-
-    <h2>实时日志（自动每秒刷新）</h2>
-    <pre id="pm2Log">正在加载状态与日志...</pre>
-</div>
-
-<script>
-const video = document.querySelector('video');
-const player = document.getElementById('videoPlayer');
-const loading = document.getElementById('loading');
-const logEl = document.getElementById('pm2Log');
-const statusIndicator = document.getElementById('statusIndicator');
-
-function httpToHttps(url){return url.replace(/^http:/,"https:")}
-
-function scrollLog(){logEl.scrollTop = logEl.scrollHeight}
-
-function updateStatus(process_status){
-    let emoji = '⚪', text = '未知';
-    if(process_status === 'online'){ emoji = '  '; text = '运行中'; }
-    else if(process_status === 'stopped'){ emoji = '  '; text = '已停止'; }
-    else if(process_status === 'errored'){ emoji = '  '; text = '错误'; }
-    else if(process_status === 'launching' || process_status === 'starting'){ emoji = '  '; text = '启动中'; }
-    else if(process_status === 'waiting restart'){ emoji = '  '; text = '等待重启'; }
-    else if(process_status === 'not_found'){ emoji = '❌'; text = '未注册到 PM2'; }
-    statusIndicator.innerHTML = `${emoji} ${text}`;
-}
-
-async function playVideo(){
-    let url = document.getElementById('videoUrlInput').value.trim();
-    if(!url) return alert('请输入视频链接');
-    url = httpToHttps(url);
-    player.style.display = 'block';
-    loading.style.opacity = 1;
-    video.pause(); video.src = '';
-
-    if(url.endsWith('.m3u8')){
-        if(Hls.isSupported()){
-            const hls = new Hls({enableWorker:true});
-            hls.loadSource(url);
-            hls.attachMedia(video);
-            hls.on(Hls.Events.MANIFEST_PARSED, ()=>loading.style.opacity=0);
-            hls.on(Hls.Events.ERROR, (e,data)=>{alert('HLS 错误: '+data.type); loading.style.opacity=0});
-        }else if(video.canPlayType('application/vnd.apple.mpegurl')){
-            video.src = url; video.play(); loading.style.opacity=0;
-        }else{alert('浏览器不支持 M3U8'); return}
-    }else if(url.endsWith('.flv')){
-        if(typeof flvjs !== 'undefined' && flvjs.isSupported()){
-            const flvPlayer = flvjs.createPlayer({type:'flv',url,isLive:true});
-            flvPlayer.attachMediaElement(video);
-            flvPlayer.load(); flvPlayer.play();
-            flvPlayer.on(flvjs.Events.LOADING_COMPLETE, ()=>loading.style.opacity=0);
-        }else{
-            const script = document.createElement('script');
-            script.src = 'https://cdn.jsdelivr.net/npm/flv.js@1.6.2/dist/flv.min.js';
-            script.onload = playVideo;
-            document.head.appendChild(script);
-            return;
-        }
-    }else{alert('仅支持 .m3u8 或 .flv 格式'); return}
-}
-document.getElementById('playButton').onclick = playVideo;
-
-// PM2 控制 + 实时状态/日志
-async function pm2Action(action){
-    const btn = document.querySelector(`[data-action="${action}"]`);
-    if(btn) btn.classList.add('loading');
-
-    try{
-        const res = await fetch(`/${action}`);
-        if(!res.ok) throw new Error('网络错误');
-        const data = await res.json();
-
-        if(action === 'status'){
-            updateStatus(data.process_status);
-
-            let logText = `【PM2 全状态表格】（${new Date().toLocaleTimeString()}）\n${data.raw_status}\n\n`;
-
-            if(data.process_status === 'not_found'){
-                logText += `【提示】进程 "hdmi" 未注册到 PM2（可能被 pm2 delete 删除）\n`;
-            }else{
-                logText += `【实时输出日志】`;
-                if(data.recent_log.includes('不存在') || data.recent_log.includes('无日志路径')){
-                    logText += `\n${data.recent_log}`;
-                }else{
-                    logText += `（最近 ${data.recent_log.trim().split('\n').length} 行）\n${data.recent_log || '无新输出'}`;
-                }
-
-                logText += `\n\n【实时错误日志】`;
-                if(data.recent_error.includes('不存在') || data.recent_error.includes('无日志路径')){
-                    logText += `\n${data.recent_error}`;
-                }else{
-                    logText += `（最近 ${data.recent_error.trim().split('\n').length} 行）\n${data.recent_error || '无错误'}`;
-                }
-            }
-
-            logEl.textContent = logText;
-            scrollLog();
-        }else{
-            logEl.textContent = `操作: ${action}\n${data.output || '成功'}\n\n正在刷新状态...`;
-            scrollLog();
-            setTimeout(fetchStatus, 1500);
-        }
-    }catch(err){
-        logEl.textContent = `请求失败: ${err.message}`;
-        scrollLog();
-        updateStatus('unknown');
-    }finally{
-        if(btn) btn.classList.remove('loading');
-    }
-}
-
-async function fetchStatus(){ pm2Action('status'); }
-
-// 按钮事件委托
-document.getElementById('pm2Buttons').addEventListener('click', e=>{
-    const btn = e.target.closest('button');
-    if(!btn) return;
-    const action = btn.dataset.action;
-    if(action && action !== 'status') pm2Action(action);
-});
-
-// 自动刷新（每 1 秒）
-setInterval(fetchStatus, 1000);
-fetchStatus();
-</script>
-</body>
-</html>

tiktok/tiktok.py

@@ -1,142 +0,0 @@
-from fastapi import FastAPI
-from fastapi.responses import FileResponse, JSONResponse
-from pathlib import Path
-import asyncio
-import re
-from fastapi.middleware.cors import CORSMiddleware
-
-app = FastAPI(title="HDMI 录制控制台")
-
-# ---------------- 配置 ----------------
-BOT_NAME = "hdmi"
-BASE_DIR = Path(__file__).parent
-DEFAULT_LOG_DIR = BASE_DIR.parent / ".pm2" / "logs"
-MAX_LOG_LINES = 300
-
-# CORS
-app.add_middleware(
-   CORSMiddleware,
-   allow_origins=["*"],
-   allow_methods=["GET"],
-   allow_headers=["*"],
-)
-
-# ---------------- 工具 ----------------
-def strip_ansi_codes(text: str) -> str:
-   return re.sub(r'\x1b\[[0-9;]*m', '', text)
-
-async def run_pm2(cmd: str) -> str:
-   process = await asyncio.create_subprocess_shell(
-       f"pm2 {cmd}",
-       stdout=asyncio.subprocess.PIPE,
-       stderr=asyncio.subprocess.PIPE,
-   )
-   try:
-       stdout, stderr = await asyncio.wait_for(process.communicate(), timeout=15.0)
-       return (stdout or stderr).decode(errors="ignore").strip()
-   except asyncio.TimeoutError:
-       process.kill()
-       return "ERROR: PM2 命令超时"
-
-async def read_log_path(path: str, lines: int) -> str:
-   if not path:
-       return "无日志路径\n"
-   if "/dev/null" in path:
-       return "日志输出被禁用（PM2 配置为无日志）\n"
-   log_file = Path(path)
-   if not log_file.exists():
-       return f"日志文件不存在: {path}\n"
-   try:
-       with open(log_file, "r", encoding="utf-8", errors="ignore") as f:
-           content_lines = f.readlines()
-           return "".join(content_lines[-lines:]) if content_lines else "无日志内容\n"
-   except Exception as e:
-       return f"读取日志失败 ({path}): {str(e)}\n"
-
-async def get_hdmi_info() -> dict:
-   describe_raw = await run_pm2(f"describe {BOT_NAME}")
-   describe_clean = strip_ansi_codes(describe_raw)
-
-   if ("No such process" in describe_clean or
-       "Unknown process" in describe_clean or
-       "not found" in describe_clean.lower() or
-       not describe_clean.strip()):
-       return {
-           "process_status": "not_found",
-           "out_path": None,
-           "err_path": None,
-       }
-
-   status = "unknown"
-   out_path = None
-   err_path = None
-
-   for line in describe_raw.splitlines():
-       line_clean = strip_ansi_codes(line)
-       if line_clean.count('│') < 2:
-           continue
-       parts = [p.strip() for p in line_clean.split('│') if p.strip()]
-
-       if len(parts) >= 2:
-           key = parts[0].lower()
-           value = parts[1]
-
-           if key == "status":
-               status = value.lower()
-           elif key == "out_log_path":
-               out_path = value
-           elif key == "err_log_path":
-               err_path = value
-
-   # 备用默认路径（仅当 describe 未提供时）
-   if not out_path:
-       out_path = str(DEFAULT_LOG_DIR / f"{BOT_NAME}-out.log")
-   if not err_path:
-       err_path = str(DEFAULT_LOG_DIR / f"{BOT_NAME}-error.log")
-
-   return {
-       "process_status": status,
-       "out_path": out_path,
-       "err_path": err_path,
-   }
-
-# ---------------- 路由 ----------------
-@app.get("/start")
-async def start():
-   output = await run_pm2(f"start {BOT_NAME}")
-   return JSONResponse({"output": output})
-
-@app.get("/stop")
-async def stop():
-   output = await run_pm2(f"stop {BOT_NAME}")
-   return JSONResponse({"output": output})
-
-@app.get("/restart")
-async def restart():
-   output = await run_pm2(f"restart {BOT_NAME}")
-   return JSONResponse({"output": output})
-
-@app.get("/status")
-async def status():
-   full_status_raw = await run_pm2("status")
-   full_status = strip_ansi_codes(full_status_raw) # 去除颜色代码，前端显示更干净
-
-   info = await get_hdmi_info()
-
-   recent_log = await read_log_path(info["out_path"], MAX_LOG_LINES)
-   recent_error = await read_log_path(info["err_path"], MAX_LOG_LINES)
-
-   if info["process_status"] == "not_found":
-       recent_log = "进程未注册到 PM2（可能被 pm2 delete 删除或从未保存）\n"
-       recent_error = ""
-
-   return JSONResponse({
-       "raw_status": full_status,
-       "process_status": info["process_status"],
-       "recent_log": recent_log,
-       "recent_error": recent_error,
-   })
-
-@app.get("/")
-async def index():
-   return FileResponse(BASE_DIR / "index.html")

tiktok/tiktok.sh

@@ -1 +0,0 @@
-uvicorn web:app --host 0.0.0.0 --port 8000 --reload

web.py

@@ -1,217 +0,0 @@
-from fastapi import FastAPI, Query, Request
-from fastapi.responses import FileResponse, JSONResponse
-from pathlib import Path
-import asyncio
-import re
-from fastapi.middleware.cors import CORSMiddleware
-
-app = FastAPI(title="多进程录制控制台")
-
-# ---------------- 配置（根目录结构） ----------------
-BASE_DIR = Path(__file__).parent
-CONFIG_DIR = BASE_DIR / "config"                  # config 文件夹在项目根目录
-DEFAULT_LOG_DIR = BASE_DIR / ".pm2" / "logs"      # .pm2/logs 在项目根目录
-
-MAX_LOG_LINES = 300
-
-# 支持的进程列表
-VALID_PROCESSES = {"tiktok", "youtube", "obs"}
-
-# CORS（支持 GET 和 POST）
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_methods=["GET", "POST"],
-    allow_headers=["*"],
-)
-
-# ---------------- 工具 ----------------
-def strip_ansi_codes(text: str) -> str:
-    return re.sub(r'\x1b\[[0-9;]*m', '', text)
-
-async def run_pm2(cmd: str) -> str:
-    process = await asyncio.create_subprocess_shell(
-        f"pm2 {cmd}",
-        stdout=asyncio.subprocess.PIPE,
-        stderr=asyncio.subprocess.PIPE,
-    )
-    try:
-        stdout, stderr = await asyncio.wait_for(process.communicate(), timeout=15.0)
-        return (stdout or stderr).decode(errors="ignore").strip()
-    except asyncio.TimeoutError:
-        process.kill()
-        return "ERROR: PM2 命令超时"
-
-async def read_log_path(path: str, lines: int) -> str:
-    if not path:
-        return "无日志路径\n"
-    if "/dev/null" in path:
-        return "日志输出被禁用（PM2 配置为无日志）\n"
-    log_file = Path(path)
-    if not log_file.exists():
-        return f"日志文件不存在: {path}\n"
-    try:
-        with open(log_file, "r", encoding="utf-8", errors="ignore") as f:
-            content_lines = f.readlines()
-            return "".join(content_lines[-lines:]) if content_lines else "无日志内容\n"
-    except Exception as e:
-        return f"读取日志失败 ({path}): {str(e)}\n"
-
-async def get_process_info(process: str) -> dict:
-    describe_raw = await run_pm2(f"describe {process}")
-    describe_clean = strip_ansi_codes(describe_raw)
-    if ("No such process" in describe_clean or
-        "Unknown process" in describe_clean or
-        "not found" in describe_clean.lower() or
-        not describe_clean.strip()):
-        return {
-            "process_status": "not_found",
-            "out_path": None,
-            "err_path": None,
-        }
-    status = "unknown"
-    out_path = None
-    err_path = None
-    for line in describe_raw.splitlines():
-        line_clean = strip_ansi_codes(line)
-        if line_clean.count('│') < 2:
-            continue
-        parts = [p.strip() for p in line_clean.split('│') if p.strip()]
-        if len(parts) >= 2:
-            key = parts[0].lower()
-            value = parts[1]
-            if key == "status":
-                status = value.lower()
-            elif key == "out_log_path":
-                out_path = value
-            elif key == "err_log_path":
-                err_path = value
-    # 备用默认路径
-    if not out_path:
-        out_path = str(DEFAULT_LOG_DIR / f"{process}-out.log")
-    if not err_path:
-        err_path = str(DEFAULT_LOG_DIR / f"{process}-error.log")
-    return {
-        "process_status": status,
-        "out_path": out_path,
-        "err_path": err_path,
-    }
-
-# ---------------- 配置路由（youtube.ini，仅 youtube） ----------------
-@app.get("/get_config")
-async def get_config(process: str = Query(..., description="进程名")):
-    if process != "youtube":
-        return JSONResponse({"error": "仅 youtube 支持此配置编辑"}, status_code=400)
-    
-    config_file = CONFIG_DIR / "youtube.ini"
-    if not config_file.exists():
-        return {"content": "# youtube.ini 文件不存在，将创建空文件\n"}
-    try:
-        content = config_file.read_text(encoding="utf-8")
-        return {"content": content}
-    except Exception as e:
-        return JSONResponse({"error": f"读取失败: {str(e)}"}, status_code=500)
-
-@app.post("/save_config")
-async def save_config(request: Request, process: str = Query(..., description="进程名")):
-    if process != "youtube":
-        return JSONResponse({"error": "仅 youtube 支持此配置编辑"}, status_code=400)
-    
-    try:
-        data = await request.json()
-        content = data.get("content", "")
-    except:
-        return JSONResponse({"error": "无效的 JSON 数据"}, status_code=400)
-    
-    config_file = CONFIG_DIR / "youtube.ini"
-    try:
-        CONFIG_DIR.mkdir(parents=True, exist_ok=True)
-        config_file.write_text(content, encoding="utf-8")
-        return {"message": "配置保存成功"}
-    except Exception as e:
-        return JSONResponse({"error": f"保存失败: {str(e)}"}, status_code=500)
-
-# ---------------- 配置路由（URL_config.ini，youtube 和 tiktok 共享） ----------------
-@app.get("/get_url_config")
-async def get_url_config(process: str = Query(..., description="进程名")):
-    if process not in ["youtube", "tiktok"]:
-        return JSONResponse({"error": "仅 youtube 和 tiktok 支持此配置编辑"}, status_code=400)
-    
-    config_file = CONFIG_DIR / "URL_config.ini"
-    if not config_file.exists():
-        return {"content": "# URL_config.ini 文件不存在，将创建空文件\n"}
-    try:
-        content = config_file.read_text(encoding="utf-8")
-        return {"content": content}
-    except Exception as e:
-        return JSONResponse({"error": f"读取失败: {str(e)}"}, status_code=500)
-
-@app.post("/save_url_config")
-async def save_url_config(request: Request, process: str = Query(..., description="进程名")):
-    if process not in ["youtube", "tiktok"]:
-        return JSONResponse({"error": "仅 youtube 和 tiktok 支持此配置编辑"}, status_code=400)
-    
-    try:
-        data = await request.json()
-        content = data.get("content", "")
-    except:
-        return JSONResponse({"error": "无效的 JSON 数据"}, status_code=400)
-    
-    config_file = CONFIG_DIR / "URL_config.ini"
-    try:
-        CONFIG_DIR.mkdir(parents=True, exist_ok=True)
-        config_file.write_text(content, encoding="utf-8")
-        return {"message": "配置保存成功"}
-    except Exception as e:
-        return JSONResponse({"error": f"保存失败: {str(e)}"}, status_code=500)
-
-# ---------------- PM2 控制路由 ----------------
-@app.get("/start")
-async def start(process: str = Query(..., description="进程名")):
-    if process not in VALID_PROCESSES:
-        return JSONResponse({"output": f"无效进程名: {process}"}, status_code=400)
-    output = await run_pm2(f"start {process}")
-    return JSONResponse({"output": output})
-
-@app.get("/stop")
-async def stop(process: str = Query(..., description="进程名")):
-    if process not in VALID_PROCESSES:
-        return JSONResponse({"output": f"无效进程名: {process}"}, status_code=400)
-    output = await run_pm2(f"stop {process}")
-    return JSONResponse({"output": output})
-
-@app.get("/restart")
-async def restart(process: str = Query(..., description="进程名")):
-    if process not in VALID_PROCESSES:
-        return JSONResponse({"output": f"无效进程名: {process}"}, status_code=400)
-    output = await run_pm2(f"restart {process}")
-    return JSONResponse({"output": output})
-
-@app.get("/status")
-async def status(process: str = Query(..., description="进程名")):
-    if process not in VALID_PROCESSES:
-        return JSONResponse({
-            "raw_status": "",
-            "process_status": "invalid",
-            "recent_log": f"无效进程名: {process}",
-            "recent_error": ""
-        })
-    full_status_raw = await run_pm2("status")
-    full_status = strip_ansi_codes(full_status_raw)
-    info = await get_process_info(process)
-    recent_log = await read_log_path(info["out_path"], MAX_LOG_LINES)
-    recent_error = await read_log_path(info["err_path"], MAX_LOG_LINES)
-    if info["process_status"] == "not_found":
-        recent_log = "进程未注册到 PM2（可能被 pm2 delete 删除或从未保存）\n"
-        recent_error = ""
-    return JSONResponse({
-        "raw_status": full_status,
-        "process_status": info["process_status"],
-        "recent_log": recent_log,
-        "recent_error": recent_error,
-    })
-
-# ---------------- 首页 ----------------
-@app.get("/")
-async def index():
-    return FileResponse(BASE_DIR / "index.html")

web.sh

@@ -1 +0,0 @@
-uvicorn web:app --host 0.0.0.0 --port 8000 --reload

youtubeKey

@@ -0,0 +1,38 @@
+ue78-1c3e-mr9g-14mz-9r4z   # 没有ypp的美食
+qxvb-r47b-r5ju-6ud3-6k7z   # vlog频道
+x04z-564w-aks7-embw-30y4   #美食ypp
+
+
+
+; https://live.douyin.com/517715534931,主播: 一只羊
+; https://live.douyin.com/460525712926,主播: 丽姐摆摊记
+; https://live.douyin.com/745606325880,主播: w、(摆摊日记_)
+; https://live.douyin.com/675343045974,主播: 张子沐的串串(你的电子榨菜)
+; https://live.douyin.com/673565298571,主播: 轻舟已撞大冰山(摆摊vlog)
+; https://live.douyin.com/835571459859,主播: 海绵饱饱
+; https://live.douyin.com/152358755212,主播: 大美_红烧肉
+; https://live.douyin.com/990825651731,主播: 王同学摆摊日记(蜜汁烤鸡腿)
+; https://live.douyin.com/591442402624,主播: 76696515302
+; https://live.douyin.com/967381081829,主播: 憨憨的摆摊日记
+; https://live.douyin.com/78012762575,主播: 摆摊儿去划水
+; https://live.douyin.com/163813589919,主播: 不要熬夜(摆摊中)
+; https://live.douyin.com/498368994814,主播: 剪头发的小帆帆
+; https://live.douyin.com/617848099204,主播: 果妈要努力
+; https://live.douyin.com/821525628944,主播: 李熙雨⭐
+; https://live.douyin.com/993102287144,主播: 小茗早餐(薪笼记助创官)
+; https://live.douyin.com/701547125568,主播: 悠悠包
+; https://live.douyin.com/816130992220,主播: 甜昕冰冰的摆摊日记
+; https://live.douyin.com/876468215361,主播: 晓晓和凡凡
+; https://live.douyin.com/511335278313,主播: 秘书(摆摊休息版)
+; https://live.douyin.com/483160615952,主播: 小胡同学你好(饭团版)
+; https://live.douyin.com/525514386431,主播: 阿闯烤肉夹馍
+; https://live.douyin.com/8687122573,主播: 小彤炒粉
+; https://live.douyin.com/642534242822,主播: (小王_)煎饼果子
+; https://live.douyin.com/743565594721,主播: 汪汪汪小妞
+; https://live.douyin.com/249578288248,主播: 思思努力版
+; https://live.douyin.com/472140253414,主播: 戴盘龙
+; https://live.douyin.com/700846653732,主播: 三哥大锅菜_炒鸡(国基路店)官方号
+; https://live.douyin.com/81849868631,主播: 纯儿²¹(休息勿跑空哦)
+; https://live.douyin.com/690114366322,主播: 卤味鲜(东大)
+; https://live.douyin.com/469980190666,主播: 茜茜柠檬茶(小米茶档_)
+; https://live.douyin.com/388066418744,主播: 加速姐的摆摊日记