B2-1 DASHBOARD

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_107":89,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":58,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",96,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","04700fba-816b-11f1-bba6-1607ee4eb77e","name","fileType","http","content","/* Open in Val Town: https://www.val.town/x/vvampa/b21-dashboard/code/main.ts */\n/* Open in Val Town: https://www.val.town/x/vvampa/b21-dashboard/code/main.ts */\n// b21-dashboard: live BFF portfolio dashboard\n// Real portfolio + Reasoning + Watchlist + Thesis + Hansen Timeline\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n// ── Database initialization ──────────────────────────────────────────\nasync function initDB() {\n // Real portfolio positions\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS real_positions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n account TEXT NOT NULL,\n ticker TEXT NOT NULL,\n avg_price REAL NOT NULL,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n // Paper trading was retired in August 2026. Remove its stored ledger.\n await sqlite.execute(`DROP TABLE IF EXISTS trades`);\n // Per-ticker reasoning\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS reasoning (\n ticker TEXT PRIMARY KEY,\n reasoning TEXT NOT NULL,\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n // Watchlist\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS watchlist (\n ticker TEXT PRIMARY KEY,\n reasoning TEXT,\n added_date TEXT DEFAULT (datetime('now'))\n )\n `);\n // Market thesis (single row)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS market_thesis (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n thesis TEXT NOT NULL,\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n // Portfolio snapshots for performance chart\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS portfolio_snapshots (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n date TEXT NOT NULL UNIQUE,\n paper_pnl_pct REAL NOT NULL DEFAULT 0,\n bff_pnl_pct REAL NOT NULL DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n // Longform theses\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS theses (\n ticker TEXT PRIMARY KEY,\n longform TEXT NOT NULL,\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n // Philosophy\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS philosophy (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n longform TEXT NOT NULL,\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n // Current prices (updated by cron from local finviz)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS current_prices (\n ticker TEXT PRIMARY KEY,\n price REAL NOT NULL,\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n // Add qty column to real_positions if missing\n await sqlite.execute(`ALTER TABLE real_positions ADD COLUMN qty REAL DEFAULT 0`).catch(() => { });\n}\n// ── Seed data ───────────────────────────────────────────────────────\nasync function seedData() {\n // Positions are never seeded or hardcoded. They arrive from the live Robinhood sync.\n await sqlite.execute({\n sql: \"INSERT OR IGNORE INTO portfolio_snapshots (date, paper_pnl_pct, bff_pnl_pct) VALUES (?, ?, ?)\",\n args: ['2026-07-16', 0, 0],\n });\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO market_thesis (id, thesis, updated_at) VALUES (1, ?, datetime('now'))`,\n args: [\"Hansen event 2 begins aug 7. Solar eclipse aug 12 (ionospheric disruption, Merriman CRD=top). North node bottom aug 18-21. Deploy aug 28-31 (lunar eclipse + Jupiter-Saturn trine). Oulu NM falling — solar activity increasing. Kp=4 recovery phase (jul 14-15). VIX at 15.82, near YTD lows. AAII bearish >50% for 10 consecutive weeks. Rotation from AI into biotech/small caps ongoing. SMH puking while SPY near highs.\"],\n });\n}\nawait initDB();\nawait seedData();\n// ── Router ──────────────────────────────────────────────────────────\nexport default async function handler(req) {\n const url = new URL(req.url);\n const path = url.pathname;\n\n if (path.match(/^\\/api\\/reasoning\\/[A-Z$]+$/))\n return getReasoning(path);\n if (path === \"/api/reasoning\" && req.method === \"POST\")\n return upsertReasoning(req);\n if (path === \"/api/positions\" && req.method === \"GET\")\n return getPositions();\n if (path === \"/api/positions\" && req.method === \"POST\")\n return updatePositions(req);\n if (path === \"/api/watchlist\" && req.method === \"GET\")\n return getWatchlist();\n if (path === \"/api/watchlist\" && req.method === \"POST\")\n return addToWatchlist(req);\n if (path.match(/^\\/api\\/watchlist\\/[A-Z]+$/) && req.method === \"DELETE\")\n return removeFromWatchlist(path);\n if (path === \"/api/thesis\" && req.method === \"GET\")\n return getThesis();\n if (path === \"/api/thesis\" && req.method === \"POST\")\n return updateThesis(req);\n if (path === \"/api/snapshots\" && req.method === \"GET\")\n return getSnapshots();\n if (path === \"/api/snapshot\" && req.method === \"POST\")\n return createSnapshot(req);\n if (path === \"/api/theses\" && req.method === \"GET\")\n return getTheses();\n if (path.match(/^\\/api\\/theses\\/[A-Z$]+$/))\n return getThesisByTicker(path);\n if (path === \"/api/theses\" && req.method === \"POST\")\n return upsertThesis(req);\n if (path === \"/api/philosophy\" && req.method === \"GET\")\n return getPhilosophy();\n if (path === \"/api/philosophy\" && req.method === \"POST\")\n return updatePhilosophy(req);\n if (path === \"/api/prices\" && req.method === \"POST\")\n return updatePrices(req);\n if (path === \"/api/prices\")\n return getPrices(req);\n if (path.startsWith(\"/api/\"))\n return Response.json({ error: \"Not found\" }, { status: 404 });\n return new Response(getDashboardHTML(), {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}\n// ── Reasoning API ───────────────────────────────────────────────────\nasync function getReasoning(path) {\n const ticker = path.split(\"/\").pop();\n const result = await sqlite.execute({ sql: \"SELECT * FROM reasoning WHERE ticker = ?\", args: [ticker] });\n if (!result.rows.length)\n return Response.json({ ticker, reasoning: \"\", found: false });\n return Response.json(result.rows[0]);\n}\nasync function upsertReasoning(req) {\n const body = await req.json();\n const ticker = body.ticker.toUpperCase();\n const newReasoning = body.reasoning;\n const replace = body.replace === true;\n let merged;\n if (replace) {\n merged = newReasoning;\n }\n else {\n const existing = await sqlite.execute({ sql: \"SELECT reasoning FROM reasoning WHERE ticker = ?\", args: [ticker] });\n if (existing.rows.length && existing.rows[0].reasoning) {\n const oldText = existing.rows[0].reasoning;\n merged = oldText.includes(newReasoning) ? oldText : oldText + \" | \" + newReasoning;\n }\n else {\n merged = newReasoning;\n }\n }\n await sqlite.execute({ sql: `INSERT OR REPLACE INTO reasoning (ticker, reasoning, updated_at) VALUES (?, ?, datetime('now'))`, args: [ticker, merged] });\n return Response.json({ success: true, ticker, reasoning: merged });\n}\n// ── Positions API ───────────────────────────────────────────────────\nasync function getPositions() {\n const result = await sqlite.execute(\"SELECT * FROM real_positions ORDER BY account, ticker\");\n return Response.json(result.rows);\n}\nasync function updatePositions(req) {\n const body = await req.json();\n const account = String(body.account || \"BFF\").toUpperCase();\n const positions = Array.isArray(body.positions) ? body.positions : [];\n await sqlite.execute({ sql: \"DELETE FROM real_positions WHERE account = ?\", args: [account] });\n for (const p of positions) {\n const ticker = String(p.ticker || \"\").toUpperCase();\n const qty = Number(p.qty);\n const avg = Number(p.avg_price);\n if (!ticker || !Number.isFinite(qty) || !Number.isFinite(avg) || qty < 0 || avg <= 0) continue;\n await sqlite.execute({\n sql: \"INSERT INTO real_positions (account, ticker, qty, avg_price) VALUES (?, ?, ?, ?)\",\n args: [account, ticker, qty, avg],\n });\n }\n return Response.json({ success: true, account, count: positions.length });\n}\n// ── Watchlist API ───────────────────────────────────────────────────\nasync function getWatchlist() {\n const result = await sqlite.execute(\"SELECT * FROM watchlist ORDER BY added_date DESC\");\n return Response.json(result.rows);\n}\nasync function addToWatchlist(req) {\n const body = await req.json();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO watchlist (ticker, reasoning, added_date) VALUES (?, ?, datetime('now'))\", args: [body.ticker.toUpperCase(), body.reasoning || \"\"] });\n return Response.json({ success: true });\n}\nasync function removeFromWatchlist(path) {\n const ticker = path.split(\"/\").pop();\n await sqlite.execute({ sql: \"DELETE FROM watchlist WHERE ticker = ?\", args: [ticker] });\n return Response.json({ success: true });\n}\n// ── Thesis API ──────────────────────────────────────────────────────\nasync function getThesis() {\n const result = await sqlite.execute(\"SELECT * FROM market_thesis WHERE id = 1\");\n return Response.json(result.rows[0] || { thesis: \"\" });\n}\nasync function updateThesis(req) {\n const body = await req.json();\n await sqlite.execute({ sql: `INSERT OR REPLACE INTO market_thesis (id, thesis, updated_at) VALUES (1, ?, datetime('now'))`, args: [body.thesis] });\n return Response.json({ success: true });\n}\n// ── Longform Theses API ─────────────────────────────────────────────\nasync function getTheses() {\n const result = await sqlite.execute(\"SELECT ticker, longform, updated_at FROM theses ORDER BY ticker\");\n return Response.json(result.rows);\n}\nasync function getThesisByTicker(path) {\n const ticker = path.split(\"/\").pop();\n const result = await sqlite.execute({ sql: \"SELECT ticker, longform, updated_at FROM theses WHERE ticker = ?\", args: [ticker] });\n if (!result.rows.length)\n return Response.json({ ticker, longform: \"\", found: false });\n return Response.json(result.rows[0]);\n}\nasync function upsertThesis(req) {\n const body = await req.json();\n await sqlite.execute({ sql: `INSERT OR REPLACE INTO theses (ticker, longform, updated_at) VALUES (?, ?, datetime('now'))`, args: [body.ticker.toUpperCase(), body.longform] });\n return Response.json({ success: true });\n}\n// ── Philosophy API ──────────────────────────────────────────────────\nasync function getPhilosophy() {\n const result = await sqlite.execute(\"SELECT * FROM philosophy WHERE id = 1\");\n return Response.json(result.rows[0] || { longform: \"\" });\n}\nasync function updatePhilosophy(req) {\n const body = await req.json();\n await sqlite.execute({ sql: `INSERT OR REPLACE INTO philosophy (id, longform, updated_at) VALUES (1, ?, datetime('now'))`, args: [body.longform] });\n return Response.json({ success: true });\n}\n// ── Snapshots API ───────────────────────────────────────────────\nasync function getSnapshots() {\n const result = await sqlite.execute(\"SELECT id, date, bff_pnl_pct, created_at FROM portfolio_snapshots ORDER BY date ASC\");\n return Response.json(result.rows.map(r => ({ id: Number(r.id), date: r.date, bff_pnl_pct: Number(r.bff_pnl_pct), created_at: r.created_at })));\n}\nasync function createSnapshot(req) {\n const body = await req.json();\n const date = body.date || new Date().toISOString().split(\"T\")[0];\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO portfolio_snapshots (date, paper_pnl_pct, bff_pnl_pct) VALUES (?, 0, ?)\", args: [date, body.bff_pnl_pct || 0] });\n return Response.json({ success: true, date });\n}\n// ── Prices API (from DB, updated by cron) ──────────────────────\nasync function getPrices(req) {\n const result = await sqlite.execute(\"SELECT ticker, price FROM current_prices\");\n const prices = {};\n result.rows.forEach(r => { prices[r.ticker] = Number(r.price); });\n return Response.json(prices);\n}\nasync function updatePrices(req) {\n const body = await req.json();\n const prices = body.prices || body;\n if (body.replace === true) {\n const keep = Object.keys(prices).map(t => t.toUpperCase());\n const existing = await sqlite.execute(`SELECT ticker FROM current_prices`);\n for (const row of existing.rows) {\n if (!keep.includes(row.ticker))\n await sqlite.execute({ sql: `DELETE FROM current_prices WHERE ticker = ?`, args: [row.ticker] });\n }\n }\n for (const [ticker, price] of Object.entries(prices)) {\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO current_prices (ticker, price, updated_at) VALUES (?, ?, datetime('now'))\", args: [ticker.toUpperCase(), Number(price)]\n });\n }\n return Response.json({ success: true, count: Object.keys(prices).length });\n}\n// ── Dashboard HTML ──────────────────────────────────────────────────\nfunction getDashboardHTML() {\n const jsCode = `(function(){\n var ds=document.getElementById('ds');\n var sgTop=document.getElementById('sunglare-top');\n var sgBot=document.getElementById('sunglare-bottom');\n var clouds=document.querySelectorAll('.cloud');\n document.addEventListener('mousemove',function(e){\n if(ds){var r=ds.getBoundingClientRect();var cx=r.left+r.width/2;var cy=r.top+r.height/2;var dx=(e.clientX-cx)/(r.width/2);var dy=(e.clientY-cy)/(r.height/2);ds.style.transform='rotateY('+(dx*4)+'deg) rotateX('+(-dy*4)+'deg)';}\n [sgTop,sgBot].forEach(function(s){if(s){var p=s.parentElement.getBoundingClientRect();s.style.setProperty('--mx',((e.clientX-p.left)/p.width)*100+'%');s.style.setProperty('--my',((e.clientY-p.top)/p.height)*100+'%');}});\n var mx=(e.clientX/window.innerWidth-0.5)*2;var my=(e.clientY/window.innerHeight-0.5)*2;\n clouds.forEach(function(c,i){var d=(i+1)*8;c.style.transform='translate('+(-mx*d)+'px,'+(-my*d)+'px)';});\n });\n })();\n (function(){\n var bffP=[];\n var prices={};var lfT={};\n function fp2(v){return(v>=0?'+':'')+v.toFixed(2)+'%'}\n function gp(t,e){return prices[t]||e}\n function fmtQty(q){if(q===Math.floor(q))return q.toFixed(0);return q<1?q.toFixed(4):q.toFixed(2)}\n function fetchPrices(){return fetch('/api/prices').then(function(r){return r.json()}).then(function(d){prices=d||{}}).catch(function(){})}\n function flt(){return fetch('/api/theses').then(function(r){return r.json()}).then(function(d){if(Array.isArray(d))d.forEach(function(t){lfT[t.ticker]=t.longform})}).catch(function(){})}\n function fph(){return fetch('/api/philosophy').then(function(r){return r.json()}).then(function(d){if(d&&d.longform){var b=document.getElementById('phil-box');var ss=d.longform.split('\\\\n\\\\n');var h='';ss.forEach(function(s){var ci=s.indexOf(':');if(ci>0&&ci<80){h+='

'+s.substring(0,ci)+':

'+s.substring(ci+1).trim()+'

'}else{h+='

'+s+'

'}});b.innerHTML=h}}).catch(function(){})}\n function ft(){return fetch('/api/thesis').then(function(r){return r.json()}).then(function(d){if(d&&d.thesis){var items=d.thesis.split(/\\\\n+/).filter(function(s){return s.trim()});var u='

'+s.trim()+'

';document.getElementById('thesis-box').innerHTML=u}}).catch(function(){})}\n function fetchBffPositions(){return fetch('/api/positions').then(function(r){return r.json()}).then(function(rows){bffP=rows.filter(function(r){return r.account==='BFF'}).map(function(r){return{t:r.ticker,q:Number(r.qty)||0,e:Number(r.avg_price)||0,s:'BFF'}})}).catch(function(){bffP=[]})}\n function bp(){\n var h='';var bBase=0;var bct=0;\n for(var i=0;i0?(p.q*p.e)/bBase*100:0;var pp=(cp-p.e)/p.e*100;var pc=pp>=0?'pnl-pos':'pnl-neg';h+=''+p.t+''+p.s+''+fmtQty(p.q)+' @ '+p.e.toFixed(2)+''+w.toFixed(1)+'%'+fp2(pp)+'';}\n }\n document.getElementById('port-body').innerHTML=h||'no positions';\n var bpn=bBase>0?((bct-bBase)/bBase*100):0;\n document.getElementById('sum-bff').textContent='BFF LIVE '+fp2(bpn);\n }\n function lc(){fetch('/api/snapshots').then(function(r){return r.json()}).then(function(ss){if(!ss.length)ss=[{date:'2026-07-16',bff_pnl_pct:0}];var labels=ss.map(function(s){return s.date});var bd=ss.map(function(s){return s.bff_pnl_pct});var ctx=document.getElementById('perf-chart').getContext('2d');new Chart(ctx,{type:'line',data:{labels:labels,datasets:[{label:'BFF live',data:bd,borderColor:'#cc6600',backgroundColor:'rgba(204,102,0,0.1)',borderWidth:2,tension:0.3,fill:false,pointRadius:3,pointBackgroundColor:'#cc6600'}]},options:{responsive:true,maintainAspectRatio:false,plugins:{legend:{display:false},tooltip:{backgroundColor:'#9a9a82',titleColor:'#2a2a2a',bodyColor:'#444',borderColor:'#666',borderWidth:1}},scales:{x:{ticks:{color:'#555',font:{family:\"'Press Start 2P',monospace\",size:5},maxRotation:45},grid:{color:'rgba(154,154,130,0.5)'}},y:{ticks:{color:'#555',font:{family:\"'Press Start 2P',monospace\",size:5},callback:function(v){return v+'%'}},grid:{color:'rgba(154,154,130,0.5)'}}}}})}).catch(function(e){console.error('Chart error:',e)})}\n Promise.all([fetchBffPositions(),fetchPrices(),flt(),fph(),ft()]).then(bp);\n lc();\n })();`;\n return `\n\n\n\n\nB2-1 DASHBOARD\n\n

Diff · v96