diff --git a/packages/ditto/storages/DittoPgStore.ts b/packages/ditto/storages/DittoPgStore.ts index e7136e5d..cacc6a1a 100644 --- a/packages/ditto/storages/DittoPgStore.ts +++ b/packages/ditto/storages/DittoPgStore.ts @@ -131,6 +131,9 @@ export class DittoPgStore extends NPostgres { dbEventsCounter.inc({ kind: event.kind }); if (NKinds.ephemeral(event.kind)) { + if (this.encounters.has(event.id)) return; + this.encounters.set(event.id, true); + return await this.fulfill(event); }