|
@@ -73,10 +73,7 @@ const convertPathPatternsToRegExp = (pagePathPatterns: string[]): Array<string |
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
export interface IOpenaiService {
|
|
export interface IOpenaiService {
|
|
|
- generateAndProcessPreMessage(
|
|
|
|
|
- message: string,
|
|
|
|
|
- deltaProcessor: (delta: ChatCompletionChunk.Choice.Delta) => void,
|
|
|
|
|
- ): Promise<void>
|
|
|
|
|
|
|
+ generateAndProcessPreMessage(message: string, deltaProcessor: (delta: ChatCompletionChunk.Choice.Delta) => void): Promise<void>
|
|
|
createThread(userId: string, type: ThreadType, aiAssistantId?: string, initialUserMessage?: string): Promise<ThreadRelationDocument>;
|
|
createThread(userId: string, type: ThreadType, aiAssistantId?: string, initialUserMessage?: string): Promise<ThreadRelationDocument>;
|
|
|
getThreadsByAiAssistantId(aiAssistantId: string): Promise<ThreadRelationDocument[]>
|
|
getThreadsByAiAssistantId(aiAssistantId: string): Promise<ThreadRelationDocument[]>
|
|
|
deleteThread(threadRelationId: string): Promise<ThreadRelationDocument>;
|
|
deleteThread(threadRelationId: string): Promise<ThreadRelationDocument>;
|
|
@@ -113,10 +110,7 @@ class OpenaiService implements IOpenaiService {
|
|
|
return getClient({ openaiServiceType });
|
|
return getClient({ openaiServiceType });
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- async generateAndProcessPreMessage(
|
|
|
|
|
- message: string,
|
|
|
|
|
- deltaProcessor: (delta: ChatCompletionChunk.Choice.Delta) => void,
|
|
|
|
|
- ): Promise<void> {
|
|
|
|
|
|
|
+ async generateAndProcessPreMessage(message: string, deltaProcessor: (delta: ChatCompletionChunk.Choice.Delta) => void): Promise<void> {
|
|
|
const systemMessage = [
|
|
const systemMessage = [
|
|
|
"Generate a message briefly confirming the user's question.",
|
|
"Generate a message briefly confirming the user's question.",
|
|
|
'Please generate up to 20 characters',
|
|
'Please generate up to 20 characters',
|