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/

tangled.orgjola.dev/kiteAn Elixir atproto Jetstream V2 subscriber library

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...

nate

@zzstoatzz.io

18 Sept

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

johanna

@jola.dev

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

20/9/26, 5:40 pm0 reposts2 likes

johanna

@jola.dev

20 Sept

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?

nate

@zzstoatzz.io

20 Sept

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

johanna

@jola.dev

20 Sept

It's not easy to blaze trails, really appreciate the things you contribute to the community!

nate

@zzstoatzz.io

20 Sept

thanks :) i also appreciate your incisive review and corrections here’s a commit (out in v1.0.5) that should clean a few things up tangled.org/zat.dev/jets...