-
-
Ticker
-
-
-
Value
-
-
-
Amount
-
-
-
Cost Basis
-
+
+
+
+
+
+
+
Account Value Over Time
+
Historical balance snapshots recorded each time this account is synced.
+
+
+ {% if latest_account_point %}
+
+
Latest Snapshot
+
${{ latest_account_point.display_value }}
+
+ {% endif %}
+
+
+
+ ${{ account_chart.max_label }}
+ Change shown on hover
+
+
+
+ {{ account_chart.start_label }}
+ ${{ account_chart.min_label }}
+ {{ account_chart.end_label }}
+
+
No account history yet. Run another sync to capture snapshots.
+ {% endif %}
+
+
+
+
+ Snapshot Timeline
+ {% if account_timeline %}
+
+ {% for point in account_timeline %}
+
+
+ {{ point.label }}
+ ${{ point.display_value }}
+
+
+ {% endfor %}
+
No snapshot points available yet.
+ {% endif %}
+
+
+
+
+
+
+
Current Holdings
+ {{ holdings|length }} position{{ holdings|length|pluralize }}
+
+
+
+
+
+
Ticker
+
Value
+
Amount
+
Cost Basis
+
+
+ {% for holding in holdings %}
+
+
+
+ {{ holding.asset.ticker }}
+
+
+ ${{ holding.holding_value|floatformat:2 }}
+
${{ holding.holding_gain|floatformat:2 }}
+
+
+ {{ holding.ammount|floatformat:4 }}
+
+
+ ${{ holding.cost_basis|floatformat:2 }}
+
+
+
+ {% empty %}
+
+
No holdings available for this account.
+
+ {% endfor %}
+
+
+{% endblock %}
diff --git a/overview/tests.py b/overview/tests.py
index 2d3c8a3..b2e0fb0 100644
--- a/overview/tests.py
+++ b/overview/tests.py
@@ -1,9 +1,10 @@
-from datetime import datetime, timezone
+from datetime import datetime, timedelta, timezone
from io import StringIO
from django.core.management import call_command
from django.core.management.base import CommandError
from django.test import TestCase
+from django.utils import timezone as django_timezone
from .brokerage_types import (
BrokerageAccountPayload,
@@ -14,7 +15,16 @@ from .brokerage_types import (
from .brokerages.base import BaseBrokerageAdapter, BrokerageAdapterError
from .brokerages.random import RandomBrokerageAdapter
from .brokerages.registry import register_brokerage_adapter
-from .models import Account, AccountHolding, Asset, BrokerageConnection, IngestionRun
+from .models import (
+ Account,
+ AccountHolding,
+ AccountSnapshot,
+ Asset,
+ AssetPriceSnapshot,
+ BrokerageConnection,
+ HoldingSnapshot,
+ IngestionRun,
+)
from .services import BrokerageIngestionService
@@ -136,14 +146,21 @@ class BrokerageIngestionServiceTests(TestCase):
self.assertEqual(Account.objects.count(), 1)
self.assertEqual(Asset.objects.count(), 1)
self.assertEqual(AccountHolding.objects.count(), 1)
+ self.assertEqual(AccountSnapshot.objects.count(), 2)
+ self.assertEqual(AssetPriceSnapshot.objects.count(), 2)
+ self.assertEqual(HoldingSnapshot.objects.count(), 2)
account = Account.objects.get()
asset = Asset.objects.get()
holding = AccountHolding.objects.get()
+ latest_holding_snapshot = HoldingSnapshot.objects.filter(
+ ingestion_run=second_run
+ ).get()
self.assertEqual(account.balance, 12500)
self.assertEqual(asset.price, 205.55)
self.assertEqual(holding.ammount, 12)
+ self.assertEqual(latest_holding_snapshot.value, 12 * 205.55)
self.assertEqual(second_run.accounts_processed, 1)
self.assertEqual(second_run.assets_processed, 1)
self.assertEqual(second_run.holdings_processed, 1)
@@ -285,6 +302,18 @@ class BrokerageIngestionServiceTests(TestCase):
).count(),
6,
)
+ self.assertEqual(
+ AccountSnapshot.objects.filter(ingestion_run=run).count(),
+ 3,
+ )
+ self.assertEqual(
+ AssetPriceSnapshot.objects.filter(ingestion_run=run).count(),
+ 6,
+ )
+ self.assertEqual(
+ HoldingSnapshot.objects.filter(ingestion_run=run).count(),
+ 6,
+ )
def test_sync_command_accepts_provider_identifier(self):
random_connection = BrokerageConnection.objects.create(
@@ -331,3 +360,257 @@ class BrokerageIngestionServiceTests(TestCase):
)
self.assertIn("matches multiple active connections", str(exc.exception))
+
+ def test_overview_page_renders_portfolio_history(self):
+ BrokerageIngestionService(
+ self.connection,
+ adapter=FakeBrokerageAdapter(
+ self.connection,
+ snapshot=BrokerageSnapshot(
+ accounts=[
+ BrokerageAccountPayload(
+ external_id="acct-1",
+ name="Brokerage Account",
+ number="1234",
+ balance=10000,
+ )
+ ],
+ assets=[
+ BrokerageAssetPayload(
+ external_id="asset-1",
+ ticker="AAPL",
+ price=200.00,
+ )
+ ],
+ holdings=[
+ BrokerageHoldingPayload(
+ external_id="holding-1",
+ account_external_id="acct-1",
+ asset_external_id="asset-1",
+ ticker="AAPL",
+ amount=10,
+ cost_basis=150.00,
+ purchase_date=datetime(2025, 1, 15, tzinfo=timezone.utc),
+ )
+ ],
+ ),
+ ),
+ ).ingest()
+
+ response = self.client.get("/")
+
+ self.assertEqual(response.status_code, 200)
+ self.assertContains(response, "Portfolio Value Over Time")
+ self.assertContains(response, "Recent Sync Points")
+
+ def test_account_page_renders_account_history(self):
+ run = BrokerageIngestionService(
+ self.connection,
+ adapter=FakeBrokerageAdapter(
+ self.connection,
+ snapshot=BrokerageSnapshot(
+ accounts=[
+ BrokerageAccountPayload(
+ external_id="acct-1",
+ name="Brokerage Account",
+ number="1234",
+ balance=10000,
+ )
+ ],
+ assets=[
+ BrokerageAssetPayload(
+ external_id="asset-1",
+ ticker="AAPL",
+ price=200.00,
+ )
+ ],
+ holdings=[
+ BrokerageHoldingPayload(
+ external_id="holding-1",
+ account_external_id="acct-1",
+ asset_external_id="asset-1",
+ ticker="AAPL",
+ amount=10,
+ cost_basis=150.00,
+ purchase_date=datetime(2025, 1, 15, tzinfo=timezone.utc),
+ )
+ ],
+ ),
+ ),
+ ).ingest()
+ account = AccountSnapshot.objects.get(ingestion_run=run).account
+
+ response = self.client.get(f"/portfolio/{account.id}")
+
+ self.assertEqual(response.status_code, 200)
+ self.assertContains(response, "Account Value Over Time")
+ self.assertContains(response, "Current Holdings")
+
+ def test_overview_range_selector_filters_to_recent_history(self):
+ first_run = BrokerageIngestionService(
+ self.connection,
+ adapter=FakeBrokerageAdapter(
+ self.connection,
+ snapshot=BrokerageSnapshot(
+ accounts=[
+ BrokerageAccountPayload(
+ external_id="acct-1",
+ name="Brokerage Account",
+ number="1234",
+ balance=8000,
+ )
+ ],
+ assets=[
+ BrokerageAssetPayload(
+ external_id="asset-1",
+ ticker="AAPL",
+ price=180.00,
+ )
+ ],
+ holdings=[
+ BrokerageHoldingPayload(
+ external_id="holding-1",
+ account_external_id="acct-1",
+ asset_external_id="asset-1",
+ ticker="AAPL",
+ amount=10,
+ cost_basis=150.00,
+ purchase_date=datetime(2025, 1, 15, tzinfo=timezone.utc),
+ )
+ ],
+ ),
+ ),
+ ).ingest()
+ second_run = BrokerageIngestionService(
+ self.connection,
+ adapter=FakeBrokerageAdapter(
+ self.connection,
+ snapshot=BrokerageSnapshot(
+ accounts=[
+ BrokerageAccountPayload(
+ external_id="acct-1",
+ name="Brokerage Account",
+ number="1234",
+ balance=12000,
+ )
+ ],
+ assets=[
+ BrokerageAssetPayload(
+ external_id="asset-1",
+ ticker="AAPL",
+ price=210.00,
+ )
+ ],
+ holdings=[
+ BrokerageHoldingPayload(
+ external_id="holding-1",
+ account_external_id="acct-1",
+ asset_external_id="asset-1",
+ ticker="AAPL",
+ amount=10,
+ cost_basis=150.00,
+ purchase_date=datetime(2025, 1, 15, tzinfo=timezone.utc),
+ )
+ ],
+ ),
+ ),
+ ).ingest()
+
+ old_timestamp = django_timezone.now() - timedelta(days=40)
+ recent_timestamp = django_timezone.now() - timedelta(days=2)
+ IngestionRun.objects.filter(pk=first_run.pk).update(started_at=old_timestamp)
+ IngestionRun.objects.filter(pk=second_run.pk).update(started_at=recent_timestamp)
+ AccountSnapshot.objects.filter(ingestion_run=first_run).update(snapshot_at=old_timestamp)
+ AccountSnapshot.objects.filter(ingestion_run=second_run).update(snapshot_at=recent_timestamp)
+
+ response = self.client.get("/", {"range": "7d"})
+
+ self.assertEqual(response.status_code, 200)
+ self.assertContains(response, "value=\"7d\" selected")
+ self.assertNotContains(response, old_timestamp.strftime("%Y-%m-%d %H:%M"))
+ self.assertContains(response, recent_timestamp.strftime("%Y-%m-%d %H:%M"))
+
+ def test_account_range_selector_filters_account_history(self):
+ first_run = BrokerageIngestionService(
+ self.connection,
+ adapter=FakeBrokerageAdapter(
+ self.connection,
+ snapshot=BrokerageSnapshot(
+ accounts=[
+ BrokerageAccountPayload(
+ external_id="acct-1",
+ name="Brokerage Account",
+ number="1234",
+ balance=9000,
+ )
+ ],
+ assets=[
+ BrokerageAssetPayload(
+ external_id="asset-1",
+ ticker="AAPL",
+ price=180.00,
+ )
+ ],
+ holdings=[
+ BrokerageHoldingPayload(
+ external_id="holding-1",
+ account_external_id="acct-1",
+ asset_external_id="asset-1",
+ ticker="AAPL",
+ amount=10,
+ cost_basis=150.00,
+ purchase_date=datetime(2025, 1, 15, tzinfo=timezone.utc),
+ )
+ ],
+ ),
+ ),
+ ).ingest()
+ second_run = BrokerageIngestionService(
+ self.connection,
+ adapter=FakeBrokerageAdapter(
+ self.connection,
+ snapshot=BrokerageSnapshot(
+ accounts=[
+ BrokerageAccountPayload(
+ external_id="acct-1",
+ name="Brokerage Account",
+ number="1234",
+ balance=11000,
+ )
+ ],
+ assets=[
+ BrokerageAssetPayload(
+ external_id="asset-1",
+ ticker="AAPL",
+ price=205.00,
+ )
+ ],
+ holdings=[
+ BrokerageHoldingPayload(
+ external_id="holding-1",
+ account_external_id="acct-1",
+ asset_external_id="asset-1",
+ ticker="AAPL",
+ amount=10,
+ cost_basis=150.00,
+ purchase_date=datetime(2025, 1, 15, tzinfo=timezone.utc),
+ )
+ ],
+ ),
+ ),
+ ).ingest()
+ account = Account.objects.get()
+
+ old_timestamp = django_timezone.now() - timedelta(days=500)
+ recent_timestamp = django_timezone.now() - timedelta(days=5)
+ IngestionRun.objects.filter(pk=first_run.pk).update(started_at=old_timestamp)
+ IngestionRun.objects.filter(pk=second_run.pk).update(started_at=recent_timestamp)
+ AccountSnapshot.objects.filter(ingestion_run=first_run).update(snapshot_at=old_timestamp)
+ AccountSnapshot.objects.filter(ingestion_run=second_run).update(snapshot_at=recent_timestamp)
+
+ response = self.client.get(f"/portfolio/{account.id}", {"range": "30d"})
+
+ self.assertEqual(response.status_code, 200)
+ self.assertContains(response, "value=\"30d\" selected")
+ self.assertNotContains(response, old_timestamp.strftime("%Y-%m-%d %H:%M"))
+ self.assertContains(response, recent_timestamp.strftime("%Y-%m-%d %H:%M"))
diff --git a/overview/views.py b/overview/views.py
index 7f16fde..4b5080a 100644
--- a/overview/views.py
+++ b/overview/views.py
@@ -1,18 +1,209 @@
-from django.http import HttpResponse
-from django.shortcuts import render
-from .models import Account, AccountHolding
+from datetime import timedelta
+from decimal import Decimal
+
+from django.http import HttpRequest
+from django.shortcuts import get_object_or_404, render
+from django.utils import timezone
+
+from .models import Account, AccountHolding, AccountSnapshot, IngestionRun
+
+
+def _format_currency(value):
+ return f"{value:,.2f}"
+
+
+DATE_RANGE_OPTIONS = [
+ ("7d", "7D"),
+ ("30d", "30D"),
+ ("90d", "90D"),
+ ("1y", "1Y"),
+ ("all", "All"),
+]
+
+
+def _get_selected_range(request: HttpRequest):
+ allowed_values = {value for value, _ in DATE_RANGE_OPTIONS}
+ selected_range = request.GET.get("range", "all")
+ if selected_range not in allowed_values:
+ return "all"
+ return selected_range
+
+
+def _get_range_cutoff(selected_range: str):
+ now = timezone.now()
+ if selected_range == "7d":
+ return now - timedelta(days=7)
+ if selected_range == "30d":
+ return now - timedelta(days=30)
+ if selected_range == "90d":
+ return now - timedelta(days=90)
+ if selected_range == "1y":
+ return now - timedelta(days=365)
+ return None
+
+
+def _filter_timeline_by_range(timeline, selected_range: str):
+ cutoff = _get_range_cutoff(selected_range)
+ if cutoff is None:
+ return timeline
+
+ filtered = [point for point in timeline if point["timestamp"] >= cutoff]
+ if filtered:
+ return filtered
+ return timeline[-1:] if timeline else []
+
+
+def _build_chart_model(timeline, width=100, height=100):
+ if not timeline:
+ return {
+ "path": "",
+ "points": [],
+ "min_label": _format_currency(0),
+ "max_label": _format_currency(0),
+ "start_label": "",
+ "end_label": "",
+ }
+
+ values = [point["value"] for point in timeline]
+ min_value = min(values)
+ max_value = max(values)
+ span = max_value - min_value
+ if span == 0:
+ span = 1
+
+ chart_points = []
+ coordinates = []
+ point_count = len(timeline)
+ for index, point in enumerate(timeline):
+ if point_count == 1:
+ x = width / 2
+ y = height / 2
+ else:
+ x = (index / (point_count - 1)) * width
+ normalized = (point["value"] - min_value) / span
+ y = height - (normalized * height)
+
+ change = None
+ change_display = "N/A"
+ if index > 0:
+ change = point["value"] - timeline[index - 1]["value"]
+ sign = "+" if change >= 0 else "-"
+ change_display = f"{sign}${_format_currency(abs(change))}"
+
+ chart_points.append(
+ {
+ "x": f"{x:.2f}",
+ "y": f"{y:.2f}",
+ "label": point["label"],
+ "display_value": point["display_value"],
+ "change_display": change_display,
+ }
+ )
+ normalized = (point["value"] - min_value) / span
+ coordinates.append(f"{x:.2f},{y:.2f}")
+
+ if len(coordinates) == 1:
+ path = f"M 0 {height / 2:.2f} L {width:.2f} {height / 2:.2f}"
+ else:
+ path = "M " + " L ".join(coordinates)
+
+ return {
+ "path": path,
+ "points": chart_points,
+ "min_label": _format_currency(min_value),
+ "max_label": _format_currency(max_value),
+ "start_label": timeline[0]["short_label"],
+ "end_label": timeline[-1]["short_label"],
+ }
+
+
+def _build_portfolio_timeline():
+ latest_balances = {}
+ timeline = []
+ runs = IngestionRun.objects.order_by("started_at", "created_at").prefetch_related(
+ "accountsnapshot_set__account"
+ )
+
+ for run in runs:
+ snapshots = list(run.accountsnapshot_set.all())
+ if not snapshots:
+ continue
+
+ for snapshot in snapshots:
+ latest_balances[snapshot.account_id] = Decimal(snapshot.balance)
+
+ total_value = sum(latest_balances.values(), Decimal("0"))
+ timestamp = run.started_at or run.created_at
+ timeline.append(
+ {
+ "timestamp": timestamp,
+ "label": timestamp.strftime("%Y-%m-%d %H:%M"),
+ "short_label": timestamp.strftime("%b %d"),
+ "value": float(total_value),
+ "display_value": _format_currency(total_value),
+ }
+ )
+
+ return timeline
+
+
+def _build_account_timeline(account):
+ snapshots = AccountSnapshot.objects.filter(account=account).order_by("snapshot_at")
+ timeline = []
+
+ for snapshot in snapshots:
+ timeline.append(
+ {
+ "timestamp": snapshot.snapshot_at,
+ "label": snapshot.snapshot_at.strftime("%Y-%m-%d %H:%M"),
+ "short_label": snapshot.snapshot_at.strftime("%b %d"),
+ "value": float(snapshot.balance),
+ "display_value": _format_currency(snapshot.balance),
+ }
+ )
+
+ return timeline
-# Create your views here.
def index(request):
+ accounts = Account.objects.all().order_by("name")
+ selected_range = _get_selected_range(request)
+ portfolio_timeline = _filter_timeline_by_range(
+ _build_portfolio_timeline(),
+ selected_range,
+ )
+ latest_portfolio_point = portfolio_timeline[-1] if portfolio_timeline else None
+ chart_model = _build_chart_model(portfolio_timeline)
- accounts = Account.objects.all()
+ context = {
+ "accounts": accounts,
+ "date_range_options": DATE_RANGE_OPTIONS,
+ "selected_range": selected_range,
+ "portfolio_timeline": portfolio_timeline,
+ "latest_portfolio_point": latest_portfolio_point,
+ "portfolio_chart": chart_model,
+ }
+ return render(request, "overviewbase.html", context)
- return render(request, "overviewbase.html", {"accounts": accounts})
def portfolio(request, account_id):
+ account = get_object_or_404(Account, pk=account_id)
+ holdings = AccountHolding.objects.filter(account=account).select_related("asset")
+ selected_range = _get_selected_range(request)
+ account_timeline = _filter_timeline_by_range(
+ _build_account_timeline(account),
+ selected_range,
+ )
+ latest_account_point = account_timeline[-1] if account_timeline else None
+ chart_model = _build_chart_model(account_timeline)
- account = Account.objects.get(pk=account_id)
- holdings = AccountHolding.objects.filter(account = account)
-
- return render(request, "portfolio.html", {"account": account, "holdings": holdings})
\ No newline at end of file
+ context = {
+ "account": account,
+ "date_range_options": DATE_RANGE_OPTIONS,
+ "selected_range": selected_range,
+ "holdings": holdings,
+ "account_timeline": account_timeline,
+ "latest_account_point": latest_account_point,
+ "account_chart": chart_model,
+ }
+ return render(request, "portfolio.html", context)
diff --git a/templates/base.html b/templates/base.html
index 508fdd2..7ee32d5 100644
--- a/templates/base.html
+++ b/templates/base.html
@@ -4,6 +4,114 @@
{% block title %}{% endblock %} - Stonks
+
@@ -29,9 +137,9 @@