readme importing, lay groundwork for #6

src/db/Version.zig

@@ -30,10 +30,11 @@ deps: DepList, // TODO remove this column, no longer used in upstream Zigmod
 dev_deps: DepList,
 root_deps: DepList,
 build_deps: DepList,
+readme: string,
 
 pub const table_name = "versions";
 
-pub fn create(alloc: std.mem.Allocator, pkg: Package, commit: string, unpackedsize: u64, totalsize: u64, files: []const string, tarsize: u64, tarhash: string, deps: []const zigmod.Dep, rootdeps: []const zigmod.Dep, builddeps: []const zigmod.Dep) !Version {
+pub fn create(alloc: std.mem.Allocator, pkg: Package, commit: string, unpackedsize: u64, totalsize: u64, files: []const string, tarsize: u64, tarhash: string, deps: []const zigmod.Dep, rootdeps: []const zigmod.Dep, builddeps: []const zigmod.Dep, readme: string) !Version {
     db.mutex.lock();
     defer db.mutex.unlock();
 
@@ -54,6 +55,7 @@ pub fn create(alloc: std.mem.Allocator, pkg: Package, commit: string, unpackedsi
         .dev_deps = DepList{ .data = &.{} },
         .root_deps = DepList{ .data = rootdeps },
         .build_deps = DepList{ .data = builddeps },
+        .readme = readme,
     });
 }
 

src/handler/_internal.zig

@@ -213,3 +213,13 @@ pub fn redirectTo(response: *http.Response, dest: string) !void {
     try response.headers.put("Location", dest);
     try response.writeHeader(.found);
 }
+
+pub fn readFileContents(dir: std.fs.Dir, alloc: std.mem.Allocator, path: string) !?string {
+    const file = dir.openFile(path, .{}) catch |err| switch (err) {
+        error.FileNotFound => return null,
+        error.IsDir => return null,
+        else => |e| return e,
+    };
+    defer file.close();
+    return try file.reader().readAllAlloc(alloc, 1024 * 1024 * 2); // 2mb
+}

src/handler/do_import.zig

@@ -93,9 +93,10 @@ pub fn get(_: void, response: *http.Response, request: http.Request, args: struc
     try std.fs.cwd().deleteTree(path);
     const tarsize = try extras.fileSize(std.fs.cwd(), destpath);
     const tarhash = try extras.hashFile(alloc, std.fs.cwd(), destpath, .sha256);
+    const readme = (_internal.readFileContents(dir, alloc, "README.md") catch null) orelse "";
 
     var p = try db.Package.create(alloc, u, name, r, details.id, repo, desc, license, details.star_count);
-    var v = try db.Version.create(alloc, p, commit, unpackedsize, totalsize, filelist, tarsize, tarhash, deps, rootdeps, builddeps);
+    var v = try db.Version.create(alloc, p, commit, unpackedsize, totalsize, filelist, tarsize, tarhash, deps, rootdeps, builddeps, readme);
 
     //
 

src/handler/hook.zig

@@ -111,8 +111,9 @@ pub fn post(_: void, response: *http.Response, request: http.Request, args: stru
     try std.fs.cwd().deleteTree(path);
     const tarsize = try extras.fileSize(std.fs.cwd(), destpath);
     const tarhash = try extras.hashFile(alloc, std.fs.cwd(), destpath, .sha256);
+    const readme = (_internal.readFileContents(dir, alloc, "README.md") catch null) orelse "";
 
-    var v = try db.Version.create(alloc, p, commit, unpackedsize, totalsize, filelist, tarsize, tarhash, deps, rootdeps, builddeps);
+    var v = try db.Version.create(alloc, p, commit, unpackedsize, totalsize, filelist, tarsize, tarhash, deps, rootdeps, builddeps, readme);
     try p.update(alloc, .license, modfile.yaml.get_string("license"));
     try p.update(alloc, .description, modfile.yaml.get_string("description"));
     try p.update(alloc, .star_count, details.star_count);