Skip to content

Commit 16b862a

Browse files
committed
fix: extend backup file detection to support additional compression formats
1 parent c664413 commit 16b862a

File tree

2 files changed

+19
-3
lines changed

2 files changed

+19
-3
lines changed

cmd/main.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -919,9 +919,12 @@ func getBackupFiles(backupDir string, selectedDatabases []string) []BackupFileIn
919919
isBackupFile := strings.HasSuffix(info.Name(), ".sql.gz") ||
920920
strings.HasSuffix(info.Name(), ".sql.zst") ||
921921
strings.HasSuffix(info.Name(), ".sql.xz") ||
922+
strings.HasSuffix(info.Name(), ".sql.lz4") ||
923+
strings.HasSuffix(info.Name(), ".sql") ||
922924
strings.HasSuffix(info.Name(), ".tar.gz") ||
923925
strings.HasSuffix(info.Name(), ".tar.zst") ||
924-
strings.HasSuffix(info.Name(), ".tar.xz")
926+
strings.HasSuffix(info.Name(), ".tar.xz") ||
927+
strings.HasSuffix(info.Name(), ".tar.lz4")
925928

926929
// For directories, check if they contain backup files (mydumper output directories)
927930
isBackupDir := info.IsDir() && containsBackupFiles(path)
@@ -979,7 +982,12 @@ func containsBackupFiles(dirPath string) bool {
979982
if strings.HasSuffix(name, ".sql.gz") ||
980983
strings.HasSuffix(name, ".sql.zst") ||
981984
strings.HasSuffix(name, ".sql.xz") ||
985+
strings.HasSuffix(name, ".sql.lz4") ||
982986
strings.HasSuffix(name, ".sql") ||
987+
strings.HasSuffix(name, ".gz") ||
988+
strings.HasSuffix(name, ".zst") ||
989+
strings.HasSuffix(name, ".xz") ||
990+
strings.HasSuffix(name, ".lz4") ||
983991
name == "metadata" {
984992
return true
985993
}

internal/backup/cleanup.go

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,13 +48,16 @@ func (c *CleanupService) GetOldFiles(backupDir string, retentionDays int) ([]str
4848
return nil
4949
}
5050

51-
// Look for actual backup files (.sql.gz, .sql.zst, .sql.xz) or backup directories
51+
// Look for actual backup files with supported compressions or backup directories
5252
isBackupFile := strings.HasSuffix(info.Name(), ".sql.gz") ||
5353
strings.HasSuffix(info.Name(), ".sql.zst") ||
5454
strings.HasSuffix(info.Name(), ".sql.xz") ||
55+
strings.HasSuffix(info.Name(), ".sql.lz4") ||
56+
strings.HasSuffix(info.Name(), ".sql") ||
5557
strings.HasSuffix(info.Name(), ".tar.gz") ||
5658
strings.HasSuffix(info.Name(), ".tar.zst") ||
57-
strings.HasSuffix(info.Name(), ".tar.xz")
59+
strings.HasSuffix(info.Name(), ".tar.xz") ||
60+
strings.HasSuffix(info.Name(), ".tar.lz4")
5861

5962
// For directories, check if they contain backup files (mydumper output directories)
6063
isBackupDir := info.IsDir() && c.containsBackupFiles(path)
@@ -87,7 +90,12 @@ func (c *CleanupService) containsBackupFiles(dirPath string) bool {
8790
if strings.HasSuffix(name, ".sql.gz") ||
8891
strings.HasSuffix(name, ".sql.zst") ||
8992
strings.HasSuffix(name, ".sql.xz") ||
93+
strings.HasSuffix(name, ".sql.lz4") ||
9094
strings.HasSuffix(name, ".sql") ||
95+
strings.HasSuffix(name, ".gz") ||
96+
strings.HasSuffix(name, ".zst") ||
97+
strings.HasSuffix(name, ".xz") ||
98+
strings.HasSuffix(name, ".lz4") ||
9199
name == "metadata" {
92100
return true
93101
}

0 commit comments

Comments
 (0)