[Plugin] astrbot_plugin_topic_starter

[exynos967]

插件信息

{
  "name": "astrbot_plugin_topic_starter",
  "display_name": "topic_starter",
  "desc": "主动话题发起、会话跟踪、可配置调度",
  "author": "薄暝",
  "repo": "https://github.com/exynos967/astrbot_plugin_topic_starter",
  "tags": [
    "话题",
    "主动发言"
  ]
}

插件检查清单

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

[astrpluginreviewer]

🤖 AI代码审核报告 for astrbot_plugin_topic_starter

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

main.py

• 潜在缺陷或问题：
  1. 过时的 asyncio API：在 _spawn_scheduler_task 方法中使用了 asyncio.get_event_loop()。在 Python 3.10 中，如果在没有运行的事件循环时调用此方法，会触发 DeprecationWarning，且该行为在未来版本中不可预期。由于插件的 __init__ 是同步的，建议改用框架支持的异步生命周期钩子（如挂载事件）来启动任务，并仅使用 asyncio.get_running_loop()。
  2. 异常捕获缺乏退避（Backoff）机制：在 _scheduler_loop 循环中，裸 except Exception as exc 捕获异常后直接进入下一轮循环的等待。如果因为配置或环境问题导致内部引发非异步等待的即时错误，极可能演变成死循环，导致 CPU 占用率飙升并刷爆日志。建议在异常处理分支中加入类似 await asyncio.sleep(5) 的保护性休眠。

topic_starter/kv_store.py

• 安全漏洞与最佳实践 (并发模型)：
  1. 数据竞争与更新丢失 (Race Condition)：高度并发危险！_track_messages 会在每次接收到消息时触发，调用 touch_user_message 和 append_message。这两个方法都采用了“读-改-写”模式（读取整个巨大的 Bucket 字典，修改后原样写回）。由于此过程没有使用任何异步锁（如 asyncio.Lock），高并发聊天时，多个协程会同时拿到旧状态覆盖写入，必然导致消息记录和触发时间戳大面积丢失。
• 潜在缺陷或问题：
  1. 严重的 O(N) 性能瓶颈：使用了大杂烩模式将所有会话和消息聚合在单一的 KV Key 下（如 _MESSAGE_KEY 存储了所有人的聊天队列）。每次单点更新一小条信息，都会对包含整个系统聊天记录的巨大 Dict 进行序列化和反序列化操作。随着消息量增多，这不仅大量消耗内存，还会引发严重的系统延迟。建议细化 KV 的键空间设计，例如按目标切分：messages:{unified_msg_origin}。

topic_starter/models.py

• 可维护性与可读性：
  1. 存在死代码 (Dead Code)：定义了 SendCandidate 这个数据类，但从始至终在整个项目代码中均未被引用和使用过，建议移除以降低认知负担和维护成本。

topic_starter/config.py

• 代码质量与编码规范：
  1. 类型检查不够严谨：在 _normalize_topic_lines 中，isinstance(raw, list) 忽略了 tuple 的可能性，尽管在常规配置反序列化中表现为 list，但使用 isinstance(raw, (list, tuple)) 会更加稳健。
     （未发现其他严重逻辑或规范缺陷）

topic_starter/services.py

• 代码质量与编码规范：
  1. 浮点数比较的潜在不确定性：在 InitiationDecisionEngine 中使用 random_value >= settings.trigger_probability 没有任何问题，但在 pick_topic 进行权重随机选择时：pick <= acc。浮点数的累加在极个别情况下可能由于精度问题，造成边缘分布的细微偏差。但在目前的业务场景下逻辑可行，算作可以接受的代码结构。
     （未发现其余违规问题）

topic_starter/init.py

• 审查未发现明显违规或严重问题。文件导出定义清晰。

---

代码评审团

Linus Torvalds：（毫不客气地指着屏幕）

“你在开玩笑吗？看看 kv_store.py 里的那个读-改-写逻辑，简直是个灾难！每次有消息进来，你都要把整个系统的聊天记录都拉进内存，改一个字段再慢吞吞地全量塞回去？在并发环境下，这种没有锁的全局状态更新会把你的数据弄得千疮百孔，数据覆盖得比你的借口还快！赶紧把你的键空间（Key-Space）细化一下，不要像个没上过数据结构基础课的业余玩家一样写代码！”

鲁迅：（点起一支烟，目光深邃）

“我向来是不惮以最坏的恶意，来推测异步并发的。然而我还不料，也不信竟会无锁地去覆写全局状态。这代码表面上看似祥和，翻开底层，字缝里歪歪斜斜地全写满了‘更新丢失’四个字。那 models.py 里冗余的 SendCandidate 数据类，就像孔乙己那件脱不下的长衫，虽然穿着，却毫无用处，平白惹人发笑，尽早脱了吧。”

史蒂夫·乔布斯：（双手合十，神情专注而挑剔）

“我们要的是极致的运行艺术，但你看看 main.py 里对 asyncio.get_event_loop() 的处理！它不仅会在 Python 3.10 里抛出丑陋的 DeprecationWarning，还彻底破坏了代码的优雅感。你应该让它自然地在现代的异步上下文中运行，而不是用陈旧的、将就的方案来糊弄用户体验。伟大的产品决不能容忍这样不纯粹的基础架构！”

---

🔍 审核摘要

统计信息

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

main.py
topic_starter/__init__.py
topic_starter/config.py
topic_starter/kv_store.py
topic_starter/models.py
topic_starter/services.py

---

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

[astrbot-plugin-copybara]

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

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