salvacybersec/CodeNomad
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ignore expected workspace stops when showing disconnect modal

Browse Source
This commit is contained in:
Shantur Rathore
2025-11-23 19:17:53 +00:00
parent 841b9daa1f
commit 48a16a6702
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/server/src/workspaces/instance-events.ts
View File

@@ -24,8 +24,8 @@ export class InstanceEventBridge {
constructor(private readonly options: InstanceEventBridgeOptions) { constructor(private readonly options: InstanceEventBridgeOptions) {
const bus = this.options.eventBus const bus = this.options.eventBus
bus.on("workspace.started", (event) => this.startStream(event.workspace.id)) bus.on("workspace.started", (event) => this.startStream(event.workspace.id))
bus.on("workspace.stopped", (event) => this.stopStream(event.workspaceId)) bus.on("workspace.stopped", (event) => this.stopStream(event.workspaceId, "workspace stopped"))
bus.on("workspace.error", (event) => this.stopStream(event.workspace.id)) bus.on("workspace.error", (event) => this.stopStream(event.workspace.id, "workspace error"))
} }
shutdown() { shutdown() {
@@ -59,14 +59,14 @@ export class InstanceEventBridge {
this.streams.set(workspaceId, { controller, task }) this.streams.set(workspaceId, { controller, task })
} }
private stopStream(workspaceId: string) { private stopStream(workspaceId: string, reason?: string) {
const active = this.streams.get(workspaceId) const active = this.streams.get(workspaceId)
if (!active) { if (!active) {
return return
} }
active.controller.abort() active.controller.abort()
this.streams.delete(workspaceId) this.streams.delete(workspaceId)
this.publishStatus(workspaceId, "disconnected") this.publishStatus(workspaceId, "disconnected", reason)
} }
private async runStream(workspaceId: string, signal: AbortSignal) { private async runStream(workspaceId: string, signal: AbortSignal) {

3
packages/ui/src/lib/sse-manager.ts
View File

@@ -59,6 +59,9 @@ class SSEManager {
const payload = event as InstanceStatusPayload const payload = event as InstanceStatusPayload
this.updateConnectionStatus(payload.instanceId, payload.status) this.updateConnectionStatus(payload.instanceId, payload.status)
if (payload.status === "disconnected") { if (payload.status === "disconnected") {
if (payload.reason === "workspace stopped") {
return
}
const reason = payload.reason ?? "Instance disconnected" const reason = payload.reason ?? "Instance disconnected"
void this.onConnectionLost?.(payload.instanceId, reason) void this.onConnectionLost?.(payload.instanceId, reason)
} }