refactor(opencode): stream events through the client and use the v2 config schema

backend/package.json

@@ -24,7 +24,6 @@
     "archiver": "^7.0.1",
     "better-auth": "^1.7.12",
     "croner": "^10.0.1",
-    "eventsource": "^4.1.0",
     "hono": "^4.13.13",
     "jsonc-parser": "^3.3.1",
     "web-push": "^3.6.7",
@@ -35,7 +34,6 @@
     "@types/archiver": "^7.0.0",
     "@types/better-sqlite3": "^7.6.13",
     "@types/bun": "latest",
-    "@types/eventsource": "^3.0.0",
     "@types/web-push": "^3.6.4",
     "@vitest/coverage-v8": "^3.2.4",
     "@vitest/ui": "^3.2.4",

backend/src/index.ts

@@ -84,7 +84,7 @@ import { RepoWorkspaceService } from './services/repo-workspace'
 import { createGitService } from './services/git/GitService'
 import { ScheduleWorktreeManager } from './services/schedule-worktree'
 import { migrateGlobalSkills } from './services/skills'
-import { installAssistantWorkspace } from './services/assistant-mode'
+import { installAssistantWorkspace, convertAssistantOpenCodeConfigToV2 } from './services/assistant-mode'
 import { detectSandboxCapability } from './services/sandbox/capability'
 import { SandboxRuntimeService, stopSandboxesOnShutdown } from './services/sandbox/runtime'
 import { getOpenCodeImportStatus, syncOpenCodeImport } from './services/opencode-import'
@@ -359,12 +359,18 @@ if (ENV.VAPID.PUBLIC_KEY && ENV.VAPID.PRIVATE_KEY) {
   })
 }
 
-sseAggregator.setPendingActionsFetcher(openCodeClient)
-sseAggregator.setPasswordResolver(() => new SettingsService(db).getOpenCodeServerPassword())
+sseAggregator.setOpenCodeClient(openCodeClient)
+sseAggregator.setResyncGate(() => opencodeServerManager.isLifecycleInitialized())
+opencodeServerManager.onLifecycleInitialized(() => sseAggregator.releasePendingResync())
 sseAggregator.onServerConnected((serverId) => {
   void sessionPermissionModeService.acceptPendingRequestsForActiveSessions(serverId).catch((err) => {
     logger.error(`Failed to accept pending permission requests for server ${serverId}:`, err)
   })
+  if (serverId === LOCAL_OPENCODE_SERVER_ID) {
+    void convertAssistantOpenCodeConfigToV2(openCodeClient.api).catch((err) => {
+      logger.error('Failed to convert the Assistant OpenCode config to v2:', err)
+    })
+  }
 })
 sseAggregator.start()
 

backend/src/routes/opencode-config.ts

@@ -1,5 +1,4 @@
 import { Hono, type Context } from 'hono'
-import { z } from 'zod'
 import {
   UpdateOpenCodeConfigPatchRequestSchema,
   UpdateOpenCodeConfigRequestSchema,
@@ -20,11 +19,15 @@ import {
   OpenCodeConfigRedactedValueError,
   OpenCodeConfigShadowedRemovalError,
   OpenCodeConfigSourceInvalidError,
+  OpenCodeConfigValidationError,
   readOpenCodeConfigFile,
+  readOpenCodeConfigSnapshot,
   withOpenCodeConfigLock,
 } from '../services/opencode-config-file'
+import { readManagedOpenCodeConfig } from '../services/opencode-config-effective'
 import { applyOpenCodeConfigUpdate, toOpenCodeConfigApplyResponse } from '../services/opencode-config-apply'
 import { redactOpenCodeConfigContent, redactOpenCodeConfigFile } from '../services/opencode-config-redact'
+import { opencodeServerManager } from '../services/opencode-single-server'
 import { logger } from '../utils/logger'
 
 interface OpenCodeConfigRoutesOptions {
@@ -53,6 +56,16 @@ function mergeMcpServerStatus(views: McpServerView[], status: McpStatusMap) {
   })
 }
 
+function toClientReadErrorResponse(c: Context, error: unknown, message: string) {
+  if (error instanceof ClientError) {
+    if (error.reason === 'Transport') {
+      return c.json({ error: 'OpenCode server unavailable' }, 503)
+    }
+    return c.json({ error: message }, 502)
+  }
+  return c.json({ error: message }, 500)
+}
+
 export function createOpenCodeConfigRoutes(
   settingsService: SettingsService,
   openCodeClient: OpenCodeClient,
@@ -90,30 +103,40 @@ export function createOpenCodeConfigRoutes(
       })
     } catch (error) {
       logger.error('Failed to get effective OpenCode config:', error)
-      if (error instanceof ClientError) {
-        if (error.reason === 'Transport') {
-          return c.json({ error: 'OpenCode server unavailable' }, 503)
-        }
-        return c.json({ error: 'Failed to get effective OpenCode config' }, 502)
-      }
-      return c.json({ error: 'Failed to get effective OpenCode config' }, 500)
+      return toClientReadErrorResponse(c, error, 'Failed to get effective OpenCode config')
+    }
+  })
+
+  app.get('/managed', async (c) => {
+    try {
+      const snapshot = await withOpenCodeConfigLock(readOpenCodeConfigSnapshot)
+      const info = await readManagedOpenCodeConfig(openCodeClient.api, snapshot.sources)
+      return c.json({
+        info: options.redactSecrets
+          ? redactOpenCodeConfigContent(info as Record<string, unknown>).content
+          : info,
+      })
+    } catch (error) {
+      logger.error('Failed to get managed OpenCode config:', error)
+      return toClientReadErrorResponse(c, error, 'Failed to get managed OpenCode config')
     }
   })
 
   app.get('/mcp', async (c) => {
     try {
-      const [config, status] = await Promise.all([
-        withOpenCodeConfigLock(readOpenCodeConfigFile),
+      const snapshot = await withOpenCodeConfigLock(readOpenCodeConfigSnapshot)
+      const [info, status] = await Promise.all([
+        readManagedOpenCodeConfig(openCodeClient.api, snapshot.sources),
         readMcpStatus(openCodeClient),
       ])
-      const views = mcpServerViewsFromConfig(config?.content.mcp)
+      const views = mcpServerViewsFromConfig(info.mcp)
       return c.json({
-        revision: config?.revision ?? null,
+        revision: snapshot.revision,
         servers: mergeMcpServerStatus(views, status),
       })
     } catch (error) {
       logger.error('Failed to get OpenCode MCP servers:', error)
-      return c.json({ error: 'Failed to get OpenCode MCP servers' }, 500)
+      return toClientReadErrorResponse(c, error, 'Failed to get OpenCode MCP servers')
     }
   })
 
@@ -152,6 +175,12 @@ export function createOpenCodeConfigRoutes(
       return c.json({ error: 'Invalid config data', details: parsed.error.issues }, 400)
     }
 
+    if (opencodeServerManager.isRestartPending()) {
+      return c.json({
+        error: 'OpenCode has not loaded the saved configuration yet. Restart OpenCode before editing entries.',
+      }, 409)
+    }
+
     return applyUpdate(c, {
       content: parsed.data.patch,
       source: parsed.data.source,
@@ -198,12 +227,12 @@ async function applyUpdate(
     if (error instanceof OpenCodeConfigRedactedValueError) {
       return c.json({ error: error.message, paths: error.paths }, 400)
     }
-    if (error instanceof z.ZodError) {
-      return c.json({ error: 'Invalid config data', details: error.issues }, 400)
+    if (error instanceof OpenCodeConfigValidationError) {
+      return c.json({ error: 'Invalid config data', validationIssues: error.issues }, 400)
     }
     if (error instanceof SyntaxError) {
       return c.json({ error: 'Invalid config data', details: error.message }, 400)
     }
-    return c.json({ error: 'Failed to update OpenCode config' }, 500)
+    return toClientReadErrorResponse(c, error, 'Failed to update OpenCode config')
   }
 }

backend/src/routes/opencode-proxy.ts

@@ -16,6 +16,7 @@ import { getRepoById } from '../db/queries'
 import { getTrustedOrigins, getWorkspacePath } from '@opencode-manager/shared/config/env'
 import { isPathWithinRoot } from '../utils/fs-safe'
 import { buildProxyResponseHeaders, filterProxyHeaders } from '../utils/proxy-headers'
+import { forwardProxyRequest } from '../utils/proxy-forward'
 import {
   connectUpstreamWebSocket,
   createBridgedSocketEvents,
@@ -192,20 +193,12 @@ export function createOpenCodeProxyRoutes(db: Database, settingsService: Setting
     const upstreamUrl = `${getOpenCodeUpstreamBaseUrl()}${pathSuffix}${url.search}`
 
     try {
-      const upstreamResponse = await fetch(upstreamUrl, {
+      return await forwardProxyRequest({
+        url: upstreamUrl,
         method: c.req.method,
         headers,
         body: requestBody,
-        redirect: 'manual',
-        duplex: 'half',
-      })
-
-      const responseHeaders = buildProxyResponseHeaders(upstreamResponse.headers)
-
-      return new Response(upstreamResponse.body, {
-        status: upstreamResponse.status,
-        statusText: upstreamResponse.statusText,
-        headers: responseHeaders,
+        buildResponseHeaders: buildProxyResponseHeaders,
       })
     } catch {
       return c.json({ error: 'Proxy request failed' }, 502)

backend/src/routes/opencode-server-proxy.ts

@@ -6,7 +6,8 @@ import {
   type OpenCodeServerConnection,
   type OpenCodeServerRegistry,
 } from '../services/opencode-server-registry'
-import { filterProxyHeaders, NULL_BODY_STATUSES } from '../utils/proxy-headers'
+import { filterProxyHeaders } from '../utils/proxy-headers'
+import { forwardProxyRequest, ProxyHeadersTimeoutError } from '../utils/proxy-forward'
 import { logger } from '../utils/logger'
 
 const MOUNT_PREFIX = '/api/opencode/servers/'
@@ -117,58 +118,28 @@ export function createOpenCodeServerProxyRoutes(
       headers.Authorization = connection.authorization
     }
 
-    const hasBody = c.req.method !== 'GET' && c.req.method !== 'HEAD'
-
-    let headersTimeoutTimer: ReturnType<typeof setTimeout> | null = null
-    let headersTimedOut = false
-    let upstreamSignal = c.req.raw.signal
-    if (!hasBody) {
-      const timeoutController = new AbortController()
-      headersTimeoutTimer = setTimeout(() => {
-        headersTimedOut = true
-        timeoutController.abort()
-      }, upstreamHeadersTimeoutMs)
-      upstreamSignal = AbortSignal.any([c.req.raw.signal, timeoutController.signal])
-    }
+    const isBodylessMethod = c.req.method === 'GET' || c.req.method === 'HEAD'
 
     try {
-      const upstreamResponse = await fetchFn(upstream.url.toString(), {
+      return await forwardProxyRequest({
+        url: upstream.url.toString(),
         method: c.req.method,
         headers,
-        body: hasBody ? c.req.raw.body : undefined,
-        redirect: 'manual',
-        signal: upstreamSignal,
-        duplex: 'half',
-      })
-
-      if (headersTimeoutTimer !== null) {
-        clearTimeout(headersTimeoutTimer)
-        headersTimeoutTimer = null
-      }
-
-      const responseHeaders = new Headers(
-        filterProxyHeaders(upstreamResponse.headers, RESPONSE_EXCLUDED_HEADERS),
-      )
-      const responseBody = NULL_BODY_STATUSES.has(upstreamResponse.status)
-        ? null
-        : upstreamResponse.body
-
-      return new Response(responseBody, {
-        status: upstreamResponse.status,
-        statusText: upstreamResponse.statusText,
-        headers: responseHeaders,
+        body: isBodylessMethod ? null : c.req.raw.body,
+        signal: c.req.raw.signal,
+        headersTimeoutMs: isBodylessMethod ? upstreamHeadersTimeoutMs : undefined,
+        fetchFn,
+        buildResponseHeaders: (upstreamHeaders) => new Headers(
+          filterProxyHeaders(upstreamHeaders, RESPONSE_EXCLUDED_HEADERS),
+        ),
       })
     } catch (error) {
-      if (headersTimedOut) {
+      if (error instanceof ProxyHeadersTimeoutError) {
         logger.warn(`OpenCode server proxy timed out waiting for headers: ${c.req.method} ${upstream.url.host}${upstreamPath.path}`, error)
         return c.json({ error: 'Remote OpenCode server timed out' }, 504)
       }
       logger.warn(`OpenCode server proxy request failed: ${c.req.method} ${upstream.url.host}${upstreamPath.path}`, error)
       return c.json({ error: 'Remote OpenCode server unreachable' }, 502)
-    } finally {
-      if (headersTimeoutTimer !== null) {
-        clearTimeout(headersTimeoutTimer)
-      }
     }
   })
 

backend/src/routes/repos.ts

@@ -27,7 +27,7 @@ import type { SecretsService } from '../services/secrets'
 import type { RepoWorkspaceService } from '../services/repo-workspace'
 import { createGitService } from '../services/git/GitService'
 import { ScheduleService } from '../services/schedules'
-import { ensureAssistantMode, getAssistantModeStatus } from '../services/assistant-mode'
+import { ensureAssistantMode, getAssistantModeStatus, convertAssistantOpenCodeConfigToV2 } from '../services/assistant-mode'
 import path from 'path'
 
 const DeleteWorkspaceRequestSchema = z.object({
@@ -614,6 +614,7 @@ app.get('/', async (c) => {
       const options = AssistantModeInitRequestSchema.parse(body)
 
       const status = await ensureAssistantMode(repo, options)
+      await convertAssistantOpenCodeConfigToV2(openCodeClient.api)
       return c.json(status)
     } catch (error: unknown) {
       logger.error('Failed to initialize assistant mode:', error)