╭ changed ───────────────╮ │src/test/event/patch.zig│ ╰────────────────────────╯ ╭───────────╮ │← all files│ ╰───────────╯ ╭──────────╮ │← previous│ ╰──────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────╮ │1100 .squash => squash_oid, │ │1101 .source => source_oid, │ │1102 }; │ │1096 - try pch.mergeAndRemoveFork(repo_opts, io, allocator, repos_dir, &admin, &target, .{│ │1103 + try pch.mergeAndRemoveFork(repo_opts, io, allocator, repos_dir, &target, .{ │ │1104 .id = patch_id_hex, │ │1105 .revision = merge_revision, │ │1106 .author = author, │ ╰─────────────────────────────────────────────────────────────────────────────────────────────╯ ╭───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │1125 try std.testing.expect(null != try evt.PatchRev.readById(Repo.DB, repo_opts.hash, merged_moment, &arena, &first_patchrev_id)); │ │1126 │ │1127 _ = arena.reset(.retain_capacity); │ │1121 - const removed_fork = (try evt.Fork.readById(evt.AdminDB, evt.admin_repo_opts.hash, try evt.currentMoment(evt.admin_repo_opts, &admin), &arena, &patch_id)) orelse return error.NotFound; │ │1128 + const removed_fork = (try evt.Fork.readById(evt.UserDB, evt.user_repo_opts.hash, try evt.currentMoment(evt.user_repo_opts, &user_repo), &arena, &patch_id)) orelse return error.NotFound;│ │1129 try std.testing.expect(removed_fork.removed); │ │1130 } │ │1131 │ ╰───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │1125 -fn indexedForkCount( │ │1126 - moment: evt.AdminDB.HashMap(.read_only), │ │1127 - index_key: []const u8, │ │1128 - parent_id: []const u8, │ │1129 -) !u64 { │ │1130 - const index_cursor = try moment.getCursor(hash.hashInt(evt.admin_repo_opts.hash, index_key)) orelse return 0; │ │1131 - const index = try evt.AdminDB.HashMap(.read_only).init(index_cursor); │ │1132 - const ids_cursor = try index.getCursor(hash.hashInt(evt.admin_repo_opts.hash, parent_id)) orelse return 0; │ │1133 - const ids = try evt.AdminDB.SortedSet(.read_only).init(ids_cursor); │ │1132 +fn draftForkCount(moment: evt.UserDB.HashMap(.read_only), repo_id: []const u8) !u64 { │ │1133 + const index_cursor = try moment.getCursor(hash.hashInt(evt.user_repo_opts.hash, evt.Fork.repo_to_draft_id_set_key)) orelse return 0;│ │1134 + const index = try evt.UserDB.HashMap(.read_only).init(index_cursor); │ │1135 + const ids_cursor = try index.getCursor(hash.hashInt(evt.user_repo_opts.hash, repo_id)) orelse return 0; │ │1136 + const ids = try evt.UserDB.SortedSet(.read_only).init(ids_cursor); │ │1137 + return try ids.count(); │ │1138 +} │ │1139 + │ │1140 +fn activeForkCount(moment: evt.UserDB.HashMap(.read_only)) !u64 { │ │1141 + const ids_cursor = try moment.getCursor(hash.hashInt(evt.user_repo_opts.hash, evt.Fork.active_id_set_key)) orelse return 0; │ │1142 + const ids = try evt.UserDB.SortedSet(.read_only).init(ids_cursor); │ │1143 return try ids.count(); │ │1144 } │ │1145 │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯