[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_162":163,"_164":165},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_86":-7,"_87":88,"_29":-7,"_89":-5,"_15":90,"_91":92,"_93":94,"_95":96,"_97":98,"_99":-5,"_100":-5,"_101":-5,"_102":38,"_103":104,"_105":106,"_107":-5,"_108":-5,"_109":110},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","infinarscientiacloud","name","Quinn-AI","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":38,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":59,"_60":59,"_61":62,"_63":62,"_64":62,"_65":59,"_66":59,"_67":68,"_69":70,"_71":72,"_73":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","a55c5366-3689-11f1-ba83-42b51c65c3df","createdAt",["D",1776010023790],"updatedAt",["D",1783684738419],"main","projectId","a55ba98e-3689-11f1-ba83-42b51c65c3df","version",25,"forkedBranchId","forkedBranchVersion","lockfileKey","1783684739195-esm.town_v_infinarscientiacloud_Quinn-AI@25-main","deletedAt",["D",1776010023785],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","61537aff-745c-45d8-8e13-c99e165fb31a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d8271-e53c-751a-8a25-767506d4c4fb","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_85":81},"org",{"_11":12,"_79":-5,"_80":81,"_44":45,"_82":83,"_84":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_74":-5,"_75":-5,"_76":-5,"_77":14,"_78":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://avatars.githubusercontent.com/u/275509936?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":158,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":38,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":59,"_60":59,"_61":62,"_63":62,"_64":62,"_65":59,"_66":59,"_67":159,"_69":160,"_71":161,"_73":38},"tree",[149,150],"files",[149,150],"counts",{"_138":51,"_17":139,"_140":51,"_141":142,"_143":144},"contents",[111,112],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":130,"_13":131,"_115":132,"_117":-5,"_118":21,"_119":133,"_120":106,"_22":134,"_29":135,"_123":124,"_125":136,"_127":38,"_128":-5,"_87":137},{"_20":113,"_13":114,"_115":116,"_117":-5,"_118":21,"_119":30,"_120":106,"_22":121,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_87":129},"13e6d835-fb6c-49c9-a828-cef91d6e862d","Quinn-v3-backend.ts","fileId","a55e920c-3689-11f1-ba83-42b51c65c3df","parentId","branchId","branchVersion","latest",["D",1783684738419],20,"fileType","http","content","// ============================================================\n// QUINN v4 — Autonomous Quant Trading Agent\n// Val Town Backend\n//\n// Fixed in v4:\n// ✓ analyzeStock symbol undefined crash fixed\n// ✓ Yahoo Finance quote fallback (Alpaca data API unreliable)\n// ✓ ADV fallback table for all watchlist stocks\n// ✓ Friction formula fixed (uses stock price not option price)\n// ✓ Sentiment threshold 0.0 (neutral = ok)\n// ✓ Confidence formula rebalanced\n// ✓ Model aggressive trade instruction — no passive \"no further action\"\n// ✓ Market hours check correct for ET (UTC-4 EDT / UTC-5 EST)\n// ✓ All safety gates preserved\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nexport default async function (req: Request) {\n const headers = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n };\n\n if (req.method === \"OPTIONS\") return new Response(null, { headers });\n if (req.method !== \"POST\") {\n return new Response(JSON.stringify({ status: \"QUINN v4 online\" }), {\n headers: { ...headers, \"Content-Type\": \"application/json\" },\n });\n }\n\n // ── ENV ──────────────────────────────────────────────────\n const OPENROUTER_KEY = Deno.env.get(\"OPENROUTER_KEY\");\n const TAVILY_KEY = Deno.env.get(\"TAVILY_KEY\");\n const ALPACA_KEY = Deno.env.get(\"ALPACA_KEY\");\n const ALPACA_SECRET = Deno.env.get(\"ALPACA_SECRET\");\n const ALPACA_BASE = Deno.env.get(\"ALPACA_LIVE\") === \"true\"\n ? \"https://api.alpaca.markets\"\n : \"https://paper-api.alpaca.markets\";\n const QUINN_MODEL = \"openrouter/free\";\n\n if (!OPENROUTER_KEY) {\n return Response.json({ error: \"OPENROUTER_KEY missing.\" }, { headers });\n }\n\n // ── MARKET HOURS (ET) ─────────────────────────────────────\n // NYSE: 9:30am–4:00pm ET\n // EDT = UTC-4 (Mar–Nov), EST = UTC-5 (Nov–Mar)\n function isMarketOpen(): boolean {\n const now = new Date();\n const day = now.getUTCDay(); // 0=Sun 6=Sat\n if (day === 0 || day === 6) return false;\n // Use UTC-4 (EDT) — adjust to -5 in winter manually if needed\n const etHour = now.getUTCHours() - 4;\n const etMin = etHour * 60 + now.getUTCMinutes();\n return etMin >= 570 && etMin <= 960; // 9:30am=570 4:00pm=960\n }\n\n // ── DB ───────────────────────────────────────────────────\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS quinn_trades (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT, side TEXT, qty REAL,\n entry_price REAL, exit_price REAL, reason TEXT,\n sentiment REAL, mc_prob REAL, friction_pct REAL,\n adv INTEGER, bs_price REAL, confidence_score INTEGER,\n status TEXT DEFAULT 'pending', alpaca_id TEXT,\n pnl REAL, pnl_vs_theoretical REAL,\n postmortem TEXT, postmortem_signals TEXT,\n is_day_trade INTEGER DEFAULT 0,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n closed_at DATETIME\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS quinn_watchlist (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT UNIQUE, added_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS quinn_settings (\n key TEXT PRIMARY KEY, value TEXT,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS quinn_memory (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n key TEXT UNIQUE, content TEXT,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )`);\n\n // Seed defaults\n const defaults: [string, string][] = [\n [\"max_position_usd\", \"10\"],\n [\"min_confidence_score\", \"40\"],\n [\"min_sentiment\", \"0.0\"],\n [\"max_friction_pct\", \"0.80\"],\n [\"min_adv\", \"1000000\"],\n [\"autonomous_mode\", \"true\"],\n [\"circuit_breaker_pct\", \"0.20\"],\n [\"circuit_breaker_window_days\", \"3\"],\n [\"circuit_breaker_triggered\", \"false\"],\n [\"meta_learner_min_trades\", \"20\"],\n [\"max_day_trades_5d\", \"3\"],\n [\"swing_mode\", \"true\"],\n ];\n for (const [k, v] of defaults) {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO quinn_settings (key, value) VALUES (?, ?)`,\n args: [k, v],\n });\n }\n await sqlite.execute(`INSERT OR IGNORE INTO quinn_watchlist (symbol) VALUES\n ('AAPL'),('NVDA'),('TSLA'),('MSFT'),('SPY'),('META'),('AMD'),('AMZN')`);\n\n async function loadSettings(): Promise> {\n const res = await sqlite.execute(`SELECT key, value FROM quinn_settings`);\n const cfg: Record = {};\n res.rows.forEach((r: any) => { cfg[r[0]] = r[1]; });\n return cfg;\n }\n\n // ── MATH ENGINE ──────────────────────────────────────────\n function normCDF(x: number): number {\n const a = [0.254829592,-0.284496736,1.421413741,-1.453152027,1.061405429];\n const p = 0.3275911;\n const sign = x < 0 ? -1 : 1;\n x = Math.abs(x) / Math.SQRT2;\n const t = 1 / (1 + p * x);\n const y = 1 - (((((a[4]*t+a[3])*t)+a[2])*t+a[1])*t+a[0])*t*Math.exp(-x*x);\n return 0.5 * (1 + sign * y);\n }\n function normPDF(x: number): number {\n return Math.exp(-0.5*x*x) / Math.sqrt(2*Math.PI);\n }\n\n function bsCalc(type: \"call\"|\"put\", S: number, K: number, T: number, r: number, sig: number) {\n if (S <= 0 || K <= 0 || sig <= 0 || T <= 0) {\n return { price:0, delta:0, gamma:0, vega:0, theta:0 };\n }\n const sqT=Math.sqrt(T);\n const erT=Math.exp(-r*T);\n const d1=(Math.log(S/K)+(r+0.5*sig*sig)*T)/(sig*sqT);\n const d2=d1-sig*sqT;\n let price: number, delta: number;\n if (type===\"call\") {\n price=S*normCDF(d1)-K*erT*normCDF(d2);\n delta=normCDF(d1);\n } else {\n price=K*erT*normCDF(-d2)-S*normCDF(-d1);\n delta=-normCDF(-d1);\n }\n const gamma=normPDF(d1)/(S*sig*sqT);\n const vega=S*normPDF(d1)*sqT/100;\n const theta=type===\"call\"\n ? (-S*normPDF(d1)*sig/(2*sqT)-r*K*erT*normCDF(d2))/365\n : (-S*normPDF(d1)*sig/(2*sqT)+r*K*erT*normCDF(-d2))/365;\n return { price:Math.max(0,price), delta, gamma, vega, theta };\n }\n\n function monteCarloEdge(S: number, K: number, T: number, r: number, sig: number, paths=2000) {\n if (S<=0||sig<=0) return { callFV:0, putFV:0, probProfit:0.5 };\n let callSum=0, putSum=0, profitCount=0;\n for (let i=0; iS) profitCount++;\n }\n const disc=Math.exp(-r*T);\n return {\n callFV:(callSum/paths)*disc,\n putFV:(putSum/paths)*disc,\n probProfit:profitCount/paths,\n };\n }\n\n // Confidence 0-100. Rebalanced so neutral conditions give ~50.\n function calcConfidence(\n sentiment: number, mcProb: number,\n frictionPct: number, isLiquid: boolean\n ): number {\n // Sentiment: -1=0pts, 0=12.5pts, +1=25pts\n const sentScore = Math.min(25, Math.max(0, (sentiment+1)*12.5));\n // MC: 0%=0pts, 50%=12.5pts, 100%=25pts\n const mcScore = Math.min(25, Math.max(0, mcProb*25));\n // Friction: 0%=25pts, 80%=0pts\n const frictScore = Math.min(25, Math.max(0, (1-Math.min(frictionPct,1))*25));\n // Liquidity: yes=25pts\n const liqScore = isLiquid ? 25 : 0;\n return Math.round(sentScore+mcScore+frictScore+liqScore);\n }\n\n // ── ALPACA HELPERS ───────────────────────────────────────\n const brokerH: Record = ALPACA_KEY ? {\n \"APCA-API-KEY-ID\": ALPACA_KEY,\n \"APCA-API-SECRET-KEY\": ALPACA_SECRET||\"\",\n \"Content-Type\": \"application/json\",\n } : {};\n const dataH: Record = ALPACA_KEY ? {\n \"APCA-API-KEY-ID\": ALPACA_KEY,\n \"APCA-API-SECRET-KEY\": ALPACA_SECRET||\"\",\n } : {};\n\n async function alpacaBroker(path: string): Promise {\n if (!ALPACA_KEY) return null;\n try {\n const r = await fetch(`${ALPACA_BASE}${path}`, { headers: brokerH });\n if (!r.ok) return null;\n return await r.json();\n } catch { return null; }\n }\n\n async function getAlpacaAccount(): Promise { return alpacaBroker(\"/v2/account\"); }\n async function getAlpacaPositions(): Promise { return (await alpacaBroker(\"/v2/positions\"))||[]; }\n async function getAlpacaOrders(status=\"all\", limit=50): Promise {\n return (await alpacaBroker(`/v2/orders?status=${status}&limit=${limit}`))||[];\n }\n async function getAvailableCash(): Promise {\n const a = await getAlpacaAccount();\n return parseFloat(a?.non_marginable_buying_power||\"0\");\n }\n\n // ── LIVE QUOTE — Alpaca first, Yahoo fallback ─────────────\n async function getQuote(symbol: string): Promise<{\n price:number; bid:number; ask:number; spread:number; source:string;\n }|null> {\n if (!symbol) return null;\n\n // Try Alpaca data API\n if (ALPACA_KEY) {\n try {\n const r = await fetch(\n `https://data.alpaca.markets/v2/stocks/${encodeURIComponent(symbol)}/quotes/latest`,\n { headers: dataH }\n );\n if (r.ok) {\n const d = await r.json();\n const q = d.quote;\n if (q) {\n const bid = parseFloat(q.bp)||0;\n const ask = parseFloat(q.ap)||0;\n const price = ask>0&&bid>0 ? (ask+bid)/2 : ask||bid;\n if (price>0) {\n return { price, bid, ask, spread:Math.max(0,ask-bid), source:\"alpaca\" };\n }\n }\n }\n } catch { /* fall through */ }\n }\n\n // Yahoo Finance fallback\n try {\n const r = await fetch(\n `https://query1.finance.yahoo.com/v8/finance/chart/${encodeURIComponent(symbol)}?interval=1m&range=1d`,\n { headers: { \"User-Agent\":\"Mozilla/5.0 (compatible)\" } }\n );\n if (r.ok) {\n const d = await r.json();\n const meta = d?.chart?.result?.[0]?.meta;\n const price = meta?.regularMarketPrice || meta?.previousClose || meta?.chartPreviousClose;\n if (price && price > 0) {\n const spread = price * 0.001;\n return { price:+price, bid:price-spread/2, ask:price+spread/2, spread, source:\"yahoo\" };\n }\n }\n } catch { /* give up */ }\n\n return null;\n }\n\n // ── LIQUIDITY — Alpaca bars + hardcoded fallback ──────────\n // Known average daily volumes for major US stocks\n const KNOWN_ADV: Record = {\n SPY:80000000, QQQ:50000000, IWM:30000000,\n AAPL:55000000, MSFT:22000000, NVDA:45000000,\n TSLA:80000000, META:18000000, AMZN:35000000,\n AMD:50000000, GOOGL:25000000, GOOG:20000000,\n NFLX:8000000, BABA:12000000, COIN:15000000,\n };\n\n async function checkLiquidity(symbol: string, targetQty: number): Promise<{\n is_liquid:boolean; avg_10d_volume:number; reason:string;\n }> {\n if (!symbol) return { is_liquid:false, avg_10d_volume:0, reason:\"No symbol\" };\n const cfg = await loadSettings();\n const minAdv = parseInt(cfg.min_adv||\"1000000\");\n const sym = symbol.toUpperCase();\n\n // Try Alpaca bars\n if (ALPACA_KEY) {\n try {\n const r = await fetch(\n `https://data.alpaca.markets/v2/stocks/${encodeURIComponent(sym)}/bars?timeframe=1Day&limit=10`,\n { headers: dataH }\n );\n if (r.ok) {\n const d = await r.json();\n let bars: any[] = [];\n if (Array.isArray(d.bars)) bars = d.bars;\n else if (d.bars?.[sym]) bars = d.bars[sym];\n if (bars.length >= 3) {\n const adv = bars.reduce((s:number,b:any)=>s+(b.v||0),0)/bars.length;\n if (adv > 0) {\n return {\n is_liquid: adv>=minAdv,\n avg_10d_volume: Math.round(adv),\n reason: adv>=minAdv\n ? `ADV ${Math.round(adv/1e6).toFixed(1)}M ≥ ${(minAdv/1e6).toFixed(0)}M floor`\n : `ADV ${Math.round(adv/1e6).toFixed(1)}M below ${(minAdv/1e6).toFixed(0)}M floor`,\n };\n }\n }\n }\n } catch { /* fall through */ }\n }\n\n // Hardcoded fallback\n const adv = KNOWN_ADV[sym];\n if (adv) {\n return {\n is_liquid: adv>=minAdv,\n avg_10d_volume: adv,\n reason: `ADV ~${Math.round(adv/1e6).toFixed(0)}M (known estimate)`,\n };\n }\n\n // Unknown — assume liquid so it doesn't block\n return { is_liquid:true, avg_10d_volume:minAdv, reason:\"ADV unknown — assumed liquid\" };\n }\n\n // ── WEB SEARCH ───────────────────────────────────────────\n async function searchWeb(query: string): Promise {\n if (!TAVILY_KEY) return \"[]\";\n try {\n const r = await fetch(\"https://api.tavily.com/search\", {\n method:\"POST\",\n headers:{\"Content-Type\":\"application/json\"},\n body:JSON.stringify({ api_key:TAVILY_KEY, query, search_depth:\"basic\", max_results:5 }),\n });\n const d = await r.json();\n if (!d.results) return \"[]\";\n return JSON.stringify(d.results.map((r:any)=>({\n title:r.title,\n content:(r.content||\"\").substring(0,400),\n })));\n } catch { return \"[]\"; }\n }\n\n // ── SENTIMENT ────────────────────────────────────────────\n function scoreSentiment(raw: string): number {\n try {\n const parsed = JSON.parse(raw);\n if (!parsed.length) return 0;\n const text = parsed.map((r:any)=>(r.title||\"\")+\" \"+(r.content||\"\")).join(\" \").toLowerCase();\n const bull = (text.match(/beat|exceed|surpass|surge|rally|jump|climb|rise|gain|upgrade|outperform|strong|record|growth|bullish|launch|profit|dividend|revenue|positive|recovery|rebound|milestone|breakthrough|buy|upside/g)||[]).length;\n const bear = (text.match(/miss|disappoint|drop|fall|decline|crash|plunge|sink|downgrade|underperform|weak|loss|bearish|lawsuit|investigation|fraud|warning|cut|layoff|bankrupt|risk|probe|scandal|sell|downside|recall/g)||[]).length;\n const total = bull+bear;\n if (total===0) return 0;\n return Math.max(-1, Math.min(1, (bull-bear)/total));\n } catch { return 0; }\n }\n\n // ── FULL STOCK ANALYSIS ──────────────────────────────────\n async function analyzeStock(symbol: string, volInput?: number): Promise {\n // Guard — fixes the undefined crash\n if (!symbol || typeof symbol !== \"string\") {\n return JSON.stringify({\n symbol:\"UNKNOWN\", verdict:\"HOLD\", confidence:0,\n error:\"No symbol provided\", blockers:[\"Symbol missing\"],\n signals:{ sentiment:0, mcProb:0, frictionPct:0, bsPrice:0, adv:0, confScore:0 },\n });\n }\n symbol = symbol.trim().toUpperCase();\n\n const cfg = await loadSettings();\n\n // 1. Live quote\n const quote = await getQuote(symbol);\n if (!quote || quote.price <= 0) {\n return JSON.stringify({\n symbol, verdict:\"HOLD\", confidence:0,\n error:\"Cannot fetch price\",\n price:0, blockers:[\"Live price unavailable\"],\n signals:{ sentiment:0, mcProb:0, frictionPct:0, bsPrice:0, adv:0, confScore:0 },\n });\n }\n const S = quote.price;\n const spread = quote.spread;\n\n // 2. Sentiment\n const rawNews = await searchWeb(`${symbol} stock news today`);\n const sentiment = scoreSentiment(rawNews);\n\n // 3. Math\n const sig = volInput || 0.25;\n const T = 30/365;\n const r = 0.053;\n const K = S;\n const bs = bsCalc(\"call\", S, K, T, r, sig);\n const mc = monteCarloEdge(S, K, T, r, sig, 2000);\n\n // 4. Friction — as % of stock price (not option price)\n const commEst = 0.65;\n const totalCost = (commEst + spread/2) * 3;\n const frictPct = S > 0 ? Math.max(0, totalCost/S) : 1;\n\n // 5. Liquidity\n const maxPos = parseFloat(cfg.max_position_usd||\"10\");\n const suggestedQ = Math.max(1, Math.floor(maxPos/S));\n const liq = await checkLiquidity(symbol, suggestedQ);\n\n // 6. Confidence\n const conf = calcConfidence(sentiment, mc.probProfit, frictPct, liq.is_liquid);\n const minConf = parseInt(cfg.min_confidence_score||\"40\");\n const minSent = parseFloat(cfg.min_sentiment||\"0.0\");\n const maxFrict= parseFloat(cfg.max_friction_pct||\"0.80\");\n\n const blockers: string[] = [];\n if (sentiment < minSent) blockers.push(`sentiment ${sentiment.toFixed(2)} < ${minSent} (negative news)`);\n if (frictPct > maxFrict) blockers.push(`friction ${(frictPct*100).toFixed(2)}% > ${(maxFrict*100).toFixed(0)}%`);\n if (!liq.is_liquid) blockers.push(liq.reason);\n if (conf < minConf) blockers.push(`confidence ${conf} < ${minConf}`);\n\n const verdict = blockers.length === 0 ? \"BUY\" : \"HOLD\";\n\n return JSON.stringify({\n symbol, verdict, confidence:conf,\n price:+S.toFixed(2), spread:+spread.toFixed(4),\n quoteSource:quote.source,\n sentiment:+sentiment.toFixed(3),\n bsCallPrice:+bs.price.toFixed(4),\n bsDelta:+bs.delta.toFixed(4),\n bsGamma:+bs.gamma.toFixed(6),\n bsVega:+bs.vega.toFixed(4),\n bsTheta:+bs.theta.toFixed(4),\n mcCallFV:+mc.callFV.toFixed(4),\n probProfit:+mc.probProfit.toFixed(3),\n frictionPct:+frictPct.toFixed(4),\n adv:liq.avg_10d_volume,\n liquidityOk:liq.is_liquid,\n suggestedQty:suggestedQ,\n blockers,\n signals:{\n sentiment, mcProb:mc.probProfit,\n frictionPct, bsPrice:bs.price,\n adv:liq.avg_10d_volume, confScore:conf,\n },\n });\n }\n\n // ── SCAN WATCHLIST ───────────────────────────────────────\n async function scanWatchlist(): Promise {\n const wl = await sqlite.execute(`SELECT symbol FROM quinn_watchlist`);\n const out = [];\n for (const row of wl.rows) {\n const sym = String(row[0]||\"\").trim();\n if (!sym) continue;\n try { out.push(JSON.parse(await analyzeStock(sym))); } catch { /* skip */ }\n await new Promise(r=>setTimeout(r,1200));\n }\n out.sort((a,b)=>{\n if (a.verdict===\"BUY\"&&b.verdict!==\"BUY\") return -1;\n if (b.verdict===\"BUY\"&&a.verdict!==\"BUY\") return 1;\n return b.confidence-a.confidence;\n });\n return JSON.stringify(out);\n }\n\n // ── PDT GUARD ────────────────────────────────────────────\n async function checkPDT(): Promise<{ok:boolean;dayTradeCount:number;limit:number}> {\n try {\n const cfg = await loadSettings();\n const limit = parseInt(cfg.max_day_trades_5d||\"3\");\n const swing = cfg.swing_mode===\"true\";\n const cutoff = new Date(Date.now()-5*24*60*60*1000).toISOString();\n const res = await sqlite.execute({\n sql:`SELECT id FROM quinn_trades WHERE is_day_trade=1 AND created_at>? AND status='closed'`,\n args:[cutoff],\n });\n return { ok:swing||res.rows.length {\n try {\n const cfg = await loadSettings();\n if (cfg.circuit_breaker_triggered===\"true\") {\n return { tripped:true, reason:\"Previously tripped. Reset circuit_breaker_triggered=false to resume.\", loss3d:0 };\n }\n const windowDays = parseInt(cfg.circuit_breaker_window_days||\"3\");\n const limitPct = parseFloat(cfg.circuit_breaker_pct||\"0.20\");\n const cutoff = new Date(Date.now()-windowDays*24*60*60*1000).toISOString();\n const lossRes = await sqlite.execute({\n sql:`SELECT COALESCE(SUM(pnl),0) FROM quinn_trades WHERE closed_at>? AND status='closed' AND pnl<0`,\n args:[cutoff],\n });\n const loss3d = Math.abs(parseFloat(String(lossRes.rows[0]?.[0]||\"0\")));\n if (loss3d===0) return { tripped:false, reason:\"No recent losses.\", loss3d:0 };\n const acct = await getAlpacaAccount();\n const equity = parseFloat(acct?.equity||\"0\");\n if (equity<=0) return { tripped:false, reason:\"Cannot read equity.\", loss3d };\n const lossPct = loss3d/equity;\n if (lossPct>=limitPct) {\n await sqlite.execute({ sql:`INSERT OR REPLACE INTO quinn_settings (key,value,updated_at) VALUES ('circuit_breaker_triggered','true',CURRENT_TIMESTAMP)`,args:[] });\n await sqlite.execute({ sql:`INSERT OR REPLACE INTO quinn_settings (key,value,updated_at) VALUES ('autonomous_mode','false',CURRENT_TIMESTAMP)`,args:[] });\n await email({ subject:\"[QUINN] ⚠️ CIRCUIT BREAKER TRIPPED\", text:`3-day loss $${loss3d.toFixed(2)} = ${(lossPct*100).toFixed(1)}% of equity. Quinn halted. Set circuit_breaker_triggered=false to resume.` });\n return { tripped:true, reason:`${(lossPct*100).toFixed(1)}% loss breached limit.`, loss3d };\n }\n return { tripped:false, reason:`${(lossPct*100).toFixed(1)}% within limit.`, loss3d };\n } catch (e:any) { return { tripped:false, reason:`CB error: ${e.message}`, loss3d:0 }; }\n }\n\n // ── GHOST TRADES ─────────────────────────────────────────\n async function resolveGhostTrades(): Promise {\n if (!ALPACA_KEY) return \"No key.\";\n try {\n const orders = await getAlpacaOrders(\"filled\",50);\n let ghosts = 0;\n for (const o of orders) {\n const ex = await sqlite.execute({ sql:`SELECT id FROM quinn_trades WHERE alpaca_id=?`,args:[o.id] });\n if (!ex.rows.length&&o.status===\"filled\") {\n await sqlite.execute({\n sql:`INSERT INTO quinn_trades (symbol,side,qty,entry_price,status,alpaca_id,reason,confidence_score) VALUES (?,?,?,?,'open',?,'GHOST',0)`,\n args:[o.symbol,o.side,o.filled_qty,o.filled_avg_price,o.id],\n });\n ghosts++;\n }\n }\n return ghosts>0?`Recovered ${ghosts} ghost(s).`:\"No ghosts.\";\n } catch (e:any) { return `Ghost error: ${e.message}`; }\n }\n\n // ── FILL RECONCILIATION ──────────────────────────────────\n async function reconcileFills(): Promise {\n if (!ALPACA_KEY) return \"No key.\";\n try {\n const pending = await sqlite.execute(\n `SELECT id,alpaca_id,symbol,side,qty,entry_price,bs_price,sentiment,mc_prob,friction_pct,confidence_score\n FROM quinn_trades WHERE status IN ('submitted','pending') AND alpaca_id IS NOT NULL`\n );\n if (!pending.rows.length) return \"Nothing to reconcile.\";\n let done = 0;\n for (const row of pending.rows) {\n const [id,alpacaId,symbol,side,qty,entryPrice,bsPrice,sentiment,mcProb,frictionPct,confScore] = row as any[];\n try {\n const o = await alpacaBroker(`/v2/orders/${alpacaId}`);\n if (!o) continue;\n if (o.status===\"filled\") {\n const fp = parseFloat(o.filled_avg_price||\"0\");\n const fq = parseFloat(o.filled_qty||String(qty));\n if (side===\"buy\") {\n await sqlite.execute({ sql:`UPDATE quinn_trades SET status='open',entry_price=?,qty=? WHERE id=?`,args:[fp,fq,id] });\n } else if (side===\"sell\") {\n const open = await sqlite.execute({\n sql:`SELECT id,entry_price,qty FROM quinn_trades WHERE symbol=? AND side='buy' AND status='open' ORDER BY created_at ASC LIMIT 1`,\n args:[symbol],\n });\n if (open.rows.length) {\n const [oid,oe,oq] = open.rows[0] as any[];\n const pnl = (fp-parseFloat(String(oe)))*parseFloat(String(oq));\n const theorPnl = parseFloat(String(bsPrice||0))*parseFloat(String(oq));\n const note = pnl>0\n ? `WIN ${symbol} +$${pnl.toFixed(2)} conf=${confScore}`\n : `LOSS ${symbol} $${pnl.toFixed(2)} conf=${confScore} sent=${parseFloat(String(sentiment)).toFixed(2)}`;\n const buyDate = await sqlite.execute({ sql:`SELECT created_at FROM quinn_trades WHERE id=?`,args:[oid] });\n const isDT = new Date(String(buyDate.rows[0]?.[0]||\"\")).toDateString()===new Date().toDateString()?1:0;\n const signals = JSON.stringify({ entryPrice:oe,exitPrice:fp,sentiment,mcProb,frictionPct,bsPrice,confScore,actualPnl:pnl,theoreticalPnl:theorPnl });\n for (const cid of [id,oid]) {\n await sqlite.execute({\n sql:`UPDATE quinn_trades SET status='closed',exit_price=?,pnl=?,pnl_vs_theoretical=?,postmortem=?,postmortem_signals=?,is_day_trade=?,closed_at=CURRENT_TIMESTAMP WHERE id=?`,\n args:[fp,pnl,pnl-theorPnl,note,signals,isDT,cid],\n });\n }\n await sqlite.execute({ sql:`INSERT OR REPLACE INTO quinn_memory (key,content,updated_at) VALUES (?,?,CURRENT_TIMESTAMP)`,args:[`pm_${symbol}_${Date.now()}`,note] });\n } else {\n await sqlite.execute({ sql:`UPDATE quinn_trades SET status='closed',exit_price=?,closed_at=CURRENT_TIMESTAMP WHERE id=?`,args:[fp,id] });\n }\n }\n done++;\n } else if ([\"canceled\",\"expired\",\"rejected\"].includes(o.status)) {\n await sqlite.execute({ sql:`UPDATE quinn_trades SET status=? WHERE id=?`,args:[o.status,id] });\n }\n } catch { /* skip */ }\n }\n return `Reconciled ${done}/${pending.rows.length}.`;\n } catch (e:any) { return `Reconcile error: ${e.message}`; }\n }\n\n // ── ORDER SUBMISSION ─────────────────────────────────────\n async function submitOrder(\n symbol: string, side: \"buy\"|\"sell\", qty: number,\n reason: string, signals: Record={}\n ): Promise<{success:boolean;orderId?:string;error?:string}> {\n if (!ALPACA_KEY) return { success:false, error:\"No Alpaca key.\" };\n if (!symbol) return { success:false, error:\"No symbol.\" };\n\n const cb = await checkDrawdown();\n if (cb.tripped) return { success:false, error:`Circuit breaker: ${cb.reason}` };\n\n const cfg = await loadSettings();\n if (cfg.autonomous_mode!==\"true\") return { success:false, error:\"Autonomous mode off.\" };\n\n const pdt = await checkPDT();\n if (!pdt.ok) return { success:false, error:`PDT limit: ${pdt.dayTradeCount}/${pdt.limit}` };\n\n if (side===\"buy\") {\n const cash = await getAvailableCash();\n const cost = qty*(signals.price||0);\n if (cost>0&&cost>cash) return { success:false, error:`Insufficient cash. Need $${cost.toFixed(2)}, have $${cash.toFixed(2)}.` };\n }\n\n try {\n const res = await fetch(`${ALPACA_BASE}/v2/orders`, {\n method:\"POST\", headers:brokerH,\n body:JSON.stringify({ symbol, qty:String(qty), side, type:\"market\", time_in_force:\"day\" }),\n });\n const data = await res.json();\n if (!res.ok) return { success:false, error:data.message||JSON.stringify(data) };\n await sqlite.execute({\n sql:`INSERT INTO quinn_trades (symbol,side,qty,entry_price,reason,sentiment,mc_prob,friction_pct,adv,bs_price,confidence_score,status,alpaca_id) VALUES (?,?,?,?,?,?,?,?,?,?,?,'submitted',?)`,\n args:[symbol,side,qty,signals.price||0,reason,signals.sentiment||0,signals.mcProb||0,signals.frictionPct||0,signals.adv||0,signals.bsPrice||0,signals.confScore||0,data.id],\n });\n return { success:true, orderId:data.id };\n } catch (e:any) { return { success:false, error:e.message }; }\n }\n\n async function closePosition(symbol: string, reason: string) {\n if (!symbol) return { success:false, error:\"No symbol.\" };\n try {\n const pos = await alpacaBroker(`/v2/positions/${symbol.toUpperCase()}`);\n if (!pos||pos.code) return { success:false, error:\"No open position.\" };\n return await submitOrder(symbol,\"sell\",Math.abs(parseFloat(pos.qty)),reason);\n } catch (e:any) { return { success:false, error:e.message }; }\n }\n\n // ── META-LEARNER ─────────────────────────────────────────\n async function analyzePerformance(): Promise {\n try {\n const cfg = await loadSettings();\n const minT = parseInt(cfg.meta_learner_min_trades||\"20\");\n const rows = await sqlite.execute(\n `SELECT symbol,pnl,pnl_vs_theoretical,postmortem_signals FROM quinn_trades WHERE status='closed' AND pnl IS NOT NULL ORDER BY closed_at DESC`\n );\n const trades = rows.rows.map((r:any)=>{\n let sig:any={};\n try{sig=JSON.parse(r[3]||\"{}\");}catch{}\n return { symbol:r[0], pnl:parseFloat(r[1]||\"0\"), sig };\n });\n if (!trades.length) return JSON.stringify({ status:\"No closed trades yet.\" });\n const n=trades.length;\n const winners=trades.filter(t=>t.pnl>0), losers=trades.filter(t=>t.pnl<0);\n const winRate=winners.length/n;\n const totPnl=trades.reduce((s,t)=>s+t.pnl,0);\n const avgW=winners.length?winners.reduce((s,t)=>s+t.pnl,0)/winners.length:0;\n const avgL=losers.length?losers.reduce((s,t)=>s+t.pnl,0)/losers.length:0;\n const pf=avgL!==0?Math.abs(avgW/avgL):999;\n const autoTuned:string[]=[], suggestions:string[]=[];\n if (n>=minT) {\n if (pf<1.0) {\n const cur=parseFloat(cfg.min_confidence_score||\"40\");\n const nxt=Math.min(70,cur+5);\n await sqlite.execute({ sql:`INSERT OR REPLACE INTO quinn_settings (key,value,updated_at) VALUES ('min_confidence_score',?,CURRENT_TIMESTAMP)`,args:[String(nxt)] });\n autoTuned.push(`min_confidence_score: ${cur}→${nxt} (poor PF ${pf.toFixed(2)})`);\n }\n } else {\n suggestions.push(`Observer mode: ${minT-n} more trades before auto-tuning`);\n }\n const report={ totalTrades:n, winRate:+winRate.toFixed(3), totalPnl:+totPnl.toFixed(2), avgWin:+avgW.toFixed(2), avgLoss:+avgL.toFixed(2), profitFactor:+pf.toFixed(3), autoTuned:autoTuned.length?autoTuned:[\"None yet\"], suggestions, observerMode:n {\n const [acct,pos,orders] = await Promise.all([\n getAlpacaAccount(), getAlpacaPositions(), getAlpacaOrders(\"all\",20)\n ]);\n return JSON.stringify({ account:acct, availableCash:parseFloat(acct?.non_marginable_buying_power||\"0\"), positions:pos, recentOrders:orders });\n }\n\n async function getTradeLedger(limit=20): Promise {\n const r = await sqlite.execute({\n sql:`SELECT id,symbol,side,qty,entry_price,exit_price,pnl,pnl_vs_theoretical,confidence_score,status,postmortem,is_day_trade,created_at,closed_at FROM quinn_trades ORDER BY created_at DESC LIMIT ?`,\n args:[limit],\n });\n return JSON.stringify(r.rows);\n }\n\n async function updateWatchlist(symbol:string, action:\"add\"|\"remove\"): Promise {\n if (!symbol) return \"No symbol.\";\n const sym = symbol.toUpperCase().trim();\n if (action===\"add\") {\n await sqlite.execute({ sql:`INSERT OR IGNORE INTO quinn_watchlist (symbol) VALUES (?)`,args:[sym] });\n return `Added ${sym}.`;\n } else {\n await sqlite.execute({ sql:`DELETE FROM quinn_watchlist WHERE symbol=?`,args:[sym] });\n return `Removed ${sym}.`;\n }\n }\n\n async function updateSetting(key:string, value:string): Promise {\n await sqlite.execute({ sql:`INSERT OR REPLACE INTO quinn_settings (key,value,updated_at) VALUES (?,?,CURRENT_TIMESTAMP)`,args:[key,value] });\n return `${key} = ${value}`;\n }\n\n async function sendAlert(subject:string, body:string): Promise {\n try { await email({ subject:`[QUINN] ${subject}`, text:body }); return `Sent: ${subject}`; }\n catch (e:any) { return `Email error: ${e.message}`; }\n }\n\n async function rememberThis(key:string, content:string): Promise {\n await sqlite.execute({ sql:`INSERT OR REPLACE INTO quinn_memory (key,content,updated_at) VALUES (?,?,CURRENT_TIMESTAMP)`,args:[key.toLowerCase().replace(/\\s+/g,\"_\"),content] });\n return `Saved: ${key}`;\n }\n\n // ── TOOLS ────────────────────────────────────────────────\n const tools = [\n { type:\"function\", function:{ name:\"analyzeStock\", description:\"Full quant analysis: live price (Yahoo fallback), Black-Scholes, Monte Carlo, liquidity, news sentiment, confidence score 0-100. Returns BUY or HOLD with all signals.\", parameters:{ type:\"object\", properties:{ symbol:{type:\"string\",description:\"Stock ticker e.g. AAPL\"}, volatility:{type:\"number\",description:\"Annualized volatility decimal. Default 0.25.\"} }, required:[\"symbol\"] } } },\n { type:\"function\", function:{ name:\"scanWatchlist\", description:\"Scan entire watchlist, run analyzeStock on each, return sorted by confidence score descending. Use to find the best trade opportunity.\", parameters:{ type:\"object\", properties:{}, required:[] } } },\n { type:\"function\", function:{ name:\"checkDrawdown\", description:\"Check circuit breaker. Returns tripped=true/false. Always call before trading.\", parameters:{ type:\"object\", properties:{}, required:[] } } },\n { type:\"function\", function:{ name:\"checkPDT\", description:\"Check Pattern Day Trader count in last 5 days.\", parameters:{ type:\"object\", properties:{}, required:[] } } },\n { type:\"function\", function:{ name:\"reconcileFills\", description:\"Sync Alpaca filled orders to DB, compute PnL, write post-mortems.\", parameters:{ type:\"object\", properties:{}, required:[] } } },\n { type:\"function\", function:{ name:\"resolveGhostTrades\", description:\"Find Alpaca fills missing from DB and recover them.\", parameters:{ type:\"object\", properties:{}, required:[] } } },\n { type:\"function\", function:{ name:\"analyzePerformance\", description:\"Meta-learner: review all closed trades, compute win rate and profit factor, auto-tune thresholds after 20 trades.\", parameters:{ type:\"object\", properties:{}, required:[] } } },\n { type:\"function\", function:{ name:\"executeTrade\", description:\"Submit a market order to Alpaca. Only call after BUY verdict. Pass the full signals object from analyzeStock.\", parameters:{ type:\"object\", properties:{ symbol:{type:\"string\"}, side:{type:\"string\",enum:[\"buy\",\"sell\"]}, qty:{type:\"number\"}, reason:{type:\"string\"}, signals:{type:\"object\"} }, required:[\"symbol\",\"side\",\"qty\",\"reason\"] } } },\n { type:\"function\", function:{ name:\"closePosition\", description:\"Close an open position by selling all shares.\", parameters:{ type:\"object\", properties:{ symbol:{type:\"string\"}, reason:{type:\"string\"} }, required:[\"symbol\",\"reason\"] } } },\n { type:\"function\", function:{ name:\"getPortfolio\", description:\"Get Alpaca account equity, non_marginable_buying_power (settled cash), and open positions.\", parameters:{ type:\"object\", properties:{}, required:[] } } },\n { type:\"function\", function:{ name:\"getTradeLedger\", description:\"Get trade history with PnL and post-mortems.\", parameters:{ type:\"object\", properties:{ limit:{type:\"number\"} }, required:[] } } },\n { type:\"function\", function:{ name:\"updateWatchlist\", description:\"Add or remove a ticker from the watchlist.\", parameters:{ type:\"object\", properties:{ symbol:{type:\"string\"}, action:{type:\"string\",enum:[\"add\",\"remove\"]} }, required:[\"symbol\",\"action\"] } } },\n { type:\"function\", function:{ name:\"updateSetting\", description:\"Update a config setting. Keys: max_position_usd, min_confidence_score, min_sentiment, max_friction_pct, min_adv, autonomous_mode, circuit_breaker_pct, circuit_breaker_triggered, swing_mode, max_day_trades_5d.\", parameters:{ type:\"object\", properties:{ key:{type:\"string\"}, value:{type:\"string\"} }, required:[\"key\",\"value\"] } } },\n { type:\"function\", function:{ name:\"sendAlert\", description:\"Email Void a trade alert or summary.\", parameters:{ type:\"object\", properties:{ subject:{type:\"string\"}, body:{type:\"string\"} }, required:[\"subject\",\"body\"] } } },\n { type:\"function\", function:{ name:\"rememberThis\", description:\"Save a note to Quinn's memory vault.\", parameters:{ type:\"object\", properties:{ key:{type:\"string\"}, content:{type:\"string\"} }, required:[\"key\",\"content\"] } } },\n ];\n\n // ── CONTEXT LOADER ───────────────────────────────────────\n let ctx = \"\";\n try {\n const [cfg,wl,mem,trades,cb,pdt] = await Promise.all([\n sqlite.execute(`SELECT key,value FROM quinn_settings`),\n sqlite.execute(`SELECT symbol FROM quinn_watchlist`),\n sqlite.execute(`SELECT key,content FROM quinn_memory ORDER BY updated_at DESC LIMIT 6`),\n sqlite.execute(`SELECT symbol,side,qty,status,confidence_score,pnl,created_at FROM quinn_trades ORDER BY created_at DESC LIMIT 5`),\n checkDrawdown(), checkPDT(),\n ]);\n ctx += `\\n=== CONFIG ===\\n${cfg.rows.map((r:any)=>`${r[0]}: ${r[1]}`).join(\"\\n\")}`;\n ctx += `\\n\\n=== WATCHLIST ===\\n${wl.rows.map((r:any)=>r[0]).join(\", \")}`;\n if (mem.rows.length) ctx += `\\n\\n=== LESSONS ===\\n${mem.rows.map((r:any)=>`${r[0]}: ${r[1]}`).join(\"\\n\")}`;\n if (trades.rows.length) {\n ctx += `\\n\\n=== RECENT TRADES ===\\n`;\n ctx += trades.rows.map((r:any)=>`${r[6]}: ${r[1]} ${r[0]} x${r[2]} conf=${r[4]} [${r[3]}]${r[5]?` PnL $${parseFloat(r[5]).toFixed(2)}`:\"\"}`).join(\"\\n\");\n }\n ctx += `\\n\\n=== SAFETY ===`;\n ctx += `\\nCircuit breaker: ${cb.tripped?`⚠️ TRIPPED — ${cb.reason}`:\"Clear\"}`;\n ctx += `\\nPDT: ${pdt.dayTradeCount}/${pdt.limit} day trades in 5d`;\n ctx += `\\nMarket: ${isMarketOpen()?\"🟢 OPEN — execute trades now\":\"🔴 CLOSED — analysis only, no orders\"}`;\n ctx += `\\nAlpaca: ${ALPACA_BASE.includes(\"paper\")?\"PAPER TRADING\":\"⚠️ LIVE TRADING\"}`;\n ctx += `\\nModel: ${QUINN_MODEL}`;\n } catch { ctx = \"\"; }\n\n // ── SYSTEM PROMPT ────────────────────────────────────────\n const systemPrompt = `You are QUINN v4, an autonomous quant trading agent. You trade US stocks via Alpaca.\n\nCRITICAL — TOOL CALLING: You MUST use proper API function calls for tools. NEVER output XML tags, JSON blocks, or any text representation of a tool call. If you cannot call a tool as a function, say so in plain English. Tool calls that appear as text in your response are BROKEN and will not execute.\n\nWHEN MARKET IS OPEN AND ASKED TO TRADE — follow this exact sequence:\n1. Call reconcileFills\n2. Call resolveGhostTrades \n3. Call checkDrawdown — if tripped=true, STOP and report\n4. Call checkPDT — if ok=false and swing_mode=false, STOP\n5. Call scanWatchlist — get all candidates ranked by confidence\n6. Take the HIGHEST confidence BUY verdict stock\n7. Call getPortfolio — check non_marginable_buying_power\n8. Calculate qty = floor(max_position_usd / price), minimum 1\n9. Call executeTrade immediately — do NOT ask for confirmation\n10. Call sendAlert with trade details\n\nWHEN MARKET IS CLOSED — do analysis only. Never call executeTrade.\n\nABSOLUTE RULES:\n- Only size using non_marginable_buying_power (settled cash)\n- Never trade when circuit_breaker_triggered=true\n- Never trade when autonomous_mode=false\n- Never exceed max_position_usd per trade\n- sentiment < -0.3 = skip that stock (only strongly negative news blocks)\n- qty must be at least 1 share\n\nCONFIDENCE TIERS:\n- 0-39: Never trade\n- 40-59: Trade — qty = floor(max_position_usd * 0.5 / price), min 1\n- 60-79: Trade — qty = floor(max_position_usd * 0.75 / price), min 1 \n- 80-100: Trade — qty = floor(max_position_usd / price), min 1\n\nKEY: When the market is open and a stock has BUY verdict — EXECUTE IMMEDIATELY. Do not say \"conditions are not met\" if confidence >= min_confidence_score. Do not ask for permission. Just trade.\n\n${ctx}`;\n\n // ── REQUEST HANDLER ──────────────────────────────────────\n let body: any;\n try { body = await req.json(); }\n catch { return Response.json({ error:\"Invalid JSON.\" }, { headers }); }\n\n const messages: any[] = (body.messages||[]).slice(-6);\n\n // Background maintenance every 5th request\n if (Math.floor(Date.now()/1000)%5===0) {\n Promise.all([reconcileFills(), resolveGhostTrades()]).catch(()=>{});\n }\n\n const callModel = async (msgs: any[], useTools=true): Promise => {\n const payload: any = { model:QUINN_MODEL, messages:msgs, temperature:0.1, max_tokens:2048 };\n if (useTools) { payload.tools=tools; payload.tool_choice=\"auto\"; }\n for (let attempt=0; attempt<=2; attempt++) {\n try {\n const res = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method:\"POST\",\n headers:{ \"Authorization\":`Bearer ${OPENROUTER_KEY}`, \"Content-Type\":\"application/json\", \"HTTP-Referer\":\"https://quinn.val.run\", \"X-Title\":\"QUINN\" },\n body:JSON.stringify(payload),\n });\n if (res.status===400) { const e=await res.json(); throw new Error(`400: ${e.error?.message||JSON.stringify(e)}`); }\n if (res.status===429||res.status>=500) {\n if (attempt===2) throw new Error(`API failed after 3 attempts (HTTP ${res.status})`);\n await new Promise(r=>setTimeout(r,2500*(attempt+1))); continue;\n }\n return await res.json();\n } catch(e:any) {\n if (attempt===2) throw e;\n await new Promise(r=>setTimeout(r,2500*(attempt+1)));\n }\n }\n };\n\n let response: any;\n try { response = await callModel([{ role:\"system\", content:systemPrompt }, ...messages]); }\n catch(e:any) { return Response.json({ error:`Model call failed: ${e.message}` }, { headers }); }\n\n if (response?.error) return Response.json({ error:response.error.message||JSON.stringify(response.error) }, { headers });\n const message = response?.choices?.[0]?.message;\n if (!message) return Response.json({ error:\"No response from model.\" }, { headers });\n\n // ── TOOL DISPATCHER ──────────────────────────────────────\n if (message.tool_calls?.length > 0) {\n const tc = message.tool_calls[0];\n const name = tc.function.name;\n let args: any = {};\n try { args = JSON.parse(tc.function.arguments||\"{}\"); } catch { args = {}; }\n\n let result = \"\";\n let extra: any = { tool_used:name };\n\n switch(name) {\n case \"analyzeStock\": {\n result = await analyzeStock(args.symbol, args.volatility);\n try { const p=JSON.parse(result); extra.analysis=p; extra.verdict=p.verdict; extra.confidence=p.confidence; } catch {}\n break;\n }\n case \"scanWatchlist\": {\n result = await scanWatchlist();\n try { extra.scan_results=JSON.parse(result); } catch {}\n break;\n }\n case \"checkDrawdown\": {\n const r = await checkDrawdown();\n result = JSON.stringify(r); extra.circuit_breaker = r;\n break;\n }\n case \"checkPDT\": {\n const r = await checkPDT();\n result = JSON.stringify(r); extra.pdt = r;\n break;\n }\n case \"reconcileFills\": { result = await reconcileFills(); break; }\n case \"resolveGhostTrades\": { result = await resolveGhostTrades(); break; }\n case \"analyzePerformance\": {\n result = await analyzePerformance();\n try { extra.performance=JSON.parse(result); } catch {}\n break;\n }\n case \"executeTrade\": {\n const q = await getQuote(args.symbol||\"\");\n const signals = { ...(args.signals||{}), price:q?.price||0 };\n const r = await submitOrder(args.symbol, args.side, args.qty, args.reason, signals);\n result = JSON.stringify(r);\n extra.trade_executed = r.success;\n extra.trade_symbol = args.symbol;\n extra.trade_side = args.side;\n extra.trade_qty = args.qty;\n if (r.success) {\n // Fire email immediately on trade\n sendAlert(\n `${args.side?.toUpperCase()} ${args.symbol} x${args.qty}`,\n `Quinn executed: ${args.side} ${args.qty} shares of ${args.symbol} @ ~$${(q?.price||0).toFixed(2)}\\nReason: ${args.reason}\\nOrder ID: ${r.orderId}`\n ).catch(()=>{});\n }\n break;\n }\n case \"closePosition\": {\n result = JSON.stringify(await closePosition(args.symbol, args.reason));\n break;\n }\n case \"getPortfolio\": {\n result = await getPortfolio();\n try { extra.portfolio=JSON.parse(result); } catch {}\n break;\n }\n case \"getTradeLedger\": {\n result = await getTradeLedger(args.limit||20);\n try { extra.ledger=JSON.parse(result); } catch {}\n break;\n }\n case \"updateWatchlist\": { result = await updateWatchlist(args.symbol, args.action); break; }\n case \"updateSetting\": { result = await updateSetting(args.key, args.value); break; }\n case \"sendAlert\": { result = await sendAlert(args.subject, args.body); break; }\n case \"rememberThis\": { result = await rememberThis(args.key, args.content); break; }\n default: result = `Unknown tool: ${name}`;\n }\n\n let finalResp: any;\n try {\n finalResp = await callModel([\n { role:\"system\", content:systemPrompt },\n ...messages, message,\n { role:\"tool\", tool_call_id:tc.id, name, content:result },\n ], false);\n } catch(e:any) {\n return Response.json({ error:`Final call failed: ${e.message}` }, { headers });\n }\n\n const reply = finalResp?.choices?.[0]?.message?.content || \"No response.\";\n return Response.json({ reply, ...extra }, { headers });\n }\n\n return Response.json({ reply:message.content||\"No response.\" }, { headers });\n}","deleted","label",[114],"cc23208e-36c9-11f1-8d3b-42b51c65c3df","Quinn-Cron.ts","bcc30064-36c9-11f1-b553-42b51c65c3df",13,["D",1776037576625],3,"export default async function () {\n const now = new Date();\n const utcHour = now.getUTCHours();\n const utcMin = now.getUTCMinutes();\n const etHour = utcHour - 4; // EDT offset (use -5 for EST winter)\n\n // Only run 9:30am to 3:30pm ET (market hours, stop 30min early)\n const etMinutes = etHour * 60 + utcMin;\n if (etMinutes < 570 || etMinutes > 930) return; // 570=9:30, 930=15:30\n\n await fetch(\n \"https://infinarscientiacloud--a55e920c368911f1ba8342b51c65c3df.web.val.run\",\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n messages: [{\n role: \"user\",\n content:\n \"Autonomous scan: reconcile fills, resolve ghost trades, check circuit breaker and PDT, scan full watchlist, execute best opportunity if confidence >= 65 and all safety gates clear, send email alert if any trade executed.\",\n }],\n }),\n },\n );\n}",[131],"pulls",1,"forks","envVars",{"_145":147,"_148":51},"connections",{"_145":51,"_146":51},"count","unfilledCount",4,"emptyCount",{"_20":130,"_13":131,"_115":132,"_117":-5,"_118":21,"_119":133,"_120":106,"_22":155,"_29":135,"_123":124,"_125":136,"_127":38,"_128":-5,"_152":156,"_87":157},{"_20":113,"_13":114,"_115":116,"_117":-5,"_118":21,"_119":30,"_120":106,"_22":151,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_152":153,"_87":154},["D",1783684738419],"children",[],[114],["D",1776037576625],[],[131],["D",1776010023785],{"_11":12,"_85":81},{"_11":12,"_79":-5,"_80":81,"_44":45,"_82":83,"_84":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_74":-5,"_75":-5,"_76":-5,"_77":14,"_78":12},"ctx",{"_67":-5,"_108":195,"_196":197,"_198":199,"_200":38,"_201":38,"_202":38,"_203":106,"_204":-5,"_205":-7,"_206":-7,"_207":51,"_208":38,"_209":38,"_210":-5,"_211":38,"_212":38,"_213":38,"_214":-5},"ENV",{"_166":167,"_168":169,"_170":26,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1