hzhang
9cb262367e
Real channel-turn dispatch (resolveAgentRoute + finalizeInboundContext + dispatchInboundReplyWithBase), wakeup->drop/dispatch, messaging target grammar (fabric:<id>) + outbound.sendText, tools use execute/parameters. Verified live: human msg in Fabric -> wakeup -> openclaw agent runs -> reply posted back into the Fabric channel as the agent. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
93 lines
3.3 KiB
TypeScript
93 lines
3.3 KiB
TypeScript
// Fabric channel plugin entry.
|
|
// COMPAT NOTE (openclaw v2026.5.7): defineChannelPluginEntry signature
|
|
// { id, name, description, plugin, setRuntime?, registerFull? }. setRuntime
|
|
// receives the PluginRuntime (has channel.turn kernel); registerFull receives
|
|
// the OpenClawPluginApi for runtime startup (transport + tools).
|
|
import { defineChannelPluginEntry } from 'openclaw/plugin-sdk/core';
|
|
import type { OpenClawPluginApi } from 'openclaw/plugin-sdk/core';
|
|
import { fabricChannelPlugin } from './src/channel.js';
|
|
import { FabricInbound } from './src/inbound.js';
|
|
import { listEnabledFabricAccounts } from './src/accounts.js';
|
|
import { registerFabricTools } from './src/tools.js';
|
|
import { FabricClient } from './src/fabric-client.js';
|
|
import { IdentityRegistry } from './src/identity.js';
|
|
import path from 'node:path';
|
|
import os from 'node:os';
|
|
|
|
let runtimeRef: unknown = null;
|
|
let inbound: FabricInbound | null = null;
|
|
|
|
export { fabricChannelPlugin } from './src/channel.js';
|
|
|
|
export default defineChannelPluginEntry({
|
|
id: 'fabric',
|
|
name: 'Fabric',
|
|
description: 'Fabric channel plugin — OpenClaw agents speak in Fabric guilds',
|
|
plugin: fabricChannelPlugin,
|
|
|
|
setRuntime(runtime: unknown) {
|
|
runtimeRef = runtime;
|
|
},
|
|
|
|
registerFull(apiRaw: OpenClawPluginApi) {
|
|
// COMPAT: access the subset we use through a loose view so SDK type
|
|
// drift in unrelated api members doesn't break the build.
|
|
const api = apiRaw as unknown as {
|
|
config?: unknown;
|
|
pluginConfig?: { identityFilePath?: string };
|
|
logger: { info: (m: string) => void; warn: (m: string) => void };
|
|
on: (ev: string, fn: () => void) => void;
|
|
registerTool: (d: unknown) => void;
|
|
};
|
|
const cfg = (api.config ?? {}) as { channels?: { fabric?: { centerApiBase?: string } } };
|
|
const centerApiBase = cfg.channels?.fabric?.centerApiBase ?? 'http://localhost:7001/api';
|
|
const idFile =
|
|
api.pluginConfig?.identityFilePath ??
|
|
path.join(os.homedir(), '.openclaw', 'fabric-identity.json');
|
|
|
|
// tools operate against a default Center; per-account keys come from config
|
|
const client = new FabricClient(centerApiBase);
|
|
const identity = new IdentityRegistry(idFile);
|
|
registerFabricTools(
|
|
{ registerTool: (d) => api.registerTool(d), logger: api.logger },
|
|
client,
|
|
identity,
|
|
);
|
|
|
|
api.on('gateway_start', () => {
|
|
const _G = globalThis as Record<string, unknown>;
|
|
if (_G._fabricInboundStarted) return;
|
|
_G._fabricInboundStarted = true;
|
|
const accounts = listEnabledFabricAccounts(cfg as never).map((a) => ({
|
|
agentId: a.accountId,
|
|
fabricApiKey: a.fabricApiKey,
|
|
}));
|
|
// also include any tool-registered identities
|
|
for (const e of identity.list()) {
|
|
if (!accounts.some((x) => x.agentId === e.agentId)) {
|
|
accounts.push({ agentId: e.agentId, fabricApiKey: e.fabricApiKey });
|
|
}
|
|
}
|
|
if (!runtimeRef) {
|
|
api.logger.warn('fabric: runtime not set; inbound disabled');
|
|
return;
|
|
}
|
|
inbound = new FabricInbound(
|
|
runtimeRef,
|
|
api.config,
|
|
client,
|
|
identity,
|
|
api.logger,
|
|
accounts,
|
|
);
|
|
void inbound.start();
|
|
api.logger.info(`fabric: inbound started for ${accounts.length} account(s)`);
|
|
});
|
|
|
|
api.on('gateway_stop', () => {
|
|
inbound?.stop();
|
|
inbound = null;
|
|
});
|
|
},
|
|
});
|