@@ -1,76 +1,17 @@
11import type { ProviderWrapStreamFnContext } from "openclaw/plugin-sdk/plugin-entry";
2-import { streamWithPayloadPatch } from "openclaw/plugin-sdk/provider-stream-shared";
3-4-type DeepSeekThinkingLevel = ProviderWrapStreamFnContext["thinkingLevel"];
2+import { createDeepSeekV4OpenAICompatibleThinkingWrapper } from "openclaw/plugin-sdk/provider-stream-shared";
5364function isDeepSeekV4ModelId(modelId: unknown): boolean {
75return modelId === "deepseek-v4-flash" || modelId === "deepseek-v4-pro";
86}
9710-function isDisabledThinkingLevel(thinkingLevel: DeepSeekThinkingLevel): boolean {
11-const normalized = typeof thinkingLevel === "string" ? thinkingLevel.toLowerCase() : "";
12-return normalized === "off" || normalized === "none";
13-}
14-15-function resolveDeepSeekReasoningEffort(thinkingLevel: DeepSeekThinkingLevel): "high" | "max" {
16-return thinkingLevel === "xhigh" || thinkingLevel === "max" ? "max" : "high";
17-}
18-19-function stripDeepSeekReasoningContent(payload: Record<string, unknown>): void {
20-if (!Array.isArray(payload.messages)) {
21-return;
22-}
23-for (const message of payload.messages) {
24-if (!message || typeof message !== "object") {
25-continue;
26-}
27-delete (message as Record<string, unknown>).reasoning_content;
28-}
29-}
30-31-function ensureDeepSeekToolCallReasoningContent(payload: Record<string, unknown>): void {
32-if (!Array.isArray(payload.messages)) {
33-return;
34-}
35-for (const message of payload.messages) {
36-if (!message || typeof message !== "object") {
37-continue;
38-}
39-const record = message as Record<string, unknown>;
40-if (record.role !== "assistant" || !Array.isArray(record.tool_calls)) {
41-continue;
42-}
43-if (!("reasoning_content" in record)) {
44-record.reasoning_content = "";
45-}
46-}
47-}
48-498export function createDeepSeekV4ThinkingWrapper(
509baseStreamFn: ProviderWrapStreamFnContext["streamFn"],
51-thinkingLevel: DeepSeekThinkingLevel,
10+thinkingLevel: ProviderWrapStreamFnContext["thinkingLevel"],
5211): ProviderWrapStreamFnContext["streamFn"] {
53-if (!baseStreamFn) {
54-return undefined;
55-}
56-const underlying = baseStreamFn;
57-return (model, context, options) => {
58-if (model.provider !== "deepseek" || !isDeepSeekV4ModelId(model.id)) {
59-return underlying(model, context, options);
60-}
61-62-return streamWithPayloadPatch(underlying, model, context, options, (payload) => {
63-if (isDisabledThinkingLevel(thinkingLevel)) {
64-payload.thinking = { type: "disabled" };
65-delete payload.reasoning_effort;
66-delete payload.reasoning;
67-stripDeepSeekReasoningContent(payload);
68-return;
69-}
70-71-payload.thinking = { type: "enabled" };
72-payload.reasoning_effort = resolveDeepSeekReasoningEffort(thinkingLevel);
73-ensureDeepSeekToolCallReasoningContent(payload);
74-});
75-};
12+return createDeepSeekV4OpenAICompatibleThinkingWrapper({
13+ baseStreamFn,
14+ thinkingLevel,
15+shouldPatchModel: (model) => model.provider === "deepseek" && isDeepSeekV4ModelId(model.id),
16+});
7617}
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。