From 900b002ff7a87707b9726c4ec153fd95be78acb5 Mon Sep 17 00:00:00 2001 From: dirtydishes Date: Tue, 30 Dec 2025 17:40:06 -0500 Subject: [PATCH] Fix flow packet notional to sum all prints --- apps/web/app/page.tsx | 5 ++++- services/compute/src/index.ts | 2 ++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/apps/web/app/page.tsx b/apps/web/app/page.tsx index 3b398dd..c3d861b 100644 --- a/apps/web/app/page.tsx +++ b/apps/web/app/page.tsx @@ -1782,7 +1782,10 @@ export default function HomePage() { const count = parseNumber(features.count, packet.members.length); const totalSize = parseNumber(features.total_size, 0); const totalPremium = parseNumber(features.total_premium, 0); - const notional = totalPremium * 100; + const totalNotional = parseNumber(features.total_notional, Number.NaN); + const notional = Number.isFinite(totalNotional) + ? totalNotional + : totalPremium * 100; const startTs = parseNumber(features.start_ts, packet.source_ts); const endTs = parseNumber(features.end_ts, startTs); const windowMs = parseNumber(features.window_ms, 0); diff --git a/services/compute/src/index.ts b/services/compute/src/index.ts index 8a67226..c8caf0e 100644 --- a/services/compute/src/index.ts +++ b/services/compute/src/index.ts @@ -399,12 +399,14 @@ const flushCluster = async ( const nbboJoin = selectNbbo(cluster.contractId, cluster.endTs); const totalPremium = roundTo(cluster.totalPremium); + const totalNotional = roundTo(totalPremium * 100, 2); const features: Record = { option_contract_id: cluster.contractId, count: cluster.members.length, total_size: cluster.totalSize, total_premium: totalPremium, + total_notional: totalNotional, first_price: cluster.firstPrice, last_price: cluster.lastPrice, start_ts: cluster.startTs,