Dev

cmd/cli/apply.go

@@ -8,7 +8,7 @@ import (
 )
 
 func init() {
-	applyCmd.Flags().StringP("file", "f", ".", "Path to manifest file")
+	applyCmd.Flags().StringP("file", "f", ".", "Path to manifests file")
 	rootCmd.AddCommand(applyCmd)
 }
 
@@ -27,16 +27,17 @@ var applyCmd = &cobra.Command{
 		ui.Printf("Applying manifests from: %s", file)
 		ui.Spinner(true, "Loading manifests")
 
-		mans, err := loader.LoadManifestsFromDir(file)
+		loadedMans, _, err := loader.LoadManifests(file)
 		if err != nil {
 			ui.Spinner(false)
 			ui.Errorf("Failed to load manifests: %s", err.Error())
 			return
 		}
 
+		ui.Spinner(false)
 		ui.Spinner(true, "Saving manifests...")
 
-		if err := store.SaveManifests(mans...); err != nil {
+		if err := store.Save(loadedMans...); err != nil {
 			ui.Error("Failed to save manifests: " + err.Error())
 			ui.Spinner(false)
 			return

cmd/cli/cleanup.go

@@ -0,0 +1,77 @@
+package cli
+
+import (
+	"fmt"
+
+	"github.com/apiqube/cli/internal/core/store"
+	"github.com/apiqube/cli/ui"
+	"github.com/spf13/cobra"
+)
+
+const keepVersionDefault = 5
+
+var cleanupCmd = &cobra.Command{
+	Use:   "cleanup [ID]",
+	Short: "Cleanup old manifest versions by its id",
+	Long: fmt.Sprintf("Delete all versions of the manifest,"+
+		"\nleaving only the latest specified."+
+		"\nBy default, the last keep amount is %d", keepVersionDefault),
+	SilenceErrors: true,
+	SilenceUsage:  true,
+	RunE: func(cmd *cobra.Command, args []string) error {
+		opts, err := parseCleanUpFlags(cmd, args)
+		if err != nil {
+			return err
+		}
+
+		keep := opts.Keep
+		if keep <= 0 {
+			keep = keepVersionDefault
+		}
+
+		ui.Spinner(true, "Cleaning up...")
+		if err = store.CleanupOldVersions(opts.ManifestID, keep); err != nil {
+			ui.Spinner(false)
+			ui.Errorf("Failed to cleanup old versions: %v", err)
+		}
+
+		ui.Spinner(false)
+		ui.Successf("Successfully cleaned up %v to last %d versions", opts.ManifestID, keep)
+		return nil
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(cleanupCmd)
+	cleanupCmd.Flags().IntP("keep", "k", keepVersionDefault, "Number of last versions to keep")
+}
+
+type CleanUpOptions struct {
+	ManifestID string
+	Keep       int
+}
+
+func parseCleanUpFlags(cmd *cobra.Command, args []string) (*CleanUpOptions, error) {
+	opts := &CleanUpOptions{}
+
+	if len(args) == 0 {
+		return nil, fmt.Errorf("manifest ID is required")
+	}
+
+	opts.ManifestID = args[0]
+	var err error
+	var keep int
+
+	if cmd.Flags().Changed("keep") {
+		keep, err = cmd.Flags().GetInt("keep")
+		if err != nil {
+			return nil, fmt.Errorf("invalid keep value: %w", err)
+		}
+		if keep < 1 {
+			return nil, fmt.Errorf("keep value must be positive")
+		}
+		opts.Keep = keep
+	}
+
+	return opts, nil
+}

cmd/cli/rollback.go

@@ -0,0 +1,74 @@
+package cli
+
+import (
+	"fmt"
+
+	"github.com/apiqube/cli/internal/core/store"
+	"github.com/apiqube/cli/ui"
+	"github.com/spf13/cobra"
+)
+
+var rollbackCmd = &cobra.Command{
+	Use:   "rollback [ID]",
+	Short: "Rollback to previous manifest version",
+	Long: fmt.Sprint("Rollback to specific version of manifest." +
+		"\nIf version is not specified, rolls back to previous one."),
+	Args: cobra.ExactArgs(1),
+	Run: func(cmd *cobra.Command, args []string) {
+		opts, err := parseRollbackFlags(cmd, args)
+		if err != nil {
+			return
+		}
+
+		targetVersion := opts.Version
+		if targetVersion <= 0 {
+			targetVersion = 1
+		}
+
+		ui.Spinner(true, "Rolling back")
+		if err = store.Rollback(opts.ManifestID, targetVersion); err != nil {
+			ui.Spinner(false, "Failed to rollback")
+			ui.Errorf("Error rolling back to previous version: %s", err)
+			return
+		}
+
+		ui.Spinner(false)
+		ui.Successf("Successfully rolled back %s to version %d\n", opts.ManifestID, targetVersion)
+	},
+}
+
+func init() {
+	rollbackCmd.Flags().IntP("version", "v", 0, "Target version number (defaults to previous version)")
+
+	rootCmd.AddCommand(rollbackCmd)
+}
+
+type RollbackOptions struct {
+	ManifestID string
+	Version    int
+}
+
+func parseRollbackFlags(cmd *cobra.Command, args []string) (*RollbackOptions, error) {
+	opts := &RollbackOptions{}
+
+	if len(args) == 0 {
+		return nil, fmt.Errorf("manifest ID is required")
+	}
+
+	opts.ManifestID = args[0]
+	var err error
+	var ver int
+
+	if cmd.Flags().Changed("version") {
+		ver, err = cmd.Flags().GetInt("version")
+		if err != nil {
+			return nil, fmt.Errorf("invalid version: %w", err)
+		}
+		if ver < 1 {
+			return nil, fmt.Errorf("version must be positive")
+		}
+		opts.Version = ver
+	}
+
+	return opts, nil
+}

cmd/cli/root.go

@@ -12,7 +12,3 @@ var rootCmd = &cobra.Command{
 func Execute() {
 	cobra.CheckErr(rootCmd.Execute())
 }
-
-func init() {
-	rootCmd.AddCommand(versionCmd)
-}