vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 05:30:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(plugins): keep explicit web providers on fast path

Browse Source
This commit is contained in:
Vincent Koc
2026-05-04 16:53:12 -07:00
parent 6dae3c273d
commit d253392ea2
2 changed files with 14 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

74
src/agents/openai-transport-stream.test.ts
View File

@@ -781,8 +781,8 @@ describe("openai transport stream", () => {
expect(output.stopReason).toBe("stop");
});
it("keeps OpenRouter thinking format for declared OpenRouter providers on custom proxy URLs", async () => {
const streamFn = buildTransportAwareSimpleStreamFn(
it("keeps OpenRouter thinking format for declared OpenRouter providers on custom proxy URLs", () => {
const params = buildOpenAICompletionsParams(
attachModelProviderRequestTransport(
{
id: "anthropic/claude-sonnet-4",
@@ -803,28 +803,6 @@ describe("openai transport stream", () => {
},
},
),
);
expect(streamFn).toBeTypeOf("function");
let capturedPayload: Record<string, unknown> | undefined;
let resolveCaptured!: () => void;
const captured = new Promise<void>((resolve) => {
resolveCaptured = resolve;
});
void streamFn!(
{
id: "anthropic/claude-sonnet-4",
name: "Claude Sonnet 4",
api: "openclaw-openai-completions-transport",
provider: "openrouter",
baseUrl: "https://proxy.example.com/v1",
reasoning: true,
input: ["text"],
cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
contextWindow: 200000,
maxTokens: 8192,
} as Model<"openclaw-openai-completions-transport">,
{
systemPrompt: "system",
messages: [],
@@ -832,25 +810,18 @@ describe("openai transport stream", () => {
} as never,
{
reasoningEffort: "high",
onPayload: async (payload: unknown) => {
capturedPayload = payload as Record<string, unknown>;
resolveCaptured();
return payload;
},
} as never,
);
) as Record<string, unknown>;
await captured;
expect(capturedPayload).toMatchObject({
expect(params).toMatchObject({
reasoning: {
effort: "high",
},
});
});
it("keeps OpenRouter thinking format for native OpenRouter hosts behind custom provider ids", async () => {
const streamFn = buildTransportAwareSimpleStreamFn(
it("keeps OpenRouter thinking format for native OpenRouter hosts behind custom provider ids", () => {
const params = buildOpenAICompletionsParams(
attachModelProviderRequestTransport(
{
id: "anthropic/claude-sonnet-4",
@@ -871,28 +842,6 @@ describe("openai transport stream", () => {
},
},
),
);
expect(streamFn).toBeTypeOf("function");
let capturedPayload: Record<string, unknown> | undefined;
let resolveCaptured!: () => void;
const captured = new Promise<void>((resolve) => {
resolveCaptured = resolve;
});
void streamFn!(
{
id: "anthropic/claude-sonnet-4",
name: "Claude Sonnet 4",
api: "openclaw-openai-completions-transport",
provider: "custom-openrouter",
baseUrl: "https://openrouter.ai/api/v1",
reasoning: true,
input: ["text"],
cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0 },
contextWindow: 200000,
maxTokens: 8192,
} as Model<"openclaw-openai-completions-transport">,
{
systemPrompt: "system",
messages: [],
@@ -900,17 +849,10 @@ describe("openai transport stream", () => {
} as never,
{
reasoningEffort: "high",
onPayload: async (payload: unknown) => {
capturedPayload = payload as Record<string, unknown>;
resolveCaptured();
return payload;
},
} as never,
);
) as Record<string, unknown>;
await captured;
expect(capturedPayload).toMatchObject({
expect(params).toMatchObject({
reasoning: {
effort: "high",
},

12
src/plugins/web-provider-public-artifacts.ts
View File

@@ -54,17 +54,17 @@ function resolveBundledCandidatePluginIds(params: {
bundledAllowlistCompat?: boolean;
onlyPluginIds?: readonly string[];
}): BundledCandidateResolution {
const resolvedConfig =
params.contract === "webSearchProviders"
? resolveBundledWebSearchResolutionConfig(params).config
: resolveBundledWebFetchResolutionConfig(params).config;
if (params.onlyPluginIds && params.onlyPluginIds.length > 0) {
if (params.onlyPluginIds !== undefined) {
return {
pluginIds: filterAllowlistedBundledPluginIds(resolvedConfig, [
pluginIds: filterAllowlistedBundledPluginIds(params.config, [
...new Set(params.onlyPluginIds),
]).toSorted((left, right) => left.localeCompare(right)),
};
}
const resolvedConfig =
params.contract === "webSearchProviders"
? resolveBundledWebSearchResolutionConfig(params).config
: resolveBundledWebFetchResolutionConfig(params).config;
const candidates = resolveManifestDeclaredWebProviderCandidates({
contract: params.contract,
configKey: params.configKey,