Create directory for local repository for restic init (#199)

Signed-off-by: hmsayem <hmsayem@appscode.com>
stashed · Mar 16, 2023 · 1c5d99c · 1c5d99c
1 parent 4fef7bc
commit 1c5d99c
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/pkg/restic/commands.go b/pkg/restic/commands.go
@@ -109,6 +109,10 @@ func (w *ResticWrapper) repositoryExist() bool {
 
 func (w *ResticWrapper) initRepository() error {
 	klog.Infoln("Initializing new restic repository in the backend....")
+	if err := w.createLocalDir(); err != nil {
+		return err
+	}
+
 	args := w.appendCacheDirFlag([]interface{}{"init"})
 	args = w.appendCaCertFlag(args)
 	args = w.appendMaxConnectionsFlag(args)
@@ -169,6 +173,13 @@ func (w *ResticWrapper) backupFromStdin(options BackupOptions) ([]byte, error) {
 	return w.run(commands...)
 }
 
+func (w *ResticWrapper) createLocalDir() error {
+	if w.config.Provider == storage.ProviderLocal {
+		return os.MkdirAll(w.config.Bucket, 0o755)
+	}
+	return nil
+}
+
 func (w *ResticWrapper) cleanup(retentionPolicy v1alpha1.RetentionPolicy, host string) ([]byte, error) {
 	klog.Infoln("Cleaning old snapshots according to retention policy")
 

diff --git a/pkg/restic/setup.go b/pkg/restic/setup.go
@@ -121,9 +121,6 @@ func (w *ResticWrapper) setupEnv() error {
 
 	case storage.ProviderLocal:
 		r := w.config.Bucket
-		if err := os.MkdirAll(r, 0o755); err != nil {
-			return err
-		}
 		w.sh.SetEnv(RESTIC_REPOSITORY, r)
 
 	case storage.ProviderS3: