Revert SSE implementation and update Docker upgrade script

Author: chriswritescode-dev

backend/src/routes/sse.ts

@@ -1,5 +1,5 @@
 import { Hono } from 'hono'
-import { streamSSE } from 'hono/streaming'
+import { stream } from 'hono/streaming'
 import { sseAggregator } from '../services/sse-aggregator'
 import { SSESubscribeSchema } from '@opencode-manager/shared/schemas'
 import { logger } from '../utils/logger'
@@ -15,32 +15,45 @@ export function createSSERoutes() {
     const directories = directoriesParam ? directoriesParam.split(',').filter(Boolean) : []
     const clientId = `client_${Date.now()}_${Math.random().toString(36).slice(2)}`
 
+    c.header('Content-Type', 'text/event-stream')
+    c.header('Cache-Control', 'no-cache, no-store, no-transform')
+    c.header('Connection', 'keep-alive')
     c.header('X-Accel-Buffering', 'no')
 
-    return streamSSE(c, async (stream) => {
+    return stream(c, async (writer) => {
+      const encoder = new TextEncoder()
+      const writeSSE = (event: string, data: string) => {
+        const lines = []
+        if (event) lines.push(`event: ${event}`)
+        lines.push(`data: ${data}`)
+        lines.push('')
+        lines.push('')
+        writer.write(encoder.encode(lines.join('\n')))
+      }
+
       const cleanup = sseAggregator.addClient(
         clientId,
-        async (event, data) => {
-          await stream.writeSSE({ event, data })
+        (event, data) => {
+          writeSSE(event, data)
         },
         directories
       )
 
-      const heartbeatInterval = setInterval(async () => {
+      const heartbeatInterval = setInterval(() => {
         try {
-          await stream.writeSSE({ event: 'heartbeat', data: JSON.stringify({ timestamp: Date.now() }) })
+          writeSSE('heartbeat', JSON.stringify({ timestamp: Date.now() }))
         } catch {
           clearInterval(heartbeatInterval)
         }
       }, HEARTBEAT_INTERVAL_MS)
 
-      stream.onAbort(() => {
+      writer.onAbort(() => {
         clearInterval(heartbeatInterval)
         cleanup()
       })
 
       try {
-        await stream.writeSSE({ event: 'connected', data: JSON.stringify({ clientId, directories, ...sseAggregator.getConnectionStatus() }) })
+        writeSSE('connected', JSON.stringify({ clientId, directories, ...sseAggregator.getConnectionStatus() }))
       } catch (err) {
         logger.error(`Failed to send SSE connected event for ${clientId}:`, err)
       }

scripts/docker-upgrade.sh

@@ -39,8 +39,8 @@ fi
 echo -e "${YELLOW}Stopping container...${NC}"
 $DOCKER_COMPOSE down
 
-echo -e "${YELLOW}Rebuilding image...${NC}"
-$DOCKER_COMPOSE build
+echo -e "${YELLOW}Rebuilding image with no cache...${NC}"
+$DOCKER_COMPOSE build --no-cache
 
 echo -e "${YELLOW}Starting container...${NC}"
 $DOCKER_COMPOSE up -d