admin-valentin/AIClient-2-API
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: filter duplicate consecutive content events from Kiro stream

Browse source
This commit is contained in:
Sanyela 2025-12-03 14:37:20 +08:00
parent fc3e7ccba4
commit 9a2f0b0c52
1 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/claude/claude-kiro.js
View file

@ -1153,6 +1153,7 @@ async initializeAuth(forceRefresh = false) {
const stream = response.data; const stream = response.data;
let buffer = ''; let buffer = '';
let lastContentEvent = null; // 用于检测连续重复的 content 事件
for await (const chunk of stream) { for await (const chunk of stream) {
buffer += chunk.toString(); buffer += chunk.toString();
@ -1161,9 +1162,15 @@ async initializeAuth(forceRefresh = false) {
const { events, remaining } = this.parseAwsEventStreamBuffer(buffer); const { events, remaining } = this.parseAwsEventStreamBuffer(buffer);
buffer = remaining; buffer = remaining;
// yield 所有事件（不再去重，因为重复内容是有效的） // yield 所有事件，但过滤连续完全相同的 content 事件（Kiro API 有时会重复发送）
for (const event of events) { for (const event of events) {
if (event.type === 'content' && event.data) { if (event.type === 'content' && event.data) {
// 检查是否与上一个 content 事件完全相同
if (lastContentEvent === event.data) {
// 跳过重复的内容
continue;
}
lastContentEvent = event.data;
yield { type: 'content', content: event.data }; yield { type: 'content', content: event.data };
} else if (event.type === 'toolUse') { } else if (event.type === 'toolUse') {
yield { type: 'toolUse', toolUse: event.data }; yield { type: 'toolUse', toolUse: event.data };