fix(clownfish): address review for ghcrawl-156721-autonomous-smoke (1)

vincentkoc · vincentkoc · commit ba9b5bf41d00 · 2026-04-28T07:23:52.000Z
diff --git a/extensions/anthropic/stream-wrappers.test.ts b/extensions/anthropic/stream-wrappers.test.ts
@@ -125,6 +125,15 @@ describe("anthropic stream wrappers", () => {
     ).toEqual(["files-api-2025-04-14"]);
   });
 
+  it("strips legacy context-1m beta from comma-separated string config", () => {
+    expect(
+      resolveAnthropicBetas(
+        { anthropicBeta: `${CONTEXT_1M_BETA},files-api-2025-04-14` },
+        "claude-sonnet-4-6",
+      ),
+    ).toEqual(["files-api-2025-04-14"]);
+  });
+
   it("preserves OAuth-required betas when context1m is the only configured beta trigger", () => {
     const captured: { headers?: Record<string, string> } = {};
     const wrapped = wrapAnthropicProviderStream({
diff --git a/extensions/anthropic/stream-wrappers.ts b/extensions/anthropic/stream-wrappers.ts
@@ -99,11 +99,15 @@ export function resolveAnthropicBetas(
   const betas = new Set<string>();
   const configured = extraParams?.anthropicBeta;
   if (typeof configured === "string" && configured.trim()) {
-    betas.add(configured.trim());
+    for (const beta of parseHeaderList(configured)) {
+      betas.add(beta);
+    }
   } else if (Array.isArray(configured)) {
     for (const beta of configured) {
       if (typeof beta === "string" && beta.trim()) {
-        betas.add(beta.trim());
+        for (const betaValue of parseHeaderList(beta)) {
+          betas.add(betaValue);
+        }
       }
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -99,11 +99,15 @@ export function resolveAnthropicBetas(`
`99`	`99`	`const betas = new Set<string>();`
`100`	`100`	`const configured = extraParams?.anthropicBeta;`
`101`	`101`	`if (typeof configured === "string" && configured.trim()) {`
`102`		`- betas.add(configured.trim());`
	`102`	`+ for (const beta of parseHeaderList(configured)) {`
	`103`	`+ betas.add(beta);`
	`104`	`+ }`
`103`	`105`	`} else if (Array.isArray(configured)) {`
`104`	`106`	`for (const beta of configured) {`
`105`	`107`	`if (typeof beta === "string" && beta.trim()) {`
`106`		`- betas.add(beta.trim());`
	`108`	`+ for (const betaValue of parseHeaderList(beta)) {`
	`109`	`+ betas.add(betaValue);`
	`110`	`+ }`
`107`	`111`	`}`
`108`	`112`	`}`
`109`	`113`	`}`