HAXY

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

╭──────────╮ │← previous│ ╰──────────╯ ╭ changed ────╮ │src/patch.zig│ ╰─────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │ 998 else => |e| return e, │ │ 999 }; │ │1000 } │ │1001 - evt.bumpRepoActivityAt(io, allocator, users_dir, target_repo.core.work_path); │ │1001 + evt.bumpRepoActivityAt(io, allocator, server, target_repo.core.work_path); │ │1002 │ │1003 // remove the consumed draft from the fork │ │1004 - try evt.consume(.{ .server = .{ .users_dir = users_dir } }, .fork, .xit, repo_opts, io, allocator, &fork_repo, evt.events_ref, &.{.{│ │1004 + try evt.consume(.{ .server = server }, .fork, .xit, repo_opts, io, allocator, &fork_repo, evt.events_ref, &.{.{ │ │1005 .id = input.id, │ │1006 .timestamp = input.timestamp, │ │1007 .author = input.author, │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │1013 if (fork_record.event.stage == .draft) { │ │1014 var published = fork_record.event; │ │1015 published.stage = .publish; │ │1016 - try evt.consume(.{ .server = .{ .users_dir = users_dir } }, .user, .xit, evt.user_repo_opts, io, allocator, &user_repo, evt.events_ref, &.{.{│ │1016 + try evt.consume(.{ .server = server }, .user, .xit, evt.user_repo_opts, io, allocator, &user_repo, evt.events_ref, &.{.{ │ │1017 .id = input.id, │ │1018 .timestamp = input.timestamp, │ │1019 .author = input.author, │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────╮ │1083 comptime repo_opts: rp.RepoOpts(.xit), │ │1084 io: std.Io, │ │1085 allocator: std.mem.Allocator, │ │1086 - users_dir: []const u8, │ │1086 + server: evt.Host.Server, │ │1087 target_repo: *rp.Repo(.xit, repo_opts),│ │1088 input: MergeInput, │ │1089 ) !void { │ ╰─────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │1090 const patch_id = try evt.parseEventId(&input.id); │ │1091 - mergeInner(repo_opts, io, allocator, users_dir, target_repo, input, patch_id) catch |err| { │ │1091 + mergeInner(repo_opts, io, allocator, server, target_repo, input, patch_id) catch |err| { │ │1092 if (err == error.PatchDataUnavailable or err == error.PatchOutOfDate) { │ │1093 - refreshMergeability(repo_opts, io, allocator, target_repo, users_dir, patch_id); │ │1093 + refreshMergeability(repo_opts, io, allocator, target_repo, server.users_dir, patch_id);│ │1094 } │ │1095 return err; │ │1096 }; │ ╰─────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────╮ │1100 comptime repo_opts: rp.RepoOpts(.xit), │ │1101 io: std.Io, │ │1102 allocator: std.mem.Allocator, │ │1103 - users_dir: []const u8, │ │1103 + server: evt.Host.Server, │ │1104 target_repo: *rp.Repo(.xit, repo_opts),│ │1105 input: MergeInput, │ │1106 patch_id: [evt.event_id_size]u8, │ ╰─────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │1125 var config = try target_repo.listConfig(io, allocator); │ │1126 defer config.deinit(); │ │1127 const forker_id = (try fork.readForkerId(&config.sections, &patch_id)) orelse return error.PatchDataUnavailable; │ │1128 - const fork_path = try fork.forkPath(arena.allocator(), users_dir, &forker_id, &patch_id); │ │1128 + const fork_path = try fork.forkPath(arena.allocator(), server.users_dir, &forker_id, &patch_id); │ │1129 break :blk rp.Repo(.xit, repo_opts).open(io, allocator, .{ .path = fork_path, .require_repo_root = true }) catch return error.PatchDataUnavailable;│ │1130 }; │ │1131 defer if (fork_repo_maybe) |*repo| repo.deinit(io, allocator); │ ╰─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────╮ │1248 .timestamp = input.timestamp, │ │1249 }); │ │1250 } │ │1251 - evt.bumpRepoActivityAt(io, allocator, users_dir, target_repo.core.work_path); │ │1251 + evt.bumpRepoActivityAt(io, allocator, server, target_repo.core.work_path); │ │1252 │ │1253 // refresh other patches affected by the updated target branch. │ │1254 - refreshOpenMergeability(repo_opts, io, allocator, target_repo, users_dir, null, null); │ │1254 + refreshOpenMergeability(repo_opts, io, allocator, target_repo, server.users_dir, null, null);│ │1255 } │ │1256 │ │1257 // merge a published patch and remove its fork │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────╮ │1259 comptime repo_opts: rp.RepoOpts(.xit), │ │1260 io: std.Io, │ │1261 allocator: std.mem.Allocator, │ │1262 - users_dir: []const u8, │ │1262 + server: evt.Host.Server, │ │1263 target_repo: *rp.Repo(.xit, repo_opts),│ │1264 input: MergeInput, │ │1265 ) !void { │ ╰─────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────────────────────────────╮ │1266 - try merge(repo_opts, io, allocator, users_dir, target_repo, input);│ │1266 + try merge(repo_opts, io, allocator, server, target_repo, input); │ │1267 var arena = std.heap.ArenaAllocator.init(allocator); │ │1268 defer arena.deinit(); │ │1269 │ ╰─────────────────────────────────────────────────────────────────────────────╯ ╭────────────────────────────────────────────────────────────────────────────────────────────────╮ │1277 defer config.deinit(); │ │1278 break :blk (try fork.readForkerId(&config.sections, &patch_id)) orelse return; │ │1279 }; │ │1280 - try fork.remove(io, allocator, users_dir, &forker_id, &input.id, input.author); │ │1280 + try fork.remove(io, allocator, server.users_dir, &forker_id, &input.id, input.author);│ │1281 } │ │1282 │ │1283 fn commitAuthor(line: []const u8) !evt.CommitAuthor { │ ╰────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────╮ │next →│ ╰──────╯