mirror of
https://github.com/zhenxun-org/zhenxun_bot.git
synced 2026-09-28 16:20:56 +08:00
* bugfix:修复内存泄露和信号量饥饿问题 * 修复图片渲染按高度截断问题 * 优化图片渲染速度 * 权限检查去掉无效引用代码 * 添加uv支持 * 🚨 auto fix by pre-commit hooks * bugfix:修改gitignore换行 * bugfix:修复测试没有新生成uv.lock * 修复导入错误 * bugfix:移除重复调用 * 🚨 auto fix by pre-commit hooks * 清理残余poetry引用 * 更新uv安装方式 * 修复阿里云获取问题 * 增加资源下载提示 * 🚨 auto fix by pre-commit hooks * 修改资源下载为流式 * 🚨 auto fix by pre-commit hooks * 提高启动速度 * 移除bot.py支持 * 🚨 auto fix by pre-commit hooks * 优化win脚本逻辑 * 🚨 auto fix by pre-commit hooks * 清理残余无效逻辑 * 代码改进 * 🚨 auto fix by pre-commit hooks * 增加数据库迁移存在性检查 * 🚨 auto fix by pre-commit hooks * chore(test): 添加pytest超时控制和优雅关闭机制 - 在GitHub Actions工作流中添加作业级和步骤级超时限制,防止测试无限期挂起 - 添加pytest-timeout依赖并配置全局超时为120秒 - 在send_queue服务添加关闭钩子,确保worker任务正确取消 - 在priority_manager添加on_shutdown钩子,支持优先级生命周期的关闭阶段 * chore(lint): 禁用超长行的lint警告 * Modify restart logic for Windows platform * 🚨 auto fix by pre-commit hooks * bugfix:修复sys导入问题 * 清理无效结构 * bugfix:修复路径问题 * bugfix:修复shell语法传递给git导致资源获取失败问题 * 优化关闭显示 * bugfix:修复路径问题 * bugfix:增加路径安全 * bugfix:修复orm绕过问题 * 放宽numpy版本限制 * 修改重启方案 * bugfix:修复循环导入 * 优化逻辑 * Enhance disconnect function with error handling Added error handling for disconnect function and imported ConfigurationError. * Implement emergency restart mechanism Added emergency restart mechanism using atexit to ensure process restart even on severe exceptions during shutdown. * 🚨 auto fix by pre-commit hooks * 重启行为归一化 * 修复测试检测问题 * bugfix:修复测试侧类型报错问题 * 引入launcher机制 * 移除重启测试 * 收紧缓存调用路径 * 类型注解收敛 * 优化浏览器回收行为 * 优化浏览器渲染 * bugfix:解决重复关闭浏览器问题 --------- Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com> Co-authored-by: ManyManyTomato <93612024+ATTomatoo@users.noreply.github.com> Co-authored-by: AkashiCoin <l1040186796@gmail.com>
55 lines
1.5 KiB
Python
55 lines
1.5 KiB
Python
from __future__ import annotations
|
|
|
|
import json
|
|
from pathlib import Path
|
|
from typing import Any
|
|
|
|
_RESTART_STATE_FILE = Path() / "data" / ".restart_state.json"
|
|
_LAUNCHER_ACTION_KEY = "launcher_action"
|
|
_ACTION_RESTART = "restart"
|
|
|
|
|
|
def _ensure_state_parent() -> None:
|
|
_RESTART_STATE_FILE.parent.mkdir(parents=True, exist_ok=True)
|
|
|
|
|
|
def read_restart_state() -> dict[str, Any]:
|
|
if not _RESTART_STATE_FILE.exists():
|
|
return {}
|
|
try:
|
|
data = json.loads(_RESTART_STATE_FILE.read_text(encoding="utf-8"))
|
|
except Exception:
|
|
return {}
|
|
return data if isinstance(data, dict) else {}
|
|
|
|
|
|
def write_restart_state(state: dict[str, Any]) -> None:
|
|
if not state:
|
|
if _RESTART_STATE_FILE.exists():
|
|
_RESTART_STATE_FILE.unlink()
|
|
return
|
|
_ensure_state_parent()
|
|
temp_file = _RESTART_STATE_FILE.with_name(f"{_RESTART_STATE_FILE.name}.tmp")
|
|
temp_file.write_text(
|
|
json.dumps(state, ensure_ascii=False, indent=2),
|
|
encoding="utf-8",
|
|
)
|
|
temp_file.replace(_RESTART_STATE_FILE)
|
|
|
|
|
|
def consume_launcher_restart_signal() -> bool:
|
|
state = read_restart_state()
|
|
if state.get(_LAUNCHER_ACTION_KEY) != _ACTION_RESTART:
|
|
return False
|
|
state.pop(_LAUNCHER_ACTION_KEY, None)
|
|
write_restart_state(state)
|
|
return True
|
|
|
|
|
|
def clear_launcher_restart_signal() -> None:
|
|
state = read_restart_state()
|
|
if _LAUNCHER_ACTION_KEY not in state:
|
|
return
|
|
state.pop(_LAUNCHER_ACTION_KEY, None)
|
|
write_restart_state(state)
|