feat: create DestDir if it does not exist

mirkobrombin · Jul 8, 2024 · faa8a03 · faa8a03
1 parent e4aeadb
commit faa8a03
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/pkg/processor/dedup.go b/pkg/processor/dedup.go
@@ -91,6 +91,16 @@ func dedupFinishProcessing(hash string) {
 
 // Process processes the files in the source directory
 func (p *DedupProcessor) Process(verbose bool) error {
+	if p.DestDir != "" {
+		if verbose {
+			log.Printf("Creating destination directory: %s", p.DestDir)
+		}
+		err := os.MkdirAll(p.DestDir, 0755)
+		if err != nil {
+			return fmt.Errorf("creating destination directory: %w", err)
+		}
+	}
+
 	jobs := make(chan string, p.Workers)
 	var wg sync.WaitGroup