GET /xrpc/app.bsky.actor.searchActorsTypeahead typeahead.waow.tech
16
fork

Configure Feed

Select the types of activity you want to include in your feed.

bump zat to v0.3.0-alpha.7

- JetstreamClient.init now takes io parameter
- subscribe returns Io.Cancelable!void
- includes websocket cross-platform fix and io threading

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

+6 -4
+2 -2
ingester/build.zig.zon
··· 5 5 .minimum_zig_version = "0.16.0", 6 6 .dependencies = .{ 7 7 .zat = .{ 8 - .url = "https://tangled.sh/zat.dev/zat/archive/v0.3.0-alpha.4", 9 - .hash = "zat-0.3.0-alpha.4-5PuC7pNgBQCDMShv93KamG-leB6U1GOgqflbaX7Faf_1", 8 + .url = "https://tangled.sh/zat.dev/zat/archive/v0.3.0-alpha.7", 9 + .hash = "zat-0.3.0-alpha.7-5PuC7uNjBQDv28db31DEKkFn1tU5I4f1GfJs-RrG8_pS", 10 10 }, 11 11 .zqlite = .{ 12 12 .url = "https://github.com/karlseguin/zqlite.zig/archive/refs/heads/master.tar.gz",
+4 -2
ingester/src/main.zig
··· 38 38 }; 39 39 defer handler.deinit(); 40 40 41 - var client = zat.JetstreamClient.init(args.allocator, .{ 41 + var client = zat.JetstreamClient.init(io, args.allocator, .{ 42 42 .wanted_collections = &.{ 43 43 "app.bsky.actor.profile", 44 44 "app.bsky.feed.post", ··· 50 50 }); 51 51 defer client.deinit(); 52 52 53 - client.subscribe(&handler); 53 + client.subscribe(&handler) catch |err| { 54 + log.err("jetstream subscribe failed: {}", .{err}); 55 + }; 54 56 } 55 57 56 58 fn setSocketTimeout(fd: std.posix.fd_t, secs: u32) !void {