vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-10 20:40:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: reuse stdio transport import

Browse Source
This commit is contained in:
Shakker
2026-05-09 17:07:35 +01:00
parent 55b5333e99
commit b9d6bb91ec
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/agents/mcp-stdio-transport.test.ts
View File

@@ -2,6 +2,7 @@ import type { SpawnOptions } from "node:child_process";
import { EventEmitter } from "node:events";
import { PassThrough } from "node:stream";
import { afterEach, describe, expect, it, vi } from "vitest";
import { OpenClawStdioClientTransport } from "./mcp-stdio-transport.js";
const spawnMock = vi.hoisted(() => vi.fn());
const killProcessTreeMock = vi.hoisted(() => vi.fn());
@@ -33,7 +34,6 @@ describe("OpenClawStdioClientTransport", () => {
it("starts stdio MCP servers in a disposable process group on POSIX", async () => {
const child = new MockChildProcess();
spawnMock.mockReturnValue(child);
const { OpenClawStdioClientTransport } = await import("./mcp-stdio-transport.js");
const transport = new OpenClawStdioClientTransport({
command: "npx",
@@ -73,7 +73,6 @@ describe("OpenClawStdioClientTransport", () => {
vi.useFakeTimers();
const child = new MockChildProcess();
spawnMock.mockReturnValue(child);
const { OpenClawStdioClientTransport } = await import("./mcp-stdio-transport.js");
const transport = new OpenClawStdioClientTransport({ command: "npx" });
const started = transport.start();
@@ -93,7 +92,6 @@ describe("OpenClawStdioClientTransport", () => {
vi.useFakeTimers();
const child = new MockChildProcess();
spawnMock.mockReturnValue(child);
const { OpenClawStdioClientTransport } = await import("./mcp-stdio-transport.js");
const transport = new OpenClawStdioClientTransport({ command: "npx" });
const started = transport.start();
@@ -111,7 +109,6 @@ describe("OpenClawStdioClientTransport", () => {
it("sends and receives JSON-RPC messages over stdio", async () => {
const child = new MockChildProcess();
spawnMock.mockReturnValue(child);
const { OpenClawStdioClientTransport } = await import("./mcp-stdio-transport.js");
const transport = new OpenClawStdioClientTransport({ command: "npx" });
const onmessage = vi.fn();
@@ -145,7 +142,6 @@ describe("OpenClawStdioClientTransport", () => {
};
child.stdin = brokenStdin;
spawnMock.mockReturnValue(child);
const { OpenClawStdioClientTransport } = await import("./mcp-stdio-transport.js");
const transport = new OpenClawStdioClientTransport({ command: "npx" });
const started = transport.start();
@@ -165,7 +161,6 @@ describe("OpenClawStdioClientTransport", () => {
};
child.stdin = brokenStdin;
spawnMock.mockReturnValue(child);
const { OpenClawStdioClientTransport } = await import("./mcp-stdio-transport.js");
const transport = new OpenClawStdioClientTransport({ command: "npx" });
const started = transport.start();