bump to version v0.2.3

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "codenomad-workspace",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "codenomad-workspace",
-      "version": "0.2.2",
+      "version": "0.2.3",
       "dependencies": {
         "7zip-bin": "^5.2.0",
         "google-auth-library": "^10.5.0"
@@ -8613,7 +8613,7 @@
     },
     "packages/electron-app": {
       "name": "@neuralnomads/codenomad-electron-app",
-      "version": "0.2.2",
+      "version": "0.2.3",
       "dependencies": {
         "@codenomad/ui": "file:../ui",
         "@neuralnomads/codenomad": "file:../server"
@@ -8641,7 +8641,7 @@
     },
     "packages/server": {
       "name": "@neuralnomads/codenomad",
-      "version": "0.2.2",
+      "version": "0.2.3",
       "dependencies": {
         "@fastify/cors": "^8.5.0",
         "@fastify/reply-from": "^9.8.0",
@@ -8680,14 +8680,14 @@
     },
     "packages/tauri-app": {
       "name": "@codenomad/tauri-app",
-      "version": "0.2.2",
+      "version": "0.2.3",
       "devDependencies": {
         "@tauri-apps/cli": "^2.9.4"
       }
     },
     "packages/ui": {
       "name": "@codenomad/ui",
-      "version": "0.2.2",
+      "version": "0.2.3",
       "dependencies": {
         "@git-diff-view/solid": "^0.0.8",
         "@kobalte/core": "0.13.11",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "codenomad-workspace",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "private": true,
   "description": "CodeNomad monorepo workspace",
   "workspaces": {

packages/electron-app/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@neuralnomads/codenomad-electron-app",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "description": "CodeNomad - AI coding assistant",
   "author": {
     "name": "Neural Nomads",

packages/server/package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "@neuralnomads/codenomad",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "@neuralnomads/codenomad",
-      "version": "0.2.2",
+      "version": "0.2.3",
       "dependencies": {
         "@fastify/cors": "^8.5.0",
         "commander": "^12.1.0",

packages/server/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@neuralnomads/codenomad",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "description": "CodeNomad Server",
   "author": {
     "name": "Neural Nomads",

packages/server/src/workspaces/instance-events.ts

@@ -1,10 +1,12 @@
-import { fetch } from "undici"
+import { Agent, fetch } from "undici"
+import { Agent as UndiciAgent } from "undici"
 import { EventBus } from "../events/bus"
 import { Logger } from "../logger"
 import { WorkspaceManager } from "./manager"
 import { InstanceStreamEvent, InstanceStreamStatus } from "../api-types"
 
 const INSTANCE_HOST = "127.0.0.1"
+const STREAM_AGENT = new UndiciAgent({ bodyTimeout: 0, headersTimeout: 0 })
 const RECONNECT_DELAY_MS = 1000
 
 interface InstanceEventBridgeOptions {
@@ -24,8 +26,8 @@ export class InstanceEventBridge {
   constructor(private readonly options: InstanceEventBridgeOptions) {
     const bus = this.options.eventBus
     bus.on("workspace.started", (event) => this.startStream(event.workspace.id))
-    bus.on("workspace.stopped", (event) => this.stopStream(event.workspaceId))
-    bus.on("workspace.error", (event) => this.stopStream(event.workspace.id))
+    bus.on("workspace.stopped", (event) => this.stopStream(event.workspaceId, "workspace stopped"))
+    bus.on("workspace.error", (event) => this.stopStream(event.workspace.id, "workspace error"))
   }
 
   shutdown() {
@@ -59,14 +61,14 @@ export class InstanceEventBridge {
     this.streams.set(workspaceId, { controller, task })
   }
 
-  private stopStream(workspaceId: string) {
+  private stopStream(workspaceId: string, reason?: string) {
     const active = this.streams.get(workspaceId)
     if (!active) {
       return
     }
     active.controller.abort()
     this.streams.delete(workspaceId)
-    this.publishStatus(workspaceId, "disconnected")
+    this.publishStatus(workspaceId, "disconnected", reason)
   }
 
   private async runStream(workspaceId: string, signal: AbortSignal) {
@@ -97,6 +99,7 @@ export class InstanceEventBridge {
     const response = await fetch(url, {
       headers: { Accept: "text/event-stream" },
       signal,
+      dispatcher: STREAM_AGENT,
     })
 
     if (!response.ok || !response.body) {

packages/tauri-app/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@codenomad/tauri-app",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "private": true,
   "scripts": {
     "dev": "tauri dev",

packages/ui/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@codenomad/ui",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "private": true,
   "type": "module",
   "scripts": {

packages/ui/src/lib/sse-manager.ts

@@ -58,8 +58,11 @@ class SSEManager {
     serverEvents.on("instance.eventStatus", (event) => {
       const payload = event as InstanceStatusPayload
       this.updateConnectionStatus(payload.instanceId, payload.status)
-      if (payload.status === "error") {
-        const reason = payload.reason ?? "Instance stream error"
+      if (payload.status === "disconnected") {
+        if (payload.reason === "workspace stopped") {
+          return
+        }
+        const reason = payload.reason ?? "Instance disconnected"
         void this.onConnectionLost?.(payload.instanceId, reason)
       }
     })