diff --git a/cmd/homed-upgrade/main.go b/cmd/homed-upgrade/main.go index dad9ece1..72c5afc1 100644 --- a/cmd/homed-upgrade/main.go +++ b/cmd/homed-upgrade/main.go @@ -42,20 +42,17 @@ import ( ) // fail 打印错误并以非零退出(CLI 专属;库内部一律返回 error)。 -// upgradeDataDir 推导数据目录(升级确认标记的落点)。 +// upgradeDataDir 推导数据目录(升级确认标记 / 备份的落点)。 // // 与生产一致:内核按 `--data ` 运行,标记必须落在同一个 dataDir 下, -// 否则 update 模块读不到它。推导规则: +// 否则 update 模块读不到它。 // -// ① 环境变量 HOMEAGENT_DATA_DIR(部署方显式指定) -// ② 二进制同级的 ../newqqagent(/usr/local/bin/homed → /home/newqqagent) -// —— 太脆弱,改为最常见的部署形态:/usr/local/bin/homed → /home/newqqagent -// ③ 退回 /home/newqqagent(本仓默认部署路径) +// ★ 三端共用 update.ResolveDataDir(CLI / WebUI / agent 工具), +// 不再在这里写死 /home/newqqagent:硬编码在生产目录迁移后会让标记和备份 +// 落到一个**不存在的路径**,而第 0 层 update 从真实的 --data 读 ⇒ 永远 +// 读不到 ⇒ 升级失败时静默不回滚(2026-10-26 迁移教训)。 func upgradeDataDir(binPath string) string { - if d := strings.TrimSpace(os.Getenv("HOMEAGENT_DATA_DIR")); d != "" { - return d - } - return "/home/newqqagent" + return update.ResolveDataDir(binPath) } func fail(format string, a ...interface{}) { diff --git a/internal/plugins/pluginmgr/kernel_update.go b/internal/plugins/pluginmgr/kernel_update.go index ff9bc1cb..8b3507bc 100644 --- a/internal/plugins/pluginmgr/kernel_update.go +++ b/internal/plugins/pluginmgr/kernel_update.go @@ -98,7 +98,7 @@ func (p *Plugin) kernelUpdateApply(pkgPath string, release bool) (interface{}, e bus = p.sdk.EventBus() } - out, err := update.Apply(root, kernelBinPath(p), newDG, kernelDataDir(p), bus) + out, err := update.Apply(root, kernelBinPath(p), newDG, update.ResolveDataDir(kernelBinPath(p)), bus) if err != nil { return map[string]interface{}{"error": err.Error()}, nil } @@ -140,36 +140,16 @@ func (p *Plugin) kernelUpdateApply(pkgPath string, release bool) (interface{}, e return res, nil } -// kernelDataDir 推导数据目录(升级确认标记的落点)。 +// kernelDataDir 推导数据目录(升级确认标记 / 备份的落点)。 // -// 从 pluginDir 反推:/plugins ⇒ 上一级即 dataDir。 -// 与内核 --data 的值一致,update 模块(第 0 层)才能读到同一个标记。 +// ★ 三端共用 update.ResolveDataDir:CLI、WebUI、agent 工具必须算出**同一个** +// 路径,否则 pending 标记落在哪、第 0 层 update 就从哪读,两边一漂移, +// 升级启动失败时就静默不回滚(本文件此前反推 pluginDir 的做法就是这么 +// 与 webui 侧走散的)。 func kernelDataDir(p *Plugin) string { - // /plugins ⇒ 上一级即 dataDir。 - // - // ★ 只 Dir 一次。此前写成 Dir(Dir(...)),把 /home/newqqagent/plugins - // 算成 /home —— pending 标记落到 /home/kernel-upgrade-pending.json, - // 而第 0 层 update 模块从 ks.DataDir 读 ⇒ **永远读不到标记** ⇒ - // agent 发起的升级一旦启动失败就**不会回滚**(静默失效)。 - // ★ 不再写死生产路径(2026-10-26 迁移教训): - // 硬编码 /home/newqqagent 在目录/用户迁移后会让 pending 标记落到一个 - // **已经不存在的目录**,而第 0 层 update 从 ks.DataDir 读 ⇒ 永远读不到 - // ⇒ agent 发起的升级失败时静默不回滚。 - // - // 优先级:显式环境变量(部署方声明自己在哪)→ 从 pluginDir 反推 → 空。 - // 空表示"不知道",由调用方拒绝执行并报错,而不是猜一个路径。 - if d := os.Getenv(dataDirEnv); d != "" { - return d - } - if p.pluginDir != "" { - return filepath.Dir(p.pluginDir) - } - return "" + return update.ResolveDataDir(kernelBinPath(p)) } -// dataDirEnv 是部署方声明数据目录的环境变量(与 webui 侧同名)。 -const dataDirEnv = "HOMEAGENT_DATA_DIR" - // currentKernelVersion 读本机 homed 自报版本(尽力而为)。 func currentKernelVersion(p *Plugin) *update.BinVersion { v, err := update.ReadBinVersion(kernelBinPath(p)) diff --git a/internal/plugins/webui/kernel_update.go b/internal/plugins/webui/kernel_update.go index 144a2f6a..44e7b40c 100644 --- a/internal/plugins/webui/kernel_update.go +++ b/internal/plugins/webui/kernel_update.go @@ -140,15 +140,12 @@ func currentKernelVersion() *update.BinVersion { return v } -// dataDirOf 推导数据目录(升级确认标记的落点)。 +// dataDirOf 推导数据目录(升级确认标记 / 备份的落点)。 // -// 与内核 `--data` 必须一致,否则第 0 层 update 模块读不到 pending 标记。 -// 优先用环境变量显式指定(部署方知道自己在哪),否则退回本机生产路径。 +// ★ 三端共用 update.ResolveDataDir:pending 标记落在哪,第 0 层 update +// 模块就从哪读。两边一漂移,升级启动失败时就**静默不回滚**。 +// 返回空的情况已不存在(ResolveDataDir 有 exe 同级 data 兜底), +// 但仍不写死任何生产绝对路径:迁移后它指向不存在的目录(静默不回滚)。 func dataDirOf(binPath string) string { - if d := os.Getenv("HOMEAGENT_DATA_DIR"); d != "" { - return d - } - // ★ 不写死生产路径:迁移后它会指向一个不存在的目录, - // 让升级 pending 标记落错地方(静默不回滚)。返回空由调用方报错。 - return "" + return update.ResolveDataDir(binPath) }