const std = @import("std"); const unicode = std.unicode; const sort = std.sort; const Allocator = std.mem.Allocator; const ArrayListUnmanaged = std.ArrayListUnmanaged; const StringHashMap = std.StringHashMap; const AutoHashMap = std.AutoHashMap; const BufSet = std.BufSet; const pad = @import("padding.zig"); const userImport = @import("user.zig"); const groupImport = @import("group.zig"); const User = userImport.User; const Group = groupImport.Group; const Corpus = struct { arena: std.heap.ArenaAllocator, // sorted by name, by unicode codepoint users: []User, // sorted by gid groups: []Group, // pointing to `users` and `groups` slices above. name2user: StringHashMap(*const User), uid2user: AutoHashMap(u32, *const User), name2group: StringHashMap(*const Group), gid2group: AutoHashMap(u32, *const Group), groupname2users: StringHashMap(ArrayListUnmanaged(*const User)), username2groups: StringHashMap(ArrayListUnmanaged(*const Group)), pub const initErr = Allocator.Error || error{InvalidUtf8} || error{Duplicate} || error{NotFound}; pub fn init( baseAllocator: Allocator, usersConst: []const User, groupsConst: []const Group, ) initErr!Corpus { var arena = std.heap.ArenaAllocator.init(baseAllocator); var allocator = arena.allocator(); var users = try allocator.alloc(User, usersConst.len); var groups = try allocator.alloc(Group, groupsConst.len); for (usersConst) |_, i| { users[i] = try usersConst[i].clone(allocator); } for (groupsConst) |_, i| { groups[i] = try groupsConst[i].clone(allocator); } sort.sort(User, users, {}, cmpUser); sort.sort(Group, groups, {}, cmpGroup); var name2user = StringHashMap(*const User).init(allocator); var uid2user = AutoHashMap(u32, *const User).init(allocator); var name2group = StringHashMap(*const Group).init(allocator); var gid2group = AutoHashMap(u32, *const Group).init(allocator); for (users) |*user| { var res1 = try name2user.getOrPut(user.name); if (res1.found_existing) { return error.Duplicate; } res1.value_ptr.* = user; var res2 = try uid2user.getOrPut(user.uid); if (res2.found_existing) { return error.Duplicate; } res2.value_ptr.* = user; } for (groups) |*group| { var res1 = try name2group.getOrPut(group.name); if (res1.found_existing) { return error.Duplicate; } res1.value_ptr.* = group; var res2 = try gid2group.getOrPut(group.gid); if (res2.found_existing) { return error.Duplicate; } res2.value_ptr.* = group; } var groupname2users = StringHashMap(ArrayListUnmanaged(*const User)).init(allocator); var username2groups = StringHashMap(ArrayListUnmanaged(*const Group)).init(allocator); for (groups) |*group| { var members = try ArrayListUnmanaged(*const User).initCapacity( allocator, group.members.count(), ); var it = group.members.iterator(); while (it.next()) |memberName| { if (name2user.get(memberName.*)) |user| { members.appendAssumeCapacity(user); } else { return error.NotFound; } var groupsOfMember = try username2groups.getOrPut(memberName.*); if (!groupsOfMember.found_existing) { groupsOfMember.value_ptr.* = ArrayListUnmanaged(*const Group){}; } try groupsOfMember.value_ptr.*.append(allocator, group); } var result = try groupname2users.getOrPut(group.name); if (result.found_existing) { return error.Duplicate; } result.value_ptr.* = members; } { var it = groupname2users.valueIterator(); while (it.next()) |groupUsers| { sort.sort(*const User, groupUsers.items, {}, cmpUserPtr); } } { var it = username2groups.valueIterator(); while (it.next()) |userGroups| { sort.sort(*const Group, userGroups.items, {}, cmpGroupPtr); } } return Corpus{ .arena = arena, .users = users, .groups = groups, .name2user = name2user, .uid2user = uid2user, .name2group = name2group, .gid2group = gid2group, .groupname2users = groupname2users, .username2groups = username2groups, }; } pub fn deinit(self: *Corpus) void { self.arena.deinit(); self.* = undefined; } }; // cmpUser compares two users for sorting. By username's utf8 codepoints, ascending. fn cmpUser(_: void, a: User, b: User) bool { var utf8_a = (unicode.Utf8View.init(a.name) catch unreachable).iterator(); var utf8_b = (unicode.Utf8View.init(b.name) catch unreachable).iterator(); while (utf8_a.nextCodepoint()) |codepoint_a| { if (utf8_b.nextCodepoint()) |codepoint_b| { if (codepoint_a != codepoint_b) { return codepoint_a < codepoint_b; } } else { // a is a prefix of b. It is thus shorter. return false; } } // b is a prefix of a return true; } fn cmpUserPtr(context: void, a: *const User, b: *const User) bool { return cmpUser(context, a.*, b.*); } fn cmpGroup(_: void, a: Group, b: Group) bool { return a.gid < b.gid; } fn cmpGroupPtr(context: void, a: *const Group, b: *const Group) bool { return cmpGroup(context, a.*, b.*); } const testing = std.testing; test "test corpus" { const allocator = testing.allocator; const users = [_]User{ User{ .uid = 1000, .gid = 1000, .name = "vidmantas", .gecos = "Vidmantas Kaminskas", .home = "/home/vidmantas", .shell = "/bin/bash", }, User{ .uid = 0, .gid = std.math.maxInt(u32), .name = "Name" ** 8, .gecos = "Gecos" ** 51, .home = "Home" ** 16, .shell = "She.LllL" ** 8, }, User{ .uid = 1002, .gid = 1002, .name = "svc-bar", .gecos = "", .home = "/", .shell = "/", } }; var members1 = try groupImport.someMembers( allocator, &[_][]const u8{"vidmantas"}, ); defer members1.deinit(); var members2 = try groupImport.someMembers( allocator, &[_][]const u8{ "svc-bar", "vidmantas" }, ); defer members2.deinit(); var members3 = try groupImport.someMembers( allocator, &[_][]const u8{ "svc-bar", "Name" ** 8, "vidmantas" }, ); defer members3.deinit(); const groups = [_]Group{ Group{ .gid = 1000, .name = "vidmantas", .members = members1, }, Group{ .gid = 9999, .name = "all", .members = members3, }, Group{ .gid = 1234, .name = "service-account", .members = members2, } }; var corpus = try Corpus.init(allocator, users[0..], groups[0..]); defer corpus.deinit(); try testing.expectEqualStrings(corpus.users[0].name, "Name" ** 8); try testing.expectEqualStrings(corpus.users[1].name, "svc-bar"); try testing.expectEqualStrings(corpus.users[2].name, "vidmantas"); try testing.expectEqual(corpus.name2user.get("404"), null); try testing.expectEqual(corpus.name2user.get("vidmantas").?.uid, 1000); try testing.expectEqual(corpus.uid2user.get(42), null); try testing.expectEqual(corpus.uid2user.get(1000).?.gid, 1000); try testing.expectEqual(corpus.name2group.get("404"), null); try testing.expectEqual(corpus.name2group.get("vidmantas").?.gid, 1000); try testing.expectEqual(corpus.gid2group.get(42), null); try testing.expectEqual(corpus.gid2group.get(1000).?.gid, 1000); const membersOfAll = corpus.groupname2users.get("all").?.items; try testing.expectEqualStrings(membersOfAll[0].name, "Name" ** 8); try testing.expectEqualStrings(membersOfAll[1].name, "svc-bar"); try testing.expectEqualStrings(membersOfAll[2].name, "vidmantas"); try testing.expectEqual(corpus.groupname2users.get("404"), null); const groupsOfVidmantas = corpus.username2groups.get("vidmantas").?.items; try testing.expectEqual(groupsOfVidmantas[0].gid, 1000); try testing.expectEqual(groupsOfVidmantas[1].gid, 1234); try testing.expectEqual(groupsOfVidmantas[2].gid, 9999); try testing.expectEqual(corpus.username2groups.get("404"), null); } fn testUser(name: []const u8) User { var result = std.mem.zeroes(User); result.name = name; return result; } test "users compare function" { const a = testUser("a"); const b = testUser("b"); const bb = testUser("bb"); try testing.expect(cmpUser({}, a, b)); try testing.expect(!cmpUser({}, b, a)); try testing.expect(cmpUser({}, a, bb)); try testing.expect(!cmpUser({}, bb, a)); try testing.expect(cmpUser({}, b, bb)); try testing.expect(!cmpUser({}, bb, b)); }