| |
| """Reproduce period-wide FIFO from a hash-checked local daily archive audit.""" |
| import argparse |
| import hashlib |
| import json |
| from pathlib import Path |
| from audit_trade_ledger import audit_fills,write_csv |
|
|
| def main(): |
| parser=argparse.ArgumentParser(description=__doc__) |
| parser.add_argument('--daily-audit',required=True);parser.add_argument('--output',required=True) |
| args=parser.parse_args();audit=json.loads(Path(args.daily_audit).read_text());fills=[] |
| for source in audit['sources']: |
| raw=Path(source['path']).read_bytes() |
| if hashlib.sha256(raw).hexdigest()!=source['sha256']:raise ValueError('Source archive checksum changed') |
| fills.extend(json.loads(raw)['trade_history']) |
| symbols=sorted({row['ticker'] for row in audit['daily']});results={};matches=[] |
| for symbol in symbols: |
| results[symbol],rows=audit_fills([row for row in fills if row['ticker']==symbol]);matches.extend(rows) |
| output=Path(args.output);output.mkdir(parents=True,exist_ok=False) |
| write_csv(output/'continuous_period_matches.csv',matches) |
| payload=dict(source_type='local order mirrors; unverified completeness and opening inventory', |
| method='FIFO across the entire nine-session period without daily inventory reset',symbols=results,sources=audit['sources'], |
| fees_verified=False,account_equity_verified=False) |
| (output/'continuous_period_audit.json').write_text(json.dumps(payload,indent=2)+'\n') |
| print(json.dumps({s:{k:r[k] for k in ('fifo_realized_before_fees','net_quantity_change')} for s,r in results.items()},indent=2)) |
|
|
| if __name__=='__main__':main() |
|
|
