6c7eed7580
Fresh history cut from cynarAI/evoo antigravity-handoff/project-timeline (Voice First + project timeline). Brand docs/titles as evOo; keep @rakazo/* packages as tech debt. Excludes node_modules, caches, secrets, voice blobs.
63 lines
1.7 KiB
TypeScript
63 lines
1.7 KiB
TypeScript
import { describe, expect, it, vi } from "vitest";
|
|
|
|
vi.mock("@earendil-works/pi-agent-core", () => ({
|
|
Agent: class {
|
|
state = { errorMessage: "WebSocket closed 1006", messages: [] };
|
|
|
|
subscribe() {}
|
|
async prompt() {}
|
|
async waitForIdle() {}
|
|
abort() {}
|
|
},
|
|
}));
|
|
|
|
vi.mock("@earendil-works/pi-ai/providers/all", () => ({
|
|
builtinModels: () => ({
|
|
getModel: () => ({ provider: "openai-codex", id: "gpt-test" }),
|
|
streamSimple: vi.fn(),
|
|
}),
|
|
}));
|
|
|
|
vi.mock("./pi-local-provider.js", () => ({
|
|
registerLocalProvider: (models: unknown) => models,
|
|
}));
|
|
|
|
vi.mock("./pi-openai-compatible-provider.js", () => ({
|
|
OPENAI_COMPATIBLE_PROVIDER_ID: "openai-compatible",
|
|
registerOpenAiCompatibleCatalog: (models: unknown) => models,
|
|
registerOpenAiCompatibleRuntime: (models: unknown) => models,
|
|
}));
|
|
|
|
import { PiAgentRuntime } from "./pi-runtime.js";
|
|
|
|
describe("Pi runtime errors", () => {
|
|
it("propagates provider failures instead of completing with error text", async () => {
|
|
const runtime = new PiAgentRuntime();
|
|
const consume = async () => {
|
|
for await (const _event of runtime.run(
|
|
{
|
|
botId: "bot",
|
|
threadId: "thread",
|
|
runId: "run",
|
|
prompt: "continue",
|
|
instructions: "test",
|
|
history: [],
|
|
tools: [],
|
|
model: { provider: "openai-codex", id: "gpt-test" },
|
|
},
|
|
{
|
|
operationId: "operation",
|
|
traceId: "trace",
|
|
spaceId: "workspace",
|
|
userId: "user",
|
|
signal: new AbortController().signal,
|
|
},
|
|
)) {
|
|
// Consume the stream so terminal failures surface to the executor.
|
|
}
|
|
};
|
|
|
|
await expect(consume()).rejects.toThrow("WebSocket closed 1006");
|
|
});
|
|
});
|