8000 test(reports): wait for post-rebuild refreshes before checking increments by InfinityPacer · Pull Request #40 · InfinityPacer/meterleaf · GitHub
[go: up one dir, main page]
Skip to content

test(reports): wait for post-rebuild refreshes before checking increments #40

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
InfinityPacer merged 1 commit into from
Oct 14, 2026
Merged

test(reports): wait for post-rebuild refreshes before checking increments #40

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 15 additions & 0 deletions tests/view-service.test.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -292,6 +292,21 @@ test("a price change rebuilds in the background and answers uncached queries fro
(await readdir(dir)).filter((name) => name.includes(".next")),
).toEqual([]);

// 重建完成后缓存里的各个查询依次刷新，上面只等到了最近使用的分页查询。
// 默认查询仍在刷新时写入增量，进行中的刷新可能已读过数据库，之后的观察读取又不会再触发刷新。
let settled = await reports.read(query, "subscription", sync, false);
const settleDeadline = Date.now() + 5000;
while (
(settled.reportStatus?.refreshing ||
settled.pricing!.version !== priceBookKey(nextBook)) &&
Date.now() < settleDeadline
) {
await Bun.sleep(20);
settled = await reports.read(query, "subscription", sync, false);
}
expect(settled.pricing!.version).toBe(priceBookKey(nextBook));
expect(settled.reportStatus?.refreshing).toBe(false);

// 替换后的索引继续接收增量。
const later = new Date().toISOString();
store.savePage(
Expand Down
Loading
0