no-mistakes(review): fix kagentz A2A status logging, tests, and contract retirement

tests/test_mumuni_monitor_removal.py

@@ -89,8 +89,7 @@ case "$host" in
     esac ;;
   192.168.68.14)
     case "$cmd" in
-      *agent.json*) printf '%s' "$AZ_A2A" ;;
-      *"ps aux"*)   printf '%s\n' "$AZ_PS" ;;
+      *"/a2a/"*) printf '%s' "$AZ_A2A_CODE" ;;
     esac ;;
   *)
     printf 'UNEXPECTED-SSH-HOST %s\n' "$host" >> "$RECORD_DIR/unexpected-ssh" ;;
@@ -122,8 +121,7 @@ def _write_exec(path: pathlib.Path, body: str) -> None:
 
 
 def _run_monitor(tmp_path, *, tanko_svc="active", tanko_http="200",
-                 az_a2a='{"name":"kagentz"}',
-                 az_ps="root 111 0.1 0.2 /opt/venv-a0/bin/python3 -u adapter.py"):
+                 az_a2a_code="401"):
     """Run the shipped monitor in a sandbox; return (proc, record_dir, log_path).
 
     Only the LOG constant is rewritten (to keep the run inside the worktree).
@@ -151,8 +149,7 @@ def _run_monitor(tmp_path, *, tanko_svc="active", tanko_http="200",
         "RECORD_DIR": str(record),
         "TANKO_SVC": tanko_svc,
         "TANKO_HTTP": tanko_http,
-        "AZ_A2A": az_a2a,
-        "AZ_PS": az_ps,
+        "AZ_A2A_CODE": az_a2a_code,
         "PI_HTTP": "200",
         "PI_BODY": CONNECTED_FIXTURE.read_text(),
         "SERVER_HTTP": "200",
@@ -171,8 +168,7 @@ def test_healthy_run_is_quiet_and_never_reaches_mumuni(tmp_path):
     assert "Server: ✅ HTTP 200" in log
     assert "Abiba: ✅ Connected" in log
     assert "Tanko: ✅ service=active http=200" in log
-    assert "kagentz: ✅ A2A alive" in log
-    assert "kagentz: ✅ Adapter running" in log
+    assert "kagentz: ✅ A2A alive (HTTP 401)" in log
     assert "Result: ✅ All healthy" in log
 
     # A healthy run emits no notify at all — and certainly no Mumuni one.
@@ -214,6 +210,17 @@ def test_failing_run_alerts_on_tanko_but_never_on_mumuni(tmp_path):
     assert "Result: 🔴 1 issue(s) found" in log
 
 
+def test_unexpected_a2a_status_is_an_issue_not_healthy(tmp_path):
+    proc, record, log_path = _run_monitor(tmp_path, az_a2a_code="500")
+    assert proc.returncode == 0, proc.stderr
+    log = log_path.read_text()
+
+    assert "kagentz: 🟡 A2A unexpected http=500 (running, warning)" in log
+    assert "kagentz: ✅ A2A alive" not in log
+    assert "Result: 🔴 1 issue(s) found" in log
+    assert "kagentz A2A server answered HTTP 500" in proc.stdout
+
+
 # ── scripts/daily-infra-report.py: behavioral digest checks ──────────
 
 @pytest.fixture(scope="module")
@@ -334,7 +341,8 @@ def test_agent_health_roster_has_no_mumuni_entry(ahc):
 def test_health_contract_retires_mumuni_only_steps():
     text = HEALTH_CONTRACT.read_text()
     assert MUMUNI_IP not in text
-    for step in ("**B4:", "**B5:", "**B6:"):
+    for step in ("**B4: Gateway Process**", "**B5: Heartbeat Verification**",
+                 "**B6: Response Delivery**"):
         assert step not in text