LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-05-17 02:37:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: tighten gateway startup assertions

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-11 07:45:35 +01:00
parent 18e0a0af6d
commit 4f05735af7
1 changed files with 27 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
src/gateway/server-startup-post-attach.test.ts
View File

@@ -248,9 +248,8 @@ describe("startGatewayPostAttachRuntime", () => {
expect(hoisted.startPluginServices).toHaveBeenCalledTimes(1);
expect(hoisted.loadInternalHooks).not.toHaveBeenCalled();
expect(hoisted.setInternalHooksEnabled).not.toHaveBeenCalled();
expect(hoisted.logGatewayStartup).toHaveBeenCalledWith(
expect.objectContaining({ loadedPluginIds: ["beta", "alpha"] }),
);
expect(hoisted.logGatewayStartup).toHaveBeenCalledTimes(1);
expect(hoisted.logGatewayStartup.mock.calls[0]?.[0].loadedPluginIds).toEqual(["beta", "alpha"]);
expect(log.info).toHaveBeenCalledWith("gateway ready");
expect(hoisted.startGatewayMemoryBackend).not.toHaveBeenCalled();
});
@@ -417,9 +416,8 @@ describe("startGatewayPostAttachRuntime", () => {
pluginRegistry: loadedPluginRegistry,
gatewayMethods: ["ping", "acp.spawn"],
});
expect(hoisted.logGatewayStartup).toHaveBeenCalledWith(
expect.objectContaining({ loadedPluginIds: ["acpx"] }),
);
expect(hoisted.logGatewayStartup).toHaveBeenCalledTimes(1);
expect(hoisted.logGatewayStartup.mock.calls[0]?.[0].loadedPluginIds).toEqual(["acpx"]);
});
it("waits for deferred startup plugin attachment before channel sidecars", async () => {
@@ -624,14 +622,22 @@ describe("startGatewayPostAttachRuntime", () => {
});
expect(hoisted.resolveDefaultAgentDir).toHaveBeenCalledWith(cfg);
expect(hoisted.ensureOpenClawModelsJson).toHaveBeenCalledWith(
cfg,
"/tmp/openclaw-state/agents/ops/agent",
expect.objectContaining({
workspaceDir: "/tmp/openclaw-workspace",
providerDiscoveryProviderIds: ["openai"],
}),
);
expect(hoisted.ensureOpenClawModelsJson).toHaveBeenCalledTimes(1);
const ensureCall = hoisted.ensureOpenClawModelsJson.mock.calls[0] as unknown as
| [
unknown,
string,
{
workspaceDir?: string;
providerDiscoveryProviderIds?: string[];
},
]
| undefined;
expect(ensureCall?.[0]).toBe(cfg);
expect(ensureCall?.[1]).toBe("/tmp/openclaw-state/agents/ops/agent");
const options = ensureCall?.[2];
expect(options?.workspaceDir).toBe("/tmp/openclaw-workspace");
expect(options?.providerDiscoveryProviderIds).toEqual(["openai"]);
});
it("starts channels without waiting for primary model prewarm completion", async () => {
@@ -672,11 +678,10 @@ describe("startGatewayPostAttachRuntime", () => {
await vi.waitFor(
() => {
expect(prewarmPrimaryModel).toHaveBeenCalledTimes(1);
expect(prewarmPrimaryModel).toHaveBeenCalledWith(
expect.objectContaining({
workspaceDir: "/tmp/openclaw-workspace",
}),
);
const prewarmCall = prewarmPrimaryModel.mock.calls[0] as unknown as
| [{ workspaceDir?: string }]
| undefined;
expect(prewarmCall?.[0].workspaceDir).toBe("/tmp/openclaw-workspace");
expect(startChannels).toHaveBeenCalledTimes(1);
},
{ timeout: 2_000 },
@@ -856,11 +861,9 @@ describe("startGatewayPostAttachRuntime", () => {
}
const [event, ctx] = firstCall;
expect(event).toEqual({ port: 18789 });
expect(ctx).toMatchObject({
port: 18789,
config: params.gatewayPluginConfigAtStart,
workspaceDir: "/tmp/openclaw-workspace",
});
expect(ctx.port).toBe(18789);
expect(ctx.config).toBe(params.gatewayPluginConfigAtStart);
expect(ctx.workspaceDir).toBe("/tmp/openclaw-workspace");
const getCron = ctx.getCron;
if (!getCron) {
throw new Error("gateway_start context did not expose getCron");