"""Constructed trace carrier and support query; not an SDK or telemetry collector."""
import json,re
TRACE_A='a'*32;TRACE_B='b'*32;WEB='1'*16;WORKER='2'*16
message={'order_id':'O42','operation_id':'op7','traceparent':f'00-{TRACE_A}-{WEB}-01'}
m=re.fullmatch(r'00-([0-9a-f]{32})-([0-9a-f]{16})-([0-9a-f]{2})',message['traceparent'])
assert m and m.group(1)!='0'*32 and m.group(2)!='0'*16
extracted={'trace_id':m.group(1),'remote_parent_span':m.group(2),'worker_span':WORKER}
logs=[{'order':'O42','operation':'op7','attempt':None,'event':'accepted','trace':TRACE_A,'span':WEB},
{'order':'O42','operation':'op7','attempt':None,'event':'worker_started','trace':extracted['trace_id'],'span':WORKER},
{'order':'O42','operation':'op7','attempt':'attempt1','event':'issued_unconfirmed','trace':None,'span':None},
{'order':'O42','operation':'op7','attempt':'attempt2','event':'queued','trace':TRACE_B,'span':'4'*16},
{'order':'O43','operation':'op8','attempt':None,'event':'accepted','trace':'c'*32,'span':'5'*16},
{'order':'O43','operation':'op8','attempt':'attempt1','event':'destination_confirmed','trace':'c'*32,'span':'6'*16}]
accepted={r['operation'] for r in logs if r['event']=='accepted'}
confirmed={r['operation'] for r in logs if r['event']=='destination_confirmed'}
missing=sorted(accepted-confirmed)
by_order=[r for r in logs if r['order']=='O42']
assert missing==['op7'] and len(by_order)==4 and {r['trace'] for r in by_order}=={TRACE_A,TRACE_B,None}
report={'message':message,'extracted':extracted,'logs':logs,'acceptedWithoutLoggedConfirmation':missing,'O42Records':by_order,'scope':'Synthetic logging query; missing log is not proof of missing external effect'}
if __name__=='__main__':print(json.dumps(report,indent=2))