|
@@ -126,9 +126,6 @@ export const postMessageHandlersFactory: PostMessageHandlersFactory = (crowi) =>
|
|
|
res.write(`data: ${JSON.stringify(content)}\n\n`);
|
|
res.write(`data: ${JSON.stringify(content)}\n\n`);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
- // Don't add await since SSE is performed asynchronously with main message
|
|
|
|
|
- openaiService.generateAndProcessPreMessage(req.body.userMessage, preMessageDeltaHandler);
|
|
|
|
|
-
|
|
|
|
|
const messageDeltaHandler = async(delta: MessageDelta) => {
|
|
const messageDeltaHandler = async(delta: MessageDelta) => {
|
|
|
const content = delta.content?.[0];
|
|
const content = delta.content?.[0];
|
|
|
|
|
|
|
@@ -144,6 +141,9 @@ export const postMessageHandlersFactory: PostMessageHandlersFactory = (crowi) =>
|
|
|
res.write(`error: ${JSON.stringify({ code, message })}\n\n`);
|
|
res.write(`error: ${JSON.stringify({ code, message })}\n\n`);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
|
|
+ // Don't add await since SSE is performed asynchronously with main message
|
|
|
|
|
+ openaiService.generateAndProcessPreMessage(req.body.userMessage, preMessageDeltaHandler);
|
|
|
|
|
+
|
|
|
stream.on('event', (delta) => {
|
|
stream.on('event', (delta) => {
|
|
|
if (delta.event === 'thread.run.failed') {
|
|
if (delta.event === 'thread.run.failed') {
|
|
|
const errorMessage = delta.data.last_error?.message;
|
|
const errorMessage = delta.data.last_error?.message;
|