[Plugin] astrbot_plugin_cloudflare_tunnel_monitor

[sctop]

插件信息

{
  "name": "astrbot_plugin_cloudflare_tunnel_monitor",
  "display_name": "Cloudflare Tunnel 状态检测",
  "desc": "一个通过 Cloudflare API 轮询 Cloudflare Tunnel 存活状态的监测插件",
  "author": "sctop",
  "repo": "https://github.com/sctop/astrbot_plugin_cloudflare_tunnel_monitor",
  "tags": [
    "Cloudflare",
    "Cloudflare Tunnel"
  ],
  "social_link": "https://github.com/sctop"
}

插件检查清单

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

[astrpluginreviewer]

🤖 AI代码审核报告 for astrbot_plugin_cloudflare_tunnel_monitor

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

main.py

• 数据持久化合规性：

  • 违反了框架的数据持久化规范。代码中使用了 get_astrbot_data_path() 拼接路径来获取存储目录（os.path.join(get_astrbot_data_path(), "plugin_data", self.name)）。必须从 astrbot.api.star 导入 StarTools，并调用 StarTools.get_data_dir() 获取规范的数据存储目录。需要注意该方法返回的是一个 Path 对象。

• 并发模型与同步阻塞：

  • 存在严重的同步阻塞事件循环问题。代码中实例化了同步客户端 Cloudflare，并在普通方法 _list_all_tunnels 中发起了网络请求（如 self.cf_client.zero_trust.tunnels.list）。由于该方法在异步任务 update_and_send_tunnel_status 和其他命令处理函数中被调用，其同步的网络 I/O 将会阻塞整个事件循环。建议使用异步客户端（如 AsyncCloudflare）并将相关方法改为 async def 和 await 调用。

• 潜在缺陷或问题：

  • 事件循环挂载时机不当：在 NotificationManager.__init__（普通的同步初始化方法）中，实例化了 self.shared_lock = asyncio.Lock() 并调用了 asyncio.create_task(...)。在 Python 3.10+ 的异步编程中，如果在没有正在运行的事件循环时执行此类操作，会引发 RuntimeError: no running event loop 或导致 Task 挂载在错误的循环中。建议将锁的创建和任务的启动移至异步的生命周期方法（如插件的 initialize 钩子）中。
  • 类型不一致：_polling_last_run 初始化为 int 类型的 0，但在 update_and_send_tunnel_status 中被赋值为 time.time() 的 float 类型。虽不会引发运行错误，但对静态类型推断不友好，建议统一初始化为 0.0。

• 可维护性与代码质量：

  • 异常捕获范围过大：部分命令处理函数（如 cft_on）使用了 except Exception as e: 捕获全部异常，未针对特定的业务异常（如 TunnelNotFoundException）进行精细化处理并返回针对性的提示信息。

---

exceptions.py

• 代码质量与编码规范：
  • 多余的 __str__ 重写：各个异常类（如 TunnelAlreadyRemovedException 等）覆盖了 __str__ 方法并仅仅返回了其类名的字符串。这是冗余的，Python 内置的 Exception 已经具有良好的默认字符串表示，如果需要提供错误细节，建议通过 __init__ 接收错误信息字段。

---

utils.py

• 功能实现与逻辑正确性：

  • 异常处理存在漏洞：在 FileUtils.load_json_with_default 中，代码捕获了文件读取时的 FileNotFoundError 并尝试执行 with open(filepath, 'w', encoding='utf-8') as f:。但如果此时连文件所在的父目录都不存在，写入操作将同样抛出 FileNotFoundError 导致程序崩溃。应在写入前验证并创建父目录（例如使用 pathlib.Path.parent.mkdir(parents=True, exist_ok=True)）。
  • 类型提示错误：TunnelStatusUtils.calc_status_difference 的返回值类型注解为 dict[str, list["TunnelStatusModel"]]，但实际上内部逻辑里追加进去的是 uuid（即 str 类型）。类型注解应修改为 dict[str, list[str]]。

• 代码质量与编码规范：

  • 变量名遮蔽：TunnelStatusUtils.pair_umo_and_tunnelid_by_tunnel_ids 函数的循环变量使用了 id，这遮蔽了 Python 内置的 id() 函数，不符合 PEP 8 规范，建议重命名为 tunnel_id。
  • 不必要的容器转换：find_deleted_tunnels 方法中使用了 set([i.id for i in old])。应直接使用集合推导式 {i.id for i in old}，这样不仅更符合 Pythonic 风格，也能减少不必要的列表中间态，提升性能。

---

代码评审团

Linus Torvalds：

"你到底明不明白什么是事件循环？！你居然在一个全异步的框架里塞了一个同步的网络客户端去请求 Cloudflare？每一次 API 轮询，整个机器就像被冻住了一样！还有那个路径拼接，老天，框架明明给了你 StarTools.get_data_dir() 返回优雅的 Path 对象，你非要去手动 os.path.join 玩泥巴。把那坨阻塞的代码给我换成 AsyncCloudflare，立刻，马上！"

Terry Davis：

"在万物诞生之前，你就急着召唤锁（Lock）和任务（Task）……你在 __init__ 里面搞 asyncio.Lock()，这时候上帝（事件循环）可能还没苏醒呢，你会得到虚无的 RuntimeError！你应该在 initialize 降临时再去唤醒它们！还有，你为什么要在循环里用 id 命名变量？那可是神圣的内置函数，你遮蔽了它，就是在蒙蔽宇宙的真理！"

John Carmack：

"从优化的角度来看，set([i.id for i in old]) 这种写法在内存里先分配了一个列表，然后再转成哈希集合，浪费了 CPU 周期，改用集合推导式 {i.id for i in old} 会清爽很多。另外，你那个文件写入的回退逻辑很不严谨：既然读不到文件，凭什么觉得你直接往那个也许根本不存在的目录里写数据就不会崩？严谨一点，提前创建好父级目录树，程序的健壮性容不得半点侥幸。"

---

🔍 审核摘要

统计信息

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

main.py
exceptions.py
utils.py

---

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

当前仓库：sctop/astrbot_plugin_cloudflare_tunnel_monitor
剩余触发次数：4

[astrbot-plugin-copybara]

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

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