refactor: opencode event stream integration and SSE aggregator updates (#212)

Author: chriswritescode-dev

backend/src/index.ts

@@ -302,6 +302,9 @@ if (ENV.VAPID.PUBLIC_KEY && ENV.VAPID.PRIVATE_KEY) {
   })
 }
 
+sseAggregator.setPendingActionsFetcher(openCodeClient)
+sseAggregator.start()
+
 void scheduleRunnerInstance.start()
 
 app.route('/api/auth', createAuthRoutes(auth))

backend/src/services/opencode/auth.ts

@@ -0,0 +1,9 @@
+import { ENV } from '@opencode-manager/shared/config/env'
+
+export function buildOpenCodeBasicAuthHeader(): string | null {
+  const password = ENV.OPENCODE.SERVER_PASSWORD
+  const username = ENV.OPENCODE.SERVER_USERNAME
+  if (!password) return null
+  const token = Buffer.from(`${username}:${password}`).toString('base64')
+  return `Basic ${token}`
+}

backend/src/services/opencode/client.ts

@@ -1,5 +1,6 @@
 import { logger } from '../../utils/logger'
 import { ENV } from '@opencode-manager/shared/config/env'
+import { buildOpenCodeBasicAuthHeader } from './auth'
 
 export interface ForwardRequest {
   method: string
@@ -40,7 +41,7 @@ export interface OpenCodeClient {
 
 export interface FetchOpenCodeClientConfig {
   baseUrl: string
-  basicAuth: string
+  basicAuth: string | null
   fetchFn?: typeof fetch
 }
 
@@ -239,11 +240,7 @@ export class FetchOpenCodeClient implements OpenCodeClient {
 
 export function createOpenCodeClient(): OpenCodeClient {
   const baseUrl = `http://${ENV.OPENCODE.HOST}:${ENV.OPENCODE.PORT}`
-  const password = ENV.OPENCODE.SERVER_PASSWORD
-  const username = ENV.OPENCODE.SERVER_USERNAME
-  const basicAuth = password
-    ? `Basic ${Buffer.from(`${username}:${password}`).toString('base64')}`
-    : ''
+  const basicAuth = buildOpenCodeBasicAuthHeader()
 
   return new FetchOpenCodeClient({ baseUrl, basicAuth })
 }

backend/src/services/schedules.ts

@@ -315,11 +315,9 @@ function getSessionStatusType(event: SSEEvent): string | null {
 }
 
 function createSessionMonitor(directory: string, sessionId: string): SessionMonitor {
-  const clientId = `schedule-monitor-${sessionId}-${Date.now()}`
   let errorText: string | null = null
   let idle = false
 
-  const removeClient = sseAggregator.addClient(clientId, () => {}, [directory])
   const unsubscribe = sseAggregator.onEvent((eventDirectory, event) => {
     if (eventDirectory !== directory) {
       return
@@ -347,10 +345,7 @@ function createSessionMonitor(directory: string, sessionId: string): SessionMoni
   return {
     getErrorText: () => errorText,
     isIdle: () => idle,
-    dispose: () => {
-      unsubscribe()
-      removeClient()
-    },
+    dispose: unsubscribe,
   }
 }