feat: add support for providing queue db file name in 'gocat push' subcommand

Author: srevinsaju

cmd/go-cat/cli.go

@@ -45,7 +45,13 @@ func catInfrastructureCliContext(context *cli.Context) error {
 
 func pushInfrastructureCliContext(context *cli.Context) error {
 	o := func() error {
-		err := ops.Push(config.NewGlobalConfigFromCliContext(context))
+		var err error
+		if context.String("queue") == "" {
+			err = ops.Push(config.NewGlobalConfigFromCliContext(context))
+		} else {
+			err = ops.PushWithDbQueue(config.NewGlobalConfigFromCliContext(context), context.String("queue"))
+		}
+
 		if err != nil {
 			fmt.Println(err)
 			fmt.Println("retrying...")

cmd/go-cat/main.go

@@ -36,6 +36,9 @@ func main() {
 		&cli.StringFlag{Name: "monitoring-links", Usage: "Multiple HTTP URLs of the monitoring dashboard of the servide, separated by comma"},
 		&cli.StringFlag{Name: "parameters", Usage: "Additional parameters"},
 	}
+	queueFlags := []cli.Flag{
+		&cli.StringFlag{Name: "queue", Required: false, Usage: "Specifies a file path to store the queue in."},
+	}
 	app := &cli.App{
 		Name:  "go-cat",
 		Usage: "CLI tool to have an overview of Infrastructure, as an API as well as Markdown",
@@ -53,16 +56,14 @@ func main() {
 				Usage:  "Add infrastructure to queue",
 				Action: addInfrastructureCliContext,
 
-				Flags: append(infraFlags,
-					&cli.StringFlag{Name: "queue", Required: false, Usage: "Specifies a file path to store the queue in."},
-				),
+				Flags: append(infraFlags, queueFlags...),
 			},
 			{
 				Name:   "push",
 				Usage:  "Push changes from infrastructure queue to git",
 				Action: pushInfrastructureCliContext,
 
-				Flags: gitFlags,
+				Flags: append(gitFlags, queueFlags...),
 			},
 			{
 				Name:   "cat",

ops/push.go

@@ -11,20 +11,24 @@ import (
 	"gitlab.com/sorcero/community/go-cat/meta"
 	"gitlab.com/sorcero/community/go-cat/parser"
 	"gitlab.com/sorcero/community/go-cat/storage"
-	"io/ioutil"
 	"os"
 )
 
 // Push pushes all the infrastructure from queue
 func Push(cfg config.GlobalConfig) error {
+	queueDB := meta.QueueDbName
+	return PushWithDbQueue(cfg, queueDB)
+}
+
+func PushWithDbQueue(cfg config.GlobalConfig, queueDB string) error {
 	repo, fs, err := storage.Clone(cfg)
 	if err != nil {
 		return err
 	}
 
 	infraMetaQueue := &infrastructure.MetadataGroup{}
-	if helpers.CheckFileExists(meta.QueueDbName) {
-		data, err := ioutil.ReadFile(meta.QueueDbName)
+	if helpers.CheckFileExists(queueDB) {
+		data, err := os.ReadFile(queueDB)
 		if err != nil {
 			return err
 		}