feat(FN-2616): merge fusion/fn-2616 (auto-resolved)
- feat(FN-2616): complete Step 5 — pass full quality gates - test(FN-2616): complete Step 4 — add Hermes plugin integration tests - test(FN-2616): complete Step 3 — add Hermes engine integration coverage - feat(FN-2616): complete Step 2 — align Hermes adapter option contract
This commit is contained in:
192
packages/engine/src/__tests__/hermes-runtime-integration.test.ts
Normal file
192
packages/engine/src/__tests__/hermes-runtime-integration.test.ts
Normal file
@@ -0,0 +1,192 @@
|
|||||||
|
import { describe, it, expect, vi, beforeEach, afterEach } from "vitest";
|
||||||
|
import type { AgentRuntime } from "../agent-runtime.js";
|
||||||
|
import { resolveRuntime } from "../runtime-resolution.js";
|
||||||
|
import { createResolvedAgentSession } from "../agent-session-helpers.js";
|
||||||
|
import type { PluginRunner } from "../plugin-runner.js";
|
||||||
|
import type { PluginRuntimeRegistration } from "@fusion/core";
|
||||||
|
|
||||||
|
const mockCreateFnAgent = vi.hoisted(() => vi.fn());
|
||||||
|
|
||||||
|
vi.mock("../logger.js", () => ({
|
||||||
|
createLogger: vi.fn(() => ({
|
||||||
|
log: vi.fn(),
|
||||||
|
warn: vi.fn(),
|
||||||
|
error: vi.fn(),
|
||||||
|
})),
|
||||||
|
}));
|
||||||
|
|
||||||
|
vi.mock("../pi.js", () => ({
|
||||||
|
createFnAgent: mockCreateFnAgent,
|
||||||
|
promptWithFallback: vi.fn().mockResolvedValue(undefined),
|
||||||
|
describeModel: vi.fn().mockReturnValue("pi/default"),
|
||||||
|
}));
|
||||||
|
|
||||||
|
function isAgentRuntime(value: unknown): value is AgentRuntime {
|
||||||
|
return (
|
||||||
|
typeof value === "object" &&
|
||||||
|
value !== null &&
|
||||||
|
"id" in value &&
|
||||||
|
"name" in value &&
|
||||||
|
typeof (value as AgentRuntime).createSession === "function" &&
|
||||||
|
typeof (value as AgentRuntime).promptWithFallback === "function" &&
|
||||||
|
typeof (value as AgentRuntime).describeModel === "function"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
function createMockPluginRunner(overrides: Partial<PluginRunner> = {}): PluginRunner {
|
||||||
|
return {
|
||||||
|
getPluginRuntimes: vi.fn().mockReturnValue([]),
|
||||||
|
getRuntimeById: vi.fn().mockReturnValue(undefined),
|
||||||
|
createRuntimeContext: vi.fn().mockResolvedValue({
|
||||||
|
pluginId: "fusion-plugin-hermes-runtime",
|
||||||
|
taskStore: {},
|
||||||
|
settings: {},
|
||||||
|
logger: { info: vi.fn(), warn: vi.fn(), error: vi.fn(), debug: vi.fn() },
|
||||||
|
emitEvent: vi.fn(),
|
||||||
|
}),
|
||||||
|
...overrides,
|
||||||
|
} as unknown as PluginRunner;
|
||||||
|
}
|
||||||
|
|
||||||
|
function createHermesRegistration(factoryImpl?: () => unknown): {
|
||||||
|
pluginId: string;
|
||||||
|
runtime: PluginRuntimeRegistration;
|
||||||
|
} {
|
||||||
|
return {
|
||||||
|
pluginId: "fusion-plugin-hermes-runtime",
|
||||||
|
runtime: {
|
||||||
|
metadata: {
|
||||||
|
runtimeId: "hermes",
|
||||||
|
name: "Hermes Runtime",
|
||||||
|
description: "Hermes-backed AI session using configured provider/model",
|
||||||
|
version: "0.1.0",
|
||||||
|
},
|
||||||
|
factory: vi.fn().mockImplementation(async () =>
|
||||||
|
factoryImpl
|
||||||
|
? factoryImpl()
|
||||||
|
: {
|
||||||
|
id: "hermes",
|
||||||
|
name: "Hermes Runtime",
|
||||||
|
createSession: vi.fn().mockResolvedValue({
|
||||||
|
session: { runtime: "hermes", prompt: vi.fn() },
|
||||||
|
sessionFile: "/tmp/hermes.session.json",
|
||||||
|
}),
|
||||||
|
promptWithFallback: vi.fn().mockResolvedValue(undefined),
|
||||||
|
describeModel: vi.fn().mockReturnValue("anthropic/claude-sonnet-4-5"),
|
||||||
|
},
|
||||||
|
),
|
||||||
|
},
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
describe("Hermes runtime integration via engine resolution pipeline", () => {
|
||||||
|
beforeEach(() => {
|
||||||
|
vi.clearAllMocks();
|
||||||
|
mockCreateFnAgent.mockResolvedValue({
|
||||||
|
session: { runtime: "pi", prompt: vi.fn() },
|
||||||
|
sessionFile: "/tmp/pi.session.json",
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
afterEach(() => {
|
||||||
|
vi.restoreAllMocks();
|
||||||
|
});
|
||||||
|
|
||||||
|
it("resolves Hermes runtime through PluginRunner lookup when runtimeHint is hermes", async () => {
|
||||||
|
const hermesRegistration = createHermesRegistration();
|
||||||
|
const pluginRunner = createMockPluginRunner({
|
||||||
|
getRuntimeById: vi.fn().mockReturnValue(hermesRegistration),
|
||||||
|
});
|
||||||
|
|
||||||
|
const resolved = await resolveRuntime({
|
||||||
|
sessionPurpose: "executor",
|
||||||
|
runtimeHint: "hermes",
|
||||||
|
pluginRunner,
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(resolved.runtimeId).toBe("hermes");
|
||||||
|
expect(resolved.wasConfigured).toBe(true);
|
||||||
|
expect(resolved.runtime.id).toBe("hermes");
|
||||||
|
expect(resolved.runtime.name).toBe("Hermes Runtime");
|
||||||
|
expect(pluginRunner.getRuntimeById).toHaveBeenCalledWith("hermes");
|
||||||
|
expect(pluginRunner.createRuntimeContext).toHaveBeenCalledWith("fusion-plugin-hermes-runtime");
|
||||||
|
});
|
||||||
|
|
||||||
|
it("returns a runtime object that conforms to AgentRuntime", async () => {
|
||||||
|
const hermesRegistration = createHermesRegistration();
|
||||||
|
const pluginRunner = createMockPluginRunner({
|
||||||
|
getRuntimeById: vi.fn().mockReturnValue(hermesRegistration),
|
||||||
|
});
|
||||||
|
|
||||||
|
const resolved = await resolveRuntime({
|
||||||
|
sessionPurpose: "executor",
|
||||||
|
runtimeHint: "hermes",
|
||||||
|
pluginRunner,
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(isAgentRuntime(resolved.runtime)).toBe(true);
|
||||||
|
});
|
||||||
|
|
||||||
|
it("createResolvedAgentSession uses Hermes runtime and reports configured runtime metadata", async () => {
|
||||||
|
const hermesSession = { runtime: "hermes", prompt: vi.fn() };
|
||||||
|
const hermesCreateSession = vi.fn().mockResolvedValue({
|
||||||
|
session: hermesSession,
|
||||||
|
sessionFile: "/tmp/hermes.session.json",
|
||||||
|
});
|
||||||
|
const hermesRegistration = createHermesRegistration(() => ({
|
||||||
|
id: "hermes",
|
||||||
|
name: "Hermes Runtime",
|
||||||
|
createSession: hermesCreateSession,
|
||||||
|
promptWithFallback: vi.fn().mockResolvedValue(undefined),
|
||||||
|
describeModel: vi.fn().mockReturnValue("anthropic/claude-sonnet-4-5"),
|
||||||
|
}));
|
||||||
|
|
||||||
|
const pluginRunner = createMockPluginRunner({
|
||||||
|
getRuntimeById: vi.fn().mockReturnValue(hermesRegistration),
|
||||||
|
});
|
||||||
|
|
||||||
|
const result = await createResolvedAgentSession({
|
||||||
|
sessionPurpose: "executor",
|
||||||
|
runtimeHint: "hermes",
|
||||||
|
pluginRunner,
|
||||||
|
cwd: "/tmp/project",
|
||||||
|
systemPrompt: "You are helpful",
|
||||||
|
tools: "coding",
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(result.runtimeId).toBe("hermes");
|
||||||
|
expect(result.wasConfigured).toBe(true);
|
||||||
|
expect(result.session).toBe(hermesSession);
|
||||||
|
expect(result.sessionFile).toBe("/tmp/hermes.session.json");
|
||||||
|
expect(hermesCreateSession).toHaveBeenCalledWith({
|
||||||
|
cwd: "/tmp/project",
|
||||||
|
systemPrompt: "You are helpful",
|
||||||
|
tools: "coding",
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
it("falls back to default pi runtime when Hermes factory throws", async () => {
|
||||||
|
const hermesRegistration = createHermesRegistration(() => {
|
||||||
|
throw new Error("factory exploded");
|
||||||
|
});
|
||||||
|
|
||||||
|
const pluginRunner = createMockPluginRunner({
|
||||||
|
getRuntimeById: vi.fn().mockReturnValue(hermesRegistration),
|
||||||
|
});
|
||||||
|
|
||||||
|
const result = await createResolvedAgentSession({
|
||||||
|
sessionPurpose: "executor",
|
||||||
|
runtimeHint: "hermes",
|
||||||
|
pluginRunner,
|
||||||
|
cwd: "/tmp/project",
|
||||||
|
systemPrompt: "Use fallback",
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(result.runtimeId).toBe("pi");
|
||||||
|
expect(result.wasConfigured).toBe(false);
|
||||||
|
expect(mockCreateFnAgent).toHaveBeenCalledWith({
|
||||||
|
cwd: "/tmp/project",
|
||||||
|
systemPrompt: "Use fallback",
|
||||||
|
});
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -8,12 +8,12 @@ export interface PiAgentResult {
|
|||||||
export interface PiAgentOptions {
|
export interface PiAgentOptions {
|
||||||
cwd: string;
|
cwd: string;
|
||||||
systemPrompt: string;
|
systemPrompt: string;
|
||||||
tools?: unknown;
|
tools?: "coding" | "readonly";
|
||||||
customTools?: unknown;
|
customTools?: unknown;
|
||||||
onText?: (text: string) => void;
|
onText?: (text: string) => void;
|
||||||
onThinking?: (text: string) => void;
|
onThinking?: (text: string) => void;
|
||||||
onToolStart?: (toolName: string, args?: unknown) => void;
|
onToolStart?: (toolName: string, args?: Record<string, unknown>) => void;
|
||||||
onToolEnd?: (toolName: string, result?: unknown) => void;
|
onToolEnd?: (toolName: string, isError: boolean, result?: unknown) => void;
|
||||||
defaultProvider?: string;
|
defaultProvider?: string;
|
||||||
defaultModelId?: string;
|
defaultModelId?: string;
|
||||||
fallbackProvider?: string;
|
fallbackProvider?: string;
|
||||||
|
|||||||
@@ -1 +1 @@
|
|||||||
{"version":3,"file":"pi-module.d.ts","sourceRoot":"","sources":["../src/pi-module.ts"],"names":[],"mappings":"AAcA,MAAM,WAAW,cAAc;IAC7B,OAAO,CAAC,EAAE,MAAM,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC;CACtC;AAED,MAAM,WAAW,aAAa;IAC5B,OAAO,EAAE,cAAc,CAAC;IACxB,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB;AAED,MAAM,WAAW,cAAc;IAC7B,GAAG,EAAE,MAAM,CAAC;IACZ,YAAY,EAAE,MAAM,CAAC;IACrB,KAAK,CAAC,EAAE,OAAO,CAAC;IAChB,WAAW,CAAC,EAAE,OAAO,CAAC;IACtB,MAAM,CAAC,EAAE,CAAC,IAAI,EAAE,MAAM,KAAK,IAAI,CAAC;IAChC,UAAU,CAAC,EAAE,CAAC,IAAI,EAAE,MAAM,KAAK,IAAI,CAAC;IACpC,WAAW,CAAC,EAAE,CAAC,QAAQ,EAAE,MAAM,EAAE,IAAI,CAAC,EAAE,OAAO,KAAK,IAAI,CAAC;IACzD,SAAS,CAAC,EAAE,CAAC,QAAQ,EAAE,MAAM,EAAE,MAAM,CAAC,EAAE,OAAO,KAAK,IAAI,CAAC;IACzD,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,cAAc,CAAC,EAAE,MAAM,CAAC;IACxB,gBAAgB,CAAC,EAAE,MAAM,CAAC;IAC1B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,oBAAoB,CAAC,EAAE,MAAM,CAAC;IAC9B,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC;CACnB;AAED,eAAO,MAAM,aAAa,EAAgC,CACxD,OAAO,EAAE,cAAc,KACpB,OAAO,CAAC,aAAa,CAAC,CAAC;AAE5B,eAAO,MAAM,kBAAkB,EAAqC,CAClE,OAAO,EAAE,cAAc,EACvB,MAAM,EAAE,MAAM,EACd,OAAO,CAAC,EAAE,OAAO,KACd,OAAO,CAAC,IAAI,CAAC,CAAC;AAEnB,eAAO,MAAM,aAAa,EAAgC,CAAC,OAAO,EAAE,cAAc,KAAK,MAAM,CAAC"}
|
{"version":3,"file":"pi-module.d.ts","sourceRoot":"","sources":["../src/pi-module.ts"],"names":[],"mappings":"AAcA,MAAM,WAAW,cAAc;IAC7B,OAAO,CAAC,EAAE,MAAM,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC;CACtC;AAED,MAAM,WAAW,aAAa;IAC5B,OAAO,EAAE,cAAc,CAAC;IACxB,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB;AAED,MAAM,WAAW,cAAc;IAC7B,GAAG,EAAE,MAAM,CAAC;IACZ,YAAY,EAAE,MAAM,CAAC;IACrB,KAAK,CAAC,EAAE,QAAQ,GAAG,UAAU,CAAC;IAC9B,WAAW,CAAC,EAAE,OAAO,CAAC;IACtB,MAAM,CAAC,EAAE,CAAC,IAAI,EAAE,MAAM,KAAK,IAAI,CAAC;IAChC,UAAU,CAAC,EAAE,CAAC,IAAI,EAAE,MAAM,KAAK,IAAI,CAAC;IACpC,WAAW,CAAC,EAAE,CAAC,QAAQ,EAAE,MAAM,EAAE,IAAI,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,KAAK,IAAI,CAAC;IACzE,SAAS,CAAC,EAAE,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,EAAE,MAAM,CAAC,EAAE,OAAO,KAAK,IAAI,CAAC;IAC3E,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,cAAc,CAAC,EAAE,MAAM,CAAC;IACxB,gBAAgB,CAAC,EAAE,MAAM,CAAC;IAC1B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,oBAAoB,CAAC,EAAE,MAAM,CAAC;IAC9B,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC;CACnB;AAED,eAAO,MAAM,aAAa,EAAgC,CACxD,OAAO,EAAE,cAAc,KACpB,OAAO,CAAC,aAAa,CAAC,CAAC;AAE5B,eAAO,MAAM,kBAAkB,EAAqC,CAClE,OAAO,EAAE,cAAc,EACvB,MAAM,EAAE,MAAM,EACd,OAAO,CAAC,EAAE,OAAO,KACd,OAAO,CAAC,IAAI,CAAC,CAAC;AAEnB,eAAO,MAAM,aAAa,EAAgC,CAAC,OAAO,EAAE,cAAc,KAAK,MAAM,CAAC"}
|
||||||
@@ -12,12 +12,12 @@ export interface AgentSession {
|
|||||||
export interface AgentRuntimeOptions {
|
export interface AgentRuntimeOptions {
|
||||||
cwd: string;
|
cwd: string;
|
||||||
systemPrompt: string;
|
systemPrompt: string;
|
||||||
tools?: unknown;
|
tools?: "coding" | "readonly";
|
||||||
customTools?: unknown;
|
customTools?: unknown;
|
||||||
onText?: (text: string) => void;
|
onText?: (text: string) => void;
|
||||||
onThinking?: (text: string) => void;
|
onThinking?: (text: string) => void;
|
||||||
onToolStart?: (toolName: string, args?: unknown) => void;
|
onToolStart?: (toolName: string, args?: Record<string, unknown>) => void;
|
||||||
onToolEnd?: (toolName: string, result?: unknown) => void;
|
onToolEnd?: (toolName: string, isError: boolean, result?: unknown) => void;
|
||||||
defaultProvider?: string;
|
defaultProvider?: string;
|
||||||
defaultModelId?: string;
|
defaultModelId?: string;
|
||||||
fallbackProvider?: string;
|
fallbackProvider?: string;
|
||||||
|
|||||||
@@ -1 +1 @@
|
|||||||
{"version":3,"file":"types.d.ts","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":"AAAA;;;;;GAKG;AAEH,yDAAyD;AACzD,MAAM,WAAW,YAAY;IAC3B,OAAO,CAAC,EAAE,MAAM,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC;CACtC;AAED,+FAA+F;AAC/F,MAAM,WAAW,mBAAmB;IAClC,GAAG,EAAE,MAAM,CAAC;IACZ,YAAY,EAAE,MAAM,CAAC;IACrB,KAAK,CAAC,EAAE,OAAO,CAAC;IAChB,WAAW,CAAC,EAAE,OAAO,CAAC;IACtB,MAAM,CAAC,EAAE,CAAC,IAAI,EAAE,MAAM,KAAK,IAAI,CAAC;IAChC,UAAU,CAAC,EAAE,CAAC,IAAI,EAAE,MAAM,KAAK,IAAI,CAAC;IACpC,WAAW,CAAC,EAAE,CAAC,QAAQ,EAAE,MAAM,EAAE,IAAI,CAAC,EAAE,OAAO,KAAK,IAAI,CAAC;IACzD,SAAS,CAAC,EAAE,CAAC,QAAQ,EAAE,MAAM,EAAE,MAAM,CAAC,EAAE,OAAO,KAAK,IAAI,CAAC;IACzD,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,cAAc,CAAC,EAAE,MAAM,CAAC;IACxB,gBAAgB,CAAC,EAAE,MAAM,CAAC;IAC1B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,oBAAoB,CAAC,EAAE,MAAM,CAAC;IAC9B,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC;CACnB;AAED,oCAAoC;AACpC,MAAM,WAAW,kBAAkB;IACjC,OAAO,EAAE,YAAY,CAAC;IACtB,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB;AAED,uCAAuC;AACvC,MAAM,WAAW,YAAY;IAC3B,EAAE,EAAE,MAAM,CAAC;IACX,IAAI,EAAE,MAAM,CAAC;IACb,aAAa,CAAC,OAAO,EAAE,mBAAmB,GAAG,OAAO,CAAC,kBAAkB,CAAC,CAAC;IACzE,kBAAkB,CAAC,OAAO,EAAE,YAAY,EAAE,MAAM,EAAE,MAAM,EAAE,OAAO,CAAC,EAAE,OAAO,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAC5F,aAAa,CAAC,OAAO,EAAE,YAAY,GAAG,MAAM,CAAC;IAC7C,OAAO,CAAC,CAAC,OAAO,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;CAChD"}
|
{"version":3,"file":"types.d.ts","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":"AAAA;;;;;GAKG;AAEH,yDAAyD;AACzD,MAAM,WAAW,YAAY;IAC3B,OAAO,CAAC,EAAE,MAAM,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC;CACtC;AAED,+FAA+F;AAC/F,MAAM,WAAW,mBAAmB;IAClC,GAAG,EAAE,MAAM,CAAC;IACZ,YAAY,EAAE,MAAM,CAAC;IACrB,KAAK,CAAC,EAAE,QAAQ,GAAG,UAAU,CAAC;IAC9B,WAAW,CAAC,EAAE,OAAO,CAAC;IACtB,MAAM,CAAC,EAAE,CAAC,IAAI,EAAE,MAAM,KAAK,IAAI,CAAC;IAChC,UAAU,CAAC,EAAE,CAAC,IAAI,EAAE,MAAM,KAAK,IAAI,CAAC;IACpC,WAAW,CAAC,EAAE,CAAC,QAAQ,EAAE,MAAM,EAAE,IAAI,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,KAAK,IAAI,CAAC;IACzE,SAAS,CAAC,EAAE,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,EAAE,MAAM,CAAC,EAAE,OAAO,KAAK,IAAI,CAAC;IAC3E,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,cAAc,CAAC,EAAE,MAAM,CAAC;IACxB,gBAAgB,CAAC,EAAE,MAAM,CAAC;IAC1B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,oBAAoB,CAAC,EAAE,MAAM,CAAC;IAC9B,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC;CACnB;AAED,oCAAoC;AACpC,MAAM,WAAW,kBAAkB;IACjC,OAAO,EAAE,YAAY,CAAC;IACtB,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB;AAED,uCAAuC;AACvC,MAAM,WAAW,YAAY;IAC3B,EAAE,EAAE,MAAM,CAAC;IACX,IAAI,EAAE,MAAM,CAAC;IACb,aAAa,CAAC,OAAO,EAAE,mBAAmB,GAAG,OAAO,CAAC,kBAAkB,CAAC,CAAC;IACzE,kBAAkB,CAAC,OAAO,EAAE,YAAY,EAAE,MAAM,EAAE,MAAM,EAAE,OAAO,CAAC,EAAE,OAAO,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAC5F,aAAa,CAAC,OAAO,EAAE,YAAY,GAAG,MAAM,CAAC;IAC7C,OAAO,CAAC,CAAC,OAAO,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;CAChD"}
|
||||||
@@ -0,0 +1,87 @@
|
|||||||
|
import { describe, it, expect, vi, beforeEach, afterEach } from "vitest";
|
||||||
|
import type { FusionPlugin } from "@fusion/plugin-sdk";
|
||||||
|
import plugin from "../index.js";
|
||||||
|
import type { AgentRuntime } from "../types.js";
|
||||||
|
|
||||||
|
const { mockCreateFnAgent, mockPromptWithFallback, mockDescribeModel } = vi.hoisted(() => ({
|
||||||
|
mockCreateFnAgent: vi.fn().mockResolvedValue({
|
||||||
|
session: { id: "hermes-session" },
|
||||||
|
sessionFile: "/tmp/hermes.session.json",
|
||||||
|
}),
|
||||||
|
mockPromptWithFallback: vi.fn().mockResolvedValue(undefined),
|
||||||
|
mockDescribeModel: vi.fn().mockReturnValue("anthropic/claude-sonnet-4-5"),
|
||||||
|
}));
|
||||||
|
|
||||||
|
vi.mock("../pi-module.js", () => ({
|
||||||
|
createFnAgent: mockCreateFnAgent,
|
||||||
|
promptWithFallback: mockPromptWithFallback,
|
||||||
|
describeModel: mockDescribeModel,
|
||||||
|
}));
|
||||||
|
|
||||||
|
function isAgentRuntime(value: unknown): value is AgentRuntime {
|
||||||
|
return (
|
||||||
|
typeof value === "object" &&
|
||||||
|
value !== null &&
|
||||||
|
"id" in value &&
|
||||||
|
"name" in value &&
|
||||||
|
typeof (value as AgentRuntime).createSession === "function" &&
|
||||||
|
typeof (value as AgentRuntime).promptWithFallback === "function" &&
|
||||||
|
typeof (value as AgentRuntime).describeModel === "function"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
function createMockContext() {
|
||||||
|
return {
|
||||||
|
pluginId: "fusion-plugin-hermes-runtime",
|
||||||
|
settings: {},
|
||||||
|
logger: {
|
||||||
|
info: vi.fn(),
|
||||||
|
warn: vi.fn(),
|
||||||
|
error: vi.fn(),
|
||||||
|
debug: vi.fn(),
|
||||||
|
},
|
||||||
|
emitEvent: vi.fn(),
|
||||||
|
taskStore: { getTask: vi.fn() },
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
describe("Hermes runtime plugin integration", () => {
|
||||||
|
beforeEach(() => {
|
||||||
|
vi.clearAllMocks();
|
||||||
|
});
|
||||||
|
|
||||||
|
afterEach(() => {
|
||||||
|
vi.restoreAllMocks();
|
||||||
|
});
|
||||||
|
|
||||||
|
it("exports a valid Fusion plugin manifest", () => {
|
||||||
|
const fusionPlugin = plugin as FusionPlugin;
|
||||||
|
|
||||||
|
expect(fusionPlugin).toBeDefined();
|
||||||
|
expect(fusionPlugin.manifest.id).toBe("fusion-plugin-hermes-runtime");
|
||||||
|
});
|
||||||
|
|
||||||
|
it("registers Hermes runtime metadata", () => {
|
||||||
|
expect(plugin.runtime).toBeDefined();
|
||||||
|
expect(plugin.runtime?.metadata.runtimeId).toBe("hermes");
|
||||||
|
});
|
||||||
|
|
||||||
|
it("runtime factory returns an AgentRuntime-compatible Hermes adapter", async () => {
|
||||||
|
const runtime = (await plugin.runtime!.factory(createMockContext() as any)) as AgentRuntime;
|
||||||
|
|
||||||
|
expect(runtime.id).toBe("hermes");
|
||||||
|
expect(runtime.name).toBe("Hermes Runtime");
|
||||||
|
expect(isAgentRuntime(runtime)).toBe(true);
|
||||||
|
});
|
||||||
|
|
||||||
|
it("onLoad emits hermes-runtime:loaded with runtime metadata", async () => {
|
||||||
|
const ctx = createMockContext();
|
||||||
|
|
||||||
|
await plugin.hooks.onLoad?.(ctx as any);
|
||||||
|
|
||||||
|
expect(ctx.emitEvent).toHaveBeenCalledWith("hermes-runtime:loaded", {
|
||||||
|
runtimeId: "hermes",
|
||||||
|
version: "0.1.0",
|
||||||
|
});
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -24,12 +24,12 @@ export interface PiAgentResult {
|
|||||||
export interface PiAgentOptions {
|
export interface PiAgentOptions {
|
||||||
cwd: string;
|
cwd: string;
|
||||||
systemPrompt: string;
|
systemPrompt: string;
|
||||||
tools?: unknown;
|
tools?: "coding" | "readonly";
|
||||||
customTools?: unknown;
|
customTools?: unknown;
|
||||||
onText?: (text: string) => void;
|
onText?: (text: string) => void;
|
||||||
onThinking?: (text: string) => void;
|
onThinking?: (text: string) => void;
|
||||||
onToolStart?: (toolName: string, args?: unknown) => void;
|
onToolStart?: (toolName: string, args?: Record<string, unknown>) => void;
|
||||||
onToolEnd?: (toolName: string, result?: unknown) => void;
|
onToolEnd?: (toolName: string, isError: boolean, result?: unknown) => void;
|
||||||
defaultProvider?: string;
|
defaultProvider?: string;
|
||||||
defaultModelId?: string;
|
defaultModelId?: string;
|
||||||
fallbackProvider?: string;
|
fallbackProvider?: string;
|
||||||
|
|||||||
@@ -14,12 +14,12 @@ export interface AgentSession {
|
|||||||
export interface AgentRuntimeOptions {
|
export interface AgentRuntimeOptions {
|
||||||
cwd: string;
|
cwd: string;
|
||||||
systemPrompt: string;
|
systemPrompt: string;
|
||||||
tools?: unknown;
|
tools?: "coding" | "readonly";
|
||||||
customTools?: unknown;
|
customTools?: unknown;
|
||||||
onText?: (text: string) => void;
|
onText?: (text: string) => void;
|
||||||
onThinking?: (text: string) => void;
|
onThinking?: (text: string) => void;
|
||||||
onToolStart?: (toolName: string, args?: unknown) => void;
|
onToolStart?: (toolName: string, args?: Record<string, unknown>) => void;
|
||||||
onToolEnd?: (toolName: string, result?: unknown) => void;
|
onToolEnd?: (toolName: string, isError: boolean, result?: unknown) => void;
|
||||||
defaultProvider?: string;
|
defaultProvider?: string;
|
||||||
defaultModelId?: string;
|
defaultModelId?: string;
|
||||||
fallbackProvider?: string;
|
fallbackProvider?: string;
|
||||||
|
|||||||
Reference in New Issue
Block a user