File tree Expand file tree Collapse file tree 2 files changed +14
-3
lines changed Expand file tree Collapse file tree 2 files changed +14
-3
lines changed Original file line number Diff line number Diff line change @@ -8,7 +8,10 @@ import {
88 SearchParams ,
99} from 'meilisearch' ;
1010import { Resource } from 'src/resources/resources.entity' ;
11- import { Message } from 'src/messages/entities/message.entity' ;
11+ import {
12+ Message ,
13+ OpenAIMessageRole ,
14+ } from 'src/messages/entities/message.entity' ;
1215import { DocType } from './doc-type.enum' ;
1316import {
1417 IndexedDocDto ,
@@ -114,7 +117,14 @@ export class SearchService implements OnModuleInit {
114117 conversationId : string ,
115118 message : Message ,
116119 ) {
117- if ( ! message . message . content ) {
120+ if ( ! message . message . content ?. trim ( ) ) {
121+ return ;
122+ }
123+ if (
124+ [ OpenAIMessageRole . TOOL , OpenAIMessageRole . SYSTEM ] . includes (
125+ message . message . role ,
126+ )
127+ ) {
118128 return ;
119129 }
120130 const content = message . message . content ;
Original file line number Diff line number Diff line change @@ -107,7 +107,7 @@ export class StreamService {
107107 throw new Error ( 'Message ID is not set in context' ) ;
108108 }
109109 const message : Message = await this . messagesService . updateOpenAIMessage (
110- context . messageId ! ,
110+ context . messageId ,
111111 chunk . message ,
112112 chunk . attrs ,
113113 ) ;
@@ -128,6 +128,7 @@ export class StreamService {
128128 context . parentId = message . id ;
129129 context . messageId = undefined ;
130130 } else if ( chunk . response_type === 'done' ) {
131+ // Do nothing, this is the end of the stream
131132 } else if ( chunk . response_type === 'error' ) {
132133 const err = new Error ( chunk . message || 'Unknown error' ) ;
133134 err . name = 'AgentError' ;
You can’t perform that action at this time.
0 commit comments