ayrisdev/lagos-back
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(chat): allow AI to finish and save responses even if client disconnects

Browse Source
This commit is contained in:
mstfyldz
2026-08-12 13:02:40 +03:00
parent d10ea1b0fd
commit f1457b02ca
1 changed files with 31 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/controllers/chat.controller.ts
+31 -17
View File
@@ -41,9 +41,15 @@ function startSse(res: Response) {
}
function sseWrite(res: Response, payload: Record<string, unknown>) {
res.write(`data: ${JSON.stringify(payload)}\n\n`);
if (typeof (res as any).flush === 'function') {
(res as any).flush();
if (res.destroyed || res.writableEnded) return;
try {
res.write(`data: ${JSON.stringify(payload)}\n\n`);
if (typeof (res as any).flush === 'function') {
(res as any).flush();
}
} catch (err) {
// Client disconnect olduysa yazma hatasını yoksay, arka planda AI'ın
// yanıt üretmeyi bitirip veritabanına kaydetmesine izin ver.
}
}
@@ -198,15 +204,19 @@ export const chatMessage = async (req: AuthenticatedRequest, res: Response) => {
}
}
sseWrite(res, { done: true, newTitle, messageId: aiMessage?.id || null });
res.end();
if (!res.destroyed && !res.writableEnded) {
sseWrite(res, { done: true, newTitle, messageId: aiMessage?.id || null });
res.end();
}
} catch (error: any) {
console.error('Chat Error:', error);
if (!res.headersSent) {
res.status(500).json({ error: error.message || 'Internal Server Error' });
} else {
sseWrite(res, { error: error.message || 'Internal Server Error' });
res.end();
if (!res.destroyed && !res.writableEnded) {
if (!res.headersSent) {
res.status(500).json({ error: error.message || 'Internal Server Error' });
} else {
sseWrite(res, { error: error.message || 'Internal Server Error' });
res.end();
}
}
}
};
@@ -281,15 +291,19 @@ export const sendThreadMessage = async (req: AuthenticatedRequest, res: Response
}
}
sseWrite(res, { done: true, newTitle, messageId: aiMessage?.id || null });
res.end();
if (!res.destroyed && !res.writableEnded) {
sseWrite(res, { done: true, newTitle, messageId: aiMessage?.id || null });
res.end();
}
} catch (error: any) {
console.error('Send Thread Message Error:', error);
if (!res.headersSent) {
res.status(500).json({ error: error.message || 'Internal Server Error' });
} else {
sseWrite(res, { error: error.message || 'Internal Server Error' });
res.end();
if (!res.destroyed && !res.writableEnded) {
if (!res.headersSent) {
res.status(500).json({ error: error.message || 'Internal Server Error' });
} else {
sseWrite(res, { error: error.message || 'Internal Server Error' });
res.end();
}
}
}
};