Files
openclaw-zero-token/gateway/test-with-server.ts
sjhu 571e14a236 feat: upgrade to upstream v2026.3.28
Major upgrade from e26988a38 to upstream v2026.3.28 (f9b107928).
Key changes:
- Upstream src/, ui/, extensions/ (89 bundled extensions)
- Zero-token web providers preserved in src/zero-token/
- AskOnce plugin restored and registered as CLI command
- Added missing packages: @anthropic-ai/vertex-sdk, @modelcontextprotocol/sdk
- Fixed tsconfig rootDir, skipLibCheck for plugin-sdk DTS build
- Added askonce to bundled plugin metadata and package.json exports
- Fixed AskOnce CLI command registration (missing commands metadata)
- Restored AskOnce adapter imports (correct 5-level relative paths)
- Removed stale migration artifacts from root directory
2026-03-30 17:58:12 +08:00

48 lines
1.4 KiB
TypeScript

import { afterAll, beforeAll, beforeEach } from "vitest";
import { connectOk, startServerWithClient, testState } from "./test-helpers.js";
type StartServerWithClient = typeof startServerWithClient;
export type GatewayWs = Awaited<ReturnType<StartServerWithClient>>["ws"];
export type GatewayServer = Awaited<ReturnType<StartServerWithClient>>["server"];
export async function withServer<T>(run: (ws: GatewayWs) => Promise<T>): Promise<T> {
const { server, ws, envSnapshot } = await startServerWithClient("secret");
try {
return await run(ws);
} finally {
ws.close();
await server.close();
envSnapshot.restore();
}
}
export function installConnectedControlUiServerSuite(
onReady: (started: { server: GatewayServer; ws: GatewayWs; port: number }) => void,
): void {
let started: Awaited<ReturnType<StartServerWithClient>> | null = null;
const token = "secret";
beforeAll(async () => {
started = await startServerWithClient(token, { controlUiEnabled: true });
onReady({
server: started.server,
ws: started.ws,
port: started.port,
});
await connectOk(started.ws);
});
beforeEach(() => {
process.env.OPENCLAW_GATEWAY_TOKEN = token;
testState.gatewayAuth = { mode: "token", token };
});
afterAll(async () => {
started?.ws.close();
if (started?.server) {
await started.server.close();
}
started?.envSnapshot.restore();
});
}