Almost got state sync test working

Author: Olshansk

Makefile

@@ -142,7 +142,7 @@ install_cli_deps: ## Installs `helm`, `tilt` and the underlying `ci_deps`
 .PHONY: install_ci_deps
 install_ci_deps: ## Installs `protoc-gen-go`, `mockgen`, 'protoc-go-inject-tag' and other tools necessary for CI
 	go install "google.golang.org/protobuf/cmd/[email protected]" && protoc-gen-go --version
-	go install "github.com/golang/mock/mockgen@v1.6.0" && mockgen --version
+	go install "github.com/golang/mock/m	ockgen@v1.6.0" && mockgen --version
 	go install "github.com/favadi/protoc-go-inject-tag@latest"
 	go install "github.com/deepmap/oapi-codegen/cmd/[email protected]"
 

app/client/cli/debug.go

@@ -1,11 +1,15 @@
 package cli
 
 import (
+	"fmt"
+	"log"
 	"os"
+	"os/exec"
 	"time"
 
 	"github.com/manifoldco/promptui"
 	"github.com/spf13/cobra"
+	"golang.org/x/exp/slices"
 	"google.golang.org/protobuf/types/known/anypb"
 
 	"github.com/pokt-network/pocket/app/client/cli/helpers"
@@ -109,6 +113,29 @@ func newDebugSubCommands() []*cobra.Command {
 				})
 			},
 		},
+		{
+			Use:               "ScaleActor",
+			Aliases:           []string{"scale"},
+			Short:             "Scales the number of actors up or down",
+			Long:              "Scales the type of actor specified to the number provided",
+			Args:              cobra.ExactArgs(2),
+			PersistentPreRunE: helpers.P2PDependenciesPreRunE,
+			Run: func(cmd *cobra.Command, args []string) {
+				fmt.Println("OLSH ARGS", args)
+				actor := args[0]
+				numActors := args[1]
+				validActors := []string{"fishermen", "full_nodes", "servicers", "validators"}
+				if !slices.Contains(validActors, actor) {
+					logger.Global.Fatal().Msg("Invalid actor type provided")
+				}
+				sedCmd := exec.Command("sed", "-i", fmt.Sprintf("/%s:/,/count:/ s/count: [0-9]*/count: %s/", actor, numActors), "/usr/local/localnet_config.yaml")
+				// fmt.Println(sedCmd.String())
+				err := sedCmd.Run()
+				if err != nil {
+					log.Fatal(err)
+				}
+			},
+		},
 	}
 	return cmds
 }
@@ -223,9 +250,9 @@ func handleSelect(cmd *cobra.Command, selection string) {
 // - Ending the task too early before the debug client completes its task results in a lack of propagation of the message or retrieval of the result
 // TECHDEBT: There is likely an event based solution to this but it would require a lot more refactoring of the p2p module.
 func runWithSleep(task func()) {
-	time.Sleep(1 * time.Second)
+	time.Sleep(1000 * time.Millisecond)
 	task()
-	time.Sleep(1 * time.Second)
+	time.Sleep(1000 * time.Millisecond)
 }
 
 // broadcastDebugMessage broadcasts the debug message to the entire visible network.