hzhang
8774cfd7cc
OpenClaw delivers an agent turn whose blocks are text -> thinking/tool -> text via multiple inbound deliver() calls (a non-text block is a delivery boundary), so one turn became N Fabric messages. Fix: buffer deliver() segments per channel (src/coalesce.ts) and flush them as ONE postMessage at a deterministic boundary — the finally after dispatchInboundReplyWithBase() resolves, which provably runs only after every deliver() of the turn (verified: deliver,deliver -> dispatch returned -> flush). No hooks, no timers, no idle guessing. The agent_end hook was rejected: it fires BEFORE deliver(). gateway_stop flushes any leftover; a long safety timeout is a leak-guard only. channels.fabric.coalesce=false restores raw per-segment posting. Verified on local openclaw + Fabric with a fake text/thinking/text model: single trigger -> exactly one merged message. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
53 lines
2.0 KiB
JavaScript
53 lines
2.0 KiB
JavaScript
// agent = openclaw channel account.
|
|
// Config shape:
|
|
// channels.fabric.centerApiBase = "http://localhost:7001/api" (shared)
|
|
// channels.fabric.accounts.<agentId> = { fabricApiKey, centerApiBase? }
|
|
// Each account id IS the openclaw agentId that owns that Fabric identity.
|
|
const DEFAULT_CENTER = 'http://localhost:7001/api';
|
|
function section(cfg) {
|
|
return cfg.channels?.fabric ?? {};
|
|
}
|
|
// The commands-sync shared secret (channel-level only). Empty string when
|
|
// unconfigured — callers decide how to handle (slash-command sync is then
|
|
// rejected by the guild).
|
|
export function resolveCommandsSyncKey(cfg) {
|
|
return (section(cfg).commandsSyncKey ?? '').trim();
|
|
}
|
|
// Whether to coalesce a split agent turn into one Fabric message
|
|
// (channel-level). Default true.
|
|
export function resolveCoalesce(cfg) {
|
|
return (cfg.channels?.fabric ?? {}).coalesce !== false;
|
|
}
|
|
export function listFabricAccountIds(cfg) {
|
|
const accts = section(cfg).accounts ?? {};
|
|
const ids = Object.keys(accts);
|
|
return ids.length ? ids : ['default'];
|
|
}
|
|
export function resolveDefaultFabricAccountId(cfg) {
|
|
const s = section(cfg);
|
|
if (s.defaultAccount)
|
|
return s.defaultAccount;
|
|
const ids = listFabricAccountIds(cfg);
|
|
return ids[0] ?? 'default';
|
|
}
|
|
export function resolveFabricAccount(cfg, accountId) {
|
|
const s = section(cfg);
|
|
const id = accountId ?? resolveDefaultFabricAccountId(cfg);
|
|
const acc = s.accounts?.[id] ?? {};
|
|
const fabricApiKey = (acc.fabricApiKey ?? '').trim();
|
|
const centerApiBase = (acc.centerApiBase ?? s.centerApiBase ?? DEFAULT_CENTER).trim();
|
|
return {
|
|
accountId: id,
|
|
enabled: acc.enabled !== false && s.enabled !== false,
|
|
centerApiBase,
|
|
fabricApiKey,
|
|
allowFrom: acc.allowFrom ?? s.allowFrom ?? [],
|
|
dmPolicy: acc.dmPolicy ?? s.dmPolicy,
|
|
};
|
|
}
|
|
export function listEnabledFabricAccounts(cfg) {
|
|
return listFabricAccountIds(cfg)
|
|
.map((id) => resolveFabricAccount(cfg, id))
|
|
.filter((a) => a.enabled && a.fabricApiKey);
|
|
}
|