From c38913a093603ba3289f79142094c6aba2c3d5b0 Mon Sep 17 00:00:00 2001 From: Patrik Oldsberg Date: Sat, 25 May 2024 08:41:04 +0200 Subject: [PATCH] events-backend: fix check for already consumed events Signed-off-by: Patrik Oldsberg --- .../events-backend/src/service/hub/DatabaseEventBusStore.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts b/plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts index 600a038793..e5e69d697d 100644 --- a/plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts +++ b/plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts @@ -339,9 +339,9 @@ export class DatabaseEventBusStore implements EventBusStore { this.#db.ref('topics').withSchema('sub').wrap('ANY(', ')'), ) // Skip events that have already been consumed by this subscription - .where( + .whereNot( this.#db.raw('?', id), - '<>', + '=', this.#db.ref('consumed_by').withSchema('event').wrap('ANY(', ')'), ) .where('event.id', '>', this.#db.ref('read_until').withSchema('sub'))