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

fix(qa): recheck Matrix sync events after poll

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-22 23:11:21 +01:00
parent a32a6c2f89
commit 698f154c28
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
extensions/qa-matrix/src/substrate/sync.ts
View File

@@ -144,7 +144,7 @@ export function createMatrixQaRoomObserver(
const startSince = await this.prime();
const startedAt = Date.now();
let cursorIndex = roomObserver.cursorIndex;
while (Date.now() - startedAt < waitParams.timeoutMs) {
while (true) {
const matched = findMatrixQaObservedEventMatch({
cursorIndex,
events: roomObserver.events,
@@ -160,8 +160,17 @@ export function createMatrixQaRoomObserver(
};
}
const elapsedMs = Date.now() - startedAt;
if (elapsedMs >= waitParams.timeoutMs) {
roomObserver.cursorIndex = Math.max(roomObserver.cursorIndex, cursorIndex);
return {
matched: false,
since: roomObserver.since ?? startSince,
};
}
cursorIndex = roomObserver.events.length;
const remainingMs = Math.max(1_000, waitParams.timeoutMs - (Date.now() - startedAt));
const remainingMs = Math.max(1_000, waitParams.timeoutMs - elapsedMs);
await pollMatrixQaRoomObserver({
...params,
observedEvents: params.observedEvents,
@@ -169,11 +178,6 @@ export function createMatrixQaRoomObserver(
timeoutMs: remainingMs,
});
}
roomObserver.cursorIndex = Math.max(roomObserver.cursorIndex, cursorIndex);
return {
matched: false,
since: roomObserver.since ?? startSince,
};
},
async waitForRoomEvent(waitParams) {
const result = await this.waitForOptionalRoomEvent(waitParams);