File size: 2,359 Bytes
76289e7 | 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 | // Agent bind Matrix integration tests cover account binding resolution through plugin registry surfaces.
import { afterEach, describe, expect, it } from "vitest";
import { setActivePluginRegistry } from "../plugins/runtime.js";
import {
createBindingResolverTestPlugin,
createTestRegistry,
} from "../test-utils/channel-plugins.js";
import { parseBindingSpecs } from "./agents.bindings.js";
const matrixBindingPlugin = createBindingResolverTestPlugin({
id: "matrix",
resolveBindingAccountId: ({ accountId, agentId }) => {
const explicit = accountId?.trim();
if (explicit) {
return explicit;
}
const agent = agentId?.trim();
return agent || "default";
},
});
describe("agents bind matrix integration", () => {
it("uses matrix plugin binding resolver when accountId is omitted", () => {
setActivePluginRegistry(
createTestRegistry([{ pluginId: "matrix", plugin: matrixBindingPlugin, source: "test" }]),
);
const parsed = parseBindingSpecs({ agentId: "main", specs: ["matrix"], config: {} });
expect(parsed.errors).toStrictEqual([]);
expect(parsed.bindings).toEqual([
{ type: "route", agentId: "main", match: { channel: "matrix", accountId: "main" } },
]);
});
it("rejects a binding spec with extra colon segments instead of silently truncating", () => {
setActivePluginRegistry(
createTestRegistry([{ pluginId: "matrix", plugin: matrixBindingPlugin, source: "test" }]),
);
const parsed = parseBindingSpecs({ agentId: "main", specs: ["matrix:work:extra"], config: {} });
expect(parsed.bindings).toEqual([]);
expect(parsed.errors).toEqual([
'Invalid binding "matrix:work:extra". Account id cannot contain ":". Use <channel>:<account>, for example telegram:default.',
]);
});
it("still accepts a single channel:account binding", () => {
setActivePluginRegistry(
createTestRegistry([{ pluginId: "matrix", plugin: matrixBindingPlugin, source: "test" }]),
);
const parsed = parseBindingSpecs({ agentId: "main", specs: ["matrix:work"], config: {} });
expect(parsed.errors).toStrictEqual([]);
expect(parsed.bindings).toEqual([
{ type: "route", agentId: "main", match: { channel: "matrix", accountId: "work" } },
]);
});
afterEach(() => {
setActivePluginRegistry(createTestRegistry());
});
});
|