diff --git a/src/server/routes/event.ts b/src/server/routes/event.ts index a86e6ab3e..9a32a9fbf 100644 --- a/src/server/routes/event.ts +++ b/src/server/routes/event.ts @@ -4,33 +4,19 @@ import type { EventBus } from '../eventBus.js' import { canonicalizePath } from '../../utils/sessionStoragePortable.js' export function createEventRoutes(eventBus: EventBus): Hono { - return new Hono() - .get('/event', async c => { - const sessionIdFilter = c.req.query('session_id') ?? undefined - const headerDir = c.req.header('x-csc-directory') - const cwdFilter = headerDir ? await canonicalizePath(decodeURIComponent(headerDir)) : undefined - return streamSSE(c, async stream => { - const clientId = eventBus.addClient(stream, sessionIdFilter, cwdFilter) - stream.onAbort(() => { - eventBus.removeClient(clientId) - }) - - while (true) { - await stream.sleep(30000) - } + return new Hono().get('/event', async c => { + const sessionIdFilter = c.req.query('session_id') ?? undefined + const headerDir = c.req.header('x-csc-directory') + const cwdFilter = headerDir ? await canonicalizePath(decodeURIComponent(headerDir)) : undefined + return streamSSE(c, async stream => { + const clientId = eventBus.addClient(stream, sessionIdFilter, cwdFilter) + stream.onAbort(() => { + eventBus.removeClient(clientId) }) - }) - .get('/global/event', async c => { - const sessionIdFilter = c.req.query('session_id') ?? undefined - return streamSSE(c, async stream => { - const clientId = eventBus.addClient(stream, sessionIdFilter) - stream.onAbort(() => { - eventBus.removeClient(clientId) - }) - while (true) { - await stream.sleep(30000) - } - }) + while (true) { + await stream.sleep(30000) + } }) + }) } diff --git a/src/server/sessionHandle.ts b/src/server/sessionHandle.ts index 3e663cd56..44737d244 100644 --- a/src/server/sessionHandle.ts +++ b/src/server/sessionHandle.ts @@ -4,7 +4,6 @@ import { jsonParse, jsonStringify } from '../utils/slowOperations.js' import { logError } from '../utils/log.js' import type { EventBus } from './eventBus.js' import type { SessionBusyStatus, SessionState } from './types.js' - // 子进程冷启动 + MCP 加载 + 鉴权可能远超 30s;env 可调 const INIT_TIMEOUT_MS = (() => { const raw = Number(process.env.CSC_SERVE_INIT_TIMEOUT_MS)