events-backend: lock subscription row when reading

Signed-off-by: Patrik Oldsberg <poldsberg@gmail.com>
2024-05-25 08:36:04 +02:00
parent 978a9daca8
commit c6e8726543
1 changed files with 3 additions and 1 deletions
@@ -324,7 +324,9 @@ export class DatabaseEventBusStore implements EventBusStore {
  async readSubscription(id: string): Promise<{ events: EventParams[] }> {
    const result = await this.#db<SubscriptionsRow>(TABLE_SUBSCRIPTIONS)
      // Read the target subscription so that we can use the read marker and topics
-      .with('sub', q => q.select().from(TABLE_SUBSCRIPTIONS).where({ id }))
+      .with('sub', q =>
+        q.select().from(TABLE_SUBSCRIPTIONS).where({ id }).forUpdate(),
+      )
      // Read the next batch of events for the subscription from its read marker
      .with('events', q =>
        q