tiny.smg.context.source

1pub const source = @import("source.zig");

1const std = @import("std");2const repo = @import("repo");3const sys = @import("sys");4const smg = @import("../root.zig");5const context = @import("root.zig");6const model = context.model;7const io = std.Options.debug_io;89pub fn inspect(builder: *model.Builder, entry: *model.Entry, node: smg.Node) !void {10    std.debug.assert(builder.entry_count != 0);11    std.debug.assert(std.mem.eql(u8, entry.name, node.name));12    const evidence = smg.api.declarationSource(node) catch {13        builder.report.coverage.unverified_spans += 1;14        return;15    };16    entry.source_span = evidence.span;17    entry.source_sha256 = try builder.allocator.dupe(18        u8,19        &std.fmt.bytesToHex(evidence.digest, .lower),20    );21    entry.basis = verify(builder, evidence) catch |err| switch (err) {22        error.OutOfMemory => return err,23        else => .unavailable,24    };25    if (entry.basis == .verified_span) {26        builder.report.coverage.verified_spans += 1;27    } else {28        builder.report.coverage.unverified_spans += 1;29    }30    if (entry.basis == .stale and builder.report.state == .ready) builder.report.state = .stale;31}3233fn verify(builder: *model.Builder, evidence: smg.api.DeclarationSource) !model.Basis {34    if (!builder.active()) return .unverified;35    const count = evidence.span.end_byte - evidence.span.start_byte;36    std.debug.assert(count != 0);37    const remaining = builder.options.limits.source_bytes - builder.report.coverage.source_bytes;38    if (count > remaining) {39        builder.report.omissions.source = true;40        builder.exhausted();41        return .oversized;42    }43    const path = try sourcePath(builder.allocator, builder.root, evidence.file);44    defer builder.allocator.free(path);45    if ((try sys.fs.statFile(path)).kind != .file) return .unavailable;46    var file = try std.Io.Dir.openFileAbsolute(io, path, .{ .follow_symlinks = false });47    defer file.close(io);48    const before = try file.stat(io);49    if (before.kind != .file) return .unavailable;50    if (evidence.span.end_byte > before.size) return .stale;51    const bytes = try builder.allocator.alloc(u8, count);52    defer builder.allocator.free(bytes);53    const read = try file.readPositionalAll(io, bytes, evidence.span.start_byte);54    std.debug.assert(read <= count);55    builder.report.coverage.source_bytes += @intCast(read);56    if (!builder.active()) return .unverified;57    if (read != bytes.len) return .stale;58    const after = try file.stat(io);59    if (before.size != after.size or before.mtime.nanoseconds != after.mtime.nanoseconds) {60        return .stale;61    }62    const digest = smg.api.sourceDigest(bytes);63    return if (std.mem.eql(u8, &digest, &evidence.digest)) .verified_span else .stale;64}6566fn sourcePath(allocator: std.mem.Allocator, root: []const u8, path: []const u8) ![]u8 {67    std.debug.assert(std.fs.path.isAbsolute(root));68    std.debug.assert(path.len != 0);69    const relative = try repo.work.resolvedPathAlloc(allocator, root, path);70    defer allocator.free(relative);71    const absolute = try std.fs.path.join(allocator, &.{ root, relative });72    defer allocator.free(absolute);73    const real = try std.Io.Dir.cwd().realPathFileAlloc(io, absolute, allocator);74    errdefer allocator.free(real);75    const checked = try repo.work.resolvedPathAlloc(allocator, root, real);76    allocator.free(checked);77    return real;78}