X-Git-Url: https://gitweb.ps.run/ziggit/blobdiff_plain/15b4b7a21d5f8a0042b69133116b5deebc675d08..efdfc67c25639929fb63ef7f6e18474690546599:/git.zig diff --git a/git.zig b/git.zig index 8c44fb6..37933c9 100644 --- a/git.zig +++ b/git.zig @@ -23,6 +23,11 @@ const Tree = std.ArrayList(TreeEntry); const Blob = struct { data: []u8, }; +const ParsedObject = union(enum) { + c: Commit, + t: Tree, + b: Blob, +}; const Object = struct { kind: u3, data: []u8, @@ -33,6 +38,55 @@ const Object = struct { .data = data, }; } + pub fn parse(self: Object, alloc: Alloc) !ParsedObject { + switch (self.kind) { + 1 => { + const authorOffset = std.mem.indexOf(u8, self.data, "author ") orelse return error.InvalidCommitFormat; + const authorNewline = std.mem.indexOfScalarPos(u8, self.data, authorOffset, '\n') orelse return error.InvalidCommitFormat; + const committerOffset = std.mem.indexOf(u8, self.data, "committer ") orelse return error.InvalidCommitFormat; + const committerNewline = std.mem.indexOfScalarPos(u8, self.data, committerOffset, '\n') orelse return error.InvalidCommitFormat; + + return .{ + .c = Commit{ + .tree = try std.fmt.parseUnsigned(Id, self.data[5..45], 16), + .parent = try std.fmt.parseUnsigned(Id, self.data[53..93], 16), + .author = self.data[authorOffset..authorNewline], + .committer = self.data[committerOffset..committerNewline], + .message = self.data[committerNewline + 1 .. self.data.len], + }, + }; + }, + 2 => { + var t = Tree.init(alloc); + + var offset: usize = 0; + + while (offset < self.data.len - 1) { + const spaceOffset = std.mem.indexOfScalarPos(u8, self.data, offset, ' ') orelse return error.InvalidTreeFormat; + const zeroOffset = std.mem.indexOfScalarPos(u8, self.data, spaceOffset, 0) orelse return error.InvalidTreeFormat; + + try t.append(.{ + .permissions = self.data[offset..spaceOffset], + .name = self.data[spaceOffset + 1 .. zeroOffset], + .id = std.mem.readVarInt(Id, self.data[zeroOffset + 1 .. zeroOffset + 21], .big), + }); + + offset = zeroOffset + 21; + } + + return .{ .t = t }; + }, + 3 => { + return .{ + .b = Blob{ .data = self.data }, + }; + }, + 4 => { + return error.TagNotImplemented; + }, + else => return error.UnknownGitObjectType, + } + } // pub fn getCommit(self: *Object) Commit {} // pub fn getBlob(self: *Object) Blob {} }; @@ -230,6 +284,9 @@ const PackFile = struct { } counter += bitsSet; + if (dataSize == 0) + dataSize = 0x10000; + std.mem.copyForwards( u8, result[resultCounter..result.len], @@ -245,6 +302,7 @@ const PackFile = struct { result[resultCounter..result.len], deltData[deltaDataOffset + counter + 1 .. deltaDataOffset + counter + 1 + dataSize], ); + resultCounter += dataSize; counter += dataSize; } @@ -282,6 +340,7 @@ const PackFile = struct { if (objectKind == 6) { const offset = try getOffset(reader); + return try self.ofsDelta( @intCast(offset.offset + objectSize.bytelen + offset.bytelen), ); @@ -296,7 +355,9 @@ const PackFile = struct { const pckReader = self.pckFile.reader().any(); try self.pckFile.seekTo(offset); - return try self.readObject(pckReader); + const o = try self.readObject(pckReader); + + return o; } return null; } @@ -376,7 +437,25 @@ test "get object" { if (try repo.getObject(head)) |o| { defer std.testing.allocator.free(o.data); - std.debug.print("object: {s}\n", .{o.data}); + std.debug.print("object({}): {s}\n", .{ o.kind, o.data }); + } +} + +test "parse commit" { + var repo = try Repo.open(std.testing.allocator, "../imgui/.git"); + defer repo.close(); + + const head = try repo.getHead(); + + if (try repo.getObject(head)) |o| { + defer std.testing.allocator.free(o.data); + + switch (try o.parse(std.testing.allocator)) { + .c => |c| { + std.debug.print("commit:\n tree: {x}\n parent: {x}\n author: {s}\n committer: {s}\n message: {s}\n", .{ c.tree, c.parent, c.author, c.committer, c.message }); + }, + else => {}, + } } } @@ -387,44 +466,75 @@ test "get tree" { if (try repo.getObject(0xceb2b2c62d6f8f3686dcacecd5be931839b02c77)) |o| { defer std.testing.allocator.free(o.data); - std.debug.print("tree: {s}\n", .{o.data}); + // std.debug.print("tree({}): {any}\n", .{ o.kind, o.data }); } } -// test "list commits" { -// var repo = Repo.open(std.testing.allocator, "../imgui/.git"); -// defer repo.close(); -// const head = repo.getObject(repo.head); -// defer head.deinit(); +test "parse tree" { + var repo = try Repo.open(std.testing.allocator, "../imgui/.git"); + defer repo.close(); + + if (try repo.getObject(0xceb2b2c62d6f8f3686dcacecd5be931839b02c77)) |o| { + defer std.testing.allocator.free(o.data); -// var c = head.getCommit(); -// for (0..3) |_| { -// std.debug.print("{}\n", .{c}); -// c = c.parent; -// } -// } + switch (try o.parse(std.testing.allocator)) { + .t => |t| { + defer t.deinit(); + for (t.items) |treeEntry| { + std.debug.print("{s} {s} {x}\n", .{ treeEntry.permissions, treeEntry.name, treeEntry.id }); + } + }, + else => {}, + } + } +} -// test "tree" { -// var repo = Repo.open(std.testing.allocator, "../imgui/.git"); -// defer repo.close(); +test "list commits" { + var repo = try Repo.open(std.testing.allocator, "../imgui/.git"); + defer repo.close(); -// const head = repo.getObject(repo.head); -// defer head.deinit(); + const head = try repo.getHead(); -// const commit = head.getCommit(); + var id = head; -// std.debug.print("{}\n", .{commit.tree}); -// } + for (0..3) |_| { + if (try repo.getObject(id)) |o| { + defer std.testing.allocator.free(o.data); -// test "blob" { -// var repo = Repo.open(std.testing.allocator, "../imgui/.git"); -// defer repo.close(); + switch (try o.parse(std.testing.allocator)) { + .c => |c| { + std.debug.print("commit {x}:\n tree: {x}\n parent: {x}\n author: {s}\n committer: {s}\n message: {s}\n", .{ id, c.tree, c.parent, c.author, c.committer, c.message }); + id = c.parent; + }, + else => {}, + } + } + } +} -// const head = repo.getObject(repo.head); -// defer head.deinit(); +test "list blobs" { + var repo = try Repo.open(std.testing.allocator, "../imgui/.git"); + defer repo.close(); -// const commit = head.getCommit(); -// const blob = repo.getBlob(commit.files[0].id); + if (try repo.getObject(0xceb2b2c62d6f8f3686dcacecd5be931839b02c77)) |o| { + defer std.testing.allocator.free(o.data); -// std.debug.print("{}\n", .{blob}); -// } + switch (try o.parse(std.testing.allocator)) { + .t => |t| { + defer t.deinit(); + for (t.items) |treeEntry| { + if (try repo.getObject(treeEntry.id)) |bo| { + defer std.testing.allocator.free(bo.data); + + if (treeEntry.permissions.len == 6) { + std.debug.print("{s}: [{x} {}]{s}\n", .{ treeEntry.name, treeEntry.id, bo.data.len, bo.data[0..50] }); + } else { + std.debug.print("[{s}]\n", .{treeEntry.name}); + } + } + } + }, + else => {}, + } + } +}