Tools/Notes
1
0
Fork 0
mirror of https://github.com/TriliumNext/Notes.git synced 2025-07-29 19:12:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(llm): handle error catching in streaming better

Browse Source
This commit is contained in:
perf3ct 2025-06-09 00:07:00 +00:00
parent e98fabcc9d
commit ca6277f6e9
No known key found for this signature in database
GPG Key ID: 569C4EEC436F5232
1 changed files with 51 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
apps/server/src/routes/api/llm.ts
View File

@ -420,41 +420,60 @@ async function sendMessage(req: Request, res: Response) {
async function streamMessage(req: Request, res: Response) { async function streamMessage(req: Request, res: Response) {
log.info("=== Starting streamMessage ==="); log.info("=== Starting streamMessage ===");
const chatNoteId = req.params.chatNoteId; try {
const { content, useAdvancedContext, showThinking, mentions } = req.body; const chatNoteId = req.params.chatNoteId;
const { content, useAdvancedContext, showThinking, mentions } = req.body;
// Input validation // Input validation
if (!content || typeof content !== 'string' || content.trim().length === 0) { if (!content || typeof content !== 'string' || content.trim().length === 0) {
return [400, { res.status(400).json({
success: false, success: false,
error: 'Content cannot be empty' error: 'Content cannot be empty'
}];
}
// Start background streaming process immediately (before sending response)
const backgroundPromise = handleStreamingProcess(chatNoteId, content, useAdvancedContext, showThinking, mentions)
.catch(error => {
log.error(`Background streaming error: ${error.message}`);
// Send error via WebSocket since HTTP response was already sent
import('../../services/ws.js').then(wsModule => {
wsModule.default.sendMessageToAllClients({
type: 'llm-stream',
chatNoteId: chatNoteId,
error: `Error during streaming: ${error.message}`,
done: true
});
}).catch(wsError => {
log.error(`Could not send WebSocket error: ${wsError}`);
}); });
// Mark response as handled to prevent further processing
(res as any).triliumResponseHandled = true;
return;
}
// Send immediate success response
res.status(200).json({
success: true,
message: 'Streaming initiated successfully'
}); });
// Mark response as handled to prevent further processing
// Return immediate acknowledgment that streaming has been initiated (res as any).triliumResponseHandled = true;
// The background process will handle the actual streaming
return { // Start background streaming process after sending response
success: true, handleStreamingProcess(chatNoteId, content, useAdvancedContext, showThinking, mentions)
message: 'Streaming initiated successfully' .catch(error => {
}; log.error(`Background streaming error: ${error.message}`);
// Send error via WebSocket since HTTP response was already sent
import('../../services/ws.js').then(wsModule => {
wsModule.default.sendMessageToAllClients({
type: 'llm-stream',
chatNoteId: chatNoteId,
error: `Error during streaming: ${error.message}`,
done: true
});
}).catch(wsError => {
log.error(`Could not send WebSocket error: ${wsError}`);
});
});
} catch (error) {
// Handle any synchronous errors
log.error(`Synchronous error in streamMessage: ${error}`);
if (!res.headersSent) {
res.status(500).json({
success: false,
error: 'Internal server error'
});
}
// Mark response as handled to prevent further processing
(res as any).triliumResponseHandled = true;
}
} }
/** /**