File size: 1,635 Bytes
03b76a5 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 | #!/usr/bin/env python3
"""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()
|