refactor(cliproxy): check lifecycle events in remaining SSE buffer

Add message_start/message_delta/message_stop detection to the
remaining-buffer block in the SSE processing path for defensive
completeness. Addresses code review feedback on PR #493.
This commit is contained in:
kaitranntt
2026-02-07 04:30:42 -05:00
parent 152f5432ae
commit 42a3eb1506
+9
View File
@@ -535,6 +535,15 @@ export class ToolSanitizationProxy {
if (buffer.includes('"content_block_start"')) {
hasReceivedContent = true;
}
if (buffer.includes('"message_start"')) {
hasReceivedMessageStart = true;
}
if (buffer.includes('"message_delta"')) {
hasReceivedMessageDelta = true;
}
if (buffer.includes('"message_stop"')) {
hasReceivedMessageStop = true;
}
const processedEvent = this.processSSEEvent(buffer, mapper);
clientRes.write(processedEvent + '\n\n');
}