import { T as StreamFn } from "./types-D0CdrmU4.js"; import { n as ThinkLevel } from "./thinking.shared-Dn7xz8fk.js"; import { Gn as ProviderWrapStreamFnContext$1 } from "./types-DIBfaBvi.js"; import { createDeferredEventBuffer as createDeferredEventBuffer$1, notifyLlmRequestActivity as notifyLlmRequestActivity$1, onLlmRequestActivity as onLlmRequestActivity$1 } from "@openclaw/ai/internal/runtime"; import { applyAnthropicRefusal as applyAnthropicRefusal$1 } from "@openclaw/ai/internal/anthropic"; //#region src/llm/providers/stream-wrappers/stream-payload-utils.d.ts /** Wraps a stream function and lets callers mutate outgoing provider payload objects. */ declare function streamWithPayloadPatch(underlying: StreamFn, model: Parameters[0], context: Parameters[1], options: Parameters[2], patchPayload: (payload: Record) => void): ReturnType; //#endregion //#region src/agents/anthropic-payload-policy.d.ts /** @deprecated Anthropic-family provider payload helper; do not use from third-party plugins. */ type AnthropicServiceTier = "auto" | "standard_only"; /** @deprecated Anthropic-family provider payload helper; do not use from third-party plugins. */ type AnthropicEphemeralCacheControl = { type: "ephemeral"; ttl?: "1h"; }; type AnthropicPayloadPolicyInput = { api?: string; baseUrl?: string; cacheRetention?: "short" | "long" | "none"; enableCacheControl?: boolean; provider?: string; serviceTier?: AnthropicServiceTier; }; /** @deprecated Anthropic-family provider payload helper; do not use from third-party plugins. */ type AnthropicPayloadPolicy = { allowsServiceTier: boolean; cacheControl: AnthropicEphemeralCacheControl | undefined; serviceTier: AnthropicServiceTier | undefined; }; /** Resolve Anthropic cache-control marker retention for a request endpoint. */ /** @deprecated Anthropic-family provider payload helper; do not use from third-party plugins. */ declare function resolveAnthropicPayloadPolicy(input: AnthropicPayloadPolicyInput): AnthropicPayloadPolicy; /** @deprecated Anthropic-family provider payload helper; do not use from third-party plugins. */ declare function applyAnthropicPayloadPolicyToParams(payloadObj: Record, policy: AnthropicPayloadPolicy, cacheBreakpointOptOutMessageIndexes: ReadonlySet): void; /** @deprecated Anthropic-family provider payload helper; do not use from third-party plugins. */ declare function applyAnthropicEphemeralCacheControlMarkers(payloadObj: Record, cacheControl?: AnthropicEphemeralCacheControl | null): void; //#endregion //#region src/llm/providers/stream-wrappers/zai.d.ts /** * Inject `tool_stream=true` so tool-call deltas stream in real time. * Providers can disable this by setting `params.tool_stream=false`. * * @deprecated Provider-owned stream helper; do not use from third-party plugins. */ declare function createToolStreamWrapper(baseStreamFn: StreamFn | undefined, enabled: boolean): StreamFn; /** @deprecated Z.ai provider-owned stream helper; do not use from third-party plugins. */ declare const createZaiToolStreamWrapper: typeof createToolStreamWrapper; //#endregion //#region src/plugin-sdk/provider-stream-shared.d.ts type ProviderWrapStreamFnContext = ProviderWrapStreamFnContext$1; /** Optional provider stream decorator factory used by shared provider wrappers. */ type ProviderStreamWrapperFactory = /** Wrapper factory that can decorate, replace, or omit a provider stream function. */((streamFn: StreamFn | undefined) => StreamFn | undefined) | null | undefined | false; /** Compose stream wrapper factories from left to right around a base stream function. */ declare function composeProviderStreamWrappers(/** Base provider stream function to pass through the wrapper chain. */ baseStreamFn: StreamFn | undefined, /** Ordered wrapper factories; falsey entries are skipped. */...wrappers: ProviderStreamWrapperFactory[]): StreamFn | undefined; /** * Provider stream wrapper for local/proxy providers that sometimes emit a * standalone textual tool-call block even when native tool calling is enabled. */ declare function createPlainTextToolCallCompatWrapper(/** Provider stream function to wrap; defaults to the simple stream implementation. */ baseStreamFn: StreamFn | undefined): StreamFn; /** @deprecated Bundled provider stream helper; do not use from third-party plugins. */ declare function defaultToolStreamExtraParams(/** Existing provider extra params; explicit tool_stream values are preserved. */ extraParams?: Record): Record; /** Wrap a provider stream so callers can patch the outbound provider payload once. */ declare function createPayloadPatchStreamWrapper(/** Provider stream function whose outbound payload should be patched. */ baseStreamFn: StreamFn | undefined, patchPayload: (params: { /** Mutable provider payload immediately before the underlying stream dispatches it. */payload: Record; /** Model selected for the stream call. */ model: Parameters[0]; /** Stream context passed by the runtime. */ context: Parameters[1]; /** Stream options passed by the runtime. */ options: Parameters[2]; }) => void, wrapperOptions?: { shouldPatch?: (params: { /** Model selected for the stream call. */model: Parameters[0]; /** Stream context passed by the runtime. */ context: Parameters[1]; /** Stream options passed by the runtime. */ options: Parameters[2]; }) => boolean; }): StreamFn; /** * Applies explicit disabled-thinking intent to OpenAI-compatible Chat * Completions payloads without changing enabled reasoning levels. */ declare function createOpenAICompatibleCompletionsThinkingOffWrapper(baseStreamFn: StreamFn | undefined, thinkingLevel?: ThinkLevel): StreamFn; /** @deprecated Anthropic-family provider stream helper; do not use from third-party plugins. */ declare function stripTrailingAnthropicAssistantPrefillWhenThinking(payload: Record): number; /** @deprecated Anthropic-family provider stream helper; do not use from third-party plugins. */ declare function createAnthropicThinkingPrefillPayloadWrapper(baseStreamFn: StreamFn | undefined, onStripped?: (stripped: number) => void, wrapperOptions?: Parameters[2]): StreamFn; /** @deprecated OpenAI-compatible provider stream helper; do not use from third-party plugins. */ type OpenAICompatibleThinkingLevel = ProviderWrapStreamFnContext["thinkingLevel"]; /** @deprecated OpenAI-compatible provider stream helper; do not use from third-party plugins. */ declare function isOpenAICompatibleThinkingEnabled(params: { thinkingLevel: OpenAICompatibleThinkingLevel; options: Parameters[2]; }): boolean; /** Applies the shared reasoning payload policy used by OpenAI-compatible proxy providers. */ declare function normalizeOpenAICompatibleReasoningPayload(payload: Record, thinkingLevel?: ThinkLevel): void; /** Applies Qwen chat-template thinking flags without discarding provider-specific kwargs. */ declare function setQwenChatTemplateThinking(payload: Record, enabled: boolean): void; /** @deprecated DeepSeek provider stream helper; do not use from third-party plugins. */ type DeepSeekV4ThinkingLevel = ProviderWrapStreamFnContext["thinkingLevel"]; /** @deprecated DeepSeek provider stream helper; do not use from third-party plugins. */ type DeepSeekV4ReasoningEffort = "minimal" | "low" | "medium" | "high" | "xhigh" | "max"; /** @deprecated DeepSeek provider stream helper; do not use from third-party plugins. */ declare function createDeepSeekV4OpenAICompatibleThinkingWrapper(params: { baseStreamFn: StreamFn | undefined; thinkingLevel: DeepSeekV4ThinkingLevel; shouldPatchModel: (model: Parameters[0]) => boolean; resolveReasoningEffort?: (thinkingLevel: DeepSeekV4ThinkingLevel) => DeepSeekV4ReasoningEffort; shouldBackfillAssistantReasoningContent?: (message: Record) => boolean; }): StreamFn | undefined; /** @deprecated OpenAI-compatible provider stream helper; do not use from third-party plugins. */ declare function createThinkingOnlyFinalTextWrapper(params: { baseStreamFn: StreamFn | undefined; shouldPatchModel: (model: Parameters[0]) => boolean; }): StreamFn | undefined; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ type GoogleThinkingLevel = "MINIMAL" | "LOW" | "MEDIUM" | "HIGH"; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ type GoogleThinkingInputLevel = "off" | "minimal" | "low" | "medium" | "adaptive" | "high" | "max" | "xhigh"; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function isGoogleThinkingRequiredModel(modelId: string): boolean; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function isGoogleGemini25ThinkingBudgetModel(modelId: string): boolean; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function isGoogleGemini3ProModel(modelId: string): boolean; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function isGoogleGemini3FlashModel(modelId: string): boolean; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function isGoogleGemini3ThinkingLevelModel(modelId: string): boolean; /** * Maps legacy numeric/semantic thinking input onto Gemini 3's provider enum. * @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function resolveGoogleGemini3ThinkingLevel(params: { modelId?: string; thinkingLevel?: GoogleThinkingInputLevel; thinkingBudget?: number; }): GoogleThinkingLevel | undefined; /** * Removes `thinkingBudget=0` only for Gemini models that reject disabled thinking. * @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function stripInvalidGoogleThinkingBudget(params: { thinkingConfig: Record; modelId?: string; }): boolean; /** * Normalizes Google thinking config across SDK payload shapes before provider transport. * @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function sanitizeGoogleThinkingPayload(params: { payload: unknown; modelId?: string; thinkingLevel?: GoogleThinkingInputLevel; }): void; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function createGoogleThinkingPayloadWrapper(baseStreamFn: StreamFn | undefined, thinkingLevel?: GoogleThinkingInputLevel): StreamFn; /** @deprecated Google provider-owned stream helper; do not use from third-party plugins. */ declare function createGoogleThinkingStreamWrapper(ctx: ProviderWrapStreamFnContext): NonNullable; //#endregion export { setQwenChatTemplateThinking as A, isGoogleThinkingRequiredModel as C, onLlmRequestActivity$1 as D, notifyLlmRequestActivity$1 as E, applyAnthropicEphemeralCacheControlMarkers as F, applyAnthropicPayloadPolicyToParams as I, resolveAnthropicPayloadPolicy as L, stripTrailingAnthropicAssistantPrefillWhenThinking as M, createToolStreamWrapper as N, resolveGoogleGemini3ThinkingLevel as O, createZaiToolStreamWrapper as P, streamWithPayloadPatch as R, isGoogleGemini3ThinkingLevelModel as S, normalizeOpenAICompatibleReasoningPayload as T, createThinkingOnlyFinalTextWrapper as _, OpenAICompatibleThinkingLevel as a, isGoogleGemini3FlashModel as b, composeProviderStreamWrappers as c, createDeferredEventBuffer$1 as d, createGoogleThinkingPayloadWrapper as f, createPlainTextToolCallCompatWrapper as g, createPayloadPatchStreamWrapper as h, GoogleThinkingLevel as i, stripInvalidGoogleThinkingBudget as j, sanitizeGoogleThinkingPayload as k, createAnthropicThinkingPrefillPayloadWrapper as l, createOpenAICompatibleCompletionsThinkingOffWrapper as m, DeepSeekV4ThinkingLevel as n, ProviderStreamWrapperFactory as o, createGoogleThinkingStreamWrapper as p, GoogleThinkingInputLevel as r, applyAnthropicRefusal$1 as s, DeepSeekV4ReasoningEffort as t, createDeepSeekV4OpenAICompatibleThinkingWrapper as u, defaultToolStreamExtraParams as v, isOpenAICompatibleThinkingEnabled as w, isGoogleGemini3ProModel as x, isGoogleGemini25ThinkingBudgetModel as y };