diff --git a/src/firehose.ts b/src/firehose.ts index ea6be62..5e24de7 100644 --- a/src/firehose.ts +++ b/src/firehose.ts @@ -17,8 +17,6 @@ pool.subscribe( /** Handle events through the firehose pipeline. */ function handleEvent(event: Event): Promise { - console.info(`firehose: Event<${event.kind}> ${event.id}`); - return pipeline .handleEvent(event) .catch(() => {}); diff --git a/src/pipeline.ts b/src/pipeline.ts index 4f0c51a..cf721c4 100644 --- a/src/pipeline.ts +++ b/src/pipeline.ts @@ -24,6 +24,7 @@ import type { EventData } from '@/types.ts'; async function handleEvent(event: Event): Promise { if (!(await verifySignatureWorker(event))) return; if (encounterEvent(event)) return; + console.info(`pipeline: Event<${event.kind}> ${event.id}`); const data = await getEventData(event); await Promise.all([