mirror of
https://github.com/openclaw/openclaw.git
synced 2026-04-17 12:11:20 +00:00
176 lines
5.6 KiB
TypeScript
176 lines
5.6 KiB
TypeScript
import type { OpenClawConfig } from "../config/config.js";
|
|
import { normalizeOptionalAccountId } from "../routing/session-key.js";
|
|
import {
|
|
discoverConfigSecretTargetsByIds,
|
|
listSecretTargetRegistryEntries,
|
|
} from "../secrets/target-registry.js";
|
|
|
|
const STATIC_QR_REMOTE_TARGET_IDS = ["gateway.remote.token", "gateway.remote.password"] as const;
|
|
const STATIC_MODEL_TARGET_IDS = [
|
|
"models.providers.*.apiKey",
|
|
"models.providers.*.headers.*",
|
|
"models.providers.*.request.headers.*",
|
|
"models.providers.*.request.auth.token",
|
|
"models.providers.*.request.auth.value",
|
|
"models.providers.*.request.proxy.tls.ca",
|
|
"models.providers.*.request.proxy.tls.cert",
|
|
"models.providers.*.request.proxy.tls.key",
|
|
"models.providers.*.request.proxy.tls.passphrase",
|
|
"models.providers.*.request.tls.ca",
|
|
"models.providers.*.request.tls.cert",
|
|
"models.providers.*.request.tls.key",
|
|
"models.providers.*.request.tls.passphrase",
|
|
] as const;
|
|
const STATIC_AGENT_RUNTIME_TARGET_IDS = [
|
|
...STATIC_MODEL_TARGET_IDS,
|
|
"agents.defaults.memorySearch.remote.apiKey",
|
|
"agents.list[].memorySearch.remote.apiKey",
|
|
"messages.tts.providers.*.apiKey",
|
|
"skills.entries.*.apiKey",
|
|
"tools.web.search.apiKey",
|
|
"plugins.entries.brave.config.webSearch.apiKey",
|
|
"plugins.entries.google.config.webSearch.apiKey",
|
|
"plugins.entries.xai.config.webSearch.apiKey",
|
|
"plugins.entries.moonshot.config.webSearch.apiKey",
|
|
"plugins.entries.perplexity.config.webSearch.apiKey",
|
|
"plugins.entries.firecrawl.config.webSearch.apiKey",
|
|
"plugins.entries.firecrawl.config.webFetch.apiKey",
|
|
"plugins.entries.tavily.config.webSearch.apiKey",
|
|
"plugins.entries.minimax.config.webSearch.apiKey",
|
|
] as const;
|
|
const STATIC_STATUS_TARGET_IDS = [
|
|
"agents.defaults.memorySearch.remote.apiKey",
|
|
"agents.list[].memorySearch.remote.apiKey",
|
|
] as const;
|
|
const STATIC_SECURITY_AUDIT_TARGET_IDS = [
|
|
"gateway.auth.token",
|
|
"gateway.auth.password",
|
|
"gateway.remote.token",
|
|
"gateway.remote.password",
|
|
] as const;
|
|
|
|
function idsByPrefix(prefixes: readonly string[]): string[] {
|
|
return listSecretTargetRegistryEntries()
|
|
.map((entry) => entry.id)
|
|
.filter((id) => prefixes.some((prefix) => id.startsWith(prefix)))
|
|
.toSorted();
|
|
}
|
|
|
|
type CommandSecretTargets = {
|
|
channels: string[];
|
|
agentRuntime: string[];
|
|
status: string[];
|
|
securityAudit: string[];
|
|
};
|
|
|
|
let cachedCommandSecretTargets: CommandSecretTargets | undefined;
|
|
let cachedChannelSecretTargetIds: string[] | undefined;
|
|
|
|
function getChannelSecretTargetIds(): string[] {
|
|
cachedChannelSecretTargetIds ??= idsByPrefix(["channels."]);
|
|
return cachedChannelSecretTargetIds;
|
|
}
|
|
|
|
function buildCommandSecretTargets(): CommandSecretTargets {
|
|
const channelTargetIds = getChannelSecretTargetIds();
|
|
return {
|
|
channels: channelTargetIds,
|
|
agentRuntime: [...STATIC_AGENT_RUNTIME_TARGET_IDS, ...channelTargetIds],
|
|
status: [...STATIC_STATUS_TARGET_IDS, ...channelTargetIds],
|
|
securityAudit: [...STATIC_SECURITY_AUDIT_TARGET_IDS, ...channelTargetIds],
|
|
};
|
|
}
|
|
|
|
function getCommandSecretTargets(): CommandSecretTargets {
|
|
cachedCommandSecretTargets ??= buildCommandSecretTargets();
|
|
return cachedCommandSecretTargets;
|
|
}
|
|
|
|
function toTargetIdSet(values: readonly string[]): Set<string> {
|
|
return new Set(values);
|
|
}
|
|
|
|
function normalizeScopedChannelId(value?: string | null): string | undefined {
|
|
const trimmed = value?.trim();
|
|
return trimmed ? trimmed : undefined;
|
|
}
|
|
|
|
function selectChannelTargetIds(channel?: string): Set<string> {
|
|
const commandSecretTargets = getCommandSecretTargets();
|
|
if (!channel) {
|
|
return toTargetIdSet(commandSecretTargets.channels);
|
|
}
|
|
return toTargetIdSet(
|
|
commandSecretTargets.channels.filter((id) => id.startsWith(`channels.${channel}.`)),
|
|
);
|
|
}
|
|
|
|
function pathTargetsScopedChannelAccount(params: {
|
|
pathSegments: readonly string[];
|
|
channel: string;
|
|
accountId: string;
|
|
}): boolean {
|
|
const [root, channelId, accountRoot, accountId] = params.pathSegments;
|
|
if (root !== "channels" || channelId !== params.channel) {
|
|
return false;
|
|
}
|
|
if (accountRoot !== "accounts") {
|
|
return true;
|
|
}
|
|
return accountId === params.accountId;
|
|
}
|
|
|
|
export function getScopedChannelsCommandSecretTargets(params: {
|
|
config: OpenClawConfig;
|
|
channel?: string | null;
|
|
accountId?: string | null;
|
|
}): {
|
|
targetIds: Set<string>;
|
|
allowedPaths?: Set<string>;
|
|
} {
|
|
const channel = normalizeScopedChannelId(params.channel);
|
|
const targetIds = selectChannelTargetIds(channel);
|
|
const normalizedAccountId = normalizeOptionalAccountId(params.accountId);
|
|
if (!channel || !normalizedAccountId) {
|
|
return { targetIds };
|
|
}
|
|
|
|
const allowedPaths = new Set<string>();
|
|
for (const target of discoverConfigSecretTargetsByIds(params.config, targetIds)) {
|
|
if (
|
|
pathTargetsScopedChannelAccount({
|
|
pathSegments: target.pathSegments,
|
|
channel,
|
|
accountId: normalizedAccountId,
|
|
})
|
|
) {
|
|
allowedPaths.add(target.path);
|
|
}
|
|
}
|
|
return { targetIds, allowedPaths };
|
|
}
|
|
|
|
export function getQrRemoteCommandSecretTargetIds(): Set<string> {
|
|
return toTargetIdSet(STATIC_QR_REMOTE_TARGET_IDS);
|
|
}
|
|
|
|
export function getChannelsCommandSecretTargetIds(): Set<string> {
|
|
return toTargetIdSet(getCommandSecretTargets().channels);
|
|
}
|
|
|
|
export function getModelsCommandSecretTargetIds(): Set<string> {
|
|
return toTargetIdSet(STATIC_MODEL_TARGET_IDS);
|
|
}
|
|
|
|
export function getAgentRuntimeCommandSecretTargetIds(): Set<string> {
|
|
return toTargetIdSet(getCommandSecretTargets().agentRuntime);
|
|
}
|
|
|
|
export function getStatusCommandSecretTargetIds(): Set<string> {
|
|
return toTargetIdSet(getCommandSecretTargets().status);
|
|
}
|
|
|
|
export function getSecurityAuditCommandSecretTargetIds(): Set<string> {
|
|
return toTargetIdSet(getCommandSecretTargets().securityAudit);
|
|
}
|