Add backup config management to flexctl

cmd/flexctl/backups.go

@@ -1,8 +1,11 @@
 package main
 
 import (
+	"bytes"
 	"context"
+	"encoding/json"
 	"fmt"
+	"net/http"
 	"os"
 	"time"
 
@@ -224,3 +227,126 @@ func listBackups(cmd *cobra.Command) error {
 func backupsEnabled() bool {
 	return os.Getenv("S3_ARCHIVE_CONFIG") != ""
 }
+
+func newBackupConfigCmd() *cobra.Command {
+	var configCmd = &cobra.Command{
+		Use:   "config",
+		Short: "Manage backup configuration",
+	}
+
+	configCmd.AddCommand(newConfigShowCmd())
+	configCmd.AddCommand(newConfigUpdateCmd())
+
+	return configCmd
+}
+
+type configShowResult struct {
+	Result flypg.BarmanSettings `json:"result"`
+}
+
+func newConfigShowCmd() *cobra.Command {
+	var configShowCmd = &cobra.Command{
+		Use:   "show",
+		Short: "Show current configuration",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			resp, err := http.Get("http://localhost:5500/commands/admin/settings/view/barman")
+			if err != nil {
+				return err
+			}
+
+			var rv configShowResult
+			err = json.NewDecoder(resp.Body).Decode(&rv)
+			if err != nil {
+				return err
+			}
+
+			fmt.Printf("  ArchiveTimeout = %s\n", rv.Result.ArchiveTimeout)
+			fmt.Printf("  RecoveryWindow = %s\n", rv.Result.RecoveryWindow)
+			fmt.Printf("  FullBackupFrequency = %s\n", rv.Result.FullBackupFrequency)
+			fmt.Printf("  MinimumRedundancy = %s\n", rv.Result.MinimumRedundancy)
+
+			return nil
+		},
+	}
+
+	return configShowCmd
+}
+
+type successfulUpdateResult struct {
+	Message         string `json:"message,omitempty"`
+	RestartRequired bool   `json:"restart_required"`
+}
+
+type configUpdateResult struct {
+	Result successfulUpdateResult `json:"result,omitempty"`
+	Error  string                 `json:"error,omitempty"`
+}
+
+func newConfigUpdateCmd() *cobra.Command {
+	var configUpdateCmd = &cobra.Command{
+		Use:   "update",
+		Short: "Update configuration",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			update := flypg.BarmanSettings{
+				ArchiveTimeout:      cmd.Flag("archive-timeout").Value.String(),
+				RecoveryWindow:      cmd.Flag("recovery-window").Value.String(),
+				FullBackupFrequency: cmd.Flag("full-backup-frequency").Value.String(),
+				MinimumRedundancy:   cmd.Flag("minimum-redundancy").Value.String(),
+			}
+
+			jsonBody, err := json.Marshal(update)
+			if err != nil {
+				return err
+			}
+
+			resp, err := http.Post("http://localhost:5500/commands/admin/settings/update/barman", "application/json", bytes.NewBuffer(jsonBody))
+			if err != nil {
+				return err
+			}
+
+			var rv configUpdateResult
+			err = json.NewDecoder(resp.Body).Decode(&rv)
+			if err != nil {
+				return err
+			}
+
+			if rv.Error != "" {
+				return fmt.Errorf("error updating configuration: %s", rv.Error)
+			}
+
+			if rv.Result.Message != "" {
+				fmt.Println(rv.Result.Message)
+			}
+
+			if rv.Result.RestartRequired {
+				fmt.Println("A restart is required for these changes to take effect.")
+			}
+
+			return nil
+		},
+	}
+
+	configUpdateCmd.Flags().StringP("archive-timeout", "", "", "Archive timeout")
+	configUpdateCmd.Flags().StringP("recovery-window", "", "", "Recovery window")
+	configUpdateCmd.Flags().StringP("full-backup-frequency", "", "", "Full backup frequency")
+	configUpdateCmd.Flags().StringP("minimum-redundancy", "", "", "Minimum redundancy")
+
+	configUpdateCmd.PreRunE = func(cmd *cobra.Command, args []string) error {
+		requiredFlags := []string{"archive-timeout", "recovery-window", "full-backup-frequency", "minimum-redundancy"}
+		providedFlags := 0
+
+		for _, flag := range requiredFlags {
+			if cmd.Flag(flag).Changed {
+				providedFlags++
+			}
+		}
+
+		if providedFlags < 1 {
+			return fmt.Errorf("at least one flag must be specified")
+		}
+
+		return nil
+	}
+
+	return configUpdateCmd
+}

cmd/flexctl/main.go

@@ -21,6 +21,7 @@ func main() {
 	backupCmd.AddCommand(backupListCmd)
 	backupCmd.AddCommand(backupShowCmd)
 	backupCmd.AddCommand(backupCreateCmd)
+	backupCmd.AddCommand(newBackupConfigCmd())
 
 	if err := rootCmd.Execute(); err != nil {
 		fmt.Println(err)

internal/flypg/barman_config.go

@@ -13,10 +13,10 @@ import (
 )
 
 type BarmanSettings struct {
-	ArchiveTimeout      string
-	RecoveryWindow      string
-	FullBackupFrequency string
-	MinimumRedundancy   string
+	ArchiveTimeout      string `json:"archive_timeout,omitempty"`
+	RecoveryWindow      string `json:"recovery_window,omitempty"`
+	FullBackupFrequency string `json:"full_backup_frequency,omitempty"`
+	MinimumRedundancy   string `json:"minimum_redundancy,omitempty"`
 }
 
 type BarmanConfig struct {

internal/supervisor/ensure_kill_linux.go

@@ -1,3 +1,4 @@
+//go:build linux
 // +build linux
 
 package supervisor