ewilliams28/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-12 21:53:00 -06:00
Code Issues Packages Projects Releases Wiki Activity

refactor(meta): inline response payload patching

Browse Source
This commit is contained in:
Amp
2026-08-12 15:20:42 +00:00
committed by Peter Steinberger
parent 22d437def9
commit 72f4ee2274
1 changed files with 10 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
extensions/meta/stream.ts
+10 -19
View File
@@ -6,18 +6,11 @@ import { filterStringEntries } from "openclaw/plugin-sdk/string-coerce-runtime";
const META_REASONING_ENCRYPTED_CONTENT_INCLUDE = "reasoning.encrypted_content";
function ensureMetaResponsesReplayFields(payloadObj: Record<string, unknown>): void {
const existing = payloadObj.include;
const include = filterStringEntries(existing);
if (!include.includes(META_REASONING_ENCRYPTED_CONTENT_INCLUDE)) {
include.push(META_REASONING_ENCRYPTED_CONTENT_INCLUDE);
export function wrapMetaProviderStream(ctx: ProviderWrapStreamFnContext): StreamFn | undefined {
if (ctx.provider !== "meta" || (ctx.sourceApi ?? ctx.model?.api) !== "openai-responses") {
return undefined;
}
payloadObj.include = include;
payloadObj.store = false;
}
function createMetaResponsesWrapper(baseStreamFn: StreamFn | undefined): StreamFn {
return createPayloadPatchStreamWrapper(baseStreamFn, ({ payload, model, options }) => {
return createPayloadPatchStreamWrapper(ctx.streamFn, ({ payload, model, options }) => {
if (model.provider !== "meta") {
return;
}
@@ -29,13 +22,11 @@ function createMetaResponsesWrapper(baseStreamFn: StreamFn | undefined): StreamF
if (!model.reasoning) {
return;
}
ensureMetaResponsesReplayFields(payload);
const include = filterStringEntries(payload.include);
if (!include.includes(META_REASONING_ENCRYPTED_CONTENT_INCLUDE)) {
include.push(META_REASONING_ENCRYPTED_CONTENT_INCLUDE);
}
payload.include = include;
payload.store = false;
});
}
export function wrapMetaProviderStream(ctx: ProviderWrapStreamFnContext): StreamFn | undefined {
if (ctx.provider !== "meta" || (ctx.sourceApi ?? ctx.model?.api) !== "openai-responses") {
return undefined;
}
return createMetaResponsesWrapper(ctx.streamFn);
}