atradio/apps/api/src/jetstream/ at main · atradio.fm/atradio · Tangled

atradio.fm / atradio

13

A social internet radio platform built on AT Protocol. atradio.fm

atproto radio

13

atradio / apps / api / src / jetstream /

at main 1 file

Tsiry Sandratraina fix(api): dedup #firehose messages across Jetstream connections 2mo ago

fix(api): dedup #firehose messages across Jetstream connections We subscribe to all four Jetstream hosts at once for redundancy, so each commit arrives ~4× and posted 4 duplicate Discord messages. Dedup on a host-stable record identity (operation:collection:did:rkey:cid) via a TTL-bounded seen-set, posting each record once. cid pins the exact record version for create/update; time_us can't be used since each host stamps its own. The check runs before the profile lookup so dupes are cheap.

2 months ago