pack optimization

This commit is contained in:
beyondkmp
2025-09-18 15:25:16 +08:00
parent 9e4b792fc3
commit b131f0c48c
10 changed files with 47 additions and 41 deletions
@@ -36,10 +36,7 @@ export const createMessage = async (req: Request, res: Response): Promise<void>
logger.debug('Streaming message data:', messageData)
// Step 1: Save user message first
const userMessage = await sessionMessageService.saveUserMessage(
sessionId,
messageData.content
)
const userMessage = await sessionMessageService.saveUserMessage(sessionId, messageData.content)
// Set SSE headers
res.setHeader('Content-Type', 'text/event-stream')
@@ -48,7 +45,6 @@ export const createMessage = async (req: Request, res: Response): Promise<void>
res.setHeader('Access-Control-Allow-Origin', '*')
res.setHeader('Access-Control-Allow-Headers', 'Cache-Control')
const messageStream = sessionMessageService.createSessionMessage(session, messageData, userMessage.id)
// Track stream lifecycle so we keep the SSE connection open until persistence finishes