torbjorn/antigravity-claude-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: handle thinking-only responses in stress test

Browse Source 
Count responses with thinking content (but no text) as successful,
and validate actual response status instead of hardcoding 200.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Badri Narayanan S
2026-02-01 20:31:10 +05:30
parent dfc054ac9e
commit b72aa0e056
1 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
tests/stress-test-streaming.cjs
View File

@@ -42,6 +42,7 @@ async function sendStreamingRequest(id) {
const reader = response.body.getReader(); const reader = response.body.getReader();
const decoder = new TextDecoder(); const decoder = new TextDecoder();
let fullText = ''; let fullText = '';
let hasThinking = false;
let eventCount = 0; let eventCount = 0;
while (true) { while (true) {
@@ -60,9 +61,13 @@ async function sendStreamingRequest(id) {
const event = JSON.parse(data); const event = JSON.parse(data);
eventCount++; eventCount++;
// Extract text from content_block_delta events // Extract text or thinking from content_block_delta events
if (event.type === 'content_block_delta' && event.delta?.text) { if (event.type === 'content_block_delta') {
if (event.delta?.text) {
fullText += event.delta.text; fullText += event.delta.text;
} else if (event.delta?.thinking) {
hasThinking = true;
}
} }
} catch (e) { } catch (e) {
// Ignore parse errors for partial chunks // Ignore parse errors for partial chunks
@@ -72,9 +77,16 @@ async function sendStreamingRequest(id) {
} }
const totalElapsed = Date.now() - startTime; const totalElapsed = Date.now() - startTime;
const textPreview = fullText.substring(0, 50) || 'No text'; const hasContent = fullText.length > 0 || hasThinking;
console.log(`[${id}] ✅ 200 after ${totalElapsed}ms (${eventCount} events): "${textPreview}..."`);
return { id, success: true, status: 200, elapsed: totalElapsed, eventCount }; if (!hasContent) {
console.log(`[${id}] ⚠️ ${response.status} after ${totalElapsed}ms (${eventCount} events): No content received`);
return { id, success: false, status: response.status, elapsed: totalElapsed, eventCount };
}
const textPreview = fullText.substring(0, 50) || '(thinking only)';
console.log(`[${id}] ✅ ${response.status} after ${totalElapsed}ms (${eventCount} events): "${textPreview}..."`);
return { id, success: true, status: response.status, elapsed: totalElapsed, eventCount };
} catch (error) { } catch (error) {
const elapsed = Date.now() - startTime; const elapsed = Date.now() - startTime;
console.log(`[${id}] ❌ Error after ${elapsed}ms: ${error.message}`); console.log(`[${id}] ❌ Error after ${elapsed}ms: ${error.message}`);