#!/usr/bin/env python3
"""Close the #2479 dichotomy-wave parallel_processor gap contract (GO port).
Full lifecycle walk in ONE process (shared-store clobber hazard; segment
transitions take ~60s each — do NOT split across processes). The final
step is iface.close() with contract_quality observed_evidence (the
bare `transition -> closed` is rejected by the quality gate). Safe to
re-run: pass the existing contract id to resume an interrupted walk.

Carries the already-pushed parity SHA as evidence:
  feat  16a2aa20  close PARTIAL gaps — dichotomy wave (3/14 -> 14/14)

Usage: close_contract_parallel_processor.py [contract_id]
"""
import json
import os
import sys
from pathlib import Path

os.environ.setdefault(
    "CS_RUST_LIB",
    "/mnt/workdrive/rune/src/rust/capability_scoring/target/release/libcapability_scoring.so",
)

sys.path.insert(0, str(Path(__file__).resolve().parents[1] / "src"))

from rune.construction_interface import ConstructionInterface

PARITY_SHA = "16a2aa20"
EVIDENCE = f"parity {PARITY_SHA}"

NEED = (
    "parallel_processor dichotomy gap-close (GO): name-preserving port of "
    "the 11 audit-missing functions (run_parallel class+module, "
    "run_parallel_with_args, get_status, shutdown, _shutdown_processor, "
    "get_processor, test_parallel + nested task_1/2/3, main CLI mirror) "
    "into src/go/parallel-processor (RunParallelWithArgs, GetStatus, "
    "Shutdown, ShutdownProcessor, GetProcessor, TestParallel with "
    "task_1/2/3 closures), semaphore-bounded goroutine pool preserving "
    "submission order, frozen-truth battery (truth.json, 23-case "
    "envelope via the shared freeze_truth.py harness + "
    "scripts/pp_freeze_seams rig: kind/fn/value SPEC grammar so "
    "callables ride JSON rows, threading.active_count pinned) verified "
    "byte-identical twice, embedded VERBATIM in truth_test.go "
    "TestFrozenTruthReplay (5/5); CI replay binary PARITY OK 23/23; live "
    "parity sweep 19/19 (scripts/check_parallel_processor_parity.py: 15 "
    "op families + 4 CLI checks), gofmt/vet/go build clean, Python "
    "oracle smoke green both pins. Oracle quirks preserved and frozen: "
    "submit-after-shutdown raises from the submit loop (crash parity "
    "panic 'cannot schedule new futures after shutdown'), "
    "ParallelProcessor(0) 'max_workers must be greater than 0', Python "
    "type-name TypeError envelopes for non-callables, with-args parse "
    "errors with type(task).__name__ and repr shapes, non-seq args "
    "wrapped, non-dict kwargs reset, pool_threads = configured bound. "
    "Dichotomy audit 3/14 PARTIAL -> 14/14 FULL. Delivered on "
    "gitea/master: feat " + PARITY_SHA + "."
)

iface = ConstructionInterface(builder="factory-gap-pp")

if len(sys.argv) > 1:
    cid = sys.argv[1]
    print("resuming contract:", cid)
else:
    r = iface.submit_need(NEED, origin="builder")
    print("submit_need:", json.dumps(r)[:300])
    if not r.get("success"):
        print("NEED FAILED — aborting")
        sys.exit(1)
    cid = r["ids"]["contract_id"]
print("contract_id:", cid)


def phase_of(cid):
    doc = iface.scaffold.load()
    e = iface.scaffold.contract(doc, cid)
    return e.get("phase") if e else "MISSING"


phase = phase_of(cid)
print("current phase:", phase)
for want in ("approved", "building", "verifying"):
    if phase == want or phase in ("verifying", "closed"):
        break
    t = iface.transition(cid, want, evidence_ref=EVIDENCE)
    ok = t.get("success")
    print(f"transition->{want}:", "ok" if ok else json.dumps(t)[:300])
    if not ok:
        sys.exit(1)
    phase = want

c = iface.close(
    cid,
    observed_evidence=[{
        "kind": "port_evidence",
        "detail": "parallel_processor dichotomy completion — parity "
                  f"{PARITY_SHA} feat(parallel_processor): close PARTIAL "
                  "gaps — dichotomy wave; pushed gitea/master. Go port at "
                  "src/go/parallel-processor closes the audit gaps "
                  "name-preserving (RunParallel/RunParallelWithArgs class+"
                  "module, GetStatus, Shutdown, ShutdownProcessor, "
                  "GetProcessor, TestParallel with task_1/2/3, oracle-"
                  "mirroring main CLI) over a semaphore-bounded goroutine "
                  "pool. Freeze rig scripts/pp_freeze_seams + generator "
                  "scripts/gen_parallel_processor_truth.py: 23-case frozen "
                  "truth regenerates byte-identical; freeze_truth --verify "
                  "OK twice against the live oracle. Battery 5/5 replay "
                  "VERBATIM (23/23 rows); replay binary PARITY OK 23/23; "
                  "live parity scripts/check_parallel_processor_parity.py "
                  "19/19 (15 op families + 4 CLI checks); gofmt/vet/build "
                  "clean; Python oracle smoke both pins. Audit 3/14 → "
                  "14/14 FULL. Divergences (documented): none — "
                  "nondeterministic surfaces (active_threads, timing "
                  "report lines) are pinned/verified structurally by "
                  "design, not divergences.",
    }],
    scope_files=[
        "src/go/parallel-processor/parallel_processor.go",
        "src/go/parallel-processor/replay.go",
        "src/go/parallel-processor/main.go",
        "src/go/parallel-processor/truth_test.go",
        "src/go/parallel-processor/truth.json",
        "scripts/pp_freeze_seams/sitecustomize.py",
        "scripts/gen_parallel_processor_truth.py",
        "scripts/check_parallel_processor_parity.py",
    ],
)
print("close:", json.dumps(c)[:400])
final = phase_of(cid)
print("FINAL PHASE:", final)
ok = c.get("success") and final == "closed"
print("CLOSED" if ok else "CLOSE_FAILED", cid)
sys.exit(0 if ok else 1)