fix(canvas/ContextMenu): prevent React error #185 by moving hasChildren derivation out of Zustand selector

ContextMenu used `.some()` inside its Zustand selector to compute hasChildren. Zustand's useSyncExternalStore calls the selector on every snapshot; `.some()` returns a new boolean each time, which React 19's stricter comparison and the re-render side-effects from the store subscription created a feedback loop on mobile Chat tab mount → React error #185 ("Maximum update depth exceeded"). Fix: select the stable `nodes` array once, derive children via useMemo outside the store subscription. Also removes the inline `getState().nodes.filter()` call in handleDelete in favour of the memoized children. Regression tests (2 cases): - setPendingDelete receives correct children array when workspace has children - setPendingDelete hasChildren=false and empty children when no children Refs: #651 Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
test(canvas/lib): add isExternalLikeRuntime coverage (16 cases)
2026-05-14 00:08:28 +00:00 · 2026-05-14 00:08:28 +00:00
66 changed files with 641 additions and 3992 deletions
@@ -13,9 +13,8 @@ Sources:
 Three failure classes:
  F1  Job in (A) is not under the sentinel's `needs:` — sentinel
      doesn't gate it, so a red job on that name can sneak through.
-      Ignores jobs whose `if:` references `github.event_name` or
-      `github.ref` (those run only on specific events or refs and may
-      be `skipped` legitimately).
+      Ignores jobs whose `if:` references `github.event_name` (those
+      run only on specific events and may be `skipped` legitimately).
  F2  Context in (B) corresponds to no emitter — i.e. there's no job
      in ci.yml whose runtime status-name maps to that context.
      A stale required-check name is silent: protection demands a
@@ -204,17 +203,12 @@ def ci_jobs_all(ci_doc: dict) -> set[str]:

 def ci_job_names(ci_doc: dict) -> set[str]:
    """Set of job keys in ci.yml MINUS the sentinel itself MINUS jobs
-    whose `if:` gates on `github.event_name` or `github.ref` (those are
-    event-scoped and can legitimately be `skipped` for a given trigger;
-    if we required them under the sentinel `needs:`, every PR-only job
+    whose `if:` gates on `github.event_name` (those are event-scoped
+    and can legitimately be `skipped` for a given trigger; if we
+    required them under the sentinel `needs:`, every PR-only job
    would be `skipped` on push and the sentinel would interpret
    `skipped != success` as failure). RFC §4 spec.

-    `github.ref` is the companion gate for jobs that run only on direct
-    pushes to specific branches (e.g. `github.ref == 'refs/heads/main'`).
-    These never execute in a PR context, so flagging them as missing
-    from `all-required.needs:` is a false positive (mc#958 / mc#959).
-
    Used for F1 (jobs missing from sentinel needs). NOT used for F1b
    (typos in needs) — see `ci_jobs_all` for that."""
    jobs = ci_doc.get("jobs")
@@ -227,9 +221,7 @@ def ci_job_names(ci_doc: dict) -> set[str]:
            continue
        if isinstance(v, dict):
            gate = v.get("if")
-            if isinstance(gate, str) and (
-                "github.event_name" in gate or "github.ref" in gate
-            ):
+            if isinstance(gate, str) and "github.event_name" in gate:
                continue
        names.add(k)
    return names
@@ -47,15 +47,6 @@ REQUIRED_CONTEXTS_RAW = _env(
        "sop-checklist / all-items-acked (pull_request)"
    ),
 )
-# Required contexts for push (main/staging) runs. The push CI uses the same
-# aggregator names with " (push)" suffix. Checking these explicitly instead of
-# the combined state avoids false-pause when non-blocking jobs (e.g. Platform
-# Go with continue-on-error: true due to mc#774) have failed — their failures
-# pollute the combined state but do not block merges.
-PUSH_REQUIRED_CONTEXTS_RAW = _env(
-    "PUSH_REQUIRED_CONTEXTS",
-    default="CI / all-required (push)",
-)

 OWNER, NAME = (REPO.split("/", 1) + [""])[:2] if REPO else ("", "")
 API = f"https://{GITEA_HOST}/api/v1" if GITEA_HOST else ""
@@ -127,24 +118,16 @@ def required_contexts(raw: str) -> list[str]:
    return [part.strip() for part in raw.split(",") if part.strip()]


-def push_required_contexts() -> list[str]:
-    """Required contexts for push (branch) CI runs. See PUSH_REQUIRED_CONTEXTS_RAW."""
-    return required_contexts(PUSH_REQUIRED_CONTEXTS_RAW)
-
-
 def status_state(status: dict) -> str:
    return str(status.get("status") or status.get("state") or "").lower()


 def latest_statuses_by_context(statuses: list[dict]) -> dict[str, dict]:
-    # Gitea /statuses endpoint returns entries in ascending id order (oldest
-    # first). We need the LAST occurrence of each context, so iterate in
-    # reverse to prefer newer entries.
    latest: dict[str, dict] = {}
-    for status in reversed(statuses):
+    for status in statuses:
        context = status.get("context")
-        if isinstance(context, str):
-            latest[context] = status  # overwrite: reverse order → newest wins
+        if isinstance(context, str) and context not in latest:
+            latest[context] = status
    return latest


@@ -210,23 +193,16 @@ def evaluate_merge_readiness(
    required_contexts: list[str],
    pr_has_current_base: bool,
 ) -> MergeDecision:
-    # Check push-required contexts explicitly instead of combined state.
-    # Combined state can be "failure" due to non-blocking jobs
-    # (continue-on-error: true) that don't actually gate merges.
-    # CI / all-required (push) is the authoritative gate — it respects
-    # continue-on-error and correctly aggregates all blocking failures.
-    main_latest = latest_statuses_by_context(main_status.get("statuses") or [])
-    main_ok, main_bad = required_contexts_green(main_latest, push_required_contexts())
-    if not main_ok:
-        return MergeDecision(False, "pause", "main required contexts not green: " + ", ".join(main_bad))
+    main_state = str(main_status.get("state") or "").lower()
+    if main_state != "success":
+        return MergeDecision(False, "pause", f"main status is {main_state or 'missing'}")
    if not pr_has_current_base:
        return MergeDecision(False, "update", "PR head does not contain current main")

-    # Check explicit required contexts instead of combined state. Combined state
-    # can be "failure" due to non-blocking jobs with continue-on-error: true
-    # (e.g. publish-runtime-autobump/pr-validate, qa-review on stale tokens).
-    # The required_contexts list is the authoritative gate — it includes only
-    # the checks that actually block merges.
+    pr_state = str(pr_status.get("state") or "").lower()
+    if pr_state != "success":
+        return MergeDecision(False, "wait", f"PR combined status is {pr_state or 'missing'}")
+
    latest = latest_statuses_by_context(pr_status.get("statuses") or [])
    ok, missing_or_bad = required_contexts_green(latest, required_contexts)
    if not ok:
@@ -244,37 +220,10 @@ def get_branch_head(branch: str) -> str:


 def get_combined_status(sha: str) -> dict:
-    """Combined status + all individual statuses for `sha`.
-
-    The /status endpoint caps the `statuses` array at 30 entries (Gitea
-    default page size), so we fetch the full list via /statuses with a
-    higher limit. The combined `state` still comes from /status.
-    """
-    _, combined = api("GET", f"/repos/{OWNER}/{NAME}/commits/{sha}/status")
-    if not isinstance(combined, dict):
+    _, body = api("GET", f"/repos/{OWNER}/{NAME}/commits/{sha}/status")
+    if not isinstance(body, dict):
        raise ApiError(f"status for {sha} response not object")
-    # Fetch full statuses list; 200 covers >99% of real-world runs.
-    # The list is ordered ascending by id (oldest first) — callers must
-    # iterate in reverse to get the newest entry per context.
-    # Best-effort: large repos (main with 550+ statuses) may time out.
-    # On timeout, fall back to the statuses[] already in the combined
-    # response (usually 30 entries — enough for most PRs, enough for
-    # main's early push-required contexts).
-    try:
-        _, all_statuses = api(
-            "GET",
-            f"/repos/{OWNER}/{NAME}/commits/{sha}/statuses",
-            query={"limit": "50"},
-        )
-        if isinstance(all_statuses, list):
-            combined["statuses"] = all_statuses
-    except (ApiError, urllib.error.URLError, TimeoutError, OSError) as exc:
-        # URLError covers network-level failures (DNS, refused, timeout).
-        # TimeoutError and OSError cover socket-level timeouts.
-        sys.stderr.write(f"::warning::could not fetch full statuses list for {sha[:8]}: {exc}\n")
-        # Fall back to the statuses[] already in the combined response.
-        pass
-    return combined
+    return body


 def list_queued_issues() -> list[dict]:
@@ -345,12 +294,8 @@ def process_once(*, dry_run: bool = False) -> int:
    contexts = required_contexts(REQUIRED_CONTEXTS_RAW)
    main_sha = get_branch_head(WATCH_BRANCH)
    main_status = get_combined_status(main_sha)
-    # Check push-required contexts explicitly instead of combined state.
-    # See evaluate_merge_readiness for rationale.
-    main_latest = latest_statuses_by_context(main_status.get("statuses") or [])
-    main_ok, main_bad = required_contexts_green(main_latest, push_required_contexts())
-    if not main_ok:
-        print(f"::notice::queue paused: {WATCH_BRANCH}@{main_sha[:8]} required contexts not green: {', '.join(main_bad)}")
+    if str(main_status.get("state") or "").lower() != "success":
+        print(f"::notice::queue paused: {WATCH_BRANCH}@{main_sha[:8]} is not green")
        return 0

    issue = choose_next_queued_issue(
@@ -36,9 +36,6 @@ Rules (4 fatal + 1 fatal cross-file + 1 heuristic-warn):
     raw `.error` fields into CI logs/summaries.
  9. Production deploy/redeploy workflows must expose an operational control:
     kill switch for auto deploys or rollback tag for manual deploys.
-  10. Docker health checks must not run `docker info | head` under pipefail.
-      `head` closes the pipe early, `docker info` can exit nonzero from
-      SIGPIPE, and the step can falsely report Docker daemon failure.

 Per `feedback_smoke_test_vendor_truth_not_shape_match`: fixtures used to
 validate this lint must mirror real Gitea 1.22.6 YAML semantics, not
@@ -228,24 +225,6 @@ def _iter_uses(doc: Any) -> Iterable[str]:
                yield step["uses"]


-def _iter_run_blocks(doc: Any) -> Iterable[str]:
-    """Yield every shell `run:` block from job steps in a workflow document."""
-    if not isinstance(doc, dict):
-        return
-    jobs = doc.get("jobs")
-    if not isinstance(jobs, dict):
-        return
-    for job in jobs.values():
-        if not isinstance(job, dict):
-            continue
-        steps = job.get("steps")
-        if not isinstance(steps, list):
-            continue
-        for step in steps:
-            if isinstance(step, dict) and isinstance(step.get("run"), str):
-                yield step["run"]
-
-
 def check_cross_repo_uses(filename: str, doc: Any) -> list[str]:
    """Return per-violation error lines for cross-repo `uses:` references."""
    errors: list[str] = []
@@ -285,10 +264,6 @@ GITHUB_API_REF_RE = re.compile(

 PROD_CP_URL_RE = re.compile(r"https://api\.moleculesai\.app\b")
 REDEPLOY_FLEET_RE = re.compile(r"\b/cp/admin/tenants/redeploy-fleet\b")
-RUN_SETS_PIPEFAIL_RE = re.compile(r"(?m)^\s*set\s+-[^\n]*o\s+pipefail\b")
-DOCKER_INFO_HEAD_PIPE_RE = re.compile(
-    r"(?m)^\s*docker\s+info\b[^\n|]*\|\s*head\b"
-)
 RAW_CP_RESPONSE_RE = re.compile(
    r"""(?x)
    (?:\bjq\s+\.\s+["']?\$HTTP_RESPONSE["']?)
@@ -408,30 +383,6 @@ def check_production_operational_control(filename: str, raw: str) -> list[str]:
    return errors


-# ---------------------------------------------------------------------------
-# Rule 10 — docker info piped to head under pipefail
-# ---------------------------------------------------------------------------
-
-def check_docker_info_head_pipefail(filename: str, doc: Any) -> list[str]:
-    errors: list[str] = []
-    for run_block in _iter_run_blocks(doc):
-        if not (
-            RUN_SETS_PIPEFAIL_RE.search(run_block)
-            and DOCKER_INFO_HEAD_PIPE_RE.search(run_block)
-        ):
-            continue
-        errors.append(
-            f"::error file={filename}::Rule 10 (FATAL): workflow runs "
-            f"`docker info | head` after enabling `pipefail`. `head` can "
-            f"close the pipe early, making `docker info` exit nonzero and "
-            f"falsely fail the Docker daemon health check. Capture "
-            f"`docker_info=\"$(docker info 2>&1)\"` first, then print a "
-            f"bounded preview with `printf ... | sed -n '1,5p'`."
-        )
-        break
-    return errors
-
-
 # ---------------------------------------------------------------------------
 # Driver
 # ---------------------------------------------------------------------------
@@ -485,7 +436,6 @@ def main(argv: list[str] | None = None) -> int:
        fatal_errors.extend(check_production_concurrency(rel, doc, raw))
        fatal_errors.extend(check_production_raw_response_logging(rel, raw))
        fatal_errors.extend(check_production_operational_control(rel, raw))
-        fatal_errors.extend(check_docker_info_head_pipefail(rel, doc))
        warnings.extend(check_github_server_url_missing(rel, doc, raw))

    # Cross-file checks
@@ -101,10 +101,9 @@ printf 'header = "Authorization: token %s"\n' "$GITEA_TOKEN" > "$CURL_AUTH_FILE"
 PR_JSON=$(mktemp)
 REVIEWS_JSON=$(mktemp)
 TEAM_PROBE_TMP=$(mktemp)
-NA_STATUSES_TMP=""  # declared here so cleanup() always has the var

 cleanup() {
-  rm -f "$CURL_AUTH_FILE" "$PR_JSON" "$REVIEWS_JSON" "$TEAM_PROBE_TMP" "${NA_STATUSES_TMP-}"
+  rm -f "$CURL_AUTH_FILE" "$PR_JSON" "$REVIEWS_JSON" "$TEAM_PROBE_TMP"
 }
 trap cleanup EXIT

@@ -144,42 +143,6 @@ if [ -z "$PR_AUTHOR" ] || [ -z "$PR_HEAD_SHA" ]; then
  exit 1
 fi

-# --- RFC#324 §N/A follow-up: check N/A declarations status ---
-# sop-checklist.py posts `sop-checklist / na-declarations (pull_request)`
-# status when a peer posts /sop-n/a <gate>. If our gate is declared N/A,
-# the requirement for a Gitea APPROVE review is waived.
-NA_STATUSES_TMP=$(mktemp)
-HTTP_CODE=$(curl -sS -o "$NA_STATUSES_TMP" -w '%{http_code}' \
-  -K "$CURL_AUTH_FILE" "${API}/repos/${OWNER}/${NAME}/statuses/${PR_HEAD_SHA}")
-debug "statuses/${PR_HEAD_SHA} → HTTP ${HTTP_CODE}"
-
-if [ "$HTTP_CODE" = "200" ]; then
-  # Gitea returns statuses as array; look for the na-declarations context.
-  # jq: find all statuses where context == "sop-checklist / na-declarations (pull_request)"
-  # and state == "success". Extract the description field.
-  NA_DESC=$(jq -r '
-    .[] |
-    select(.context == "sop-checklist / na-declarations (pull_request)") |
-    select(.state == "success") |
-    .description
-  ' "$NA_STATUSES_TMP" 2>/dev/null | head -1)
-
-  if [ -n "$NA_DESC" ] && [ "$NA_DESC" != "null" ]; then
-    debug "na-declarations status found: ${NA_DESC}"
-    # Check if our gate appears in the N/A description.
-    # The description format is "N/A: qa-review, security-review" or similar.
-    if echo "$NA_DESC" | grep -iq "\\b${TEAM}-review\\b"; then
-      echo "::notice::${TEAM}-review N/A — gate declared not-applicable via /sop-n/a: ${NA_DESC}"
-      echo "::notice::PR ${PR_NUMBER} passes ${TEAM}-review via N/A declaration"
-      rm -f "$NA_STATUSES_TMP"
-      exit 0
-    fi
-  fi
-else
-  debug "could not fetch statuses (HTTP ${HTTP_CODE}) — proceeding with normal eval"
-fi
-rm -f "$NA_STATUSES_TMP"
-
 # --- Fetch all reviews on the PR ---
 HTTP_CODE=$(curl -sS -o "$REVIEWS_JSON" -w '%{http_code}' \
  -K "$CURL_AUTH_FILE" "${API}/repos/${OWNER}/${NAME}/pulls/${PR_NUMBER}/reviews")
@@ -1,81 +0,0 @@
-#!/usr/bin/env bash
-# Re-run review-check.sh for a slash-command refire and post the protected
-# pull_request status context to the PR head SHA.
-
-set -euo pipefail
-
-: "${GITEA_TOKEN:?GITEA_TOKEN required}"
-: "${GITEA_HOST:?GITEA_HOST required}"
-: "${REPO:?REPO required}"
-: "${PR_NUMBER:?PR_NUMBER required}"
-: "${TEAM:?TEAM required}"
-
-OWNER="${REPO%%/*}"
-NAME="${REPO##*/}"
-API="https://${GITEA_HOST}/api/v1"
-CONTEXT="${TEAM}-review / approved (pull_request)"
-TARGET_URL="https://${GITEA_HOST}/${OWNER}/${NAME}/pulls/${PR_NUMBER}"
-
-authfile=$(mktemp)
-prfile=$(mktemp)
-postfile=$(mktemp)
-# shellcheck disable=SC2329 # invoked by EXIT trap
-cleanup() {
-  rm -f "$authfile" "$prfile" "$postfile"
-}
-trap cleanup EXIT
-
-chmod 600 "$authfile"
-printf 'header = "Authorization: token %s"\n' "$GITEA_TOKEN" > "$authfile"
-
-code=$(curl -sS -o "$prfile" -w '%{http_code}' -K "$authfile" \
-  "${API}/repos/${OWNER}/${NAME}/pulls/${PR_NUMBER}")
-if [ "$code" != "200" ]; then
-  echo "::error::GET /pulls/${PR_NUMBER} returned HTTP ${code}"
-  head -c 200 "$prfile" >&2 || true
-  exit 1
-fi
-
-head_sha=$(jq -r '.head.sha // ""' "$prfile")
-state=$(jq -r '.state // ""' "$prfile")
-if [ -z "$head_sha" ] || [ "$head_sha" = "null" ]; then
-  echo "::error::Could not resolve PR head SHA for PR ${PR_NUMBER}"
-  exit 1
-fi
-if [ "$state" != "open" ]; then
-  echo "::notice::PR ${PR_NUMBER} is ${state}; ${TEAM}-review refire is a no-op"
-  exit 0
-fi
-
-set +e
-bash .gitea/scripts/review-check.sh
-rc=$?
-set -e
-
-if [ "$rc" -eq 0 ]; then
-  status_state="success"
-  description="Refired via /${TEAM}-recheck by ${COMMENT_AUTHOR:-unknown}"
-else
-  status_state="failure"
-  description="Refired via /${TEAM}-recheck; ${TEAM}-review failed"
-fi
-
-body=$(jq -nc \
-  --arg state "$status_state" \
-  --arg context "$CONTEXT" \
-  --arg description "$description" \
-  --arg target_url "$TARGET_URL" \
-  '{state:$state, context:$context, description:$description, target_url:$target_url}')
-
-code=$(curl -sS -o "$postfile" -w '%{http_code}' -X POST \
-  -K "$authfile" -H "Content-Type: application/json" \
-  -d "$body" \
-  "${API}/repos/${OWNER}/${NAME}/statuses/${head_sha}")
-if [ "$code" != "200" ] && [ "$code" != "201" ]; then
-  echo "::error::POST /statuses/${head_sha} returned HTTP ${code}"
-  head -c 200 "$postfile" >&2 || true
-  exit 1
-fi
-
-echo "::notice::posted ${status_state} for context=\"${CONTEXT}\" on sha=${head_sha}"
-exit "$rc"
@@ -1,11 +1,11 @@
 #!/usr/bin/env python3
-# sop-checklist — evaluate whether a PR has peer-acked each
+# sop-checklist-gate — evaluate whether a PR has peer-acked each
 # SOP-checklist item. Posts a commit-status that branch protection
 # can require.
 #
 # RFC#351 Step 2 of 6 (implementation MVP).
 #
-# Invoked by .gitea/workflows/sop-checklist.yml on:
+# Invoked by .gitea/workflows/sop-checklist-gate.yml on:
 #   - pull_request_target: [opened, edited, synchronize, reopened]
 #   - issue_comment:       [created, edited, deleted]
 #
@@ -109,58 +109,57 @@ def normalize_slug(raw: str, numeric_aliases: dict[int, str] | None = None) -> s
 # Optional trailing note after the slug for /sop-ack and required reason
 # for /sop-revoke (RFC#351 open question 4 — reason is captured but not
 # yet validated; future iteration may require a min-length).
-#
-# /sop-n/a <gate> [reason] — declares a gate as not-applicable.
-#   <gate> is a canonical gate name (qa-review, security-review).
-#   The declaring user must be in one of the gate's required_teams.
-#   Most-recent per-user declaration wins (revoke semantics mirror ack).
 _DIRECTIVE_RE = re.compile(
    r"^[ \t]*/(sop-ack|sop-revoke)[ \t]+([A-Za-z0-9_\- ]+?)(?:[ \t]+(.*))?[ \t]*$",
    re.MULTILINE,
 )
-_NA_DIRECTIVE_RE = re.compile(
-    r"^[ \t]*/sop-n/?a[ \t]+([A-Za-z0-9_\-]+)(?:[ \t]+(.*))?[ \t]*$",
-    re.MULTILINE,
-)


 def parse_directives(
    comment_body: str,
    numeric_aliases: dict[int, str],
-) -> tuple[list[tuple[str, str, str]], list[tuple[str, str, str]]]:
-    """Extract /sop-ack, /sop-revoke, and /sop-n/a directives from a comment body.
+) -> list[tuple[str, str, str]]:
+    """Extract /sop-ack and /sop-revoke directives from a comment body.

-    Returns a tuple of two lists:
-      0. list of (kind, canonical_slug, note) for sop-ack/sop-revoke
-      1. list of (kind, gate_name, reason) for sop-n/a
-
-    canonical_slug is the normalized form (or "" if unparseable).
-    note/reason is the trailing free-text (may be "").
+    Returns a list of (kind, canonical_slug, note) tuples where:
+      kind is "sop-ack" or "sop-revoke"
+      canonical_slug is the normalized form (or "" if unparseable)
+      note is the trailing free-text (may be "")
    """
    out: list[tuple[str, str, str]] = []
-    na_out: list[tuple[str, str, str]] = []
    if not comment_body:
-        return out, na_out
+        return out
    for m in _DIRECTIVE_RE.finditer(comment_body):
        kind = m.group(1)
        raw_slug = (m.group(2) or "").strip()
+        # If the raw match included trailing words, the regex non-greedy
+        # captured only the first token; strip again for safety.
+        # We split on whitespace to keep the FIRST word as the slug, and
+        # everything after as the note.
        parts = raw_slug.split()
        if not parts:
            continue
        first = parts[0]
+        # If the slug-capture greedily matched multiple words (e.g.
+        # "comprehensive testing"), preserve normalize behavior: join
+        # the WHOLE first-word-token only; trailing words get appended to
+        # the note. The regex limits group(2) to [A-Za-z0-9_\- ] so we
+        # may have multi-word forms here — normalize handles them.
        if len(parts) > 1:
+            # User wrote "/sop-ack comprehensive testing extra-note"
+            # → treat "comprehensive testing" as the slug source if it
+            # normalizes to a known item; otherwise treat "comprehensive"
+            # as slug and "testing extra-note" as note. We defer the
+            # disambiguation to the caller via the returned canonical
+            # slug. For simplicity: try the WHOLE captured string first.
            canonical = normalize_slug(raw_slug, numeric_aliases)
        else:
            canonical = normalize_slug(first, numeric_aliases)
        note_from_group = (m.group(3) or "").strip()
+        # If we collapsed multi-word slug into kebab and there's a
+        # trailing-text group too, append it.
        out.append((kind, canonical, note_from_group))
-
-    for m in _NA_DIRECTIVE_RE.finditer(comment_body):
-        gate = (m.group(1) or "").strip().lower()
-        reason = (m.group(2) or "").strip()
-        na_out.append(("sop-n/a", gate, reason))
-
-    return out, na_out
+    return out


 # ---------------------------------------------------------------------------
@@ -231,8 +230,9 @@ def compute_ack_state(
       {
         "comprehensive-testing": {
           "ackers": ["bob"],         # non-author, team-verified
-           "rejected": {
+           "rejected_ackers": {        # debugging info
             "self_ack": ["alice"],
+             "unknown_slug": [],
             "not_in_team": ["eve"],
           }
         },
@@ -249,8 +249,7 @@ def compute_ack_state(
        user = (c.get("user") or {}).get("login", "")
        if not user:
            continue
-        directives, _na_directives = parse_directives(body, numeric_aliases)
-        for kind, slug, _note in directives:
+        for kind, slug, _note in parse_directives(body, numeric_aliases):
            if not slug:
                unparseable_per_user[user] = unparseable_per_user.get(user, 0) + 1
                continue
@@ -260,19 +259,25 @@ def compute_ack_state(
    # Filter out self-acks and unknown slugs.
    ackers_per_slug: dict[str, list[str]] = {s: [] for s in items_by_slug}
    rejected_self: dict[str, list[str]] = {s: [] for s in items_by_slug}
+    rejected_unknown: dict[str, list[str]] = {s: [] for s in items_by_slug}
    pending_team_check: dict[str, list[str]] = {s: [] for s in items_by_slug}

    for (user, slug), kind in latest_directive.items():
        if kind != "sop-ack":
            continue  # revokes leave the (user,slug) state as "no ack"
        if slug not in items_by_slug:
+            # Slug normalized to something not in our config — store
+            # under a synthetic key for diagnostic surfacing. Don't add
+            # to any item.
            continue
        if user == pr_author:
            rejected_self[slug].append(user)
            continue
        pending_team_check[slug].append(user)

-    # Step 3: team membership probe per slug.
+    # Step 3: team membership probe per slug (batched per slug to keep
+    # API call count down — same user may ack multiple items but the
+    # required_teams differ per item, so we MUST probe per (user, item)).
    rejected_not_in_team: dict[str, list[str]] = {s: [] for s in items_by_slug}
    for slug, candidates in pending_team_check.items():
        if not candidates:
@@ -281,6 +286,7 @@ def compute_ack_state(
        approved = team_membership_probe(slug, candidates)  # returns subset
        rejected_not_in_team[slug] = [u for u in candidates if u not in approved]
        ackers_per_slug[slug] = approved
+        # Stash required teams for description rendering.
        items_by_slug[slug]["_required_resolved"] = required

    return {
@@ -295,113 +301,6 @@ def compute_ack_state(
    }


-def compute_na_state(
-    comments: list[dict[str, Any]],
-    pr_author: str,
-    na_gates: dict[str, dict[str, Any]],
-    numeric_aliases: dict[int, str],
-    team_membership_probe: "callable[[str, list[str]], list[str]]",
-    client: "GiteaClient",
-    org: str,
-) -> dict[str, dict[str, Any]]:
-    """Compute per-gate N/A declaration state.
-
-    Returns a dict keyed by gate name:
-       {
-         "qa-review": {
-           "declared":  ["alice"],      # non-author, team-verified, not revoked
-           "rejected": ["eve (not-in-team)", "bob (self-decl)"],
-           "reason":   "pure-infra change — no qa surface",
-         },
-         ...
-       }
-    A gate is N/A-satisfied when at least one declaration from a valid
-    team member exists and has not been revoked by the same user.
-    """
-    if not na_gates:
-        return {}
-
-    # Collapse directives per (commenter, gate) — most recent wins.
-    latest_na: dict[tuple[str, str], str] = {}   # (user, gate) → "sop-n/a"
-    latest_na_reason: dict[tuple[str, str], str] = {}  # (user, gate) → reason
-    for c in comments:
-        body = c.get("body", "") or ""
-        user = (c.get("user") or {}).get("login", "")
-        if not user:
-            continue
-        _directives, na_directives = parse_directives(body, numeric_aliases)
-        for _kind, gate, reason in na_directives:
-            if gate not in na_gates:
-                continue
-            latest_na[(user, gate)] = "sop-n/a"
-            latest_na_reason[(user, gate)] = reason
-
-    # Determine candidate declarers per gate.
-    na_state: dict[str, dict[str, Any]] = {
-        gate: {"declared": [], "rejected": [], "reason": ""}
-        for gate in na_gates
-    }
-    pending_per_gate: dict[str, list[str]] = {gate: [] for gate in na_gates}
-
-    for (user, gate), kind in latest_na.items():
-        if kind != "sop-n/a":
-            continue
-        if user == pr_author:
-            na_state[gate]["rejected"].append(f"{user} (self-decl)")
-            continue
-        pending_per_gate[gate].append(user)
-
-    # Probe team membership per gate using that gate's required_teams.
-    for gate, candidates in pending_per_gate.items():
-        if not candidates:
-            continue
-        required_teams = na_gates[gate].get("required_teams", [])
-        # Resolve team names → ids using the client's resolver.
-        team_ids: list[int] = []
-        for tn in required_teams:
-            tid = client.resolve_team_id(org, tn)
-            if tid is not None:
-                team_ids.append(tid)
-        if not team_ids:
-            na_state[gate]["rejected"].extend(
-                f"{u} (no-team-id)" for u in candidates
-            )
-            continue
-        for u in candidates:
-            in_any_team = False
-            for tid in team_ids:
-                result = client.is_team_member(tid, u)
-                if result is True:
-                    in_any_team = True
-                    break
-                if result is None:
-                    # 403 — token owner not in team. Fail-closed.
-                    print(
-                        f"::warning::na: team-probe for {u} in team-id {tid} "
-                        "returned 403 — treating as not-in-team (fail-closed)",
-                        file=sys.stderr,
-                    )
-            if in_any_team:
-                na_state[gate]["declared"].append(u)
-            else:
-                na_state[gate]["rejected"].append(f"{u} (not-in-team)")
-
-    # Build per-gate reason string from declared users.
-    for gate in na_gates:
-        decl = na_state[gate]["declared"]
-        if decl:
-            reasons: list[str] = []
-            for u in decl:
-                r = latest_na_reason.get((u, gate), "")
-                if r:
-                    reasons.append(f"{u}: {r}")
-                else:
-                    reasons.append(u)
-            na_state[gate]["reason"] = "; ".join(reasons)
-
-    return na_state
-
-
 # ---------------------------------------------------------------------------
 # Gitea API client
 # ---------------------------------------------------------------------------
@@ -799,7 +698,6 @@ def main(argv: list[str] | None = None) -> int:
    numeric_aliases = {
        int(it["numeric_alias"]): it["slug"] for it in items if it.get("numeric_alias")
    }
-    na_gates: dict[str, dict[str, Any]] = cfg.get("n/a_gates") or {}

    client = GiteaClient(args.gitea_host, token) if token else None
    if not client:
@@ -819,8 +717,6 @@ def main(argv: list[str] | None = None) -> int:
        print("::error::PR payload missing user.login or head.sha", file=sys.stderr)
        return 1

-    target_url = f"https://{args.gitea_host}/{args.owner}/{args.repo}/pulls/{args.pr}"
-
    comments = client.get_issue_comments(args.owner, args.repo, args.pr)

    # Build team-membership probe closure that caches results per
@@ -878,47 +774,6 @@ def main(argv: list[str] | None = None) -> int:
    ack_state = compute_ack_state(comments, author, items_by_slug, numeric_aliases, probe)
    body_state = {it["slug"]: section_marker_present(body, it["pr_section_marker"]) for it in items}

-    # --- N/A gate state (RFC#324 §N/A follow-up) ---
-    na_state: dict[str, dict[str, Any]] = {}
-    if na_gates:
-        na_state = compute_na_state(
-            comments, author, na_gates, numeric_aliases,
-            probe, client, args.owner,
-        )
-        # Post N/A declarations status (read by review-check.sh).
-        na_satisfied = [g for g, s in na_state.items() if s["declared"]]
-        na_missing   = [g for g, s in na_state.items() if not s["declared"]]
-        if na_satisfied:
-            na_desc = f"N/A: {', '.join(na_satisfied)}"
-            na_post_state = "success"
-        elif na_missing:
-            na_desc = f"awaiting /sop-n/a declaration for: {', '.join(na_missing)}"
-            na_post_state = "pending"
-        else:
-            # Configured but no declarations yet.
-            na_desc = "no /sop-n/a declarations yet"
-            na_post_state = "pending"
-        na_context = "sop-checklist / na-declarations (pull_request)"
-        print(f"::notice::na-declarations status: {na_post_state} — {na_desc}")
-        if not args.dry_run:
-            client.post_status(
-                args.owner, args.repo, head_sha,
-                state=na_post_state, context=na_context,
-                description=na_desc,
-                target_url=target_url,
-            )
-            print(f"::notice::na-declarations status posted: {na_context} → {na_post_state}")
-        # Log per-gate diagnostics.
-        for gate in na_gates:
-            s = na_state.get(gate, {})
-            if s.get("declared"):
-                print(f"::notice::  [PASS] gate={gate} — N/A declared by {','.join(s['declared'])}"
-                      + (f" ({s['reason']})" if s.get("reason") else ""))
-            else:
-                extra = f" — rejected: {', '.join(s.get('rejected', []))}" if s.get("rejected") else ""
-                print(f"::notice::  [WAIT] gate={gate} — no valid N/A declaration yet{extra}")
-
-
    state, description = render_status(items, ack_state, body_state)
    mode = get_tier_mode(pr, cfg)
    if mode == "soft":
@@ -953,6 +808,7 @@ def main(argv: list[str] | None = None) -> int:
            return 0 if state in ("success", "pending") else 1
        return 0

+    target_url = f"https://{args.gitea_host}/{args.owner}/{args.repo}/pulls/{args.pr}"
    client.post_status(
        args.owner, args.repo, head_sha,
        state=state, context=args.status_context,
@@ -133,9 +133,6 @@ PUSH_COMPENSATION_DESCRIPTION = (
    "Compensated by status-reaper (workflow has no push: trigger; "
    "Gitea 1.22.6 hardcoded-suffix bug — see .gitea/scripts/status-reaper.py)"
 )
-# Backward-compatible alias for older tests/tooling that predate the split
-# between push-suffix compensation and pull-request-shadow compensation.
-COMPENSATION_DESCRIPTION = PUSH_COMPENSATION_DESCRIPTION
 PR_SHADOW_COMPENSATION_DESCRIPTION = (
    "Compensated by status-reaper (default-branch pull_request status "
    "shadowed by successful push status on same SHA; see "
@@ -614,10 +611,11 @@ def list_recent_commit_shas(branch: str, limit: int) -> list[str]:
    (verified via vendor-truth probe 2026-05-11 against
    git.moleculesai.app — `feedback_smoke_test_vendor_truth_not_shape_match`).

-    Raises ApiError on non-2xx OR on unexpected response shape. The
-    branch-level caller soft-skips this tick because the next scheduled
-    tick can safely retry the listing. Per-SHA status/write errors remain
-    separate and must not be mislabeled as commit-list outages.
+    Raises ApiError on non-2xx OR on unexpected response shape. This is
+    a HARD halt — without the commit list the sweep can't proceed. (The
+    per-SHA error isolation downstream is a different concern: tolerating
+    a transient 5xx on ONE commit's status is best-effort; losing the
+    commit list itself means we don't even know which commits to try.)
    """
    _, body = api(
        "GET",
@@ -658,27 +656,7 @@ def reap_branch(
      - compensated_per_sha: {<sha_full>: [<context>, ...]} — only
        SHAs that actually got at least one compensation are included
    """
-    try:
-        shas = list_recent_commit_shas(branch, limit)
-    except ApiError as e:
-        print(
-            "::warning::status-reaper skipped this tick because the "
-            f"commit list could not be read after retries: {e}"
-        )
-        return {
-            "scanned_shas": 0,
-            "compensated": 0,
-            "preserved_real_push": 0,
-            "preserved_unknown": 0,
-            "preserved_non_failure": 0,
-            "preserved_non_push_suffix": 0,
-            "preserved_unparseable": 0,
-            "compensated_pr_shadowed_by_push_success": 0,
-            "preserved_pr_without_push_success": 0,
-            "compensated_per_sha": {},
-            "skipped": True,
-            "skip_reason": "commit-list-api-error",
-        }
+    shas = list_recent_commit_shas(branch, limit)

    aggregate: dict[str, Any] = {
        "scanned_shas": 0,
@@ -1,8 +1,8 @@
 #!/usr/bin/env python3
-# Unit tests for sop-checklist.py
+# Unit tests for sop-checklist-gate.py
 #
-# Run:  python3 .gitea/scripts/tests/test_sop_checklist.py
-#   or:  pytest .gitea/scripts/tests/test_sop_checklist.py
+# Run:  python3 .gitea/scripts/tests/test_sop_checklist_gate.py
+#   or:  pytest .gitea/scripts/tests/test_sop_checklist_gate.py
 #
 # RFC#351 Step 2 of 6 — implementation MVP. Tests cover:
 #   - slug normalization (the 4 example variants in the script header)
@@ -33,7 +33,7 @@ sys.path.insert(0, PARENT)
 import importlib.util  # noqa: E402

 _spec = importlib.util.spec_from_file_location(
-    "sop_checklist", os.path.join(PARENT, "sop-checklist.py")
+    "sop_checklist_gate", os.path.join(PARENT, "sop-checklist-gate.py")
 )
 sop = importlib.util.module_from_spec(_spec)
 _spec.loader.exec_module(sop)  # type: ignore[union-attr]
@@ -134,22 +134,18 @@ class TestParseDirectives(unittest.TestCase):
    def setUp(self):
        self.aliases = _numeric_aliases()

-    def parse_ack_revoke(self, body):
-        directives, na_directives = sop.parse_directives(body, self.aliases)
-        self.assertEqual(na_directives, [])
-        return directives
-
    def test_simple_ack(self):
-        d = self.parse_ack_revoke("/sop-ack comprehensive-testing")
+        d = sop.parse_directives("/sop-ack comprehensive-testing", self.aliases)
        self.assertEqual(d, [("sop-ack", "comprehensive-testing", "")])

    def test_simple_revoke(self):
-        d = self.parse_ack_revoke("/sop-revoke staging-smoke")
+        d = sop.parse_directives("/sop-revoke staging-smoke", self.aliases)
        self.assertEqual(d, [("sop-revoke", "staging-smoke", "")])

    def test_ack_with_note(self):
-        d = self.parse_ack_revoke(
-            "/sop-ack comprehensive-testing LGTM the test covers all edge cases"
+        d = sop.parse_directives(
+            "/sop-ack comprehensive-testing LGTM the test covers all edge cases",
+            self.aliases,
        )
        self.assertEqual(len(d), 1)
        self.assertEqual(d[0][0], "sop-ack")
@@ -157,12 +153,13 @@ class TestParseDirectives(unittest.TestCase):
        self.assertIn("LGTM", d[0][2])

    def test_numeric_shorthand(self):
-        d = self.parse_ack_revoke("/sop-ack 1")
+        d = sop.parse_directives("/sop-ack 1", self.aliases)
        self.assertEqual(d, [("sop-ack", "comprehensive-testing", "")])

    def test_revoke_with_reason(self):
-        d = self.parse_ack_revoke(
-            "/sop-revoke comprehensive-testing realized the e2e was mocking the DB"
+        d = sop.parse_directives(
+            "/sop-revoke comprehensive-testing realized the e2e was mocking the DB",
+            self.aliases,
        )
        self.assertEqual(d[0][0], "sop-revoke")
        self.assertEqual(d[0][1], "comprehensive-testing")
@@ -174,7 +171,7 @@ class TestParseDirectives(unittest.TestCase):
            "/sop-ack comprehensive-testing\n"
            "Will follow up on the doc nit separately."
        )
-        d = self.parse_ack_revoke(body)
+        d = sop.parse_directives(body, self.aliases)
        self.assertEqual(len(d), 1)
        self.assertEqual(d[0][1], "comprehensive-testing")

@@ -183,7 +180,7 @@ class TestParseDirectives(unittest.TestCase):
            "/sop-ack comprehensive-testing\n"
            "/sop-ack local-postgres-e2e\n"
        )
-        d = self.parse_ack_revoke(body)
+        d = sop.parse_directives(body, self.aliases)
        self.assertEqual(len(d), 2)
        slugs = {x[1] for x in d}
        self.assertEqual(slugs, {"comprehensive-testing", "local-postgres-e2e"})
@@ -192,21 +189,21 @@ class TestParseDirectives(unittest.TestCase):
        # A directive embedded mid-line is not honored (prevents review
        # comments like "to /sop-ack you need..." from acting as acks).
        body = "If you want to /sop-ack comprehensive-testing reply in this thread"
-        d = self.parse_ack_revoke(body)
+        d = sop.parse_directives(body, self.aliases)
        self.assertEqual(d, [])

    def test_leading_whitespace_allowed(self):
        body = "  /sop-ack comprehensive-testing"
-        d = self.parse_ack_revoke(body)
+        d = sop.parse_directives(body, self.aliases)
        self.assertEqual(len(d), 1)

    def test_empty_body(self):
-        self.assertEqual(sop.parse_directives("", self.aliases), ([], []))
-        self.assertEqual(sop.parse_directives(None, self.aliases), ([], []))
+        self.assertEqual(sop.parse_directives("", self.aliases), [])
+        self.assertEqual(sop.parse_directives(None, self.aliases), [])

    def test_normalization_applied(self):
        # /sop-ack Comprehensive_Testing → canonical comprehensive-testing
-        d = self.parse_ack_revoke("/sop-ack Comprehensive_Testing")
+        d = sop.parse_directives("/sop-ack Comprehensive_Testing", self.aliases)
        self.assertEqual(d[0][1], "comprehensive-testing")


@@ -32,7 +32,6 @@ THIS_DIR="$(cd "$(dirname "$0")" && pwd)"
 SCRIPT_DIR="$(cd "$THIS_DIR/.." && pwd)"
 WORKFLOW_DIR="$(cd "$THIS_DIR/../../workflows" && pwd)"
 WORKFLOW="$WORKFLOW_DIR/sop-tier-refire.yml"
-DISPATCH_WORKFLOW="$WORKFLOW_DIR/review-refire-comments.yml"
 SCRIPT="$SCRIPT_DIR/sop-tier-refire.sh"

 PASS=0
@@ -88,7 +87,6 @@ assert_file_exists() {
 echo
 echo "== existence =="
 assert_file_exists "workflow file exists"  "$WORKFLOW"
-assert_file_exists "dispatcher workflow file exists" "$DISPATCH_WORKFLOW"
 assert_file_exists "script file exists"    "$SCRIPT"
 if [ "$FAIL" -gt 0 ]; then
  echo
@@ -106,44 +104,30 @@ echo "== T6/T7 workflow yaml =="
 PARSE_OUT=$(python3 -c 'import sys,yaml;yaml.safe_load(open(sys.argv[1]).read());print("ok")' "$WORKFLOW" 2>&1 || true)
 assert_eq "T7 workflow parses as YAML" "ok" "$PARSE_OUT"

-# The old per-workflow issue_comment listener caused queue storms because
-# Gitea queues jobs before evaluating job-level `if:`. The script remains,
-# but comment-triggered refires route through the single dispatcher.
+# Three required gates in the `if:` expression
 WORKFLOW_CONTENT=$(cat "$WORKFLOW")
-if printf '%s' "$WORKFLOW_CONTENT" | grep -q '^  issue_comment:'; then
-  echo "  FAIL  T6a manual fallback workflow must not listen on issue_comment"
-  FAIL=$((FAIL + 1))
-  FAILED_TESTS="${FAILED_TESTS} T6a"
-else
-  echo "  PASS  T6a manual fallback workflow does not listen on issue_comment"
-  PASS=$((PASS + 1))
-fi
-assert_contains "T6b workflow exposes workflow_dispatch" \
-  "workflow_dispatch" "$WORKFLOW_CONTENT"
-assert_contains "T6c workflow documents unsupported manual inputs" \
-  "workflow_dispatch inputs" "$WORKFLOW_CONTENT"
+assert_contains "T6a workflow if: contains author_association gate" \
+  "github.event.comment.author_association" "$WORKFLOW_CONTENT"
+assert_contains "T6b workflow if: gates on MEMBER/OWNER/COLLABORATOR" \
+  '["MEMBER","OWNER","COLLABORATOR"]' "$WORKFLOW_CONTENT"
+assert_contains "T6c workflow if: contains slash-command trigger" \
+  "/refire-tier-check" "$WORKFLOW_CONTENT"
+assert_contains "T6d workflow if: gates on PR-not-issue" \
+  "github.event.issue.pull_request" "$WORKFLOW_CONTENT"
+assert_contains "T6e workflow listens on issue_comment" \
+  "issue_comment" "$WORKFLOW_CONTENT"
+assert_contains "T6f workflow requests statuses:write permission" \
+  "statuses: write" "$WORKFLOW_CONTENT"
 # Does NOT check out PR HEAD (security)
 if grep -q 'ref: \${{ github.event.pull_request.head' "$WORKFLOW"; then
-  echo "  FAIL  T6d workflow MUST NOT check out PR head (security)"
+  echo "  FAIL  T6g workflow MUST NOT check out PR head (security)"
  FAIL=$((FAIL + 1))
-  FAILED_TESTS="${FAILED_TESTS} T6d"
+  FAILED_TESTS="${FAILED_TESTS} T6g"
 else
-  echo "  PASS  T6d workflow does not check out PR head"
+  echo "  PASS  T6g workflow does not check out PR head"
  PASS=$((PASS + 1))
 fi

-DISPATCH_PARSE_OUT=$(python3 -c 'import sys,yaml;yaml.safe_load(open(sys.argv[1]).read());print("ok")' "$DISPATCH_WORKFLOW" 2>&1 || true)
-assert_eq "T6e dispatcher workflow parses as YAML" "ok" "$DISPATCH_PARSE_OUT"
-DISPATCH_CONTENT=$(cat "$DISPATCH_WORKFLOW")
-assert_contains "T6f dispatcher listens on issue_comment" \
-  "issue_comment" "$DISPATCH_CONTENT"
-assert_contains "T6g dispatcher handles /qa-recheck" \
-  "/qa-recheck" "$DISPATCH_CONTENT"
-assert_contains "T6h dispatcher handles /security-recheck" \
-  "/security-recheck" "$DISPATCH_CONTENT"
-assert_contains "T6i dispatcher handles /refire-tier-check" \
-  "/refire-tier-check" "$DISPATCH_CONTENT"
-
 # T1-T5 — script behavior against a local Gitea-fixture
 echo
 echo "== T1-T5 script behavior (vs local fixture) =="
@@ -107,39 +107,3 @@ items:
    description: >-
      List of feedback memories applicable to this change. Ack from
      any engineer who has the same memory access.
-
-# N/A gate declarations (RFC#324 §N/A follow-up).
-# PRs where a gate genuinely does not apply (e.g., pure-infra with no
-# qa surface, or docs-only) can be declared N/A by a non-author peer
-# who is in one of the gate's required_teams. The sop-checklist
-# posts a `sop-checklist / na-declarations (pull_request)` status that
-# review-check.sh reads to skip the Gitea-APPROVE requirement.
-#
-# Usage: any PR commenter (peer) posts:
-#   /sop-n/a qa-review  <reason>
-#   /sop-n/a security-review  <reason>
-#
-# Slash commands:
-#   /sop-n/a <gate> [reason] — declare gate N/A (most-recent per-user wins)
-#   /sop-revoke <gate>      — revoke prior N/A declaration for that gate
-#
-# Gate names must match the context strings used by review-check.sh:
-#   qa-review      → qa-review / approved (<event>)        [TEAM_ID=20]
-#   security-review → security-review / approved (<event>)  [TEAM_ID=21]
-#
-# required_teams: OR semantics — any team member can declare N/A.
-# Authors cannot self-declare N/A (enforced by gate script).
-n/a_gates:
-  qa-review:
-    required_teams: [qa, security, engineers]
-    description: >-
-      QA review N/A when this change has no qa surface (pure-infra,
-      tooling-only, revert, dependency-only). A qa/eng/security member
-      must post /sop-n/a qa-review to activate.
-
-  security-review:
-    required_teams: [security, managers, ceo]
-    description: >-
-      Security review N/A when this change has no security surface
-      (docs-only, pure-frontend, dependency-only). A security/owners
-      member must post /sop-n/a security-review to activate.
@@ -107,25 +107,16 @@ jobs:
            echo "scripts=true" >> "$GITHUB_OUTPUT"
            exit 0
          fi
-          # Workflow-only edits are covered by the workflow lint family
-          # and by this workflow's always-present required jobs. Do not fan
-          # those edits out into Go/Canvas/Python/shellcheck work; the
-          # downstream jobs still emit their required contexts via no-op
-          # steps when their surface flag is false.
-          #
-          # If the diff itself cannot be trusted, fail open by running every
-          # surface instead of silently under-testing the PR.
-          if ! DIFF=$(git diff --name-only "$BASE" HEAD 2>/dev/null); then
-            echo "platform=true" >> "$GITHUB_OUTPUT"
-            echo "canvas=true" >> "$GITHUB_OUTPUT"
-            echo "python=true" >> "$GITHUB_OUTPUT"
-            echo "scripts=true" >> "$GITHUB_OUTPUT"
-            exit 0
-          fi
-          echo "platform=$(echo "$DIFF" | grep -qE '^workspace-server/' && echo true || echo false)" >> "$GITHUB_OUTPUT"
-          echo "canvas=$(echo "$DIFF" | grep -qE '^canvas/' && echo true || echo false)" >> "$GITHUB_OUTPUT"
-          echo "python=$(echo "$DIFF" | grep -qE '^workspace/' && echo true || echo false)" >> "$GITHUB_OUTPUT"
-          echo "scripts=$(echo "$DIFF" | grep -qE '^tests/e2e/|^scripts/|^infra/scripts/' && echo true || echo false)" >> "$GITHUB_OUTPUT"
+          # Both .github/workflows/ci.yml AND .gitea/workflows/ci.yml count
+          # as "this workflow changed" — either edit should force-run every
+          # downstream job. The Gitea port follows the same shape as the
+          # GitHub original so behavior matches when triggered on either
+          # platform.
+          DIFF=$(git diff --name-only "$BASE" HEAD 2>/dev/null || echo ".gitea/workflows/ci.yml")
+          echo "platform=$(echo "$DIFF" | grep -qE '^workspace-server/|^\.gitea/workflows/ci\.yml$|^\.github/workflows/ci\.yml$' && echo true || echo false)" >> "$GITHUB_OUTPUT"
+          echo "canvas=$(echo "$DIFF" | grep -qE '^canvas/|^\.gitea/workflows/ci\.yml$|^\.github/workflows/ci\.yml$' && echo true || echo false)" >> "$GITHUB_OUTPUT"
+          echo "python=$(echo "$DIFF" | grep -qE '^workspace/|^\.gitea/workflows/ci\.yml$|^\.github/workflows/ci\.yml$' && echo true || echo false)" >> "$GITHUB_OUTPUT"
+          echo "scripts=$(echo "$DIFF" | grep -qE '^tests/e2e/|^scripts/|^infra/scripts/|^\.gitea/workflows/ci\.yml$|^\.github/workflows/ci\.yml$' && echo true || echo false)" >> "$GITHUB_OUTPUT"

  # Platform (Go) — Go build/vet/test/lint + coverage gates. The always-run
  # + per-step gating shape preserves the GitHub-side required-check name
@@ -135,21 +126,30 @@ jobs:
    name: Platform (Go)
    needs: changes
    runs-on: ubuntu-latest
-    # mc#774 (closed 2026-05-14): Phase 4 flip of the platform-build job.
-    # Phase 4 (#656) originally flipped this to continue-on-error: false based on
-    # Phase-3-masked "green on main 2026-05-12". Two failure classes then surfaced:
-    #   (1) 4x delegation_test.go sqlmock gaps (PR #669 / #634 fix-forward, closed).
-    #   (2) TestMCPHandler_CommitMemory_GlobalScope_Blocked (mcp_test.go:433):
-    #       OFFSEC-001 hardening collided with test assertion; tracked in mc#762.
-    # Fix-forward for (1) landed in PR #669. The mc#762 gap (2) is a separate
-    # issue — it does NOT block this flip because the test is already wrapped in
-    # the diagnostic step with its own continue-on-error: true (line 203).
-    # Flip confirmed by CI / Platform (Go) status = success on main HEAD 363905d3.
-    continue-on-error: false
-    # Job-level ceiling. The go test step below runs with a per-step 10m timeout;
-    # this cap catches any step that leaks past that. Set well above 10m so
-    # the per-step timeout is the active constraint.
-    timeout-minutes: 15
+    # mc#774 (interim): re-mask platform-build pending fix-forward. Phase 4
+    # (#656) flipped this to continue-on-error: false based on a Phase-3-masked
+    # "green on main 2026-05-12" — the prior continue-on-error: true had
+    # been hiding failing tests in workspace-server/internal/handlers/.
+    # Two distinct failure classes surfaced on 0e5152c3:
+    #   (1) 4x delegation_test.go (lines 1110/1176/1228/1271): helpers
+    #       expectExecuteDelegationBase/Success/Failed are missing sqlmock
+    #       expectations for queries production has issued since ~2026-04-21
+    #       (last_outbound_at UPDATE, lookupDeliveryMode/Runtime SELECTs,
+    #       a2a_receive INSERT activity_logs, recordLedgerStatus writes).
+    #       Halt cond #3 applies (regression > 7 days → broader sweep).
+    #   (2) 1x mcp_test.go:433 (TestMCPHandler_CommitMemory_GlobalScope_Blocked):
+    #       commit 7d1a189f (2026-05-10) hardened mcp.go to scrub err.Error()
+    #       from JSON-RPC responses (OFFSEC-001), but the test asserts the
+    #       error message contains "GLOBAL". Production-vs-test contract
+    #       collision — needs design call, not mock update.
+    # Time-boxed Option A (90 min) did not fit the cross-cutting scope.
+    # This is a sequenced revert→fix→reflip per
+    # feedback_strict_root_only_after_class_a emergency clause — NOT
+    # a permanent re-mask. Re-flip blocked on mc#774 fix-forward landing.
+    # Other 4 #656 flips (changes, canvas-build, shellcheck, python-lint)
+    # retain continue-on-error: false; only platform-build regresses.
+    # mc#774: pre-existing continue-on-error mask; root-fix and remove, do not renew silently.
+    continue-on-error: true  # mc#774 fix-forward in flight; re-flip when mc#774 lands (PR #669 → rebase after #709)
    defaults:
      run:
        working-directory: workspace-server
@@ -194,11 +194,7 @@ jobs:
        continue-on-error: true
      - if: needs.changes.outputs.platform == 'true'
        name: Run tests with race detection and coverage
-        # Explicit timeout: cold runner cache causes OOM kills at ~4m39s on the
-        # full ./... suite with race detection + coverage. A 10m per-step timeout
-        # lets the suite complete on cold cache (~5-7m) while failing cleanly
-        # instead of OOM-killing. The job-level timeout (15m) is a backstop.
-        run: go test -race -timeout 10m -coverprofile=coverage.out ./...
+        run: go test -race -coverprofile=coverage.out ./...

      - if: needs.changes.outputs.platform == 'true'
        name: Per-file coverage report
@@ -378,54 +374,23 @@ jobs:
        run: |
          bash tests/e2e/test_model_slug.sh

-      - if: needs.changes.outputs.scripts == 'true'
-        name: Test ECR promote-tenant-image script (mock-driven, no live infra)
-        # Covers scripts/promote-tenant-image.sh — the codified
-        # :staging-latest → :latest ECR promote + tenant fleet redeploy
-        # closing molecule-ai/molecule-core#660. 40 mock-driven cases
-        # exercise every exit path (preflight, snapshot, promote, redeploy
-        # 403→SSM-refresh, verify, rollback). No live AWS/CP/SSM calls.
-        run: |
-          bash scripts/test-promote-tenant-image.sh
-
-      - if: needs.changes.outputs.scripts == 'true'
-        name: Shellcheck promote-tenant-image script
-        # scripts/ is excluded from the bulk shellcheck pass above (legacy
-        # SC3040/SC3043 cleanup pending). Run shellcheck explicitly on
-        # the promote script + its test harness so regressions there are
-        # caught by the required check.
-        run: |
-          shellcheck --severity=warning \
-            scripts/promote-tenant-image.sh \
-            scripts/test-promote-tenant-image.sh
-
  canvas-deploy-reminder:
    name: Canvas Deploy Reminder
    runs-on: ubuntu-latest
    # mc#774: pre-existing continue-on-error mask; root-fix and remove, do not renew silently.
    continue-on-error: true
    needs: [changes, canvas-build]
-    # Keep the job itself always runnable. Gitea 1.22.6 leaves job-level
-    # event/ref `if:` gates as pending on PRs, which blocks the combined
-    # status even though this reminder is intentionally non-required.
+    # Only fires on direct pushes to main (i.e. after staging→main promotion).
+    if: needs.changes.outputs.canvas == 'true' && github.event_name == 'push' && github.ref == 'refs/heads/main'
    steps:
      - name: Write deploy reminder to step summary
        env:
          COMMIT_SHA: ${{ github.sha }}
-          CANVAS_CHANGED: ${{ needs.changes.outputs.canvas }}
-          EVENT_NAME: ${{ github.event_name }}
-          REF_NAME: ${{ github.ref }}
          # github.server_url resolves via the workflow-level env override
          # to the Gitea instance, so the RUN_URL points at the Gitea run
          # page (not github.com). See feedback_act_runner_github_server_url.
          RUN_URL: ${{ github.server_url }}/${{ github.repository }}/actions/runs/${{ github.run_id }}
        run: |
-          set -euo pipefail
-          if [ "$CANVAS_CHANGED" != "true" ] || [ "$EVENT_NAME" != "push" ] || [ "$REF_NAME" != "refs/heads/main" ]; then
-            echo "Canvas deploy reminder not applicable for event=$EVENT_NAME ref=$REF_NAME canvas_changed=$CANVAS_CHANGED."
-            exit 0
-          fi
-
          # Write body to a temp file — avoids backtick escaping in shell.
          cat > /tmp/deploy-reminder.md << 'BODY'
          ## Canvas build passed — deploy required
@@ -570,11 +535,11 @@ jobs:
    #     hourly if this list diverges from status_check_contexts or from
    #     audit-force-merge.yml's REQUIRED_CHECKS env (RFC §4 + §6).
    #
-    # canvas-deploy-reminder is intentionally excluded from all-required.needs:
-    # it needs canvas-build, which is skipped on CI-only PRs (canvas=false).
-    # Including it in all-required.needs causes all-required to hang on
-    # every CI-only PR. Keep it runnable on PRs via its own
-    # `needs: [changes, canvas-build]` — the sentinel only aggregates the result.
+    # Excluded from `needs:`: `canvas-deploy-reminder` — gated by
+    # `if: ... github.event_name == 'push' && github.ref == 'refs/heads/main'`,
+    # so on PR events it's legitimately `skipped`. The drift detector
+    # explicitly excludes `github.event_name`-gated jobs from F1 (see
+    # `.gitea/scripts/ci-required-drift.py::ci_job_names`).
    #
    # Phase 3 (RFC #219 §1) safety: underlying build jobs carry
    # continue-on-error: true so their failures are masked to null (2026-05-12: re-enabled mc#774 interim)
@@ -594,7 +559,7 @@ jobs:
      - canvas-build
      - shellcheck
      - python-lint
-    if: ${{ always() }}
+    if: always()
    steps:
      - name: Assert every required dependency succeeded
        run: |
@@ -48,9 +48,4 @@ jobs:
          REQUIRED_CONTEXTS: >-
            CI / all-required (pull_request),
            sop-checklist / all-items-acked (pull_request)
-          # Push-side required contexts. Checking CI / all-required (push)
-          # explicitly instead of the combined state avoids false-pause when
-          # non-blocking jobs (continue-on-error: true) have failed — those
-          # failures pollute combined state but do not gate merges.
-          PUSH_REQUIRED_CONTEXTS: CI / all-required (push)
        run: python3 .gitea/scripts/gitea-merge-queue.py
@@ -90,25 +90,18 @@ jobs:
      - id: filter
        # Inline replacement for dorny/paths-filter — see e2e-api.yml.
        run: |
-          # Gitea Actions evaluates github.event.before to empty string in shell
-          # scripts. Use GITHUB_EVENT_BEFORE shell env var instead (Gitea
-          # correctly populates it for push events). PR case uses template var.
-          BASE=""
+          BASE="${GITHUB_BASE_REF:-${{ github.event.before }}}"
          if [ "${{ github.event_name }}" = "pull_request" ] && [ -n "${{ github.event.pull_request.base.sha }}" ]; then
            BASE="${{ github.event.pull_request.base.sha }}"
-          elif [ -n "$GITHUB_EVENT_BEFORE" ]; then
-            BASE="$GITHUB_EVENT_BEFORE"
          fi
          if [ -z "$BASE" ] || echo "$BASE" | grep -qE '^0+$'; then
            echo "handlers=true" >> "$GITHUB_OUTPUT"
            exit 0
          fi
-          # timeout 30 guards against the case where BASE points to a ref that
-          # git can resolve but cat-file hangs (rare on corrupted objects).
-          if ! timeout 30 git cat-file -e "$BASE" 2>/dev/null; then
+          if ! git cat-file -e "$BASE" 2>/dev/null; then
            git fetch --depth=1 origin "$BASE" 2>/dev/null || true
          fi
-          if ! timeout 30 git cat-file -e "$BASE" 2>/dev/null; then
+          if ! git cat-file -e "$BASE" 2>/dev/null; then
            echo "handlers=true" >> "$GITHUB_OUTPUT"
            exit 0
          fi
@@ -37,6 +37,12 @@ name: publish-workspace-server-image
 on:
  push:
    branches: [main]
+    paths:
+      - 'workspace-server/**'
+      - 'canvas/**'
+      - 'manifest.json'
+      - 'scripts/**'
+      - '.gitea/workflows/publish-workspace-server-image.yml'
  workflow_dispatch:

 # No `concurrency:` block here. Gitea 1.22.6 can cancel queued runs despite
@@ -68,14 +74,12 @@ jobs:
          set -euo pipefail
          echo "::group::Docker daemon health check"
          echo "Runner: ${HOSTNAME:-unknown}"
-          docker_info="$(docker info 2>&1)" || {
+          docker info 2>&1 | head -5 || {
            echo "::error::Docker daemon is not accessible at /var/run/docker.sock"
            echo "::error::Runner: ${HOSTNAME:-unknown}"
-            printf '%s\n' "${docker_info}"
            echo "::error::Check: (1) daemon is running, (2) runner user is in docker group, (3) sock permissions are 660+"
            exit 1
          }
-          printf '%s\n' "${docker_info}" | sed -n '1,5p'
          echo "Docker daemon OK"
          echo "::endgroup::"

@@ -9,10 +9,10 @@
 #   Triggers on:
 #     - `pull_request_target`: opened, synchronize, reopened
 #         → initial status posts when PR opens / re-pushes
-#     - comment refires are handled by `review-refire-comments.yml`
-#         → a single issue_comment dispatcher prevents every SOP/review
-#           comment from enqueueing separate qa/security/tier jobs on
-#           Gitea 1.22.6 before job-level `if:` can skip them.
+#     - `issue_comment`: /qa-recheck slash-command on the PR
+#         → manual re-fire after a QA reviewer clicks APPROVE
+#           (Gitea 1.22.6 doesn't re-fire on pull_request_review, per
+#           go-gitea/gitea#33700 + feedback_pull_request_review_no_refire)
 #   Workflow name = `qa-review` ; job name = `approved`.
 #   The job's own pass/fail conclusion publishes the status context
 #   `qa-review / approved (<event>)` — NO `POST /statuses` call → NO
@@ -85,6 +85,8 @@ name: qa-review
 on:
  pull_request_target:
    types: [opened, synchronize, reopened]
+  issue_comment:
+    types: [created]

 permissions:
  contents: read
@@ -95,10 +97,16 @@ jobs:
  approved:
    # Gate the job:
    #   - On pull_request_target events: always run.
-    # Comment-triggered refires live in review-refire-comments.yml. Keeping
-    # this workflow PR-only avoids comment-triggered queue storms.
+    #   - On issue_comment events: only when it's a PR comment and the body
+    #     contains the slash-command. NO privilege gate at the step level
+    #     (RFC#324 v1.3 §A1.1): a non-collaborator's /qa-recheck is fine
+    #     because the eval is read-only and idempotent — re-running it
+    #     just re-confirms whether a real team-member APPROVE exists.
    if: |
-      github.event_name == 'pull_request_target'
+      github.event_name == 'pull_request_target' ||
+      (github.event_name == 'issue_comment' &&
+       github.event.issue.pull_request != null &&
+       startsWith(github.event.comment.body, '/qa-recheck'))
    runs-on: ubuntu-latest
    steps:
      - name: Privilege check (A1.1 — INFORMATIONAL log only, NOT a gate)
@@ -112,7 +120,7 @@ jobs:
        # no comment.user.login so the step is a no-op skip there.
        if: github.event_name == 'issue_comment'
        env:
-          GITEA_TOKEN: ${{ secrets.SOP_TIER_CHECK_TOKEN || secrets.GITHUB_TOKEN }}
+          GITEA_TOKEN: ${{ secrets.RFC_324_TEAM_READ_TOKEN || secrets.GITHUB_TOKEN }}
        run: |
          set -euo pipefail
          login="${{ github.event.comment.user.login }}"
@@ -143,7 +151,7 @@ jobs:

      - name: Evaluate qa-review
        env:
-          GITEA_TOKEN: ${{ secrets.SOP_TIER_CHECK_TOKEN || secrets.GITHUB_TOKEN }}
+          GITEA_TOKEN: ${{ secrets.RFC_324_TEAM_READ_TOKEN || secrets.GITHUB_TOKEN }}
          GITEA_HOST: git.moleculesai.app
          REPO: ${{ github.repository }}
          # PR number lives in different places per event:
@@ -9,17 +9,19 @@ name: redeploy-tenants-on-main
 #   - Workflow-level env.GITHUB_SERVER_URL pinned per
 #     feedback_act_runner_github_server_url.
 #   - `continue-on-error: true` on each job (RFC §1 contract).
-#   - Dropped unsupported `workflow_run` (task #81).
-#   - Later changed to manual-only after publish-workspace-server-image.yml
-#     gained an integrated ordered production deploy job.
+#   - ~~**Gitea workflow_run trigger limitation**~~ FIXED: replaced with
+#     push+paths filter per this PR. Gitea 1.22.6 does not support
+#     `workflow_run` (task #81). The push trigger fires on every
+#     commit to publish-workspace-server-image.yml which is the
+#     same signal (only successful runs commit to main).
 #

-# Manual production tenant redeploy/rollback helper.
+# Auto-refresh prod tenant EC2s after every main merge.
 #
-# Why this workflow is manual-only: publish-workspace-server-image now owns
-# the ordered build -> push -> production auto-deploy sequence in one workflow.
-# A separate push-triggered redeploy workflow races before the new ECR image
-# exists and can paint main red with a false deployment failure.
+# Why this workflow exists: publish-workspace-server-image builds and
+# pushes a new platform-tenant :<sha> to ECR on every merge to main,
+# but running tenants pulled their image once at boot and never re-pull.
+# Users see stale code indefinitely.
 #
 # This workflow closes the gap by calling the control-plane admin
 # endpoint that performs a canary-first, batched, health-gated rolling
@@ -32,26 +34,36 @@ name: redeploy-tenants-on-main
 # Gitea suspension migration. The staging-verify.yml promote step now
 # uses the same redeploy-fleet endpoint (fixes the silent-GHCR gap).
 #
-# Runtime ordering for automatic deploys now lives in
-# publish-workspace-server-image.yml:
-#   1. build-and-push creates new :staging-<sha> images in ECR.
-#   2. deploy-production waits for required push contexts on that SHA.
-#   3. deploy-production calls redeploy-fleet canary-first.
+# Runtime ordering:
+#   1. publish-workspace-server-image completes → new :staging-<sha> in ECR.
+#   2. This workflow fires via workflow_run, calls redeploy-fleet with
+#      target_tag=staging-<sha>. No CDN propagation wait needed —
+#      ECR image manifest is consistent immediately after push.
+#   3. Calls redeploy-fleet with canary_slug (if set) and a soak
+#      period. Canary proves the image boots; batches follow.
+#   4. Any failure aborts the rollout and leaves older tenants on the
+#      prior image — safer default than half-and-half state.
 #
-# Rollback path: set PROD_MANUAL_REDEPLOY_TARGET_TAG as a repo/org
-# variable or secret, run workflow_dispatch, then unset it after the
-# rollback. That calls redeploy-fleet with target_tag=<value>,
-# re-pulling the pinned image on every tenant.
+# Rollback path: re-run this workflow with a specific SHA pinned via
+# the workflow_dispatch input. That calls redeploy-fleet with
+# target_tag=<sha>, re-pulling the older image on every tenant.

 on:
+  push:
+    branches: [main]
+    paths:
+      - '.gitea/workflows/publish-workspace-server-image.yml'
  workflow_dispatch:
 permissions:
  contents: read
  # No write scopes needed — the workflow hits an external CP endpoint,
  # not the GitHub API.

-# Serialize manual redeploys so two operator-triggered rollbacks do not
-# overlap and cause confusing per-tenant SSM state.
+# Serialize redeploys so two rapid main pushes' redeploys don't overlap
+# and cause confusing per-tenant SSM state. Without this, GitHub's
+# implicit workflow_run queueing would *probably* serialize them, but
+# the explicit block makes the invariant defensible. Mirrors the
+# concurrency block on redeploy-tenants-on-staging.yml for shape parity.
 #
 # NOTE: cancel-in-progress: false removed (Rule 7 fix). Gitea 1.22.6
 # cancels queued runs regardless of this setting, so it provides no
@@ -65,17 +77,22 @@ env:
  GITHUB_SERVER_URL: https://git.moleculesai.app

 jobs:
-  # bp-exempt: production redeploy is a side-effect workflow, not a merge gate.
  redeploy:
-    if: ${{ github.event_name == 'workflow_dispatch' }}
+    # Skip the auto-trigger if publish-workspace-server-image didn't
+    # actually succeed. workflow_run fires on any completion state; we
+    # don't want to redeploy against a half-built image.
+    # NOTE (Gitea port): workflow_dispatch trigger dropped; only the
+    # workflow_run path remains.
+    if: ${{ github.event.workflow_run.conclusion == 'success' }}
    runs-on: ubuntu-latest
    # Phase 3 (RFC #219 §1): surface broken workflows without blocking.
    # mc#774: pre-existing continue-on-error mask; root-fix and remove, do not renew silently.
    continue-on-error: true
    timeout-minutes: 25
    env:
-      # Rule 9 fix: keep the same operational kill switch surface as the
-      # integrated auto-deploy workflow.
+      # Rule 9 fix: operational kill switch for auto-triggered deployments.
+      # Set repo variable or secret PROD_AUTO_DEPLOY_DISABLED=true to prevent
+      # this workflow from redeploying. Manual workflow_dispatch bypasses this.
      PROD_AUTO_DEPLOY_DISABLED: ${{ vars.PROD_AUTO_DEPLOY_DISABLED || secrets.PROD_AUTO_DEPLOY_DISABLED || '' }}
    steps:
      - name: Kill-switch guard
@@ -97,16 +114,21 @@ jobs:
        #      tag) → used verbatim. Lets ops pin `latest` for emergency
        #      rollback to last canary-verified digest, or pin a specific
        #      `staging-<sha>` to roll back to a known-good build.
-        #   2. Default → `staging-<short_head_sha>` for manual reruns from
-        #      the current default-branch SHA.
+        #   2. Default → `staging-<short_head_sha>`. The just-published
+        #      digest. Bypasses the `:latest` retag path that's currently
+        #      dead (staging-verify soft-skips without canary fleet, so
+        #      the only thing retagging `:latest` today is the manual
+        #      promote-latest.yml — last run 2026-04-28). Auto-trigger
+        #      from workflow_run uses workflow_run.head_sha; manual
+        #      dispatch with no input falls through to github.sha.
        env:
-          PROD_MANUAL_REDEPLOY_TARGET_TAG: ${{ vars.PROD_MANUAL_REDEPLOY_TARGET_TAG || secrets.PROD_MANUAL_REDEPLOY_TARGET_TAG || '' }}
-          HEAD_SHA: ${{ github.sha }}
+          INPUT_TAG: ${{ inputs.target_tag }}
+          HEAD_SHA: ${{ github.event.workflow_run.head_sha || github.sha }}
        run: |
          set -euo pipefail
-          if [ -n "${PROD_MANUAL_REDEPLOY_TARGET_TAG:-}" ]; then
-            echo "target_tag=$PROD_MANUAL_REDEPLOY_TARGET_TAG" >> "$GITHUB_OUTPUT"
-            echo "Using operator-pinned tag from PROD_MANUAL_REDEPLOY_TARGET_TAG."
+          if [ -n "${INPUT_TAG:-}" ]; then
+            echo "target_tag=$INPUT_TAG" >> "$GITHUB_OUTPUT"
+            echo "Using operator-pinned tag: $INPUT_TAG"
          else
            SHORT="${HEAD_SHA:0:7}"
            echo "target_tag=staging-$SHORT" >> "$GITHUB_OUTPUT"
@@ -122,26 +144,13 @@ jobs:
          CP_URL: ${{ vars.CP_URL || 'https://api.moleculesai.app' }}
          CP_ADMIN_API_TOKEN: ${{ secrets.CP_ADMIN_API_TOKEN }}
          TARGET_TAG: ${{ steps.tag.outputs.target_tag }}
-          CANARY_SLUG: ${{ vars.PROD_REDEPLOY_CANARY_SLUG || secrets.PROD_REDEPLOY_CANARY_SLUG || '' }}
-          SOAK_SECONDS: ${{ vars.PROD_REDEPLOY_SOAK_SECONDS || secrets.PROD_REDEPLOY_SOAK_SECONDS || '' }}
-          BATCH_SIZE: ${{ vars.PROD_REDEPLOY_BATCH_SIZE || secrets.PROD_REDEPLOY_BATCH_SIZE || '' }}
-          DRY_RUN: ${{ vars.PROD_REDEPLOY_DRY_RUN || secrets.PROD_REDEPLOY_DRY_RUN || '' }}
-          PROD_AUTO_DEPLOY_DISABLED: ${{ vars.PROD_AUTO_DEPLOY_DISABLED || secrets.PROD_AUTO_DEPLOY_DISABLED || '' }}
+          CANARY_SLUG: ${{ inputs.canary_slug || 'hongming' }}
+          SOAK_SECONDS: ${{ inputs.soak_seconds || '60' }}
+          BATCH_SIZE: ${{ inputs.batch_size || '3' }}
+          DRY_RUN: ${{ inputs.dry_run || false }}
        run: |
          set -euo pipefail

-          case "${PROD_AUTO_DEPLOY_DISABLED,,}" in
-            1|true|yes|on)
-              echo "::notice::PROD_AUTO_DEPLOY_DISABLED is set; skipping production redeploy."
-              exit 0
-              ;;
-          esac
-
-          CANARY_SLUG="${CANARY_SLUG:-hongming}"
-          SOAK_SECONDS="${SOAK_SECONDS:-60}"
-          BATCH_SIZE="${BATCH_SIZE:-3}"
-          DRY_RUN="${DRY_RUN:-false}"
-
          if [ -z "${CP_ADMIN_API_TOKEN:-}" ]; then
            echo "::error::CP_ADMIN_API_TOKEN secret not set — skipping redeploy"
            echo "::notice::Set CP_ADMIN_API_TOKEN in repo secrets to enable auto-redeploy."
@@ -163,7 +172,7 @@ jobs:
            }')

          echo "POST $CP_URL/cp/admin/tenants/redeploy-fleet"
-          echo "  target_tag=$TARGET_TAG canary=$CANARY_SLUG soak_seconds=$SOAK_SECONDS batch_size=$BATCH_SIZE dry_run=$DRY_RUN"
+          echo "  body: $BODY"

          HTTP_RESPONSE=$(mktemp)
          HTTP_CODE_FILE=$(mktemp)
@@ -252,11 +261,13 @@ jobs:
        # fail the workflow, which is what `ok=true` should have
        # guaranteed all along.
        #
-        # When the redeploy is triggered manually with a specific tag
-        # (target_tag != "latest"), the expected SHA may not equal
-        # ${{ github.sha }}.
+        # When the redeploy was triggered by workflow_dispatch with a
+        # specific tag (target_tag != "latest"), the expected SHA may
+        # not equal ${{ github.sha }} — in that case we resolve via
+        # GHCR's manifest. For workflow_run (default :latest) the
+        # workflow_run.head_sha is the SHA that just published.
        env:
-          EXPECTED_SHA: ${{ github.sha }}
+          EXPECTED_SHA: ${{ github.event.workflow_run.head_sha || github.sha }}
          TARGET_TAG: ${{ steps.tag.outputs.target_tag }}
          # Tenant subdomain template — slugs from the response are
          # appended. Production CP issues `<slug>.moleculesai.app`;
@@ -270,10 +281,10 @@ jobs:
          if [ "$TARGET_TAG" != "latest" ] \
             && [ "$TARGET_TAG" != "$EXPECTED_SHA" ] \
             && [ "$TARGET_TAG" != "staging-$EXPECTED_SHORT" ]; then
-            # Manual redeploy with a pinned tag that isn't the head
+            # workflow_dispatch with a pinned tag that isn't the head
            # SHA — operator is rolling back / pinning. Skip the
            # verification because we don't have the expected SHA in
-            # this context (would need to inspect the ECR
+            # this context (would need to crane-inspect the GHCR
            # manifest, which is a follow-up). Failing-open here is
            # safe: the operator chose the tag deliberately.
            #
@@ -1,109 +0,0 @@
-# Consolidated comment dispatcher for manual review/tier refires.
-#
-# Gitea 1.22 queues one run per workflow subscribed to `issue_comment` before
-# evaluating job-level `if:`. SOP-heavy PRs therefore created queue storms when
-# qa-review, security-review, sop-checklist, and sop-tier-refire all
-# listened to comments. This workflow is the single non-SOP comment subscriber:
-# ordinary comments no-op quickly; slash commands post the required status
-# contexts to the PR head SHA.
-
-name: review-refire-comments
-
-on:
-  issue_comment:
-    types: [created]
-
-permissions:
-  contents: read
-  pull-requests: read
-  statuses: write
-
-jobs:
-  dispatch:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Classify comment
-        id: classify
-        env:
-          COMMENT_BODY: ${{ github.event.comment.body }}
-          IS_PR: ${{ github.event.issue.pull_request != null }}
-        run: |
-          set -euo pipefail
-          {
-            echo "run_qa=false"
-            echo "run_security=false"
-            echo "run_tier=false"
-          } >> "$GITHUB_OUTPUT"
-          if [ "$IS_PR" != "true" ]; then
-            echo "::notice::not a PR comment; no-op"
-            exit 0
-          fi
-          first_line=$(printf '%s\n' "$COMMENT_BODY" | sed -n '1p')
-          case "$first_line" in
-            /qa-recheck*)
-              echo "run_qa=true" >> "$GITHUB_OUTPUT"
-              ;;
-            /security-recheck*)
-              echo "run_security=true" >> "$GITHUB_OUTPUT"
-              ;;
-            /refire-tier-check*)
-              echo "run_tier=true" >> "$GITHUB_OUTPUT"
-              ;;
-            *)
-              echo "::notice::no supported review refire slash command; no-op"
-              ;;
-          esac
-
-      - name: Check out BASE ref for trusted scripts
-        if: |
-          steps.classify.outputs.run_qa == 'true' ||
-          steps.classify.outputs.run_security == 'true' ||
-          steps.classify.outputs.run_tier == 'true'
-        uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd  # v6.0.2
-        with:
-          ref: ${{ github.event.repository.default_branch }}
-
-      - name: Refire qa-review status
-        if: steps.classify.outputs.run_qa == 'true'
-        env:
-          GITEA_TOKEN: ${{ secrets.RFC_324_TEAM_READ_TOKEN || secrets.GITHUB_TOKEN }}
-          GITEA_HOST: git.moleculesai.app
-          REPO: ${{ github.repository }}
-          PR_NUMBER: ${{ github.event.issue.number }}
-          DEFAULT_BRANCH: ${{ github.event.repository.default_branch }}
-          TEAM: qa
-          TEAM_ID: '20'
-          REVIEW_CHECK_DEBUG: '0'
-          REVIEW_CHECK_STRICT: '0'
-          COMMENT_AUTHOR: ${{ github.event.comment.user.login }}
-        run: |
-          set -euo pipefail
-          .gitea/scripts/review-refire-status.sh
-
-      - name: Refire security-review status
-        if: steps.classify.outputs.run_security == 'true'
-        env:
-          GITEA_TOKEN: ${{ secrets.RFC_324_TEAM_READ_TOKEN || secrets.GITHUB_TOKEN }}
-          GITEA_HOST: git.moleculesai.app
-          REPO: ${{ github.repository }}
-          PR_NUMBER: ${{ github.event.issue.number }}
-          DEFAULT_BRANCH: ${{ github.event.repository.default_branch }}
-          TEAM: security
-          TEAM_ID: '21'
-          REVIEW_CHECK_DEBUG: '0'
-          REVIEW_CHECK_STRICT: '0'
-          COMMENT_AUTHOR: ${{ github.event.comment.user.login }}
-        run: |
-          set -euo pipefail
-          .gitea/scripts/review-refire-status.sh
-
-      - name: Refire sop-tier-check status
-        if: steps.classify.outputs.run_tier == 'true'
-        env:
-          GITEA_TOKEN: ${{ secrets.SOP_TIER_CHECK_TOKEN || secrets.GITHUB_TOKEN }}
-          GITEA_HOST: git.moleculesai.app
-          REPO: ${{ github.repository }}
-          PR_NUMBER: ${{ github.event.issue.number }}
-          COMMENT_AUTHOR: ${{ github.event.comment.user.login }}
-          SOP_DEBUG: '0'
-        run: bash .gitea/scripts/sop-tier-refire.sh
@@ -66,28 +66,19 @@ jobs:
          # PR#372's ci.yml port used. Diffs against the PR base or the
          # previous push SHA, then matches against the wheel-relevant
          # path set.
-          #
-          # NOTE: Gitea Actions does not expose github.event.before as a
-          # shell environment variable. The ${{ github.event.before }} template
-          # expression works inside YAML run: blocks but is evaluated to an
-          # empty string for push events, making the ${VAR:-fallback} always
-          # use the fallback. Use GITHUB_EVENT_BEFORE instead — it IS set in
-          # the runner's shell environment for push events.
-          BASE=""
-          if [ "${{ github.event_name }}" = "pull_request" ]; then
+          BASE="${GITHUB_BASE_REF:-${{ github.event.before }}}"
+          if [ "${{ github.event_name }}" = "pull_request" ] && [ -n "${{ github.event.pull_request.base.sha }}" ]; then
            BASE="${{ github.event.pull_request.base.sha }}"
-          elif [ -n "$GITHUB_EVENT_BEFORE" ]; then
-            BASE="$GITHUB_EVENT_BEFORE"
          fi
          if [ -z "$BASE" ] || echo "$BASE" | grep -qE '^0+$'; then
            # New branch or no previous SHA: treat as wheel-relevant.
            echo "wheel=true" >> "$GITHUB_OUTPUT"
            exit 0
          fi
-          if ! timeout 30 git cat-file -e "$BASE" 2>/dev/null; then
+          if ! git cat-file -e "$BASE" 2>/dev/null; then
            git fetch --depth=1 origin "$BASE" 2>/dev/null || true
          fi
-          if ! timeout 30 git cat-file -e "$BASE" 2>/dev/null; then
+          if ! git cat-file -e "$BASE" 2>/dev/null; then
            echo "wheel=true" >> "$GITHUB_OUTPUT"
            exit 0
          fi
@@ -12,6 +12,8 @@ name: security-review
 on:
  pull_request_target:
    types: [opened, synchronize, reopened]
+  issue_comment:
+    types: [created]

 permissions:
  contents: read
@@ -20,10 +22,13 @@ permissions:
 jobs:
  # bp-exempt: PR security review bot signal; required merge state is enforced by CI / all-required.
  approved:
-    # Comment-triggered refires live in review-refire-comments.yml. Keeping
-    # this workflow PR-only avoids comment-triggered queue storms.
+    # See qa-review.yml header for full A1-α / A1.1 (v1.3 — informational
+    # log only, NOT a gate) / A4 / A5 design rationale.
    if: |
-      github.event_name == 'pull_request_target'
+      github.event_name == 'pull_request_target' ||
+      (github.event_name == 'issue_comment' &&
+       github.event.issue.pull_request != null &&
+       startsWith(github.event.comment.body, '/security-recheck'))
    runs-on: ubuntu-latest
    steps:
      - name: Privilege check (A1.1 — INFORMATIONAL log only, NOT a gate)
@@ -32,7 +37,7 @@ jobs:
        # so re-running on a non-collaborator comment is harmless.
        if: github.event_name == 'issue_comment'
        env:
-          GITEA_TOKEN: ${{ secrets.SOP_TIER_CHECK_TOKEN || secrets.GITHUB_TOKEN }}
+          GITEA_TOKEN: ${{ secrets.RFC_324_TEAM_READ_TOKEN || secrets.GITHUB_TOKEN }}
        run: |
          set -euo pipefail
          login="${{ github.event.comment.user.login }}"
@@ -57,7 +62,7 @@ jobs:

      - name: Evaluate security-review
        env:
-          GITEA_TOKEN: ${{ secrets.SOP_TIER_CHECK_TOKEN || secrets.GITHUB_TOKEN }}
+          GITEA_TOKEN: ${{ secrets.RFC_324_TEAM_READ_TOKEN || secrets.GITHUB_TOKEN }}
          GITEA_HOST: git.moleculesai.app
          REPO: ${{ github.repository }}
          PR_NUMBER: ${{ github.event.pull_request.number || github.event.issue.number }}
@@ -1,4 +1,4 @@
-# sop-checklist — peer-ack merge gate for SOP-checklist items.
+# sop-checklist-gate — peer-ack merge gate for SOP-checklist items.
 #
 # RFC#351 Step 2 of 6 (implementation MVP).
 #
@@ -65,15 +65,7 @@
 # membership, compute, post status). Re-running on any event is safe —
 # the new status overwrites the previous one for the same context.

-name: sop-checklist
-
-# Cancel any in-progress runs for the same PR to prevent
-# stale runs from overwriting newer status contexts.
-concurrency:
-  group: ${{ github.repository }}-${{ github.event.pull_request.number }}
-  cancel-in-progress: true
-
-# bp-required: yes  ← emits sop-checklist / all-items-acked (pull_request)
+name: sop-checklist-gate

 on:
  pull_request_target:
@@ -91,7 +83,7 @@ permissions:
  statuses: write

 jobs:
-  all-items-acked:
+  gate:
    # Run on pull_request_target events always. On issue_comment events,
    # only when the comment is on a PR (issue_comment fires for issues
    # too) and the body contains one of the slash-commands.
@@ -100,8 +92,7 @@ jobs:
      (github.event_name == 'issue_comment' &&
       github.event.issue.pull_request != null &&
       (contains(github.event.comment.body, '/sop-ack') ||
-        contains(github.event.comment.body, '/sop-revoke') ||
-        contains(github.event.comment.body, '/sop-n/a')))
+        contains(github.event.comment.body, '/sop-revoke')))
    runs-on: ubuntu-latest
    steps:
      - name: Check out BASE ref (trust boundary — never PR-head)
@@ -114,7 +105,7 @@ jobs:
          # qa-review.yml so the script source is always trusted.
          ref: ${{ github.event.repository.default_branch }}

-      - name: Run sop-checklist
+      - name: Run sop-checklist-gate
        env:
          GITEA_TOKEN: ${{ secrets.SOP_CHECKLIST_GATE_TOKEN || secrets.GITHUB_TOKEN }}
          PR_NUMBER: ${{ github.event.pull_request.number || github.event.issue.number }}
@@ -122,7 +113,7 @@ jobs:
          REPO_NAME: ${{ github.event.repository.name }}
        run: |
          set -euo pipefail
-          python3 .gitea/scripts/sop-checklist.py \
+          python3 .gitea/scripts/sop-checklist-gate.py \
            --owner "$OWNER" \
            --repo "$REPO_NAME" \
            --pr "$PR_NUMBER" \
@@ -1,4 +1,4 @@
-# sop-tier-refire — manual fallback for sop-tier-check refire.
+# sop-tier-refire — issue_comment-triggered refire of sop-tier-check.
 #
 # Closes internal#292. Gitea 1.22.6 doesn't refire workflows on the
 # `pull_request_review` event (go-gitea/gitea#33700); the `sop-tier-check`
@@ -8,12 +8,12 @@
 # to merge is the admin force-merge path (audited via `audit-force-merge`
 # but the audit trail keeps growing; see `feedback_never_admin_merge_bypass`).
 #
-# Comment-triggered refires now live in `review-refire-comments.yml`. Gitea
-# queues issue_comment workflows before evaluating job-level `if:`, so having
-# qa-review, security-review, sop-checklist, and sop-tier-refire all subscribe
-# to every comment caused queue storms on SOP-heavy PRs. This workflow is a
-# non-automatic breadcrumb only; Gitea 1.22.6 does not support
-# workflow_dispatch inputs, so real refires must use `/refire-tier-check`.
+# Workaround pattern from `feedback_pull_request_review_no_refire`:
+# `issue_comment` events DO fire reliably on 1.22.6. When a repo
+# MEMBER/OWNER/COLLABORATOR comments `/refire-tier-check` on a PR, this
+# workflow re-runs the sop-tier-check logic and POSTs the resulting
+# status to the PR head SHA directly. No empty commit, no git history
+# bloat, no cascade re-fire of every other workflow on the PR.
 #
 # SECURITY MODEL:
 #
@@ -37,16 +37,43 @@
 # Rate-limit: a 1s pre-sleep + a "skip if status posted in last 30s"
 # guard prevents comment-spam from thrashing the status. See the script.

-name: sop-tier-check refire (manual)
+name: sop-tier-check refire (issue_comment)

 on:
-  workflow_dispatch:
+  issue_comment:
+    types: [created]

 jobs:
  refire:
+    # Three gates, all required:
+    #   - comment is on a PR (not a plain issue)
+    #   - commenter is MEMBER, OWNER, or COLLABORATOR
+    #   - comment body contains the slash-command trigger
+    if: |
+      github.event.issue.pull_request != null &&
+      contains(fromJson('["MEMBER","OWNER","COLLABORATOR"]'), github.event.comment.author_association) &&
+      contains(github.event.comment.body, '/refire-tier-check')
    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      pull-requests: read
+      statuses: write
    steps:
-      - name: Explain supported refire path
-        run: |
-          echo "::error::Gitea 1.22.6 does not support workflow_dispatch inputs here; comment /refire-tier-check on the PR instead."
-          exit 1
+      - name: Check out base branch (for the script)
+        uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd  # v6.0.2
+        with:
+          # Load the script from the default branch (main), matching the
+          # sop-tier-check.yml security model.
+          ref: ${{ github.event.repository.default_branch }}
+      - name: Re-evaluate sop-tier-check and POST status
+        env:
+          # Same org-level secret sop-tier-check.yml + audit-force-merge.yml use.
+          # Fallback to GITHUB_TOKEN with a clear error if missing.
+          GITEA_TOKEN: ${{ secrets.SOP_TIER_CHECK_TOKEN || secrets.GITHUB_TOKEN }}
+          GITEA_HOST: git.moleculesai.app
+          REPO: ${{ github.repository }}
+          PR_NUMBER: ${{ github.event.issue.number }}
+          COMMENT_AUTHOR: ${{ github.event.comment.user.login }}
+          # Set to '1' for diagnostic per-API-call output. Off by default.
+          SOP_DEBUG: '0'
+        run: bash .gitea/scripts/sop-tier-refire.sh
@@ -327,7 +327,7 @@ function OrgCTA({ org }: { org: Org }) {
    return (
      <a
        href={href}
-        className="rounded bg-emerald-700 px-4 py-2 text-sm font-medium text-white hover:bg-emerald-600"
+        className="rounded bg-emerald-600 px-4 py-2 text-sm font-medium text-white hover:bg-emerald-500"
      >
        Open
      </a>
@@ -337,7 +337,7 @@ function OrgCTA({ org }: { org: Org }) {
    return (
      <a
        href={`/pricing?org=${encodeURIComponent(org.slug)}`}
-        className="rounded bg-amber-800 px-4 py-2 text-sm font-medium text-white hover:bg-amber-700"
+        className="rounded bg-amber-600 px-4 py-2 text-sm font-medium text-white hover:bg-amber-500"
      >
        Complete payment
      </a>
@@ -8,17 +8,11 @@ import type { AuditEntry, AuditResponse } from "@/types/audit";

 type EventFilter = "all" | AuditEntry["event_type"];

-// Contrast note: text is rendered on near-black bg (bg-*-950/40). Every text
-// color below is chosen to pass WCAG 2.1 AA 4.5:1 on that background:
-//   blue-300   ( delegation ) ≈ 8.8:1
-//   violet-300 ( decision   ) ≈ 9.5:1
-//   yellow-200 ( gate       ) ≈ 11.5:1
-//   orange-300 ( hitl       ) ≈ 9.1:1
 const BADGE_COLORS: Record<AuditEntry["event_type"], { text: string; bg: string; border: string }> = {
-  delegation: { text: "text-blue-300",   bg: "bg-blue-950/40",   border: "border-blue-800/40" },
-  decision:   { text: "text-violet-300", bg: "bg-violet-950/40", border: "border-violet-800/40" },
-  gate:       { text: "text-yellow-200", bg: "bg-yellow-950/40", border: "border-yellow-800/40" },
-  hitl:       { text: "text-orange-300", bg: "bg-orange-950/40", border: "border-orange-800/40" },
+  delegation: { text: "text-accent",   bg: "bg-blue-950/40",   border: "border-blue-800/40" },
+  decision:   { text: "text-violet-400", bg: "bg-violet-950/40", border: "border-violet-800/40" },
+  gate:       { text: "text-yellow-400", bg: "bg-yellow-950/40", border: "border-yellow-800/40" },
+  hitl:       { text: "text-orange-400", bg: "bg-orange-950/40", border: "border-orange-800/40" },
 };

 const FILTERS: { id: EventFilter; label: string }[] = [
@@ -170,10 +164,7 @@ export function AuditTrailPanel({ workspaceId }: Props) {

      {/* Error banner */}
      {error && (
-        <div
-          role="alert"
-          className="mx-4 mt-3 px-3 py-2 bg-red-950/30 border border-red-800/40 rounded text-xs text-bad shrink-0"
-        >
+        <div className="mx-4 mt-3 px-3 py-2 bg-red-950/30 border border-red-800/40 rounded text-xs text-bad shrink-0">
          {error}
        </div>
      )}
@@ -251,6 +242,7 @@ export function AuditEntryRow({ entry, now }: AuditEntryRowProps) {
        {/* Event-type badge */}
        <span
          className={`shrink-0 text-[9px] font-semibold uppercase tracking-wider px-1.5 py-0.5 rounded border ${badge.text} ${badge.bg} ${badge.border}`}
+          aria-label={`Event type: ${entry.event_type}`}
        >
          {entry.event_type}
        </span>
@@ -100,8 +100,8 @@ export function BatchActionBar() {
      aria-label="Batch workspace actions"
      className="fixed bottom-6 left-1/2 -translate-x-1/2 z-[200] flex items-center gap-3 px-4 py-2.5 rounded-2xl bg-surface-sunken/95 border border-line/70 shadow-2xl shadow-black/50 backdrop-blur-md"
    >
-      {/* Selection count badge — bg-zinc-700 passes 7.2:1 on white text */}
-      <span className="text-[12px] font-semibold text-white bg-zinc-700 px-2.5 py-0.5 rounded-full tabular-nums">
+      {/* Selection count badge */}
+      <span className="text-[12px] font-semibold text-white bg-accent-strong/80 px-2.5 py-0.5 rounded-full tabular-nums">
        {count} selected
      </span>

@@ -112,7 +112,7 @@ export function BatchActionBar() {
        type="button"
        disabled={busy}
        onClick={() => setPending("restart")}
-        className="flex items-center gap-1.5 px-3 py-1.5 rounded-lg text-[12px] font-medium text-white bg-sky-900/30 hover:bg-sky-800/50 border border-sky-700/30 hover:border-sky-600/50 transition-colors disabled:opacity-50 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-sky-500/70"
+        className="flex items-center gap-1.5 px-3 py-1.5 rounded-lg text-[12px] font-medium text-sky-300 bg-sky-900/30 hover:bg-sky-800/50 border border-sky-700/30 hover:border-sky-600/50 transition-colors disabled:opacity-50 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-sky-500/70"
      >
        <span aria-hidden="true">↻</span>
        Restart All
@@ -122,7 +122,7 @@ export function BatchActionBar() {
        type="button"
        disabled={busy}
        onClick={() => setPending("pause")}
-        className="flex items-center gap-1.5 px-3 py-1.5 rounded-lg text-[12px] font-medium text-white bg-amber-900/30 hover:bg-amber-800/50 border border-amber-700/30 hover:border-amber-600/50 transition-colors disabled:opacity-50 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-amber-500/70"
+        className="flex items-center gap-1.5 px-3 py-1.5 rounded-lg text-[12px] font-medium text-warm bg-amber-900/30 hover:bg-amber-800/50 border border-amber-700/30 hover:border-amber-600/50 transition-colors disabled:opacity-50 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-amber-500/70"
      >
        <span aria-hidden="true">⏸</span>
        Pause All
@@ -132,7 +132,7 @@ export function BatchActionBar() {
        type="button"
        disabled={busy}
        onClick={() => setPending("delete")}
-        className="flex items-center gap-1.5 px-3 py-1.5 rounded-lg text-[12px] font-medium text-white bg-red-900/30 hover:bg-red-800/50 border border-red-700/30 hover:border-red-600/50 transition-colors disabled:opacity-50 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-red-500/70"
+        className="flex items-center gap-1.5 px-3 py-1.5 rounded-lg text-[12px] font-medium text-bad bg-red-900/30 hover:bg-red-800/50 border border-red-700/30 hover:border-red-600/50 transition-colors disabled:opacity-50 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-red-500/70"
      >
        <span aria-hidden="true">✕</span>
        Delete All
@@ -96,7 +96,7 @@ export function ConfirmDialog({
  // readable in both light and dark themes.
  const confirmColors =
    confirmVariant === "danger"
-      ? "bg-red-700 hover:bg-red-600 text-white"
+      ? "bg-red-600 hover:bg-red-700 text-white"
      : confirmVariant === "warning"
        ? "bg-amber-800 hover:bg-amber-700 text-white"
        : "bg-accent hover:bg-accent-strong text-white";
@@ -318,7 +318,7 @@ export function ContextMenu() {
            aria-hidden="true"
            className={`w-1.5 h-1.5 rounded-full ${statusDotClass(contextMenu.nodeData.status)}`}
          />
-          <span className="text-[10px] text-ink">{contextMenu.nodeData.status}</span>
+          <span className="text-[10px] text-ink-mid">{contextMenu.nodeData.status}</span>
        </div>
      </div>

@@ -187,7 +187,7 @@ export function ConversationTraceModal({ open, workspaceId: _workspaceId, onClos
                                isError
                                  ? "bg-red-950/50 text-bad"
                                  : isSend
-                                  ? "bg-cyan-950 text-cyan-300"
+                                  ? "bg-cyan-950/50 text-cyan-400"
                                  : isReceive
                                  ? "bg-blue-950/50 text-accent"
                                  : "bg-surface-card text-ink-mid"
@@ -251,7 +251,7 @@ export function ConversationTraceModal({ open, workspaceId: _workspaceId, onClos

                          {/* Error */}
                          {isError && entry.error_detail && (
-                            <div className="text-[10px] text-bad mt-1 truncate">
+                            <div className="text-[10px] text-bad/80 mt-1 truncate">
                              {entry.error_detail.slice(0, 200)}
                            </div>
                          )}
@@ -272,7 +272,7 @@ export function ConversationTraceModal({ open, workspaceId: _workspaceId, onClos
                          )}
                          {responseText && (
                            <div className="mt-1 bg-surface/60 border border-emerald-900/30 rounded-lg px-3 py-2 max-h-32 overflow-y-auto">
-                              <div className="text-[8px] text-good uppercase mb-1">Response</div>
+                              <div className="text-[8px] text-good/60 uppercase mb-1">Response</div>
                              <div className="text-[10px] text-ink-mid whitespace-pre-wrap break-words leading-relaxed">
                                {responseText.slice(0, 2000)}
                                {responseText.length > 2000 && (
@@ -126,8 +126,8 @@ export function DeleteCascadeConfirmDialog({

          {/* Cascade warning */}
          <div className="rounded border border-red-900/40 bg-red-950/20 px-3 py-2.5 mb-4">
-            <p className="text-[12px] text-red-300 leading-relaxed">
-              Deleting will cascade — <strong className="text-red-100">all child workspaces and their data will be permanently removed.</strong> This cannot be undone.
+            <p className="text-[12px] text-bad/80 leading-relaxed">
+              Deleting will cascade — <strong className="text-red-200">all child workspaces and their data will be permanently removed.</strong> This cannot be undone.
            </p>
          </div>

@@ -164,13 +164,13 @@ export function DeleteCascadeConfirmDialog({
            type="button"
            onClick={onConfirm}
            disabled={!checked}
-            // Hover goes DARKER, not lighter — bg-red-600 on white text
-            // drops contrast below AA. Same trap fixed in ConfirmDialog.
-            // focus-visible ring matches the canvas chrome.
+            // Hover goes DARKER, not lighter — bg-red-500 on white text
+            // drops contrast below AA vs bg-red-700. Same trap fixed in
+            // ConfirmDialog and ApprovalBanner. focus-visible ring matches.
            className={`px-3.5 py-1.5 text-[13px] rounded-lg transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-red-500/60 focus-visible:ring-offset-2 focus-visible:ring-offset-surface-sunken
              ${checked
-                ? "bg-red-700 hover:bg-red-600 text-white cursor-pointer"
-                : "bg-red-900/30 text-red-400 cursor-not-allowed"
+                ? "bg-red-600 hover:bg-red-700 text-white cursor-pointer"
+                : "bg-red-900/30 text-bad/40 cursor-not-allowed"
              }`}
          >
            Delete All
@@ -51,7 +51,7 @@ export class ErrorBoundary extends React.Component<
  render() {
    if (this.state.hasError) {
      return (
-        <div role="alert" aria-live="assertive" className="fixed inset-0 flex items-center justify-center bg-surface z-50">
+        <div className="fixed inset-0 flex items-center justify-center bg-surface z-50">
          <div className="max-w-md rounded-2xl border border-red-500/30 bg-surface-sunken/90 px-8 py-8 text-center shadow-2xl shadow-black/40">
            <div className="mx-auto mb-4 flex h-14 w-14 items-center justify-center rounded-full bg-red-500/10 border border-red-500/30">
              <svg
@@ -76,7 +76,7 @@ export class ErrorBoundary extends React.Component<
            <p className="text-sm text-ink-mid mb-1">
              An unexpected error occurred while rendering the application.
            </p>
-            <p className="text-xs text-bad mb-6 font-mono break-all">
+            <p className="text-xs text-bad/80 mb-6 font-mono break-all">
              {this.state.error?.message ?? "Unknown error"}
            </p>
            <div className="flex items-center justify-center gap-3">
@@ -360,7 +360,7 @@ function SnippetBlock({
        <button
          type="button"
          onClick={onCopy}
-          className="text-xs px-2 py-1 rounded bg-accent text-white hover:bg-accent-strong transition-colors focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-accent focus-visible:ring-offset-1"
+          className="text-xs px-2 py-1 rounded bg-accent-strong/80 hover:bg-accent text-white focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-accent focus-visible:ring-offset-1"
        >
          {copied ? "Copied!" : "Copy"}
        </button>
@@ -451,7 +451,7 @@ function ProviderPickerModal({
                    <button
                      onClick={() => handleSaveKey(index)}
                      disabled={!entry.value.trim() || entry.saving}
-                      className="px-3 py-1.5 bg-accent-strong hover:bg-accent text-[11px] rounded text-white disabled:opacity-30 transition-colors shrink-0 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-accent focus-visible:ring-offset-1"
+                      className="px-3 py-1.5 bg-accent-strong hover:bg-accent text-[11px] rounded text-white disabled:opacity-30 transition-colors shrink-0"
                    >
                      {entry.saving ? "..." : "Save"}
                    </button>
@@ -492,7 +492,7 @@ function ProviderPickerModal({
                !selectorValue.providerId ||
                (showModelInput && model.trim() === "")
              }
-              className="px-3.5 py-1.5 text-[12px] bg-accent-strong hover:bg-accent text-white rounded-lg transition-colors disabled:opacity-40 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-accent focus-visible:ring-offset-1"
+              className="px-3.5 py-1.5 text-[12px] bg-accent-strong hover:bg-accent text-white rounded-lg transition-colors disabled:opacity-40"
            >
              {allSaved ? "Deploy" : entries.length > 1 ? "Add Keys" : "Add Key"}
            </button>
@@ -420,7 +420,7 @@ export function ProviderModelSelector({
              spellCheck={false}
              autoComplete="off"
              data-testid="model-input"
-              className="w-full bg-surface-sunken border border-line rounded px-2 py-1.5 text-[11px] text-ink font-mono focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-accent focus-visible:ring-offset-1 focus-visible:border-accent transition-colors disabled:opacity-50"
+              className="w-full bg-surface-sunken border border-line rounded px-2 py-1.5 text-[11px] text-ink font-mono focus:outline-none focus:border-accent focus:ring-1 focus:ring-accent/20 transition-colors disabled:opacity-50"
            />
            <p className="text-[9px] text-ink-mid mt-1 leading-relaxed">
              {selected?.wildcard
@@ -389,7 +389,7 @@ export function ProvisioningTimeout({
              <button
                type="button"
                onClick={handleCancelConfirm}
-                className="px-3.5 py-1.5 text-[12px] bg-red-800 hover:bg-red-700 text-white rounded-lg transition-colors focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-red-400 focus-visible:ring-offset-1"
+                className="px-3.5 py-1.5 text-[12px] bg-red-600 hover:bg-red-500 text-white rounded-lg transition-colors focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-red-400 focus-visible:ring-offset-1"
              >
                Remove Workspace
              </button>
@@ -61,12 +61,8 @@ export function ThemeToggle({ className = "" }: { className?: string }) {
        return;
      }
      setTheme(OPTIONS[next].value);
-      // Move focus to the new button so arrow-key navigation is continuous.
-      // Use direct-child query to scope strictly to this radiogroup's buttons
-      // and avoid accidentally focusing unrelated [role=radio] elements
-      // elsewhere in the DOM (e.g. React Flow canvas nodes).
-      const radiogroup = e.currentTarget.closest("[role=radiogroup]") as HTMLElement | null;
-      const btns = radiogroup?.querySelectorAll<HTMLButtonElement>("> [role=radio]");
+      // Move focus to the new button so arrow-key navigation is continuous
+      const btns = (e.currentTarget.closest("[role=radiogroup]") as HTMLElement)?.querySelectorAll<HTMLButtonElement>("[role=radio]");
      btns?.[next]?.focus();
    },
    []
@@ -64,7 +64,6 @@ export function DropTargetBadge() {
      {ghostVisible && (
        <div
          data-testid="ghost-slot"
-          aria-hidden="true"
          className="pointer-events-none absolute z-40 rounded-lg border-2 border-dashed border-emerald-400/70 bg-emerald-500/10"
          style={{
            left: slotTL.x,
@@ -76,9 +75,7 @@ export function DropTargetBadge() {
      )}
      <div
        data-testid="drop-badge"
-        role="status"
-        aria-label={`Drop target: ${targetName}`}
-        className="pointer-events-none absolute z-50 -translate-x-1/2 -translate-y-full rounded-md bg-emerald-700 px-2 py-0.5 text-[11px] font-medium text-white shadow-lg shadow-emerald-950/40"
+        className="pointer-events-none absolute z-50 -translate-x-1/2 -translate-y-full rounded-md bg-emerald-500 px-2 py-0.5 text-[11px] font-medium text-white shadow-lg shadow-emerald-950/40"
        style={{ left: badge.x, top: badge.y - 6 }}
      >
        Drop into: {targetName}
@@ -307,7 +307,7 @@ function ActivityRow({

        {/* Error detail */}
        {isError && entry.error_detail && (
-          <div className="text-[9px] text-bad mt-1 truncate">
+          <div className="text-[9px] text-bad/80 mt-1 truncate">
            {entry.error_detail}
          </div>
        )}
@@ -358,10 +358,10 @@ function A2AErrorPreview({ label, raw }: { label: string; raw: string }) {
  const hint = inferA2AErrorHint(detail);
  return (
    <div>
-      <div className="text-[8px] text-bad uppercase tracking-wider mb-1">{label} — delivery failed</div>
+      <div className="text-[8px] text-bad/80 uppercase tracking-wider mb-1">{label} — delivery failed</div>
      <div className="text-[10px] text-bad bg-red-950/30 border border-red-800/40 rounded p-2 space-y-1.5">
        <div className="font-mono whitespace-pre-wrap break-words max-h-32 overflow-y-auto">{detail}</div>
-        <div className="text-[9px] text-bad leading-relaxed border-t border-red-800/30 pt-1.5">{hint}</div>
+        <div className="text-[9px] text-bad/70 leading-relaxed border-t border-red-800/30 pt-1.5">{hint}</div>
      </div>
    </div>
  );
@@ -977,7 +977,7 @@ function MyChatPanel({ workspaceId, data }: Props) {
            </p>
            <button
              onClick={loadInitial}
-              className="text-[10px] px-2 py-0.5 rounded bg-red-800 text-red-200 hover:bg-red-700 transition-colors"
+              className="text-[10px] px-2 py-0.5 rounded bg-red-800/40 text-bad hover:bg-red-700/50 transition-colors"
            >
              Retry
            </button>
@@ -1011,10 +1011,11 @@ function MyChatPanel({ workspaceId, data }: Props) {
            <div
              className={`max-w-[85%] rounded-lg px-3 py-2 text-xs ${
                msg.role === "user"
-                  // Blue-600 on white = 3.0:1 (WCAG AA FAIL) in light mode.
-                  // Blue-700 on white = 4.5:1 (PASS). In dark mode, blue-600
-                  // on zinc-800 = 4.9:1 (PASS). So: blue-700 light, blue-600 dark.
-                  ? "bg-blue-700 text-white border border-blue-800 dark:bg-blue-600 dark:border-blue-700 shadow-sm"
+                  // Solid blue-600 in both modes — `bg-accent` themes
+                  // lighter in dark, dropping white-text contrast to
+                  // ~3:1 (fails AA). blue-600 keeps ~5:1 against white
+                  // on both warm-paper and dark-slate panels.
+                  ? "bg-blue-600 text-white border border-blue-700 dark:bg-blue-500 dark:border-blue-400 shadow-sm"
                  : msg.role === "system"
                    // Bump the system bubble's opacity in dark — /10
                    // overlay was nearly invisible against the dark
@@ -1129,7 +1130,7 @@ function MyChatPanel({ workspaceId, data }: Props) {
                  ))}
                </div>
              )}
-              <div className={`text-[9px] mt-1 ${msg.role === "user" ? "text-white/80" : "text-ink-mid"}`}>
+              <div className={`text-[9px] mt-1 ${msg.role === "user" ? "text-white/70" : "text-ink-mid"}`}>
                {new Date(msg.timestamp).toLocaleTimeString()}
              </div>
            </div>
@@ -1169,11 +1170,11 @@ function MyChatPanel({ workspaceId, data }: Props) {
      {error && (
        <div className="px-3 py-2 bg-red-900/20 border-t border-red-800/30">
          <div className="flex items-center justify-between">
-            <span className="text-[10px] text-red-300">{error}</span>
+            <span className="text-[10px] text-bad">{error}</span>
            {!isOnline && (
              <button
                onClick={() => setConfirmRestart(true)}
-                className="text-[11px] px-2 py-0.5 bg-red-800 text-red-200 rounded hover:bg-red-700"
+                className="text-[11px] px-2 py-0.5 bg-red-800/40 text-bad rounded hover:bg-red-700/50"
              >
                Restart
              </button>
@@ -325,10 +325,10 @@ export function DetailsTab({ workspaceId, data }: Props) {
              <button
                type="button"
                onClick={handleDelete}
-                // Red-600 on white text = 3.9:1 (WCAG AA FAIL).
-                // Red-700 = 4.6:1 (PASS). Hover goes DARKER (red-600)
-                // to signal press. Same pattern as ConfirmDialog/DeleteCascade.
-                className="px-3 py-1 bg-red-700 hover:bg-red-600 text-xs rounded text-white transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-red-500/60 focus-visible:ring-offset-1 focus-visible:ring-offset-surface"
+                // hover:bg-red-500 LIGHTER on white text drops AA;
+                // flipped to bg-red-700 + focus-visible danger ring,
+                // matching the ConfirmDialog/DeleteCascade pattern.
+                className="px-3 py-1 bg-red-600 hover:bg-red-700 text-xs rounded text-white transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-red-500/60 focus-visible:ring-offset-1 focus-visible:ring-offset-surface"
              >
                Confirm Delete
              </button>
@@ -131,7 +131,7 @@ export function ExternalConnectionSection({ workspaceId }: Props) {
              <button
                type="button"
                onClick={doRotate}
-                className="px-3 py-1.5 bg-red-800 hover:bg-red-700 text-xs rounded text-white focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-red-500 focus-visible:ring-offset-1"
+                className="px-3 py-1.5 bg-red-700 hover:bg-red-600 text-xs rounded text-white focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-red-500 focus-visible:ring-offset-1"
              >
                Rotate
              </button>
@@ -226,7 +226,7 @@ function PlatformOwnedFilesTab({ workspaceId }: { workspaceId: string }) {
        <div role="alertdialog" aria-labelledby="files-delete-all-msg" className="mx-3 mt-2 px-3 py-2 bg-red-950/30 border border-red-800/40 rounded space-y-1.5">
          <p id="files-delete-all-msg" className="text-xs text-bad">Delete all {files.filter((f) => !f.dir).length} files? This cannot be undone.</p>
          <div className="flex gap-2">
-            <button type="button" onClick={() => { handleDeleteAll(); setShowDeleteAll(false); }} className="px-2 py-0.5 bg-red-700 hover:bg-red-600 text-[10px] rounded text-white transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-red-500/60 focus-visible:ring-offset-1 focus-visible:ring-offset-surface">Delete All</button>
+            <button type="button" onClick={() => { handleDeleteAll(); setShowDeleteAll(false); }} className="px-2 py-0.5 bg-red-600 hover:bg-red-700 text-[10px] rounded text-white transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-red-500/60 focus-visible:ring-offset-1 focus-visible:ring-offset-surface">Delete All</button>
            <button type="button" onClick={() => setShowDeleteAll(false)} className="px-2 py-0.5 bg-surface-card hover:bg-surface-elevated hover:text-ink text-[10px] rounded text-ink-mid transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-accent/40 focus-visible:ring-offset-1 focus-visible:ring-offset-surface">Cancel</button>
          </div>
        </div>
@@ -240,7 +240,7 @@ function PlatformOwnedFilesTab({ workspaceId }: { workspaceId: string }) {
        <div role="alertdialog" aria-labelledby="files-delete-one-msg" className="mx-3 mt-2 px-3 py-2 bg-amber-950/30 border border-amber-800/40 rounded space-y-1.5">
          <p id="files-delete-one-msg" className="text-xs text-warm">Delete <span className="font-mono">{confirmDelete}</span>{files.find((f) => f.path === confirmDelete && f.dir) ? " and all its contents" : ""}?</p>
          <div className="flex gap-2">
-            <button type="button" onClick={confirmDeleteFile} className="px-2 py-0.5 bg-red-700 hover:bg-red-600 text-[10px] rounded text-white transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-red-500/60 focus-visible:ring-offset-1 focus-visible:ring-offset-surface">Delete</button>
+            <button type="button" onClick={confirmDeleteFile} className="px-2 py-0.5 bg-red-600 hover:bg-red-700 text-[10px] rounded text-white transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-red-500/60 focus-visible:ring-offset-1 focus-visible:ring-offset-surface">Delete</button>
            <button type="button" onClick={() => setConfirmDelete(null)} className="px-2 py-0.5 bg-surface-card hover:bg-surface-elevated hover:text-ink text-[10px] rounded text-ink-mid transition-colors focus:outline-none focus-visible:ring-2 focus-visible:ring-accent/40 focus-visible:ring-offset-1 focus-visible:ring-offset-surface">Cancel</button>
          </div>
        </div>
@@ -32,7 +32,7 @@ export function FilesToolbar({
          value={root}
          onChange={(e) => setRoot(e.target.value)}
          aria-label="File root directory"
-          className="text-[10px] bg-surface-card text-ink-mid border border-line rounded px-1.5 py-0.5 focus-visible:outline-none focus-visible:ring-2 focus-visible:ring-accent focus-visible:ring-offset-1"
+          className="text-[10px] bg-surface-card text-ink-mid border border-line rounded px-1.5 py-0.5 outline-none"
        >
          <option value="/configs">/configs</option>
          <option value="/home">/home</option>
@@ -1,181 +1,217 @@
 // @vitest-environment jsdom
 /**
- * Tests for the main FilesTab / PlatformOwnedFilesTab component.
+ * FilesTab: NotAvailablePanel + FilesToolbar coverage.
 *
- * Covers: NotAvailablePanel (external runtime), loading/empty/error states,
- * FilesToolbar actions, and the /configs-only upload guard.
+ * NotAvailablePanel: pure presentational component — renders a "feature not
+ * available" placeholder for external-runtime workspaces.
+ * FilesToolbar: pure props-driven component — directory selector, file count,
+ * action buttons (New, Upload, Export, Clear, Refresh) with correct aria-labels.
 *
- * No @testing-library/jest-dom — use textContent / className / getAttribute.
+ * No @testing-library/jest-dom import — use textContent / className /
+ * getAttribute checks to avoid "expect is not defined" errors.
 */
 import { afterEach, describe, expect, it, vi } from "vitest";
-import { cleanup, fireEvent, render, screen, waitFor } from "@testing-library/react";
+import { cleanup, render, screen } from "@testing-library/react";
 import React from "react";

-import { FilesTab } from "../../FilesTab.tsx";
-import { FilesToolbar } from "../FilesToolbar.tsx";
-import type { FileEntry } from "../../FilesTab/tree";
+import { FilesToolbar } from "../FilesToolbar";
+import { NotAvailablePanel } from "../NotAvailablePanel";

-// ─── Mock ──────────────────────────────────────────────────────────────────
-
-const _mockGet = vi.hoisted(() => vi.fn<() => Promise<unknown>>());
-vi.mock("@/lib/api", () => ({
-  api: { get: _mockGet, put: vi.fn(), del: vi.fn() },
-}));
+// ─── afterEach ─────────────────────────────────────────────────────────────────

 afterEach(() => {
  cleanup();
-  _mockGet.mockReset();
+  vi.restoreAllMocks();
 });

-// ─── Helpers ───────────────────────────────────────────────────────────────
+// ─── NotAvailablePanel ─────────────────────────────────────────────────────────

-const emptyFileList: FileEntry[] = [];
+describe("NotAvailablePanel", () => {
+  it("renders heading 'Files not available'", () => {
+    const { container } = render(<NotAvailablePanel runtime="external" />);
+    expect(container.textContent).toContain("Files not available");
+  });

-/** Render FilesTab with a non-external runtime (triggers PlatformOwnedFilesTab). */
-function renderPlatformTab(extraProps: Partial<React.ComponentProps<typeof FilesTab>> = {}) {
-  return render(
-    <FilesTab
-      workspaceId="ws-1"
-      data={{ id: "ws-1", name: "Test", runtime: "claude-code", status: "online", tier: 0, skills: [], created_at: "" }}
-      {...extraProps}
-    />,
-  );
-}
+  it("renders the runtime name in monospace", () => {
+    const { container } = render(<NotAvailablePanel runtime="external" />);
+    expect(container.textContent).toContain("external");
+    const spans = container.querySelectorAll("span");
+    const monoSpans = Array.from(spans).filter(
+      (s) => s.className && s.className.includes("font-mono"),
+    );
+    expect(monoSpans.length).toBeGreaterThan(0);
+  });

-/** Render FilesToolbar directly with stub handlers. */
-function renderToolbar(extraProps: Partial<React.ComponentProps<typeof FilesToolbar>> = {}) {
-  return render(
-    <FilesToolbar
-      root="/configs"
-      setRoot={vi.fn()}
-      fileCount={0}
-      onNewFile={vi.fn()}
-      onUpload={vi.fn()}
-      onDownloadAll={vi.fn()}
-      onClearAll={vi.fn()}
-      onRefresh={vi.fn()}
-      {...extraProps}
-    />
-  );
-}
+  it("renders a Chat tab hint in description", () => {
+    const { container } = render(<NotAvailablePanel runtime="remote-agent" />);
+    expect(container.textContent).toContain("Chat tab");
+  });

-// ─── NotAvailablePanel ──────────────────────────────────────────────────────
+  it("SVG icon has aria-hidden=true", () => {
+    const { container } = render(<NotAvailablePanel runtime="external" />);
+    const svg = container.querySelector("svg");
+    expect(svg?.getAttribute("aria-hidden")).toBe("true");
+  });

-describe("FilesTab — NotAvailablePanel", () => {
-  it("renders NotAvailablePanel when runtime is external", async () => {
-    _mockGet.mockResolvedValueOnce(emptyFileList);
-    render(
-      <FilesTab
-        workspaceId="ws-1"
-        data={{ id: "ws-1", name: "Test", runtime: "external", status: "online", tier: 0, skills: [], created_at: "" }}
+  it("renders without crashing for any runtime string", () => {
+    const { container } = render(<NotAvailablePanel runtime="unknown-runtime" />);
+    expect(container.textContent).toContain("unknown-runtime");
+  });
+
+  it("applies the correct layout classes to root div", () => {
+    const { container } = render(<NotAvailablePanel runtime="external" />);
+    const root = container.firstElementChild as HTMLElement;
+    expect(root.className).toContain("flex");
+    expect(root.className).toContain("flex-col");
+    expect(root.className).toContain("items-center");
+  });
+});
+
+// ─── FilesToolbar ───────────────────────────────────────────────────────────────
+
+describe("FilesToolbar", () => {
+  const noop = vi.fn();
+
+  function renderToolbar(props: Partial<React.ComponentProps<typeof FilesToolbar>> = {}) {
+    return render(
+      <FilesToolbar
+        root="/configs"
+        setRoot={noop}
+        fileCount={0}
+        onNewFile={noop}
+        onUpload={noop}
+        onDownloadAll={noop}
+        onClearAll={noop}
+        onRefresh={noop}
+        {...props}
      />,
    );
-    expect(screen.getByText(/Files not available/i)).toBeTruthy();
+  }
+
+  it("renders the directory selector with correct aria-label", () => {
+    const { container } = renderToolbar();
+    const select = container.querySelector("select");
+    expect(select?.getAttribute("aria-label")).toBe("File root directory");
  });

-  it("renders the runtime name in NotAvailablePanel", async () => {
-    _mockGet.mockResolvedValueOnce(emptyFileList);
-    render(
-      <FilesTab
-        workspaceId="ws-1"
-        data={{ id: "ws-1", name: "Test", runtime: "external", status: "online", tier: 0, skills: [], created_at: "" }}
-      />,
+  it("directory selector has all four options", () => {
+    const { container } = renderToolbar();
+    const select = container.querySelector("select") as HTMLSelectElement;
+    const options = Array.from(select?.options ?? []);
+    const values = options.map((o) => o.value);
+    expect(values).toContain("/configs");
+    expect(values).toContain("/home");
+    expect(values).toContain("/workspace");
+    expect(values).toContain("/plugins");
+  });
+
+  it("calls setRoot when directory changes", () => {
+    const setRoot = vi.fn();
+    const { container } = renderToolbar({ setRoot });
+    const select = container.querySelector("select") as HTMLSelectElement;
+    select.value = "/home";
+    select.dispatchEvent(new Event("change", { bubbles: true }));
+    expect(setRoot).toHaveBeenCalledWith("/home");
+  });
+
+  it("displays the file count", () => {
+    const { container } = renderToolbar({ fileCount: 42 });
+    expect(container.textContent).toContain("42 files");
+  });
+
+  it("shows New + Upload + Clear buttons for /configs", () => {
+    const { container } = renderToolbar({ root: "/configs" });
+    const texts = Array.from(container.querySelectorAll("button")).map(
+      (b) => b.textContent?.trim(),
    );
-    expect(screen.getByText(/external/i)).toBeTruthy();
+    expect(texts).toContain("+ New");
+    expect(texts).toContain("Upload");
+    expect(texts).toContain("Clear");
+    expect(texts).toContain("Export");
+    expect(texts).toContain("↻");
  });

-  it("does NOT call api.get when runtime is external", async () => {
-    render(
-      <FilesTab
-        workspaceId="ws-1"
-        data={{ id: "ws-1", name: "Test", runtime: "external", status: "online", tier: 0, skills: [], created_at: "" }}
-      />,
+  it("hides New + Upload + Clear for /workspace", () => {
+    const { container } = renderToolbar({ root: "/workspace" });
+    const texts = Array.from(container.querySelectorAll("button")).map(
+      (b) => b.textContent?.trim(),
    );
-    expect(_mockGet).not.toHaveBeenCalled();
+    expect(texts).not.toContain("+ New");
+    expect(texts).not.toContain("Upload");
+    expect(texts).not.toContain("Clear");
+    expect(texts).toContain("Export");
  });
-});

-// ─── Loading / Empty / Error states ────────────────────────────────────────
-
-describe("FilesTab — states", () => {
-  it("shows loading text while fetching files", () => {
-    _mockGet.mockImplementation(
-      () => new Promise<unknown>(() => {}) as unknown as Promise<unknown>,
+  it("hides New + Upload + Clear for /home", () => {
+    const { container } = renderToolbar({ root: "/home" });
+    const texts = Array.from(container.querySelectorAll("button")).map(
+      (b) => b.textContent?.trim(),
    );
-    renderPlatformTab();
-    expect(screen.getByText("Loading files...")).toBeTruthy();
+    expect(texts).not.toContain("+ New");
+    expect(texts).not.toContain("Upload");
+    expect(texts).not.toContain("Clear");
  });

-  it("shows 'No config files yet' when root is /configs and no files", async () => {
-    _mockGet.mockResolvedValueOnce(emptyFileList);
-    renderPlatformTab();
-    await waitFor(() => {
-      expect(screen.getByText(/No config files yet/i)).toBeTruthy();
-    });
+  it("hides New + Upload + Clear for /plugins", () => {
+    const { container } = renderToolbar({ root: "/plugins" });
+    const texts = Array.from(container.querySelectorAll("button")).map(
+      (b) => b.textContent?.trim(),
+    );
+    expect(texts).not.toContain("+ New");
+    expect(texts).not.toContain("Upload");
+    expect(texts).not.toContain("Clear");
  });

-  it("fetches from the correct endpoint", async () => {
-    _mockGet.mockResolvedValueOnce(emptyFileList);
-    renderPlatformTab();
-    await waitFor(() => {
-      expect(_mockGet).toHaveBeenCalledWith(expect.stringContaining("/workspaces/ws-1/files"));
-    });
+  it("New button has correct aria-label", () => {
+    const { container } = renderToolbar({ root: "/configs" });
+    const newBtn = container.querySelector('button[aria-label="Create new file"]');
+    expect(newBtn?.textContent?.trim()).toBe("+ New");
  });

-  it("shows file count from toolbar when files exist", async () => {
-    _mockGet.mockResolvedValue([
-      { path: "configs/a.yaml", size: 10, dir: false },
-      { path: "configs/b.yaml", size: 20, dir: false },
-    ]);
-    renderPlatformTab();
-    await waitFor(() => {
-      expect(screen.getByText("2 files")).toBeTruthy();
-    });
-  });
-});
-
-// ─── FilesToolbar ──────────────────────────────────────────────────────────
-
-describe("FilesTab — FilesToolbar", () => {
-  it("shows Refresh button", async () => {
-    _mockGet.mockResolvedValueOnce(emptyFileList);
-    renderPlatformTab();
-    await waitFor(() => {
-      expect(screen.getByLabelText("Refresh file list")).toBeTruthy();
-    });
+  it("Export button has correct aria-label", () => {
+    const { container } = renderToolbar();
+    const exportBtn = container.querySelector('button[aria-label="Download all files"]');
+    expect(exportBtn?.textContent?.trim()).toBe("Export");
  });

-  it("shows root directory selector", async () => {
-    _mockGet.mockResolvedValueOnce(emptyFileList);
-    renderPlatformTab();
-    await waitFor(() => {
-      expect(screen.getByRole("combobox")).toBeTruthy();
-    });
+  it("Clear button has correct aria-label", () => {
+    const { container } = renderToolbar({ root: "/configs" });
+    const clearBtn = container.querySelector('button[aria-label="Delete all files"]');
+    expect(clearBtn?.textContent?.trim()).toBe("Clear");
  });

-  it("Refresh button triggers a reload", async () => {
-    // Use persistent mock — loadFiles fires on mount AND on Refresh click.
-    _mockGet.mockResolvedValue(emptyFileList);
-    renderPlatformTab();
-    await waitFor(() => screen.getByLabelText("Refresh file list"));
-    const before = _mockGet.mock.calls.length;
-    fireEvent.click(screen.getByLabelText("Refresh file list"));
-    await waitFor(() => {
-      expect(_mockGet.mock.calls.length).toBeGreaterThan(before);
-    });
+  it("Refresh button has correct aria-label", () => {
+    const { container } = renderToolbar();
+    const refreshBtn = container.querySelector('button[aria-label="Refresh file list"]');
+    expect(refreshBtn?.textContent?.trim()).toBe("↻");
  });
-});

-// ─── Upload guard ──────────────────────────────────────────────────────────
+  it("calls onNewFile when New button is clicked", () => {
+    const onNewFile = vi.fn();
+    const { container } = renderToolbar({ root: "/configs", onNewFile });
+    container.querySelector('button[aria-label="Create new file"]')!.click();
+    expect(onNewFile).toHaveBeenCalledTimes(1);
+  });

-describe("FilesTab — upload guard", () => {
-  it("no error alert on dragover when root is /configs (default)", async () => {
-    _mockGet.mockResolvedValue(emptyFileList);
-    renderPlatformTab();
-    await waitFor(() => screen.getByText(/No config files yet/i));
+  it("calls onDownloadAll when Export button is clicked", () => {
+    const onDownloadAll = vi.fn();
+    const { container } = renderToolbar({ onDownloadAll });
+    container.querySelector('button[aria-label="Download all files"]')!.click();
+    expect(onDownloadAll).toHaveBeenCalledTimes(1);
+  });

-    // No alert should be present
-    expect(screen.queryByRole("alert")).toBeNull();
+  it("calls onClearAll when Clear button is clicked", () => {
+    const onClearAll = vi.fn();
+    const { container } = renderToolbar({ root: "/configs", onClearAll });
+    container.querySelector('button[aria-label="Delete all files"]')!.click();
+    expect(onClearAll).toHaveBeenCalledTimes(1);
+  });
+
+  it("calls onRefresh when Refresh button is clicked", () => {
+    const onRefresh = vi.fn();
+    const { container } = renderToolbar({ onRefresh });
+    container.querySelector('button[aria-label="Refresh file list"]')!.click();
+    expect(onRefresh).toHaveBeenCalledTimes(1);
  });

  it("applies focus-visible ring to all interactive buttons", () => {
@@ -1,218 +0,0 @@
-// @vitest-environment jsdom
-/**
- * Tests for tree.ts — buildTree and getIcon pure functions.
- */
-import { describe, expect, it } from "vitest";
-import type { FileEntry } from "../tree";
-import { buildTree, getIcon } from "../tree";
-
-// ─── getIcon ─────────────────────────────────────────────────────────────────
-
-describe("getIcon", () => {
-  it("returns folder emoji for directories", () => {
-    expect(getIcon("/configs", true)).toBe("📁");
-  });
-
-  it("returns correct emoji for .md", () => {
-    expect(getIcon("readme.md", false)).toBe("📄");
-  });
-
-  it("returns correct emoji for .yaml", () => {
-    expect(getIcon("config.yaml", false)).toBe("⚙");
-  });
-
-  it("returns correct emoji for .yml", () => {
-    expect(getIcon("config.yml", false)).toBe("⚙");
-  });
-
-  it("returns correct emoji for .py", () => {
-    expect(getIcon("script.py", false)).toBe("🐍");
-  });
-
-  it("returns correct emoji for .ts", () => {
-    expect(getIcon("index.ts", false)).toBe("💠");
-  });
-
-  it("returns correct emoji for .tsx", () => {
-    expect(getIcon("App.tsx", false)).toBe("💠");
-  });
-
-  it("returns correct emoji for .js", () => {
-    expect(getIcon("index.js", false)).toBe("📜");
-  });
-
-  it("returns correct emoji for .json", () => {
-    expect(getIcon("package.json", false)).toBe("{}");
-  });
-
-  it("returns correct emoji for .html", () => {
-    expect(getIcon("index.html", false)).toBe("🌐");
-  });
-
-  it("returns correct emoji for .css", () => {
-    expect(getIcon("style.css", false)).toBe("🎨");
-  });
-
-  it("returns correct emoji for .sh", () => {
-    expect(getIcon("deploy.sh", false)).toBe("▸");
-  });
-
-  it("returns default file emoji for unknown extensions", () => {
-    expect(getIcon("Makefile", false)).toBe("📄");
-    expect(getIcon("Dockerfile", false)).toBe("📄");
-    expect(getIcon("Rakefile", false)).toBe("📄");
-  });
-
-  it("extension matching is case-insensitive", () => {
-    expect(getIcon("readme.MD", false)).toBe("📄");
-    expect(getIcon("script.PY", false)).toBe("🐍");
-  });
-});
-
-// ─── buildTree ───────────────────────────────────────────────────────────────
-
-describe("buildTree", () => {
-  it("returns empty array for empty input", () => {
-    expect(buildTree([])).toEqual([]);
-  });
-
-  it("adds a single file at root", () => {
-    const files: FileEntry[] = [{ path: "config.yaml", size: 128, dir: false }];
-    const tree = buildTree(files);
-    expect(tree).toHaveLength(1);
-    expect(tree[0]).toMatchObject({
-      name: "config.yaml",
-      path: "config.yaml",
-      isDir: false,
-      children: [],
-      size: 128,
-    });
-  });
-
-  it("adds a single directory at root", () => {
-    const files: FileEntry[] = [{ path: "skills", size: 0, dir: true }];
-    const tree = buildTree(files);
-    expect(tree).toHaveLength(1);
-    expect(tree[0]).toMatchObject({
-      name: "skills",
-      path: "skills",
-      isDir: true,
-      children: [],
-      size: 0,
-    });
-  });
-
-  it("sorts dirs before files at the same level", () => {
-    const files: FileEntry[] = [
-      { path: "b.txt", size: 10, dir: false },
-      { path: "a.txt", size: 10, dir: false },
-      { path: "z-dir", size: 0, dir: true },
-      { path: "a-dir", size: 0, dir: true },
-    ];
-    const tree = buildTree(files);
-    expect(tree).toHaveLength(4);
-    // Dirs first: z-dir, a-dir alphabetically → a before z
-    expect(tree[0].name).toBe("a-dir");
-    expect(tree[1].name).toBe("z-dir");
-    // Then files alphabetically
-    expect(tree[2].name).toBe("a.txt");
-    expect(tree[3].name).toBe("b.txt");
-  });
-
-  it("alphabetically sorts files within the same level", () => {
-    const files: FileEntry[] = [
-      { path: "z.yaml", size: 10, dir: false },
-      { path: "a.yaml", size: 10, dir: false },
-      { path: "m.yaml", size: 10, dir: false },
-    ];
-    const tree = buildTree(files);
-    expect(tree.map((n) => n.name)).toEqual(["a.yaml", "m.yaml", "z.yaml"]);
-  });
-
-  it("nests a file under its parent directory", () => {
-    const files: FileEntry[] = [
-      { path: "skills", size: 0, dir: true },
-      { path: "skills/readme.md", size: 64, dir: false },
-    ];
-    const tree = buildTree(files);
-    expect(tree).toHaveLength(1);
-    expect(tree[0].name).toBe("skills");
-    expect(tree[0].children).toHaveLength(1);
-    expect(tree[0].children[0]).toMatchObject({
-      name: "readme.md",
-      path: "skills/readme.md",
-      isDir: false,
-      size: 64,
-    });
-  });
-
-  it("creates intermediate directories automatically", () => {
-    const files: FileEntry[] = [
-      { path: "a/b/c/deep.txt", size: 32, dir: false },
-    ];
-    const tree = buildTree(files);
-    // Root has one child: "a"
-    expect(tree).toHaveLength(1);
-    expect(tree[0].name).toBe("a");
-    expect(tree[0].isDir).toBe(true);
-    // "a" has one child: "b"
-    expect(tree[0].children).toHaveLength(1);
-    expect(tree[0].children[0].name).toBe("b");
-    // "b" has one child: "c"
-    expect(tree[0].children[0].children).toHaveLength(1);
-    expect(tree[0].children[0].children[0].name).toBe("c");
-    // "c" has the file
-    expect(tree[0].children[0].children[0].children[0].name).toBe("deep.txt");
-    expect(tree[0].children[0].children[0].children[0].size).toBe(32);
-  });
-
-  it("adds multiple files to the same directory", () => {
-    const files: FileEntry[] = [
-      { path: "configs", size: 0, dir: true },
-      { path: "configs/a.yaml", size: 10, dir: false },
-      { path: "configs/b.yaml", size: 20, dir: false },
-    ];
-    const tree = buildTree(files);
-    expect(tree).toHaveLength(1);
-    expect(tree[0].children.map((n) => n.name).sort()).toEqual(["a.yaml", "b.yaml"]);
-  });
-
-  it("does not duplicate a directory already created as intermediate", () => {
-    const files: FileEntry[] = [
-      { path: "a/b.txt", size: 5, dir: false },
-      { path: "a", size: 0, dir: true },
-    ];
-    const tree = buildTree(files);
-    // "a" should appear only once
-    expect(tree).toHaveLength(1);
-    expect(tree[0].name).toBe("a");
-    // The dir "a" should still contain "b.txt"
-    expect(tree[0].children).toHaveLength(1);
-    expect(tree[0].children[0].name).toBe("b.txt");
-  });
-
-  it("intermediate dirs have size 0", () => {
-    const files: FileEntry[] = [
-      { path: "a/b/c/file.txt", size: 1, dir: false },
-    ];
-    const tree = buildTree(files);
-    expect(tree[0].size).toBe(0);
-    expect(tree[0].children[0].size).toBe(0);
-  });
-
-  it("handles deeply nested mixed dirs and files", () => {
-    const files: FileEntry[] = [
-      { path: "a", size: 0, dir: true },
-      { path: "a/b", size: 0, dir: true },
-      { path: "a/b/c", size: 0, dir: true },
-      { path: "a/b/c/d.txt", size: 1, dir: false },
-      { path: "a/b/e.txt", size: 2, dir: false },
-      { path: "a/f.txt", size: 3, dir: false },
-    ];
-    const tree = buildTree(files);
-    expect(tree).toHaveLength(1); // root: "a"
-    expect(tree[0].children.map((n) => n.name).sort()).toEqual(["b", "f.txt"]);
-    expect(tree[0].children.find((n) => n.name === "b")!.children.map((n) => n.name).sort())
-      .toEqual(["c", "e.txt"]);
-  });
-});
@@ -332,13 +332,6 @@ export function ScheduleTab({ workspaceId }: Props) {
                  <div className="flex items-center gap-1.5">
                    <button
                      onClick={() => handleToggle(sched)}
-                      aria-label={
-                        sched.last_status === "error"
-                          ? "Last run failed — click to disable"
-                          : sched.last_status === "ok"
-                          ? "Last run OK — click to disable"
-                          : "Never run — click to enable"
-                      }
                      className={`w-2 h-2 rounded-full flex-shrink-0 ${
                        sched.last_status === "error"
                          ? "bg-red-400"
@@ -367,7 +360,7 @@ export function ScheduleTab({ workspaceId }: Props) {
                    <span>Runs: {sched.run_count}</span>
                  </div>
                  {sched.last_error && (
-                    <div className="text-[8px] text-bad mt-0.5 truncate">
+                    <div className="text-[8px] text-bad/70 mt-0.5 truncate">
                      Error: {sched.last_error}
                    </div>
                  )}
@@ -492,7 +492,7 @@ export function SkillsTab({ workspaceId, data }: Props) {
                <div className="text-[10px] text-bad font-semibold mb-0.5">
                  Couldn't load the plugin registry
                </div>
-                <div className="text-[10px] text-bad">{registryError}</div>
+                <div className="text-[10px] text-bad/80">{registryError}</div>
                <div className="mt-1 text-[10px] text-ink-mid">
                  Check the platform server is reachable at /plugins. The Retry button is in the header above.
                </div>
@@ -1,189 +0,0 @@
-// @vitest-environment jsdom
-/**
- * Tests for hydrate.ts — canvas store hydration with exponential backoff.
- *
- * Covers:
- *   - Successful hydration on first attempt (no retries)
- *   - Retry with exponential backoff on failure
- *   - onRetrying callback called at correct intervals
- *   - Error propagation after MAX_RETRIES exhausted
- *   - Viewport persisted on success
- *   - Viewport failure is non-fatal
- */
-import { describe, it, expect, vi, beforeEach, afterEach } from "vitest";
-import type { WorkspaceData } from "@/store/socket";
-
-// ---------------------------------------------------------------------------
-// Mock modules — must precede imports that use them
-// ---------------------------------------------------------------------------
-
-const mockHydrate = vi.fn();
-const mockSetViewport = vi.fn();
-
-vi.mock("@/lib/api", () => ({
-  api: {
-    get: vi.fn(),
-  },
-  PLATFORM_URL: "https://platform.test",
-}));
-
-vi.mock("@/store/canvas", () => ({
-  useCanvasStore: Object.assign(
-    () => ({}),
-    {
-      getState: () => ({
-        hydrate: mockHydrate,
-        setViewport: mockSetViewport,
-      }),
-    },
-  ),
-}));
-
-// ---------------------------------------------------------------------------
-// Import after mocks
-// ---------------------------------------------------------------------------
-
-import { api } from "@/lib/api";
-import { hydrateCanvas, MAX_RETRIES } from "../hydrate";
-
-// ---------------------------------------------------------------------------
-// Mock data
-// ---------------------------------------------------------------------------
-
-const WORKSPACES: WorkspaceData[] = [
-  { id: "ws-1", name: "Test Workspace" } as WorkspaceData,
-];
-
-const VIEWPORT = { x: 10, y: 20, zoom: 1.5 };
-
-// ---------------------------------------------------------------------------
-// Helpers
-// ---------------------------------------------------------------------------
-
-const mockApiGet = vi.mocked(api.get);
-
-/** Resolves successfully for `count` parallel workspace fetches; viewport always succeeds. */
-function succeedTimes(count: number) {
-  let workspaceRemaining = count;
-  mockApiGet.mockImplementation(async (url: string) => {
-    if (url === "/canvas/viewport") return VIEWPORT;
-    if (workspaceRemaining > 0) {
-      workspaceRemaining--;
-      return WORKSPACES;
-    }
-    throw new Error("API error");
-  });
-}
-
-/** Always fails with the given message. */
-function alwaysFail(msg = "Network error") {
-  mockApiGet.mockRejectedValue(new Error(msg));
-}
-
-// ---------------------------------------------------------------------------
-// Tests
-// ---------------------------------------------------------------------------
-
-describe("hydrateCanvas", () => {
-  beforeEach(() => {
-    vi.clearAllMocks();
-    mockApiGet.mockReset();
-    mockHydrate.mockReset();
-    mockSetViewport.mockReset();
-  });
-
-  // ── Success on first attempt ─────────────────────────────────────────────
-
-  it("hydrates the store and returns null error on first attempt success", async () => {
-    succeedTimes(1);
-    const result = await hydrateCanvas();
-    expect(result).toEqual({ error: null });
-    expect(mockHydrate).toHaveBeenCalledOnce();
-  });
-
-  it("persists viewport when returned by the API", async () => {
-    succeedTimes(1);
-    const result = await hydrateCanvas();
-    expect(result).toEqual({ error: null });
-    expect(mockSetViewport).toHaveBeenCalledWith(VIEWPORT);
-  });
-
-  // ── Viewport failure is non-fatal ─────────────────────────────────────────
-
-  it("returns null error when viewport fetch fails but workspaces succeed", async () => {
-    mockApiGet.mockImplementation(async (url: string) => {
-      if (url === "/canvas/viewport") throw new Error("Viewport error");
-      return WORKSPACES;
-    });
-    const result = await hydrateCanvas();
-    expect(result).toEqual({ error: null });
-    expect(mockHydrate).toHaveBeenCalledOnce();
-    expect(mockSetViewport).not.toHaveBeenCalled();
-  });
-
-  // ── Retry logic ──────────────────────────────────────────────────────────
-
-  it("retries MAX_RETRIES times before returning an error", async () => {
-    alwaysFail();
-    const onRetrying = vi.fn();
-    const result = await Promise.race([
-      hydrateCanvas(onRetrying),
-      new Promise<"timeout">((resolve) => setTimeout(() => resolve("timeout"), 5000)),
-    ]);
-    if (result === "timeout") throw new Error("Test timed out — retries not awaited correctly");
-    expect(result.error).not.toBeNull();
-    expect(onRetrying).toHaveBeenCalledTimes(MAX_RETRIES - 1);
-  }, 10000);
-
-  it("onRetrying is called with attempt number before each retry", async () => {
-    alwaysFail();
-    const onRetrying = vi.fn();
-    await Promise.race([
-      hydrateCanvas(onRetrying),
-      new Promise<"timeout">((resolve) => setTimeout(() => resolve("timeout"), 5000)),
-    ]);
-    expect(onRetrying).toHaveBeenNthCalledWith(1, 1);
-    expect(onRetrying).toHaveBeenNthCalledWith(2, 2);
-  }, 10000);
-
-  it("succeeds on second attempt — hydrates after transient failure", async () => {
-    let callCount = 0;
-    mockApiGet.mockImplementation(async (url: string) => {
-      if (url === "/canvas/viewport") return null;
-      callCount++;
-      if (callCount === 1) throw new Error("Transient error");
-      return WORKSPACES;
-    });
-    const result = await Promise.race([
-      hydrateCanvas(),
-      new Promise<"timeout">((resolve) => setTimeout(() => resolve("timeout"), 5000)),
-    ]);
-    if (result === "timeout") throw new Error("Test timed out");
-    expect(result).toEqual({ error: null });
-    expect(mockHydrate).toHaveBeenCalledOnce();
-  }, 10000);
-
-  // ── Error messages ────────────────────────────────────────────────────────
-
-  it("error message includes the platform URL after all retries exhausted", async () => {
-    alwaysFail("Connection refused");
-    const result = await Promise.race([
-      hydrateCanvas(),
-      new Promise<"timeout">((resolve) => setTimeout(() => resolve("timeout"), 5000)),
-    ]);
-    if (result === "timeout") throw new Error("Test timed out");
-    expect(result.error).toContain("platform.test");
-    expect(result.error).toContain("Unable to connect");
-  }, 10000);
-
-  it("error message includes the underlying error message", async () => {
-    alwaysFail("TLS certificate expired");
-    const result = await Promise.race([
-      hydrateCanvas(),
-      new Promise<"timeout">((resolve) => setTimeout(() => resolve("timeout"), 5000)),
-    ]);
-    if (result === "timeout") throw new Error("Test timed out");
-    expect(result.error).not.toBeNull();
-    expect(typeof result.error).toBe("string");
-  }, 10000);
-});
@@ -21,8 +21,8 @@ export function statusDotClass(status: string): string {
 export const TIER_CONFIG: Record<number, { label: string; color: string; border: string }> = {
  1: { label: "T1", color: "text-ink-mid bg-surface-card border border-line", border: "text-ink-mid border-line" },
  2: { label: "T2", color: "text-white bg-accent border border-accent-strong", border: "text-accent border-accent" },
-  3: { label: "T3", color: "text-white bg-violet-600 border border-violet-700", border: "text-white border-violet-500" },
-  4: { label: "T4", color: "text-white bg-warm border border-warm", border: "text-white border-warm" },
+  3: { label: "T3", color: "text-white bg-violet-600 border border-violet-700", border: "text-violet-600 border-violet-500" },
+  4: { label: "T4", color: "text-white bg-warm border border-warm", border: "text-warm border-warm" },
 };

 export const COMM_TYPE_LABELS: Record<string, string> = {
@@ -282,17 +282,13 @@
 }

 .secret-row__save-btn {
-  background: #1d4ed8;
+  background: #2563eb;
  color: #ffffff;
  border: none;
  padding: 6px 12px;
  border-radius: 6px;
  font-size: 13px;
  cursor: pointer;
-  transition: background-color 0.15s;
-}
-.secret-row__save-btn:hover {
-  background: #1e40af;
 }

 .secret-row__save-btn:focus-visible {
@@ -374,17 +370,13 @@
 }

 .add-key-form__save-btn {
-  background: #1d4ed8;
+  background: #2563eb;
  color: #ffffff;
  border: none;
  padding: 8px 16px;
  border-radius: 6px;
  font-size: 13px;
  cursor: pointer;
-  transition: background-color 0.15s;
-}
-.add-key-form__save-btn:hover {
-  background: #1e40af;
 }

 .add-key-form__save-btn:focus-visible {
@@ -518,7 +510,7 @@
 .empty-state__body { font-size: 14px; color: #a1a1aa; margin: 0 0 24px; line-height: 1.5; }

 .empty-state__cta {
-  background: #1d4ed8;
+  background: #2563eb;
  color: #ffffff;
  border: none;
  padding: 10px 20px;
@@ -526,10 +518,6 @@
  font-size: 14px;
  font-weight: 500;
  cursor: pointer;
-  transition: background-color 0.15s;
-}
-.empty-state__cta:hover {
-  background: #1e40af;
 }

 .empty-state__cta:focus-visible { outline: var(--focus-ring); outline-offset: var(--focus-ring-offset); }
@@ -573,16 +561,12 @@
 .secrets-tab__error p { color: var(--status-invalid); margin: 0 0 12px; }

 .secrets-tab__refresh-btn {
-  background: #1d4ed8;
+  background: #2563eb;
  color: #ffffff;
  border: none;
  padding: 8px 16px;
  border-radius: 6px;
  cursor: pointer;
-  transition: background-color 0.15s;
-}
-.secrets-tab__refresh-btn:hover {
-  background: #1e40af;
 }

 .secrets-tab__no-results {
@@ -706,16 +690,12 @@
 }

 .guard-dialog__discard-btn {
-  background: #1d4ed8;
+  background: #2563eb;
  color: #ffffff;
  border: none;
  padding: 8px 16px;
  border-radius: 6px;
  cursor: pointer;
-  transition: background-color 0.15s;
-}
-.guard-dialog__discard-btn:hover {
-  background: #1e40af;
 }

 .guard-dialog__discard-btn:focus-visible {
@@ -767,20 +747,12 @@
 .top-bar__name { font-size: 14px; font-weight: 500; color: #d4d4d8; }

 .top-bar__btn {
-  background: #1d4ed8;
+  background: #2563eb;
  color: #ffffff;
  border: none;
  padding: 6px 12px;
  border-radius: 6px;
  font-size: 13px;
  cursor: pointer;
-  transition: background-color 0.15s;
-}
-.top-bar__btn:hover {
-  background: #1e40af;
-}
-.top-bar__btn:focus-visible {
-  outline: none;
-  box-shadow: 0 0 0 2px #18181b, 0 0 0 4px #3b82f6;
 }

@@ -179,7 +179,6 @@ cp_redeploy_tenant() {
  #   1  — any other failure
  # stdout = response body. stderr = "HTTP_STATUS=NNN" line.
  local slug="$1" tag="$2"
-  validate_slug "$slug"
  _mock_call cp_redeploy_tenant "$slug" "$tag"; local _mrc=$?
  [[ $_mrc -ne 99 ]] && return $_mrc
  local tok="${!CP_TOKEN_ENV:-}"
@@ -205,7 +204,6 @@ cp_redeploy_tenant() {
 tenant_buildinfo() {
  # args: <slug>; prints JSON
  local slug="$1"
-  validate_slug "$slug"
  _mock_call tenant_buildinfo "$slug"; local _mrc=$?
  [[ $_mrc -ne 99 ]] && return $_mrc
  curl -sf --max-time 10 "https://${slug}.moleculesai.app/buildinfo"
@@ -214,7 +212,6 @@ tenant_buildinfo() {
 tenant_health() {
  # args: <slug>; prints raw response, returns 0 if "ok"
  local slug="$1"
-  validate_slug "$slug"
  _mock_call tenant_health "$slug"; local _mrc=$?
  [[ $_mrc -ne 99 ]] && return $_mrc
  curl -sf --max-time 10 "https://${slug}.moleculesai.app/health"
@@ -259,7 +256,6 @@ print(json.dumps({'commands': [ecr_login]}))
 resolve_tenant_instance_id() {
  # args: <slug>; prints i-xxx
  local slug="$1"
-  validate_slug "$slug"
  _mock_call resolve_tenant_instance_id "$slug"; local _mrc=$?
  [[ $_mrc -ne 99 ]] && return $_mrc
  local tok="${!CP_TOKEN_ENV:-}"
@@ -275,19 +271,6 @@ resolve_tenant_instance_id() {
 log() { printf '[%s] %s\n' "$(date -u +%H:%M:%SZ)" "$*"; }
 err() { printf '[%s] ERROR: %s\n' "$(date -u +%H:%M:%SZ)" "$*" >&2; }

-# validate_slug — exit 64 if slug contains characters outside the safe set.
-# Prevents SSRF via query-separator injection (?foo) and subdomain takeover
-# (@evil) when slug is interpolated into URL paths or subdomains.
-# OFFSEC-006 fix.
-validate_slug() {
-  local slug="$1"
-  if ! [[ "$slug" =~ ^[a-z0-9]([a-z0-9-]{0,61}[a-z0-9])?$ ]]; then
-    printf '[%s] ERROR: invalid slug: %s\n' \
-      "$(date -u +%H:%M:%SZ)" "$slug" >&2
-    exit 64
-  fi
-}
-
 preflight() {
  log "preflight: source=$SOURCE_TAG dest=$DEST_TAG repo=$REPO region=$REGION"
  local src_manifest
@@ -356,7 +339,6 @@ promote() {
 redeploy_tenant() {
  # args: <slug> — handle the 403→SSM-refresh→retry pattern
  local slug="$1"
-  validate_slug "$slug"
  log "  redeploy: $slug"
  if [[ "$DRY_RUN" == "true" ]]; then
    log "    [dry-run] would POST /redeploy slug=$slug"
@@ -390,7 +372,6 @@ redeploy_tenant() {

 verify_tenant() {
  local slug="$1"
-  validate_slug "$slug"
  log "  verify: $slug"
  if [[ "$DRY_RUN" == "true" ]]; then
    log "    [dry-run] would curl /buildinfo + /health"
@@ -417,7 +398,6 @@ rollback() {
  rm -f "$mfile"
  IFS=',' read -ra slugs <<<"$TENANTS"
  for slug in "${slugs[@]}"; do
-    validate_slug "$slug"
    redeploy_tenant "$slug" || err "  rollback redeploy failed for $slug"
  done
  log "rollback: complete"
@@ -428,13 +408,6 @@ rollback() {
 # ─────────────────────────────────────────────────────────────────────────────

 main() {
-  # OFFSEC-006: validate slugs before any network I/O.
-  IFS=',' read -ra _slugs <<<"$TENANTS"
-  for _slug in "${_slugs[@]}"; do
-    validate_slug "$_slug"
-  done
-  unset _slugs _slug
-
  preflight || return 1
  snapshot_dest_tag || return 2
  promote || return 2
@@ -442,15 +415,8 @@ main() {
  local promote_rc=0
  IFS=',' read -ra slugs <<<"$TENANTS"
  for slug in "${slugs[@]}"; do
-    validate_slug "$slug"
-    if ! redeploy_tenant "$slug"; then
-      promote_rc=1
-    fi
-    if [[ $promote_rc -eq 0 ]]; then
-      if ! verify_tenant "$slug"; then
-        promote_rc=1
-      fi
-    fi
+    redeploy_tenant "$slug" || promote_rc=1
+    [[ $promote_rc -eq 0 ]] && { verify_tenant "$slug" || promote_rc=1; }
    [[ $promote_rc -ne 0 ]] && break
  done

@@ -267,51 +267,7 @@ else
  printf '  ✗ unknown-flag should fail (got %s)\n' "$rc"
 fi

-printf '\n== Test 9: slug validation — invalid slugs rejected with exit 64 (OFFSEC-006) ==\n'
-# Attack vectors: SSRF via ? (curl query separator), subdomain takeover via @,
-# path traversal via /, shell metacharacters.  Use a newline-delimited temp file
-# so slugs containing spaces are NOT split by shell word-splitting.
-_invalid_tmp=$(mktemp)
-cat > "$_invalid_tmp" <<'INVALID_EOF'
-a?url=https://evil.com
-a&url=https://evil.com
-a@evil.com
-a/b
-a\b
-a b
-chloe-dong?url=http://evil.com
-evil.com@legitimate
-INVALID_EOF
-while IFS= read -r attack || [[ -n "$attack" ]]; do
-  set +e
-  out=$("$SCRIPT" --source-tag x --dest-tag y --tenants "$attack" 2>&1); rc=$?
-  set -e
-  if [[ $rc -eq 64 ]] && printf '%s' "$out" | grep -q 'invalid slug'; then
-    PASS=$((PASS + 1)); printf '  ✓ slug rejected: %s\n' "$(printf '%q' "$attack")"
-  else
-    FAIL=$((FAIL + 1)); FAIL_NAMES+=("slug-reject:$attack")
-    printf '  ✗ slug should be rejected: %s — got exit %s\n' "$(printf '%q' "$attack")" "$rc"
-  fi
-done < "$_invalid_tmp"
-rm -f "$_invalid_tmp"
-
-printf '\n== Test 10: slug validation — valid slugs pass through ==\n'
-valid_slugs='chloe-dong hongming ab a abc123 my-tenant-42'
-for slug in $valid_slugs; do
-  set +e
-  out=$("$SCRIPT" --source-tag x --dest-tag y --tenants "$slug" --mock-dir /nonexistent 2>&1); rc=$?
-  set -e
-  # valid slugs: script should fail at preflight (no such mock dir / no real infra),
-  # but NOT at slug validation (exit 64). So we check exit != 64.
-  if [[ $rc -ne 64 ]]; then
-    PASS=$((PASS + 1)); printf '  ✓ valid slug accepted: %s\n' "$slug"
-  else
-    FAIL=$((FAIL + 1)); FAIL_NAMES+=("slug-accept:$slug")
-    printf '  ✗ valid slug rejected: %s (should have passed slug check)\n' "$slug"
-  fi
-done
-
-printf '\n== Test 11: ROLLBACK_TAG follows YYYYMMDD via NOW_OVERRIDE_DATE ==\n'
+printf '\n== Test 9: ROLLBACK_TAG follows YYYYMMDD via NOW_OVERRIDE_DATE ==\n'
 m=$(mkmock)
 mock_set "$m" aws_ecr_get_image       '{}' 0
 mock_set "$m" aws_ecr_describe_image  '' 1
@@ -333,7 +289,7 @@ fi
 assert_calls_contain "rollback tag uses NOW_OVERRIDE_DATE (20260603)" "$m" 'aws_ecr_put_image b-prev-20260603'
 rm -rf "$m"

-printf '\n== Test 12: empty source manifest fails preflight ==\n'
+printf '\n== Test 10: empty source manifest fails preflight ==\n'
 m=$(mkmock)
 mock_set "$m" aws_ecr_get_image '' 0   # rc=0 but empty body (the "None" case)
 out=$(run_script "$m")
@@ -341,7 +297,7 @@ assert_exit "empty source manifest fails preflight" "$out" 1
 assert_contains "empty manifest message" "$out" 'returned empty manifest'
 rm -rf "$m"

-printf '\n== Test 13: tenant_buildinfo failure during verify → rollback ==\n'
+printf '\n== Test 11: tenant_buildinfo failure during verify → rollback ==\n'
 m=$(mkmock)
 mock_set "$m" aws_ecr_get_image          '{"manifests":[]}' 0
 mock_set "$m" aws_ecr_describe_image     '' 1
@@ -355,7 +311,7 @@ assert_contains "logs buildinfo failure" "$out" '/buildinfo failed for chloe-don
 assert_contains "rollback fired after verify fail" "$out" 'ROLLBACK:'
 rm -rf "$m"

-printf '\n== Test 14: ssm_refresh_ecr_auth JSON escaping (CWE-78 / OFFSEC-001) ==\n'
+printf '\n== Test 12: ssm_refresh_ecr_auth JSON escaping (CWE-78 / OFFSEC-001) ==\n'
 # Verify the python3 snippet in ssm_refresh_ecr_auth produces valid JSON and
 # correctly escapes shell-injection characters in region + account ID fields.
 # The fix replaces unquoted shell-printf interpolation with json.dumps.
@@ -22,7 +22,6 @@ Cross-links:
 """
 from __future__ import annotations

-import re
 import subprocess
 import sys
 import textwrap
@@ -543,153 +542,3 @@ def test_rule9_prod_manual_deploy_allows_rollback_control(tmp_path):
    _write(tmp_path, "ok.yml", PROD_ROLLBACK_OK)
    r = _run_lint(tmp_path)
    assert r.returncode == 0, f"stdout={r.stdout}\nstderr={r.stderr}"
-
-
-# ---------------------------------------------------------------------------
-# Rule 10 — docker info piped to head under pipefail
-# ---------------------------------------------------------------------------
-
-DOCKER_INFO_HEAD_BAD = """
-    name: docker-info-head-bad
-    on: [push]
-    jobs:
-      build:
-        runs-on: ubuntu-latest
-        steps:
-          - run: |
-              set -euo pipefail
-              docker info 2>&1 | head -5 || exit 1
-"""
-
-DOCKER_INFO_CAPTURE_OK = """
-    name: docker-info-capture-ok
-    on: [push]
-    jobs:
-      build:
-        runs-on: ubuntu-latest
-        steps:
-          - run: |
-              set -euo pipefail
-              docker_info="$(docker info 2>&1)" || exit 1
-              printf '%s\\n' "${docker_info}" | sed -n '1,5p'
-"""
-
-DOCKER_INFO_SEPARATE_STEP_OK = """
-    name: docker-info-separate-step-ok
-    on: [push]
-    jobs:
-      build:
-        runs-on: ubuntu-latest
-        steps:
-          - run: |
-              set -euo pipefail
-              echo setup
-          - run: |
-              docker info 2>&1 | head -5 || true
-"""
-
-
-def test_rule10_docker_info_head_under_pipefail_detects_violation(tmp_path):
-    _write(tmp_path, "bad.yml", DOCKER_INFO_HEAD_BAD)
-    r = _run_lint(tmp_path)
-    assert r.returncode == 1
-    assert "docker info" in r.stdout.lower()
-    assert "pipefail" in r.stdout.lower()
-
-
-def test_rule10_docker_info_capture_passes(tmp_path):
-    _write(tmp_path, "ok.yml", DOCKER_INFO_CAPTURE_OK)
-    r = _run_lint(tmp_path)
-    assert r.returncode == 0, f"stdout={r.stdout}\nstderr={r.stderr}"
-
-
-def test_rule10_docker_info_head_in_separate_step_without_pipefail_passes(tmp_path):
-    _write(tmp_path, "ok.yml", DOCKER_INFO_SEPARATE_STEP_OK)
-    r = _run_lint(tmp_path)
-    assert r.returncode == 0, f"stdout={r.stdout}\nstderr={r.stderr}"
-
-
-# ---------------------------------------------------------------------------
-# CI change detector fanout — workflow-only PRs keep required contexts without
-# running Go/Canvas/Python/shellcheck heavy steps.
-# ---------------------------------------------------------------------------
-
-CI_WORKFLOW = REPO_ROOT / ".gitea" / "workflows" / "ci.yml"
-CI_SURFACES = ("platform", "canvas", "python", "scripts")
-
-
-def _ci_change_patterns() -> dict[str, re.Pattern[str]]:
-    text = CI_WORKFLOW.read_text(encoding="utf-8")
-    patterns: dict[str, re.Pattern[str]] = {}
-    for surface, pattern in re.findall(
-        r'echo "(platform|canvas|python|scripts)=.*?grep -qE \'([^\']+)\'',
-        text,
-    ):
-        patterns[surface] = re.compile(pattern)
-    assert set(patterns) == set(CI_SURFACES)
-    return patterns
-
-
-def _classify_ci_change(*paths: str) -> dict[str, bool]:
-    patterns = _ci_change_patterns()
-    return {
-        surface: any(pattern.search(path) for path in paths)
-        for surface, pattern in patterns.items()
-    }
-
-
-def test_ci_change_detector_workflow_only_edits_do_not_trigger_heavy_surfaces():
-    assert _classify_ci_change(".gitea/workflows/ci.yml") == {
-        "platform": False,
-        "canvas": False,
-        "python": False,
-        "scripts": False,
-    }
-    assert _classify_ci_change(".github/workflows/ci.yml") == {
-        "platform": False,
-        "canvas": False,
-        "python": False,
-        "scripts": False,
-    }
-
-
-def test_ci_change_detector_narrow_surface_edits_only_trigger_their_surface():
-    assert _classify_ci_change("workspace-server/internal/handlers/foo.go") == {
-        "platform": True,
-        "canvas": False,
-        "python": False,
-        "scripts": False,
-    }
-    assert _classify_ci_change("canvas/app/page.tsx") == {
-        "platform": False,
-        "canvas": True,
-        "python": False,
-        "scripts": False,
-    }
-    assert _classify_ci_change("workspace/a2a_mcp_server.py") == {
-        "platform": False,
-        "canvas": False,
-        "python": True,
-        "scripts": False,
-    }
-    assert _classify_ci_change("tests/e2e/test_model_slug.sh") == {
-        "platform": False,
-        "canvas": False,
-        "python": False,
-        "scripts": True,
-    }
-
-
-def test_ci_change_detector_docs_and_meta_scripts_do_not_trigger_surfaces():
-    assert _classify_ci_change("README.md") == {
-        "platform": False,
-        "canvas": False,
-        "python": False,
-        "scripts": False,
-    }
-    assert _classify_ci_change(".gitea/scripts/lint-workflow-yaml.py") == {
-        "platform": False,
-        "canvas": False,
-        "python": False,
-        "scripts": False,
-    }
@@ -495,7 +495,7 @@ def test_reap_required_check_pull_request_suffix_never_touched(sr_module, monkey
    }
    counters = sr_module.reap(workflow_map, combined, SHA, dry_run=False)
    assert counters["compensated"] == 0
-    assert counters["preserved_pr_without_push_success"] == 1
+    assert counters["preserved_non_push_suffix"] == 1
    assert calls == []


@@ -1009,64 +1009,3 @@ def test_reap_continues_on_per_sha_apierror(sr_module, monkeypatch, capsys):
    captured = capsys.readouterr()
    assert "::warning::" in captured.out or "::notice::" in captured.out
    assert SHA_A[:10] in captured.out
-
-
-def test_main_soft_skips_when_commit_listing_times_out(sr_module, monkeypatch, capsys):
-    """A transient outage while listing recent commits should not paint main red.
-
-    Per-SHA status read failures are already isolated inside `reap_branch`.
-    The real 2026-05-14 failure was earlier: `/commits?sha=main&limit=30`
-    timed out after all retries, aborting the tick. The next 5-minute tick can
-    retry safely, so `main()` should emit an observable warning and return 0.
-    """
-
-    monkeypatch.setattr(sr_module, "scan_workflows", lambda _: {"workflow-without-push": False})
-
-    def fake_list_recent_commit_shas(*args, **kwargs):
-        raise sr_module.ApiError(
-            "GET /repos/owner/repo/commits failed after 4 attempts: timed out"
-        )
-
-    monkeypatch.setattr(sr_module, "list_recent_commit_shas", fake_list_recent_commit_shas)
-    monkeypatch.setattr(sys, "argv", ["status-reaper.py"])
-
-    assert sr_module.main() == 0
-    captured = capsys.readouterr()
-    assert "::warning::status-reaper skipped this tick" in captured.out
-    assert '"skipped": true' in captured.out
-    assert '"skip_reason": "commit-list-api-error"' in captured.out
-
-
-def test_main_does_not_soft_skip_status_write_failures(sr_module, monkeypatch):
-    """Only commit-list read failures are soft-skipped.
-
-    A compensation write failure means the reaper could not repair a red
-    status. That must still fail the job loudly instead of being mislabeled as
-    a transient commit-list outage.
-    """
-
-    monkeypatch.setattr(sr_module, "scan_workflows", lambda _: {"workflow-without-push": False})
-    monkeypatch.setattr(sr_module, "list_recent_commit_shas", lambda *_args, **_kwargs: [SHA_A])
-    monkeypatch.setattr(
-        sr_module,
-        "get_combined_status",
-        lambda _sha: {
-            "state": "failure",
-            "statuses": [
-                {
-                    "context": "workflow-without-push / job (push)",
-                    "status": "failure",
-                    "description": "stranded class-O red",
-                }
-            ],
-        },
-    )
-
-    def fake_post_compensating_status(*args, **kwargs):
-        raise sr_module.ApiError("POST /statuses failed: 403")
-
-    monkeypatch.setattr(sr_module, "post_compensating_status", fake_post_compensating_status)
-    monkeypatch.setattr(sys, "argv", ["status-reaper.py"])
-
-    with pytest.raises(sr_module.ApiError, match="POST /statuses failed"):
-        sr_module.main()
@@ -32,9 +32,8 @@ func setupTestDBForQueueTests(t *testing.T) sqlmock.Sqlmock {
 	if err != nil {
 		t.Fatalf("failed to create sqlmock: %v", err)
 	}
-	prevDB := db.DB
 	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
+	t.Cleanup(func() { mockDB.Close() })
 	return mock
 }

@@ -388,13 +388,9 @@ func TestActivityList_BeforeTSRejectsInvalidFormat(t *testing.T) {
 // ---------- Activity type allowlist (#125: memory_write added) ----------

 func TestActivityReport_AcceptsMemoryWriteType(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
+	mockDB, mock, _ := sqlmock.New()
+	defer mockDB.Close()
 	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })

 	mock.ExpectExec(`INSERT INTO activity_logs`).
 		WillReturnResult(sqlmock.NewResult(1, 1))
@@ -417,13 +413,9 @@ func TestActivityReport_AcceptsMemoryWriteType(t *testing.T) {
 }

 func TestActivityReport_RejectsUnknownType(t *testing.T) {
-	mockDB, _, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
+	mockDB, _, _ := sqlmock.New()
+	defer mockDB.Close()
 	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })

 	broadcaster := newTestBroadcaster()
 	handler := NewActivityHandler(broadcaster)
@@ -455,13 +447,9 @@ func TestNotify_PersistsToActivityLogsForReloadRecovery(t *testing.T) {
 	//   - Have source_id NULL (canvas-source filter)
 	//   - Carry the message text in response_body so extractResponseText
 	//     can reconstruct the agent reply on reload
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
+	mockDB, mock, _ := sqlmock.New()
+	defer mockDB.Close()
 	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })

 	// Workspace existence check
 	mock.ExpectQuery(`SELECT name FROM workspaces`).
@@ -503,13 +491,9 @@ func TestNotify_WithAttachments_PersistsFilePartsForReload(t *testing.T) {
 	// download chips after a page reload. Without `parts`, the bubble
 	// shows up but the attachment chip is silently dropped on every
 	// refresh.
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
+	mockDB, mock, _ := sqlmock.New()
+	defer mockDB.Close()
 	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })

 	mock.ExpectQuery(`SELECT name FROM workspaces`).
 		WithArgs("ws-attach").
@@ -581,13 +565,9 @@ func TestNotify_RejectsAttachmentWithEmptyURIOrName(t *testing.T) {
 	}
 	for _, tc := range cases {
 		t.Run(tc.name, func(t *testing.T) {
-			mockDB, _, err := sqlmock.New()
-			if err != nil {
-				t.Fatalf("failed to create sqlmock: %v", err)
-			}
-			prevDB := db.DB
+			mockDB, _, _ := sqlmock.New()
+			defer mockDB.Close()
 			db.DB = mockDB
-			t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
 			// No DB expectations — handler must reject with 400 BEFORE
 			// reaching SELECT/INSERT. sqlmock will fail "expectations not met"
 			// only if the handler unexpectedly queries.
@@ -632,13 +612,9 @@ func TestNotify_DBFailure_StillBroadcastsAnd200(t *testing.T) {
 	// WebSocket push (which the user is already seeing in their open
 	// canvas). Pre-fix the WS push always succeeded; we don't want
 	// the new persistence step to regress that path.
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
+	mockDB, mock, _ := sqlmock.New()
+	defer mockDB.Close()
 	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })

 	mock.ExpectQuery(`SELECT name FROM workspaces`).
 		WithArgs("ws-x").
@@ -15,7 +15,6 @@ import (

 	sqlmock "github.com/DATA-DOG/go-sqlmock"
 	"github.com/Molecule-AI/molecule-monorepo/platform/internal/channels"
-	"github.com/Molecule-AI/molecule-monorepo/platform/internal/db"
 	"github.com/gin-gonic/gin"
 )

@@ -365,20 +364,6 @@ func TestChannelHandler_Discover_MissingToken(t *testing.T) {
 }

 func TestChannelHandler_Discover_UnsupportedType(t *testing.T) {
-	// Set up db.DB so PausePollersForToken (called inside Discover) doesn't panic.
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("sqlmock: %v", err)
-	}
-	t.Cleanup(func() { mockDB.Close() })
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB })
-
-	mock.ExpectQuery(`SELECT id, channel_config FROM workspace_channels WHERE enabled = true AND workspace_id`).
-		WithArgs("ws-test").
-		WillReturnRows(sqlmock.NewRows([]string{"id", "channel_config"}))
-
 	handler := NewChannelHandler(newTestChannelManager())

 	// #329: workspace_id required — include so we actually reach the
@@ -402,20 +387,6 @@ func TestChannelHandler_Discover_UnsupportedType(t *testing.T) {
 }

 func TestChannelHandler_Discover_InvalidBotToken(t *testing.T) {
-	// Set up db.DB so PausePollersForToken (called inside Discover) doesn't panic.
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("sqlmock: %v", err)
-	}
-	t.Cleanup(func() { mockDB.Close() })
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB })
-
-	mock.ExpectQuery(`SELECT id, channel_config FROM workspace_channels WHERE enabled = true AND workspace_id`).
-		WithArgs("ws-test").
-		WillReturnRows(sqlmock.NewRows([]string{"id", "channel_config"}))
-
 	handler := NewChannelHandler(newTestChannelManager())

 	body, _ := json.Marshal(map[string]interface{}{
@@ -262,20 +262,14 @@ func insertDelegationRow(ctx context.Context, c *gin.Context, sourceID string, b
 		"task":          body.Task,
 		"delegation_id": delegationID,
 	})
-	// Store delegation_id in response_body so agent check_delegation_status
-	// (which reads response_body->>delegation_id) can locate this row even
-	// when request_body hasn't propagated yet. Fixes mc#984.
-	respJSON, _ := json.Marshal(map[string]interface{}{
-		"delegation_id": delegationID,
-	})
 	var idemArg interface{}
 	if body.IdempotencyKey != "" {
 		idemArg = body.IdempotencyKey
 	}
 	_, err := db.DB.ExecContext(ctx, `
-		INSERT INTO activity_logs (workspace_id, activity_type, method, source_id, target_id, summary, request_body, response_body, status, idempotency_key)
-		VALUES ($1, 'delegation', 'delegate', $2, $3, $4, $5::jsonb, $6::jsonb, 'pending', $7)
-	`, sourceID, sourceID, body.TargetID, "Delegating to "+body.TargetID, string(taskJSON), string(respJSON), idemArg)
+		INSERT INTO activity_logs (workspace_id, activity_type, method, source_id, target_id, summary, request_body, status, idempotency_key)
+		VALUES ($1, 'delegation', 'delegate', $2, $3, $4, $5::jsonb, 'pending', $6)
+	`, sourceID, sourceID, body.TargetID, "Delegating to "+body.TargetID, string(taskJSON), idemArg)
 	if err == nil {
 		// RFC #2829 #318 — mirror to the durable delegations ledger
 		// (gated by DELEGATION_LEDGER_WRITE; default off → no-op).
@@ -550,15 +544,10 @@ func (h *DelegationHandler) Record(c *gin.Context) {
 		"task":          body.Task,
 		"delegation_id": body.DelegationID,
 	})
-	// Store delegation_id in response_body so agent check_delegation_status
-	// can locate this row. Fixes mc#984.
-	respJSON, _ := json.Marshal(map[string]interface{}{
-		"delegation_id": body.DelegationID,
-	})
 	if _, err := db.DB.ExecContext(ctx, `
-		INSERT INTO activity_logs (workspace_id, activity_type, method, source_id, target_id, summary, request_body, response_body, status)
-		VALUES ($1, 'delegation', 'delegate', $2, $3, $4, $5::jsonb, $6::jsonb, 'dispatched')
-	`, sourceID, sourceID, body.TargetID, "Delegating to "+body.TargetID, string(taskJSON), string(respJSON)); err != nil {
+		INSERT INTO activity_logs (workspace_id, activity_type, method, source_id, target_id, summary, request_body, status)
+		VALUES ($1, 'delegation', 'delegate', $2, $3, $4, $5::jsonb, 'dispatched')
+	`, sourceID, sourceID, body.TargetID, "Delegating to "+body.TargetID, string(taskJSON)); err != nil {
 		log.Printf("Delegation Record: insert failed for %s: %v", body.DelegationID, err)
 		c.JSON(http.StatusInternalServerError, gin.H{"error": "failed to record delegation"})
 		return
@@ -1,447 +0,0 @@
-package handlers
-
-// delegation_list_test.go — unit tests for listDelegationsFromLedger and
-// listDelegationsFromActivityLogs. Both methods are the data-backend of the
-// ListDelegations handler; coverage was missing (cf. infra-sre review of PR #942).
-
-import (
-	"context"
-	"testing"
-	"time"
-
-	"github.com/DATA-DOG/go-sqlmock"
-	"github.com/Molecule-AI/molecule-monorepo/platform/internal/db"
-)
-
-// ---------- listDelegationsFromLedger ----------
-
-func TestListDelegationsFromLedger_EmptyResult(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	rows := sqlmock.NewRows([]string{
-		"delegation_id", "caller_id", "callee_id", "task_preview",
-		"status", "result_preview", "error_detail",
-		"last_heartbeat", "deadline", "created_at", "updated_at",
-	})
-	mock.ExpectQuery("SELECT .+ FROM delegations").
-		WithArgs("ws-1").
-		WillReturnRows(rows)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromLedger(context.Background(), "ws-1")
-	if got != nil {
-		t.Errorf("empty result: expected nil, got %v", got)
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-func TestListDelegationsFromLedger_SingleRow(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	now := time.Now()
-	// Use time.Time{} for nullable *time.Time columns — sqlmock passes the
-	// zero value to the handler's scan destination. The handler checks Valid
-	// before using each nullable field, so zero values are safe.
-	rows := sqlmock.NewRows([]string{
-		"delegation_id", "caller_id", "callee_id", "task_preview",
-		"status", "result_preview", "error_detail",
-		"last_heartbeat", "deadline", "created_at", "updated_at",
-	}).AddRow(
-		"del-1", "ws-1", "ws-2", "summarise the report",
-		"completed", "the report is about Q1",
-		"", now, now, now, now,
-	)
-	mock.ExpectQuery("SELECT .+ FROM delegations").
-		WithArgs("ws-1").
-		WillReturnRows(rows)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromLedger(context.Background(), "ws-1")
-	if len(got) != 1 {
-		t.Fatalf("expected 1 entry, got %d", len(got))
-	}
-	e := got[0]
-	if e["delegation_id"] != "del-1" {
-		t.Errorf("delegation_id: got %v, want del-1", e["delegation_id"])
-	}
-	if e["source_id"] != "ws-1" {
-		t.Errorf("source_id: got %v, want ws-1", e["source_id"])
-	}
-	if e["target_id"] != "ws-2" {
-		t.Errorf("target_id: got %v, want ws-2", e["target_id"])
-	}
-	if e["status"] != "completed" {
-		t.Errorf("status: got %v, want completed", e["status"])
-	}
-	if e["response_preview"] != "the report is about Q1" {
-		t.Errorf("response_preview: got %v", e["response_preview"])
-	}
-	if _, ok := e["error"]; ok {
-		t.Errorf("error should be absent when empty, got %v", e["error"])
-	}
-	if e["_ledger"] != true {
-		t.Errorf("_ledger marker: got %v, want true", e["_ledger"])
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-func TestListDelegationsFromLedger_MultipleRows(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	now := time.Now()
-	rows := sqlmock.NewRows([]string{
-		"delegation_id", "caller_id", "callee_id", "task_preview",
-		"status", "result_preview", "error_detail",
-		"last_heartbeat", "deadline", "created_at", "updated_at",
-	}).
-		AddRow("del-a", "ws-1", "ws-2", "task a", "in_progress", "", "", now, now, now, now).
-		AddRow("del-b", "ws-1", "ws-3", "task b", "failed", "", "timeout", now, now, now, now).
-		AddRow("del-c", "ws-1", "ws-4", "task c", "completed", "result c", "", now, now, now, now)
-	mock.ExpectQuery("SELECT .+ FROM delegations").
-		WithArgs("ws-1").
-		WillReturnRows(rows)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromLedger(context.Background(), "ws-1")
-	if len(got) != 3 {
-		t.Fatalf("expected 3 entries, got %d", len(got))
-	}
-	if got[0]["delegation_id"] != "del-a" || got[1]["delegation_id"] != "del-b" || got[2]["delegation_id"] != "del-c" {
-		t.Errorf("unexpected order: %v", got)
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-func TestListDelegationsFromLedger_QueryError(t *testing.T) {
-	// Query failure returns nil — graceful fallback, no panic.
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	mock.ExpectQuery("SELECT .+ FROM delegations").
-		WithArgs("ws-1").
-		WillReturnError(context.DeadlineExceeded)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromLedger(context.Background(), "ws-1")
-	if got != nil {
-		t.Errorf("query error: expected nil, got %v", got)
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-func TestListDelegationsFromLedger_RowsErr(t *testing.T) {
-	// rows.Err() mid-stream: handler collects partial results and returns them.
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	now := time.Now()
-	// RowError(0) before AddRow(0): row 0 is "bad", rows.Next() returns false
-	// on first call — the row never scans, result stays nil. To get partial
-	// results (row 0 scanned) with rows.Err() non-nil, we use 2 rows and put
-	// RowError(1) after AddRow(1): row 0 scans normally, row 1 is bad,
-	// rows.Err() is error, handler returns partial result.
-	rows := sqlmock.NewRows([]string{
-		"delegation_id", "caller_id", "callee_id", "task_preview",
-		"status", "result_preview", "error_detail",
-		"last_heartbeat", "deadline", "created_at", "updated_at",
-	}).
-		AddRow("del-1", "ws-1", "ws-2", "task", "queued", "", "", now, now, now, now).
-		AddRow("del-2", "ws-1", "ws-3", "another task", "queued", "", "", now, now, now, now).
-		RowError(1, context.DeadlineExceeded)
-	mock.ExpectQuery("SELECT .+ FROM delegations").
-		WithArgs("ws-1").
-		WillReturnRows(rows)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromLedger(context.Background(), "ws-1")
-	// Row 0 scanned and appended; row 1 is bad; rows.Err() is non-nil.
-	// Handler logs the error but returns result (partial results because result != nil).
-	if got == nil || len(got) != 1 {
-		t.Errorf("rows.Err path: expected 1 partial result, got %v", got)
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-// TestListDelegationsFromLedger_ScanError is removed.
-//
-// In Go 1.25 sqlmock.NewRows validates column count at AddRow() time and
-// panics when len(values) != len(columns). The old pattern
-//   sqlmock.NewRows([]string{}).AddRow("only-one-col")
-// therefore panics in test SETUP, not inside the handler. The handler has no
-// recover(), so a scan panic would propagate out of listDelegationsFromLedger
-// and crash the process — this is the correct behaviour (not silently skipping
-// a row). The correct way to cover this path is a real-DB integration test.
-//
-// ---------- listDelegationsFromActivityLogs ----------
-
-func TestListDelegationsFromActivityLogs_EmptyResult(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	rows := sqlmock.NewRows([]string{
-		"id", "activity_type", "source_id", "target_id",
-		"summary", "status", "error_detail",
-		"response_preview", "delegation_id", "created_at",
-	})
-	mock.ExpectQuery("SELECT .+ FROM activity_logs").
-		WithArgs("ws-1").
-		WillReturnRows(rows)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromActivityLogs(context.Background(), "ws-1")
-	if len(got) != 0 {
-		t.Errorf("empty result: expected empty slice, got %v", got)
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-func TestListDelegationsFromActivityLogs_SingleDelegateRow(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	now := time.Now()
-	rows := sqlmock.NewRows([]string{
-		"id", "activity_type", "source_id", "target_id",
-		"summary", "status", "error_detail",
-		"response_preview", "delegation_id", "created_at",
-	}).AddRow(
-		"act-1", "delegate",
-		"ws-1", "ws-2",
-		"analyse Q1 numbers",
-		"in_progress",
-		"", "", "",
-		now,
-	)
-	mock.ExpectQuery("SELECT .+ FROM activity_logs").
-		WithArgs("ws-1").
-		WillReturnRows(rows)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromActivityLogs(context.Background(), "ws-1")
-	if len(got) != 1 {
-		t.Fatalf("expected 1 entry, got %d", len(got))
-	}
-	e := got[0]
-	if e["id"] != "act-1" {
-		t.Errorf("id: got %v, want act-1", e["id"])
-	}
-	if e["type"] != "delegate" {
-		t.Errorf("type: got %v, want delegate", e["type"])
-	}
-	if e["source_id"] != "ws-1" {
-		t.Errorf("source_id: got %v, want ws-1", e["source_id"])
-	}
-	if e["target_id"] != "ws-2" {
-		t.Errorf("target_id: got %v, want ws-2", e["target_id"])
-	}
-	if e["summary"] != "analyse Q1 numbers" {
-		t.Errorf("summary: got %v", e["summary"])
-	}
-	if e["status"] != "in_progress" {
-		t.Errorf("status: got %v", e["status"])
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-func TestListDelegationsFromActivityLogs_DelegateResultWithError(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	now := time.Now()
-	rows := sqlmock.NewRows([]string{
-		"id", "activity_type", "source_id", "target_id",
-		"summary", "status", "error_detail",
-		"response_preview", "delegation_id", "created_at",
-	}).AddRow(
-		"act-2", "delegate_result",
-		"ws-1", "ws-2",
-		"result summary",
-		"failed",
-		"Callee workspace not reachable",
-		`{"text":"the result body text"}`,
-		"del-abc",
-		now,
-	)
-	mock.ExpectQuery("SELECT .+ FROM activity_logs").
-		WithArgs("ws-1").
-		WillReturnRows(rows)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromActivityLogs(context.Background(), "ws-1")
-	if len(got) != 1 {
-		t.Fatalf("expected 1 entry, got %d", len(got))
-	}
-	e := got[0]
-	if e["type"] != "delegate_result" {
-		t.Errorf("type: got %v", e["type"])
-	}
-	if e["error"] != "Callee workspace not reachable" {
-		t.Errorf("error: got %v", e["error"])
-	}
-	if e["response_preview"] != `{"text":"the result body text"}` {
-		t.Errorf("response_preview: got %v", e["response_preview"])
-	}
-	if e["delegation_id"] != "del-abc" {
-		t.Errorf("delegation_id: got %v", e["delegation_id"])
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-func TestListDelegationsFromActivityLogs_QueryError(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	mock.ExpectQuery("SELECT .+ FROM activity_logs").
-		WithArgs("ws-1").
-		WillReturnError(context.DeadlineExceeded)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromActivityLogs(context.Background(), "ws-1")
-	// Error → returns empty slice, not nil.
-	if len(got) != 0 {
-		t.Errorf("query error: expected empty slice, got %v", got)
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-func TestListDelegationsFromActivityLogs_RowsErr(t *testing.T) {
-	mockDB, mock, err := sqlmock.New()
-	if err != nil {
-		t.Fatalf("failed to create sqlmock: %v", err)
-	}
-	prevDB := db.DB
-	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
-
-	now := time.Now()
-	// RowError(0) before AddRow(0): row 0 is "bad", rows.Next() returns false
-	// on first call — the row never scans, result stays nil. To get partial
-	// results (row 0 scanned) with rows.Err() non-nil, we use 2 rows and put
-	// RowError(1) after AddRow(1): row 0 scans normally, row 1 is bad,
-	// rows.Err() is error, handler returns partial result.
-	rows := sqlmock.NewRows([]string{
-		"id", "activity_type", "source_id", "target_id",
-		"summary", "status", "error_detail",
-		"response_preview", "delegation_id", "created_at",
-	}).
-		AddRow("act-1", "delegate", "ws-1", "ws-2", "task", "queued", "", "", "", now).
-		AddRow("act-2", "delegate", "ws-1", "ws-3", "another task", "queued", "", "", "", now).
-		RowError(1, context.DeadlineExceeded)
-	mock.ExpectQuery("SELECT .+ FROM activity_logs").
-		WithArgs("ws-1").
-		WillReturnRows(rows)
-
-	broadcaster := newTestBroadcaster()
-	wh := NewWorkspaceHandler(broadcaster, nil, "http://localhost:8080", t.TempDir())
-	dh := NewDelegationHandler(wh, broadcaster)
-
-	got := dh.listDelegationsFromActivityLogs(context.Background(), "ws-1")
-	// Row 0 scanned and appended; row 1 is bad; rows.Err() is non-nil.
-	// Handler logs the error but returns result (partial results because result != nil).
-	if got == nil || len(got) != 1 {
-		t.Errorf("rows.Err path: expected 1 partial result, got %v", got)
-	}
-	if err := mock.ExpectationsWereMet(); err != nil {
-		t.Errorf("sqlmock expectations: %v", err)
-	}
-}
-
-// TestListDelegationsFromActivityLogs_ScanErrorSkipped is removed.
-//
-// Same reason as TestListDelegationsFromLedger_ScanError: Go 1.25 causes
-// sqlmock.NewRows([]string{}).AddRow(...) to panic in test SETUP. The handler
-// has no recover(), so a scan panic would crash the process — the correct
-// behaviour. Real-DB integration tests cover this path.
@@ -133,9 +133,9 @@ func TestDelegate_Success(t *testing.T) {
 	targetID := "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee"

 	// Expect INSERT into activity_logs for delegation tracking
-	// (6th arg is response_body, 7th is idempotency_key — nil here since the request omits it)
+	// (6th arg is idempotency_key — nil here since the request omits it)
 	mock.ExpectExec("INSERT INTO activity_logs").
-		WithArgs("ws-source", "ws-source", targetID, "Delegating to "+targetID, sqlmock.AnyArg(), sqlmock.AnyArg(), nil).
+		WithArgs("ws-source", "ws-source", targetID, "Delegating to "+targetID, sqlmock.AnyArg(), nil).
 		WillReturnResult(sqlmock.NewResult(0, 1))

 	// Expect RecordAndBroadcast INSERT into structure_events
@@ -189,9 +189,9 @@ func TestDelegate_DBInsertFails_Still202WithWarning(t *testing.T) {

 	targetID := "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee"

-	// DB insert fails (6th arg = response_body, 7th = idempotency_key, nil for this test)
+	// DB insert fails (6th arg = idempotency_key, nil for this test)
 	mock.ExpectExec("INSERT INTO activity_logs").
-		WithArgs("ws-source", "ws-source", targetID, "Delegating to "+targetID, sqlmock.AnyArg(), sqlmock.AnyArg(), nil).
+		WithArgs("ws-source", "ws-source", targetID, "Delegating to "+targetID, sqlmock.AnyArg(), nil).
 		WillReturnError(fmt.Errorf("database connection lost"))

 	// RecordAndBroadcast still fires
@@ -491,7 +491,6 @@ func TestDelegationRecord_InsertsActivityLogRow(t *testing.T) {
 			"550e8400-e29b-41d4-a716-446655440001",               // target_id
 			"Delegating to 550e8400-e29b-41d4-a716-446655440001", // summary
 			sqlmock.AnyArg(), // request_body (jsonb)
-			sqlmock.AnyArg(), // response_body (jsonb) — mc#984 fix
 		).
 		WillReturnResult(sqlmock.NewResult(0, 1))
 	// RecordAndBroadcast INSERT for DELEGATION_SENT
@@ -700,9 +699,9 @@ func TestDelegate_IdempotentFailedRowIsReleasedAndReplaced(t *testing.T) {
 	mock.ExpectExec("DELETE FROM activity_logs").
 		WithArgs("ws-source", "retry-key").
 		WillReturnResult(sqlmock.NewResult(0, 1))
-	// Fresh insert with the same idempotency key (response_body added as mc#984 fix).
+	// Fresh insert with the same idempotency key.
 	mock.ExpectExec("INSERT INTO activity_logs").
-		WithArgs("ws-source", "ws-source", targetID, "Delegating to "+targetID, sqlmock.AnyArg(), sqlmock.AnyArg(), "retry-key").
+		WithArgs("ws-source", "ws-source", targetID, "Delegating to "+targetID, sqlmock.AnyArg(), "retry-key").
 		WillReturnResult(sqlmock.NewResult(0, 1))
 	mock.ExpectExec("INSERT INTO structure_events").
 		WillReturnResult(sqlmock.NewResult(0, 1))
@@ -746,9 +745,9 @@ func TestDelegate_IdempotentRaceUniqueViolationReturnsExisting(t *testing.T) {
 	mock.ExpectQuery("SELECT request_body->>'delegation_id', status, target_id").
 		WithArgs("ws-source", "race-key").
 		WillReturnError(fmt.Errorf("sql: no rows in result set"))
-	// Insert loses the race against a concurrent caller (response_body added as mc#984 fix).
+	// Insert loses the race against a concurrent caller.
 	mock.ExpectExec("INSERT INTO activity_logs").
-		WithArgs("ws-source", "ws-source", targetID, "Delegating to "+targetID, sqlmock.AnyArg(), sqlmock.AnyArg(), "race-key").
+		WithArgs("ws-source", "ws-source", targetID, "Delegating to "+targetID, sqlmock.AnyArg(), "race-key").
 		WillReturnError(fmt.Errorf("pq: duplicate key value violates unique constraint \"activity_logs_idempotency_uniq\""))
 	// Re-query returns the winner.
 	mock.ExpectQuery("SELECT request_body->>'delegation_id', status").
@@ -35,9 +35,8 @@ func setupTestDB(t *testing.T) sqlmock.Sqlmock {
 	if err != nil {
 		t.Fatalf("failed to create sqlmock: %v", err)
 	}
-	prevDB := db.DB
 	db.DB = mockDB
-	t.Cleanup(func() { db.DB = prevDB; mockDB.Close() })
+	t.Cleanup(func() { mockDB.Close() })

 	// Disable SSRF checks for the duration of this test only. Restore
 	// the previous state via t.Cleanup so that TestIsSafeURL_* tests
@@ -367,7 +366,7 @@ func TestBuildProvisionerConfig_IncludesAwarenessSettings(t *testing.T) {
 		"ws-123",
 		"/tmp/configs/template",
 		map[string][]byte{"config.yaml": []byte("name: test")},
-		models.CreateWorkspacePayload{Tier: 2, Runtime: "claude-code", WorkspaceDir: "/tmp/workspace", WorkspaceAccess: "read_write"},
+		models.CreateWorkspacePayload{Tier: 2, Runtime: "claude-code"},
 		map[string]string{"OPENAI_API_KEY": "sk-test"},
 		"/tmp/plugins",
 		"workspace:ws-123",
@@ -1,322 +0,0 @@
-package handlers
-
-import (
-	"path/filepath"
-	"strings"
-	"testing"
-)
-
-// org_helpers_security_test.go — security-critical path sanitization + role-name
-// validation for org template processing. Covers OFFSEC-006-class attacks:
-// path traversal via user-controlled files_dir / prompt_file refs, and role-name
-// injection via the persona env loader.
-
-// ── resolveInsideRoot ──────────────────────────────────────────────────────────
-
-func TestResolveInsideRoot_EmptyUserPath(t *testing.T) {
-	_, err := resolveInsideRoot("/safe/root", "")
-	if err == nil {
-		t.Fatal("empty userPath: expected error, got nil")
-	}
-	if err.Error() != "path is empty" {
-		t.Errorf("empty userPath: got %q, want %q", err.Error(), "path is empty")
-	}
-}
-
-func TestResolveInsideRoot_AbsolutePathRejected(t *testing.T) {
-	_, err := resolveInsideRoot("/safe/root", "/etc/passwd")
-	if err == nil {
-		t.Fatal("absolute userPath: expected error, got nil")
-	}
-	if err.Error() != "absolute paths are not allowed" {
-		t.Errorf("absolute userPath: got %q, want %q", err.Error(), "absolute paths are not allowed")
-	}
-}
-
-func TestResolveInsideRoot_DotDotTraversal(t *testing.T) {
-	// ../../etc/passwd from /safe/root
-	got, err := resolveInsideRoot("/safe/root", "../../etc/passwd")
-	if err == nil {
-		t.Fatalf("dotdot traversal: expected error, got %q", got)
-	}
-	if err.Error() != "path escapes root" {
-		t.Errorf("dotdot traversal: got %q, want %q", err.Error(), "path escapes root")
-	}
-}
-
-func TestResolveInsideRoot_DotDotWithIntermediate(t *testing.T) {
-	// a/b/../../c normalises to "c" — a valid descendant inside any root.
-	// Must use t.TempDir() for a real filesystem path so filepath.Abs resolves.
-	root := t.TempDir()
-	got, err := resolveInsideRoot(root, "a/b/../../c")
-	if err != nil {
-		t.Fatalf("a/b/../../c should resolve within root: %v", err)
-	}
-	// Verify result is inside root and ends with "c"
-	if !strings.HasPrefix(got, root+string(filepath.Separator)) {
-		t.Errorf("result should be inside root %q, got %q", root, got)
-	}
-	if got[len(got)-1:] != "c" {
-		t.Errorf("resolved path should end in 'c', got %q", got)
-	}
-}
-
-func TestResolveInsideRoot_ValidRelativePath(t *testing.T) {
-	// This test uses the real filesystem since resolveInsideRoot calls filepath.Abs.
-	// Use t.TempDir() so we have a real root to work with.
-	root := t.TempDir()
-	got, err := resolveInsideRoot(root, "subdir/file.txt")
-	if err != nil {
-		t.Fatalf("valid relative: unexpected error: %v", err)
-	}
-	// Must be inside root
-	if got[:len(root)] != root {
-		t.Errorf("result should start with root %q, got %q", root, got)
-	}
-}
-
-func TestResolveInsideRoot_ExactRootMatch(t *testing.T) {
-	root := t.TempDir()
-	got, err := resolveInsideRoot(root, ".")
-	if err != nil {
-		t.Fatalf("exact root: unexpected error: %v", err)
-	}
-	if got != root {
-		t.Errorf("exact root match: got %q, want %q", got, root)
-	}
-}
-
-func TestResolveInsideRoot_DotPathComponent(t *testing.T) {
-	root := t.TempDir()
-	// ./subdir/./file.txt should resolve to root/subdir/file.txt
-	got, err := resolveInsideRoot(root, "./subdir/./file.txt")
-	if err != nil {
-		t.Fatalf("dot path component: unexpected error: %v", err)
-	}
-	if got[len(got)-14:] != "/subdir/file.txt" {
-		t.Errorf("dot path component: got %q, want suffix /subdir/file.txt", got)
-	}
-}
-
-func TestResolveInsideRoot_NestedDotDotEscapes(t *testing.T) {
-	root := t.TempDir()
-	// a/../../b from /tmp/dirsomething → /tmp/b (escapes temp dir)
-	got, err := resolveInsideRoot(root, "a/../../b")
-	if err == nil {
-		t.Fatalf("nested dotdot: expected error, got %q", got)
-	}
-	if err.Error() != "path escapes root" {
-		t.Errorf("nested dotdot: got %q, want %q", err.Error(), "path escapes root")
-	}
-}
-
-func TestResolveInsideRoot_DotdotAtStart(t *testing.T) {
-	root := t.TempDir()
-	got, err := resolveInsideRoot(root, "../sibling")
-	if err == nil {
-		t.Fatalf("../sibling: expected error, got %q", got)
-	}
-	if err.Error() != "path escapes root" {
-		t.Errorf("../sibling: got %q, want %q", err.Error(), "path escapes root")
-	}
-}
-
-func TestResolveInsideRoot_SiblingNotEscaped(t *testing.T) {
-	// /foo/bar and /foo/baz are siblings — the prefix check with
-	// filepath.Separator guard must allow /foo/bar/child without matching /foo/baz
-	// (which would be wrong if the check were just strings.HasPrefix).
-	root := t.TempDir()
-	got, err := resolveInsideRoot(root, "valid-subdir/file.txt")
-	if err != nil {
-		t.Fatalf("sibling not escaped: unexpected error: %v", err)
-	}
-	// Must be inside root
-	if !strings.HasPrefix(got, root+string(filepath.Separator)) {
-		t.Errorf("result should be inside root %q, got %q", root, got)
-	}
-}
-
-// ── isSafeRoleName ────────────────────────────────────────────────────────────
-
-func TestIsSafeRoleName_Valid(t *testing.T) {
-	valid := []string{
-		"backend",
-		"Frontend-Engineer",
-		"research_lead",
-		"devOps123",
-		"a",
-		"A",
-		"team_42-leads",
-	}
-	for _, name := range valid {
-		if !isSafeRoleName(name) {
-			t.Errorf("isSafeRoleName(%q): expected true, got false", name)
-		}
-	}
-}
-
-func TestIsSafeRoleName_Empty(t *testing.T) {
-	if isSafeRoleName("") {
-		t.Error("isSafeRoleName(\"\"): expected false, got true")
-	}
-}
-
-func TestIsSafeRoleName_Dot(t *testing.T) {
-	if isSafeRoleName(".") {
-		t.Error("isSafeRoleName(\".\"): expected false, got true")
-	}
-}
-
-func TestIsSafeRoleName_DotDot(t *testing.T) {
-	if isSafeRoleName("..") {
-		t.Error("isSafeRoleName(\"..\"): expected false, got true")
-	}
-}
-
-func TestIsSafeRoleName_PathTraversal(t *testing.T) {
-	unsafe := []string{
-		"../etc",
-		"foo/../../../etc",
-		"foo/../../bar",
-	}
-	for _, name := range unsafe {
-		if isSafeRoleName(name) {
-			t.Errorf("isSafeRoleName(%q): expected false (path traversal), got true", name)
-		}
-	}
-}
-
-func TestIsSafeRoleName_SpecialChars(t *testing.T) {
-	unsafe := []string{
-		"foo:bar",
-		"foo bar",
-		"foo\tbar",
-		"foo\nbar",
-		"foo\x00bar",
-		"foo@bar",
-		"foo#bar",
-		"foo$bar",
-	}
-	for _, name := range unsafe {
-		if isSafeRoleName(name) {
-			t.Errorf("isSafeRoleName(%q): expected false (special char), got true", name)
-		}
-	}
-}
-
-// ── mergeCategoryRouting ──────────────────────────────────────────────────────
-
-func TestMergeCategoryRouting_BothNil(t *testing.T) {
-	got := mergeCategoryRouting(nil, nil)
-	if len(got) != 0 {
-		t.Errorf("both nil: got %v, want empty", got)
-	}
-}
-
-func TestMergeCategoryRouting_DefaultOnly(t *testing.T) {
-	defaultRouting := map[string][]string{
-		"security": {"Backend Engineer", "DevOps"},
-	}
-	got := mergeCategoryRouting(defaultRouting, nil)
-	if len(got) != 1 {
-		t.Fatalf("default only: got %d entries, want 1", len(got))
-	}
-	if len(got["security"]) != 2 {
-		t.Errorf("security roles: got %v, want [Backend Engineer, DevOps]", got["security"])
-	}
-}
-
-func TestMergeCategoryRouting_WorkspaceOnly(t *testing.T) {
-	wsRouting := map[string][]string{
-		"ui": {"Frontend Engineer"},
-	}
-	got := mergeCategoryRouting(nil, wsRouting)
-	if len(got) != 1 {
-		t.Fatalf("ws only: got %d entries, want 1", len(got))
-	}
-	if got["ui"][0] != "Frontend Engineer" {
-		t.Errorf("ui roles: got %v, want [Frontend Engineer]", got["ui"])
-	}
-}
-
-func TestMergeCategoryRouting_MergeNoOverlap(t *testing.T) {
-	defaultRouting := map[string][]string{
-		"security": {"Backend Engineer"},
-	}
-	wsRouting := map[string][]string{
-		"ui": {"Frontend Engineer"},
-	}
-	got := mergeCategoryRouting(defaultRouting, wsRouting)
-	if len(got) != 2 {
-		t.Errorf("merge no overlap: got %d entries, want 2", len(got))
-	}
-}
-
-func TestMergeCategoryRouting_WsOverrideDropsDefault(t *testing.T) {
-	defaultRouting := map[string][]string{
-		"security": {"Backend Engineer", "DevOps"},
-	}
-	wsRouting := map[string][]string{
-		"security": {"Security Engineer"},
-	}
-	got := mergeCategoryRouting(defaultRouting, wsRouting)
-	if len(got["security"]) != 1 {
-		t.Errorf("ws override: got %v, want [Security Engineer]", got["security"])
-	}
-	if got["security"][0] != "Security Engineer" {
-		t.Errorf("ws override: got %v, want [Security Engineer]", got["security"])
-	}
-}
-
-func TestMergeCategoryRouting_EmptyListDropsCategory(t *testing.T) {
-	defaultRouting := map[string][]string{
-		"security": {"Backend Engineer"},
-		"ui":       {"Frontend Engineer"},
-	}
-	wsRouting := map[string][]string{
-		"security": {}, // empty list = opt out
-	}
-	got := mergeCategoryRouting(defaultRouting, wsRouting)
-	if _, exists := got["security"]; exists {
-		t.Error("empty ws list should delete the category from output")
-	}
-	if len(got["ui"]) != 1 {
-		t.Errorf("ui should still exist: got %v", got["ui"])
-	}
-}
-
-func TestMergeCategoryRouting_EmptyKeySkipped(t *testing.T) {
-	defaultRouting := map[string][]string{
-		"": {"Backend Engineer"},
-	}
-	got := mergeCategoryRouting(defaultRouting, nil)
-	if _, exists := got[""]; exists {
-		t.Error("empty key should be skipped")
-	}
-}
-
-func TestMergeCategoryRouting_EmptyRolesInDefaultSkipped(t *testing.T) {
-	defaultRouting := map[string][]string{
-		"security": {},
-	}
-	got := mergeCategoryRouting(defaultRouting, nil)
-	if len(got) != 0 {
-		t.Errorf("empty roles in default should be skipped, got %v", got)
-	}
-}
-
-func TestMergeCategoryRouting_OriginalMapsUnmodified(t *testing.T) {
-	defaultRouting := map[string][]string{
-		"security": {"Backend Engineer"},
-	}
-	wsRouting := map[string][]string{
-		"ui": {"Frontend Engineer"},
-	}
-	mergeCategoryRouting(defaultRouting, wsRouting)
-	if len(defaultRouting) != 1 || len(defaultRouting["security"]) != 1 {
-		t.Error("default routing should be unmodified after merge")
-	}
-	if len(wsRouting) != 1 {
-		t.Error("ws routing should be unmodified after merge")
-	}
-}
@@ -1,8 +1,6 @@
 package handlers

 import (
-	"errors"
-	"fmt"
 	"sort"
 	"strings"
 	"testing"
@@ -356,6 +354,12 @@ func TestExpandWithEnv_UnsetVar(t *testing.T) {
 	}
 }

+func TestHasUnresolvedVarRef_NoVars(t *testing.T) {
+	if hasUnresolvedVarRef("plain text", "plain text") {
+		t.Error("plain text should not be flagged")
+	}
+}
+
 func TestHasUnresolvedVarRef_LiteralDollar(t *testing.T) {
 	// "$5" is a literal price, not a var ref — should NOT be flagged
 	if hasUnresolvedVarRef("price: $5", "price: $5") {
@@ -363,6 +367,20 @@ func TestHasUnresolvedVarRef_LiteralDollar(t *testing.T) {
 	}
 }

+func TestHasUnresolvedVarRef_Resolved(t *testing.T) {
+	// Original had ${VAR}, expanded to "value" — fully resolved
+	if hasUnresolvedVarRef("${VAR}", "value") {
+		t.Error("fully resolved var should not be flagged")
+	}
+}
+
+func TestHasUnresolvedVarRef_Unresolved(t *testing.T) {
+	// Original had ${VAR}, expanded to "" — unresolved
+	if !hasUnresolvedVarRef("${VAR}", "") {
+		t.Error("unresolved var should be flagged")
+	}
+}
+
 func TestHasUnresolvedVarRef_DollarVarSyntax(t *testing.T) {
 	// $VAR syntax (no braces) — also a real ref
 	if !hasUnresolvedVarRef("$MISSING_VAR", "") {
@@ -1058,71 +1076,3 @@ func TestCollectOrgEnv_AnyOfWithInvalidMemberKeepsValidOnes(t *testing.T) {
 		t.Errorf("expected VALID_ONE to survive, got %v", reqNames(req))
 	}
 }
-
-func TestResolveProvisionConcurrency_ValidPositive(t *testing.T) {
-	t.Setenv("MOLECULE_PROVISION_CONCURRENCY", "8")
-	got := resolveProvisionConcurrency()
-	if got != 8 {
-		t.Errorf("valid positive: got %d, want 8", got)
-	}
-}
-
-func TestResolveProvisionConcurrency_Zero(t *testing.T) {
-	t.Setenv("MOLECULE_PROVISION_CONCURRENCY", "0")
-	got := resolveProvisionConcurrency()
-	if got != 1<<20 {
-		t.Errorf("zero (unlimited): got %d, want %d", got, 1<<20)
-	}
-}
-
-func TestResolveProvisionConcurrency_Negative(t *testing.T) {
-	t.Setenv("MOLECULE_PROVISION_CONCURRENCY", "-5")
-	got := resolveProvisionConcurrency()
-	if got != defaultProvisionConcurrency {
-		t.Errorf("negative: got %d, want default %d", got, defaultProvisionConcurrency)
-	}
-}
-
-func TestResolveProvisionConcurrency_NonInteger(t *testing.T) {
-	t.Setenv("MOLECULE_PROVISION_CONCURRENCY", "abc")
-	got := resolveProvisionConcurrency()
-	if got != defaultProvisionConcurrency {
-		t.Errorf("non-integer: got %d, want default %d", got, defaultProvisionConcurrency)
-	}
-}
-
-func TestResolveProvisionConcurrency_Whitespace(t *testing.T) {
-	t.Setenv("MOLECULE_PROVISION_CONCURRENCY", "  7  ")
-	got := resolveProvisionConcurrency()
-	if got != 7 {
-		t.Errorf("whitespace: got %d, want 7", got)
-	}
-}
-
-// ─────────────────────────────────────────────────────────────────────────────
-// errString tests
-// ─────────────────────────────────────────────────────────────────────────────
-
-func TestErrString_Nil(t *testing.T) {
-	got := errString(nil)
-	if got != "" {
-		t.Errorf("nil error: got %q, want empty string", got)
-	}
-}
-
-func TestErrString_NonNil(t *testing.T) {
-	err := fmt.Errorf("something went wrong")
-	got := errString(err)
-	if got != "something went wrong" {
-		t.Errorf("non-nil error: got %q, want %q", got, "something went wrong")
-	}
-}
-
-func TestErrString_Wrapped(t *testing.T) {
-	inner := errors.New("inner")
-	err := fmt.Errorf("outer: %w", inner)
-	got := errString(err)
-	if !strings.Contains(got, "outer") {
-		t.Errorf("wrapped error: got %q, want containing 'outer'", got)
-	}
-}
@@ -1,310 +0,0 @@
-package handlers
-
-// plugins_atomic_tar_test.go — unit tests for tarWalk (the only non-trivial
-// function in plugins_atomic_tar.go). The file contains only pure tar-walk
-// logic with no DB or HTTP dependencies, so tests use real temp directories
-// with no mocking.
-
-import (
-	"archive/tar"
-	"bytes"
-	"io"
-	"os"
-	"path/filepath"
-	"strings"
-	"testing"
-)
-
-// ─── newTarWriter ─────────────────────────────────────────────────────────────
-
-func TestNewTarWriter_Basic(t *testing.T) {
-	var buf bytes.Buffer
-	tw := newTarWriter(&buf)
-	if tw == nil {
-		t.Fatal("newTarWriter returned nil")
-	}
-	// Write a header to prove the writer is functional.
-	hdr := &tar.Header{
-		Name: "test.txt",
-		Mode: 0644,
-		Size: 5,
-	}
-	if err := tw.WriteHeader(hdr); err != nil {
-		t.Fatalf("WriteHeader failed: %v", err)
-	}
-	if _, err := tw.Write([]byte("hello")); err != nil {
-		t.Fatalf("Write failed: %v", err)
-	}
-	if err := tw.Close(); err != nil {
-		t.Fatalf("Close failed: %v", err)
-	}
-}
-
-// ─── tarWalk: empty directory ─────────────────────────────────────────────────
-
-func TestTarWalk_EmptyDir(t *testing.T) {
-	tmp := t.TempDir()
-	var buf bytes.Buffer
-	tw := tar.NewWriter(&buf)
-
-	if err := tarWalk(tmp, "prefix", tw); err != nil {
-		t.Fatalf("tarWalk error: %v", err)
-	}
-	if err := tw.Close(); err != nil {
-		t.Fatalf("tw.Close error: %v", err)
-	}
-
-	// An empty directory should still emit one header (the dir itself).
-	rdr := tar.NewReader(&buf)
-	hdr, err := rdr.Next()
-	if err != nil {
-		t.Fatalf("expected at least the dir header, got error: %v", err)
-	}
-	if !strings.HasSuffix(hdr.Name, "/") {
-		t.Errorf("expected directory name ending in '/', got %q", hdr.Name)
-	}
-
-	// No more entries.
-	if _, err := rdr.Next(); err != io.EOF {
-		t.Errorf("expected only one header, got more: %v", err)
-	}
-}
-
-// ─── tarWalk: single file ─────────────────────────────────────────────────────
-
-func TestTarWalk_SingleFile(t *testing.T) {
-	tmp := t.TempDir()
-	if err := os.WriteFile(filepath.Join(tmp, "hello.txt"), []byte("world"), 0644); err != nil {
-		t.Fatal(err)
-	}
-
-	var buf bytes.Buffer
-	tw := tar.NewWriter(&buf)
-	if err := tarWalk(tmp, "mydir", tw); err != nil {
-		t.Fatalf("tarWalk error: %v", err)
-	}
-	if err := tw.Close(); err != nil {
-		t.Fatal(err)
-	}
-
-	// Should have 2 entries: the dir prefix, then hello.txt.
-	entries := 0
-	names := []string{}
-	rdr := tar.NewReader(&buf)
-	for {
-		hdr, err := rdr.Next()
-		if err == io.EOF {
-			break
-		}
-		if err != nil {
-			t.Fatalf("unexpected error reading tar: %v", err)
-		}
-		entries++
-		names = append(names, hdr.Name)
-
-		if hdr.Name == "mydir/hello.txt" {
-			if hdr.Size != 5 {
-				t.Errorf("expected size 5, got %d", hdr.Size)
-			}
-			content := make([]byte, 5)
-			if _, err := rdr.Read(content); err != nil && err != io.EOF {
-				t.Fatalf("read error: %v", err)
-			}
-			if string(content) != "world" {
-				t.Errorf("expected 'world', got %q", string(content))
-			}
-		}
-	}
-	if entries != 2 {
-		t.Errorf("expected 2 entries, got %d: %v", entries, names)
-	}
-}
-
-// ─── tarWalk: nested directories ───────────────────────────────────────────────
-
-func TestTarWalk_NestedDirs(t *testing.T) {
-	tmp := t.TempDir()
-	subdir := filepath.Join(tmp, "a", "b", "c")
-	if err := os.MkdirAll(subdir, 0755); err != nil {
-		t.Fatal(err)
-	}
-	if err := os.WriteFile(filepath.Join(subdir, "deep.txt"), []byte("nested"), 0644); err != nil {
-		t.Fatal(err)
-	}
-
-	var buf bytes.Buffer
-	tw := tar.NewWriter(&buf)
-	if err := tarWalk(tmp, "root", tw); err != nil {
-		t.Fatalf("tarWalk error: %v", err)
-	}
-	if err := tw.Close(); err != nil {
-		t.Fatal(err)
-	}
-
-	// Collect all file paths (not dirs) with content.
-	files := map[string]string{}
-	rdr := tar.NewReader(&buf)
-	for {
-		hdr, err := rdr.Next()
-		if err == io.EOF {
-			break
-		}
-		if err != nil {
-			t.Fatal(err)
-		}
-		if !strings.HasSuffix(hdr.Name, "/") && hdr.Size > 0 {
-			content := make([]byte, hdr.Size)
-			rdr.Read(content)
-			files[hdr.Name] = string(content)
-		}
-	}
-
-	expected := "root/a/b/c/deep.txt"
-	if _, ok := files[expected]; !ok {
-		t.Errorf("expected file %q in tar; got: %v", expected, files)
-	} else if files[expected] != "nested" {
-		t.Errorf("expected content 'nested', got %q", files[expected])
-	}
-}
-
-// ─── tarWalk: symlinks are skipped ────────────────────────────────────────────
-
-func TestTarWalk_SymlinksSkipped(t *testing.T) {
-	tmp := t.TempDir()
-
-	// Create a real file.
-	realPath := filepath.Join(tmp, "real.txt")
-	if err := os.WriteFile(realPath, []byte("real content"), 0644); err != nil {
-		t.Fatal(err)
-	}
-
-	// Create a symlink to it.
-	linkPath := filepath.Join(tmp, "link.txt")
-	if err := os.Symlink(realPath, linkPath); err != nil {
-		t.Fatal(err)
-	}
-
-	var buf bytes.Buffer
-	tw := tar.NewWriter(&buf)
-	if err := tarWalk(tmp, "prefix", tw); err != nil {
-		t.Fatalf("tarWalk error: %v", err)
-	}
-	if err := tw.Close(); err != nil {
-		t.Fatal(err)
-	}
-
-	// Only real.txt should appear; link.txt should be absent.
-	names := []string{}
-	rdr := tar.NewReader(&buf)
-	for {
-		hdr, err := rdr.Next()
-		if err == io.EOF {
-			break
-		}
-		if err != nil {
-			t.Fatal(err)
-		}
-		names = append(names, hdr.Name)
-	}
-
-	foundLink := false
-	for _, n := range names {
-		if strings.Contains(n, "link") {
-			foundLink = true
-		}
-	}
-	if foundLink {
-		t.Errorf("symlink should be skipped; got names: %v", names)
-	}
-}
-
-// ─── tarWalk: prefix trailing slash is normalized ─────────────────────────────
-
-func TestTarWalk_PrefixTrailingSlashNormalized(t *testing.T) {
-	tmp := t.TempDir()
-	if err := os.WriteFile(filepath.Join(tmp, "f.txt"), []byte("x"), 0644); err != nil {
-		t.Fatal(err)
-	}
-
-	var buf bytes.Buffer
-	tw := tar.NewWriter(&buf)
-	// Pass prefix WITH trailing slash — should produce same archive as without.
-	if err := tarWalk(tmp, "foo/", tw); err != nil {
-		t.Fatal(err)
-	}
-	if err := tw.Close(); err != nil {
-		t.Fatal(err)
-	}
-
-	// The file should be under "foo/", not "foo//".
-	rdr := tar.NewReader(&buf)
-	for {
-		hdr, err := rdr.Next()
-		if err == io.EOF {
-			break
-		}
-		if err != nil {
-			t.Fatal(err)
-		}
-		if !strings.HasSuffix(hdr.Name, "/") && strings.Contains(hdr.Name, "f.txt") {
-			if strings.Contains(hdr.Name, "//") {
-				t.Errorf("double slash found in path %q — trailing slash not normalized", hdr.Name)
-			}
-			if !strings.HasPrefix(hdr.Name, "foo/") {
-				t.Errorf("expected path to start with 'foo/', got %q", hdr.Name)
-			}
-		}
-	}
-}
-
-// ─── tarWalk: prefix = "." emits flat paths ───────────────────────────────────
-
-func TestTarWalk_PrefixDotEmitsFlatPaths(t *testing.T) {
-	tmp := t.TempDir()
-	subdir := filepath.Join(tmp, "sub")
-	if err := os.MkdirAll(subdir, 0755); err != nil {
-		t.Fatal(err)
-	}
-	if err := os.WriteFile(filepath.Join(subdir, "file.txt"), []byte("data"), 0644); err != nil {
-		t.Fatal(err)
-	}
-
-	var buf bytes.Buffer
-	tw := tar.NewWriter(&buf)
-	if err := tarWalk(tmp, ".", tw); err != nil {
-		t.Fatal(err)
-	}
-	if err := tw.Close(); err != nil {
-		t.Fatal(err)
-	}
-
-	// With prefix ".", paths should NOT start with "./" (filepath.Clean normalizes it).
-	rdr := tar.NewReader(&buf)
-	for {
-		hdr, err := rdr.Next()
-		if err == io.EOF {
-			break
-		}
-		if err != nil {
-			t.Fatal(err)
-		}
-		if !strings.HasSuffix(hdr.Name, "/") && strings.Contains(hdr.Name, "file.txt") {
-			if strings.HasPrefix(hdr.Name, "./") {
-				t.Errorf("prefix '.' should not emit './' prefix; got %q", hdr.Name)
-			}
-		}
-	}
-}
-
-// ─── tarWalk: walk error propagates ───────────────────────────────────────────
-
-func TestTarWalk_NonexistentDir(t *testing.T) {
-	nonexistent := filepath.Join(t.TempDir(), "does-not-exist")
-	var buf bytes.Buffer
-	tw := tar.NewWriter(&buf)
-
-	err := tarWalk(nonexistent, "x", tw)
-	if err == nil {
-		t.Error("expected error for nonexistent directory, got nil")
-	}
-}
@@ -215,6 +215,51 @@ func TestTarWalk_EmptyDirectory(t *testing.T) {
 	}
 }

+// TestTarWalk_NestedDirs: deeply nested directories produce all intermediate
+// dir entries plus leaf entries. This exercises the recursive walk.
+func TestTarWalk_NestedDirs(t *testing.T) {
+	hostDir := t.TempDir()
+	deep := filepath.Join(hostDir, "a", "b", "c")
+	if err := os.MkdirAll(deep, 0o755); err != nil {
+		t.Fatal(err)
+	}
+	if err := os.WriteFile(filepath.Join(deep, "leaf.txt"), []byte("content"), 0o644); err != nil {
+		t.Fatal(err)
+	}
+	var buf bytes.Buffer
+	tw := newTarWriter(&buf)
+	if err := tarWalk(hostDir, "configs/plugins/.staging", tw); err != nil {
+		t.Fatalf("tarWalk: %v", err)
+	}
+	if err := tw.Close(); err != nil {
+		t.Fatalf("Close: %v", err)
+	}
+	entries := readTarNames(&buf)
+	// Must include: prefix/, prefix/a/, prefix/a/b/, prefix/a/b/c/, prefix/a/b/c/leaf.txt
+	expected := []string{
+		"configs/plugins/.staging/",
+		"configs/plugins/.staging/a/",
+		"configs/plugins/.staging/a/b/",
+		"configs/plugins/.staging/a/b/c/",
+		"configs/plugins/.staging/a/b/c/leaf.txt",
+	}
+	if len(entries) != len(expected) {
+		t.Errorf("nested dirs: got %d entries; want %d: %v", len(entries), len(expected), entries)
+	}
+	for _, e := range expected {
+		found := false
+		for _, g := range entries {
+			if g == e {
+				found = true
+				break
+			}
+		}
+		if !found {
+			t.Errorf("missing entry: %q", e)
+		}
+	}
+}
+
 // TestTarWalk_DirEntryHasTrailingSlash: directory entries must end with '/'
 // per tar format; tar.Header.Typeflag '5' (dir) must produce "name/" not "name".
 func TestTarWalk_DirEntryHasTrailingSlash(t *testing.T) {
@@ -12,14 +12,12 @@ Environment variables (set by the workspace container):
  PLATFORM_URL  — platform API base URL (e.g. http://platform:8080)
 """

-import argparse
 import asyncio
 import json
 import logging
 import os
 import stat
 import sys
-import uuid
 from typing import Callable

 # Top-level (not inside main()) so the wheel rewriter expands this to
@@ -827,163 +825,24 @@ async def main():  # pragma: no cover
            break


-# --- HTTP/SSE Transport (for Hermes runtime) ---
-
-# Per-connection pending request queue.
-# Maps connection-id → asyncio.Queue of JSON-RPC responses.
-_http_connection_queues: dict[str, asyncio.Queue] = {}
-_http_connection_lock = asyncio.Lock()
-
-
-async def _handle_http_mcp(request) -> dict | None:
-    """Handle an incoming JSON-RPC request over HTTP. Returns the JSON-RPC response dict, or None for notifications."""
-    try:
-        body = await request.json()
-    except Exception:
-        return {"jsonrpc": "2.0", "id": None, "error": {"code": -32700, "message": "Parse error"}}
-
-    req_id = body.get("id")
-    method = body.get("method", "")
-
-    if method == "initialize":
-        return {
-            "jsonrpc": "2.0",
-            "id": req_id,
-            "result": _build_initialize_result(),
-        }
-    elif method == "notifications/initialized":
-        return None  # No response needed
-    elif method == "tools/list":
-        return {"jsonrpc": "2.0", "id": req_id, "result": {"tools": TOOLS}}
-    elif method == "tools/call":
-        params = body.get("params", {})
-        tool_name = params.get("name", "")
-        tool_args = params.get("arguments", {})
-        result_text = await handle_tool_call(tool_name, tool_args)
-        return {
-            "jsonrpc": "2.0",
-            "id": req_id,
-            "result": {"content": [{"type": "text", "text": result_text}]},
-        }
-    else:
-        return {"jsonrpc": "2.0", "id": req_id, "error": {"code": -32601, "message": f"Method not found: {method}"}}
-
-
-async def _run_http_server(port: int) -> None:
-    """Run MCP server over HTTP/SSE — compatible with Hermes MCP-native agents."""
-    try:
-        from starlette.applications import Starlette  # noqa: F401
-        from starlette.routing import Route  # noqa: F401
-        from starlette.responses import JSONResponse, Response, StreamingResponse  # noqa: F401
-    except ImportError:
-        logger.error("HTTP transport requires starlette — install with: pip install starlette uvicorn")
-        return
-
-    # Import uvicorn here so the stdio path (the common case) doesn't pay
-    # the import cost if starlette/uvicorn aren't installed.
-    import uvicorn  # noqa: F401
-
-    _http_connection_queues.clear()
-
-    async def mcp_handler(request):
-        """POST /mcp — receive and process JSON-RPC requests."""
-        conn_id = request.headers.get("x-mcp-conn-id", "default")
-        response = await _handle_http_mcp(request)
-        if response is None:
-            return Response(status_code=202)
-        async with _http_connection_lock:
-            queue = _http_connection_queues.get(conn_id)
-        if queue is not None and not queue.full():
-            await queue.put(response)
-            return Response(status_code=202)
-        # No SSE subscriber — return JSON directly
-        return JSONResponse(response)
-
-    async def sse_handler(request):
-        """GET /mcp/stream — SSE stream for push-based responses."""
-        conn_id = str(uuid.uuid4())
-        queue: asyncio.Queue = asyncio.Queue(maxsize=100)
-        async with _http_connection_lock:
-            _http_connection_queues[conn_id] = queue
-
-        async def event_stream():
-            yield f"event: connected\ndata: {json.dumps({'conn_id': conn_id})}\n\n"
-            try:
-                while True:
-                    response = await asyncio.wait_for(queue.get(), timeout=300)
-                    yield f"event: message\ndata: {json.dumps(response)}\n\n"
-                    if queue.empty():
-                        yield "event: heartbeat\ndata: null\n\n"
-            except asyncio.TimeoutError:
-                pass
-            finally:
-                async with _http_connection_lock:
-                    _http_connection_queues.pop(conn_id, None)
-
-        return StreamingResponse(
-            event_stream(),
-            media_type="text/event-stream",
-            headers={
-                "Cache-Control": "no-cache",
-                "Connection": "keep-alive",
-                "X-Accel-Buffering": "no",
-            },
-        )
-
-    async def health_handler(_request):
-        return JSONResponse({"ok": True, "transport": "http+sse", "port": port})
-
-    app = Starlette(
-        routes=[
-            Route("/mcp", mcp_handler, methods=["POST"]),
-            Route("/mcp/stream", sse_handler, methods=["GET"]),
-            Route("/health", health_handler),
-        ]
-    )
-    config = uvicorn.Config(app, host="127.0.0.1", port=port, log_level="warning")
-    server = uvicorn.Server(config)
-    logger.info(f"A2A MCP HTTP server listening on http://127.0.0.1:{port}/mcp")
-    await server.serve()
-
-
-def cli_main(transport: str = "stdio", port: int = 9100) -> None:  # pragma: no cover
-    """Synchronous wrapper — selects stdio or HTTP transport.
+def cli_main() -> None:  # pragma: no cover
+    """Synchronous wrapper around the async MCP stdio loop.

    Called by ``mcp_cli.main`` (the ``molecule-mcp`` console-script
    entry point in scripts/build_runtime_package.py) AFTER env
    validation and the standalone register + heartbeat thread setup.
    Direct callers (in-container code that already validated env and
-    runs heartbeat.py separately) can also invoke this.
+    runs heartbeat.py separately) can also invoke this — it's the
+    smallest possible "run the MCP stdio JSON-RPC loop" surface.

    Wheel-smoke gates in scripts/wheel_smoke.py pin the importability
    of this name (alongside ``mcp_cli.main``) so a silent rename can't
    break every external-runtime operator's MCP install — the 0.1.16
    ``main_sync`` rename incident is the cautionary precedent.
-
-    Args:
-        transport: "stdio" (default) or "http" (HTTP+SSE for Hermes).
-        port: TCP port for HTTP transport (default 9100).
    """
-    if transport == "http":
-        asyncio.run(_run_http_server(port))
-    else:
-        _warn_if_stdio_not_pipe()
-        asyncio.run(main())
+    _warn_if_stdio_not_pipe()
+    asyncio.run(main())


 if __name__ == "__main__":  # pragma: no cover
-    parser = argparse.ArgumentParser(description="A2A MCP Server")
-    parser.add_argument(
-        "--transport",
-        default="stdio",
-        choices=["stdio", "http"],
-        help="Transport mode: stdio (default) or http (HTTP+SSE for Hermes)",
-    )
-    parser.add_argument(
-        "--port",
-        type=int,
-        default=9100,
-        help="TCP port for HTTP transport (default 9100)",
-    )
-    args = parser.parse_args()
-    cli_main(transport=args.transport, port=args.port)
+    cli_main()
@@ -1,671 +0,0 @@
-"""Tests for the HTTP/SSE transport of a2a_mcp_server.
-
-Covers:
- _handle_http_mcp: JSON-RPC request parsing and routing
- Starlette app routes: POST /mcp, GET /mcp/stream, GET /health
- cli_main argparse: --transport and --port flags
-"""
-
-from __future__ import annotations
-
-import asyncio
-import json
-import sys
-import types
-import uuid
-from unittest.mock import AsyncMock, MagicMock, patch
-
-import httpx
-import pytest
-
-
-# ---------------------------------------------------------------------------
-# Helpers
-# ---------------------------------------------------------------------------
-
-
-class _DummyRequest:
-    """Minimal request duck-type for _handle_http_mcp."""
-
-    def __init__(self, body_json: dict, headers: dict | None = None):
-        self._body = body_json
-        self.headers = headers or {}
-
-    async def json(self) -> dict:
-        return self._body
-
-
-# ---------------------------------------------------------------------------
-# _handle_http_mcp — unit tests (no I/O)
-# ---------------------------------------------------------------------------
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_initialize():
-    """initialize method returns protocol version, capabilities, and server info."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    req = _DummyRequest({"jsonrpc": "2.0", "id": 42, "method": "initialize", "params": {}})
-    resp = await _handle_http_mcp(req)
-
-    assert resp["jsonrpc"] == "2.0"
-    assert resp["id"] == 42
-    assert "protocolVersion" in resp["result"]
-    assert "capabilities" in resp["result"]
-    assert resp["result"]["serverInfo"]["name"] == "molecule"
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_notifications_initialized_returns_none():
-    """notifications/initialized is a notification (no response needed)."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    req = _DummyRequest({"jsonrpc": "2.0", "method": "notifications/initialized"})
-    resp = await _handle_http_mcp(req)
-
-    assert resp is None
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_tools_list():
-    """tools/list returns the TOOLS schema."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    req = _DummyRequest({"jsonrpc": "2.0", "id": 7, "method": "tools/list"})
-    resp = await _handle_http_mcp(req)
-
-    assert resp["jsonrpc"] == "2.0"
-    assert resp["id"] == 7
-    assert "tools" in resp["result"]
-    assert isinstance(resp["result"]["tools"], list)
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_unknown_method_returns_error():
-    """Unknown method returns -32601 Method not found."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    req = _DummyRequest({"jsonrpc": "2.0", "id": 3, "method": "foobar", "params": {}})
-    resp = await _handle_http_mcp(req)
-
-    assert resp["jsonrpc"] == "2.0"
-    assert resp["id"] == 3
-    assert resp["error"]["code"] == -32601
-    assert "Method not found" in resp["error"]["message"]
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_malformed_json_returns_parse_error():
-    """Request with bad JSON returns -32700 parse error."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    req = _DummyRequest.__new__(_DummyRequest)
-    req.headers = {}
-    req.json = AsyncMock(side_effect=ValueError("bad json"))
-
-    resp = await _handle_http_mcp(req)
-
-    assert resp["error"]["code"] == -32700
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_tools_call_with_get_workspace_info():
-    """tools/call for get_workspace_info returns workspace info (mocked platform call)."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    with patch("a2a_mcp_server.tool_get_workspace_info", AsyncMock(return_value="mocked info")):
-        req = _DummyRequest({
-            "jsonrpc": "2.0",
-            "id": 9,
-            "method": "tools/call",
-            "params": {"name": "get_workspace_info", "arguments": {}},
-        })
-        resp = await _handle_http_mcp(req)
-
-    assert resp["jsonrpc"] == "2.0"
-    assert resp["id"] == 9
-    assert resp["result"]["content"][0]["text"] == "mocked info"
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_tools_call_unknown_tool():
-    """tools/call for an unknown tool returns the handle_tool_call error text."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    req = _DummyRequest({
-        "jsonrpc": "2.0",
-        "id": 11,
-        "method": "tools/call",
-        "params": {"name": "not_a_real_tool", "arguments": {}},
-    })
-    resp = await _handle_http_mcp(req)
-
-    assert resp["jsonrpc"] == "2.0"
-    assert resp["id"] == 11
-    assert "Unknown tool" in resp["result"]["content"][0]["text"]
-
-
-# ---------------------------------------------------------------------------
-# Starlette app — integration tests with TestClient
-# ---------------------------------------------------------------------------
-
-
-@pytest.fixture()
-def _clear_http_globals():
-    """Reset module-level HTTP state before and after each test."""
-    import a2a_mcp_server
-
-    # Save and restore globals
-    saved_queues = a2a_mcp_server._http_connection_queues.copy()
-    saved_lock = a2a_mcp_server._http_connection_lock
-    a2a_mcp_server._http_connection_queues.clear()
-    yield
-    # Restore
-    a2a_mcp_server._http_connection_queues = saved_queues
-
-
-
-
-
-def _register_sse_queue():
-    """Register a queue for SSE push delivery (synchronous — callable from tests)."""
-    conn_id = str(uuid.uuid4())
-    queue = asyncio.Queue(maxsize=100)
-    import a2a_mcp_server
-    a2a_mcp_server._http_connection_queues[conn_id] = queue
-    return conn_id, queue
-
-
-def _build_test_app(port: int = 9100):
-    """Build the Starlette app for testing without starting a real server.
-
-    Mirrors the app construction inside _run_http_server, but returns
-    the app directly so TestClient can drive it without binding a port.
-    """
-    from starlette.applications import Starlette
-    from starlette.routing import Route
-
-    import a2a_mcp_server
-
-    async def mcp_handler(request):
-        conn_id = request.headers.get("x-mcp-conn-id", "default")
-        response = await a2a_mcp_server._handle_http_mcp(request)
-        if response is None:
-            from starlette.responses import Response
-            return Response(status_code=202)
-        async with a2a_mcp_server._http_connection_lock:
-            queue = a2a_mcp_server._http_connection_queues.get(conn_id)
-        if queue is not None and not queue.full():
-            await queue.put(response)
-            from starlette.responses import Response
-            return Response(status_code=202)
-        from starlette.responses import JSONResponse
-        return JSONResponse(response)
-
-    async def sse_handler(request):
-        conn_id, queue = _register_sse_queue()
-
-        import asyncio as _asyncio
-
-        async def event_stream():
-            import json as _json
-            yield f"event: connected\ndata: {_json.dumps({'conn_id': conn_id})}\n\n"
-            try:
-                while True:
-                    response = await _asyncio.wait_for(queue.get(), timeout=300)
-                    import json as _json
-                    yield f"event: message\ndata: {_json.dumps(response)}\n\n"
-                    if queue.empty():
-                        yield "event: heartbeat\ndata: null\n\n"
-            except _asyncio.TimeoutError:
-                pass
-            finally:
-                async with a2a_mcp_server._http_connection_lock:
-                    a2a_mcp_server._http_connection_queues.pop(conn_id, None)
-
-        from starlette.responses import StreamingResponse
-        return StreamingResponse(
-            event_stream(),
-            media_type="text/event-stream",
-            headers={
-                "Cache-Control": "no-cache",
-                "Connection": "keep-alive",
-                "X-Accel-Buffering": "no",
-            },
-        )
-
-    async def health_handler(_request):
-        from starlette.responses import JSONResponse
-        return JSONResponse({"ok": True, "transport": "http+sse", "port": port})
-
-    return Starlette(
-        routes=[
-            Route("/mcp", mcp_handler, methods=["POST"]),
-            Route("/mcp/stream", sse_handler, methods=["GET"]),
-            Route("/health", health_handler),
-        ]
-    )
-
-
-class TestHTTPAppRoutes:
-    """Integration tests using Starlette TestClient against the HTTP app.
-
-    Starlette TestClient uses the ASGI interface directly (no real HTTP server
-    or uvicorn needed), so no uvicorn mock is required.
-    """
-
-    def test_health_returns_ok_and_transport(self, _clear_http_globals):
-        from starlette.testclient import TestClient
-
-        app = _build_test_app(port=9100)
-        with TestClient(app) as client:
-            resp = client.get("/health")
-
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["ok"] is True
-        assert data["transport"] == "http+sse"
-        assert data["port"] == 9100
-
-    def test_health_accepts_different_port(self, _clear_http_globals):
-        from starlette.testclient import TestClient
-
-        app = _build_test_app(port=9999)
-        with TestClient(app) as client:
-            resp = client.get("/health")
-
-        assert resp.json()["port"] == 9999
-
-    def test_mcp_post_initialize(self, _clear_http_globals):
-        from starlette.testclient import TestClient
-
-        app = _build_test_app()
-        with TestClient(app) as client:
-            resp = client.post("/mcp", json={
-                "jsonrpc": "2.0",
-                "id": 1,
-                "method": "initialize",
-                "params": {},
-            })
-
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["id"] == 1
-        assert "protocolVersion" in data["result"]
-
-    def test_mcp_post_tools_list(self, _clear_http_globals):
-        from starlette.testclient import TestClient
-
-        app = _build_test_app()
-        with TestClient(app) as client:
-            resp = client.post("/mcp", json={
-                "jsonrpc": "2.0",
-                "id": 2,
-                "method": "tools/list",
-                "params": {},
-            })
-
-        assert resp.status_code == 200
-        data = resp.json()
-        assert "tools" in data["result"]
-        assert len(data["result"]["tools"]) > 0
-
-    def test_mcp_post_notifications_initialized_returns_202(self, _clear_http_globals):
-        from starlette.testclient import TestClient
-
-        app = _build_test_app()
-        with TestClient(app) as client:
-            resp = client.post("/mcp", json={
-                "jsonrpc": "2.0",
-                "method": "notifications/initialized",
-            })
-
-        # Notifications return 202 with no body
-        assert resp.status_code == 202
-
-    def test_mcp_post_unknown_method_returns_200_with_error(self, _clear_http_globals):
-        from starlette.testclient import TestClient
-
-        app = _build_test_app()
-        with TestClient(app) as client:
-            resp = client.post("/mcp", json={
-                "jsonrpc": "2.0",
-                "id": 5,
-                "method": "no_such_method",
-                "params": {},
-            })
-
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["error"]["code"] == -32601
-
-    def test_mcp_post_malformed_json_returns_error(self, _clear_http_globals):
-        """Malformed JSON body returns a JSON-RPC parse-error response (HTTP 200)."""
-        from starlette.testclient import TestClient
-
-        app = _build_test_app()
-        with TestClient(app, raise_server_exceptions=False) as client:
-            resp = client.post(
-                "/mcp",
-                content=b"not json at all",
-                headers={"Content-Type": "application/json"},
-            )
-        # _handle_http_mcp catches ValueError from request.json() and returns
-        # a JSON-RPC parse-error response with HTTP 200.
-        assert resp.status_code == 200
-        assert resp.json()["error"]["code"] == -32700
-        assert "Parse error" in resp.json()["error"]["message"]
-
-    @pytest.mark.asyncio()
-    async def test_sse_stream_populates_queue(self, _clear_http_globals):
-        """_register_sse_queue adds a queue to _http_connection_queues before any async work."""
-        import a2a_mcp_server
-
-        conn_id, queue = _register_sse_queue()
-
-        # The queue is registered synchronously — no await needed, no cleanup ran yet.
-        assert conn_id in a2a_mcp_server._http_connection_queues
-        assert len(conn_id) == 36  # valid UUID format
-        assert not queue.full()
-
-    @pytest.mark.asyncio()
-    async def test_sse_queue_delivers_response(self, _clear_http_globals):
-        """POST /mcp with x-mcp-conn-id routes response into the SSE queue."""
-        import uuid
-
-        import a2a_mcp_server
-        from starlette.testclient import TestClient
-
-        # Pre-register an SSE queue to simulate an active SSE subscriber
-        conn_id = str(uuid.uuid4())
-        queue: asyncio.Queue = asyncio.Queue(maxsize=100)
-        async with a2a_mcp_server._http_connection_lock:
-            a2a_mcp_server._http_connection_queues[conn_id] = queue
-
-        # POST a tools/call with the conn_id header
-        with TestClient(_build_test_app()) as client:
-            with patch("a2a_mcp_server.tool_get_workspace_info", AsyncMock(return_value="test-ws-info")):
-                resp = client.post(
-                    "/mcp",
-                    headers={"x-mcp-conn-id": conn_id},
-                    json={
-                        "jsonrpc": "2.0",
-                        "id": 99,
-                        "method": "tools/call",
-                        "params": {"name": "get_workspace_info", "arguments": {}},
-                    },
-                )
-
-        # The handler returns 202 because the response was queued for SSE delivery
-        assert resp.status_code == 202
-
-        # Verify the response was placed in the SSE queue
-        result = await asyncio.wait_for(queue.get(), timeout=2.0)
-        assert result["id"] == 99
-        assert result["result"]["content"][0]["text"] == "test-ws-info"
-
-
-# ---------------------------------------------------------------------------
-# handle_tool_call — remaining tool branches
-# ---------------------------------------------------------------------------
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_tools_call_send_message_to_user_with_mixed_attachments():
-    """attachments with non-string elements are filtered; the list branch is exercised."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    with patch("a2a_mcp_server.tool_send_message_to_user", AsyncMock(return_value="sent ok")) as mock_fn:
-        req = _DummyRequest({
-            "jsonrpc": "2.0",
-            "id": 21,
-            "method": "tools/call",
-            "params": {
-                "name": "send_message_to_user",
-                "arguments": {
-                    "message": "hello",
-                    # Mixed types: list contains a dict (non-string) and an empty string
-                    "attachments": [{"url": "http://x"}, "", "valid.zip", None],
-                },
-            },
-        })
-        resp = await _handle_http_mcp(req)
-
-    assert resp["result"]["content"][0]["text"] == "sent ok"
-    # Only string, non-empty values passed through
-    mock_fn.assert_called_once()
-    _, kwargs = mock_fn.call_args
-    assert kwargs["attachments"] == ["valid.zip"]
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_tools_call_wait_for_message():
-    """wait_for_message is dispatched and returns the wrapped result."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    with patch("a2a_mcp_server.tool_wait_for_message", AsyncMock(return_value="no messages")):
-        req = _DummyRequest({
-            "jsonrpc": "2.0",
-            "id": 22,
-            "method": "tools/call",
-            "params": {"name": "wait_for_message", "arguments": {"timeout_secs": 5.0}},
-        })
-        resp = await _handle_http_mcp(req)
-
-    assert resp["result"]["content"][0]["text"] == "no messages"
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_tools_call_inbox_peek():
-    """inbox_peek is dispatched with the limit argument."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    with patch("a2a_mcp_server.tool_inbox_peek", AsyncMock(return_value="2 items")):
-        req = _DummyRequest({
-            "jsonrpc": "2.0",
-            "id": 23,
-            "method": "tools/call",
-            "params": {"name": "inbox_peek", "arguments": {"limit": 5}},
-        })
-        resp = await _handle_http_mcp(req)
-
-    assert resp["result"]["content"][0]["text"] == "2 items"
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_tools_call_inbox_pop():
-    """inbox_pop is dispatched with the activity_id argument."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    with patch("a2a_mcp_server.tool_inbox_pop", AsyncMock(return_value="acked")):
-        req = _DummyRequest({
-            "jsonrpc": "2.0",
-            "id": 24,
-            "method": "tools/call",
-            "params": {"name": "inbox_pop", "arguments": {"activity_id": "abc-123"}},
-        })
-        resp = await _handle_http_mcp(req)
-
-    assert resp["result"]["content"][0]["text"] == "acked"
-
-
-@pytest.mark.asyncio()
-async def test_handle_http_mcp_tools_call_chat_history():
-    """chat_history is dispatched with peer_id, limit, and before_ts arguments."""
-    from a2a_mcp_server import _handle_http_mcp
-
-    with patch("a2a_mcp_server.tool_chat_history", AsyncMock(return_value="history")):
-        req = _DummyRequest({
-            "jsonrpc": "2.0",
-            "id": 25,
-            "method": "tools/call",
-            "params": {
-                "name": "chat_history",
-                "arguments": {"peer_id": "ws-peer-1", "limit": 10, "before_ts": ""},
-            },
-        })
-        resp = await _handle_http_mcp(req)
-
-    assert resp["result"]["content"][0]["text"] == "history"
-
-
-# ---------------------------------------------------------------------------
-# cli_main argparse — unit tests
-# ---------------------------------------------------------------------------
-
-
-def test_mcp_post_falls_back_to_json_when_sse_queue_is_full(_clear_http_globals):
-    """When the SSE queue is full (>100 pending), the handler returns JSON directly."""
-    import a2a_mcp_server
-    from starlette.testclient import TestClient
-
-    # Pre-register a queue and fill it to capacity
-    conn_id = str(uuid.uuid4())
-    queue: asyncio.Queue = asyncio.Queue(maxsize=2)  # small queue for testing
-
-    async def _setup():
-        async with a2a_mcp_server._http_connection_lock:
-            a2a_mcp_server._http_connection_queues[conn_id] = queue
-        queue.put_nowait({"id": 1})
-        queue.put_nowait({"id": 2})
-
-    _sync_run(_setup())
-    assert queue.full()
-
-    app = _build_test_app()
-    with TestClient(app) as client:
-        resp = client.post(
-            "/mcp",
-            headers={"x-mcp-conn-id": conn_id},
-            json={"jsonrpc": "2.0", "id": 99, "method": "initialize", "params": {}},
-        )
-
-    # With a full queue, the handler returns the response as JSON (not 202)
-    assert resp.status_code == 200
-    assert resp.json()["id"] == 99
-    assert "result" in resp.json()
-
-
-def _sync_run(coro):
-    """Run a coroutine synchronously for test isolation (no real event loop needed)."""
-    try:
-        loop = asyncio.new_event_loop()
-        asyncio.set_event_loop(loop)
-        try:
-            return loop.run_until_complete(coro)
-        finally:
-            loop.close()
-    except Exception:
-        raise
-
-
-def test_cli_main_transport_stdio_calls_main(monkeypatch):
-    """cli_main(transport='stdio') calls asyncio.run(main) without HTTP."""
-    import a2a_mcp_server
-
-    run_calls: list = []
-
-    async def fake_main():
-        run_calls.append("called")
-
-    monkeypatch.setattr(a2a_mcp_server, "main", fake_main)
-    monkeypatch.setattr(a2a_mcp_server.asyncio, "run", _sync_run)
-    monkeypatch.setattr(a2a_mcp_server, "_assert_stdio_is_pipe_compatible", lambda: None)
-
-    a2a_mcp_server.cli_main(transport="stdio", port=9100)
-
-    assert "called" in run_calls
-
-
-def test_cli_main_transport_http_calls_run_http_server(monkeypatch):
-    """cli_main(transport='http') calls _run_http_server without stdio."""
-    import a2a_mcp_server
-
-    run_http_calls = []
-
-    async def fake_run_http(port):
-        run_http_calls.append(port)
-
-    # asyncio.run must execute the coroutine for _run_http_server to be called
-    monkeypatch.setattr(a2a_mcp_server.asyncio, "run", _sync_run)
-    monkeypatch.setattr(a2a_mcp_server, "_run_http_server", fake_run_http)
-    # stdio path must not be entered
-    monkeypatch.setattr(a2a_mcp_server, "_assert_stdio_is_pipe_compatible", lambda: None)
-
-    a2a_mcp_server.cli_main(transport="http", port=9102)
-
-    assert run_http_calls == [9102]
-
-
-def test_cli_main_http_skips_stdio_check(monkeypatch):
-    """When transport=http, _assert_stdio_is_pipe_compatible must NOT be called."""
-    import a2a_mcp_server
-
-    called = []
-
-    def fake_assert():
-        called.append("assert_called")
-
-    # Patch on the module object directly
-    monkeypatch.setattr(a2a_mcp_server, "_assert_stdio_is_pipe_compatible", fake_assert)
-    monkeypatch.setattr(a2a_mcp_server.asyncio, "run", lambda fn: None)
-
-    a2a_mcp_server.cli_main(transport="http", port=9100)
-
-    assert "assert_called" not in called
-
-
-def test_cli_main_default_transport_is_stdio(monkeypatch):
-    """cli_main() with no args defaults to stdio transport."""
-    import a2a_mcp_server
-
-    called_as: list = []
-
-    async def fake_main():
-        called_as.append("called")
-
-    monkeypatch.setattr(a2a_mcp_server, "main", fake_main)
-    monkeypatch.setattr(a2a_mcp_server.asyncio, "run", _sync_run)
-    monkeypatch.setattr(a2a_mcp_server, "_assert_stdio_is_pipe_compatible", lambda: None)
-
-    a2a_mcp_server.cli_main()  # No args — defaults to stdio
-
-    assert "called" in called_as
-
-
-def test_cli_main_main_raises_propagates(monkeypatch):
-    """If main() raises, cli_main() re-raises (doesn't swallow)."""
-    import a2a_mcp_server
-
-    async def fake_main():
-        raise RuntimeError("boom")
-
-    monkeypatch.setattr(a2a_mcp_server, "main", fake_main)
-    monkeypatch.setattr(a2a_mcp_server.asyncio, "run", _sync_run)
-    monkeypatch.setattr(a2a_mcp_server, "_assert_stdio_is_pipe_compatible", lambda: None)
-
-    with pytest.raises(RuntimeError, match="boom"):
-        a2a_mcp_server.cli_main(transport="stdio")
-
-
-# ---------------------------------------------------------------------------
-# uvicorn/starlette lazy-import
-# ---------------------------------------------------------------------------
-
-
-def test_run_http_server_is_coroutine_function():
-    """_run_http_server is a coroutine function accepting a port argument."""
-    import inspect
-    from a2a_mcp_server import _run_http_server
-
-    assert inspect.iscoroutinefunction(_run_http_server)
-
-
-def test_run_http_server_signature_port_int():
-    """_run_http_server accepts port as int."""
-    import inspect
-    from a2a_mcp_server import _run_http_server
-
-    sig = inspect.signature(_run_http_server)
-    assert "port" in sig.parameters
-    assert sig.parameters["port"].annotation == int
@@ -1,107 +0,0 @@
-"""Test coverage for builtin_tools.security._redact_secrets().
-
-Issue #834 (C2): commit_memory must not persist API keys verbatim.
-
-Pre-commit hook blocks bare secret-like strings (ghp_, sk-ant-, etc.) to prevent
-accidental commits of real credentials.  These tests focus on the functional
-behaviour of the redaction logic: idempotency, contextual keyword=value patterns,
-boundary cases, and mixed content — without triggering the hook's length thresholds.
-The pre-commit hook itself is the primary guard for bare-pattern detection.
-"""
-from __future__ import annotations
-
-from builtin_tools.security import REDACTED, _redact_secrets
-
-
-class TestRedactContextual:
-    """Keyword=value patterns with high-entropy values (under pre-commit threshold)."""
-
-    def test_api_key_contextual(self):
-        """api_key=X where X ≥ 40 base64 chars → value replaced, keyword preserved."""
-        value = "A" * 40
-        assert _redact_secrets(f"api_key={value}") == f"api_key={REDACTED}"
-
-    def test_keyword_contextual(self):
-        """Generic 'key=' also matches."""
-        value = "B" * 45
-        assert _redact_secrets(f"key={value}") == f"key={REDACTED}"
-
-    def test_secret_contextual(self):
-        value = "C" * 50
-        assert _redact_secrets(f"secret= {value}") == f"secret= {REDACTED}"
-
-    def test_token_contextual(self):
-        value = "D" * 40
-        assert _redact_secrets(f"token={value}") == f"token={REDACTED}"
-
-    def test_password_contextual(self):
-        value = "E" * 50
-        assert _redact_secrets(f"password={value}") == f"password={REDACTED}"
-
-    def test_keyword_spacing_tolerated(self):
-        """Spaces around = are tolerated by the pattern."""
-        value = "F" * 40
-        assert _redact_secrets(f"key = {value}") == f"key = {REDACTED}"
-
-    def test_contextual_too_short_not_redacted(self):
-        """Value shorter than 40 chars is not redacted."""
-        short = "A" * 39
-        assert _redact_secrets(f"api_key={short}") == f"api_key={short}"
-
-    def test_case_insensitive_keyword(self):
-        """Keyword matching is case-insensitive."""
-        value = "G" * 40
-        assert _redact_secrets(f"API_KEY={value}") == f"API_KEY={REDACTED}"
-        assert _redact_secrets(f"Token={value}") == f"Token={REDACTED}"
-        assert _redact_secrets(f"SECRET={value}") == f"SECRET={REDACTED}"
-
-    def test_boundary_preserved(self):
-        """Contextual pattern preserves the keyword; only value is replaced."""
-        value = "H" * 40
-        result = _redact_secrets(f"api_key={value}")
-        assert result.startswith("api_key=")
-        assert result.endswith(REDACTED)
-        assert result == f"api_key={REDACTED}"
-
-    def test_base64_chars_in_value(self):
-        """Base64 alphabet chars (/ +) in value are covered by the charset."""
-        # 40-char string with base64 chars
-        value = "A" * 20 + "/+" + "A" * 18
-        result = _redact_secrets(f"api_key={value}")
-        assert result == f"api_key={REDACTED}"
-
-
-class TestRedactEdgeCases:
-    """Non-secret strings, idempotency, and boundary conditions."""
-
-    def test_idempotent(self):
-        """Calling redaction twice produces the same result."""
-        text = f"token={'A' * 40}"
-        first = _redact_secrets(text)
-        second = _redact_secrets(first)
-        assert second == first
-        assert REDACTED in first
-
-    def test_already_redacted_string(self):
-        """The [REDACTED] sentinel itself is not matched by any pattern."""
-        assert _redact_secrets(f"see {REDACTED} here") == f"see {REDACTED} here"
-
-    def test_no_match_passthrough(self):
-        """Normal prose passes through unchanged."""
-        assert _redact_secrets("The answer is 42.") == "The answer is 42."
-        assert _redact_secrets("Hello, world!") == "Hello, world!"
-        assert _redact_secrets("api_key short") == "api_key short"
-        assert _redact_secrets("") == ""
-
-    def test_empty_string(self):
-        assert _redact_secrets("") == ""
-
-    def test_short_value_not_secret(self):
-        """A short string after a keyword= prefix is not a secret."""
-        assert _redact_secrets("token=short") == "token=short"
-
-    def test_mixed_content(self):
-        """Real text with a secret-like prefix → only the secret is redacted."""
-        value = "A" * 40
-        result = _redact_secrets(f"found secret: api_key={value} in config")
-        assert result == f"found secret: api_key={REDACTED} in config"