import { streamAnthropic } from "../llm/providers/anthropic.js";

import { createAnthropicMessagesTransportStreamFn } from "./anthropic-transport-stream.js";

import { isLiveTestEnabled } from "./live-test-helpers.js";

import { isLiveBillingDrift } from "./live-test-provider-drift.js";

const LIVE = isLiveTestEnabled(["ANTHROPIC_TRANSPORT_LIVE_TEST"]);

const describeLive = LIVE ? describe : describe.skip;

return Buffer.concat(chunks).toString("utf8");

}

function skipAnthropicBillingDrift(

label: string,

result: { stopReason: string; errorMessage?: string },

): boolean {

if (result.stopReason !== "error" || !isLiveBillingDrift(result.errorMessage ?? "")) {

return false;

}

console.warn(`[anthropic:live] skip ${label}: billing drift`);

return true;

}

describeLive("anthropic transport stream live", () => {

it("cancels an in-flight SSE body read over a real HTTP stream", async () => {

const controller = new AbortController();

);

const result = await stream.result();

if (skipAnthropicBillingDrift("forced tool projection", result)) {

return;

}

const toolCall = result.content.find(

(block) => block.type === "toolCall" && block.name === "healthy_probe",

);

);

const result = await stream.result();

if (skipAnthropicBillingDrift("SDK forced tool projection", result)) {

return;

}

const toolCall = result.content.find(

(block) => block.type === "toolCall" && block.name === "healthy_probe",

);