Prepare for release v0.27.0 (#178)

ProductLine: Stash
Release: v2023.03.13
Release-tracker: stashed/CHANGELOG#63
Signed-off-by: 1gtm <1gtm@appscode.com>

Author: 1gtm

go.mod

@@ -25,8 +25,8 @@ require (
 	kmodules.xyz/objectstore-api v0.25.1-0.20221104003322-f0289b5b6ca2
 	kmodules.xyz/offshoot-api v0.25.0
 	kmodules.xyz/openshift v0.25.0
-	stash.appscode.dev/apimachinery v0.26.0
-	stash.appscode.dev/stash v0.26.0
+	stash.appscode.dev/apimachinery v0.27.0
+	stash.appscode.dev/stash v0.27.0
 )
 
 require (

go.sum

@@ -1100,7 +1100,7 @@ sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=
 sigs.k8s.io/yaml v1.2.0/go.mod h1:yfXDCHCao9+ENCvLSE62v9VSji2MKu5jeNfTrofGhJc=
 sigs.k8s.io/yaml v1.3.0 h1:a2VclLzOGrwOHDiV8EfBGhvjHvP46CtW5j6POvhYGGo=
 sigs.k8s.io/yaml v1.3.0/go.mod h1:GeOyir5tyXNByN85N/dRIT9es5UQNerPYEKK56eTBm8=
-stash.appscode.dev/apimachinery v0.26.0 h1:74H87DYEMFUO6vesQARIaiXG9N6wSyakTzSoJhBRJZ0=
-stash.appscode.dev/apimachinery v0.26.0/go.mod h1:SLknx4Og4nrUflEJIQF5gjolXmetqXrpisoDlFNV2DI=
-stash.appscode.dev/stash v0.26.0 h1:tiCvWnUbay8ZTvoymenDmPss8ziecSLB9BexUWU3gLQ=
-stash.appscode.dev/stash v0.26.0/go.mod h1:A1qKswp8cXiS6vc/tRWtMj+I9F6UVZKb6SZ/PxU2zJM=
+stash.appscode.dev/apimachinery v0.27.0 h1:3Ldo0ncYnsRT4VukSrawan0jWjc+D/nss1yAyDjWj8A=
+stash.appscode.dev/apimachinery v0.27.0/go.mod h1:0bPMB3d0+3oR2hBqFeZyskBDEO5CyWnkHNV+Gp67bMA=
+stash.appscode.dev/stash v0.27.0 h1:HesmCBHmmlwusftjwrduwYQC7KbQzSzaXCamcSFZtyA=
+stash.appscode.dev/stash v0.27.0/go.mod h1:mI4KrWYan8tPvpjaZ6FbH2V5YoJWSIfe454hcqqggWE=

vendor/modules.txt

@@ -932,7 +932,7 @@ sigs.k8s.io/structured-merge-diff/v4/value
 # sigs.k8s.io/yaml v1.3.0
 ## explicit; go 1.12
 sigs.k8s.io/yaml
-# stash.appscode.dev/apimachinery v0.26.0
+# stash.appscode.dev/apimachinery v0.27.0
 ## explicit; go 1.18
 stash.appscode.dev/apimachinery/apis
 stash.appscode.dev/apimachinery/apis/repositories
@@ -961,7 +961,7 @@ stash.appscode.dev/apimachinery/pkg/docker
 stash.appscode.dev/apimachinery/pkg/invoker
 stash.appscode.dev/apimachinery/pkg/metrics
 stash.appscode.dev/apimachinery/pkg/restic
-# stash.appscode.dev/stash v0.26.0
+# stash.appscode.dev/stash v0.27.0
 ## explicit; go 1.18
 stash.appscode.dev/stash/pkg/registry/snapshot
 stash.appscode.dev/stash/pkg/util

vendor/stash.appscode.dev/apimachinery/pkg/restic/commands.go

@@ -149,12 +149,7 @@ func (w *ResticWrapper) backupFromStdin(options BackupOptions) ([]byte, error) {
 	klog.Infoln("Backing up stdin data")
 
 	// first add StdinPipeCommands, then add restic command
-	var commands []Command
-	if len(options.StdinPipeCommands) != 0 {
-		for i := range options.StdinPipeCommands {
-			commands = append(commands, options.StdinPipeCommands[i])
-		}
-	}
+	commands := options.StdinPipeCommands
 
 	args := []interface{}{"backup", "--stdin", "--quiet", "--json"}
 	if options.StdinFileName != "" {
@@ -177,6 +172,19 @@ func (w *ResticWrapper) backupFromStdin(options BackupOptions) ([]byte, error) {
 func (w *ResticWrapper) cleanup(retentionPolicy v1alpha1.RetentionPolicy, host string) ([]byte, error) {
 	klog.Infoln("Cleaning old snapshots according to retention policy")
 
+	out, err := w.tryCleanup(retentionPolicy, host)
+	if err == nil || !strings.Contains(err.Error(), "unlock") {
+		return out, err
+	}
+	// repo is locked, so unlock first
+	klog.Warningln("repo found locked, so unlocking before pruning, err:", err.Error())
+	if o2, e2 := w.unlock(); e2 != nil {
+		return o2, e2
+	}
+	return w.tryCleanup(retentionPolicy, host)
+}
+
+func (w *ResticWrapper) tryCleanup(retentionPolicy v1alpha1.RetentionPolicy, host string) ([]byte, error) {
 	args := []interface{}{"forget", "--quiet", "--json"}
 
 	if host != "" {
@@ -304,11 +312,7 @@ func (w *ResticWrapper) dump(dumpOptions DumpOptions) ([]byte, error) {
 	commands := []Command{
 		{Name: ResticCMD, Args: args},
 	}
-	if len(dumpOptions.StdoutPipeCommands) != 0 {
-		for i := range dumpOptions.StdoutPipeCommands {
-			commands = append(commands, dumpOptions.StdoutPipeCommands[i])
-		}
-	}
+	commands = append(commands, dumpOptions.StdoutPipeCommands...)
 	return w.run(commands...)
 }