from fin_infra.net_worth.aggregator import NetWorthAggregatorAggregates net worth from multiple financial providers. **Features**: - Multi-provider support (banking, brokerage, crypto) - Parallel account fetching (faster performance) - Graceful error handling (continue if one provider fails) - Currency normalization (all -> base currency) - Market value calculation (stocks/crypto) **Example**:
aggregator = NetWorthAggregator(
banking_provider=banking,
brokerage_provider=brokerage,
crypto_provider=crypto,
base_currency="USD"
)
snapshot = await aggregator.aggregate_net_worth("user_123")
print(f"Assets: ${snapshot.total_assets:,.2f}")
print(f"Liabilities: ${snapshot.total_liabilities:,.2f}")
print(f"Net Worth: ${snapshot.total_net_worth:,.2f}")