diff --git a/src/firehose.ts b/src/firehose.ts index 9278ef8..b6d7ad4 100644 --- a/src/firehose.ts +++ b/src/firehose.ts @@ -1,5 +1,6 @@ import { getActiveRelays } from '@/db/relays.ts'; import { type Event, RelayPool } from '@/deps.ts'; +import { nostrNow } from '@/utils.ts'; import * as pipeline from './pipeline.ts'; @@ -10,7 +11,7 @@ const pool = new RelayPool(relays); // side-effects based on them, such as trending hashtag tracking // and storing events for notifications and the home feed. pool.subscribe( - [{ kinds: [0, 1, 3, 5, 6, 7, 10002], limit: 0 }], + [{ kinds: [0, 1, 3, 5, 6, 7, 10002], limit: 0, since: nostrNow() }], relays, handleEvent, undefined,