jandre/formolcli
1
0
Fork 0
Code Issues 4 Pull Requests Projects Releases 1 Wiki Activity

Skip the restore if it has already been done

Browse Source
This commit is contained in:
jandre 2021-02-21 14:27:54 +01:00
parent b7468cbe2b
commit 956c726a63
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/restore/root.go
View File

@ -26,7 +26,9 @@ func init() {
func RestoreVolume(snapshotId string) error {
log := logger.WithName("restore-volume")
session.RestoreSessionUpdateTargetStatus(formolv1alpha1.Running)
if err := session.RestoreSessionUpdateTargetStatus(formolv1alpha1.Running); err != nil {
return err
}
state := formolv1alpha1.Success
output, err := restic.RestorePaths(snapshotId)
if err != nil {

8
pkg/session/root.go
View File

@ -2,6 +2,7 @@ package session
import (
"context"
"errors"
formolv1alpha1 "github.com/desmo999r/formol/api/v1alpha1"
"github.com/go-logr/logr"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@ -88,8 +89,13 @@ func RestoreSessionUpdateTargetStatus(state formolv1alpha1.SessionState) error {
}
for i, target := range restoreSession.Status.Targets {
if target.Name == targetName {
if target.SessionState == formolv1alpha1.Success {
return errors.New("the restore has already been done. Skipping")
}
restoreSession.Status.Targets[i].SessionState = state
restoreSession.Status.Targets[i].Duration = &metav1.Duration{Duration: time.Now().Sub(restoreSession.Status.Targets[i].StartTime.Time)}
if state == formolv1alpha1.Success || state == formolv1alpha1.Failure {
restoreSession.Status.Targets[i].Duration = &metav1.Duration{Duration: time.Now().Sub(restoreSession.Status.Targets[i].StartTime.Time)}
}
}
}