@dataclass
class VideoInfo:
    bvid: str             # BV 号（如 BV1xx4y1a7AB）
    title: str            # 视频标题
    uid: int              # UP 主 UID
    author: str           # UP 主名称
    pubdate: int          # 发布时间（Unix timestamp）
    duration: int         # 时长（秒）
    desc: str = ""        # 视频描述
    pic: str = ""         # 封面图 URL

@dataclass
class DynamicInfo:
    dynamic_id: str       # 动态 ID
    title: str           # 动态标题/摘要
    author: str          # UP 主名称
    uid: int             # UP 主 UID
    pubdate: int         # 发布时间
    link: str            # 动态链接
    content: str = ""    # 动态正文
    image_urls: list[str] = field(default_factory=list)  # 配图
    linked_bvid: str = "" # 关联视频 BV 号

@dataclass
class NoteInfo:
    note_id: str         # 笔记 ID
    title: str           # 笔记标题
    author: str          # 博主昵称
    user_id: str         # 博主 ID
    note_type: str       # "video" | "normal"
    pubdate: int         # 发布时间
    desc: str = ""       # 笔记描述
    cover_url: str = ""  # 封面图 URL
    liked_count: int = 0 # 点赞数
    xsec_token: str = "" # 访问令牌

@dataclass
class DownloadResult:
    success: bool
    bvid: str
    title: str
    filepath: Optional[Path] = None
    error: Optional[str] = None
    access_limited: bool = False      # 是否权限受限
    access_note: str = ""            # 权限说明

@dataclass
class TranscriptResult:
    success: bool
    bvid: str
    title: str
    transcript_path: Optional[Path] = None
    json_path: Optional[Path] = None
    text: str = ""                    # 转写文本
    language: str = ""               # 检测语言
    duration_seconds: float = 0.0
    error: Optional[str] = None

async def process_video(bvid, config, title, author, uid, pubdate, duration, store, warning_tracker):
    # Step 1: 下载视频（优先音频）
    dl_result = await download_video(bvid, config)
    if not dl_result.success:
        # 永久性失败（付费/404）标记已知，避免无限重试
        return result

    # Step 2: SenseVoice 转写
    tr_result = transcribe_file(dl_result.filepath, config, bvid, title, author)
    if not tr_result.success:
        return result

    # Step 3: 抓取评论区亮点
    comment_result = fetch_comment_highlights(bvid, config)

    # Step 4: AI 摘要生成（CodeBuddy CLI）
    summary, summary_source, is_ai = post_transcribe_hook(...)

    # Step 5: 提炼关键词
    keywords = extract_keywords_codebuddy(summary, title, author)

    # Step 6: Gotify 推送通知
    notified = notify_new_video(bvid, title, author, summary, ...)

    # Step 7: 清理原始文件
    if config.transcribe.delete_after_transcribe:
        cleanup_media(dl_result.filepath, bvid)

    # Step 8: 标记为已知视频
    store.mark_known(VideoInfo(...))

class InstanceHealth:
    success_count: int = 0
    fail_count: int = 0
    last_success: float = 0
    avg_response_time: float = 0

    @property
    def score(self) -> float:
        # 基础成功率权重 70%
        score = (self.success_count / total) * 70
        # 近期活跃度权重 30%
        if now - last_success < 3600:  # 1 小时内
            score += 30
        elif now - last_success < 7200:  # 2 小时内
            score += 15
        return score

async def process_xhs_note(note, config, store):
    # Step 1: 下载笔记内容
    dl_result = await download_note(note, config)

    # Step 2: 解析笔记内容
    # - 图文笔记：直接提取正文
    # - 视频笔记：返回视频路径供转写
    content = parse_note_content(note, dl_result)

    # Step 3: 视频笔记转写
    if content.is_video and content.video_path:
        tr_result = transcribe_file(content.video_path, ...)
        content.text = tr_result.text

    # Step 4: 评论亮点
    comment_result = xhs_fetch_comment_highlights(note.note_id, config)

    # Step 5: AI 摘要
    summary = post_transcribe_hook(...)

    # Step 6: 关键词
    keywords = extract_keywords_codebuddy(...)

    # Step 7: 推送
    notify_new_xhs_note(note, content, summary, ...)

    # Step 8: 清理
    if content.video_path and config.transcribe.delete_after_transcribe:
        cleanup_media(content.video_path, note.note_id)

    # Step 9: 标记已知
    store.mark_known(note)

@dataclass
class Config:
    credential: Credential              # B 站凭证
    download: DownloadConfig           # 下载配置
    transcribe: TranscribeConfig       # 转写配置
    subscriptions: list[Subscription] # B 站订阅列表
    monitor: MonitorConfig            # 监控配置
    analysis: AnalysisConfig          # AI 分析配置
    notification: NotificationConfig  # 推送配置
    xiaohongshu: XhsConfig         # 小红书配置

# 凭证配置
credential:
  sessdata: "你的B站SESSDATA"
  bili_jct: "你的bili_jct"
  buvid3: "你的buvid3"
  dedeuserid: "你的DedeUserID"
cookies_file: ''  # 或指定 cookies.txt 路径

# 下载配置
download:
  dir: ./downloads
  quality: worst          # 优先级：省空间
  format: bestaudio/worst  # 优先只下音频
  max_concurrent: 3

# 转写配置
transcribe:
  model: base
  language: zh
  output_dir: ./transcripts
  delete_after_transcribe: true

# B 站订阅配置（示例）
subscriptions:
  - uid: 12345678
    name: "示例UP主A"

# 监控配置
monitor:
  mode: rss                # rss（推荐）/ api
  rsshub_base: https://rsshub.yfi.moe
  interval_minutes: 3
  watch_dynamic: true
  max_videos_per_check: 10

# AI 分析配置
analysis:
  enabled: true

# 推送配置
notification:
  enabled: true
  gotify_url: ''
  gotify_token: ''
  priority: 5

# 小红书配置（示例）
xiaohongshu:
  enabled: true
  cookie: ''                  # 或环境变量 XHS_COOKIE
  subscriptions:
    - user_id: "示例user_id"
      name: "示例博主"
  monitor:
    mode: api
    interval_minutes: 10
  notification:
    gotify_token: ''           # 或环境变量 GOTIFY_TOKEN_XHS

# 安装 uv（Python 包管理器）
# macOS: brew install uv
# 其他: https://docs.astral.sh/uv/getting-started/installation/

# 安装 FFmpeg（音频提取）
# macOS: brew install ffmpeg
# Ubuntu: apt install ffmpeg

# 安装 Node.js 20+（小红书签名依赖）
# nvm install 22

# 手动执行一次
uv run python run_check.py
uv run python run_check.py --platform bili
uv run python run_check.py --platform xhs

# Cron 定时执行（推荐）
# 每 3 分钟执行一次
*/3 * * * * cd /path/to/feedflow && uv run python run_check.py --platform all >> cron.log 2>&1

docker run -d \
  --name gotify \
  -p 8080:80 \
  -v gotify-data:/app/data \
  -e GOTIFY_DEFAULTUSER_NAME=admin \
  -e GOTIFY_DEFAULTUSER_PASS=<your-password> \
  gotify/server:latest
# 访问 http://your-server:8080，登录后在 Settings → Apps 创建 Token

# platforms/youtube/monitor.py
@dataclass
class VideoInfo:
    video_id: str
    title: str
    channel_id: str
    author: str
    pubdate: int
    duration: int

class SubscriptionStore:
    def is_known(self, video_id: str) -> bool: ...
    def mark_known(self, video: VideoInfo): ...

def check_new_videos(config, store) -> list[VideoInfo]: ...

# 单独测试转写
from core.transcriber import transcribe_file
result = transcribe_file(Path("test.mp4"), config)

# 单独测试摘要
from core.summarizer import generate_summary
summary, source, is_ai = generate_summary(bvid, title, author, text, config)

# 单独测试推送
from core.notifier import send_gotify
send_gotify("测试", "这是一条测试消息", config)