"""Run a frozen list of episodes with explicit per-episode input files.

The manifest is JSON list. Each row supplies spec, registry, controller, trace.
This runner records failures and never invents task inputs or fills results.
"""
import argparse,json,subprocess,sys,hashlib
from pathlib import Path

def main():
    p=argparse.ArgumentParser();p.add_argument('manifest');p.add_argument('--output',required=True);p.add_argument('--dry-run',action='store_true');a=p.parse_args()
    rows=json.loads(Path(a.manifest).read_text());report=[]
    for r in rows:
        hashes={}
        for key in ['spec','registry','controller']:
            path=Path(r[key]);hashes[key]=hashlib.sha256(path.read_bytes()).hexdigest()
        command=[sys.executable,'-m','peppa.cli','run','--spec',r['spec'],'--registry',r['registry'],'--controller',r['controller'],'--trace',r['trace']]
        status={'episode':r.get('episode',r['trace']),'hashes':hashes,'command':command}
        if a.dry_run:status['status']='validated paths'
        else:
            result=subprocess.run(command,text=True,capture_output=True,check=False)
            status.update(returncode=result.returncode,stdout=result.stdout,stderr=result.stderr)
        report.append(status)
        Path(a.output).parent.mkdir(parents=True,exist_ok=True);Path(a.output).write_text(json.dumps(report,indent=2))
if __name__=='__main__':main()