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

matrix: stabilize healthy sync epochs

Browse Source
This commit is contained in:
Gustavo Madeira Santana
2026-04-11 21:36:50 -04:00
parent 4032c34f36
commit a2ad02ecba
2 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
extensions/matrix/src/matrix/monitor/index.test.ts
View File

@@ -523,7 +523,16 @@ describe("monitorMatrixProvider", () => {
expect(getHealthySyncSinceMs()).toBeUndefined();
hoisted.client.emit("sync.state", "SYNCING", "RECONNECTING", undefined);
expect(getHealthySyncSinceMs()).toBe(Date.now());
const firstHealthySyncSinceMs = Date.now();
expect(getHealthySyncSinceMs()).toBe(firstHealthySyncSinceMs);
await vi.advanceTimersByTimeAsync(3_000);
hoisted.client.emit("sync.state", "CATCHUP", "SYNCING", undefined);
expect(getHealthySyncSinceMs()).toBe(firstHealthySyncSinceMs);
await vi.advanceTimersByTimeAsync(2_000);
hoisted.client.emit("sync.state", "PREPARED", "CATCHUP", undefined);
expect(getHealthySyncSinceMs()).toBe(firstHealthySyncSinceMs);
await vi.advanceTimersByTimeAsync(5_000);
hoisted.client.emit("sync.state", "RECONNECTING", "SYNCING", new Error("network flap"));

2
extensions/matrix/src/matrix/monitor/index.ts
View File

@@ -250,7 +250,7 @@ export async function monitorMatrixProvider(opts: MonitorMatrixOpts = {}): Promi
let healthySyncSinceMs: number | undefined;
const noteSyncHealthState = (state: MatrixSyncState, at = Date.now()) => {
if (isMatrixReadySyncState(state)) {
healthySyncSinceMs = at;
healthySyncSinceMs ??= at;
return;
}
if (isMatrixDisconnectedSyncState(state)) {