tiny.smg.batch

1pub const Entry = struct {2    line: usize,3    kind: EntryKind,4    name: ?[]const u8 = null,5    source: ?[]const u8 = null,6    target: ?[]const u8 = null,7    message: ?[]const u8 = null,8};

1pub const EntryKind = enum {2    add,3    link,4    rm,5    unlink,6    update,7    err,8};

1pub const Result = struct {2    ok: usize = 0,3    errors: usize = 0,4    ops: []const Entry = &.{},5};

1pub fn process(allocator: std.mem.Allocator, graph: *graph_mod.Graph, jsonl: []const u8) !Result {2    try graph_mod.buildSuffixIndex(graph);3    var entries: std.ArrayList(Entry) = .empty;4    var result = Result{};5    const state = State{6        .allocator = allocator,7        .graph = graph,8        .entries = &entries,9        .result = &result,10    };11    var lines = std.mem.splitScalar(u8, jsonl, '\n');12    var line_no: usize = 0;13    while (lines.next()) |line_raw| {14        line_no += 1;15        const line = text.trim(line_raw);16        if (line.len == 0) continue;17        const parsed = std.json.parseFromSlice(18            std.json.Value,19            allocator,20            line,21            .{},22        ) catch |err| {23            try appendError(state, line_no, try batch_json.decodeError(allocator, line, err));24            continue;25        };26        const object = switch (parsed.value) {27            .object => |object| object,28            else => {29                try appendError(state, line_no, "unknown op: null");30                continue;31            },32        };33        try processObject(state, line_no, object);34    }35    result.ops = try entries.toOwnedSlice(allocator);36    return result;37}

1pub fn renderJson(allocator: std.mem.Allocator, result: Result) ![]const u8 {2    var out: std.Io.Writer.Allocating = .init(allocator);3    var writer = pretty_json.Writer.init(&out.writer, .minified);4    try writer.beginObject();5    try writer.objectField("ok");6    try writer.write(result.ok);7    try writer.objectField("errors");8    try writer.write(result.errors);9    try writer.objectField("ops");10    try writer.beginArray();11    for (result.ops) |entry| {12        try writer.beginObject();13        try writer.objectField("line");14        try writer.write(entry.line);15        if (entry.kind == .err) {16            try writer.objectField("error");17            try writer.write(entry.message orelse "");18        } else {19            try writer.objectField("op");20            try writer.write(opName(entry.kind));21            if (entry.name) |name| {22                try writer.objectField("name");23                try writer.write(name);24            }25            if (entry.source) |source| {26                try writer.objectField("source");27                try writer.write(source);28            }29            if (entry.target) |target| {30                try writer.objectField("target");31                try writer.write(target);32            }33        }34        try writer.endObject();35    }36    try writer.endArray();37    try writer.endObject();38    try out.writer.writeByte('\n');39    return try out.toOwnedSlice();40}

1pub fn renderText(allocator: std.mem.Allocator, result: Result) ![]const u8 {2    var out: std.Io.Writer.Allocating = .init(allocator);3    try out.writer.print("Batch complete: {d} ok, {d} errors\n", .{ result.ok, result.errors });4    for (result.ops) |entry| {5        if (entry.kind == .err) try out.writer.print("  line {d}: {s}\n", .{ entry.line, entry.message orelse "" });6    }7    return try out.toOwnedSlice();8}

1const batch_model = @import("model.zig");2pub const input = @import("input/root.zig");3const mutation = @import("mutation.zig");4const output = @import("output.zig");56pub const EntryKind = batch_model.EntryKind;7pub const Entry = batch_model.Entry;8pub const Result = batch_model.Result;9pub const InputCapacity = input.Capacity;10pub const InputExhaustion = input.Exhaustion;11pub const InputLimits = input.Limits;12pub const InputStatus = input.Status;13pub const InputStorage = input.Storage;14pub const default_input_limits = input.default_limits;15pub const process = mutation.process;16pub const renderJson = output.renderJson;17pub const renderText = output.renderText;

1pub const batch = @import("batch/root.zig");