hyf

commit 0523c4975aad5d447ee7984cb9d4dba79a4e1f3b
parent e7dcfb47d2ae66191784083edd9c889a85411b9a
Author: triesap <tyson@radroots.org>
Date:   Mon, 21 Sep 2026 19:47:25 +0000

test: repair traceability setup and frame/timeout assertions (C001B)

Diffstat:
M
tests/test_persistent_stdio.mojo
 | 
22
+++++++++++++++++++---
M
tests/test_stdio_contract.mojo
 | 
2
+-
M
tests/test_traceability.mojo
 | 
7
++++++-

3 files changed, 26 insertions(+), 5 deletions(-)
diff --git a/tests/test_persistent_stdio.mojo b/tests/test_persistent_stdio.mojo
@@ -8,7 +8,7 @@ from hyf_runtime.startup import (
     RuntimeStartupInput,
     resolve_startup_context,
 )
-from hyf_stdio.server import run_stdio_session
+from hyf_stdio.server import MAX_FRAME_BYTES, run_stdio_session
 
 
 def _context(temp_dir: String) raises -> RuntimeStartupContext:
@@ -71,9 +71,10 @@ def test_session_preserves_order_and_recovers_after_malformed() raises:
 def test_session_rejects_oversized_frame() raises:
     with SafeTempDir() as temp_dir:
         var context = _context(temp_dir)
-        var huge = "{\"version\":1,\"request_id\":\"big\","
-        for _ in range(200000):
+        var huge = String("")
+        for _ in range(MAX_FRAME_BYTES + 1):
             huge += "x"
+        assert_true(huge.byte_length() == MAX_FRAME_BYTES + 1)
         var frames = List[String]()
         frames.append(huge)
         frames.append(load_scenario_request_json("scenarios/status_ok.json"))
@@ -82,6 +83,21 @@ def test_session_rejects_oversized_frame() raises:
         assert_true(responses[1].find('"ok":true') >= 0)
 
 
+def test_session_accepts_frame_at_configured_limit() raises:
+    with SafeTempDir() as temp_dir:
+        var context = _context(temp_dir)
+        var at_limit = String("")
+        for _ in range(MAX_FRAME_BYTES):
+            at_limit += "x"
+        assert_true(at_limit.byte_length() == MAX_FRAME_BYTES)
+        var frames = List[String]()
+        frames.append(at_limit)
+        frames.append(load_scenario_request_json("scenarios/status_ok.json"))
+        var responses = run_stdio_session(frames, context)
+        assert_true(responses[0].find("size limit") < 0)
+        assert_true(responses[1].find('"ok":true') >= 0)
+
+
 def test_farm_update_operation_is_gated_until_enabled() raises:
     with SafeTempDir() as temp_dir:
         var context = _context(temp_dir)
diff --git a/tests/test_stdio_contract.mojo b/tests/test_stdio_contract.mojo
@@ -845,7 +845,7 @@ def test_status_loads_valid_runtime_config_truthfully() raises:
                             "max_local_request_timeout_ms"
                         ].int_value()
                     ),
-                    15000,
+                    250,
                 )
                 assert_true(
                     not _has_key(
diff --git a/tests/test_traceability.mojo b/tests/test_traceability.mojo
@@ -1,5 +1,6 @@
 import std.os
 from std.collections import List
+from std.os.path import dirname, isfile
 from std.pathlib import Path, _dir_of_current_file
 from safe_tempdir import SafeTempDir
 from std.testing import TestSuite, assert_equal, assert_true
@@ -13,8 +14,12 @@ from fixture_validator import (
 
 
 def _write(path: Path, text: String) raises:
-    std.os.makedirs(path.__fspath__(), exist_ok=True)
+    _ = std.os.makedirs(dirname(path.__fspath__()), exist_ok=True)
     path.write_text(text)
+    assert_true(
+        isfile(path.__fspath__()),
+        "expected a regular file at " + path.__fspath__(),
+    )
 
 
 def _make_corpus(base: Path, mutation: String) raises: