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/
Post
tangled.orgjola.dev/kiteAn Elixir atproto Jetstream V2 subscriber library
fwiw: coverage: relay-eval.waow.tech/chart?relays... failover: tangled.org/zat.dev/jets...
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?
0 reposts1 like
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
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...