return createAnthropicServiceTierWrapper(baseStreamFn, fastMode ? "auto" : "standard_only");

}

import { isAnthropicBedrockModel } from "./pi-embedded-runner/anthropic-family-cache-semantics.js";

import { createAnthropicToolPayloadCompatibilityWrapper } from "./pi-embedded-runner/anthropic-family-tool-payload-compat.js";

import {

createBedrockNoCacheWrapper,

isAnthropicBedrockModel,

} from "./pi-embedded-runner/bedrock-stream-wrappers.js";

import {

applyExtraParamsToAgent,

resolveAgentTransportOverride,

if (params.provider === "amazon-bedrock") {

return isAnthropicBedrockModel(params.context.modelId)

? params.context.streamFn

: createBedrockNoCacheWrapper(params.context.streamFn);

: createTestBedrockNoCacheWrapper(params.context.streamFn);

}

if (params.provider === "google") {

return createGoogleThinkingPayloadWrapper(

});

}

function createTestBedrockNoCacheWrapper(baseStreamFn: StreamFn | undefined): StreamFn {

const underlying = baseStreamFn ?? (() => ({}) as ReturnType<StreamFn>);

return (model, context, options) =>

underlying(model, context, {

...options,

cacheRetention: "none",

});

}

function withMinimalProviderRuntimeDepsForTest<T>(run: () => T): T {

extraParamsTesting.setProviderRuntimeDepsForTest({

prepareProviderExtraParams: () => undefined,