fix status and use devplane as source of truth

Makefile

@@ -42,11 +42,9 @@ ifdef env
 ifeq ($(env),local-stack)
 	@echo 'export BREV_API_URL="http://localhost:8080"' >> brev
 	@echo 'export BREV_PUBLIC_API_URL="http://localhost:8081"' >> brev
-	@echo 'export BREV_GRPC_URL="localhost:8081"' >> brev
 else
 	@echo 'export BREV_API_URL="https://bd.$(env).brev.nvidia.com"' >> brev
 	@echo 'export BREV_PUBLIC_API_URL="https://api.$(env).brev.nvidia.com"' >> brev
-	@echo 'export BREV_GRPC_URL="api.$(env).brev.nvidia.com:443"' >> brev
 endif
 	@echo 'exec "$$(cd "$$(dirname "$$0")" && pwd)/brev-local" "$$@"' >> brev
 	@chmod +x brev

go.mod

@@ -3,8 +3,8 @@ module github.com/brevdev/brev-cli
 go 1.25.0
 
 require (
-	buf.build/gen/go/brevdev/devplane/connectrpc/go v1.21.0-20260915224432-6a5d0c858507.1
-	buf.build/gen/go/brevdev/devplane/protocolbuffers/go v1.36.12-20260915224432-6a5d0c858507.2
+	buf.build/gen/go/brevdev/devplane/connectrpc/go v1.21.0-20261002013339-6f4f902cdf2d.1
+	buf.build/gen/go/brevdev/devplane/protocolbuffers/go v1.36.12-20261002013339-6f4f902cdf2d.2
 	connectrpc.com/connect v1.21.0
 	github.com/NVIDIA/go-nvml v0.13.0-1
 	github.com/alessio/shellescape v1.4.1

go.sum

@@ -1,7 +1,7 @@
-buf.build/gen/go/brevdev/devplane/connectrpc/go v1.21.0-20260915224432-6a5d0c858507.1 h1:CFXTDUzEoMYQzJXAG+hnMO5Cs6h3zVq734k/VnyWuCM=
-buf.build/gen/go/brevdev/devplane/connectrpc/go v1.21.0-20260915224432-6a5d0c858507.1/go.mod h1:dS34xJi+QXqWDdKwUHTBfzkcbQFNK3u4UH3F3L6izx0=
-buf.build/gen/go/brevdev/devplane/protocolbuffers/go v1.36.12-20260915224432-6a5d0c858507.2 h1:CjGsO8kcUR0YcKzjKy/L5m2jIhnNW6VW6ArYliA2p6o=
-buf.build/gen/go/brevdev/devplane/protocolbuffers/go v1.36.12-20260915224432-6a5d0c858507.2/go.mod h1:SBVLUYGc/4vgMlhOJL5SkwIrSh/FL9EEimlpI8zQSXo=
+buf.build/gen/go/brevdev/devplane/connectrpc/go v1.21.0-20261002013339-6f4f902cdf2d.1 h1:6YxQ+ovFXTH0qhavCXrRAsa/+CgyJviIBBPvuar5fAU=
+buf.build/gen/go/brevdev/devplane/connectrpc/go v1.21.0-20261002013339-6f4f902cdf2d.1/go.mod h1:0EoTlhUve4UaoJRDO8DXLA79x0HYGLnFchd8ITsIn/4=
+buf.build/gen/go/brevdev/devplane/protocolbuffers/go v1.36.12-20261002013339-6f4f902cdf2d.2 h1:FoyCt/oxRt8ZFE4JmtAclKTlGOT7zFbyyhY/xeEmyjQ=
+buf.build/gen/go/brevdev/devplane/protocolbuffers/go v1.36.12-20261002013339-6f4f902cdf2d.2/go.mod h1:SBVLUYGc/4vgMlhOJL5SkwIrSh/FL9EEimlpI8zQSXo=
 buf.build/gen/go/brevdev/protoc-gen-gotag/protocolbuffers/go v1.36.12-20220906235457-8b4922735da5.2 h1:W5SVs96P8ZgLElYzL93rJu+S+XmkdGQSaVWzPvR5lvg=
 buf.build/gen/go/brevdev/protoc-gen-gotag/protocolbuffers/go v1.36.12-20220906235457-8b4922735da5.2/go.mod h1:SacJAYqnICCQAsBA46cSA/hxhqhxYkiYzseucf6/fhQ=
 cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=

pkg/cmd/deregister/deregister_test.go

@@ -19,6 +19,7 @@ import (
 	"github.com/brevdev/brev-cli/pkg/entity"
 	"github.com/brevdev/brev-cli/pkg/externalnode"
 	"github.com/brevdev/brev-cli/pkg/sshcert"
+	"github.com/brevdev/brev-cli/pkg/store"
 	"github.com/brevdev/brev-cli/pkg/sudo"
 	"github.com/brevdev/brev-cli/pkg/terminal"
 )
@@ -141,7 +142,7 @@ type mockNodeClientFactory struct {
 }
 
 func (m mockNodeClientFactory) NewNodeClient(provider externalnode.TokenProvider, _ string) nodev1connect.ExternalNodeServiceClient {
-	return register.NewNodeServiceClient(provider, m.serverURL)
+	return store.NewDevPlaneClient(provider, m.serverURL).ExternalNodes
 }
 
 type mockSSHKeyRemover struct {

pkg/cmd/enablessh/enablessh_test.go

@@ -17,6 +17,7 @@ import (
 	"github.com/brevdev/brev-cli/pkg/cmd/register"
 	"github.com/brevdev/brev-cli/pkg/entity"
 	"github.com/brevdev/brev-cli/pkg/externalnode"
+	"github.com/brevdev/brev-cli/pkg/store"
 	"github.com/brevdev/brev-cli/pkg/terminal"
 )
 
@@ -222,7 +223,7 @@ func Test_RemoveAuthorizedKey_DoesNotRemoveOtherBrevKeys(t *testing.T) {
 type mockNodeClientFactory struct{ serverURL string }
 
 func (m mockNodeClientFactory) NewNodeClient(provider externalnode.TokenProvider, _ string) nodev1connect.ExternalNodeServiceClient {
-	return register.NewNodeServiceClient(provider, m.serverURL)
+	return store.NewDevPlaneClient(provider, m.serverURL).ExternalNodes
 }
 
 type mockEnableSSHStore struct {

pkg/cmd/gpucreate/gpucreate.go

@@ -3,6 +3,7 @@ package gpucreate
 
 import (
 	"encoding/json"
+	"errors"
 	"fmt"
 	"io"
 	"math/rand/v2"
@@ -25,6 +26,7 @@ import (
 	"github.com/brevdev/brev-cli/pkg/cmd/util"
 	"github.com/brevdev/brev-cli/pkg/config"
 	"github.com/brevdev/brev-cli/pkg/entity"
+	"github.com/brevdev/brev-cli/pkg/environment"
 	breverrors "github.com/brevdev/brev-cli/pkg/errors"
 	"github.com/brevdev/brev-cli/pkg/featureflag"
 	"github.com/brevdev/brev-cli/pkg/names"
@@ -109,7 +111,7 @@ type GPUCreateStore interface {
 	GetActiveOrganizationOrDefault() (*entity.Organization, error)
 	GetAuthTokens() (*entity.AuthTokens, error)
 	GetCurrentUser() (*entity.User, error)
-	GetWorkspace(workspaceID string) (*entity.Workspace, error)
+	GetEnvironmentStatus(environmentID string) (environment.Status, error)
 	CreateWorkspace(organizationID string, options *store.CreateWorkspacesOptions) (*entity.Workspace, error)
 	DeleteWorkspace(workspaceID string) (*entity.Workspace, error)
 	GetAllInstanceTypesWithCloudCreds(orgID string) (*gpusearch.AllInstanceTypesResponse, error)
@@ -1130,25 +1132,48 @@ func (c *createContext) cleanupExtraInstances(workspaces []*entity.Workspace) []
 	return workspaces[:c.opts.Count]
 }
 
-// waitForInstances waits for all instances to be ready
-func (c *createContext) waitForInstances(workspaces []*entity.Workspace) {
+// errReadyTimeout marks a pollUntilReady timeout. It is non-fatal: waiting is a
+// convenience and the instance may still finish provisioning after the window.
+var errReadyTimeout = errors.New("timeout waiting for instance to be ready")
+
+type workspaceFailedError struct{ message string }
+
+func (e *workspaceFailedError) Error() string { return e.message }
+
+// waitForInstances blocks until each workspace is ready. It returns an error
+// when any instance reaches a terminal failure so the command exits non-zero;
+// timeouts and transient polling errors are reported but remain non-fatal.
+func (c *createContext) waitForInstances(workspaces []*entity.Workspace) error {
 	if c.opts.Detached {
-		return
+		return nil
 	}
 
 	c.logf("\nWaiting for instance(s) to be ready...\n")
 	c.logf("You can safely ctrl+c to exit\n")
 
+	var failed []string
 	for _, ws := range workspaces {
 		err := c.pollUntilReady(ws.ID)
-		if err != nil {
-			if strings.Contains(err.Error(), "timeout waiting") {
-				c.logf("  %s: Timeout waiting for ready state\n", ws.Name)
-			} else {
-				c.logf("  %s: %s\n", ws.Name, c.colorize(err.Error(), c.t.Red))
-			}
+		var failedErr *workspaceFailedError
+		switch {
+		case err == nil:
+		case errors.Is(err, errReadyTimeout):
+			c.logf("  %s: Timeout waiting for ready state\n", ws.Name)
+		case errors.As(err, &failedErr):
+			c.logf("  %s: %s\n", ws.Name, c.colorize(err.Error(), c.t.Red))
+			failed = append(failed, err.Error())
+		default:
+			c.logf("  %s: %s\n", ws.Name, c.colorize(err.Error(), c.t.Red))
 		}
 	}
+
+	if len(failed) > 0 {
+		return breverrors.NewValidationError(fmt.Sprintf(
+			"%d/%d instance(s) failed to become ready: %s",
+			len(failed), len(workspaces), strings.Join(failed, "; "),
+		))
+	}
+	return nil
 }
 
 // printSummary outputs the final creation summary
@@ -1230,7 +1255,9 @@ func RunGPUCreate(t *terminal.Terminal, gpuCreateStore GPUCreateStore, opts GPUC
 	}
 
 	successfulWorkspaces = ctx.cleanupExtraInstances(successfulWorkspaces)
-	ctx.waitForInstances(successfulWorkspaces)
+	if err := ctx.waitForInstances(successfulWorkspaces); err != nil {
+		return err
+	}
 	ctx.printSummary(successfulWorkspaces)
 
 	return nil
@@ -1613,27 +1640,35 @@ func (c *createContext) pollUntilReady(wsID string) error {
 	deadline := time.Now().Add(c.opts.Timeout)
 
 	for time.Now().Before(deadline) {
-		ws, err := c.store.GetWorkspace(wsID)
+		status, err := c.store.GetEnvironmentStatus(wsID)
 		if err != nil {
 			return breverrors.WrapAndTrace(err)
 		}
 
-		if ws.Status == entity.Running {
-			c.logf("  %s: %s\n", ws.Name, c.colorize("Ready", c.t.Green))
-			return nil
+		name := status.Name
+		if name == "" {
+			name = wsID
 		}
 
-		if ws.Status == entity.Failure {
-			if ws.StatusMessage != "" {
-				return breverrors.NewValidationError(fmt.Sprintf("instance %s failed: %s", ws.Name, ws.StatusMessage))
-			}
-			return breverrors.NewValidationError(fmt.Sprintf("instance %s failed", ws.Name))
+		switch {
+		case status.Ready:
+			c.logf("  %s: %s\n", name, c.colorize("Ready", c.t.Green))
+			return nil
+		case status.Failed:
+			return &workspaceFailedError{message: instanceFailureMessage(name, status.Message)}
 		}
 
 		time.Sleep(5 * time.Second)
 	}
 
-	return breverrors.NewValidationError("timeout waiting for instance to be ready")
+	return errReadyTimeout
+}
+
+func instanceFailureMessage(name, statusMessage string) string {
+	if statusMessage != "" {
+		return fmt.Sprintf("instance %s failed: %s", name, statusMessage)
+	}
+	return fmt.Sprintf("instance %s failed", name)
 }
 
 // displayConnectBreadCrumb shows connection instructions