vrr/openclaw
2
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-10-03 01:29:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 29

test(buzz): advance the room restoration deadline after admission (#154855)

Browse source
This commit is contained in:
Peter Steinberger 2026-09-22 05:33:41 -07:00 • committed by GitHub
parent 774687378d
commit 98ac96ef80
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 15 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

18
extensions/buzz/src/buzz-bus.room-restoration.test.ts
View file

@ -15,6 +15,7 @@ beforeEach(() => {
});
afterEach(() => {
vi.useRealTimers();
resetPluginStateStoreForTests();
vi.restoreAllMocks();
vi.unstubAllEnvs();
@ -438,18 +439,29 @@ it.each(["closed", "missing EOSE"] as const)(
onMessage: async () => {},
onFatalError: (error) => fatal.push(error),
});
if (failure === "missing EOSE") {
await bus.sendText({ channelId: fixture.roomId, text: "restoration startup barrier" });
vi.useFakeTimers({ toFake: ["setTimeout", "clearTimeout"] });
}
const history = fixture.pauseNextRoomHistory();
publishBotRole(fixture, skipped.roomId, "bot", skipped.createdAt + 1);
notifyBotMembership(fixture, skipped.roomId, 44100, skipped.createdAt + 1);
await history.started;
if (failure === "closed") {
history.close("fixture room history failed");
await vi.waitFor(() => expect(fatal).toHaveLength(1), { timeout: 11000 });
expect(fatal[0]?.message).toContain("closed");
} else {
expect(fatal).toEqual([]);
await vi.advanceTimersByTimeAsync(10_000);
expect(fatal).toHaveLength(1);
expect(fatal[0]?.message).toBe(
`Timed out loading Buzz room membership changes for ${skipped.roomId}`,
);
}
await vi.waitFor(() => expect(fatal).toHaveLength(1), { timeout: 11000 });
expect(fatal[0]?.message).toContain(failure === "closed" ? "closed" : "Timed out");
await expect(
bus.sendText({ channelId: fixture.roomId, text: "failed generation reply" }),
).rejects.toThrow();
).rejects.toThrow(fatal[0]);
} finally {
await bus?.close();
await fixture.close();