admin
563c9515d9
Major refactor of backup and storage paths: - Per-drive restic repos at <drive>/backups/primary/restic/ - Per-app DB dumps at <drive>/backups/primary/<app>/db-dumps/ - Remove global BackupDir, DBDumpDir, ResticRepo config fields - Add SystemDataPath config (fallback for apps without HDD) - New backup/paths.go with pure path computation helpers - Add GetStackHDDPath to StackDataProvider interface - Restic methods now accept repoPath as parameter - Cross-drive backup uses new secondary path structure - Rename storage/ to appdata/ in scripts and compose templates - Update protected HDD paths (storage → appdata + backups) - Simplify backup UI (remove global path displays) Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
98 lines
2.9 KiB
Go
98 lines
2.9 KiB
Go
package backup
|
|
|
|
import (
|
|
"fmt"
|
|
"path/filepath"
|
|
"regexp"
|
|
)
|
|
|
|
// snapshotIDRe validates restic snapshot IDs: 8-64 lowercase hex characters.
|
|
var snapshotIDRe = regexp.MustCompile(`^[0-9a-f]{8,64}$`)
|
|
|
|
// RestoreApp restores an app from a restic snapshot.
|
|
// All apps get config + DB dump restored. Apps with HDD data also get user data restored.
|
|
func (m *Manager) RestoreApp(stackName, snapshotID string) error {
|
|
if m.stackProvider == nil {
|
|
return fmt.Errorf("stack provider not configured")
|
|
}
|
|
|
|
// Validate snapshot ID format
|
|
if !snapshotIDRe.MatchString(snapshotID) {
|
|
return fmt.Errorf("invalid snapshot ID: must be 8-64 lowercase hex characters")
|
|
}
|
|
|
|
// Prevent concurrent operations
|
|
m.mu.Lock()
|
|
if m.running {
|
|
m.mu.Unlock()
|
|
return fmt.Errorf("backup or restore already in progress")
|
|
}
|
|
m.running = true
|
|
m.mu.Unlock()
|
|
defer func() {
|
|
m.mu.Lock()
|
|
m.running = false
|
|
m.mu.Unlock()
|
|
}()
|
|
|
|
// Determine what to restore
|
|
hddMounts := m.stackProvider.GetStackHDDMounts(stackName)
|
|
hasHDD := len(hddMounts) > 0
|
|
|
|
// Build list of paths to restore from the snapshot
|
|
var restorePaths []string
|
|
|
|
// Always restore the stack's config dir (compose + app.yaml + .felhom.yml)
|
|
composePath, ok := m.stackProvider.GetStackComposePath(stackName)
|
|
if ok {
|
|
stackDir := filepath.Dir(composePath)
|
|
restorePaths = append(restorePaths, stackDir)
|
|
}
|
|
|
|
// Restore DB dump files for this stack (per-drive path)
|
|
drivePath := m.GetAppDrivePath(stackName)
|
|
dumpDir := AppDBDumpPath(drivePath, stackName)
|
|
restorePaths = append(restorePaths, dumpDir)
|
|
|
|
// Restore HDD data (always included for apps that have it — backup is mandatory)
|
|
if hasHDD {
|
|
restorePaths = append(restorePaths, hddMounts...)
|
|
}
|
|
|
|
if len(restorePaths) == 0 {
|
|
return fmt.Errorf("no restorable paths found for %s", stackName)
|
|
}
|
|
|
|
// Use the app's primary restic repo
|
|
repoPath := PrimaryResticRepoPath(drivePath)
|
|
|
|
m.logger.Printf("[WARN] RESTORE starting: stack=%s, snapshot=%s, repo=%s, paths=%v, hasHDD=%v",
|
|
stackName, snapshotID, repoPath, restorePaths, hasHDD)
|
|
|
|
// Stop the app before restore
|
|
if err := m.stackProvider.StopStack(stackName); err != nil {
|
|
m.logger.Printf("[WARN] RESTORE could not stop %s: %v (proceeding anyway)", stackName, err)
|
|
}
|
|
|
|
// Execute restore via restic
|
|
if err := m.restic.RestoreAppData(repoPath, snapshotID, restorePaths); err != nil {
|
|
m.logger.Printf("[ERROR] RESTORE failed for %s: %v", stackName, err)
|
|
if startErr := m.stackProvider.StartStack(stackName); startErr != nil {
|
|
m.logger.Printf("[WARN] RESTORE could not restart %s after failure: %v", stackName, startErr)
|
|
}
|
|
return err
|
|
}
|
|
|
|
// Restart the app
|
|
if err := m.stackProvider.StartStack(stackName); err != nil {
|
|
m.logger.Printf("[WARN] RESTORE could not restart %s after restore: %v", stackName, err)
|
|
}
|
|
|
|
restoreType := "config+DB"
|
|
if hasHDD {
|
|
restoreType = "full (config+DB+userdata)"
|
|
}
|
|
m.logger.Printf("[INFO] RESTORE completed: stack=%s, snapshot=%s, type=%s", stackName, snapshotID, restoreType)
|
|
return nil
|
|
}
|