✓
Passing This code compiles and runs correctly.
Code
// Pins: a destructure arm inside an interpreted flow — `| missing { v }` —
// is refused at the flow's own parse, because the interpreter's eval binds
// only `| <branch> name`. Before the refusal the `{` tokenized as a literal
// binding and the field names (with any `[row]`-style annotation) dropped
// silently — a binder that bound nothing. Turn 1 is the control: a plain
// `| <branch> name` arm binds and runs.
import std/io
import std/bridge
import std/runtime
tor risky { }
| ok string
| missing string
proc risky|zig {
return .{ .missing = "gone" };
}
tor echo { text: string }
proc echo|zig {
@import("std").debug.print("echo: {s}\n", .{text});
}
std/runtime:register(scope: "api") {
risky(1)
echo(1)
}
// Turn 1 (control): the name-binding arm runs.
tor turn1 { br: *std/bridge:Bridge<session> }
turn1 = std/bridge:run(br, source: "risky()\n| missing v |> echo(text: v)")
| result r |> std/io:print.ln("t1 result")
| residue _ |> std/io:print.ln("FAIL: residue outcome")
| error runerr |> std/bridge:error-decode(e: runerr)
| parse-error p |> std/io:print.ln("FAIL t1 parse {{ p.message:s }}")
| validation-error v |> std/io:print.ln("FAIL t1 invalid {{ v:s }}")
| dispatch-error e |> std/io:print.ln("FAIL t1 dispatch {{ e.message:s }}")
| exhausted _ |> std/io:print.ln("FAIL t1 exhausted")
| shape-error sh |> std/io:print.ln("FAIL t1 shape {{ sh.message:s }}")
| event-denied ev |> std/io:print.ln("FAIL t1 denied {{ ev:s }}")
| scope-not-found s2 |> std/io:print.ln("FAIL t1 noscope {{ s2:s }}")
| unhandled-branch ub |> std/io:print.ln("FAIL t1 unhandled {{ ub.branch:s }}")
| defined d |> std/io:print.ln("FAIL t1 defined {{ d:s }}")
| partial p |> std/io:print.ln("FAIL t1 partial {{ p.report:s }}")
// Turn 2: a destructure arm refuses at the flow's own parse — annotated
// fields included — instead of silently binding a literal `{`.
tor turn2 { br: *std/bridge:Bridge<session> }
turn2 = std/bridge:run(br, source: "risky()\n| missing { [row]v } |> echo(text: v)")
| result r |> std/io:print.ln("FAIL t2 result")
| residue _ |> std/io:print.ln("FAIL: residue outcome")
| error runerr |> std/bridge:error-decode(e: runerr)
| parse-error p |> std/io:print.ln("t2 refused {{ p.message:s }}")
| validation-error v |> std/io:print.ln("t2 refused-invalid {{ v:s }}")
| dispatch-error e |> std/io:print.ln("FAIL t2 dispatch {{ e.message:s }}")
| exhausted _ |> std/io:print.ln("FAIL t2 exhausted")
| shape-error sh |> std/io:print.ln("FAIL t2 shape {{ sh.message:s }}")
| event-denied ev |> std/io:print.ln("FAIL t2 denied {{ ev:s }}")
| scope-not-found s2 |> std/io:print.ln("FAIL t2 noscope {{ s2:s }}")
| unhandled-branch ub |> std/io:print.ln("FAIL t2 unhandled {{ ub.branch:s }}")
| defined d |> std/io:print.ln("FAIL t2 defined {{ d:s }}")
| partial p |> std/io:print.ln("FAIL t2 partial {{ p.report:s }}")
[with]std/bridge:create(id: "d", scope: "api"): br
|> turn1(br)
|> turn2(br)
Supporting Files
NoCsProcBody
Actual · Zig
✓ passecho: gone
t1 result
t2 refused destructure `| <branch> { … }` is not implemented in an interpreted flow — bind the payload by name (`| <branch> name |>`)
Actual · JavaScript
✗ error[KORU047]Actual · C#
✗ NoCsProcBodyExpected output
✓ Zig✗ JavaScript✗ C#echo: gone
t1 result
t2 refused destructure `| <branch> { … }` is not implemented in an interpreted flow — bind the payload by name (`| <branch> name |>`)
Emitted Zig source
// Access compiler flags via the per-user compiler_env module
const CompilerEnv = @import("compiler_env").CompilerEnv;
pub const panic = if (@import("builtin").mode == .Debug)
@import("std").debug.FullPanic(@import("std").debug.defaultPanic)
else
@import("std").debug.simple_panic;
const __koru_bare = struct {
extern fn posix_memalign(memptr: *?*anyopaque, alignment: usize, size: usize) c_int;
extern fn free(ptr: ?*anyopaque) void;
fn bareAlloc(_: *anyopaque, len: usize, alignment: @import("std").mem.Alignment, _: usize) ?[*]u8 {
var p: ?*anyopaque = null;
const a = @max(alignment.toByteUnits(), @sizeOf(usize));
if (posix_memalign(&p, a, len) != 0) return null;
return @ptrCast(p);
}
fn bareResize(_: *anyopaque, _: []u8, _: @import("std").mem.Alignment, _: usize, _: usize) bool { return false; }
fn bareRemap(_: *anyopaque, _: []u8, _: @import("std").mem.Alignment, _: usize, _: usize) ?[*]u8 { return null; }
fn bareFree(_: *anyopaque, memory: []u8, _: @import("std").mem.Alignment, _: usize) void { free(@ptrCast(memory.ptr)); }
const vtable = @import("std").mem.Allocator.VTable{ .alloc = bareAlloc, .resize = bareResize, .remap = bareRemap, .free = bareFree };
const allocator = @import("std").mem.Allocator{ .ptr = undefined, .vtable = &vtable };
};
const __koru_backing = if (@import("builtin").link_libc) @import("std").heap.c_allocator else if (@import("builtin").os.tag == .freestanding and !@import("builtin").cpu.arch.isWasm()) __koru_bare.allocator else @import("std").heap.page_allocator;
var __koru_leak_count: @import("std").atomic.Value(usize) = .init(0);
fn __koru_alloc(ctx: *anyopaque, len: usize, alignment: @import("std").mem.Alignment, ret_addr: usize) ?[*]u8 {
_ = ctx;
const r = __koru_backing.rawAlloc(len, alignment, ret_addr);
if (comptime @import("builtin").mode == .Debug) {
if (r != null) _ = __koru_leak_count.fetchAdd(1, .monotonic);
}
return r;
}
fn __koru_resize(ctx: *anyopaque, memory: []u8, alignment: @import("std").mem.Alignment, new_len: usize, ret_addr: usize) bool {
_ = ctx;
return __koru_backing.rawResize(memory, alignment, new_len, ret_addr);
}
fn __koru_remap(ctx: *anyopaque, memory: []u8, alignment: @import("std").mem.Alignment, new_len: usize, ret_addr: usize) ?[*]u8 {
_ = ctx;
return __koru_backing.rawRemap(memory, alignment, new_len, ret_addr);
}
fn __koru_free(ctx: *anyopaque, memory: []u8, alignment: @import("std").mem.Alignment, ret_addr: usize) void {
_ = ctx;
__koru_backing.rawFree(memory, alignment, ret_addr);
if (comptime @import("builtin").mode == .Debug) {
_ = __koru_leak_count.fetchSub(1, .monotonic);
}
}
const __koru_vtable = @import("std").mem.Allocator.VTable{ .alloc = __koru_alloc, .resize = __koru_resize, .remap = __koru_remap, .free = __koru_free };
pub fn koru_allocator() @import("std").mem.Allocator {
return .{ .ptr = undefined, .vtable = &__koru_vtable };
}
pub inline fn __koru_intcast(comptime T: type, x: anytype) T {
if (comptime (@import("builtin").mode == .Debug or @import("builtin").mode == .ReleaseSafe))
return @as(T, @intCast(x));
const dst = @typeInfo(T);
const src = @typeInfo(@TypeOf(x));
if (comptime (dst == .int and src == .int and dst.int.bits == src.int.bits and dst.int.signedness != src.int.signedness))
return @as(T, @bitCast(x));
return @as(T, @intCast(x));
}
pub fn koru_leak_check() void {
if (comptime @import("builtin").mode != .Debug) return;
if (__koru_leak_count.load(.acquire) == 0) return;
if (comptime @import("builtin").target.os.tag == .freestanding) {
if (comptime @import("builtin").cpu.arch == .wasm32 or @import("builtin").cpu.arch == .wasm64) {
@panic("KORU LEAK CHECK FAILED: the produced program leaked");
} else {
const __klc = struct { extern var stdout: ?*anyopaque; extern fn fputs(__s: [*:0]const u8, __st: ?*anyopaque) c_int; };
var __lb: [128]u8 = undefined;
const __lm = "KORU LEAK CHECK FAILED: allocations still outstanding at end of run: ";
@memcpy(__lb[0..__lm.len], __lm);
var __ln: usize = __lm.len;
var __lv = __koru_leak_count.load(.acquire);
var __ld: [20]u8 = undefined;
var __lk: usize = 0;
while (__lv > 0) : (__lk += 1) { __ld[__lk] = @intCast('0' + __lv % 10); __lv /= 10; }
for (0..__lk) |__li| { __lb[__ln] = __ld[__lk - 1 - __li]; __ln += 1; }
__lb[__ln] = '\n'; __ln += 1; __lb[__ln] = 0;
_ = __klc.fputs(@as([*:0]const u8, @ptrCast(&__lb)), __klc.stdout);
@trap();
}
} else {
@import("std").debug.print("KORU LEAK CHECK FAILED: the produced program leaked (trace above)\n", .{});
@import("std").process.exit(1);
}
}
pub const main_module = struct {
pub const risky_event = struct {
pub const Input = struct {
};
pub const Output = union(enum(u8)) {
ok: []const u8,
missing: []const u8,
};
pub fn handler(__koru_event_input: @This().Input) @This().Output {
// >>> PROC: risky [tests/regression/400_RUNTIME_FEATURES/440_RESOURCE_BRIDGE/440_028_interpreted_arm_destructure_refused/input.k:15]
_ = &__koru_event_input;
return .{ .missing = "gone" };
}
};
pub const echo_event = struct {
pub const Input = struct {
text: []const u8,
};
pub const Output = void;
pub fn handler(__koru_event_input: @This().Input) @This().Output {
// >>> PROC: echo [tests/regression/400_RUNTIME_FEATURES/440_RESOURCE_BRIDGE/440_028_interpreted_arm_destructure_refused/input.k:20]
const text = __koru_event_input.text;
_ = &text;
_ = &__koru_event_input;
@import("std").debug.print("echo: {s}\n", .{text});
}
};
// __KORU_RUNTIME_REGISTRY_HELPERS__
const __koru_dispatcher_std = @import("std");
const __koru_dispatcher_ast = @import("ast");
pub const Path = __koru_dispatcher_ast.DottedPath;
pub const Arg = __koru_dispatcher_ast.Arg;
pub const Invocation = __koru_dispatcher_ast.Invocation;
pub const DispatchResult = koru_std.koru_runtime.DispatchResult;
const __koru_ScopeEvent = koru_std.koru_runtime.ScopeEvent;
const __koru_ScopeDescriptor = koru_std.koru_runtime.ScopeDescriptor;
const __koru_ScopeManifest = koru_std.koru_runtime.ScopeManifest;
const __koru_ManifestEvent = koru_std.koru_runtime.ManifestEvent;
const __koru_ManifestArg = koru_std.koru_runtime.ManifestArg;
const __koru_ManifestCreate = koru_std.koru_runtime.ManifestCreate;
const __koru_ManifestDischarge = koru_std.koru_runtime.ManifestDischarge;
const __koru_ManifestBranch = koru_std.koru_runtime.ManifestBranch;
const __koru_ManifestBranchField = koru_std.koru_runtime.ManifestBranchField;
const __koru_FieldValue = koru_std.koru_runtime.FieldValue;
const __koru_NamedField = koru_std.koru_runtime.NamedField;
fn __koru_getArg(__koru_args: []const __koru_dispatcher_ast.Arg, __koru_n: []const u8) ?[]const u8 {
for (__koru_args) |__koru_arg| {
if (__koru_dispatcher_std.mem.eql(u8, __koru_arg.name, __koru_n)) {
var __koru_v = __koru_arg.value;
if (__koru_v.len >= 2 and __koru_v[0] == '"' and __koru_v[__koru_v.len-1] == '"') __koru_v = __koru_v[1..__koru_v.len-1];
return __koru_v;
}
}
return null;
}
fn __koru_buildInput(comptime __koru_T: type, __koru_args: []const __koru_dispatcher_ast.Arg) !__koru_T {
var __koru_input: __koru_T = undefined;
inline for (__koru_dispatcher_std.meta.fields(__koru_T)) |__koru_field| {
const __koru_raw = __koru_getArg(__koru_args, __koru_field.name) orelse "";
const __koru_F = __koru_field.type;
if (__koru_F == bool) {
@field(__koru_input, __koru_field.name) = __koru_dispatcher_std.mem.eql(u8, __koru_raw, "true") or __koru_dispatcher_std.mem.eql(u8, __koru_raw, "1");
} else switch (@typeInfo(__koru_F)) {
.int => {
@field(__koru_input, __koru_field.name) = __koru_dispatcher_std.fmt.parseInt(__koru_F, __koru_raw, 10) catch {
koru_std.koru_interpreter.setDispatchDetail(__koru_dispatcher_std.fmt.allocPrint(__koru_dispatcher_std.heap.page_allocator, "field '{s}' expected " ++ @typeName(__koru_F) ++ ", got '{s}'", .{ __koru_field.name, __koru_raw }) catch @panic("dispatch: OOM"));
return error.InvalidArgument;
};
},
.float => {
@field(__koru_input, __koru_field.name) = __koru_dispatcher_std.fmt.parseFloat(__koru_F, __koru_raw) catch {
koru_std.koru_interpreter.setDispatchDetail(__koru_dispatcher_std.fmt.allocPrint(__koru_dispatcher_std.heap.page_allocator, "field '{s}' expected " ++ @typeName(__koru_F) ++ ", got '{s}'", .{ __koru_field.name, __koru_raw }) catch @panic("dispatch: OOM"));
return error.InvalidArgument;
};
},
.pointer => |__koru_ptr_info| {
if (__koru_ptr_info.size == .slice and __koru_ptr_info.child == u8) {
@field(__koru_input, __koru_field.name) = __koru_raw;
} else {
@field(__koru_input, __koru_field.name) = koru_std.koru_interpreter.resolveDispatchResource(__koru_F, __koru_raw) orelse {
koru_std.koru_interpreter.setDispatchDetail(__koru_dispatcher_std.fmt.allocPrint(__koru_dispatcher_std.heap.page_allocator, "field '{s}' names a resource token this pool does not hold — got '{s}'", .{ __koru_field.name, __koru_raw }) catch @panic("dispatch: OOM"));
return error.InvalidArgument;
};
}
},
else => {
@field(__koru_input, __koru_field.name) = __koru_dispatcher_std.mem.zeroes(__koru_F);
},
}
}
return __koru_input;
}
fn __koru_own(comptime __koru_T: type, __koru_s: []const __koru_T) []const __koru_T {
const __koru_a = __koru_dispatcher_std.heap.page_allocator;
if (__koru_T == u8) return __koru_a.dupe(u8, __koru_s) catch @panic("dispatch: OOM owning result");
const __koru_out = __koru_a.alloc(__koru_T, __koru_s.len) catch @panic("dispatch: OOM owning result");
for (__koru_s, 0..) |__koru_e, __koru_i| __koru_out[__koru_i] = __koru_a.dupe(u8, __koru_e) catch @panic("dispatch: OOM owning result");
return __koru_out;
}
fn dispatch_api_risky(__koru_inv: *const __koru_dispatcher_ast.Invocation, __koru_out: *koru_std.koru_runtime.DispatchResult) !void {
const __koru_Input = main_module.risky_event.Input;
const __koru_Handler = main_module.risky_event;
const __koru_ReturnType = @typeInfo(@TypeOf(__koru_Handler.handler)).@"fn".return_type.?;
if (__koru_ReturnType == void) {
// Void event - just call and return empty __koru_branch
__koru_Handler.handler(try __koru_buildInput(__koru_Input, __koru_inv.args));
__koru_out.* = .{ .branch = "", .fields = &.{} };
return;
}
if (@typeInfo(__koru_ReturnType) != .@"union") {
// Single-return tor (`-> __koru_T`): the value BINDS, it does not select a
// __koru_branch. Reported as the empty __koru_branch with the value on __type_ref,
// the same channel identity branches use for bare payloads.
const __koru_v = __koru_Handler.handler(try __koru_buildInput(__koru_Input, __koru_inv.args));
const __koru_V = @TypeOf(__koru_v);
const __koru_SR = struct { threadlocal var buf: [1]__koru_NamedField = undefined; };
var __koru_n: usize = 0;
if (__koru_V == bool) {
__koru_SR.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .bool_val = __koru_v } };
__koru_n = 1;
} else if (@typeInfo(__koru_V) == .int) {
__koru_SR.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .int_val = @as(i64, @intCast(__koru_v)) } };
__koru_n = 1;
} else if (@typeInfo(__koru_V) == .float) {
__koru_SR.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .float_val = @as(f64, @floatCast(__koru_v)) } };
__koru_n = 1;
} else if (@typeInfo(__koru_V) == .pointer) {
const __koru_ptr_info = @typeInfo(__koru_V).pointer;
if (__koru_ptr_info.size == .slice and __koru_ptr_info.child == u8) {
__koru_SR.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .string_val = __koru_own(u8, __koru_v) } };
__koru_n = 1;
} else if (__koru_ptr_info.size == .slice and __koru_ptr_info.child == []const u8) {
__koru_SR.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .string_array = __koru_own([]const u8, __koru_v) } };
__koru_n = 1;
} else {
__koru_SR.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .string_val = koru_std.koru_interpreter.registerDispatchResource(@typeName(__koru_ptr_info.child), __koru_v) } };
__koru_n = 1;
}
}
__koru_out.* = .{ .branch = "", .fields = __koru_SR.buf[0..__koru_n] };
return;
}
// Branched event - extract __koru_branch and fields
const __koru_r = __koru_Handler.handler(try __koru_buildInput(__koru_Input, __koru_inv.args));
const __koru_S = struct { threadlocal var buf: [16]__koru_NamedField = undefined; };
const __koru_branch = @tagName(__koru_r);
const __koru_field_count = switch (__koru_r) { inline else => |__koru_p| blk: {
const __koru_P = @TypeOf(__koru_p);
// Identity branches have bare types, not structs
if (@typeInfo(__koru_P) != .@"struct") {
// Identity __koru_branch - create synthetic __type_ref __koru_field
if (__koru_P == bool) {
__koru_S.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .bool_val = __koru_p } };
} else if (@typeInfo(__koru_P) == .int) {
__koru_S.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .int_val = @as(i64, @intCast(__koru_p)) } };
} else if (@typeInfo(__koru_P) == .float) {
__koru_S.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .float_val = @as(f64, @floatCast(__koru_p)) } };
} else if (@typeInfo(__koru_P) == .pointer) {
const __koru_ptr_info = @typeInfo(__koru_P).pointer;
if (__koru_ptr_info.size == .slice and __koru_ptr_info.child == u8) {
__koru_S.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .string_val = __koru_own(u8, __koru_p) } };
} else if (__koru_ptr_info.size == .slice and __koru_ptr_info.child == []const u8) {
__koru_S.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .string_array = __koru_own([]const u8, __koru_p) } };
} else {
__koru_S.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .string_val = koru_std.koru_interpreter.registerDispatchResource(@typeName(__koru_ptr_info.child), __koru_p) } };
}
} else {
break :blk @as(usize, 0);
}
break :blk @as(usize, 1);
}
// Compound __koru_branch - iterate over struct fields
const __koru_payload_fields = __koru_dispatcher_std.meta.fields(__koru_P);
comptime var __koru_count: usize = 0;
inline for (__koru_payload_fields) |__koru_field| {
const __koru_T = __koru_field.type;
if (__koru_T == bool) {
__koru_S.buf[__koru_count] = .{ .name = __koru_field.name, .value = __koru_FieldValue{ .bool_val = @field(__koru_p, __koru_field.name) } };
__koru_count += 1;
} else switch (@typeInfo(__koru_T)) {
.int => {
__koru_S.buf[__koru_count] = .{ .name = __koru_field.name, .value = __koru_FieldValue{ .int_val = @as(i64, @intCast(@field(__koru_p, __koru_field.name))) } };
__koru_count += 1;
},
.float => {
__koru_S.buf[__koru_count] = .{ .name = __koru_field.name, .value = __koru_FieldValue{ .float_val = @as(f64, @floatCast(@field(__koru_p, __koru_field.name))) } };
__koru_count += 1;
},
.pointer => |__koru_ptr_info| {
if (__koru_ptr_info.size == .slice and __koru_ptr_info.child == u8) {
__koru_S.buf[__koru_count] = .{ .name = __koru_field.name, .value = __koru_FieldValue{ .string_val = __koru_own(u8, @field(__koru_p, __koru_field.name)) } };
__koru_count += 1;
} else if (__koru_ptr_info.size == .slice and __koru_ptr_info.child == []const u8) {
__koru_S.buf[__koru_count] = .{ .name = __koru_field.name, .value = __koru_FieldValue{ .string_array = __koru_own([]const u8, @field(__koru_p, __koru_field.name)) } };
__koru_count += 1;
} else if (__koru_ptr_info.size == .one) {
__koru_S.buf[__koru_count] = .{ .name = __koru_field.name, .value = __koru_FieldValue{ .string_val = koru_std.koru_interpreter.registerDispatchResource(@typeName(__koru_ptr_info.child), @field(__koru_p, __koru_field.name)) } };
__koru_count += 1;
}
},
else => {},
}
}
break :blk __koru_count;
}};
__koru_out.* = .{ .branch = __koru_branch, .fields = __koru_S.buf[0..__koru_field_count] };
return;
}
fn dispatch_api_echo(__koru_inv: *const __koru_dispatcher_ast.Invocation, __koru_out: *koru_std.koru_runtime.DispatchResult) !void {
const __koru_Input = main_module.echo_event.Input;
const __koru_Handler = main_module.echo_event;
const __koru_ReturnType = @typeInfo(@TypeOf(__koru_Handler.handler)).@"fn".return_type.?;
if (__koru_ReturnType == void) {
// Void event - just call and return empty __koru_branch
__koru_Handler.handler(try __koru_buildInput(__koru_Input, __koru_inv.args));
__koru_out.* = .{ .branch = "", .fields = &.{} };
return;
}
if (@typeInfo(__koru_ReturnType) != .@"union") {
// Single-return tor (`-> __koru_T`): the value BINDS, it does not select a
// __koru_branch. Reported as the empty __koru_branch with the value on __type_ref,
// the same channel identity branches use for bare payloads.
const __koru_v = __koru_Handler.handler(try __koru_buildInput(__koru_Input, __koru_inv.args));
const __koru_V = @TypeOf(__koru_v);
const __koru_SR = struct { threadlocal var buf: [1]__koru_NamedField = undefined; };
var __koru_n: usize = 0;
if (__koru_V == bool) {
__koru_SR.buf[0] = .{ .name = "__type_ref", .value = __koru_FieldValue{ .boo
... [truncated - 421KB total]Flows
flow ~register click a branch to expand · @labels scroll to their anchor
register (scope: "api", source: risky(1)
echo(1))
subflow ~turn1 click a branch to expand · @labels scroll to their anchor
run (br, source: "risky()\n| missing v |> echo(text: v)")
subflow ~turn2 click a branch to expand · @labels scroll to their anchor
run (br, source: "risky()\n| missing { [row]v } |> echo(text: v)")
flow ~create click a branch to expand · @labels scroll to their anchor
create (id: "d", scope: "api")
Test Configuration
MUST_RUN JS_REFUSES LANGUAGES: zig js cs
JS must refuse with:
error[KORU047]