tiny.machine.fabric.transition

1pub const Admission = struct {2    node: fabric.NodeId,3    record: AdmissionRecord,4    effect: AdmissionEffect,5    fault_value: ?Fault,6};

1pub const AdmissionEffect = union(enum) {2    direct,3    packet_send: PacketSend,4    packet_delivery: u64,5};

1pub const AdmissionRecord = union(enum) {2    terminal: Terminal,3    virtual_time: VirtualTime,4    entropy: Entropy,5    effect_result: EffectResult,6};

1pub const Fault = struct {2    kind: fault.Kind,3    choice: fault.Choice,4    primary: u64 = 0,5    secondary: u64 = 0,6};

1pub const Settlement = struct {2    node: fabric.NodeId,3};

1pub const Value = union(enum) {2    admission: Admission,3    settlement: Settlement,4    fault: Fault,5};

1pub const View = struct {2    previous: fabric.Root,3    result: fabric.Root,4    sequence: u64,5    value: Value,6};

1pub fn encodeDisjoint(2    before: *const fabric.Fabric,3    value: *const fabric.Transition,4    writer: *std.Io.Writer,5) Error!void {6    try validateSink(before, value, writer);7    var bytes: [stream_bytes]u8 = undefined;8    try encode.transition(before, value, &bytes);9    try writer.writeAll(&bytes);10}

1pub fn replayDisjoint(2    owner: *fabric.Fabric,3    reader: *std.Io.Reader,4    expected_root: fabric.Root,5) Error!fabric.Transition {6    try validateSource(owner, reader);7    var bytes: [stream_bytes]u8 = undefined;8    try readExact(reader, &bytes);9    var trailing: [1]u8 = undefined;10    if (try reader.readSliceShort(&trailing) != 0) return error.TrailingData;11    const decoded = try decode.transition(&bytes, owner, expected_root);12    owner.* = decoded.owner;13    std.debug.assert(std.meta.eql(owner.root(), expected_root));14    return decoded.value;15}

1pub fn inspect(2    input: *const [schema.stream_bytes]u8,3) transition_types.Error!View {4    try decode.validateEnvelope(input);5    const kind = input[schema.Header.kind_offset];6    try decode.validateReserved(input, kind);7    return .{8        .previous = try decode.decodeRoot(input, schema.Header.previous_offset),9        .result = try decode.decodeRoot(input, schema.Header.result_offset),10        .sequence = decode.get64(input, schema.Header.sequence_offset),11        .value = switch (kind) {12            1 => .{ .admission = try inspectAdmission(input) },13            2 => .{ .settlement = inspectSettlement(input) },14            3 => .{ .fault = try inspectFault(15                input,16                schema.Header.limit + schema.Fault.effect_offset,17                schema.Header.limit + schema.Fault.decision_offset,18            ) },19            else => return error.UnknownTransitionField,20        },21    };22}

1pub const stream_bytes: usize = 1024;

1pub const Error = TransitionError ||2    fabric.Error ||3    std.Io.Reader.ShortError ||4    std.Io.Writer.Error;

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

1const codec = @import("codec.zig");2const inspect_owner = @import("inspect.zig");34pub const Error = codec.Error;5pub const AdmissionEffectView = inspect_owner.AdmissionEffect;6pub const AdmissionRecordView = inspect_owner.AdmissionRecord;7pub const AdmissionView = inspect_owner.Admission;8pub const FaultView = inspect_owner.Fault;9pub const InspectView = inspect_owner.View;10pub const SettlementView = inspect_owner.Settlement;11pub const ValueView = inspect_owner.Value;12pub const Wire = [codec.stream_bytes]u8;13pub const encodeDisjoint = codec.encodeDisjoint;14pub const inspect = inspect_owner.inspect;15pub const replayDisjoint = codec.replayDisjoint;16pub const stream_bytes = codec.stream_bytes;