toolshed/abra
4
2
Fork 18
Code Issues 34 Pull Requests 3 Packages Releases 40 Activity

fixup! feat: backup revolution

Browse Source
This commit is contained in:
decentral1se
2024-01-12 16:26:45 +01:00
parent 529cb9bd12
commit 3ff37ddb87
1 changed files with 30 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

90
cli/app/backup.go
View File

@ -15,6 +15,7 @@ import (
"github.com/docker/cli/cli/command" "github.com/docker/cli/cli/command"
"github.com/docker/docker/api/types" "github.com/docker/docker/api/types"
"github.com/docker/docker/api/types/filters" "github.com/docker/docker/api/types/filters"
dockerClient "github.com/docker/docker/client"
"github.com/sirupsen/logrus" "github.com/sirupsen/logrus"
"github.com/urfave/cli" "github.com/urfave/cli"
) )
@ -40,6 +41,31 @@ var resticRepoFlag = &cli.StringFlag{
Destination: &resticRepo, Destination: &resticRepo,
} }
// retrieveBackupBotContainer gets the deployed backupbot container.
func retrieveBackupBotContainer(cl *dockerClient.Client) (types.Container, error) {
ctx := context.Background()
chosenService, err := service.GetServiceByLabel(ctx, cl, config.BackupbotLabel, internal.NoInput)
if err != nil {
return types.Container{}, err
}
logrus.Debugf("retrieved %s as backup enabled service", chosenService.Spec.Name)
filters := filters.NewArgs()
filters.Add("name", chosenService.Spec.Name)
targetContainer, err := containerPkg.GetContainer(
ctx,
cl,
filters,
internal.NoInput,
)
if err != nil {
return types.Container{}, err
}
return targetContainer, nil
}
var appBackupListCommand = cli.Command{ var appBackupListCommand = cli.Command{
Name: "list", Name: "list",
Aliases: []string{"ls"}, Aliases: []string{"ls"},
@ -80,21 +106,7 @@ var appBackupListCommand = cli.Command{
logrus.Fatal(err) logrus.Fatal(err)
} }
chosenService, err := service.GetServiceByLabel(context.Background(), cl, config.BackupbotLabel, internal.NoInput) targetContainer, err := retrieveBackupBotContainer(cl)
if err != nil {
logrus.Fatal(err)
}
logrus.Debugf("retrieved %s as backup enabled service", chosenService.Spec.Name)
filters := filters.NewArgs()
filters.Add("name", chosenService.Spec.Name)
targetContainer, err := containerPkg.GetContainer(
context.Background(),
cl,
filters,
internal.NoInput,
)
if err != nil { if err != nil {
logrus.Fatal(err) logrus.Fatal(err)
} }
@ -175,21 +187,7 @@ var appBackupDownloadCommand = cli.Command{
logrus.Fatal(err) logrus.Fatal(err)
} }
chosenService, err := service.GetServiceByLabel(context.Background(), cl, config.BackupbotLabel, internal.NoInput) targetContainer, err := retrieveBackupBotContainer(cl)
if err != nil {
logrus.Fatal(err)
}
logrus.Debugf("retrieved %s as backup enabled service", chosenService.Spec.Name)
filters := filters.NewArgs()
filters.Add("name", chosenService.Spec.Name)
targetContainer, err := containerPkg.GetContainer(
context.Background(),
cl,
filters,
internal.NoInput,
)
if err != nil { if err != nil {
logrus.Fatal(err) logrus.Fatal(err)
} }
@ -278,21 +276,7 @@ var appBackupCreateCommand = cli.Command{
logrus.Fatal(err) logrus.Fatal(err)
} }
chosenService, err := service.GetServiceByLabel(context.Background(), cl, config.BackupbotLabel, internal.NoInput) targetContainer, err := retrieveBackupBotContainer(cl)
if err != nil {
logrus.Fatal(err)
}
logrus.Debugf("retrieved %s as backup enabled service", chosenService.Spec.Name)
filters := filters.NewArgs()
filters.Add("name", chosenService.Spec.Name)
targetContainer, err := containerPkg.GetContainer(
context.Background(),
cl,
filters,
internal.NoInput,
)
if err != nil { if err != nil {
logrus.Fatal(err) logrus.Fatal(err)
} }
@ -367,21 +351,7 @@ var appBackupSnapshotsCommand = cli.Command{
logrus.Fatal(err) logrus.Fatal(err)
} }
chosenService, err := service.GetServiceByLabel(context.Background(), cl, config.BackupbotLabel, internal.NoInput) targetContainer, err := retrieveBackupBotContainer(cl)
if err != nil {
logrus.Fatal(err)
}
logrus.Debugf("retrieved %s as backup enabled service", chosenService.Spec.Name)
filters := filters.NewArgs()
filters.Add("name", chosenService.Spec.Name)
targetContainer, err := containerPkg.GetContainer(
context.Background(),
cl,
filters,
internal.NoInput,
)
if err != nil { if err != nil {
logrus.Fatal(err) logrus.Fatal(err)
} }