hyf

commit b3040f37f2a952becc32f84ebfe0f89a6ac67288
parent d2e043118258db815d4811515d80032d12111f7a
Author: triesap <tyson@radroots.org>
Date:   Mon, 21 Sep 2026 13:47:37 +0000

provider: verify transport cleanup and local cancellation

Diffstat:
M
tests/jev_provider_helper.mojo
 | 
5
++++-
M
tests/test_jev.mojo
 | 
21
+++++++++++++++++++++

2 files changed, 25 insertions(+), 1 deletion(-)
diff --git a/tests/jev_provider_helper.mojo b/tests/jev_provider_helper.mojo
@@ -160,7 +160,10 @@ def _serve(port: Int, mode: String, requests: Int) raises:
     _write(1, "ready\n")
     for _ in range(requests):
         var stream = listener.accept()
-        _handle(stream, mode)
+        try:
+            _handle(stream, mode)
+        except:
+            pass
     listener.close()
 
 
diff --git a/tests/test_jev.mojo b/tests/test_jev.mojo
@@ -367,3 +367,24 @@ def test_bounded_retry_and_budget_behavior() raises:
     assert_true(not retry_decision(policy, 0, 390, 429))
     with assert_raises():
         _ = retry_decision(policy, 0, 0, 200)
+
+
+def test_transport_cleanup_and_local_cancellation() raises:
+    var port = reserve_jev_port()
+    var stub = spawn_jev_stub(port, "ok", 1)
+    var outcome = post_jev_systemone(
+        "http://127.0.0.1:" + String(port),
+        _loads('{"model":"jev-1.13.0","state":"s","questions":{}}'),
+        5000,
+    )
+    assert_equal(outcome.status, 200)
+    stub.wait()
+
+    # A refused connection is a bounded local transport failure (no listener).
+    var dead_port = reserve_jev_port()
+    with assert_raises():
+        _ = post_jev_systemone(
+            "http://127.0.0.1:" + String(dead_port),
+            _loads('{"model":"jev-1.13.0","state":"s","questions":{}}'),
+            150,
+        )