diff --git a/plugins/events-backend/src/service/EventsPlugin.test.ts b/plugins/events-backend/src/service/EventsPlugin.test.ts index 3c08637b1f..215d4e9190 100644 --- a/plugins/events-backend/src/service/EventsPlugin.test.ts +++ b/plugins/events-backend/src/service/EventsPlugin.test.ts @@ -379,7 +379,7 @@ describe('eventsPlugin', () => { await helper.subscribe('tester', ['test']).expect(201); jest.useFakeTimers({ - doNotFake: ['nextTick'], + advanceTimers: true, }); try { diff --git a/plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts b/plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts index 87c9263e79..6694703a2e 100644 --- a/plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts +++ b/plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts @@ -447,7 +447,7 @@ export class DatabaseEventBusStore implements EventBusStore { // events where read, the last ID out of all events .update({ read_until: this.#db.raw( - 'COALESCE(last_event_id, (SELECT MAX(id) FROM event_bus_events))', + 'COALESCE(last_event_id, (SELECT MAX(id) FROM event_bus_events), 0)', ), }) .updateFrom({