╭ changed ───╮ │src/fork.zig│ ╰────────────╯ ╭───────────╮ │← all files│ ╰───────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │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); │ ╰────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────╮ │313 if (published_patch.event.patchrev_id) |*published_revision| { │ │314 if (std.mem.eql(u8, published_revision, &revision_hex)) return; │ │315 } │ │316 - evt.consume(.xit, repo_opts, io, allocator, target_repo, evt.events_ref, &.{.{ │ │316 + evt.consume(.repo, .xit, repo_opts, io, allocator, target_repo, evt.events_ref, &.{.{│ │317 .id = id.*, │ │318 .timestamp = timestamp, │ │319 .author = author, │ ╰──────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────╮ │385 if (revision.removed) return error.PatchNotPushed; │ │386 const metadata = existing orelse local_patch; │ │387 │ │388 - try evt.consume(.xit, repo_opts, io, allocator, target_repo, evt.events_ref, &.{.{ │ │388 + try evt.consume(.repo, .xit, repo_opts, io, allocator, target_repo, evt.events_ref, &.{.{│ │389 .id = input.id, │ │390 .timestamp = input.timestamp, │ │391 .author = input.author, │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────────╮ │398 } }, │ │399 }}); │ │400 │ │401 - try evt.consume(.xit, repo_opts, io, allocator, &fork_repo, evt.events_ref, &.{.{ │ │401 + try evt.consume(.fork, .xit, repo_opts, io, allocator, &fork_repo, evt.events_ref, &.{.{│ │402 .id = input.id, │ │403 .timestamp = input.timestamp, │ │404 .author = input.author, │ ╰─────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │426 const path = try forkPath(allocator, repo_root_path, id); │ │427 defer allocator.free(path); │ │428 try std.Io.Dir.cwd().deleteTree(io, path); │ │429 - if (!record.removed) try evt.remove(.xit, evt.admin_repo_opts, io, allocator, admin_repo, &fork_id, .fork, author); │ │429 + if (!record.removed) try evt.remove(.admin, .xit, evt.admin_repo_opts, io, allocator, admin_repo, &fork_id, .fork, author);│ │430 } │ │431 │ ╰────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯