vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-06-12 18:02:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(gateway): share channel health fixtures

Browse Source
This commit is contained in:
Vincent Koc
2026-06-02 07:57:14 +02:00
parent 85d2dd8ed2
commit 3901f48b0e
1 changed files with 28 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
src/gateway/channel-health-monitor.test.ts
View File

@@ -94,6 +94,20 @@ function runningConnectedSlackAccount(
};
}
function disconnectedAccount(
lastStartAt: number,
overrides: Partial<ChannelAccountSnapshot> = {},
): Partial<ChannelAccountSnapshot> {
return {
running: true,
connected: false,
enabled: true,
configured: true,
lastStartAt,
...overrides,
};
}
function createSlackSnapshotManager(
account: Partial<ChannelAccountSnapshot>,
overrides?: Partial<ChannelManager>,
@@ -113,11 +127,7 @@ function createBusyDisconnectedManager(lastRunActivityAt: number): ChannelManage
return createSnapshotManager({
discord: {
default: {
running: true,
connected: false,
enabled: true,
configured: true,
lastStartAt: now - 300_000,
...disconnectedAccount(now - 300_000),
activeRuns: 1,
busy: true,
lastRunActivityAt,
@@ -150,6 +160,10 @@ async function expectNoStart(manager: ChannelManager) {
monitor.stop();
}
async function advanceHealthCheck() {
await vi.advanceTimersByTimeAsync(DEFAULT_CHECK_INTERVAL_MS);
}
describe("channel-health-monitor", () => {
beforeEach(() => {
vi.useFakeTimers();
@@ -286,20 +300,8 @@ describe("channel-health-monitor", () => {
const manager = createSnapshotManager(
{
discord: {
default: {
running: true,
connected: false,
enabled: true,
configured: true,
lastStartAt: now - 300_000,
},
quiet: {
running: true,
connected: false,
enabled: true,
configured: true,
lastStartAt: now - 300_000,
},
default: disconnectedAccount(now - 300_000),
quiet: disconnectedAccount(now - 300_000),
},
},
{
@@ -320,14 +322,9 @@ describe("channel-health-monitor", () => {
const now = Date.now();
const manager = createSnapshotManager({
whatsapp: {
default: {
running: true,
connected: false,
enabled: true,
configured: true,
default: disconnectedAccount(now - 300_000, {
linked: true,
lastStartAt: now - 300_000,
},
}),
},
});
const monitor = await startAndRunCheck(manager);
@@ -341,16 +338,11 @@ describe("channel-health-monitor", () => {
const now = Date.now();
const manager = createSnapshotManager({
discord: {
default: {
running: true,
connected: false,
enabled: true,
configured: true,
lastStartAt: now - 300_000,
default: disconnectedAccount(now - 300_000, {
activeRuns: 2,
busy: true,
lastRunActivityAt: now - 30_000,
},
}),
},
});
await expectNoRestart(manager);
@@ -452,11 +444,11 @@ describe("channel-health-monitor", () => {
});
const monitor = await startAndRunCheck(manager);
expect(manager.startChannel).toHaveBeenCalledTimes(1);
await vi.advanceTimersByTimeAsync(DEFAULT_CHECK_INTERVAL_MS);
await advanceHealthCheck();
expect(manager.startChannel).toHaveBeenCalledTimes(1);
await vi.advanceTimersByTimeAsync(DEFAULT_CHECK_INTERVAL_MS);
await advanceHealthCheck();
expect(manager.startChannel).toHaveBeenCalledTimes(1);
await vi.advanceTimersByTimeAsync(DEFAULT_CHECK_INTERVAL_MS);
await advanceHealthCheck();
expect(manager.startChannel).toHaveBeenCalledTimes(2);
monitor.stop();
});