"""Finite C269 source-path audit; exact arithmetic, no search or graph mutation."""
from pathlib import Path
from fractions import Fraction as F
import argparse, hashlib, json, csv

ROOT=Path(__file__).resolve().parents[1]
p=argparse.ArgumentParser();p.add_argument('--output',type=Path,default=ROOT/'evidence')
OUT=p.parse_args().output;OUT.mkdir(parents=True,exist_ok=True)
checks=[]
def check(name,condition):
    if not condition:raise AssertionError(name)
    checks.append(name)
def sha(path):return hashlib.sha256(path.read_bytes()).hexdigest()
def load(name):return json.loads((ROOT/'sources'/name).read_text())
def dump(name,obj):(OUT/name).write_text(json.dumps(obj,indent=2,ensure_ascii=False,default=str)+'\n')
def pair(x):return [F(x)-F(1,4),F(x)+F(1,4)]
def spans(a,b):return [q-p for p,q in zip(pair(a),pair(b))]
for name,row in json.loads((ROOT/'SOURCE_MANIFEST.json').read_text()).items():
    src=ROOT/'sources'/name
    check('frozen '+name,sha(src)==row['sha256'] and src.stat().st_size==row['bytes'])
prev=load('C268_CERTIFICATE.json')
for name,key in [('C268_REPORT.md','report_sha256'),('C268_CHECKPOINT.md','checkpoint_sha256'),('C268_RESULTS.json','results_sha256')]:
    check('C268 certificate '+name,sha(ROOT/'sources'/name)==prev[key])
expected={'FILE_18.md':'68301ab760bfbe2e874aedc5c8d943ced7a6219d34bc2859332a70713f9630d5','FILE_09.md':'45851004c5864229ebf6a896f9099819a08d8926715d3e97e4bc3985c4a3876e','C127_GRAPH.json':'d7be8886117c8c550e39f8846862ec613f621c0ed560d4c9d8c89446fae53503','C18_REPORT.md':'b11fefdbcfe2f5c95532d851cca1b6eede99bbd9e4e166d214c087f11fc3b753'}
for name,digest in expected.items():check('controlling hash '+name,sha(ROOT/'sources'/name)==digest)
G=load('C127_GRAPH.json')['graph'];nodes={n['id']:n for n in G['nodes']};edges={e['id']:e for e in G['duration_edges']}
check('frozen graph sizes',len(nodes)==208 and len(edges)==382)
old=load('C01_RESULTS.json');events=old['events'];chains=old['complete_three_stage_chains']
check('fixed source domain',len(events)==48 and len(chains)==2)
records=load('C266_ENDPOINTS.json')
flood=sorted([r for r in records if r['profile']=='LXX_OFF' and r['source_role']=='Flood'],key=lambda r:r['source_index'])
check('retained LXX full Flood field',len(flood)==8 and [r['source_BC_base'] for r in flood]==list(range(5290,5282,-1)))
fc=flood[-1]
sc=[r for r in records if r['profile']=='LXX_OFF' and r['source_role']=='Shem' and r['source_index']==7 and r['reflection_after_translation']][0]
l=-fc['source_BC_base'];s=-sc['source_BC_base']
check('closing source identities',(l,s)==(-5283,-5883))
check('closing local transforms',l+fc['translation']==7 and -(s+sc['translation'])==-5)
check('no cumulative Gear',fc['regular_Gear'] is None and sc['regular_Gear'] is None)
check('Flood closing not stored in C127',not any(n['signed_center']==l for n in nodes.values()))
check('Shem closing stored identity',nodes['N04_cm']['signed_center']==s and nodes['N04_cm']['role']=='cum_LXX_OFF_Shem')

selected_edges=[]
def edge(identifier,source,target,width):
    e=edges[identifier]
    check('stored edge '+identifier,(e['from'],e['to'],e['width'])==(source,target,width))
    check('edge coordinate width '+identifier,nodes[target]['signed_center']-nodes[source]['signed_center']==width)
    selected_edges.append(e);return e
paths=[];operator=[]
for label,chain,j in zip(['N02','N04'],chains,[3,5]):
    c=nodes[label+'_c']['signed_center'];a=-chain['Creation_BC_Nisan']
    f=chain['Flood']['BC_Nisan'];m=chain['midpoint']['BC_Nisan'];n=chain['MT_Noah']['BC_Nisan'];v=chain['SP_Noah']['BC_Nisan']
    check(label+' cumulative source member',flood[j]['source_BC_base']==-c and flood[j]['pair_center']==j)
    for suffix,value in [('_b',a),('_f',f),('_spDeath',m),('_mtN',n),('_s',v)]:
        check(label+' graph source '+suffix,nodes[label+suffix]['signed_center']==value and nodes[label+suffix]['source_membership_verified'])
    route=[('_868','_c','_b',868),('_13','_b','_f',6877),('_299a','_f','_spDeath',299),('_299b','_spDeath','_mtN',299),('_650','_mtN','_s',650)]
    for eid,u,w,d in route:edge(label+eid,label+u,label+w,d)
    edge(label+'_17',label+'_c',label+'_s',8993)
    edge(label+'_opening_member_offset','opening_OFF_BC',label+'_c',j)
    # Subdivide the stored attachment with the existing source closing boundary.
    gap=l-c;tail=a-l;points=[c,l,a,f,m,n,v];widths=[q-p for p,q in zip(points,points[1:])]
    check(label+' closing insertion ordered',c<l<a)
    check(label+' attachment subdivision',(gap,tail)==((4,864) if label=='N02' else (2,866)) and gap+tail==868)
    check(label+' full ordered source comparison',widths==[gap,tail,6877,299,299,650] and sum(widths)==8993)
    for k,(u,w,d) in enumerate(zip(points,points[1:],widths)):check(label+' both phases segment '+str(k),spans(u,w)==[d,d])
    terminal=[f-l,m-l,n-l,v-l]
    check(label+' closing-to-existing-target widths',terminal==([7741,8040,8339,8989] if label=='N02' else [7743,8042,8341,8991]))
    check(label+' residual from17K',8993-(v-l)==gap)
    paths.append({'chain':label,'source_member_index':j,'centers':points,'widths':widths,'stored_attachment_edge':label+'_868','new_subdivision_status':'source-supported finite subdivision; closing node and subdivision edges are not stored in C127','closing_to_targets':dict(zip(['MT_Flood','SP_companion_Noah_death','MT_Noah_birth','SP_primary_Noah_birth'],terminal))})
    check(label+' inherited7745 translation',c+7745==f and (c+5290)+2455==f)
    for scale in [1196,1300]:
        psi=lambda q:a+scale*(q+5289)
        check(label+' C268 original-source anchor '+str(scale),psi(-5289)==a)
        residual=psi(c)-a
        check(label+' attachment chart mismatch '+str(scale),residual==scale*(j-1) and residual!=0)
        target=m if scale==1196 else F(n+v,2)
        check(label+' C268 closing image '+str(scale),psi(l)==target)
        raw=[psi(t) for t in pair(l)]
        check(label+' C268 changes source phase width '+str(scale),raw[1]-raw[0]==F(scale,2) and raw!=pair(target))
        operator.append({'chain':label,'scale':scale,'original_source_anchor':-5289,'retained_attachment_source':c,'attachment_target':a,'C268_image_of_attachment_source':psi(c),'image_minus_attachment_target':residual,'C268_closing_center_image':target,'C268_raw_closing_phase_images':raw,'raw_width':F(scale,2),'target_standard_pair':pair(target)})

# Bilateral source ancestry: the stored598 selects an interior Flood member.
edge('N04_598cum','N04_cm','N04_c',598)
edge('N04_17opposite','N04_cm','N04_r',8993)
c4=nodes['N04_c']['signed_center'];H=nodes['N04_r']['signed_center']
check('Shem close to Flood close600',l-s==600 and c4-s==598 and l-c4==2)
check('same-phase598plus2',spans(s,c4)==[598,598] and spans(c4,l)==[2,2] and spans(s,l)==[600,600])
check('598 absorbed by inherited translations',s+5888==c4+5290==5 and 5888-5290==598)
check('bilateral local endpoints',-(s+5888)==-5 and l+5290==7 and 2-(l+5290)==-(s+5888))

# Recover just the already completed C254 closing route, not its full campaign.
routes=load('C254_CERTIFICATE.json')['evidence']['new_17fold_source_routes']
r=[r for r in routes if r['s']==7]
check('unique inherited C254 closing selector',len(r)==1);r=r[0]
check('C254 recorded passing status',load('C254_RESULTS.json')['status']=='passed')
closing_route=[-r['D'],-r['b'],r['q'],r['q2'],r['x']]
check('C254 inherited route endpoints',closing_route==[-5283,-4415,1404,2460,3710])
closing_widths=[q-p for p,q in zip(closing_route,closing_route[1:])]
check('C254 inherited route widths',closing_widths==[868,5819,1056,1250] and sum(closing_widths)==8993)
for k,(u,v,d) in enumerate(zip(closing_route,closing_route[1:],closing_widths)):check('C254 both phases '+str(k),spans(u,v)==[d,d])
for ident,value,role in [('C6_creation',-4415,'SP_Creation'),('C6_conquest',1404,'Conquest')]:
    check('closing route retained graph member '+ident,nodes[ident]['signed_center']==value and nodes[ident]['role']==role)
def event(tradition,role,gear,rail,base):
    matches=[e for e in events if (e['tradition'],e['role'],e['gear'],e['rail'],e['BC_Nisan'])==(tradition,role,gear,rail,base)]
    check('unique retained event '+str((tradition,role,gear,base)),len(matches)==1);return matches[0]
MT=event('MT','Flood start',3,None,2460)
SPF=event('SP','Flood start',3,None,3110)
SPN=event('SP','Noah birth',3,'primary',3710)
check('C254 Flood source tag',r['flood_matches']==[MT])
check('old2462 exact13K limit',l+7745==2462 and -r['b']+6877==2462 and not any(e['tradition']=='MT' and e['role'].startswith('Flood') and e['BC_Nisan']==2462 for e in events))
check('new6875 source prefix stays distinct',r['b']+r['q2']==6875 and 6877-6875==2)

# Closing four-point source rectangle. Both17K sides are inherited.
N=r['x'];N4=chains[1]['SP_Noah']['BC_Nisan']
check('closing rectangle source coordinates',(s,l,H,N)==(-5883,-5283,3110,3710))
check('two17K rectangle sides',H-s==N-l==8993==17*529)
check('two600 rectangle sides',l-s==N-H==600)
check('both600 sides split598plus2',[c4-s,l-c4,N4-H,N-N4]==[598,2,598,2])
check('single8993 translation on three source members',[q+8993 for q in [s,c4,l]]==[H,N4,N])
for name,u,v,w in [('left600',s,l,600),('right600',H,N,600),('Shem17K',s,H,8993),('Flood17K',l,N,8993)]:check('rectangle same phases '+name,spans(u,v)==[w,w])
check('equal ordered rectangle routes',600+8993==8993+600==N-s)

dump('SOURCE_PATHS.json',{'N02_N04_refinements':paths,'Shem_closing_link':{'source_centers':[s,c4,l],'widths':[598,2],'stored_edge':'N04_598cum','terminal_extension_status':'source-supported field subdivision, not stored edge'},'inherited_C254_closing_route':{'source_certificate_row':r,'centers':closing_route,'widths':closing_widths,'SP_Noah_source':SPN},'C09_closing_translation_limit':{'translation':7745,'closing_image':2462,'MT_Flood_source_match':False,'status':'inherited exact13K boundary limit, not a rejection of C2546875 route'}})
dump('GRAPH_INCIDENCE.json',{'graph_node_count':208,'selected_stored_edges':selected_edges,'Shem_closing_node':nodes['N04_cm'],'Flood_closing_stored_node':None,'closing_Creation_node':nodes['C6_creation'],'closing_Conquest_node':nodes['C6_conquest'],'graph_modified':False,'new_closing_subdivision_edges_added':False})
dump('CLOSING_RECTANGLE.json',{'source_centers':{'Shem_close':s,'Flood_close':l,'SP_G3_Flood_start':H,'SP_G3_primary_Noah_birth':N},'source_records':{'Shem_close':sc,'Flood_close':fc,'SP_G3_Flood_start':SPF,'SP_G3_primary_Noah_birth':SPN},'parallel17K_width':8993,'parallel600_width':600,'internal598plus2':{'cumulative':c4,'regular':N4},'translation':8993,'status':'dependent integration of existing source relations; not a new independent17K witness'})
dump('OPERATOR_COMPARISON.json',{'C268_source_charts':operator,'source_attachment':'q->q+868 for retained selected members','C09_source_to_MT_Flood':'q->q+7745 on admitted selected members; closing2462 unsourced','source_rectangle':'q->q+8993 on three listed source members','limit':'Connected source paths do not identify the C268 source anchor or implement its seasonal-component-to-pair-center rescaling'})
dump('RESULTS.json',{'step':'C269','status':'passed','check_count':len(checks),'checks':checks,'main_result':'The exact closing sources join retained17K paths and a600-by8993 source rectangle; C254 closing support is retained; C268 affine charts remain distinct operators','canonical_sources_modified':False,'prior_graph_modified':False})
with (OUT/'SOURCE_PATHS.csv').open('w',newline='') as f:
    w=csv.writer(f);w.writerow(['path','from_center','to_center','width','evidence_status'])
    for row in paths:
        for k,(a,b,d) in enumerate(zip(row['centers'],row['centers'][1:],row['widths'])):w.writerow([row['chain'],a,b,d,'new source-supported subdivision' if k<2 else 'existing directed source comparison'])
    for a,b,d in zip(closing_route,closing_route[1:],closing_widths):w.writerow(['C254 selector7',a,b,d,'inherited completed source path'])
print(json.dumps({'step':'C269','status':'passed','checks':len(checks),'output_files':6}))