import type { SettingsManager } from "@mariozechner/pi-coding-agent";

import type { ThinkLevel } from "../../auto-reply/thinking.js";

import type { OpenClawConfig } from "../../config/types.openclaw.js";

import { createDeepSeekV4OpenAICompatibleThinkingWrapper } from "../../plugin-sdk/provider-stream-shared.js";

import {

prepareProviderExtraParams as prepareProviderExtraParamsRuntime,

type ProviderRuntimePluginHandle,

ctx.agent.streamFn = createOpenAICompletionsToolsCompatWrapper(ctx.agent.streamFn);

if (!ctx.providerWrapperHandled) {

ctx.agent.streamFn = createDeepSeekV4OpenAICompatibleThinkingWrapper({

baseStreamFn: ctx.agent.streamFn,

thinkingLevel: ctx.thinkingLevel,

shouldPatchModel: isDeepSeekV4OpenAICompatibleModel,

});

// Guard Google-family payloads against invalid negative thinking budgets

// emitted by upstream model-ID heuristics for Gemini 3.1 variants.

ctx.agent.streamFn = createGoogleThinkingPayloadWrapper(ctx.agent.streamFn, ctx.thinkingLevel);

log.warn(`ignoring invalid parallel_tool_calls param: ${summary}`);

}

function normalizeDeepSeekV4CandidateId(modelId: unknown): string | undefined {

if (typeof modelId !== "string") {

return undefined;

}

const withoutSuffix = modelId.trim().toLowerCase().split(":", 1)[0];

return withoutSuffix.split("/").pop();

}

function isDeepSeekV4OpenAICompatibleModel(model: Parameters<StreamFn>[0]): boolean {

const normalizedModelId = normalizeDeepSeekV4CandidateId(model.id);

return (

model.api === "openai-completions" &&

(normalizedModelId === "deepseek-v4-flash" || normalizedModelId === "deepseek-v4-pro")

);

}

/**

* Apply extra params (like temperature) to an agent's streamFn.

* Also applies verified provider-specific request wrappers, such as OpenRouter attribution.