╭ changed ───────────────╮ │src/test/event/admin.zig│ ╰────────────────────────╯ ╭───────────╮ │← all files│ ╰───────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │78 }; │ │79 │ │80 // commit and consume the seed events │ │81 - try evt.consume(.admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &events_to_consume); │ │81 + try evt.consume(.server, .admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &events_to_consume);│ │82 │ │83 { │ │84 const haxy_moment = try evt.currentMoment(repo_opts, &repo); │ ╰────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │134 }; │ │135 │ │136 // commit and consume the removal │ │137 - try evt.consume(.admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &events_to_consume2); │ │137 + try evt.consume(.server, .admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &events_to_consume2);│ │138 │ │139 { │ │140 const haxy_moment = try evt.currentMoment(repo_opts, &repo); │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │160 } │ │161 │ │162 // a non-null payload restores the repo and its indexes │ │163 - try evt.consume(.admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &[_]evt.EventWithId{.{ │ │163 + try evt.consume(.server, .admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &[_]evt.EventWithId{.{│ │164 .id = std.fmt.bytesToHex(repo_event_id, .lower), │ │165 .author = author, │ │166 .event = events_to_consume[2].event, │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │195 }; │ │196 │ │197 // commit and consume the removal │ │198 - try evt.consume(.admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &events_to_consume3); │ │198 + try evt.consume(.server, .admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &events_to_consume3);│ │199 │ │200 { │ │201 const haxy_moment = try evt.currentMoment(repo_opts, &repo); │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │274 .{ .id = std.fmt.bytesToHex(repo_ids[2], .lower), .author = author, .timestamp = 5_000, .event = .{ .repo = .{ .user_id = &user_id, .name = "repo2", .description = "d2" } } },│ │275 .{ .id = std.fmt.bytesToHex(repo_ids[3], .lower), .author = author, .timestamp = 20, .event = .{ .repo = .{ .user_id = &user_id, .name = "repo3", .description = "d3" } } }, │ │276 }; │ │277 - try evt.consume(.admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &events); │ │277 + try evt.consume(.server, .admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &events); │ │278 │ │279 { │ │280 const moment = try evt.currentMoment(repo_opts, &repo); │ ╰────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │287 } │ │288 │ │289 // removing repo1 retains its place in the canonical order │ │290 - try evt.consume(.admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &[_]evt.EventWithId{ │ │290 + try evt.consume(.server, .admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &[_]evt.EventWithId{ │ │291 .{ .id = std.fmt.bytesToHex(repo_ids[1], .lower), .author = author, .timestamp = 200, .event = .{ .repo = null } },│ │292 }); │ │293 { │ ╰────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │296 } │ │297 │ │298 // update repo0 at a later timestamp -> keeps its original place │ │299 - try evt.consume(.admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &[_]evt.EventWithId{ │ │299 + try evt.consume(.server, .admin, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &[_]evt.EventWithId{ │ │300 .{ .id = std.fmt.bytesToHex(repo_ids[0], .lower), .author = author, .timestamp = 300, .event = .{ .repo = .{ .user_id = &user_id, .name = "repo0", .description = "updated" } } },│ │301 }); │ │302 { │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │336 │ │337 var admin = try rp.Repo(.xit, evt.admin_repo_opts).init(io, allocator, .{ .path = admin_path }); │ │338 defer admin.deinit(io, allocator); │ │339 - try evt.consume(.admin, .xit, evt.admin_repo_opts, io, allocator, &admin, evt.events_ref, &.{ │ │339 + try evt.consume(.server, .admin, .xit, evt.admin_repo_opts, io, allocator, &admin, evt.events_ref, &.{│ │340 .{ │ │341 .id = std.fmt.bytesToHex(user_id, .lower), │ │342 .timestamp = 1, │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────╯