✓
Passing This code compiles and runs correctly.
Code
~import app/db
~app/db:open(connstr: "postgres://localhost/test")
| connected c |> app/db:tx.begin(conn: c)
| tx t |> app/db:tx.exec(tx: t, sql: "INSERT INTO users VALUES (1)")
| ok _ |> _
| connection-failed |> _
Must contain:
active!Error Verification
Actual Compiler Output
error[KORU030]: Resource '_auto_0' <active!> was not discharged. Call one of: tx.rollback, tx.commit
--> auto_discharge:4:0
❌ Compiler coordination error: Auto-discharge failed (multiple disposal options or no disposal event)
error: CompilerCoordinationFailed
/Users/larsde/src/koru/tests/regression/300_ADVANCED_FEATURES/336_OBLIGATION_MATRIX/336_005_transaction_active_nonvoid_only/backend.zig:94:13: 0x1053423b3 in emit (backend)
return error.CompilerCoordinationFailed;
^
/Users/larsde/src/koru/tests/regression/300_ADVANCED_FEATURES/336_OBLIGATION_MATRIX/336_005_transaction_active_nonvoid_only/backend.zig:190:28: 0x10534309f in main (backend)
const generated_code = try RuntimeEmitter.emit(compile_allocator, final_ast);
^Imported Files
// open/tx lifecycle API — ground truth for korulang.org phantom explorer
const std = @import("std");
const Connection = struct { handle: i32 };
const Transaction = struct { conn_handle: i32 };
~pub event open { connstr: []const u8 }
| connected *Connection<connected!>
| connection-failed
~proc open|zig {
_ = connstr;
const c = std.heap.page_allocator.create(Connection) catch unreachable;
c.* = Connection{ .handle = 42 };
return .{ .connected = c };
}
~pub event tx.begin { conn: *Connection<!connected|!active> }
| tx *Transaction<started!>
~proc tx.begin|zig {
const t = std.heap.page_allocator.create(Transaction) catch unreachable;
t.* = Transaction{ .conn_handle = conn.handle };
return .{ .tx = t };
}
~pub event tx.exec { tx: *Transaction<!started|!active>, sql: []const u8 }
| ok *Transaction<active!>
~proc tx.exec|zig {
std.debug.print("Executing: {s}\n", .{sql});
return .{ .ok = tx };
}
~pub event tx.commit { tx: *Transaction<!active> }
| committed *Connection<active!>
~proc tx.commit|zig {
std.debug.print("COMMIT\n", .{});
const c = std.heap.page_allocator.create(Connection) catch unreachable;
c.* = Connection{ .handle = tx.conn_handle };
std.heap.page_allocator.destroy(tx);
return .{ .committed = c };
}
~pub event tx.rollback { tx: *Transaction<!active> }
| rolled-back *Connection<active!>
~proc tx.rollback|zig {
std.debug.print("ROLLBACK\n", .{});
const c = std.heap.page_allocator.create(Connection) catch unreachable;
c.* = Connection{ .handle = tx.conn_handle };
std.heap.page_allocator.destroy(tx);
return .{ .rolled_back = c };
}
~[!]pub event close { conn: *Connection<!active> }
~proc close|zig {
std.debug.print("Connection closed\n", .{});
std.heap.page_allocator.destroy(conn);
}
Test Configuration
MUST_FAIL