Function PullVars

cli/cmd/env/pull.go:49–131

(ctx context.Context, ch *cmdutil.Helper, projectPath, projectName, environment string, warnForNoVars bool)

}

func PullVars(ctx context.Context, ch *cmdutil.Helper, projectPath, projectName, environment string, warnForNoVars bool) error {
	// Parse and verify the project directory
	repo, instanceID, err := cmdutil.RepoForProjectPath(projectPath)
	if err != nil {
		return err
	}
	p, err := parser.Parse(ctx, repo, instanceID, "prod", "duckdb", true)
	if err != nil {
		return fmt.Errorf("failed to parse project: %w", err)
	}
	if p.RillYAML == nil {
		return fmt.Errorf("not a valid Rill project (missing a rill.yaml file)")
	}

	// Find the cloud project name
	if projectName == "" {
		projectName, err = ch.InferProjectName(ctx, projectPath, "use --project to specify the name")
		if err != nil {
			return err
		}
	}
	client, err := ch.Client()
	if err != nil {
		return err
	}
	res, err := client.GetProjectVariables(ctx, &adminv1.GetProjectVariablesRequest{
		Org:                ch.Org,
		Project:            projectName,
		Environment:        environment,
		ForAllEnvironments: environment == "",
	})
	if err != nil {
		return err
	}

	// new vars from the cloud
	newVars := groupVariablesByEnv(res)

	// existing vars from the .env files in the project
	currentVars := p.GetDotEnvPerEnvironment()

	// If variables for every environment are exactly the same as what's in the .env file, skip writing and warn the user
	equal := true
	for env, resVars := range newVars {
		if !maps.Equal(resVars, currentVars[env]) {
			equal = false
			break
		}
	}

	if equal && warnForNoVars {
		if len(res.Variables) == 0 {
			ch.Printf("No cloud credentials found for project %q.\n", projectName)
		} else {
			ch.Printf("Local .env file is already up to date with cloud credentials.\n")
		}
		return nil
	}