atproto utils for zig zat.dev
atproto sdk zig
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091//! sync types - com.atproto.sync.subscribeRepos//!//! enums for firehose/event stream consumption.//! see: https://atproto.com/specs/event-stream
const std = @import("std");
/// repo operation action (create/update/delete)////// from com.atproto.sync.subscribeRepos#repoOp/// used in firehose commit messages to indicate what happened to a record.pub const CommitAction = enum { create, update, delete,
/// parse from string (for manual parsing) pub fn parse(s: []const u8) ?CommitAction { return std.meta.stringToEnum(CommitAction, s); }};
/// event stream message types////// from com.atproto.sync.subscribeRepos message union/// the top-level discriminator for firehose messages.pub const EventKind = enum { commit, sync, identity, account, info,
pub fn parse(s: []const u8) ?EventKind { return std.meta.stringToEnum(EventKind, s); }};
/// account status reasons////// from com.atproto.sync.subscribeRepos#account status field/// indicates why an account is inactive.pub const AccountStatus = enum { takendown, suspended, deleted, deactivated, desynchronized, throttled,
pub fn parse(s: []const u8) ?AccountStatus { return std.meta.stringToEnum(AccountStatus, s); }};
// === tests ===
test "CommitAction parse" { try std.testing.expectEqual(CommitAction.create, CommitAction.parse("create").?); try std.testing.expectEqual(CommitAction.update, CommitAction.parse("update").?); try std.testing.expectEqual(CommitAction.delete, CommitAction.parse("delete").?); try std.testing.expect(CommitAction.parse("invalid") == null);}
test "CommitAction json parsing" { const json_str = \\{"action": "create", "path": "app.bsky.feed.post/abc"} ;
const Op = struct { action: CommitAction, path: []const u8, };
const parsed = try std.json.parseFromSlice(Op, std.testing.allocator, json_str, .{}); defer parsed.deinit();
try std.testing.expectEqual(CommitAction.create, parsed.value.action);}
test "EventKind parse" { try std.testing.expectEqual(EventKind.commit, EventKind.parse("commit").?); try std.testing.expectEqual(EventKind.identity, EventKind.parse("identity").?); try std.testing.expect(EventKind.parse("unknown") == null);}
test "AccountStatus parse" { try std.testing.expectEqual(AccountStatus.takendown, AccountStatus.parse("takendown").?); try std.testing.expectEqual(AccountStatus.suspended, AccountStatus.parse("suspended").?);}