diff --git a/src/pipeline.ts b/src/pipeline.ts index e60ce6c..81e9b5e 100644 --- a/src/pipeline.ts +++ b/src/pipeline.ts @@ -115,6 +115,11 @@ async function storeEvent(event: DittoEvent, signal?: AbortSignal): Promise= 2_147_483_647) { + throw new RelayError('blocked', 'event too far in the future'); + } + await updateStats({ event, store, kysely }).catch(debug); await store.event(event, { signal }); }