mirror of
https://github.com/openclaw/openclaw.git
synced 2026-05-06 07:00:43 +00:00
perf: remove Matrix test polling
This commit is contained in:
@@ -182,13 +182,17 @@ describe("matrix credentials storage", () => {
|
||||
);
|
||||
|
||||
let releaseFirstWrite: (() => void) | undefined;
|
||||
let firstWriteStarted = false;
|
||||
let resolveFirstWriteStarted: (() => void) | undefined;
|
||||
const firstWriteStarted = new Promise<void>((resolve) => {
|
||||
resolveFirstWriteStarted = resolve;
|
||||
});
|
||||
const originalRename = fsPromises.rename.bind(fsPromises);
|
||||
const renameSpy = vi
|
||||
.spyOn(fsPromises, "rename")
|
||||
.mockImplementation(async (...args: Parameters<typeof fsPromises.rename>) => {
|
||||
if (!firstWriteStarted) {
|
||||
firstWriteStarted = true;
|
||||
if (resolveFirstWriteStarted) {
|
||||
resolveFirstWriteStarted();
|
||||
resolveFirstWriteStarted = undefined;
|
||||
await new Promise<void>((resolve) => {
|
||||
releaseFirstWrite = resolve;
|
||||
});
|
||||
@@ -208,9 +212,7 @@ describe("matrix credentials storage", () => {
|
||||
"default",
|
||||
);
|
||||
|
||||
await vi.waitFor(() => {
|
||||
expect(firstWriteStarted).toBe(true);
|
||||
});
|
||||
await firstWriteStarted;
|
||||
|
||||
const newerSavePromise = saveMatrixCredentials(
|
||||
{
|
||||
|
||||
@@ -142,18 +142,16 @@ describe("matrix thread bindings", () => {
|
||||
parentConversationId?: string;
|
||||
},
|
||||
) {
|
||||
await vi.waitFor(async () => {
|
||||
const persistedRaw = await fs.readFile(bindingsPath, "utf-8");
|
||||
expect(JSON.parse(persistedRaw)).toMatchObject({
|
||||
version: 1,
|
||||
bindings: [
|
||||
expect.objectContaining({
|
||||
conversationId: expected.conversationId,
|
||||
parentConversationId: expected.parentConversationId ?? "!room:example",
|
||||
targetSessionKey: expected.targetSessionKey,
|
||||
}),
|
||||
],
|
||||
});
|
||||
const persistedRaw = await fs.readFile(bindingsPath, "utf-8");
|
||||
expect(JSON.parse(persistedRaw)).toMatchObject({
|
||||
version: 1,
|
||||
bindings: [
|
||||
expect.objectContaining({
|
||||
conversationId: expected.conversationId,
|
||||
parentConversationId: expected.parentConversationId ?? "!room:example",
|
||||
targetSessionKey: expected.targetSessionKey,
|
||||
}),
|
||||
],
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user