Post

I've extracted an Elixir Jetstream V2 library from @shelf.cafe. Define multiple subscribers, filter on collections and dids, keep track of cursors. All the good stuff! Makes it trivial to connect to the live data stream for atproto in #ElixirLang. Check it out! tangled.org/jola.dev/kite/

oooh 👀

ironically `jetstream.us-east.bsky.network.` is returning 503 for me right now

Same

I guess the next feature I add is automatically falling back to the other jetstream...

fwiw: coverage: relay-eval.waow.tech/chart?relays... failover: tangled.org/zat.dev/jets...

Thank you for the library link, I did look at it when I implemented failover for Kite. I think you can simplify it a bit. Timestamps are valid cursors, you don't need to translate them to seq to failover normal live subscriptions

Also you're doing archive replay after the 10s rewind, you can just pass the rewound timestamp and go from there. And it looks like if you don't configure an API key it will just fail to rewind and skip to live?

thanks i’ll take a look! i did all of this quickly after i got stream.waow.tech running so i could switch all my things over, definitely some polish to do