github-mirrors/openclaw
1
0
Fork 0
mirror of https://fastgit.cc/github.com/openclaw/openclaw synced 2026-04-30 22:12:32 +08:00
Code Issues Packages Projects Releases Wiki Activity

test: shorten Matrix thread binding waits

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-17 17:26:46 +01:00
parent b9d5c1a58b
commit c580933623
1 changed files with 37 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

67
extensions/matrix/src/matrix/thread-bindings.test.ts
View File

@@ -311,15 +311,17 @@ describe("matrix thread bindings", () => {
});
await vi.advanceTimersByTimeAsync(61_000);
await Promise.resolve();
await vi.waitFor(async () => {
const persistedRaw = await fs.readFile(resolveBindingsFilePath(), "utf-8");
expect(JSON.parse(persistedRaw)).toMatchObject({
version: 1,
bindings: [],
});
});
await vi.waitFor(
async () => {
const persistedRaw = await fs.readFile(resolveBindingsFilePath(), "utf-8");
expect(JSON.parse(persistedRaw)).toMatchObject({
version: 1,
bindings: [],
});
},
{ interval: 1, timeout: 100 },
);
} finally {
vi.useRealTimers();
}
@@ -353,23 +355,22 @@ describe("matrix thread bindings", () => {
renameMock.mockRejectedValueOnce(new Error("disk full"));
await vi.advanceTimersByTimeAsync(61_000);
await Promise.resolve();
await vi.waitFor(() => {
expect(
logVerboseMessage.mock.calls.some(
([message]) =>
typeof message === "string" &&
message.includes("failed auto-unbinding expired bindings"),
),
).toBe(true);
});
await vi.waitFor(() => {
expect(logVerboseMessage).toHaveBeenCalledWith(
expect.stringContaining("matrix: auto-unbinding $thread due to idle-expired"),
);
});
await vi.waitFor(
() => {
expect(
logVerboseMessage.mock.calls.some(
([message]) =>
typeof message === "string" &&
message.includes("failed auto-unbinding expired bindings"),
),
).toBe(true);
expect(logVerboseMessage).toHaveBeenCalledWith(
expect.stringContaining("matrix: auto-unbinding $thread due to idle-expired"),
);
},
{ interval: 1, timeout: 100 },
);
expect(
getSessionBindingService().resolveByConversation({
@@ -640,9 +641,12 @@ describe("matrix thread bindings", () => {
expect(await readPersistedLastActivityAt(bindingsPath)).toBe(originalLastActivityAt);
await vi.advanceTimersByTimeAsync(1_000);
await vi.waitFor(async () => {
expect(await readPersistedLastActivityAt(bindingsPath)).toBe(secondTouchedAt);
});
await vi.waitFor(
async () => {
expect(await readPersistedLastActivityAt(bindingsPath)).toBe(secondTouchedAt);
},
{ interval: 1, timeout: 100 },
);
} finally {
vi.useRealTimers();
}
@@ -661,9 +665,12 @@ describe("matrix thread bindings", () => {
vi.useRealTimers();
const bindingsPath = resolveBindingsFilePath();
await vi.waitFor(async () => {
expect(await readPersistedLastActivityAt(bindingsPath)).toBe(touchedAt);
});
await vi.waitFor(
async () => {
expect(await readPersistedLastActivityAt(bindingsPath)).toBe(touchedAt);
},
{ interval: 1, timeout: 100 },
);
} finally {
vi.useRealTimers();
}