✗
Failing This test is currently failing.
Failed: frontend
Failure Output
Showing last 10 of 11 lines
--> /Users/larsde/src/koru/tests/regression/300_ADVANCED_FEATURES/335_OBLIGATION_STRESS/335_006_err_branch_leaks_opened_resource/db.kz:20:1
|
20 | ~pub event connect { url: []const u8 }
| ^
error[PARSE003]: single continuation branch 'started' carrying a payload is a one-variant tag union — declare the single output as a bare return instead: `-> <type>`
--> /Users/larsde/src/koru/tests/regression/300_ADVANCED_FEATURES/335_OBLIGATION_STRESS/335_006_err_branch_leaks_opened_resource/db.kz:34:1
|
34 | ~pub event query { conn: *Connection<connected>, sql: []const u8 }
| ^Code
// PIN: connection leaked when query returns | err.
// connect() opens a connection with connected! obligation.
// query()'s | err branch exits without calling disconnect() — the
// connection is dropped without being discharged.
//
// The legal form (both paths discharge) is 330_027_db_transaction_pattern/input.kz:4-8:
// | then |> app/db:commit(tx) |> app/db:disconnect(conn: c)
// | else |> app/db:rollback(tx) |> app/db:disconnect(conn: c)
//
// This test removes disconnect() from the query error path.
//
// Grounding:
// Chain structure: 330_027_db_transaction_pattern/input.kz:4-8
// | err branch drop syntax: 330_061_inline_obligation_cascade/input.kz:81 (| err _ |> _)
// connected! obligation discharge event: 330_027_db_transaction_pattern/db.kz:60 (disconnect)
~import std/control
~import app/db
const query_succeeded = false;
~app/db:connect(url: "postgres://localhost/test")
| connected c |> app/db:query(conn: c, sql: "SELECT 1")
| started tx |> if(query_succeeded)
| then |> app/db:commit(tx) |> app/db:disconnect(conn: c)
| else |> app/db:rollback(tx) |> app/db:disconnect(conn: c)
| err _ |> _
Must contain:
was not dischargedError Verification
Actual Compiler Output
error[PARSE003]: single continuation branch 'connected' carrying a payload is a one-variant tag union — declare the single output as a bare return instead: `-> <type>`
--> /Users/larsde/src/koru/tests/regression/300_ADVANCED_FEATURES/335_OBLIGATION_STRESS/335_006_err_branch_leaks_opened_resource/db.kz:20:1
|
20 | ~pub event connect { url: []const u8 }
| ^
error[PARSE003]: single continuation branch 'started' carrying a payload is a one-variant tag union — declare the single output as a bare return instead: `-> <type>`
--> /Users/larsde/src/koru/tests/regression/300_ADVANCED_FEATURES/335_OBLIGATION_STRESS/335_006_err_branch_leaks_opened_resource/db.kz:34:1
|
34 | ~pub event query { conn: *Connection<connected>, sql: []const u8 }
| ^Flows
flow ~connect click a branch to expand · @labels scroll to their anchor
connect (url: "postgres://localhost/test")
Imported Files
// Library module: db
// Database operations with layered cleanup obligations
//
// Pattern: connect → query → (commit OR rollback) → disconnect
// Two obligations:
// 1. connected! on Connection - must call disconnect
// 2. transaction! on Transaction - must call commit or rollback
const std = @import("std");
const Connection = struct {
id: i32,
};
const Transaction = struct {
conn: *Connection,
};
// Connect to database - creates connected! obligation
~pub event connect { url: []const u8 }
| connected *Connection<connected!>
~proc connect|zig {
std.debug.print("Connecting to: {s}\n", .{url});
const allocator = std.heap.page_allocator;
const c = allocator.create(Connection) catch unreachable;
c.* = Connection{ .id = 1 };
return .{ .connected = c };
}
// Start a query/transaction - creates transaction! obligation
// The connection must be in [connected] state (required, but not consumed)
// The connected! obligation is tracked separately and discharged by disconnect()
~pub event query { conn: *Connection<connected>, sql: []const u8 }
| started *Transaction<transaction!>
~proc query|zig {
std.debug.print("Query: {s}\n", .{sql});
const allocator = std.heap.page_allocator;
const t = allocator.create(Transaction) catch unreachable;
t.* = Transaction{ .conn = conn };
return .{ .started = t };
}
// Commit - CONSUMES transaction! obligation
~pub event commit { tx: *Transaction<!transaction> }
~proc commit|zig {
std.debug.print("Committing transaction\n", .{});
}
// Rollback - CONSUMES transaction! obligation (alternative to commit)
~pub event rollback { tx: *Transaction<!transaction> }
~proc rollback|zig {
std.debug.print("Rolling back transaction\n", .{});
}
// Disconnect - CONSUMES connected! obligation
~pub event disconnect { conn: *Connection<!connected> }
~proc disconnect|zig {
std.debug.print("Disconnecting\n", .{});
}
Test Configuration
MUST_FAIL