╭──────────╮ │← previous│ ╰──────────╯ ╭ changed ────╮ │src/event.zig│ ╰─────────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │1559 io.random(&id_bytes); │ │1560 const event_id_hex = std.fmt.bytesToHex(id_bytes, .lower); │ │1561 │ │1531 - try consume(.xit, admin_repo_opts, io, allocator, &repo, events_ref, &[_]EventWithId{.{ │ │1562 + try consume(.admin, .xit, admin_repo_opts, io, allocator, &repo, events_ref, &[_]EventWithId{.{│ │1563 .id = event_id_hex, │ │1564 .timestamp = @intCast(std.Io.Timestamp.now(io, .real).toSeconds()), │ │1565 .author = .{ .name = owner.event.name, .email = owner.event.email }, │ ╰─────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭ changed ───────────────╮ │src/event/Attachment.zig│ ╰────────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────╮ │150 var id_bytes: [evt.event_id_size]u8 = undefined; │ │151 io.random(&id_bytes); │ │152 const event_id = std.fmt.bytesToHex(id_bytes, .lower); │ │153 - try evt.consume(repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &.{.{ │ │153 + try evt.consume(.repo, repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &.{.{│ │154 .id = event_id, │ │155 .timestamp = @intCast(std.Io.Timestamp.now(io, .real).toSeconds()), │ │156 .author = author, │ ╰────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭ changed ────────────╮ │src/event/Comment.zig│ ╰─────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────╮ │119 var id_bytes: [evt.event_id_size]u8 = undefined; │ │120 io.random(&id_bytes); │ │121 const event_id = std.fmt.bytesToHex(id_bytes, .lower); │ │122 - try evt.consume(repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &.{.{ │ │122 + try evt.consume(.repo, repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &.{.{│ │123 .id = event_id, │ │124 .timestamp = @intCast(std.Io.Timestamp.now(io, .real).toSeconds()), │ │125 .author = author, │ ╰────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────╮ │165 │ │166 var updated = comment.event; │ │167 updated.body = body; │ │168 - try evt.consume(repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &.{.{ │ │168 + try evt.consume(.repo, repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &.{.{│ │169 .id = std.fmt.bytesToHex(comment_id.*, .lower), │ │170 .timestamp = @intCast(std.Io.Timestamp.now(io, .real).toSeconds()), │ │171 .author = author, │ ╰────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭ changed ───────────────╮ │src/event/Discussion.zig│ ╰────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │165 const discussion = (try readById(repo_kind, repo_opts, io, allocator, &arena, repo, id)) orelse return error.NotFound;│ │166 if (discussion.removed) return error.NotFound; │ │167 │ │168 - try evt.consume(repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &.{.{ │ │168 + try evt.consume(.repo, repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &.{.{ │ │169 .id = std.fmt.bytesToHex(id.*, .lower), │ │170 .timestamp = @intCast(std.Io.Timestamp.now(io, .real).toSeconds()), │ │171 .author = author, │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭ changed ──────────╮ │src/event/Issue.zig│ ╰───────────────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │223 }, │ │224 } │ │225 │ │226 - try evt.consume(repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &[_]evt.EventWithId{.{ │ │226 + try evt.consume(.repo, repo_kind, repo_opts, io, allocator, repo, evt.events_ref, &[_]evt.EventWithId{.{│ │227 .id = std.fmt.bytesToHex(id_bytes.*, .lower), │ │228 .timestamp = @intCast(std.Io.Timestamp.now(io, .real).toSeconds()), │ │229 .author = author, │ ╰─────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭ changed ─────────╮ │src/event/User.zig│ ╰──────────────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │279 │ │280 var updated = user.event; │ │281 updated.enable_ansi = !updated.enable_ansi; │ │282 - try evt.consume(.xit, repo_opts, io, allocator, repo, evt.events_ref, &[_]evt.EventWithId{.{ │ │282 + try evt.consume(.admin, .xit, repo_opts, io, allocator, repo, evt.events_ref, &[_]evt.EventWithId{.{│ │283 .id = std.fmt.bytesToHex(user_id[0..evt.event_id_size].*, .lower), │ │284 .timestamp = @intCast(std.Io.Timestamp.now(io, .real).toSeconds()), │ │285 .author = .{ .name = user.event.name, .email = user.event.email }, │ ╰─────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭ changed ───╮ │src/fork.zig│ ╰────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │100 try repo.addConfig(io, allocator, .{ .name = "receive.denycurrentbranch", .value = "updateinstead" });│ │101 try repo.addConfig(io, allocator, .{ .name = "receive.denydeletes", .value = "true" }); │ │102 │ │103 - try evt.consume(.xit, repo_opts, io, allocator, &repo, evt.events_ref, &.{.{ │ │103 + try evt.consume(.fork, .xit, repo_opts, io, allocator, &repo, evt.events_ref, &.{.{ │ │104 .id = input.id, │ │105 .timestamp = input.timestamp, │ │106 .author = input.author, │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │110 .tags = input.tags, │ │111 } }, │ │112 }}); │ │113 - try evt.consume(.xit, evt.admin_repo_opts, io, allocator, admin_repo, evt.events_ref, &.{.{ │ │113 + try evt.consume(.admin, .xit, evt.admin_repo_opts, io, allocator, admin_repo, evt.events_ref, &.{.{│ │114 .id = input.id, │ │115 .timestamp = input.timestamp, │ │116 .author = input.author, │ ╰────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │269 } │ │270 if (event_count > 0) { │ │271 try evt.commitEvents(.xit, repo_opts, state, ctx.io, ctx.allocator, evt.events_ref, events[0..event_count], null); │ │272 - if (!try evt.consumeInTransaction(.xit, repo_opts, state, &ctx.core.db, &moment, ctx.io, ctx.allocator, evt.events_ref)) return error.CancelTransaction; │ │272 + if (!try evt.consumeInTransaction(.fork, .xit, repo_opts, state, &ctx.core.db, &moment, ctx.io, ctx.allocator, evt.events_ref)) return error.CancelTransaction;│ │273 } │ │274 try xit.undo.writeMessage(repo_opts, state, .push); │ │275 try ctx.core.chunk_store_file.sync(ctx.io); │ ╰────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────╮ │next →│ ╰──────╯