diff --git a/src/internal/serve/wire.zig b/src/internal/serve/wire.zig index 11beb94..170058d 100644 --- a/src/internal/serve/wire.zig +++ b/src/internal/serve/wire.zig @@ -582,8 +582,7 @@ test "encodeCommitV2 emits a proposal-0015 message frame in lexgen key order" { .cid = cid, }, 42); const json = out.written(); - try testing.expect(std.mem.startsWith(u8, json, - "{\"$type\":\"message\",\"payload\":{\"$type\":\"network.bsky.jetstream.subscribeEvents#commit\",\"cid\":\"b")); + try testing.expect(std.mem.startsWith(u8, json, "{\"$type\":\"message\",\"payload\":{\"$type\":\"network.bsky.jetstream.subscribeEvents#commit\",\"cid\":\"b")); // lexgen order: cid, collection, did, operation, record, rev, rkey, seq, time const c = std.mem.indexOf(u8, json, "\"collection\":").?; const d = std.mem.indexOf(u8, json, "\"did\":").?; @@ -616,8 +615,7 @@ test "encodeInfoV2 and encodeErrorV2 frames" { var out: std.Io.Writer.Allocating = .init(testing.allocator); defer out.deinit(); try encodeInfoV2(&out.writer, "OutdatedCursor", "requested cursor was below retention; clamped"); - try testing.expect(std.mem.startsWith(u8, out.written(), - "{\"$type\":\"message\",\"payload\":{\"$type\":\"network.bsky.jetstream.subscribeEvents#info\",\"message\":")); + try testing.expect(std.mem.startsWith(u8, out.written(), "{\"$type\":\"message\",\"payload\":{\"$type\":\"network.bsky.jetstream.subscribeEvents#info\",\"message\":")); try testing.expect(std.mem.endsWith(u8, out.written(), "\"name\":\"OutdatedCursor\"}}")); out.clearRetainingCapacity();