@@ -288,37 +288,38 @@ router.post('/chat-process', [auth, limiter], async (req, res) => {
288288 return
289289 }
290290 }
291-
291+
292292 message = regenerate ? await getChat ( roomId , uuid ) : await insertChat ( uuid , prompt , uploadFileKeys , roomId , model , options as ChatOptions )
293-
293+
294294 result = await chatReplyProcess ( {
295295 message : prompt ,
296296 uploadFileKeys,
297297 parentMessageId : options ?. parentMessageId ,
298298 process : ( chunk : ResponseChunk ) => {
299299 lastResponse = chunk
300-
300+
301301 // 根据数据类型发送不同的 SSE 事件
302302 if ( chunk . searchQuery ) {
303303 sendSSEData ( 'search_query' , { searchQuery : chunk . searchQuery } )
304304 }
305305 if ( chunk . searchResults ) {
306- sendSSEData ( 'search_results' , {
306+ sendSSEData ( 'search_results' , {
307307 searchResults : chunk . searchResults ,
308- searchUsageTime : chunk . searchUsageTime
308+ searchUsageTime : chunk . searchUsageTime ,
309309 } )
310310 }
311311 if ( chunk . delta ) {
312312 // 发送增量数据
313- sendSSEData ( 'delta' , { m : chunk . delta } )
314- } else {
313+ sendSSEData ( 'delta' , { m : chunk . delta } )
314+ }
315+ else {
315316 // 兼容现有格式,发送完整数据但标记为增量类型
316317 sendSSEData ( 'message' , {
317318 id : chunk . id ,
318319 reasoning : chunk . reasoning ,
319320 text : chunk . text ,
320321 role : chunk . role ,
321- finish_reason : chunk . finish_reason
322+ finish_reason : chunk . finish_reason ,
322323 } )
323324 }
324325 } ,
@@ -330,12 +331,12 @@ router.post('/chat-process', [auth, limiter], async (req, res) => {
330331 room,
331332 chatUuid : uuid ,
332333 } )
333-
334+
334335 // 发送最终完成数据
335336 if ( result && result . status === 'Success' ) {
336337 sendSSEData ( 'complete' , result . data )
337338 }
338-
339+
339340 sendSSEEnd ( )
340341 }
341342 catch ( error ) {
0 commit comments