liuyu/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-06-06 05:51:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: share channel start test helpers

Browse Source
This commit is contained in:
Vincent Koc
2026-06-01 04:40:21 +02:00
parent 98b8e85beb
commit c5eddadd9d
1 changed files with 43 additions and 84 deletions
Download Patch File Download Diff File Expand all files Collapse all files

127
src/gateway/server-methods/channels.start.test.ts
View File

@@ -26,6 +26,25 @@ vi.mock("../../channels/plugins/index.js", () => ({
import { channelsHandlers } from "./channels.js";
function createChannelRuntimeSnapshot(running: boolean): ChannelRuntimeSnapshot {
return {
channels: {
whatsapp: {
accountId: "default-account",
running,
},
},
channelAccounts: {
whatsapp: {
"default-account": {
accountId: "default-account",
running,
},
},
},
};
}
function createOptions(
params: Record<string, unknown>,
overrides?: Partial<GatewayRequestHandlerOptions>,
@@ -41,29 +60,33 @@ function createOptions(
startChannel: vi.fn(),
stopChannel: vi.fn(),
markChannelLoggedOut: vi.fn(),
getRuntimeSnapshot: vi.fn(
(): ChannelRuntimeSnapshot => ({
channels: {
whatsapp: {
accountId: "default-account",
running: true,
},
},
channelAccounts: {
whatsapp: {
"default-account": {
accountId: "default-account",
running: true,
},
},
},
}),
),
getRuntimeSnapshot: vi.fn(() => createChannelRuntimeSnapshot(true)),
},
...overrides,
} as unknown as GatewayRequestHandlerOptions;
}
async function runChannelsStart(running: boolean) {
const startChannel = vi.fn();
const respond = vi.fn();
await channelsHandlers["channels.start"](
createOptions(
{ channel: "whatsapp" },
{
respond,
context: {
getRuntimeConfig: mocks.getRuntimeConfig,
startChannel,
getRuntimeSnapshot: vi.fn(() => createChannelRuntimeSnapshot(running)),
} as unknown as GatewayRequestHandlerOptions["context"],
},
),
);
return { respond, startChannel };
}
describe("channelsHandlers channels.start", () => {
beforeEach(() => {
vi.clearAllMocks();
@@ -81,39 +104,7 @@ describe("channelsHandlers channels.start", () => {
});
it("resolves the default account and starts the channel runtime", async () => {
const startChannel = vi.fn();
const respond = vi.fn();
await channelsHandlers["channels.start"](
createOptions(
{ channel: "whatsapp" },
{
respond,
context: {
getRuntimeConfig: mocks.getRuntimeConfig,
startChannel,
getRuntimeSnapshot: vi.fn(
(): ChannelRuntimeSnapshot => ({
channels: {
whatsapp: {
accountId: "default-account",
running: true,
},
},
channelAccounts: {
whatsapp: {
"default-account": {
accountId: "default-account",
running: true,
},
},
},
}),
),
} as unknown as GatewayRequestHandlerOptions["context"],
},
),
);
const { respond, startChannel } = await runChannelsStart(true);
expect(mocks.applyPluginAutoEnable).toHaveBeenCalledWith({
config: {},
@@ -131,39 +122,7 @@ describe("channelsHandlers channels.start", () => {
});
it("reports started=false when the channel runtime remains stopped", async () => {
const startChannel = vi.fn();
const respond = vi.fn();
await channelsHandlers["channels.start"](
createOptions(
{ channel: "whatsapp" },
{
respond,
context: {
getRuntimeConfig: mocks.getRuntimeConfig,
startChannel,
getRuntimeSnapshot: vi.fn(
(): ChannelRuntimeSnapshot => ({
channels: {
whatsapp: {
accountId: "default-account",
running: false,
},
},
channelAccounts: {
whatsapp: {
"default-account": {
accountId: "default-account",
running: false,
},
},
},
}),
),
} as unknown as GatewayRequestHandlerOptions["context"],
},
),
);
const { respond, startChannel } = await runChannelsStart(false);
expect(startChannel).toHaveBeenCalledWith("whatsapp", "default-account");
expect(respond).toHaveBeenCalledWith(