192 lines
5.7 KiB
Go
192 lines
5.7 KiB
Go
|
package installer
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
"fmt"
|
||
|
|
"log"
|
||
|
|
"os"
|
||
|
|
"path/filepath"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/volcano-tts/tts-api/store"
|
||
|
|
)
|
||
|
|
|
||
|
|
// Mode 表示服务当前的运行模式。
|
||
|
|
// 启动期由 Detect 确定,运行期不变。
|
||
|
|
type Mode int
|
||
|
|
|
||
|
|
const (
|
||
|
|
// ModeSetup 未安装,只放行 /setup + /api/setup/*。
|
||
|
|
ModeSetup Mode = iota
|
||
|
|
// ModeNormal 已安装,全部路由可用。
|
||
|
|
ModeNormal
|
||
|
|
)
|
||
|
|
|
||
|
|
func (m Mode) String() string {
|
||
|
|
switch m {
|
||
|
|
case ModeSetup:
|
||
|
|
return "setup"
|
||
|
|
case ModeNormal:
|
||
|
|
return "normal"
|
||
|
|
}
|
||
|
|
return "unknown"
|
||
|
|
}
|
||
|
|
|
||
|
|
// CurrentMode 是 Detect 确定的运行期模式;供 controller/middleware 双保险使用。
|
||
|
|
// 进程内只有一个二进制实例,所以全局变量是合适的;不必走 DI。
|
||
|
|
var CurrentMode Mode = ModeSetup // 默认 setup,Detect 后会被覆盖
|
||
|
|
|
||
|
|
// SetMode 在 Detect 完成后调用,设置进程级模式。
|
||
|
|
func SetMode(m Mode) { CurrentMode = m }
|
||
|
|
|
||
|
|
// GetMode 返回进程级模式;Controller 双保险用。
|
||
|
|
func GetMode() Mode { return CurrentMode }
|
||
|
|
|
||
|
|
// Result 是 Detect 的完整输出;调用方关心 Mode + 一些诊断信息。
|
||
|
|
type Result struct {
|
||
|
|
Mode Mode
|
||
|
|
DBPath string // 实际打开的 db 路径
|
||
|
|
LockPath string
|
||
|
|
Corrupted bool // 这次启动是否从损坏回退
|
||
|
|
BackupTo string // 损坏回退时备份文件路径
|
||
|
|
}
|
||
|
|
|
||
|
|
// ErrInUse 标识在 Detect 期间发现 db 正在被另一个进程占用;
|
||
|
|
// 这种情况下不应该自动 rename,会破坏另一个进程的运行。
|
||
|
|
// 上层应记录日志并按"装模式"启动,等下次重启再处理。
|
||
|
|
var ErrInUse = errors.New("installer: database is locked by another process")
|
||
|
|
|
||
|
|
// Detect 是启动期的总入口:打开/创建 db、判定 lock、检测损坏并自愈。
|
||
|
|
//
|
||
|
|
// 流程:
|
||
|
|
// 1. Open db(可能新建)
|
||
|
|
// 2. 检查 lock:
|
||
|
|
// - 不存在 → ModeSetup
|
||
|
|
// - 存在 → 跑 IntegrityCheck
|
||
|
|
// - 通过 → ModeNormal
|
||
|
|
// - 不通过 → 备份 db.corrupt-<ts> + 删 lock + ModeSetup(并标记 Corrupted=true)
|
||
|
|
//
|
||
|
|
// 返回的 *store.Store 必须由调用方在进程退出时 Close。
|
||
|
|
func Detect(dbPath string) (*store.Store, Result, error) {
|
||
|
|
if dbPath == "" {
|
||
|
|
return nil, Result{}, fmt.Errorf("installer: db path is empty")
|
||
|
|
}
|
||
|
|
|
||
|
|
res := Result{
|
||
|
|
DBPath: dbPath,
|
||
|
|
LockPath: LockPath(dbPath),
|
||
|
|
}
|
||
|
|
|
||
|
|
s, err := store.Open(dbPath)
|
||
|
|
if err != nil {
|
||
|
|
// 打开失败通常意味着文件损坏;走自愈回退。
|
||
|
|
// 重要:不要区分"不存在"和"损坏"——SQLite 第一次 Open 会自动建空库,
|
||
|
|
// 如果"不存在"能走到这里说明更严重的系统错误,也不该贸然启动。
|
||
|
|
if backup, ok := tryBackupCorrupt(dbPath, err); ok {
|
||
|
|
res.Corrupted = true
|
||
|
|
res.BackupTo = backup
|
||
|
|
log.Printf("[installer] 检测到损坏 db,已备份到 %q,删除 lock,回退到安装模式", backup)
|
||
|
|
} else {
|
||
|
|
return nil, res, fmt.Errorf("installer: open db %q failed: %w", dbPath, err)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// lock 状态判定
|
||
|
|
exists, err := LockExists(dbPath)
|
||
|
|
if err != nil {
|
||
|
|
if s != nil {
|
||
|
|
_ = s.Close()
|
||
|
|
}
|
||
|
|
return nil, res, fmt.Errorf("installer: lock check failed: %w", err)
|
||
|
|
}
|
||
|
|
if !exists {
|
||
|
|
res.Mode = ModeSetup
|
||
|
|
SetMode(ModeSetup)
|
||
|
|
if !res.Corrupted {
|
||
|
|
log.Printf("[installer] 启动模式: 安装模式(无 lock 文件)")
|
||
|
|
}
|
||
|
|
return s, res, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// lock 在,跑完整性检查
|
||
|
|
if s == nil {
|
||
|
|
// 自愈回退已经走完,应该删了 lock;但保险起见再删一次
|
||
|
|
if err := DeleteLock(dbPath); err != nil {
|
||
|
|
return nil, res, fmt.Errorf("installer: delete lock after fallback: %w", err)
|
||
|
|
}
|
||
|
|
res.Mode = ModeSetup
|
||
|
|
SetMode(ModeSetup)
|
||
|
|
return nil, res, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
check, err := s.IntegrityCheck()
|
||
|
|
if err != nil {
|
||
|
|
_ = s.Close()
|
||
|
|
// integrity_check 自身报错,等同损坏,走自愈
|
||
|
|
backup, ok := tryBackupCorrupt(dbPath, err)
|
||
|
|
if !ok {
|
||
|
|
return nil, res, fmt.Errorf("installer: integrity_check failed: %w", err)
|
||
|
|
}
|
||
|
|
_ = DeleteLock(dbPath)
|
||
|
|
res.Corrupted = true
|
||
|
|
res.BackupTo = backup
|
||
|
|
res.Mode = ModeSetup
|
||
|
|
SetMode(ModeSetup)
|
||
|
|
log.Printf("[installer] integrity_check 错误,已备份到 %q,删除 lock,回退到安装模式", backup)
|
||
|
|
return nil, res, nil
|
||
|
|
}
|
||
|
|
if check != "ok" {
|
||
|
|
_ = s.Close()
|
||
|
|
backup, ok := tryBackupCorrupt(dbPath, fmt.Errorf("integrity_check returned: %s", check))
|
||
|
|
if !ok {
|
||
|
|
return nil, res, fmt.Errorf("installer: integrity_check = %q (not ok)", check)
|
||
|
|
}
|
||
|
|
_ = DeleteLock(dbPath)
|
||
|
|
res.Corrupted = true
|
||
|
|
res.BackupTo = backup
|
||
|
|
res.Mode = ModeSetup
|
||
|
|
SetMode(ModeSetup)
|
||
|
|
log.Printf("[installer] 库不完整(integrity_check=%q),已备份到 %q,删除 lock,回退到安装模式", check, backup)
|
||
|
|
return nil, res, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
res.Mode = ModeNormal
|
||
|
|
SetMode(ModeNormal)
|
||
|
|
log.Printf("[installer] 启动模式: 正常模式(lock=%s)", res.LockPath)
|
||
|
|
return s, res, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// tryBackupCorrupt 尝试把损坏的 db 文件 rename 为 .corrupt-<unix-ms>;
|
||
|
|
// 成功返回 (新路径, true),失败 (任何原因) 返回 ("", false)。
|
||
|
|
// 注意:这里不返回 error,因为 "无法备份" 不应阻止回退(可以后续人工排查)。
|
||
|
|
func tryBackupCorrupt(dbPath string, reason error) (string, bool) {
|
||
|
|
if dbPath == "" {
|
||
|
|
return "", false
|
||
|
|
}
|
||
|
|
// 不存在的话没法 rename(也没必要)
|
||
|
|
if _, err := os.Stat(dbPath); err != nil {
|
||
|
|
return "", false
|
||
|
|
}
|
||
|
|
ts := time.Now().UnixMilli()
|
||
|
|
backup := fmt.Sprintf("%s.corrupt-%d", dbPath, ts)
|
||
|
|
if err := os.Rename(dbPath, backup); err != nil {
|
||
|
|
log.Printf("[installer] 备份损坏 db 失败: %v(将直接重建空库)", err)
|
||
|
|
return "", false
|
||
|
|
}
|
||
|
|
log.Printf("[installer] 损坏原因: %v", reason)
|
||
|
|
return backup, true
|
||
|
|
}
|
||
|
|
|
||
|
|
// EnsureDBDir 确保 dbPath 所在目录存在(对首次安装很有用;
|
||
|
|
// 当 dbDir 是新目录时 store.Open 之前需要先 mkdir)。
|
||
|
|
func EnsureDBDir(dbPath string) error {
|
||
|
|
if dbPath == "" {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
dir := filepath.Dir(dbPath)
|
||
|
|
if dir == "" || dir == "." {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
return os.MkdirAll(dir, 0o755)
|
||
|
|
}
|