HAXY

▄ ▄▀▀▀▀ ▀ ▄▀▀▀▀▀ ▄▀▀▀ ▄▀▀▀▄▀▀ ▄▄▀▀▀▀▄▀ ▄▀▀▄▀▀▀▀ ▀▀▀▀▀▀▀▀▄ ▀▀▀▀▀▀▀▀▀ ▄ ▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀ ▀▄▄▀▄▀▀▀▀ ▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀ ▄ ▀▀▀▄▀▀▀▀▀▀▀ ▀▀▀▀▀ ▄▀▀▀▀▀▀▀▀▀▄▀▀▄ ▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▄ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▄ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▄ ▀▀▄ ▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄ ▀▀▀▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▄▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▄▄▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▄▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▄▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀ ▀▀▀▀▀▄▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▄▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▄▀▄ ▀▀ ▀▀▀▀▀▀▄▀▀▀▀▀▄▄▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▄▀▄▄▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀▀ ▀▀ ▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀ ▀ ▀▀▀▀▀▀▀▄▄▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▄▄▀▀▀▄▄▀▄▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▄▄▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▄▀▀▄ ▀▀▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀

╭ changed ───╮ │src/fork.zig│ ╰────────────╯ ╭───────────╮ │← all files│ ╰───────────╯ ╭────────────────────────────────────────────╮ │37 id: [evt.event_id_size * 2]u8, │ │38 user_id: [evt.event_id_size]u8, │ │39 repo_id: [evt.event_id_size]u8, │ │40 + repo_user_id: [evt.event_id_size]u8,│ │41 title: []const u8, │ │42 description: []const u8, │ │43 labels: []const u8, │ ╰────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────╮ │51 io: std.Io, │ │52 allocator: std.mem.Allocator, │ │53 repo_root_path: []const u8, │ │53 - admin_repo: *rp.Repo(.xit, evt.admin_repo_opts), │ │54 + user_repo: *rp.Repo(.xit, evt.user_repo_opts), │ │55 input: CreateInput, │ │56 ) ![]u8 { │ │57 if (!evt.Patch.fieldsValid(input.title, input.labels)) return error.InvalidPatch;│ ╰─────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────╮ │65 // make sure the fork id doesn't already exist │ │66 var arena = std.heap.ArenaAllocator.init(allocator); │ │67 defer arena.deinit(); │ │67 - const existing = if (evt.currentMoment(evt.admin_repo_opts, admin_repo)) |moment| │ │68 - try evt.Fork.readById(evt.AdminDB, evt.admin_repo_opts.hash, moment, &arena, &fork_id)│ │69 - else |err| switch (err) { │ │70 - error.NotFound => null, │ │71 - else => |other| return other, │ │72 - }; │ │68 + const existing = if (try evt.userMoment(user_repo)) |moment| │ │69 + try evt.Fork.readById(evt.UserDB, evt.user_repo_opts.hash, moment, &arena, &fork_id) │ │70 + else │ │71 + null; │ │72 if (existing != null) return error.InvalidPatchDraft; │ │73 │ │74 // get the target repo │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────╮ │122 core: *rp.Repo(.xit, repo_opts).Core, │ │123 io: std.Io, │ │124 allocator: std.mem.Allocator, │ │125 + forker_id: [evt.event_id_size * 2]u8, │ │126 │ │127 pub fn run(ctx: @This(), cursor: *DB.Cursor(.read_write)) !void {│ │128 var moment = try DB.HashMap(.read_write).init(cursor.*); │ ╰──────────────────────────────────────────────────────────────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │157 var config = try xit.config.Config(.xit, repo_opts).init(state.readOnly(), ctx.io, ctx.allocator);│ │158 defer config.deinit(); │ │159 try config.add(state, ctx.io, .{ .name = "receive.denydeletes", .value = "true" }); │ │160 + try config.add(state, ctx.io, .{ .name = "haxy.forker", .value = &ctx.forker_id }); │ │161 │ │162 // the copied db carries the target's file index, so the patch │ │163 // branch's entry starts from one of those rather than walking │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │174 const history = try DB.ArrayList(.read_write).init(fork_repo.core.db.rootCursor()); │ │175 try history.appendContext( │ │176 .{ .slot = try history.getSlot(-1) }, │ │176 - Ctx{ .core = &fork_repo.core, .io = io, .allocator = allocator }, │ │177 + Ctx{ .core = &fork_repo.core, .io = io, .allocator = allocator, .forker_id = std.fmt.bytesToHex(input.user_id, .lower) },│ │178 ); │ │179 } │ │180 │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │192 }}); │ │193 │ │194 // create the fork event │ │194 - try evt.consume(.server, .admin, .xit, evt.admin_repo_opts, io, allocator, admin_repo, evt.events_ref, &.{.{│ │195 + try evt.consume(.server, .user, .xit, evt.user_repo_opts, io, allocator, user_repo, evt.events_ref, &.{.{ │ │196 .id = input.id, │ │197 .timestamp = input.timestamp, │ │198 .author = input.author, │ ╰─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────╮ │199 .event = .{ .fork = .{ │ │199 - .user_id = &input.user_id, │ │200 .repo_id = &input.repo_id, │ │201 + .repo_user_id = &input.repo_user_id,│ │202 } }, │ │203 }}); │ │204 │ ╰─────────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────────╮ │210 io: std.Io, │ │211 allocator: std.mem.Allocator, │ │212 repo_root_path: []const u8, │ │212 - admin_repo: *rp.Repo(.xit, evt.admin_repo_opts),│ │213 + user_repo: *rp.Repo(.xit, evt.user_repo_opts), │ │214 id: *const [evt.event_id_size * 2]u8, │ │214 - expected_user_id: ?*const [evt.event_id_size]u8,│ │215 author: evt.CommitAuthor, │ │216 ) !void { │ │217 const fork_id = try evt.parseEventId(id); │ ╰─────────────────────────────────────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │218 var arena = std.heap.ArenaAllocator.init(allocator); │ │219 defer arena.deinit(); │ │220 - const moment = try evt.currentMoment(evt.admin_repo_opts, admin_repo); │ │221 - const record = (try evt.Fork.readById(evt.AdminDB, evt.admin_repo_opts.hash, moment, &arena, &fork_id)) orelse return error.InvalidPatchDraft;│ │222 - if (expected_user_id) |user_id| { │ │223 - if (!std.mem.eql(u8, record.event.user_id, user_id)) return error.InvalidPatchDraft; │ │224 - } │ │225 - if (!record.removed) try evt.remove(.server, .admin, .xit, evt.admin_repo_opts, io, allocator, admin_repo, &fork_id, .fork, author); │ │220 + const moment = (try evt.userMoment(user_repo)) orelse return error.InvalidPatchDraft; │ │221 + const record = (try evt.Fork.readById(evt.UserDB, evt.user_repo_opts.hash, moment, &arena, &fork_id)) orelse return error.InvalidPatchDraft; │ │222 + if (!record.removed) try evt.remove(.server, .user, .xit, evt.user_repo_opts, io, allocator, user_repo, &fork_id, .fork, author); │ │223 │ │224 const path = try forkPath(allocator, repo_root_path, id); │ │225 defer allocator.free(path); │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────╮ │next →│ ╰──────╯