From 6d6e3bcecc871996719b605b49967c4345f46f26 Mon Sep 17 00:00:00 2001 From: Alex Gleason Date: Fri, 22 Dec 2023 10:24:14 -0600 Subject: [PATCH] Move console.info from firehose to pipeline --- src/firehose.ts | 2 -- src/pipeline.ts | 1 + 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/src/firehose.ts b/src/firehose.ts index ea6be62a..5e24de76 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 4f0c51ab..cf721c49 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([