惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
美团技术团队
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
月光博客
月光博客
J
Java Code Geeks
Jina AI
Jina AI
罗磊的独立博客
宝玉的分享
宝玉的分享
S
SegmentFault 最新的问题
D
DataBreaches.Net
博客园 - 叶小钗
腾讯CDC
freeCodeCamp Programming Tutorials: Python, JavaScript, Git & More
Last Week in AI
Last Week in AI
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
Google DeepMind News
Google DeepMind News
阮一峰的网络日志
阮一峰的网络日志
B
Blog
V
Visual Studio Blog
雷峰网
雷峰网
博客园 - 【当耐特】
Apple Machine Learning Research
Apple Machine Learning Research
Engineering at Meta
Engineering at Meta
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报

Recent Commits to openclaw:main

test: merge chat side-result checks · openclaw/openclaw@ddd2c2a test: merge cron history checks · openclaw/openclaw@f7eb746 test: merge responsive navigation shell checks · openclaw/openclaw@c2e4b47 docs(changelog): add codex oauth fixes · openclaw/openclaw@628e6cd test: merge navigation routing cases · openclaw/openclaw@5d8cecb Tests: mock channel registry bundled fallback · openclaw/openclaw@2b08233 Secrets: avoid broad web search discovery for single plugin config · openclaw/openclaw@a464f59 test: merge config view browser checks · openclaw/openclaw@20cf511 fix(status): align oauth health with runtime · openclaw/openclaw@eed7116 feat: add macOS screen snapshots for monitor preview (#67954) thanks … · openclaw/openclaw@f377db1 fix: report shared auth scopes in hello-ok (#67810) thanks @BunsDev · openclaw/openclaw@0b6c39b Auto-reply: avoid eager bundled route fallback · openclaw/openclaw@3ea1bf4 Tests: narrow session binding contract setup · openclaw/openclaw@54e4e16 fix(macOS): enable undo/redo in webchat composer text input (#34962) · openclaw/openclaw@00951dc Tests: speed up channel setup promotion · openclaw/openclaw@82b529a Docs: refresh agent instructions · openclaw/openclaw@5775fe2 fix(auth): serialize OAuth refresh across agents to fix #26322 (#67876) · openclaw/openclaw@8e79080 test: allow ollama public surface boundary test · openclaw/openclaw@7d4f1a6 Docs: add test performance guardrails · openclaw/openclaw@89706d3 Tests: restore context-engine usage proof · openclaw/openclaw@e4c4f95 Tests: slim context engine runtime coverage · openclaw/openclaw@74c198f ci: retry failed custom checkouts · openclaw/openclaw@0ee5baf test: trim duplicate provider auth onboarding cases · openclaw/openclaw@1ffc02e matrix: fix sessions_spawn --thread subagent session spawning (#67643) · openclaw/openclaw@1ce2596 test: reduce auth choice fixture churn · openclaw/openclaw@857b9cd test: mock health status config boundaries · openclaw/openclaw@9d5ab4a test: mock onboard config io boundary · openclaw/openclaw@299694d test: mock legacy state plugin boundaries · openclaw/openclaw@2713089 test: mock channel install boundaries · openclaw/openclaw@b945248 test: mock doctor preview channel boundaries · openclaw/openclaw@b1a3ad4
refactor: share fal provider http auth · openclaw/opencla...
vincentkoc · 2026-05-29 · via Recent Commits to openclaw:main
Original file line numberDiff line numberDiff line change

@@ -0,0 +1,48 @@

1+

import { type AuthProfileStore, type OpenClawConfig } from "openclaw/plugin-sdk/provider-auth";

2+

import { resolveApiKeyForProvider } from "openclaw/plugin-sdk/provider-auth-runtime";

3+

import {

4+

resolveProviderHttpRequestConfig,

5+

type ProviderRequestCapability,

6+

} from "openclaw/plugin-sdk/provider-http";

7+

import { normalizeOptionalString } from "openclaw/plugin-sdk/string-coerce-runtime";

8+
9+

const DEFAULT_FAL_BASE_URL = "https://fal.run";

10+
11+

type FalAuthenticatedRequest = {

12+

cfg?: OpenClawConfig;

13+

agentDir?: string;

14+

authStore?: AuthProfileStore;

15+

};

16+
17+

function resolveFalConfiguredBaseUrl(cfg?: OpenClawConfig): string | undefined {

18+

return normalizeOptionalString(cfg?.models?.providers?.fal?.baseUrl);

19+

}

20+
21+

export async function resolveFalHttpRequestConfig(params: {

22+

req: FalAuthenticatedRequest;

23+

baseUrl?: string;

24+

capability: ProviderRequestCapability;

25+

}): Promise<ReturnType<typeof resolveProviderHttpRequestConfig>> {

26+

const auth = await resolveApiKeyForProvider({

27+

provider: "fal",

28+

cfg: params.req.cfg,

29+

agentDir: params.req.agentDir,

30+

store: params.req.authStore,

31+

});

32+

if (!auth.apiKey) {

33+

throw new Error("fal API key missing");

34+

}

35+
36+

return resolveProviderHttpRequestConfig({

37+

baseUrl: params.baseUrl ?? resolveFalConfiguredBaseUrl(params.req.cfg),

38+

defaultBaseUrl: DEFAULT_FAL_BASE_URL,

39+

allowPrivateNetwork: false,

40+

defaultHeaders: {

41+

Authorization: `Key ${auth.apiKey}`,

42+

"Content-Type": "application/json",

43+

},

44+

provider: "fal",

45+

capability: params.capability,

46+

transport: "http",

47+

});

48+

}

Original file line numberDiff line numberDiff line change

@@ -8,11 +8,9 @@ import {

88

toImageDataUrl,

99

} from "openclaw/plugin-sdk/image-generation";

1010

import { isProviderApiKeyConfigured } from "openclaw/plugin-sdk/provider-auth";

11-

import { resolveApiKeyForProvider } from "openclaw/plugin-sdk/provider-auth-runtime";

1211

import {

1312

assertOkOrThrowHttpError,

1413

assertOkOrThrowProviderError,

15-

resolveProviderHttpRequestConfig,

1614

} from "openclaw/plugin-sdk/provider-http";

1715

import {

1816

buildHostnameAllowlistPolicyFromSuffixAllowlist,

@@ -26,8 +24,8 @@ import {

2624

normalizeLowercaseStringOrEmpty,

2725

normalizeOptionalString,

2826

} from "openclaw/plugin-sdk/string-coerce-runtime";

27+

import { resolveFalHttpRequestConfig } from "./http-config.js";

2928
30-

const DEFAULT_FAL_BASE_URL = "https://fal.run";

3129

const DEFAULT_FAL_IMAGE_MODEL = "fal-ai/flux/dev";

3230

const DEFAULT_FAL_EDIT_SUBPATH = "image-to-image";

3331

const FAL_KREA_2_MODEL_PREFIX = "krea/v2/";

@@ -551,15 +549,6 @@ export function buildFalImageGenerationProvider(): ImageGenerationProvider {

551549

},

552550

},

553551

async generateImage(req) {

554-

const auth = await resolveApiKeyForProvider({

555-

provider: "fal",

556-

cfg: req.cfg,

557-

agentDir: req.agentDir,

558-

store: req.authStore,

559-

});

560-

if (!auth.apiKey) {

561-

throw new Error("fal API key missing");

562-

}

563552

const inputImageCount = req.inputImages?.length ?? 0;

564553

const hasInputImages = inputImageCount > 0;

565554

const requestedModel = req.model?.trim() || DEFAULT_FAL_IMAGE_MODEL;

@@ -588,20 +577,8 @@ export function buildFalImageGenerationProvider(): ImageGenerationProvider {

588577

if (!schema.supportsOutputFormat && req.outputFormat) {

589578

throw new Error(`fal ${requestedModel} does not support outputFormat overrides`);

590579

}

591-

const explicitBaseUrl = req.cfg?.models?.providers?.fal?.baseUrl?.trim();

592580

const { baseUrl, allowPrivateNetwork, headers, dispatcherPolicy } =

593-

resolveProviderHttpRequestConfig({

594-

baseUrl: explicitBaseUrl,

595-

defaultBaseUrl: DEFAULT_FAL_BASE_URL,

596-

allowPrivateNetwork: false,

597-

defaultHeaders: {

598-

Authorization: `Key ${auth.apiKey}`,

599-

"Content-Type": "application/json",

600-

},

601-

provider: "fal",

602-

capability: "image",

603-

transport: "http",

604-

});

581+

await resolveFalHttpRequestConfig({ req, capability: "image" });

605582

const networkPolicy = resolveFalNetworkPolicy({ baseUrl, allowPrivateNetwork });

606583

const requestBody: Record<string, unknown> = {

607584

prompt: req.prompt,

Original file line numberDiff line numberDiff line change

@@ -5,15 +5,10 @@ import {

55

type MusicGenerationRequest,

66

} from "openclaw/plugin-sdk/music-generation";

77

import { isProviderApiKeyConfigured } from "openclaw/plugin-sdk/provider-auth";

8-

import { resolveApiKeyForProvider } from "openclaw/plugin-sdk/provider-auth-runtime";

9-

import {

10-

assertOkOrThrowHttpError,

11-

postJsonRequest,

12-

resolveProviderHttpRequestConfig,

13-

} from "openclaw/plugin-sdk/provider-http";

8+

import { assertOkOrThrowHttpError, postJsonRequest } from "openclaw/plugin-sdk/provider-http";

149

import { normalizeOptionalString } from "openclaw/plugin-sdk/string-coerce-runtime";

10+

import { resolveFalHttpRequestConfig } from "./http-config.js";

1511
16-

const DEFAULT_FAL_BASE_URL = "https://fal.run";

1712

const DEFAULT_FAL_MUSIC_MODEL = "fal-ai/minimax-music/v2.6";

1813

const FAL_ACE_STEP_MODEL = "fal-ai/ace-step/prompt-to-audio";

1914

const FAL_STABLE_AUDIO_MODEL = "fal-ai/stable-audio-25/text-to-audio";

@@ -29,10 +24,6 @@ function resolveFalMusicModel(model: string | undefined): string {

2924

return normalizeOptionalString(model) ?? DEFAULT_FAL_MUSIC_MODEL;

3025

}

3126
32-

function resolveFalMusicBaseUrl(req: MusicGenerationRequest): string | undefined {

33-

return normalizeOptionalString(req.cfg?.models?.providers?.fal?.baseUrl);

34-

}

35-
3627

function buildFalMinimaxBody(req: MusicGenerationRequest): Record<string, unknown> {

3728

const lyrics = normalizeOptionalString(req.lyrics);

3829

if (lyrics && req.instrumental === true) {

@@ -145,29 +136,8 @@ export function buildFalMusicGenerationProvider(): MusicGenerationProvider {

145136

throw new Error("fal music generation does not support image reference inputs.");

146137

}

147138
148-

const auth = await resolveApiKeyForProvider({

149-

provider: "fal",

150-

cfg: req.cfg,

151-

agentDir: req.agentDir,

152-

store: req.authStore,

153-

});

154-

if (!auth.apiKey) {

155-

throw new Error("fal API key missing");

156-

}

157-
158139

const { baseUrl, allowPrivateNetwork, headers, dispatcherPolicy } =

159-

resolveProviderHttpRequestConfig({

160-

baseUrl: resolveFalMusicBaseUrl(req),

161-

defaultBaseUrl: DEFAULT_FAL_BASE_URL,

162-

allowPrivateNetwork: false,

163-

defaultHeaders: {

164-

Authorization: `Key ${auth.apiKey}`,

165-

"Content-Type": "application/json",

166-

},

167-

provider: "fal",

168-

capability: "audio",

169-

transport: "http",

170-

});

140+

await resolveFalHttpRequestConfig({ req, capability: "audio" });

171141

const model = resolveFalMusicModel(req.model);

172142

const { response, release } = await postJsonRequest({

173143

url: `${baseUrl}/${model}`,

Original file line numberDiff line numberDiff line change

@@ -1,10 +1,6 @@

11

import { extensionForMime } from "openclaw/plugin-sdk/media-mime";

22

import { isProviderApiKeyConfigured } from "openclaw/plugin-sdk/provider-auth";

3-

import { resolveApiKeyForProvider } from "openclaw/plugin-sdk/provider-auth-runtime";

4-

import {

5-

assertOkOrThrowHttpError,

6-

resolveProviderHttpRequestConfig,

7-

} from "openclaw/plugin-sdk/provider-http";

3+

import { assertOkOrThrowHttpError } from "openclaw/plugin-sdk/provider-http";

84

import {

95

fetchWithSsrFGuard,

106

type SsrFPolicy,

@@ -20,8 +16,8 @@ import type {

2016

VideoGenerationProvider,

2117

VideoGenerationRequest,

2218

} from "openclaw/plugin-sdk/video-generation";

19+

import { resolveFalHttpRequestConfig } from "./http-config.js";

2320
24-

const DEFAULT_FAL_BASE_URL = "https://fal.run";

2521

const DEFAULT_FAL_QUEUE_BASE_URL = "https://queue.fal.run";

2622

const DEFAULT_FAL_VIDEO_MODEL = "fal-ai/minimax/video-01-live";

2723

const HEYGEN_VIDEO_AGENT_MODEL = "fal-ai/heygen/v2/video-agent";

@@ -573,28 +569,8 @@ export function buildFalVideoGenerationProvider(): VideoGenerationProvider {

573569

async generateVideo(req) {

574570

const model = normalizeOptionalString(req.model) || DEFAULT_FAL_VIDEO_MODEL;

575571

validateFalVideoReferenceInputs({ req, model });

576-

const auth = await resolveApiKeyForProvider({

577-

provider: "fal",

578-

cfg: req.cfg,

579-

agentDir: req.agentDir,

580-

store: req.authStore,

581-

});

582-

if (!auth.apiKey) {

583-

throw new Error("fal API key missing");

584-

}

585572

const { baseUrl, allowPrivateNetwork, headers, dispatcherPolicy } =

586-

resolveProviderHttpRequestConfig({

587-

baseUrl: normalizeOptionalString(req.cfg?.models?.providers?.fal?.baseUrl),

588-

defaultBaseUrl: DEFAULT_FAL_BASE_URL,

589-

allowPrivateNetwork: false,

590-

defaultHeaders: {

591-

Authorization: `Key ${auth.apiKey}`,

592-

"Content-Type": "application/json",

593-

},

594-

provider: "fal",

595-

capability: "video",

596-

transport: "http",

597-

});

573+

await resolveFalHttpRequestConfig({ req, capability: "video" });

598574

const requestBody = buildFalVideoRequestBody({ req, model });

599575

const policy = buildPolicy(allowPrivateNetwork);

600576

const queueBaseUrl = resolveFalQueueBaseUrl(baseUrl);