[Plugin] astrbot_plugin_Lumi-Hub-plugin

[Lumivers]

插件信息

{
  "name": "astrbot_plugin_Lumi-Hub-plugin",
  "display_name": "Lumi-Hub-plugin",
  "desc": "一套独立的私有化 Agent 交互框架，作为 AstrBot 的自定义消息平台与专属 Flutter 客户端通信，内置原生 MCP 执行引擎与 HitL 审批拦截机制。",
  "author": "Lumivers",
  "repo": "https://github.com/Lumivers/Lumi-Hub-plugin",
  "tags": [
    "platform",
    "tool",
    "mcp"
  ],
  "social_link": "https://github.com/Lumivers/Lumi-Hub"
}

插件检查清单

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

[astrpluginreviewer]

🤖 AI代码审核报告 for astrbot_plugin_Lumi-Hub-plugin

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

main.py

1. 日志实现不符合框架要求
   使用了 import logging + logging.getLogger(...)，违反“logger 必须且只能从 astrbot.api 导入”的约束。

2. 数据目录获取方式不规范
   通过 os.path.dirname(...)/data 手工拼接 data_dir（在 LumiHub.initialize 与 LumiHubAdapter.__init__ 中），未使用 StarTools.get_data_dir()。

3. 存在重复导入与可读性问题
   time、uuid 被重复导入；Context 等导入未使用，影响维护性。

4. terminate() 未唤醒 _run() 的等待逻辑，存在退出挂死风险
   _run() 在 await self._shutdown_event.wait() 阻塞，但 terminate() 中未 self._shutdown_event.set()。

5. 全局可变共享状态 _lumi_shared_state 缺乏并发隔离
   在异步多会话场景下共享 mcp_manager/persona_manager，无锁/无作用域隔离，可能出现竞态与跨会话污染。

6. 人格切换为全局状态，存在用户间串扰
   多处直接修改 pm.default_persona（如 _handle_chat_request、_handle_persona_switch），会影响其他用户会话。

7. MCP 配置接口缺少登录鉴权
   _handle_mcp_config_get/_update 未验证 active_sessions，未登录连接也可读取/修改 MCP 配置，属于高风险权限漏洞。

8. 事件完成检测依赖私有内部结构，脆弱且易失效
   直接访问 self._event_queue._queue 与 active_event_registry._events 私有字段，框架内部变动后易崩溃。

9. 后台任务未纳入生命周期管理
   _handle_chat_request 里 asyncio.create_task(wait_for_event_completion()) 未保存引用、未在关闭时取消，可能产生悬挂任务。

10. LumiHubAdapter 内声明了 @filter.llm_tool，结构上不合理
    filter 监听/工具通常由 Star 插件类承载；放在 Platform 子类上，框架可能不会扫描注册，导致“看似存在但不可用”。

11. call_mcp_tool 在 LumiHubAdapter 中实现存在逻辑错误

    • self.mcp_manager 在该类中未初始化。
    • 调用了不存在的方法 self.mcp_manager.call_tool(...)（LumiMCPManager 实际是 execute_tool）。
      结果是该工具路径不可用或必然报错。

12. 同名 LLM 工具 call_mcp_tool 在两个类重复定义
    可能导致注册冲突、覆盖或行为不确定。

13. 历史接口参数缺乏边界控制
    limit/offset 来自客户端未做范围校验，可被滥用导致重查询压力。

14. send_by_session 中将消息再次落库，可能与事件发送链路重复写入
    与 LumiMessageEvent.send/send_streaming 的存储路径可能形成重复记录（需结合框架调用链确认，当前实现有风险）。

---

lumi_event.py

1. 日志实现不符合框架要求
   使用 logging.getLogger，未按要求从 astrbot.api 导入 logger。

2. 网络发送缺乏异常保护
   send() / send_streaming() 多处 await self._ws_server.send_to_client(...) 未做异常捕获，网络抖动可能把异常向上抛出中断消息管道。

3. 流式结束后再发送完整 CHAT_RESPONSE，存在重复语义风险
   已发完 CHAT_STREAM_CHUNK(finished=True) 后再发完整内容，若前端未去重，会重复展示/重复入库。

4. 无效代码片段影响可读性
   _empty_gen 中 return 后 yield 为不可达语句，维护成本高。

---

mcp_manager.py

1. 日志实现不符合框架要求
   使用 logging.getLogger，未按框架要求使用 astrbot.api.logger。

2. _connect_server 使用轮询等待会话建立，存在启动性能瓶颈
   每服务最多轮询 10 秒，且顺序连接，服务多时会显著拉长初始化时间。

3. get_all_tools() 迭代 self.sessions 时存在并发修改风险
   循环内有 await，期间其他任务可能增删 self.sessions，导致运行时异常或漏读。

4. 缺少配置合法性校验
   stdio 分支未校验 command 是否为空；http 分支未校验 url 是否为空，失败路径靠异常兜底，错误反馈滞后。

---

native_tools.py

1. 日志实现不符合框架要求
   使用 logging.getLogger("astrbot")，违反日志导入规范。

2. 文件系统操作缺少沙箱边界，权限过大
   read/write/delete/list 等可操作任意路径，未限制在安全目录内，存在高风险越权读写/删文件问题。

3. 输入参数缺少严格校验
   如 insert_content 对 line_number<=0 自动修正为 0，行为隐式且容易误改文件。

4. 大量 except Exception 吞异常细节
   错误类型被抹平，排障困难，且可能掩盖真实缺陷。

5. search_replace 会强制重写换行风格并追加末尾换行
   可能非预期改变文件格式（尤其对无末尾换行或 CRLF 文件）。

---

ws_server.py

1. 日志实现不符合框架要求
   使用 logging.getLogger，不符合框架限定。

2. broadcast() 串行发送，网络 I/O 易形成队头阻塞
   某个慢连接会拖慢全部广播，异步场景下应并发发送并处理失败连接。

3. stop() 未主动关闭现有 client 连接
   仅关闭 server listener，已连接 websocket 可能残留，导致资源回收不彻底。

4. 响应匹配流程缺少 Future 状态检查
   _dispatch_message 中直接 set_result，若 Future 已完成/取消可能抛 InvalidStateError。

5. 连接断开时未清理关联 pending response
   等待审批的 Future 只能靠超时结束，增加无效等待与内存占用窗口。

---

database/manager.py

1. 日志实现不符合框架要求
   使用 logging.getLogger，不符合框架日志规范。

2. 密码哈希方案不安全
   使用单次 sha256（无盐、无拉伸），抗暴力破解能力弱，属于明显安全风险。

3. Token 以明文长期存储且无过期机制
   get_user_by_token 仅按值查询，无 TTL/吊销策略，凭证泄露后风险持续。

4. 数据库访问为同步 ORM，直接跑在异步消息处理链路中
   在高并发下会阻塞事件循环（虽非网络 I/O，但属于性能与可用性隐患）。

5. 查询参数未做边界限制
   get_messages(limit/offset) 对输入无上限校验，可能触发大分页查询。

---

database/models.py

1. 未使用导入
   import os 未使用，代码整洁度问题。

2. 时间字段时区处理存在语义风险
   SQLite 下 DateTime 时区信息处理不稳定，外层又使用 replace(tzinfo=timezone.utc)，可能把本地时间“伪装成 UTC”。

3. 数据库初始化缺少连接参数策略
   create_engine 使用默认参数，未体现并发访问场景下的连接/线程策略，存在潜在运行时问题（尤其插件并发请求增多时）。

---

代码评审团

人物一：Linus Torvalds（直球毒舌流）
“你这套东西能跑，但在 main.py 里把框架私有结构 _event_queue._queue、active_event_registry._events 直接扒开看，属于‘今天能跑，明天炸给你看’。建议：别做 private-hacking，用官方生命周期钩子或事件完成回调机制。”

人物二：Steve Jobs（产品体验偏执流）
“你把 MCP 配置读写接口暴露给未登录连接，这是‘用户还没进门就能改电闸’。功能再酷也会毁在安全细节上。建议：所有高危消息类型统一走鉴权中间层，不要在各 handler 里零散判断。”

人物三：Geralt of Rivia（猎魔人务实流）
“怪物不只在外面，也在你代码里：sha256 存密码、全路径文件操作、全局 default_persona 串会话。建议：先打三只大怪——强哈希（带盐+拉伸）、文件沙箱、会话级 persona 隔离。先保命，再谈优雅。”

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

---

🔍 审核摘要

统计信息

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

main.py
__init__.py
lumi_event.py
mcp_manager.py
native_tools.py
ws_server.py
database/__init__.py
database/manager.py
database/models.py

---

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

当前仓库：Lumivers/Lumi-Hub-plugin
剩余触发次数：4

[Lumivers]

刚刚改了两个问题，剩下的是插件及消息平台需要的属性，所以没必要改。

[astrbot-plugin-copybara]

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

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