Compare commits
1 Commits
fix/ctime-
...
c76a357570
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c76a357570 |
33
README.md
33
README.md
@@ -150,7 +150,7 @@ passphrase is needed or stored locally.
|
|||||||
vaultik [--config <path>] snapshot create [snapshot-names...] [--cron] [--daemon] [--prune]
|
vaultik [--config <path>] snapshot create [snapshot-names...] [--cron] [--daemon] [--prune]
|
||||||
vaultik [--config <path>] snapshot list [--json]
|
vaultik [--config <path>] snapshot list [--json]
|
||||||
vaultik [--config <path>] snapshot verify <snapshot-id> [--deep]
|
vaultik [--config <path>] snapshot verify <snapshot-id> [--deep]
|
||||||
vaultik [--config <path>] snapshot purge [--keep-latest | --older-than <duration>] [--force]
|
vaultik [--config <path>] snapshot purge [--keep-latest | --older-than <duration>] [--name <name>] [--force]
|
||||||
vaultik [--config <path>] snapshot remove <snapshot-id> [--dry-run] [--force]
|
vaultik [--config <path>] snapshot remove <snapshot-id> [--dry-run] [--force]
|
||||||
vaultik [--config <path>] snapshot prune
|
vaultik [--config <path>] snapshot prune
|
||||||
vaultik [--config <path>] restore <snapshot-id> <target-dir> [paths...]
|
vaultik [--config <path>] restore <snapshot-id> <target-dir> [paths...]
|
||||||
@@ -180,8 +180,9 @@ vaultik [--config <path>] store info
|
|||||||
* `--deep`: Download and verify blob contents (not just existence)
|
* `--deep`: Download and verify blob contents (not just existence)
|
||||||
|
|
||||||
**snapshot purge**: Remove old snapshots based on criteria
|
**snapshot purge**: Remove old snapshots based on criteria
|
||||||
* `--keep-latest`: Keep only the most recent snapshot
|
* `--keep-latest`: Keep the most recent snapshot per snapshot name
|
||||||
* `--older-than`: Remove snapshots older than duration (e.g., 30d, 6mo, 1y)
|
* `--older-than`: Remove snapshots older than duration (e.g., 30d, 6mo, 1y)
|
||||||
|
* `--name`: Filter purge to a specific snapshot name
|
||||||
* `--force`: Skip confirmation prompt
|
* `--force`: Skip confirmation prompt
|
||||||
|
|
||||||
**snapshot remove**: Remove a specific snapshot
|
**snapshot remove**: Remove a specific snapshot
|
||||||
@@ -194,9 +195,8 @@ vaultik [--config <path>] store info
|
|||||||
* Requires `VAULTIK_AGE_SECRET_KEY` environment variable with age private key
|
* Requires `VAULTIK_AGE_SECRET_KEY` environment variable with age private key
|
||||||
* Optional path arguments to restore specific files/directories (default: all)
|
* Optional path arguments to restore specific files/directories (default: all)
|
||||||
* Downloads and decrypts metadata, fetches required blobs, reconstructs files
|
* Downloads and decrypts metadata, fetches required blobs, reconstructs files
|
||||||
* Preserves file permissions, mtime, and ownership (ownership requires root)
|
* Preserves file permissions, timestamps, and ownership (ownership requires root)
|
||||||
* Handles symlinks and directories
|
* Handles symlinks and directories
|
||||||
* Note: ctime cannot be restored (see [platform notes](#platform-specific-ctime-semantics))
|
|
||||||
|
|
||||||
**prune**: Remove unreferenced blobs from remote storage
|
**prune**: Remove unreferenced blobs from remote storage
|
||||||
* Scans all snapshots for referenced blobs
|
* Scans all snapshots for referenced blobs
|
||||||
@@ -248,14 +248,11 @@ Snapshot IDs follow the format `<hostname>_<snapshot-name>_<timestamp>` (e.g., `
|
|||||||
CREATE TABLE files (
|
CREATE TABLE files (
|
||||||
id TEXT PRIMARY KEY,
|
id TEXT PRIMARY KEY,
|
||||||
path TEXT NOT NULL UNIQUE,
|
path TEXT NOT NULL UNIQUE,
|
||||||
source_path TEXT NOT NULL DEFAULT '',
|
|
||||||
mtime INTEGER NOT NULL,
|
mtime INTEGER NOT NULL,
|
||||||
ctime INTEGER NOT NULL,
|
|
||||||
size INTEGER NOT NULL,
|
size INTEGER NOT NULL,
|
||||||
mode INTEGER NOT NULL,
|
mode INTEGER NOT NULL,
|
||||||
uid INTEGER NOT NULL,
|
uid INTEGER NOT NULL,
|
||||||
gid INTEGER NOT NULL,
|
gid INTEGER NOT NULL
|
||||||
link_target TEXT
|
|
||||||
);
|
);
|
||||||
|
|
||||||
CREATE TABLE file_chunks (
|
CREATE TABLE file_chunks (
|
||||||
@@ -343,25 +340,7 @@ CREATE TABLE snapshot_blobs (
|
|||||||
1. For each file, get ordered chunk list from file_chunks
|
1. For each file, get ordered chunk list from file_chunks
|
||||||
1. Download required blobs, decrypt, decompress
|
1. Download required blobs, decrypt, decompress
|
||||||
1. Extract chunks and reconstruct files
|
1. Extract chunks and reconstruct files
|
||||||
1. Restore permissions, mtime, uid/gid (ctime cannot be restored — see platform notes above)
|
1. Restore permissions, mtime, uid/gid
|
||||||
|
|
||||||
### platform-specific ctime semantics
|
|
||||||
|
|
||||||
The `ctime` field in the files table stores a platform-dependent timestamp:
|
|
||||||
|
|
||||||
* **macOS (Darwin)**: `ctime` is the file's **birth time** — when the file was
|
|
||||||
first created on disk. This value never changes after file creation, even if
|
|
||||||
the file's content or metadata is modified.
|
|
||||||
|
|
||||||
* **Linux**: `ctime` is the **inode change time** — the last time the file's
|
|
||||||
metadata (permissions, ownership, link count, etc.) was modified. This is NOT
|
|
||||||
the file creation time. Linux did not expose birth time (via `statx(2)`) until
|
|
||||||
kernel 4.11, and Go's `syscall` package does not yet surface it.
|
|
||||||
|
|
||||||
**Restore limitation**: `ctime` cannot be restored on either platform. On Linux,
|
|
||||||
the kernel manages the inode change time and userspace cannot set it. On macOS,
|
|
||||||
there is no standard POSIX API to set birth time. The `ctime` value is preserved
|
|
||||||
in the snapshot database for informational/forensic purposes only.
|
|
||||||
|
|
||||||
#### prune
|
#### prune
|
||||||
|
|
||||||
|
|||||||
@@ -11,16 +11,9 @@ import (
|
|||||||
"go.uber.org/fx"
|
"go.uber.org/fx"
|
||||||
)
|
)
|
||||||
|
|
||||||
// PurgeOptions contains options for the purge command
|
|
||||||
type PurgeOptions struct {
|
|
||||||
KeepLatest bool
|
|
||||||
OlderThan string
|
|
||||||
Force bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// NewPurgeCommand creates the purge command
|
// NewPurgeCommand creates the purge command
|
||||||
func NewPurgeCommand() *cobra.Command {
|
func NewPurgeCommand() *cobra.Command {
|
||||||
opts := &PurgeOptions{}
|
opts := &vaultik.SnapshotPurgeOptions{}
|
||||||
|
|
||||||
cmd := &cobra.Command{
|
cmd := &cobra.Command{
|
||||||
Use: "purge",
|
Use: "purge",
|
||||||
@@ -28,8 +21,15 @@ func NewPurgeCommand() *cobra.Command {
|
|||||||
Long: `Removes snapshots based on age or count criteria.
|
Long: `Removes snapshots based on age or count criteria.
|
||||||
|
|
||||||
This command allows you to:
|
This command allows you to:
|
||||||
- Keep only the latest snapshot (--keep-latest)
|
- Keep only the latest snapshot per name (--keep-latest)
|
||||||
- Remove snapshots older than a specific duration (--older-than)
|
- Remove snapshots older than a specific duration (--older-than)
|
||||||
|
- Filter to a specific snapshot name (--name)
|
||||||
|
|
||||||
|
When --keep-latest is used, retention is applied per snapshot name. For example,
|
||||||
|
if you have snapshots named "home" and "system", --keep-latest keeps the most
|
||||||
|
recent of each.
|
||||||
|
|
||||||
|
Use --name to restrict the purge to a single snapshot name.
|
||||||
|
|
||||||
Config is located at /etc/vaultik/config.yml by default, but can be overridden by
|
Config is located at /etc/vaultik/config.yml by default, but can be overridden by
|
||||||
specifying a path using --config or by setting VAULTIK_CONFIG to a path.`,
|
specifying a path using --config or by setting VAULTIK_CONFIG to a path.`,
|
||||||
@@ -66,7 +66,7 @@ specifying a path using --config or by setting VAULTIK_CONFIG to a path.`,
|
|||||||
// Start the purge operation in a goroutine
|
// Start the purge operation in a goroutine
|
||||||
go func() {
|
go func() {
|
||||||
// Run the purge operation
|
// Run the purge operation
|
||||||
if err := v.PurgeSnapshots(opts.KeepLatest, opts.OlderThan, opts.Force); err != nil {
|
if err := v.PurgeSnapshotsWithOptions(opts); err != nil {
|
||||||
if err != context.Canceled {
|
if err != context.Canceled {
|
||||||
log.Error("Purge operation failed", "error", err)
|
log.Error("Purge operation failed", "error", err)
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
@@ -92,9 +92,10 @@ specifying a path using --config or by setting VAULTIK_CONFIG to a path.`,
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
cmd.Flags().BoolVar(&opts.KeepLatest, "keep-latest", false, "Keep only the latest snapshot")
|
cmd.Flags().BoolVar(&opts.KeepLatest, "keep-latest", false, "Keep only the latest snapshot per name")
|
||||||
cmd.Flags().StringVar(&opts.OlderThan, "older-than", "", "Remove snapshots older than duration (e.g. 30d, 6m, 1y)")
|
cmd.Flags().StringVar(&opts.OlderThan, "older-than", "", "Remove snapshots older than duration (e.g. 30d, 6m, 1y)")
|
||||||
cmd.Flags().BoolVar(&opts.Force, "force", false, "Skip confirmation prompts")
|
cmd.Flags().BoolVar(&opts.Force, "force", false, "Skip confirmation prompts")
|
||||||
|
cmd.Flags().StringVar(&opts.Name, "name", "", "Filter purge to a specific snapshot name")
|
||||||
|
|
||||||
return cmd
|
return cmd
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -167,21 +167,25 @@ func newSnapshotListCommand() *cobra.Command {
|
|||||||
|
|
||||||
// newSnapshotPurgeCommand creates the 'snapshot purge' subcommand
|
// newSnapshotPurgeCommand creates the 'snapshot purge' subcommand
|
||||||
func newSnapshotPurgeCommand() *cobra.Command {
|
func newSnapshotPurgeCommand() *cobra.Command {
|
||||||
var keepLatest bool
|
opts := &vaultik.SnapshotPurgeOptions{}
|
||||||
var olderThan string
|
|
||||||
var force bool
|
|
||||||
|
|
||||||
cmd := &cobra.Command{
|
cmd := &cobra.Command{
|
||||||
Use: "purge",
|
Use: "purge",
|
||||||
Short: "Purge old snapshots",
|
Short: "Purge old snapshots",
|
||||||
Long: "Removes snapshots based on age or count criteria",
|
Long: `Removes snapshots based on age or count criteria.
|
||||||
|
|
||||||
|
When --keep-latest is used, retention is applied per snapshot name. For example,
|
||||||
|
if you have snapshots named "home" and "system", --keep-latest keeps the most
|
||||||
|
recent of each.
|
||||||
|
|
||||||
|
Use --name to restrict the purge to a single snapshot name.`,
|
||||||
Args: cobra.NoArgs,
|
Args: cobra.NoArgs,
|
||||||
RunE: func(cmd *cobra.Command, args []string) error {
|
RunE: func(cmd *cobra.Command, args []string) error {
|
||||||
// Validate flags
|
// Validate flags
|
||||||
if !keepLatest && olderThan == "" {
|
if !opts.KeepLatest && opts.OlderThan == "" {
|
||||||
return fmt.Errorf("must specify either --keep-latest or --older-than")
|
return fmt.Errorf("must specify either --keep-latest or --older-than")
|
||||||
}
|
}
|
||||||
if keepLatest && olderThan != "" {
|
if opts.KeepLatest && opts.OlderThan != "" {
|
||||||
return fmt.Errorf("cannot specify both --keep-latest and --older-than")
|
return fmt.Errorf("cannot specify both --keep-latest and --older-than")
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -205,7 +209,7 @@ func newSnapshotPurgeCommand() *cobra.Command {
|
|||||||
lc.Append(fx.Hook{
|
lc.Append(fx.Hook{
|
||||||
OnStart: func(ctx context.Context) error {
|
OnStart: func(ctx context.Context) error {
|
||||||
go func() {
|
go func() {
|
||||||
if err := v.PurgeSnapshots(keepLatest, olderThan, force); err != nil {
|
if err := v.PurgeSnapshotsWithOptions(opts); err != nil {
|
||||||
if err != context.Canceled {
|
if err != context.Canceled {
|
||||||
log.Error("Failed to purge snapshots", "error", err)
|
log.Error("Failed to purge snapshots", "error", err)
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
@@ -228,9 +232,10 @@ func newSnapshotPurgeCommand() *cobra.Command {
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
cmd.Flags().BoolVar(&keepLatest, "keep-latest", false, "Keep only the latest snapshot")
|
cmd.Flags().BoolVar(&opts.KeepLatest, "keep-latest", false, "Keep only the latest snapshot per name")
|
||||||
cmd.Flags().StringVar(&olderThan, "older-than", "", "Remove snapshots older than duration (e.g., 30d, 6m, 1y)")
|
cmd.Flags().StringVar(&opts.OlderThan, "older-than", "", "Remove snapshots older than duration (e.g., 30d, 6m, 1y)")
|
||||||
cmd.Flags().BoolVar(&force, "force", false, "Skip confirmation prompt")
|
cmd.Flags().BoolVar(&opts.Force, "force", false, "Skip confirmation prompt")
|
||||||
|
cmd.Flags().StringVar(&opts.Name, "name", "", "Filter purge to a specific snapshot name")
|
||||||
|
|
||||||
return cmd
|
return cmd
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -16,8 +16,8 @@ type File struct {
|
|||||||
ID types.FileID // UUID primary key
|
ID types.FileID // UUID primary key
|
||||||
Path types.FilePath // Absolute path of the file
|
Path types.FilePath // Absolute path of the file
|
||||||
SourcePath types.SourcePath // The source directory this file came from (for restore path stripping)
|
SourcePath types.SourcePath // The source directory this file came from (for restore path stripping)
|
||||||
MTime time.Time // Last modification time
|
MTime time.Time
|
||||||
CTime time.Time // Creation/change time (platform-specific: birth time on macOS, inode change time on Linux)
|
CTime time.Time
|
||||||
Size int64
|
Size int64
|
||||||
Mode uint32
|
Mode uint32
|
||||||
UID uint32
|
UID uint32
|
||||||
|
|||||||
@@ -345,7 +345,7 @@ func (b *BackupEngine) Backup(ctx context.Context, fsys fs.FS, root string) (str
|
|||||||
Size: info.Size(),
|
Size: info.Size(),
|
||||||
Mode: uint32(info.Mode()),
|
Mode: uint32(info.Mode()),
|
||||||
MTime: info.ModTime(),
|
MTime: info.ModTime(),
|
||||||
CTime: fileCTime(info), // platform-specific: birth time on macOS, inode change time on Linux
|
CTime: info.ModTime(), // Use mtime as ctime for test
|
||||||
UID: 1000, // Default UID for test
|
UID: 1000, // Default UID for test
|
||||||
GID: 1000, // Default GID for test
|
GID: 1000, // Default GID for test
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,26 +0,0 @@
|
|||||||
package snapshot
|
|
||||||
|
|
||||||
import (
|
|
||||||
"os"
|
|
||||||
"syscall"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
// fileCTime returns the file creation time (birth time) on macOS.
|
|
||||||
//
|
|
||||||
// On macOS/Darwin, "ctime" refers to the file's birth time (when the file
|
|
||||||
// was first created on disk). This is stored in the Birthtimespec field of
|
|
||||||
// the syscall.Stat_t structure.
|
|
||||||
//
|
|
||||||
// This differs from Linux where "ctime" means inode change time (the last
|
|
||||||
// time file metadata was modified). See ctime_linux.go for details.
|
|
||||||
//
|
|
||||||
// If the underlying stat information is unavailable (e.g. when using a
|
|
||||||
// virtual filesystem like afero.MemMapFs), this falls back to mtime.
|
|
||||||
func fileCTime(info os.FileInfo) time.Time {
|
|
||||||
stat, ok := info.Sys().(*syscall.Stat_t)
|
|
||||||
if !ok {
|
|
||||||
return info.ModTime()
|
|
||||||
}
|
|
||||||
return time.Unix(stat.Birthtimespec.Sec, stat.Birthtimespec.Nsec).UTC()
|
|
||||||
}
|
|
||||||
@@ -1,28 +0,0 @@
|
|||||||
package snapshot
|
|
||||||
|
|
||||||
import (
|
|
||||||
"os"
|
|
||||||
"syscall"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
// fileCTime returns the inode change time on Linux.
|
|
||||||
//
|
|
||||||
// On Linux, "ctime" refers to the inode change time — the last time the
|
|
||||||
// file's metadata (permissions, ownership, link count, etc.) was modified.
|
|
||||||
// This is NOT the file creation time; Linux did not expose birth time until
|
|
||||||
// the statx(2) syscall was added in kernel 4.11, and Go's syscall package
|
|
||||||
// does not yet surface it.
|
|
||||||
//
|
|
||||||
// This differs from macOS/Darwin where "ctime" means birth time (file
|
|
||||||
// creation time). See ctime_darwin.go for details.
|
|
||||||
//
|
|
||||||
// If the underlying stat information is unavailable (e.g. when using a
|
|
||||||
// virtual filesystem like afero.MemMapFs), this falls back to mtime.
|
|
||||||
func fileCTime(info os.FileInfo) time.Time {
|
|
||||||
stat, ok := info.Sys().(*syscall.Stat_t)
|
|
||||||
if !ok {
|
|
||||||
return info.ModTime()
|
|
||||||
}
|
|
||||||
return time.Unix(stat.Ctim.Sec, stat.Ctim.Nsec).UTC()
|
|
||||||
}
|
|
||||||
@@ -1,133 +0,0 @@
|
|||||||
package snapshot
|
|
||||||
|
|
||||||
import (
|
|
||||||
"os"
|
|
||||||
"path/filepath"
|
|
||||||
"testing"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestFileCTime_RealFile(t *testing.T) {
|
|
||||||
// Create a temporary file
|
|
||||||
dir := t.TempDir()
|
|
||||||
path := filepath.Join(dir, "testfile.txt")
|
|
||||||
|
|
||||||
if err := os.WriteFile(path, []byte("hello"), 0644); err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
info, err := os.Stat(path)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
ctime := fileCTime(info)
|
|
||||||
|
|
||||||
// ctime should be a valid time (not zero)
|
|
||||||
if ctime.IsZero() {
|
|
||||||
t.Fatal("fileCTime returned zero time")
|
|
||||||
}
|
|
||||||
|
|
||||||
// ctime should be close to now (within a few seconds)
|
|
||||||
diff := time.Since(ctime)
|
|
||||||
if diff < 0 || diff > 5*time.Second {
|
|
||||||
t.Fatalf("fileCTime returned unexpected time: %v (diff from now: %v)", ctime, diff)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ctime should not equal mtime exactly in all cases, but for a freshly
|
|
||||||
// created file they should be very close
|
|
||||||
mtime := info.ModTime()
|
|
||||||
ctimeMtimeDiff := ctime.Sub(mtime)
|
|
||||||
if ctimeMtimeDiff < 0 {
|
|
||||||
ctimeMtimeDiff = -ctimeMtimeDiff
|
|
||||||
}
|
|
||||||
// For a freshly created file, ctime and mtime should be within 1 second
|
|
||||||
if ctimeMtimeDiff > time.Second {
|
|
||||||
t.Fatalf("ctime and mtime differ by too much for a new file: ctime=%v, mtime=%v, diff=%v",
|
|
||||||
ctime, mtime, ctimeMtimeDiff)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFileCTime_AfterMtimeChange(t *testing.T) {
|
|
||||||
// Create a temporary file
|
|
||||||
dir := t.TempDir()
|
|
||||||
path := filepath.Join(dir, "testfile.txt")
|
|
||||||
|
|
||||||
if err := os.WriteFile(path, []byte("hello"), 0644); err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get initial ctime
|
|
||||||
info1, err := os.Stat(path)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
ctime1 := fileCTime(info1)
|
|
||||||
|
|
||||||
// Change mtime to a time in the past
|
|
||||||
pastTime := time.Date(2020, 1, 1, 0, 0, 0, 0, time.UTC)
|
|
||||||
if err := os.Chtimes(path, pastTime, pastTime); err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get new stats
|
|
||||||
info2, err := os.Stat(path)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
ctime2 := fileCTime(info2)
|
|
||||||
mtime2 := info2.ModTime()
|
|
||||||
|
|
||||||
// mtime should now be in the past
|
|
||||||
if mtime2.Year() != 2020 {
|
|
||||||
t.Fatalf("mtime not set correctly: %v", mtime2)
|
|
||||||
}
|
|
||||||
|
|
||||||
// On macOS: ctime (birth time) should remain unchanged since birth time
|
|
||||||
// doesn't change when mtime is updated.
|
|
||||||
// On Linux: ctime (inode change time) will be updated to ~now because
|
|
||||||
// changing mtime is a metadata change.
|
|
||||||
// Either way, ctime should NOT equal the past mtime we just set.
|
|
||||||
if ctime2.Equal(pastTime) {
|
|
||||||
t.Fatal("ctime should not equal the artificially set past mtime")
|
|
||||||
}
|
|
||||||
|
|
||||||
// ctime should still be a recent time (the original creation time or
|
|
||||||
// the metadata change time, depending on platform)
|
|
||||||
_ = ctime1 // used for reference; both platforms will have a recent ctime2
|
|
||||||
if time.Since(ctime2) > 10*time.Second {
|
|
||||||
t.Fatalf("ctime is unexpectedly old: %v", ctime2)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestFileCTime_NonSyscallFileInfo verifies the fallback to mtime when
|
|
||||||
// the FileInfo doesn't have a *syscall.Stat_t (e.g. afero.MemMapFs).
|
|
||||||
type mockFileInfo struct {
|
|
||||||
name string
|
|
||||||
size int64
|
|
||||||
mode os.FileMode
|
|
||||||
modTime time.Time
|
|
||||||
isDir bool
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockFileInfo) Name() string { return m.name }
|
|
||||||
func (m *mockFileInfo) Size() int64 { return m.size }
|
|
||||||
func (m *mockFileInfo) Mode() os.FileMode { return m.mode }
|
|
||||||
func (m *mockFileInfo) ModTime() time.Time { return m.modTime }
|
|
||||||
func (m *mockFileInfo) IsDir() bool { return m.isDir }
|
|
||||||
func (m *mockFileInfo) Sys() interface{} { return nil } // No syscall.Stat_t
|
|
||||||
|
|
||||||
func TestFileCTime_FallbackToMtime(t *testing.T) {
|
|
||||||
now := time.Now().UTC().Truncate(time.Second)
|
|
||||||
info := &mockFileInfo{
|
|
||||||
name: "test.txt",
|
|
||||||
size: 100,
|
|
||||||
mode: 0644,
|
|
||||||
modTime: now,
|
|
||||||
}
|
|
||||||
|
|
||||||
ctime := fileCTime(info)
|
|
||||||
if !ctime.Equal(now) {
|
|
||||||
t.Fatalf("expected fallback to mtime %v, got %v", now, ctime)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -728,7 +728,7 @@ func (s *Scanner) checkFileInMemory(path string, info os.FileInfo, knownFiles ma
|
|||||||
Path: types.FilePath(path),
|
Path: types.FilePath(path),
|
||||||
SourcePath: types.SourcePath(s.currentSourcePath), // Store source directory for restore path stripping
|
SourcePath: types.SourcePath(s.currentSourcePath), // Store source directory for restore path stripping
|
||||||
MTime: info.ModTime(),
|
MTime: info.ModTime(),
|
||||||
CTime: fileCTime(info), // platform-specific: birth time on macOS, inode change time on Linux
|
CTime: info.ModTime(), // afero doesn't provide ctime
|
||||||
Size: info.Size(),
|
Size: info.Size(),
|
||||||
Mode: uint32(info.Mode()),
|
Mode: uint32(info.Mode()),
|
||||||
UID: uid,
|
UID: uid,
|
||||||
|
|||||||
@@ -79,6 +79,21 @@ func parseSnapshotTimestamp(snapshotID string) (time.Time, error) {
|
|||||||
return timestamp.UTC(), nil
|
return timestamp.UTC(), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// parseSnapshotName extracts the snapshot name from a snapshot ID.
|
||||||
|
// Format: hostname_snapshotname_timestamp (3 parts) or hostname_timestamp (2 parts, no name).
|
||||||
|
// Returns the snapshot name, or empty string if no name component is present.
|
||||||
|
func parseSnapshotName(snapshotID string) string {
|
||||||
|
parts := strings.Split(snapshotID, "_")
|
||||||
|
if len(parts) < 3 {
|
||||||
|
// Format: hostname_timestamp — no snapshot name
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
// Format: hostname_name_timestamp — middle parts are the name.
|
||||||
|
// The last part is the RFC3339 timestamp, the first part is the hostname,
|
||||||
|
// everything in between is the snapshot name (which may itself contain underscores).
|
||||||
|
return strings.Join(parts[1:len(parts)-1], "_")
|
||||||
|
}
|
||||||
|
|
||||||
// parseDuration parses a duration string with support for days
|
// parseDuration parses a duration string with support for days
|
||||||
func parseDuration(s string) (time.Duration, error) {
|
func parseDuration(s string) (time.Duration, error) {
|
||||||
// Check for days suffix
|
// Check for days suffix
|
||||||
|
|||||||
119
internal/vaultik/helpers_test.go
Normal file
119
internal/vaultik/helpers_test.go
Normal file
@@ -0,0 +1,119 @@
|
|||||||
|
package vaultik
|
||||||
|
|
||||||
|
import (
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestParseSnapshotName(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
snapshotID string
|
||||||
|
want string
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "standard format with name",
|
||||||
|
snapshotID: "myhost_home_2026-01-12T14:41:15Z",
|
||||||
|
want: "home",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "standard format with different name",
|
||||||
|
snapshotID: "server1_system_2026-02-15T09:30:00Z",
|
||||||
|
want: "system",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "no snapshot name (legacy format)",
|
||||||
|
snapshotID: "myhost_2026-01-12T14:41:15Z",
|
||||||
|
want: "",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "name with underscores",
|
||||||
|
snapshotID: "myhost_my_special_backup_2026-03-01T00:00:00Z",
|
||||||
|
want: "my_special_backup",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "single part (edge case)",
|
||||||
|
snapshotID: "nounderscore",
|
||||||
|
want: "",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "empty string",
|
||||||
|
snapshotID: "",
|
||||||
|
want: "",
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
got := parseSnapshotName(tt.snapshotID)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("parseSnapshotName(%q) = %q, want %q", tt.snapshotID, got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseSnapshotTimestamp(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
snapshotID string
|
||||||
|
wantErr bool
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "valid with name",
|
||||||
|
snapshotID: "myhost_home_2026-01-12T14:41:15Z",
|
||||||
|
wantErr: false,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "valid without name",
|
||||||
|
snapshotID: "myhost_2026-01-12T14:41:15Z",
|
||||||
|
wantErr: false,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "invalid - single part",
|
||||||
|
snapshotID: "nounderscore",
|
||||||
|
wantErr: true,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "invalid - bad timestamp",
|
||||||
|
snapshotID: "myhost_home_notadate",
|
||||||
|
wantErr: true,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
_, err := parseSnapshotTimestamp(tt.snapshotID)
|
||||||
|
if (err != nil) != tt.wantErr {
|
||||||
|
t.Errorf("parseSnapshotTimestamp(%q) error = %v, wantErr %v", tt.snapshotID, err, tt.wantErr)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestSnapshotPurgeOptions(t *testing.T) {
|
||||||
|
opts := &SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Name: "home",
|
||||||
|
Force: true,
|
||||||
|
}
|
||||||
|
if !opts.KeepLatest {
|
||||||
|
t.Error("Expected KeepLatest to be true")
|
||||||
|
}
|
||||||
|
if opts.Name != "home" {
|
||||||
|
t.Errorf("Expected Name to be 'home', got %q", opts.Name)
|
||||||
|
}
|
||||||
|
if !opts.Force {
|
||||||
|
t.Error("Expected Force to be true")
|
||||||
|
}
|
||||||
|
|
||||||
|
opts2 := &SnapshotPurgeOptions{
|
||||||
|
OlderThan: "30d",
|
||||||
|
Name: "system",
|
||||||
|
}
|
||||||
|
if opts2.OlderThan != "30d" {
|
||||||
|
t.Errorf("Expected OlderThan to be '30d', got %q", opts2.OlderThan)
|
||||||
|
}
|
||||||
|
if opts2.Name != "system" {
|
||||||
|
t.Errorf("Expected Name to be 'system', got %q", opts2.Name)
|
||||||
|
}
|
||||||
|
}
|
||||||
303
internal/vaultik/purge_per_name_test.go
Normal file
303
internal/vaultik/purge_per_name_test.go
Normal file
@@ -0,0 +1,303 @@
|
|||||||
|
package vaultik_test
|
||||||
|
|
||||||
|
import (
|
||||||
|
"bytes"
|
||||||
|
"context"
|
||||||
|
"database/sql"
|
||||||
|
"strings"
|
||||||
|
"testing"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"git.eeqj.de/sneak/vaultik/internal/database"
|
||||||
|
"git.eeqj.de/sneak/vaultik/internal/log"
|
||||||
|
"git.eeqj.de/sneak/vaultik/internal/types"
|
||||||
|
"git.eeqj.de/sneak/vaultik/internal/vaultik"
|
||||||
|
"github.com/stretchr/testify/assert"
|
||||||
|
"github.com/stretchr/testify/require"
|
||||||
|
)
|
||||||
|
|
||||||
|
// setupPurgeTest creates a Vaultik instance with an in-memory database and mock
|
||||||
|
// storage pre-populated with the given snapshot IDs. Each snapshot is marked as
|
||||||
|
// completed. Remote metadata stubs are created so syncWithRemote keeps them.
|
||||||
|
func setupPurgeTest(t *testing.T, snapshotIDs []string) *vaultik.Vaultik {
|
||||||
|
t.Helper()
|
||||||
|
log.Initialize(log.Config{})
|
||||||
|
|
||||||
|
ctx := context.Background()
|
||||||
|
db, err := database.New(ctx, ":memory:")
|
||||||
|
require.NoError(t, err)
|
||||||
|
t.Cleanup(func() { _ = db.Close() })
|
||||||
|
|
||||||
|
repos := database.NewRepositories(db)
|
||||||
|
mockStorage := NewMockStorer()
|
||||||
|
|
||||||
|
// Insert each snapshot into the DB and create remote metadata stubs.
|
||||||
|
// Use timestamps parsed from snapshot IDs for realistic ordering.
|
||||||
|
for _, id := range snapshotIDs {
|
||||||
|
// Parse timestamp from the snapshot ID
|
||||||
|
parts := strings.Split(id, "_")
|
||||||
|
timestampStr := parts[len(parts)-1]
|
||||||
|
startedAt, err := time.Parse(time.RFC3339, timestampStr)
|
||||||
|
require.NoError(t, err, "parsing timestamp from snapshot ID %q", id)
|
||||||
|
|
||||||
|
completedAt := startedAt.Add(5 * time.Minute)
|
||||||
|
snap := &database.Snapshot{
|
||||||
|
ID: types.SnapshotID(id),
|
||||||
|
Hostname: "testhost",
|
||||||
|
VaultikVersion: "test",
|
||||||
|
StartedAt: startedAt,
|
||||||
|
CompletedAt: &completedAt,
|
||||||
|
}
|
||||||
|
err = repos.WithTx(ctx, func(ctx context.Context, tx *sql.Tx) error {
|
||||||
|
return repos.Snapshots.Create(ctx, tx, snap)
|
||||||
|
})
|
||||||
|
require.NoError(t, err, "creating snapshot %s", id)
|
||||||
|
|
||||||
|
// Create remote metadata stub so syncWithRemote keeps it
|
||||||
|
metadataKey := "metadata/" + id + "/manifest.json.zst"
|
||||||
|
err = mockStorage.Put(ctx, metadataKey, strings.NewReader("stub"))
|
||||||
|
require.NoError(t, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
stdout := &bytes.Buffer{}
|
||||||
|
stderr := &bytes.Buffer{}
|
||||||
|
stdin := &bytes.Buffer{}
|
||||||
|
|
||||||
|
v := &vaultik.Vaultik{
|
||||||
|
Storage: mockStorage,
|
||||||
|
Repositories: repos,
|
||||||
|
DB: db,
|
||||||
|
Stdout: stdout,
|
||||||
|
Stderr: stderr,
|
||||||
|
Stdin: stdin,
|
||||||
|
}
|
||||||
|
v.SetContext(ctx)
|
||||||
|
|
||||||
|
return v
|
||||||
|
}
|
||||||
|
|
||||||
|
// listRemainingSnapshots returns IDs of all completed snapshots in the database.
|
||||||
|
func listRemainingSnapshots(t *testing.T, v *vaultik.Vaultik) []string {
|
||||||
|
t.Helper()
|
||||||
|
ctx := context.Background()
|
||||||
|
dbSnaps, err := v.Repositories.Snapshots.ListRecent(ctx, 10000)
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
var ids []string
|
||||||
|
for _, s := range dbSnaps {
|
||||||
|
if s.CompletedAt != nil {
|
||||||
|
ids = append(ids, s.ID.String())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return ids
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeKeepLatest_PerName(t *testing.T) {
|
||||||
|
// Create snapshots for two different names: "home" and "system".
|
||||||
|
// With per-name --keep-latest, the latest of each should be kept.
|
||||||
|
snapshotIDs := []string{
|
||||||
|
"testhost_system_2026-01-01T00:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T01:00:00Z",
|
||||||
|
"testhost_system_2026-01-01T02:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T03:00:00Z",
|
||||||
|
"testhost_system_2026-01-01T04:00:00Z",
|
||||||
|
}
|
||||||
|
|
||||||
|
v := setupPurgeTest(t, snapshotIDs)
|
||||||
|
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Force: true,
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
remaining := listRemainingSnapshots(t, v)
|
||||||
|
|
||||||
|
// Should keep the latest of each name
|
||||||
|
assert.Len(t, remaining, 2, "should keep exactly 2 snapshots (one per name)")
|
||||||
|
assert.Contains(t, remaining, "testhost_system_2026-01-01T04:00:00Z", "should keep latest system")
|
||||||
|
assert.Contains(t, remaining, "testhost_home_2026-01-01T03:00:00Z", "should keep latest home")
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeKeepLatest_SingleName(t *testing.T) {
|
||||||
|
// All snapshots have the same name — keep-latest should keep exactly one.
|
||||||
|
snapshotIDs := []string{
|
||||||
|
"testhost_home_2026-01-01T00:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T01:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T02:00:00Z",
|
||||||
|
}
|
||||||
|
|
||||||
|
v := setupPurgeTest(t, snapshotIDs)
|
||||||
|
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Force: true,
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
remaining := listRemainingSnapshots(t, v)
|
||||||
|
assert.Len(t, remaining, 1)
|
||||||
|
assert.Contains(t, remaining, "testhost_home_2026-01-01T02:00:00Z", "should keep the newest")
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeKeepLatest_WithNameFilter(t *testing.T) {
|
||||||
|
// Use --name to filter purge to only "home" snapshots.
|
||||||
|
// "system" snapshots should be untouched.
|
||||||
|
snapshotIDs := []string{
|
||||||
|
"testhost_system_2026-01-01T00:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T01:00:00Z",
|
||||||
|
"testhost_system_2026-01-01T02:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T03:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T04:00:00Z",
|
||||||
|
}
|
||||||
|
|
||||||
|
v := setupPurgeTest(t, snapshotIDs)
|
||||||
|
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Force: true,
|
||||||
|
Name: "home",
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
remaining := listRemainingSnapshots(t, v)
|
||||||
|
|
||||||
|
// 2 system snapshots untouched + 1 latest home = 3
|
||||||
|
assert.Len(t, remaining, 3)
|
||||||
|
assert.Contains(t, remaining, "testhost_system_2026-01-01T00:00:00Z")
|
||||||
|
assert.Contains(t, remaining, "testhost_system_2026-01-01T02:00:00Z")
|
||||||
|
assert.Contains(t, remaining, "testhost_home_2026-01-01T04:00:00Z")
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeKeepLatest_NoSnapshots(t *testing.T) {
|
||||||
|
v := setupPurgeTest(t, nil)
|
||||||
|
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Force: true,
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeKeepLatest_NameFilterNoMatch(t *testing.T) {
|
||||||
|
snapshotIDs := []string{
|
||||||
|
"testhost_system_2026-01-01T00:00:00Z",
|
||||||
|
"testhost_system_2026-01-01T01:00:00Z",
|
||||||
|
}
|
||||||
|
|
||||||
|
v := setupPurgeTest(t, snapshotIDs)
|
||||||
|
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Force: true,
|
||||||
|
Name: "nonexistent",
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
// All snapshots should remain — the name filter matched nothing
|
||||||
|
remaining := listRemainingSnapshots(t, v)
|
||||||
|
assert.Len(t, remaining, 2)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeOlderThan_WithNameFilter(t *testing.T) {
|
||||||
|
// Snapshots with different names and timestamps.
|
||||||
|
// --older-than should apply only to the named subset when --name is used.
|
||||||
|
snapshotIDs := []string{
|
||||||
|
"testhost_system_2020-01-01T00:00:00Z",
|
||||||
|
"testhost_home_2020-01-01T00:00:00Z",
|
||||||
|
"testhost_system_2026-01-01T00:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T00:00:00Z",
|
||||||
|
}
|
||||||
|
|
||||||
|
v := setupPurgeTest(t, snapshotIDs)
|
||||||
|
|
||||||
|
// Purge only "home" snapshots older than 365 days
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
OlderThan: "365d",
|
||||||
|
Force: true,
|
||||||
|
Name: "home",
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
remaining := listRemainingSnapshots(t, v)
|
||||||
|
|
||||||
|
// Old system stays (not filtered by name), old home deleted, recent ones stay
|
||||||
|
assert.Len(t, remaining, 3)
|
||||||
|
assert.Contains(t, remaining, "testhost_system_2020-01-01T00:00:00Z")
|
||||||
|
assert.Contains(t, remaining, "testhost_system_2026-01-01T00:00:00Z")
|
||||||
|
assert.Contains(t, remaining, "testhost_home_2026-01-01T00:00:00Z")
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeKeepLatest_LegacyNoNameSnapshots(t *testing.T) {
|
||||||
|
// Legacy snapshots without a name component (hostname_timestamp).
|
||||||
|
// Should be grouped together under empty-name.
|
||||||
|
snapshotIDs := []string{
|
||||||
|
"testhost_2026-01-01T00:00:00Z",
|
||||||
|
"testhost_2026-01-01T01:00:00Z",
|
||||||
|
"testhost_2026-01-01T02:00:00Z",
|
||||||
|
}
|
||||||
|
|
||||||
|
v := setupPurgeTest(t, snapshotIDs)
|
||||||
|
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Force: true,
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
remaining := listRemainingSnapshots(t, v)
|
||||||
|
assert.Len(t, remaining, 1)
|
||||||
|
assert.Contains(t, remaining, "testhost_2026-01-01T02:00:00Z")
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeKeepLatest_MixedNamedAndLegacy(t *testing.T) {
|
||||||
|
// Mix of named snapshots and legacy ones (no name).
|
||||||
|
snapshotIDs := []string{
|
||||||
|
"testhost_2026-01-01T00:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T01:00:00Z",
|
||||||
|
"testhost_2026-01-01T02:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T03:00:00Z",
|
||||||
|
}
|
||||||
|
|
||||||
|
v := setupPurgeTest(t, snapshotIDs)
|
||||||
|
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Force: true,
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
remaining := listRemainingSnapshots(t, v)
|
||||||
|
|
||||||
|
// Should keep latest of each group: latest legacy + latest home
|
||||||
|
assert.Len(t, remaining, 2)
|
||||||
|
assert.Contains(t, remaining, "testhost_2026-01-01T02:00:00Z")
|
||||||
|
assert.Contains(t, remaining, "testhost_home_2026-01-01T03:00:00Z")
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPurgeKeepLatest_ThreeNames(t *testing.T) {
|
||||||
|
// Three different snapshot names with multiple snapshots each.
|
||||||
|
snapshotIDs := []string{
|
||||||
|
"testhost_home_2026-01-01T00:00:00Z",
|
||||||
|
"testhost_system_2026-01-01T01:00:00Z",
|
||||||
|
"testhost_media_2026-01-01T02:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T03:00:00Z",
|
||||||
|
"testhost_system_2026-01-01T04:00:00Z",
|
||||||
|
"testhost_media_2026-01-01T05:00:00Z",
|
||||||
|
"testhost_home_2026-01-01T06:00:00Z",
|
||||||
|
}
|
||||||
|
|
||||||
|
v := setupPurgeTest(t, snapshotIDs)
|
||||||
|
|
||||||
|
err := v.PurgeSnapshotsWithOptions(&vaultik.SnapshotPurgeOptions{
|
||||||
|
KeepLatest: true,
|
||||||
|
Force: true,
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
remaining := listRemainingSnapshots(t, v)
|
||||||
|
assert.Len(t, remaining, 3, "should keep one per name")
|
||||||
|
assert.Contains(t, remaining, "testhost_home_2026-01-01T06:00:00Z")
|
||||||
|
assert.Contains(t, remaining, "testhost_system_2026-01-01T04:00:00Z")
|
||||||
|
assert.Contains(t, remaining, "testhost_media_2026-01-01T05:00:00Z")
|
||||||
|
}
|
||||||
@@ -411,11 +411,7 @@ func (v *Vaultik) restoreDirectory(file *database.File, targetPath string, resul
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Set mtime (atime is set to mtime as a reasonable default).
|
// Set mtime
|
||||||
// Note: ctime cannot be restored. On Linux, ctime (inode change time) is
|
|
||||||
// managed by the kernel and cannot be set by userspace. On macOS, birth
|
|
||||||
// time cannot be set via standard POSIX APIs. The ctime value is preserved
|
|
||||||
// in the snapshot database for informational purposes.
|
|
||||||
if err := v.Fs.Chtimes(targetPath, file.MTime, file.MTime); err != nil {
|
if err := v.Fs.Chtimes(targetPath, file.MTime, file.MTime); err != nil {
|
||||||
log.Debug("Failed to set directory mtime", "path", targetPath, "error", err)
|
log.Debug("Failed to set directory mtime", "path", targetPath, "error", err)
|
||||||
}
|
}
|
||||||
@@ -512,11 +508,7 @@ func (v *Vaultik) restoreRegularFile(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Set mtime (atime is set to mtime as a reasonable default).
|
// Set mtime
|
||||||
// Note: ctime cannot be restored. On Linux, ctime (inode change time) is
|
|
||||||
// managed by the kernel and cannot be set by userspace. On macOS, birth
|
|
||||||
// time cannot be set via standard POSIX APIs. The ctime value is preserved
|
|
||||||
// in the snapshot database for informational purposes.
|
|
||||||
if err := v.Fs.Chtimes(targetPath, file.MTime, file.MTime); err != nil {
|
if err := v.Fs.Chtimes(targetPath, file.MTime, file.MTime); err != nil {
|
||||||
log.Debug("Failed to set file mtime", "path", targetPath, "error", err)
|
log.Debug("Failed to set file mtime", "path", targetPath, "error", err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -488,8 +488,30 @@ func (v *Vaultik) ListSnapshots(jsonOutput bool) error {
|
|||||||
return w.Flush()
|
return w.Flush()
|
||||||
}
|
}
|
||||||
|
|
||||||
// PurgeSnapshots removes old snapshots based on criteria
|
// SnapshotPurgeOptions contains options for the snapshot purge command
|
||||||
|
type SnapshotPurgeOptions struct {
|
||||||
|
KeepLatest bool
|
||||||
|
OlderThan string
|
||||||
|
Force bool
|
||||||
|
Name string // Filter purge to a specific snapshot name
|
||||||
|
}
|
||||||
|
|
||||||
|
// PurgeSnapshots removes old snapshots based on criteria.
|
||||||
|
// When keepLatest is true, retention is applied per snapshot name — the latest
|
||||||
|
// snapshot for each distinct name is kept.
|
||||||
func (v *Vaultik) PurgeSnapshots(keepLatest bool, olderThan string, force bool) error {
|
func (v *Vaultik) PurgeSnapshots(keepLatest bool, olderThan string, force bool) error {
|
||||||
|
return v.PurgeSnapshotsWithOptions(&SnapshotPurgeOptions{
|
||||||
|
KeepLatest: keepLatest,
|
||||||
|
OlderThan: olderThan,
|
||||||
|
Force: force,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// PurgeSnapshotsWithOptions removes old snapshots based on criteria with full options.
|
||||||
|
// When KeepLatest is true, retention is applied per snapshot name — the latest
|
||||||
|
// snapshot for each distinct name is kept. If Name is non-empty, only snapshots
|
||||||
|
// matching that name are considered for purge.
|
||||||
|
func (v *Vaultik) PurgeSnapshotsWithOptions(opts *SnapshotPurgeOptions) error {
|
||||||
// Sync with remote first
|
// Sync with remote first
|
||||||
if err := v.syncWithRemote(); err != nil {
|
if err := v.syncWithRemote(); err != nil {
|
||||||
return fmt.Errorf("syncing with remote: %w", err)
|
return fmt.Errorf("syncing with remote: %w", err)
|
||||||
@@ -513,6 +535,17 @@ func (v *Vaultik) PurgeSnapshots(keepLatest bool, olderThan string, force bool)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// If --name is specified, filter to only snapshots matching that name
|
||||||
|
if opts.Name != "" {
|
||||||
|
filtered := make([]SnapshotInfo, 0, len(snapshots))
|
||||||
|
for _, snap := range snapshots {
|
||||||
|
if parseSnapshotName(snap.ID.String()) == opts.Name {
|
||||||
|
filtered = append(filtered, snap)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
snapshots = filtered
|
||||||
|
}
|
||||||
|
|
||||||
// Sort by timestamp (newest first)
|
// Sort by timestamp (newest first)
|
||||||
sort.Slice(snapshots, func(i, j int) bool {
|
sort.Slice(snapshots, func(i, j int) bool {
|
||||||
return snapshots[i].Timestamp.After(snapshots[j].Timestamp)
|
return snapshots[i].Timestamp.After(snapshots[j].Timestamp)
|
||||||
@@ -520,14 +553,23 @@ func (v *Vaultik) PurgeSnapshots(keepLatest bool, olderThan string, force bool)
|
|||||||
|
|
||||||
var toDelete []SnapshotInfo
|
var toDelete []SnapshotInfo
|
||||||
|
|
||||||
if keepLatest {
|
if opts.KeepLatest {
|
||||||
// Keep only the most recent snapshot
|
// Keep the latest snapshot per snapshot name
|
||||||
if len(snapshots) > 1 {
|
// Group snapshots by name, then mark all but the newest in each group
|
||||||
toDelete = snapshots[1:]
|
latestByName := make(map[string]bool) // tracks whether we've seen the latest for each name
|
||||||
|
for _, snap := range snapshots {
|
||||||
|
name := parseSnapshotName(snap.ID.String())
|
||||||
|
if latestByName[name] {
|
||||||
|
// Already kept the latest for this name — delete this one
|
||||||
|
toDelete = append(toDelete, snap)
|
||||||
|
} else {
|
||||||
|
// This is the latest (sorted newest-first) — keep it
|
||||||
|
latestByName[name] = true
|
||||||
}
|
}
|
||||||
} else if olderThan != "" {
|
}
|
||||||
|
} else if opts.OlderThan != "" {
|
||||||
// Parse duration
|
// Parse duration
|
||||||
duration, err := parseDuration(olderThan)
|
duration, err := parseDuration(opts.OlderThan)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("invalid duration: %w", err)
|
return fmt.Errorf("invalid duration: %w", err)
|
||||||
}
|
}
|
||||||
@@ -555,7 +597,7 @@ func (v *Vaultik) PurgeSnapshots(keepLatest bool, olderThan string, force bool)
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Confirm unless --force is used
|
// Confirm unless --force is used
|
||||||
if !force {
|
if !opts.Force {
|
||||||
v.printfStdout("\nDelete %d snapshot(s)? [y/N] ", len(toDelete))
|
v.printfStdout("\nDelete %d snapshot(s)? [y/N] ", len(toDelete))
|
||||||
var confirm string
|
var confirm string
|
||||||
if _, err := v.scanStdin(&confirm); err != nil {
|
if _, err := v.scanStdin(&confirm); err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user