simple server flow

// ============================================================================
// VERIFIED REGRESSION TEST - DO NOT MODIFY WITHOUT DISCUSSION
// ============================================================================
// Test 208: Simple server-style flow with nested labels
// A simplified synthetic example inspired by tcp-echo for flow visualization
// ============================================================================

const std = @import("std");

// Server events
~tor listen { port: u16 }
| ready u32
| failed string

~proc listen|zig {
    std.debug.print("Listening on port {}\n", .{port});
    if (port == 0) {
        return .{ .failed = "Invalid port" };
    }
    return .{ .ready = port };
}

~tor accept { server: u32 }
| connected { conn: u32, server: u32 }
| failed u32

~proc accept|zig {
    std.debug.print("Accepting connection\n", .{});
    if (server == 9999) {
        return .{ .failed = server };
    }
    return .{ .connected = .{ .conn = server + 1, .server = server } };
}

~tor process { conn: u32 }
| done u32
| retry u32
| error { conn: u32, msg: string }

~proc process|zig {
    std.debug.print("Processing connection {}\n", .{conn});
    if (conn % 3 == 0) {
        return .{ .error = .{ .conn = conn, .msg = "Processing error" } };
    }
    if (conn % 2 == 0) {
        return .{ .done = conn };
    }
    return .{ .retry = conn };
}

~tor close { conn: u32 }

~proc close|zig {
    std.debug.print("Closed connection {}\n", .{conn});
}

~tor log-error { conn: u32, msg: string } -> u32

~proc log-error|zig {
    std.debug.print("Error on connection {}: {s}\n", .{conn, msg});
    return conn;
}

~tor cleanup { conn: u32 }

~proc cleanup|zig {
    std.debug.print("Cleaning up connection {}\n", .{conn});
}

// Main flow with nested labels
~listen(port: 8080)
| ready s |> #accept_loop accept(server: s)
    | connected c |> #process_loop process(c.conn)
        | done d |> close(conn: d) |> @accept_loop(c.server)
        | retry r |> @process_loop(conn: r)
        | error e |> log-error(e.conn, e.msg): l |> cleanup(conn: l) |> @accept_loop(c.server)
    | failed f |> @accept_loop(server: f)
| failed _ |> _