Spaces:
Running
Running
File size: 3,809 Bytes
fb4d8fe | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 | import type { OpenClawConfig } from "../config/config.js";
import type { AgentBinding } from "../config/types.agents.js";
import { resolveDefaultAgentId } from "../agents/agent-scope.js";
import { normalizeChatChannelId } from "../channels/registry.js";
import { normalizeAccountId, normalizeAgentId } from "./session-key.js";
function normalizeBindingChannelId(raw?: string | null): string | null {
const normalized = normalizeChatChannelId(raw);
if (normalized) {
return normalized;
}
const fallback = (raw ?? "").trim().toLowerCase();
return fallback || null;
}
export function listBindings(cfg: OpenClawConfig): AgentBinding[] {
return Array.isArray(cfg.bindings) ? cfg.bindings : [];
}
export function listBoundAccountIds(cfg: OpenClawConfig, channelId: string): string[] {
const normalizedChannel = normalizeBindingChannelId(channelId);
if (!normalizedChannel) {
return [];
}
const ids = new Set<string>();
for (const binding of listBindings(cfg)) {
if (!binding || typeof binding !== "object") {
continue;
}
const match = binding.match;
if (!match || typeof match !== "object") {
continue;
}
const channel = normalizeBindingChannelId(match.channel);
if (!channel || channel !== normalizedChannel) {
continue;
}
const accountId = typeof match.accountId === "string" ? match.accountId.trim() : "";
if (!accountId || accountId === "*") {
continue;
}
ids.add(normalizeAccountId(accountId));
}
return Array.from(ids).toSorted((a, b) => a.localeCompare(b));
}
export function resolveDefaultAgentBoundAccountId(
cfg: OpenClawConfig,
channelId: string,
): string | null {
const normalizedChannel = normalizeBindingChannelId(channelId);
if (!normalizedChannel) {
return null;
}
const defaultAgentId = normalizeAgentId(resolveDefaultAgentId(cfg));
for (const binding of listBindings(cfg)) {
if (!binding || typeof binding !== "object") {
continue;
}
if (normalizeAgentId(binding.agentId) !== defaultAgentId) {
continue;
}
const match = binding.match;
if (!match || typeof match !== "object") {
continue;
}
const channel = normalizeBindingChannelId(match.channel);
if (!channel || channel !== normalizedChannel) {
continue;
}
const accountId = typeof match.accountId === "string" ? match.accountId.trim() : "";
if (!accountId || accountId === "*") {
continue;
}
return normalizeAccountId(accountId);
}
return null;
}
export function buildChannelAccountBindings(cfg: OpenClawConfig) {
const map = new Map<string, Map<string, string[]>>();
for (const binding of listBindings(cfg)) {
if (!binding || typeof binding !== "object") {
continue;
}
const match = binding.match;
if (!match || typeof match !== "object") {
continue;
}
const channelId = normalizeBindingChannelId(match.channel);
if (!channelId) {
continue;
}
const accountId = typeof match.accountId === "string" ? match.accountId.trim() : "";
if (!accountId || accountId === "*") {
continue;
}
const agentId = normalizeAgentId(binding.agentId);
const byAgent = map.get(channelId) ?? new Map<string, string[]>();
const list = byAgent.get(agentId) ?? [];
const normalizedAccountId = normalizeAccountId(accountId);
if (!list.includes(normalizedAccountId)) {
list.push(normalizedAccountId);
}
byAgent.set(agentId, list);
map.set(channelId, byAgent);
}
return map;
}
export function resolvePreferredAccountId(params: {
accountIds: string[];
defaultAccountId: string;
boundAccounts: string[];
}): string {
if (params.boundAccounts.length > 0) {
return params.boundAccounts[0];
}
return params.defaultAccountId;
}
|