Added ExecutionState as struct that passes args and remote config to …

…Go code

cli/cmd/turbo/main.go

@@ -15,14 +15,14 @@ func main() {
 		os.Exit(1)
 	}
 
-	argsString := os.Args[1]
-	var args turbostate.ParsedArgsFromRust
-	err := json.Unmarshal([]byte(argsString), &args)
+	executionStateString := os.Args[1]
+	var executionState turbostate.ExecutionState
+	err := json.Unmarshal([]byte(executionStateString), &executionState)
 	if err != nil {
-		fmt.Printf("Error unmarshalling CLI args: %v\n Arg string: %v\n", err, argsString)
+		fmt.Printf("Error unmarshalling execution state: %v\n Execution state string: %v\n", err, executionStateString)
 		os.Exit(1)
 	}
 
-	exitCode := cmd.RunWithArgs(&args, turboVersion)
+	exitCode := cmd.RunWithExecutionState(&executionState, turboVersion)
 	os.Exit(exitCode)
 }

cli/internal/client/client.go

@@ -17,6 +17,7 @@ import (
 	"github.com/hashicorp/go-hclog"
 	"github.com/hashicorp/go-retryablehttp"
 	"github.com/vercel/turbo/cli/internal/ci"
+	"github.com/vercel/turbo/cli/internal/turbostate"
 )
 
 // APIClient is the main interface for making network requests to Vercel
@@ -47,14 +48,6 @@ func (c *APIClient) SetToken(token string) {
 	c.token = token
 }
 
-// RemoteConfig holds the authentication and endpoint details for the API client
-type RemoteConfig struct {
-	Token    string
-	TeamID   string
-	TeamSlug string
-	APIURL   string
-}
-
 // Opts holds values for configuring the behavior of the API client
 type Opts struct {
 	UsePreflight bool
@@ -65,7 +58,7 @@ type Opts struct {
 const ClientTimeout uint64 = 20
 
 // NewClient creates a new APIClient
-func NewClient(remoteConfig RemoteConfig, logger hclog.Logger, turboVersion string, opts Opts) *APIClient {
+func NewClient(remoteConfig turbostate.RemoteConfig, logger hclog.Logger, turboVersion string, opts Opts) *APIClient {
 	client := &APIClient{
 		baseURL:      remoteConfig.APIURL,
 		turboVersion: turboVersion,

cli/internal/client/client_test.go

@@ -12,6 +12,7 @@ import (
 
 	"github.com/google/uuid"
 	"github.com/hashicorp/go-hclog"
+	"github.com/vercel/turbo/cli/internal/turbostate"
 	"github.com/vercel/turbo/cli/internal/util"
 )
 
@@ -30,7 +31,7 @@ func Test_sendToServer(t *testing.T) {
 		}))
 	defer ts.Close()
 
-	remoteConfig := RemoteConfig{
+	remoteConfig := turbostate.RemoteConfig{
 		TeamSlug: "my-team-slug",
 		APIURL:   ts.URL,
 		Token:    "my-token",
@@ -85,7 +86,7 @@ func Test_PutArtifact(t *testing.T) {
 	defer ts.Close()
 
 	// Set up test expected values
-	remoteConfig := RemoteConfig{
+	remoteConfig := turbostate.RemoteConfig{
 		TeamSlug: "my-team-slug",
 		APIURL:   ts.URL,
 		Token:    "my-token",
@@ -111,7 +112,7 @@ func Test_PutWhenCachingDisabled(t *testing.T) {
 	defer ts.Close()
 
 	// Set up test expected values
-	remoteConfig := RemoteConfig{
+	remoteConfig := turbostate.RemoteConfig{
 		TeamSlug: "my-team-slug",
 		APIURL:   ts.URL,
 		Token:    "my-token",
@@ -138,7 +139,7 @@ func Test_FetchWhenCachingDisabled(t *testing.T) {
 	defer ts.Close()
 
 	// Set up test expected values
-	remoteConfig := RemoteConfig{
+	remoteConfig := turbostate.RemoteConfig{
 		TeamSlug: "my-team-slug",
 		APIURL:   ts.URL,
 		Token:    "my-token",

cli/internal/cmd/root.go

@@ -45,31 +45,31 @@ func initializeOutputFiles(helper *cmdutil.Helper, parsedArgs *turbostate.Parsed
 	return nil
 }
 
-// RunWithArgs runs turbo with the ParsedArgsFromRust that is passed from the Rust side.
-func RunWithArgs(args *turbostate.ParsedArgsFromRust, turboVersion string) int {
+// RunWithExecutionState runs turbo with the ParsedArgsFromRust that is passed from the Rust side.
+func RunWithExecutionState(executionState *turbostate.ExecutionState, turboVersion string) int {
 	util.InitPrintf()
 	// TODO: replace this with a context
 	signalWatcher := signals.NewWatcher()
-	helper := cmdutil.NewHelper(turboVersion, args)
+	helper := cmdutil.NewHelper(turboVersion, &executionState.CLIArgs)
 	ctx := context.Background()
 
-	err := initializeOutputFiles(helper, args)
+	err := initializeOutputFiles(helper, &executionState.CLIArgs)
 	if err != nil {
 		fmt.Printf("%v", err)
 		return 1
 	}
-	defer helper.Cleanup(args)
+	defer helper.Cleanup(&executionState.CLIArgs)
 
 	doneCh := make(chan struct{})
 	var execErr error
 	go func() {
-		command := args.Command
+		command := executionState.CLIArgs.Command
 		if command.Daemon != nil {
-			execErr = daemon.ExecuteDaemon(ctx, helper, signalWatcher, args)
+			execErr = daemon.ExecuteDaemon(ctx, helper, signalWatcher, executionState)
 		} else if command.Prune != nil {
-			execErr = prune.ExecutePrune(helper, args)
+			execErr = prune.ExecutePrune(helper, executionState)
 		} else if command.Run != nil {
-			execErr = run.ExecuteRun(ctx, helper, signalWatcher, args)
+			execErr = run.ExecuteRun(ctx, helper, signalWatcher, executionState)
 		} else {
 			execErr = fmt.Errorf("unknown command: %v", command)
 		}

cli/internal/cmdutil/cmdutil.go

@@ -74,12 +74,12 @@ func (h *Helper) Cleanup(cliConfig *turbostate.ParsedArgsFromRust) {
 	}
 }
 
-func (h *Helper) getUI(cliConfig *turbostate.ParsedArgsFromRust) cli.Ui {
+func (h *Helper) getUI(cliArgs *turbostate.ParsedArgsFromRust) cli.Ui {
 	colorMode := ui.GetColorModeFromEnv()
-	if cliConfig.GetNoColor() {
+	if cliArgs.NoColor {
 		colorMode = ui.ColorModeSuppressed
 	}
-	if cliConfig.GetColor() {
+	if cliArgs.Color {
 		colorMode = ui.ColorModeForced
 	}
 	return ui.BuildColoredUi(colorMode)
@@ -134,15 +134,15 @@ func NewHelper(turboVersion string, args *turbostate.ParsedArgsFromRust) *Helper
 
 // GetCmdBase returns a CmdBase instance configured with values from this helper.
 // It additionally returns a mechanism to set an error, so
-func (h *Helper) GetCmdBase(cliConfig *turbostate.ParsedArgsFromRust) (*CmdBase, error) {
+func (h *Helper) GetCmdBase(executionState *turbostate.ExecutionState) (*CmdBase, error) {
 	// terminal is for color/no-color output
-	terminal := h.getUI(cliConfig)
+	terminal := h.getUI(&executionState.CLIArgs)
 	// logger is configured with verbosity level using --verbosity flag from end users
 	logger, err := h.getLogger()
 	if err != nil {
 		return nil, err
 	}
-	cwdRaw, err := cliConfig.GetCwd()
+	cwdRaw := executionState.CLIArgs.CWD
 	if err != nil {
 		return nil, err
 	}
@@ -155,15 +155,7 @@ func (h *Helper) GetCmdBase(cliConfig *turbostate.ParsedArgsFromRust) (*CmdBase,
 	if err != nil {
 		return nil, err
 	}
-	repoConfig, err := config.ReadRepoConfigFile(config.GetRepoConfigPath(repoRoot), cliConfig)
-	if err != nil {
-		return nil, err
-	}
-	userConfig, err := config.ReadUserConfigFile(h.UserConfigPath, cliConfig)
-	if err != nil {
-		return nil, err
-	}
-	remoteConfig := repoConfig.GetRemoteConfig(userConfig.Token())
+	remoteConfig := executionState.RemoteConfig
 	if remoteConfig.Token == "" && ui.IsCI {
 		vercelArtifactsToken := os.Getenv("VERCEL_ARTIFACTS_TOKEN")
 		vercelArtifactsOwner := os.Getenv("VERCEL_ARTIFACTS_OWNER")
@@ -176,7 +168,7 @@ func (h *Helper) GetCmdBase(cliConfig *turbostate.ParsedArgsFromRust) (*CmdBase,
 	}
 
 	// Primacy: Arg > Env
-	timeout, err := cliConfig.GetRemoteCacheTimeout()
+	timeout, err := executionState.CLIArgs.GetRemoteCacheTimeout()
 	if err == nil {
 		h.clientOpts.Timeout = timeout
 	} else {
@@ -201,8 +193,6 @@ func (h *Helper) GetCmdBase(cliConfig *turbostate.ParsedArgsFromRust) (*CmdBase,
 		Logger:       logger,
 		RepoRoot:     repoRoot,
 		APIClient:    apiClient,
-		RepoConfig:   repoConfig,
-		UserConfig:   userConfig,
 		RemoteConfig: remoteConfig,
 		TurboVersion: h.TurboVersion,
 	}, nil
@@ -214,9 +204,7 @@ type CmdBase struct {
 	Logger       hclog.Logger
 	RepoRoot     turbopath.AbsoluteSystemPath
 	APIClient    *client.APIClient
-	RepoConfig   *config.RepoConfig
-	UserConfig   *config.UserConfig
-	RemoteConfig client.RemoteConfig
+	RemoteConfig turbostate.RemoteConfig
 	TurboVersion string
 }