lee/puter
1
0 Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2026-11-07 06:23:05 +00:00
Code Issues Actions 16 Packages Projects Releases Wiki Activity

test(push): wait for the expected pushes before checking for more

Browse Source
This commit is contained in:
Juan Castro committed 2026-10-24 16:07:59 -04:00
1 parent d09f1b0f89
commit 50c166889a
1 file changed
+10 -6
Download Patch File Download Diff File Expand all files Collapse all files
src/backend/services/push/PushService.delivery.test.ts
+10 -6
View File
@@ -810,10 +810,12 @@ describe('PushService with three app pushes a minute', () => {
it('pushes three app messages and skips the fourth', async () => {
const { user, app } = await appPushReady(state.server);
for (let i = 0; i < 4; i++) {
for (let i = 1; i <= 3; i++) {
await appMessage(state.server, user.id, app.uid);
await settle();
await vi.waitFor(() => expect(provider.calls).toHaveLength(i));
}
await appMessage(state.server, user.id, app.uid);
await settle();
expect(provider.calls).toHaveLength(3);
});
});
@@ -827,10 +829,12 @@ describe('PushService app push limit over time', () => {
const warn = vi.spyOn(console, 'warn').mockImplementation(() => {});
vi.useFakeTimers({ toFake: ['Date'] });
try {
for (let i = 0; i < 3; i++) {
await appMessage(state.server, user.id, app.uid);
await settle();
}
await appMessage(state.server, user.id, app.uid);
await vi.waitFor(() => expect(provider.calls).toHaveLength(1));
await appMessage(state.server, user.id, app.uid);
await vi.waitFor(() => expect(limitWarnings(warn)).toHaveLength(1));
await appMessage(state.server, user.id, app.uid);
await settle();
expect(provider.calls).toHaveLength(1);
expect(limitWarnings(warn)).toHaveLength(1);
expect(limitWarnings(warn)[0][1]).toEqual({ skipped: 1 });