File tree 1 file changed +17
-1
lines changed
1 file changed +17
-1
lines changed Original file line number Diff line number Diff line change @@ -385,6 +385,7 @@ export class ChatService {
385
385
async chat ( msg : string | ChatBody ) : Promise < void > {
386
386
this . #ctrl = new AbortController ( ) ;
387
387
let hadMatchMessage = false ;
388
+ let hadUsefulMessage = false ;
388
389
this . #chatting = true ;
389
390
await fetchEventSource (
390
391
`${ getBasePath ( ) } api/gateway/easyops.api.aiops_chat.manage.LLMChatProxy@1.0.0/api/aiops_chat/v1/chat/completions` ,
@@ -424,8 +425,23 @@ export class ChatService {
424
425
hadMatchMessage = true ;
425
426
if ( data === "[DONE]" ) {
426
427
this . #ctrl! . abort ( ) ;
428
+ if ( ! hadUsefulMessage ) {
429
+ this . enqueue ( {
430
+ topic : "add" ,
431
+ message : {
432
+ created : moment ( ) . format ( "YYYY-MM-DD HH:mm:ss" ) ,
433
+ delta : {
434
+ role : "assistant" ,
435
+ content : "" ,
436
+ } ,
437
+ agentId : this . #agentId,
438
+ robotId : this . #robotId,
439
+ } ,
440
+ } ) ;
441
+ }
427
442
return ;
428
443
}
444
+ hadUsefulMessage = true ;
429
445
let result = { } as SSEMessageItem ;
430
446
try {
431
447
result = JSON . parse ( data ) ;
@@ -538,7 +554,7 @@ export class ChatService {
538
554
539
555
stop ( ) {
540
556
clearTimeout ( this . #emitTimer) ;
541
- this . #ctrl && this . #ctrl ?. abort ( ) ;
557
+ this . #ctrl?. abort ( ) ;
542
558
this . #chatting = false ;
543
559
this . #emitTimer = undefined ;
544
560
this . #isStartEmitEvent = false ;
You can’t perform that action at this time.
0 commit comments