[Plugin] astrbot_plugin_livepulse

[cxyfer]

插件信息

插件信息

{
  "name": "astrbot_plugin_livepulse",
  "display_name": "LivePulse",
  "desc": "Multi-platform live stream monitor for YouTube, Twitch, and Bilibili.",
  "author": "Xyfer",
  "repo": "https://github.com/cxyfer/astrbot_plugin_livepulse",
  "tags": [
    "直播",
    "Bilibili",
    "YouTube",
    "Twitch"
  ],
  "social_link": "https://github.com/cxyfer"
}

插件检查清单

• 我的插件经过完整的测试
• 我的插件不包含恶意代码
• 我已阅读并同意遵守该项目的 行为准则。

[astrpluginreviewer]

🤖 AI代码审核报告 for astrbot_plugin_livepulse

您好！我已经对你提交的插件代码进行了初步自动化审核，作为初步参考:

main.py

1. 严重逻辑错误：config 可能为 None 时被直接调用 .get()

   • 在 __init__ 中先做了 self.config = config or {}，但后面却使用了 config.get("default_language", "en")。
   • 当 config is None 时这里会直接抛出 AttributeError，导致插件初始化失败。
   • 应统一使用 self.config.get(...)。

2. 框架规范问题：@filter.command_group("live") 方法签名缺少 event 参数

   • 当前：

     @filter.command_group("live")
     def live(self):
         pass

   • 按你给出的审查规则，除 on_astrbot_loaded 外，所有 @filter 装饰方法都应包含 event 参数。

3. 可维护性问题：cmd_add/cmd_remove 的形参未被使用

   • platform: str = "", channel_id: str = "" 未参与逻辑，实际解析来自 event.message_str。
   • 会误导后续维护者，增加接口理解成本。

4. 并发一致性风险：_global_notify/_global_end_notify 仅在 initialize() 中赋值

   • 若存在异常生命周期调用（例如初始化失败后仍触发命令），cmd_notify/cmd_end_notify/cmd_status 会访问未定义属性，存在 AttributeError 风险。

---

core/batch.py

1. 类型与实现不一致：results: list[BatchResultItem] = [None] * len(items)

   • 这里实际是 list[BatchResultItem | None]，与注解冲突。
   • 在静态检查和维护时会产生噪音，也容易掩盖“漏填充”问题。

2. API 鲁棒性不足：detect_mode(args, ...) 未对空列表自校验

   • 内部直接 first = args[0]，若调用方未先校验会抛 IndexError。
   • 现在依赖外部调用者前置判断，函数自身防御性不足。

---

core/notifier.py

1. 并发数据竞争风险：失败计数更新未加锁
   • _send_chain() 中直接调用 self._store.increment_failure/reset_failure，未走 store.lock。
   • 与 poller/命令处理并发时可能出现计数丢失、通知状态抖动等一致性问题。

---

core/persistence.py

1. 类型标注不规范（Python 3.10）

   • _MIGRATIONS: dict[int, callable] = {} 使用了内建 callable，这不是类型。
   • 应使用 typing.Callable[...]，否则类型系统不可用，影响可维护性。

2. 数据副作用风险：save() 会原地修改入参 state

   • state["schema_version"] = CURRENT_SCHEMA_VERSION 会修改调用方对象。
   • 若调用方后续复用同一 dict，可能引入隐式状态污染。

---

core/poller.py

1. 无效参数：_compute_transition() 的 new_stream_id 未使用

   • 该参数传入后从未参与逻辑，说明要么设计未落地，要么遗留参数未清理。
   • 容易让人误以为“换流/同状态不同 stream_id”被处理了，实际没有。

2. 性能风险：每轮处理后无条件持久化

   • _process_results() 在 async with self._store.lock 内总是 await self._store.persist()。
   • 即使状态无变化也落盘，监控规模扩大后会造成不必要 I/O 与锁占用。

---

core/store.py

1. 并发模型不统一：存在大量“可变状态方法”未强制锁保护
   • 如 increment_failure/reset_failure/update_status/add_monitor/remove_monitor 可直接修改共享状态。
   • 当前靠“调用方自觉加锁”，但 Notifier 路径已经出现未加锁调用，说明该约束不可靠。
   • 建议至少在文档或接口层统一约束，否则容易出现竞态缺陷。

---

i18n/init.py

1. 健壮性问题：加载语言文件缺少异常处理
   • json.load(fh) 若遇到格式错误会直接抛异常，导致插件整体初始化失败。
   • 对多语言文件这种外部资源，建议最少做单文件降级并记录错误。

---

platforms/youtube.py

1. 限流识别逻辑不一致
   • _resolve_handle() 在 HTML 层识别到 blocked 会抛 RateLimitError；
   • _get_channel_name() 未做同样处理，遇到相同页面阻断仅返回 None。
   • 结果是同平台不同入口的限流行为不一致，会导致误报“频道不存在/校验失败”。

---

代码评审团

人物一：Linus Torvalds（毒舌工程流）
“你这 config or {} 后面又拿 config.get(...)，这就是典型‘我以为我处理了空值’。这类 bug 不是语法问题，是注意力问题。把配置读取统一到一个对象上，别让初始化阶段变成俄罗斯轮盘。”

人物二：Steve Jobs（产品体验导向）
“用户不会关心你内部是 batch、poller 还是 checker。用户只会看到：有时被限流提示正确，有时说频道不存在。youtube 两条校验路径行为不一致，会直接伤害信任感。统一错误语义，就是体验的一部分。”

人物三：Tony Stark（高并发实战派）
“你在 Notifier 里直接改共享状态不加锁，这在低并发像没事，一上量就会开始‘幽灵故障’：计数乱跳、自动禁用时机飘忽。要么把 Store 做成强一致接口（内部自己锁），要么全链路强制调用约定，别混搭。”

Disclaimer: 以上评审内容由 AI 自动生成，所涉及人物形象与现实无关，不代表真实人物观点。如果给出的建议无关痛痒请忽略。

---

🔍 审核摘要

统计信息

• 仓库文件总数: 27 个 Python 文件
• 已选择审核文件: 15 / 27
  已发送至 AI 审核的文件清单

main.py
core/__init__.py
core/batch.py
core/models.py
core/notifier.py
core/persistence.py
core/poller.py
core/store.py
i18n/__init__.py
platforms/__init__.py
platforms/base.py
platforms/bilibili.py
platforms/twitch.py
platforms/youtube.py
tests/__init__.py

注意：由于项目规模或Token限制，本次仅审核了部分优先文件。以上报告内容由 AI 直接生成。

---

此报告由AI自动生成，旨在提供初步反馈和改进建议，不能完全替代人工审核。最终决策以社区维护者的人工审核为准。目前自动审核（仓库地址）处于试验阶段，如遇问题请向维护者反馈。

[astrbot-plugin-copybara]

插件信息已同步到集合仓库。
PR: AstrBotDevs/AstrBot_Plugins_Collection#280
已自动合并 PR #280

该插件已上架。
This plugin is now published.