|
|
@@ -86,11 +86,6 @@ export const postMessageHandlersFactory: PostMessageHandlersFactory = (crowi) =>
|
|
|
res.write(`error: ${JSON.stringify({ code, message })}\n\n`);
|
|
|
};
|
|
|
|
|
|
- stream.on('messageDone', async(event) => {
|
|
|
- const pageData = await extructPageDataFromMessageEvent(event);
|
|
|
- // res.write();
|
|
|
- });
|
|
|
-
|
|
|
stream.on('event', async(delta) => {
|
|
|
if (delta.event === 'thread.run.failed') {
|
|
|
const errorMessage = delta.data.last_error?.message;
|
|
|
@@ -101,6 +96,10 @@ export const postMessageHandlersFactory: PostMessageHandlersFactory = (crowi) =>
|
|
|
sendError(errorMessage, getStreamErrorCode(errorMessage));
|
|
|
}
|
|
|
});
|
|
|
+ stream.on('messageDone', async(event) => {
|
|
|
+ const pageData = await extructPageDataFromMessageEvent(event);
|
|
|
+ // res.write();
|
|
|
+ });
|
|
|
stream.on('messageDelta', messageDeltaHandler);
|
|
|
stream.once('messageDone', () => {
|
|
|
stream.off('messageDelta', messageDeltaHandler);
|