import importlib.util,hashlib,json,os,shutil,sys,uuid
from pathlib import Path
sys.dont_write_bytecode=True
CO=Path('/Users/korizatou114/Projects/TheTree-managed-worktrees/p24-02-operations/.runtime/coordinator-resume-20261017-r02')
context=json.loads((CO/'ACTUAL_REPAIR6_PREPARED_COMPOSITION.json').read_text())
review=json.loads((CO/'REPAIR6_LIMITED_STATIC_REVIEW_RESULT.json').read_text())
assert review['S']==context['S'] and review['Q']==context['Q'] and review['result']['status']=='pass'
assert not [f for f in review['result']['findings'] if f['severity'] in ('critical','high','medium')]
ROOT=Path(context['worktree'])
OUT=Path('/Users/korizatou114/Projects/TheTree-managed-worktrees/p24-02-operations/.runtime/P24-02/build')/('p24-local-r6-'+context['S'][:7]+'-r01')
spec=importlib.util.spec_from_file_location('p24_existing_native_runner',ROOT/'tools/run_all_tests.py');r=importlib.util.module_from_spec(spec);spec.loader.exec_module(r)
paths=['tests/ui/test_operations_notification.gd','tests/ui/test_event_log_ui.gd','tests/ui/test_selection_autosave.gd']
import subprocess
candidate=subprocess.check_output(['git','rev-parse','HEAD'],cwd=ROOT,text=True).strip()
r.require(len(sys.argv)==2 and candidate==sys.argv[1]==context['Q'], 'exact prepared actual Q; not normal integration candidate')
dirty_status=subprocess.check_output(['git','status','--porcelain'],cwd=ROOT,text=True)
r.require(not dirty_status, 'submitted candidate clean')
# Preflight only: exact source map and ordinary guards remain; no submitted-version acceptance.

refs=r.source_refs(ROOT);before=refs;expected={n:{'bytes':v['bytes'],'sha256':v['sha256']} for n,v in refs.items()};policy=r.read(ROOT/'tools/regression/suite-policy.json');r.policy_coverage(paths,refs,policy)
markers=r.module('p24_local_markers',ROOT/'tools/strict_test_markers.py');cp=ROOT/'docs/plans/original-completion-2026-10-02/execution/completion_marker_contracts.json';contracts=markers.load_contracts(cp)
OUT.parent.mkdir(parents=True,exist_ok=True)
outer=r.module('p24_local_owned_outer',ROOT/'tools/regression/owned_outer.py');r.require(not outer.native.helper['live_engines'](),'another Godot is live');r.require(shutil.disk_usage(OUT.parent).free>=500*1024*1024,'local admission free>=500MiB')
OUT.mkdir(parents=True,exist_ok=False);stage=OUT/'stage';stage.mkdir();(OUT/'starters').mkdir();(OUT/'bootstrap').mkdir()
for n,pin in r.read(ROOT/'tools/regression/bootstrap-scripts.json').items():
 data=pin['text'].encode();r.require(hashlib.sha256(data).hexdigest()==pin['sha256'],'bootstrap exact');(OUT/'bootstrap'/n).write_bytes(data)
for n,pin in refs.items():
 target=stage/n;target.parent.mkdir(parents=True,exist_ok=True);r.copy_source(Path(pin['path']),target)
r.require(r.inventory(stage,stage=True)==expected,'whole separate CoW stage exact')
protected=r.default_player(ROOT);public=(stage/'project.godot').read_bytes();parse=['res://'+n for n in sorted(refs) if n.endswith('.gd')];r.write(OUT/'parse-paths.json',parse)
selected={'root_before':before,'map':{n:p['sha256'] for n,p in refs.items()},'timeout':300};engine='/Applications/Godot.app/Contents/MacOS/Godot'
r.write(OUT/'runner-input.json',{'protocol':'guarded-operations-local-v1','full_regression':False,'source_commit':candidate,'source_state':'exact prepared Q/T local affected verification; not normal integration candidate or whole-unit acceptance','S':context['S'],'M':context['M'],'Q':context['Q'],'T':context['T'],'dirty_status':dirty_status,'selected_source_map':selected['map'],'roster':paths,'full_roster':r.roster(ROOT),'owner_runner_pid':os.getpid(),'stage':str(stage),'default_player_before':protected,'engine':engine,'engine_sha256':r.sha(engine),'marker_contract_sha256':r.sha(cp),'execution_controller_sha256':r.sha(Path(__file__)),'existing_phase_controller_sha256':r.sha(ROOT/'tools/run_all_tests.py')})
diagnostics=r.module('p24_local_diagnostics',ROOT/'tools/regression/diagnostic_gate.py');owners=r.module('p24_local_owners',ROOT/'tools/regression/ordinary_proof_gate.py');audio=r.module('p24_local_audio',ROOT/'tools/regression/audio_evidence_gate.py')
rows=[];phases=[];previous={};error=None
try:
 for label,test in [('import',None),('parse',None)]+[(str(i).zfill(3),n)for i,n in enumerate(paths)]:
  row=r.execute_phase(engine,stage,OUT,label,test,selected,expected,previous,policy,contracts,parse,public,protected,ROOT,outer,markers,diagnostics,owners,audio);phases.append(row)
  if test:rows.append(row)
  print(json.dumps({'phase':label,'test':test,'passed':row['passed'],'actual_pid':row.get('actual_pid'),'checks':row.get('reported_checks'),'error':row.get('validation_error') or row.get('guard_error')},ensure_ascii=False),flush=True)
  r.require(row['passed'],'first local phase failure; no retry')
except BaseException as e:error=type(e).__name__+': '+str(e)
finally:cleanup,cleanup_errors=outer.finish_captured(outer.OWNED)
guards=[]
try:
 r.require(r.source_refs(ROOT)==before,'whole source unchanged');r.require(r.default_player(ROOT)==protected,'default player unchanged');r.require(r.inventory(stage,stage=True)==dict(expected,**previous),'whole stage and generated file set exact')
except BaseException as e:guards.append(type(e).__name__+': '+str(e))
passed=not error and not guards and not cleanup_errors and len(phases)==len(paths)+2 and all(x['passed'] for x in phases)
r.write(OUT/'local-ended.json',{'protocol':'guarded-operations-local-v1','full_regression':False,'passed':passed,'error':error,'guard_errors':guards,'cleanup_errors':cleanup_errors,'final_owned_cleanup':cleanup,'actual_captured_pids':[p.pid for p in outer.OWNED],'phases':phases,'rows':rows,'original_unit_accepted':False,'preflight_only':True,'S':context['S'],'M':context['M'],'Q':context['Q'],'T':context['T'],'OS_input_executed':False,'cross_process_executed':False,'independent_review_executed':False})
print(json.dumps({'selected_local_passed':passed,'executed_suites':len(rows),'planned_local_suites':len(paths),'error':error,'guard_errors':guards,'cleanup_errors':cleanup_errors,'full_regression':False}),flush=True)
sys.exit(0 if passed else 1)
