Method OpenRuntimeClient

cli/pkg/cmdutil/helper.go:470–511

OpenRuntimeClient opens a client for the production deployment for the given project. If local is true, it connects to the locally running runtime instead of the deployed project's runtime. It returns the runtime client and instance ID for the project.

(ctx context.Context, org, project, branch string, local bool)

// If local is true, it connects to the locally running runtime instead of the deployed project's runtime.
// It returns the runtime client and instance ID for the project.
func (h *Helper) OpenRuntimeClient(ctx context.Context, org, project, branch string, local bool) (*runtimeclient.Client, string, error) {
	var host, instanceID, jwt string
	if local {
		// This is the default port that Rill localhost uses for gRPC.
		// TODO: In the future, we should capture the gRPC port in ~/.rill and use it here.
		host = "http://localhost:49009"
		instanceID = "default"
	} else {
		adm, err := h.Client()
		if err != nil {
			return nil, "", err
		}

		proj, err := adm.GetProject(ctx, &adminv1.GetProjectRequest{
			Org:     org,
			Project: project,
			Branch:  branch,
		})
		if err != nil {
			return nil, "", err
		}

		depl := proj.Deployment
		if depl == nil {
			return nil, "", fmt.Errorf("project %q is not currently deployed", project)
		}
		if depl.Status != adminv1.DeploymentStatus_DEPLOYMENT_STATUS_RUNNING {
			return nil, "", fmt.Errorf("deployment status not RUNNING: %s", depl.Status.String())
		}

		host = depl.RuntimeHost
		instanceID = depl.RuntimeInstanceId
		jwt = proj.Jwt
	}

	rt, err := runtimeclient.New(host, jwt)
	if err != nil {
		return nil, "", fmt.Errorf("failed to connect to runtime: %w", err)
	}

	return rt, instanceID, nil
}

func (h *Helper) GitHelper(org, project, localPath string) *GitHelper {
	h.gitHelperMu.Lock()