feat: add file locking on go-cat add command

Author: srevinsaju

go.mod

@@ -8,6 +8,7 @@ require (
 	github.com/go-git/go-billy/v5 v5.3.1
 	github.com/go-git/go-git/v5 v5.4.2
 	github.com/hashicorp/terraform-plugin-sdk/v2 v2.13.0
+	github.com/juju/fslock v0.0.0-20160525022230-4d5c94c67b4b
 	github.com/urfave/cli/v2 v2.4.0
 	github.com/withmandala/go-log v0.1.0
 )

go.sum

@@ -152,6 +152,8 @@ github.com/jessevdk/go-flags v1.5.0/go.mod h1:Fw0T6WPc1dYxT4mKEZRfG5kJhaTDP9pj1c
 github.com/jhump/protoreflect v1.6.0/go.mod h1:eaTn3RZAmMBcV0fifFvlm6VHNz3wSkYyXYWUh7ymB74=
 github.com/jtolds/gls v4.20.0+incompatible h1:xdiiI2gbIgH/gLH7ADydsJ1uDOEzR8yvV7C0MuV77Wo=
 github.com/jtolds/gls v4.20.0+incompatible/go.mod h1:QJZ7F/aHp+rZTRtaJ1ow/lLfFfVYBRgL+9YlvaHOwJU=
+github.com/juju/fslock v0.0.0-20160525022230-4d5c94c67b4b h1:FQ7+9fxhyp82ks9vAuyPzG0/vVbWwMwLJ+P6yJI5FN8=
+github.com/juju/fslock v0.0.0-20160525022230-4d5c94c67b4b/go.mod h1:HMcgvsgd0Fjj4XXDkbjdmlbI505rUPBs6WBMYg2pXks=
 github.com/kevinburke/ssh_config v0.0.0-20201106050909-4977a11b4351/go.mod h1:CT57kijsi8u/K/BOFA39wgDQJ9CxiF4nAY/ojJ6r6mM=
 github.com/kevinburke/ssh_config v1.2.0 h1:x584FjTGwHzMwvHx18PXxbBVzfnxogHaAReU4gf13a4=
 github.com/kevinburke/ssh_config v1.2.0/go.mod h1:CT57kijsi8u/K/BOFA39wgDQJ9CxiF4nAY/ojJ6r6mM=

ops/add.go

@@ -2,17 +2,23 @@ package ops
 
 import (
 	"encoding/json"
+	"github.com/juju/fslock"
 	"gitlab.com/sorcero/community/go-cat/infrastructure"
 	"gitlab.com/sorcero/community/go-cat/internal/helpers"
 	"gitlab.com/sorcero/community/go-cat/meta"
-	"io/ioutil"
 	"os"
+	"time"
 )
 
 func AddWithDbName(infra *infrastructure.Metadata, queueDb string) error {
 	infraMeta := &infrastructure.MetadataGroup{}
+	lock := fslock.New(queueDb + ".lock")
+	err := lock.LockWithTimeout(time.Hour * 1)
+	if err != nil {
+		panic(err)
+	}
 	if helpers.CheckFileExists(queueDb) {
-		data, err := ioutil.ReadFile(queueDb)
+		data, err := os.ReadFile(queueDb)
 		if err != nil {
 			return err
 		}
@@ -21,7 +27,7 @@ func AddWithDbName(infra *infrastructure.Metadata, queueDb string) error {
 			return err
 		}
 	}
-	infraMeta, err := infraMeta.Add(infra)
+	infraMeta, err = infraMeta.Add(infra)
 	if err != nil {
 		return err
 	}
@@ -33,6 +39,10 @@ func AddWithDbName(infra *infrastructure.Metadata, queueDb string) error {
 	if err != nil {
 		return err
 	}
+	err = lock.Unlock()
+	if err != nil {
+		panic(err)
+	}
 
 	return nil
 }