atradio/apps/api/src/discord/ 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 / discord /

at main 2 files

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

feat(api): rich Discord embeds for #firehose, filtered to fm.atradio.* Forward only fm.atradio.* commits (dropping identity/account events) and render them as rocksky-style embeds instead of plain text: author block with the actor's avatar + display name linking to their atradio profile, station name linking to its homepage, station logo as thumbnail, plus a per-collection accent colour, emoji, and timestamp. Forwarding runs after indexing so the actor's profile is already cached for enrichment. Splits transport (discord/firehose.ts, now queues embeds, ≤10 per message) from formatting (discord/format.ts).

2 months ago