Function pollDeploymentStatus

cli/cmd/project/deployment/create.go:86–134

pollDeploymentStatus polls the deployment status until it's either running or errored, then prints the result

(ctx context.Context, client adminv1.AdminServiceClient, ch *cmdutil.Helper, deploymentID, project, branch, environment string)

// pollDeploymentStatus polls the deployment status until it's either running or errored, then prints the result
func pollDeploymentStatus(ctx context.Context, client adminv1.AdminServiceClient, ch *cmdutil.Helper, deploymentID, project, branch, environment string) error {
	ticker := time.NewTicker(5 * time.Second)
	defer ticker.Stop()

	for {
		select {
		case <-ctx.Done():
			return ctx.Err()
		case <-ticker.C:
			ch.Printf(".")

			// Fetch the deployment status using ListDeployments filtered by branch
			resp, err := client.ListDeployments(ctx, &adminv1.ListDeploymentsRequest{
				Org:         ch.Org,
				Project:     project,
				Environment: environment,
				Branch:      branch,
			})
			if err != nil {
				return err
			}

			// Find the deployment with matching ID - usually there's only one per branch
			var deployment *adminv1.Deployment
			for _, d := range resp.Deployments {
				if d.Id == deploymentID {
					deployment = d
					break
				}
			}

			if deployment == nil {
				return fmt.Errorf("deployment not found")
			}

			// Check if deployment is in a terminal state and print result
			switch deployment.Status {
			case adminv1.DeploymentStatus_DEPLOYMENT_STATUS_RUNNING:
				ch.PrintfSuccess("\n\nRuntime provisioned successfully!\n\n")
				ch.Printf("Runtime Host: %s\n", deployment.RuntimeHost)
				return nil
			case adminv1.DeploymentStatus_DEPLOYMENT_STATUS_ERRORED:
				ch.Printf("\n\n")
				return fmt.Errorf("runtime provisioning failed: %s", deployment.StatusMessage)
			}
			// Continue polling for other statuses (PENDING, UPDATING, etc.)
		}
	}
}