tiny.smg.command.batch

1const std = @import("std");23const smg = @import("../root.zig");4const batch = smg.batch;5const cli_options = smg.cli.options;6const cli_output = smg.cli.output;7const cli_session = smg.command.session;89pub fn run(10    allocator: std.mem.Allocator,11    phases: std.mem.Allocator,12    args: []const []const u8,13    limits: smg.Limits,14) !u8 {15    const root = try smg.storage.requireRoot(allocator);16    var storage = try smg.BatchInputStorage.init(phases, limits.batch_input);17    defer storage.deinit(phases);18    storage.activate();19    var stdin_buffer: [8192]u8 = undefined;20    var reader = std.Io.File.stdin().reader(std.Options.debug_io, &stdin_buffer);21    const input = storage.read(&reader.interface) catch |err| switch (err) {22        error.ReadFailed => return reader.err.?,23        error.BatchInputCapacityExceeded => return error.StreamTooLong,24        else => |other| return other,25    };26    defer storage.release();27    const loaded = try cli_session.loadMutationAt(allocator, phases, root, limits);28    var graph = loaded.graph;29    const result = try batch.process(allocator, &graph, input);30    try smg.storage.graph.publish(phases, loaded.root, graph, loaded.head, limits);31    if (std.mem.eql(u8, cli_options.flagValue(args, "--format") orelse "", "json")) return try cli_output.writeOut(try batch.renderJson(allocator, result));32    return try cli_output.writeOut(try batch.renderText(allocator, result));33}

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