[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_336":337,"_338":339},"routes/_app.x.$handle.$name",{"_110":109,"_37":50,"_119":96,"_32":120,"_13":14,"_121":-5,"_11":122,"_123":124,"_125":126,"_127":128,"_129":130,"_26":-5,"_131":132,"_133":134,"_135":30,"_136":137,"_138":65,"_139":-5,"_140":-5,"_141":142},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_48":49,"_37":50,"_43":51,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":60,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":30},"version",14,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","bf00e29e-f96a-49ea-97bb-09e0bc60b927","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":14,"_46":47,"_29":30},"previous","deleted",false,"deletedHere","path","frontend/components/StatsBar.tsx","latestPath","fileId","4b4abc8e-798f-11f1-ab32-1607ee4eb77e","name","StatsBar.tsx","fileType","script","content","/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\nexport function StatsBar({ stats, risk }: { stats: any; risk: any }) {\n const items = [\n {\n label: \"Active Positions\",\n value: stats?.active_positions ?? 0,\n icon: \"📈\",\n color: \"text-blue-400\",\n },\n {\n label: \"Total Positions\",\n value: stats?.total_positions ?? 0,\n icon: \"📊\",\n color: \"text-gray-300\",\n },\n {\n label: \"Demo Balance\",\n value: stats?.balance != null ? `$${stats.balance.toFixed(2)}` : \"—\",\n icon: \"💰\",\n color: \"text-yellow-400\",\n },\n {\n label: \"Win Rate\",\n value: stats?.winRate != null ? `${stats.winRate}%` : \"—\",\n icon: \"🎯\",\n color: stats?.winRate >= 50 ? \"text-green-400\" : \"text-red-400\",\n },\n {\n label: \"Total P&L\",\n value: stats?.totalPnL != null\n ? `${stats.totalPnL >= 0 ? \"+\" : \"\"}$${stats.totalPnL.toFixed(2)}`\n : \"—\",\n icon: stats?.totalPnL >= 0 ? \"📈\" : \"📉\",\n color: stats?.totalPnL >= 0 ? \"text-green-400\" : \"text-red-400\",\n },\n {\n label: \"Alerts Sent\",\n value: stats?.total_alerts ?? 0,\n icon: \"🔔\",\n color: \"text-orange-400\",\n },\n ];\n\n return (\n

\n {items.map((item) => (\n \n

\n {item.icon} {item.label}\n

{item.value}

\n ))}\n \n );\n}\n","createdAt",["D",1783379177499],"branchVersion","branchId","7c7585b6-26ec-4b48-a71e-b55cd6373bb7","id","ffcf456e-ea1b-45b3-ae3b-4aa3f7336137","risk-guardian",["D",1783377974103],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","XAU/USD Risk Guardian — risk scoring, alerts, paper trading","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/64dc00cc-94d9-47dd-81b1-dde02610d900/square512?exp=1789541999&sig=8fad4d8ed521ff338d1e7bb443f46241d1f9e0e657d24a41f82306e6eb92823c","ed44d53c-06eb-4d40-875e-31a1ddc3df9e","pinnedFileId","019f399c-53b9-739a-90ff-bb0a30775a63","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f3991-9a05-72bb-a327-cf5b31f62d93","tursoName","ffcf456eea1b45b3ae3b4aa3f7336137","tursoHostname","ffcf456eea1b45b3ae3b4aa3f7336137-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_110":109,"_118":114},"org",{"_110":109,"_111":112,"_113":114,"_19":61,"_115":116,"_117":30},"branch",{"_13":95,"_37":96,"_48":47,"_97":49,"_98":99,"_100":101,"_102":55,"_103":104,"_105":106,"_107":50,"_108":109},"isOwned",27,"main","projectId","forkedBranchId","961078ea-f528-11ef-aa68-569c3dd06744","forkedBranchVersion",89,"forkedProjectPrivacy","forkedProjectId","96102714-f528-11ef-aa68-569c3dd06744","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","Hunter5","handle","displayName","Francis Ngugi","avatar","https://lh3.googleusercontent.com/a/ACg8ocK4Afj4B1r5sKudXPEQcQec_doIzFyxxVnr6ivB6YdptbXKMQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_48":49,"_37":50,"_43":331,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":60,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":332,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":333,"_90":334,"_92":335,"_94":30},"tree",[197,205,213,214],"files",[197,198,199,200,201,202,203,204,205,206,207,208,209,210,211,212,213,214],"counts",{"_187":69,"_188":164,"_189":69,"_190":191,"_192":193},"contents",[154,155,156,157],"upstreamProject",{"_48":104,"_37":150,"_57":151,"_59":60,"_54":55,"_88":152},"upstreamBranch",{"_48":99,"_43":143,"_144":145,"_37":96,"_97":104,"_13":146,"_98":-5,"_100":-5,"_147":148,"_52":-5,"_94":30,"_54":55,"_108":149,"_70":106,"_107":150},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1740674013689],"updatedAt",["D",1785420707976],91,"lockfileKey","1785420708123-esm.town_v_templates_react-hono-starter@91-main","templates","react-hono-starter","Starter template with client-side React & Hono server",{"_110":149,"_118":153},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789541999&sig=156ae2b8ac752fc06f52d45eab428b512e0d31e2aab99a830d8bb32149c64f0f",{"_48":182,"_37":183,"_35":184,"_160":-5,"_46":47,"_45":164,"_162":65,"_43":185,"_13":69,"_39":180,"_41":-5,"_29":30,"_167":-5,"_32":186},{"_48":175,"_37":176,"_35":177,"_160":-5,"_46":47,"_45":178,"_162":65,"_43":179,"_13":69,"_39":180,"_41":-5,"_29":30,"_167":-5,"_32":181},{"_48":169,"_37":170,"_35":171,"_160":-5,"_46":47,"_45":164,"_162":30,"_43":172,"_13":69,"_39":26,"_41":173,"_29":30,"_167":-5,"_32":174},{"_48":158,"_37":159,"_35":63,"_160":-5,"_46":47,"_45":161,"_162":30,"_43":163,"_13":164,"_39":165,"_41":166,"_29":30,"_167":50,"_32":168},"5bbe9204-1847-448c-8294-4aa04a6f9f3b","index.ts","parentId",10,"latest",["D",1783379133104],1,"http","import { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono\";\n\nimport { initDB, getStats, getActivePositions, getAllPositions, getRecentAlerts, getRiskHistory, getDemoAccount, getOpenDemoTrades, getAllDemoTrades, getRecentRiskHistory } from \"./lib/db.ts\";\nimport { getGoldPrice, getDXY } from \"./lib/price.ts\";\nimport { pollSignals, receiveWebhookSignal, injectSignal } from \"./lib/signal-poller.ts\";\nimport { calculateRiskScore, shouldAlert } from \"./lib/risk.ts\";\nimport { sendTelegramMessage, formatRiskAlert } from \"./lib/telegram.ts\";\nimport { updateDemoEquity, checkDemoSLTP, getDemoStats, calculatePnL } from \"./lib/demo.ts\";\nimport { addRiskHistory, addAlert } from \"./lib/db.ts\";\nimport type { ConfirmedSignal } from \"./lib/types.ts\";\n\nconst app = new Hono();\n\n// ── Frontend ──────────────────────────────────────────────────\napp.get(\"/\", (c) => serveFile(\"/frontend/index.html\"));\napp.get(\"/frontend/**/*\", (c) => serveFile(c.req.path));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ── Health ────────────────────────────────────────────────────\napp.get(\"/api/health\", (c) => c.json({ status: \"ok\", service: \"risk-guardian\", version: \"1.0\" }));\n\n// ── Dashboard Stats ───────────────────────────────────────────\napp.get(\"/api/stats\", async (c) => {\n await initDB();\n const stats = await getStats();\n const demoStats = await getDemoStats();\n return c.json({ ...stats, ...demoStats });\n});\n\n// ── Live Price + DXY ──────────────────────────────────────────\napp.get(\"/api/price\", async (c) => {\n const [gold, dxy] = await Promise.all([getGoldPrice(), getDXY()]);\n if (!gold) return c.json({ error: \"Price fetch failed\" }, 502);\n return c.json({\n gold: gold.price,\n source: gold.source,\n dxy,\n timestamp: gold.timestamp,\n });\n});\n\n// ── Positions ─────────────────────────────────────────────────\napp.get(\"/api/positions\", async (c) => {\n await initDB();\n const positions = await getAllPositions(100);\n return c.json(positions);\n});\n\napp.get(\"/api/positions/active\", async (c) => {\n await initDB();\n const positions = await getActivePositions();\n return c.json(positions);\n});\n\n// ── Risk Assessment (live) ────────────────────────────────────\napp.get(\"/api/risk\", async (c) => {\n await initDB();\n const positions = await getActivePositions();\n if (positions.length === 0) return c.json({ positions: [], summary: \"No active positions\" });\n\n const [gold, dxy] = await Promise.all([getGoldPrice(), getDXY()]);\n if (!gold) return c.json({ error: \"Price fetch failed\" }, 502);\n\n const assessments = await Promise.all(positions.map(async (pos) => {\n const history = await getRiskHistory(pos.id, 1);\n const prevPrice = history.length > 0 ? history[0].current_price : null;\n const result = calculateRiskScore({\n direction: pos.direction,\n entry_price: pos.entry_price,\n sl_price: pos.sl_price,\n tp_price: pos.tp_price,\n invalidation_level: pos.invalidation_level,\n current_price: gold.price,\n dxy_value: dxy,\n prev_price: prevPrice,\n });\n\n const pnl = calculatePnL(pos.direction, pos.entry_price, gold.price, 0.1);\n\n return {\n signal_id: pos.signal_id,\n direction: pos.direction,\n entry_price: pos.entry_price,\n current_price: gold.price,\n risk_score: result.score,\n risk_level: result.level,\n distance_to_sl: result.distance_to_sl,\n distance_to_tp: result.distance_to_tp,\n unrealized_pnl: pnl,\n notes: result.notes,\n };\n }));\n\n const highRisk = assessments.filter((a) => a.risk_level === \"danger\" || a.risk_level === \"critical\").length;\n return c.json({\n gold_price: gold.price,\n dxy,\n positions: assessments,\n summary: `${assessments.length} active, ${highRisk} at elevated risk`,\n });\n});\n\n// ── Risk History ──────────────────────────────────────────────\napp.get(\"/api/risk/history\", async (c) => {\n await initDB();\n const history = await getRecentRiskHistory(50);\n return c.json(history);\n});\n\napp.get(\"/api/risk/:positionId\", async (c) => {\n await initDB();\n const id = parseInt(c.req.param(\"positionId\"));\n const history = await getRiskHistory(id, 100);\n return c.json(history);\n});\n\n// ── Alerts ────────────────────────────────────────────────────\napp.get(\"/api/alerts\", async (c) => {\n await initDB();\n const alerts = await getRecentAlerts(50);\n return c.json(alerts);\n});\n\n// ── Demo Account ──────────────────────────────────────────────\napp.get(\"/api/demo\", async (c) => {\n const stats = await getDemoStats();\n return c.json(stats);\n});\n\napp.get(\"/api/demo/trades\", async (c) => {\n await initDB();\n const trades = await getAllDemoTrades(100);\n return c.json(trades);\n});\n\napp.get(\"/api/demo/open\", async (c) => {\n await initDB();\n const trades = await getOpenDemoTrades();\n return c.json(trades);\n});\n\n// ── Signal Polling ────────────────────────────────────────────\napp.post(\"/api/poll\", async (c) => {\n const result = await pollSignals();\n return c.json(result);\n});\n\n// ── Webhook Receiver (external bots POST signals here) ────────\napp.post(\"/api/signals/webhook\", async (c) => {\n let body: ConfirmedSignal | ConfirmedSignal[];\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid JSON body\" }, 400);\n }\n const result = await receiveWebhookSignal(body);\n return c.json(result, 201);\n});\n\n// ── Manual Signal Injection ───────────────────────────────────\napp.post(\"/api/signals/inject\", async (c) => {\n let body: ConfirmedSignal;\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid JSON body\" }, 400);\n }\n const pos = await injectSignal(body);\n return c.json(pos, 201);\n});\n\n// ── Full Risk Monitor (poll signals + assess risk + demo) ─────\napp.post(\"/api/monitor\", async (c) => {\n // 1. Poll for new/closed signals\n const pollResult = await pollSignals();\n\n // 2. Get live price\n const [gold, dxy] = await Promise.all([getGoldPrice(), getDXY()]);\n if (!gold) return c.json({ ...pollResult, priceError: \"Price fetch failed\" });\n\n // 3. Update demo equity\n await updateDemoEquity(gold.price);\n\n // 4. Check SL/TP on demo trades\n const sltpResult = await checkDemoSLTP(gold.price);\n\n // 5. Assess risk on all active positions\n await initDB();\n const positions = await getActivePositions();\n const riskResults: any[] = [];\n\n for (const pos of positions) {\n const history = await getRiskHistory(pos.id, 1);\n const prevPrice = history.length > 0 ? history[0].current_price : null;\n const prevLevel = history.length > 0 ? (history[0].risk_level as any) : null;\n\n const result = calculateRiskScore({\n direction: pos.direction,\n entry_price: pos.entry_price,\n sl_price: pos.sl_price,\n tp_price: pos.tp_price,\n invalidation_level: pos.invalidation_level,\n current_price: gold.price,\n dxy_value: dxy,\n prev_price: prevPrice,\n });\n\n // Store risk history\n await addRiskHistory({\n position_id: pos.id,\n risk_score: result.score,\n risk_level: result.level,\n current_price: gold.price,\n distance_to_sl: result.distance_to_sl,\n distance_to_tp: result.distance_to_tp,\n dxy_value: dxy,\n notes: result.notes.join(\"; \"),\n });\n\n // Telegram alert if risk escalated\n if (shouldAlert(result, prevLevel)) {\n const msg = formatRiskAlert(\n pos.signal_id,\n pos.direction,\n result.level,\n result.score,\n gold.price,\n result.notes,\n );\n const sent = await sendTelegramMessage(msg);\n await addAlert(\n pos.id,\n \"risk_escalation\",\n result.level,\n `Risk escalated to ${result.level} (${result.score}/100) at price ${gold.price}`,\n sent ? 1 : 0,\n );\n }\n\n riskResults.push({\n signal_id: pos.signal_id,\n direction: pos.direction,\n score: result.score,\n level: result.level,\n });\n }\n\n return c.json({\n ...pollResult,\n gold_price: gold.price,\n dxy,\n risk_assessments: riskResults,\n demo_sltp_closed: sltpResult.closed.length,\n active_positions: positions.length,\n });\n});\n\n// ── Error handling ────────────────────────────────────────────\napp.onError((err) => Promise.reject(err));\n\nexport default app.fetch;\n","label",[159],"9600efcd-06e8-4c04-94fe-be81dc8e7a98","README.md","019f399c-53b8-772f-829b-4a24b1f70d71",["D",1783377974103],"# React + Hono Starter\n\nA minimal starter template for building client-side React apps with a Hono\nbackend on Val Town. Click **Remix** to get your own copy.\n\n## Picking a starter\n\n| Starter | When to pick it |\n| --- | --- |\n| [`basic-html-starter`](https://www.val.town/x/templates/basic-html-starter) | Static HTML pages. Sprinkle of vanilla JS. No server-side rendering. |\n| [`hono-jsx-starter`](https://www.val.town/x/templates/hono-jsx-starter) | Dynamic server-rendered HTML with JSX. API routes. No React, no SPA. |\n| **[`react-hono-starter`](https://www.val.town/x/templates/react-hono-starter)** *(you're here)* | Client-side React SPA with a Hono API backend. |\n\n**Want to build UI?** Start writing React components in\n[`frontend/components/`](/frontend/components/). Import them into `App.tsx` and\nyou're good to go. Styling is [Twind](https://twind.style/) — just use Tailwind\nutility classes, zero config.\n\n**Want to add an API?** Add routes in [`index.ts`](/index.ts) (there's a\ncommented-out example). Fetch them from your React components.\n\n## Architecture\n\n```mermaid\ngraph LR\n Browser -->|\"GET /\"| Hono[\"index.ts
(Hono server)\"]\n Hono -->|serves| HTML[\"index.html\"]\n HTML -->|loads| Entry[\"index.tsx\"]\n Entry -->|renders| App[\"App.tsx\"]\n App -->|renders| Counter[\"Counter.tsx\"]\n```\n\n## File structure\n\n```\nindex.ts ← Hono backend (serves frontend + API routes)\nfrontend/\n index.html ← HTML shell (loads Twind + React)\n index.tsx ← React entrypoint (mounts )\n favicon.svg ← App icon\n components/\n App.tsx ← Root component (layout + view source link)\n Counter.tsx ← Example component with state\n```\n\n## How it works\n\n1. **`index.ts`** is the HTTP entrypoint — a Hono server that serves the\n frontend and any API routes you add.\n2. **`frontend/index.html`** loads Twind and the React entrypoint.\n3. **`frontend/index.tsx`** mounts the React app.\n4. **`frontend/components/App.tsx`** is the root layout — add new components\n alongside it.\n5. **`frontend/components/Counter.tsx`** is an example stateful component —\n replace it with your own!\n\n## Next steps\n\n- Add API routes in `index.ts`\n- Add new components in `frontend/components/`\n- Add a SQLite database — see the\n [React Hono Example](https://www.val.town/x/stevekrouse/reactHonoExample) for\n a full-stack example with database, queries, and shared types\n",[170],"c973a0a3-2142-4571-b5da-46d4c1bcdd97","lib","bd4d577a-c696-45e0-a725-3df4ce483845",2,["D",1783377986977],"directory",[176],"2a74a97c-04f1-415b-9032-c043670177a4","frontend","019f399c-53b8-772f-829b-46f036e99f2c",["D",1783377974103],[183],"pulls","branches","forks","envVars",{"_194":69,"_196":69},"connections",{"_194":69,"_195":69},"count","unfilledCount","emptyCount",{"_48":182,"_37":183,"_35":184,"_160":-5,"_46":47,"_45":164,"_162":65,"_43":328,"_13":69,"_39":180,"_41":-5,"_29":30,"_167":-5,"_216":329,"_32":330},{"_48":324,"_37":308,"_35":304,"_160":184,"_46":47,"_45":164,"_162":65,"_43":325,"_13":69,"_39":180,"_41":-5,"_29":30,"_167":-5,"_216":326,"_32":327},{"_48":316,"_37":317,"_35":318,"_160":304,"_46":47,"_45":319,"_162":30,"_43":320,"_13":164,"_39":40,"_41":321,"_29":30,"_167":-5,"_216":322,"_32":323},{"_48":309,"_37":310,"_35":311,"_160":304,"_46":47,"_45":164,"_162":30,"_43":312,"_13":69,"_39":40,"_41":313,"_29":30,"_167":-5,"_216":314,"_32":315},{"_48":303,"_37":38,"_35":36,"_160":304,"_46":47,"_45":14,"_162":65,"_43":305,"_13":69,"_39":40,"_41":42,"_29":30,"_167":-5,"_216":306,"_32":307},{"_48":296,"_37":297,"_35":298,"_160":184,"_46":47,"_45":164,"_162":65,"_43":299,"_13":69,"_39":26,"_41":300,"_29":30,"_167":-5,"_216":301,"_32":302},{"_48":288,"_37":289,"_35":290,"_160":184,"_46":47,"_45":291,"_162":65,"_43":292,"_13":164,"_39":26,"_41":293,"_29":30,"_167":-5,"_216":294,"_32":295},{"_48":280,"_37":281,"_35":282,"_160":184,"_46":47,"_45":283,"_162":65,"_43":284,"_13":164,"_39":40,"_41":285,"_29":30,"_167":-5,"_216":286,"_32":287},{"_48":175,"_37":176,"_35":177,"_160":-5,"_46":47,"_45":178,"_162":65,"_43":277,"_13":69,"_39":180,"_41":-5,"_29":30,"_167":-5,"_216":278,"_32":279},{"_48":269,"_37":270,"_35":271,"_160":177,"_46":47,"_45":272,"_162":65,"_43":273,"_13":69,"_39":40,"_41":274,"_29":30,"_167":-5,"_216":275,"_32":276},{"_48":261,"_37":262,"_35":263,"_160":177,"_46":47,"_45":264,"_162":65,"_43":265,"_13":69,"_39":40,"_41":266,"_29":30,"_167":-5,"_216":267,"_32":268},{"_48":253,"_37":254,"_35":255,"_160":177,"_46":47,"_45":256,"_162":65,"_43":257,"_13":69,"_39":40,"_41":258,"_29":30,"_167":-5,"_216":259,"_32":260},{"_48":245,"_37":246,"_35":247,"_160":177,"_46":47,"_45":248,"_162":65,"_43":249,"_13":69,"_39":40,"_41":250,"_29":30,"_167":-5,"_216":251,"_32":252},{"_48":237,"_37":238,"_35":239,"_160":177,"_46":47,"_45":240,"_162":65,"_43":241,"_13":164,"_39":40,"_41":242,"_29":30,"_167":-5,"_216":243,"_32":244},{"_48":229,"_37":230,"_35":231,"_160":177,"_46":47,"_45":232,"_162":65,"_43":233,"_13":69,"_39":40,"_41":234,"_29":30,"_167":-5,"_216":235,"_32":236},{"_48":222,"_37":223,"_35":224,"_160":177,"_46":47,"_45":178,"_162":65,"_43":225,"_13":69,"_39":40,"_41":226,"_29":30,"_167":-5,"_216":227,"_32":228},{"_48":169,"_37":170,"_35":171,"_160":-5,"_46":47,"_45":164,"_162":30,"_43":219,"_13":69,"_39":26,"_41":173,"_29":30,"_167":-5,"_216":220,"_32":221},{"_48":158,"_37":159,"_35":63,"_160":-5,"_46":47,"_45":161,"_162":30,"_43":215,"_13":164,"_39":165,"_41":166,"_29":30,"_167":50,"_216":217,"_32":218},["D",1783379133104],"children",[],[159],["D",1783377974103],[],[170],"34a3721c-75f6-45cc-a840-88ef40c75370","types.ts","85a83dbe-798c-11f1-87d2-1607ee4eb77e",["D",1783377986977],"// Shared types for Risk Guardian\n\nexport type Direction = \"LONG\" | \"SHORT\";\n\nexport type PositionStatus = \"watching\" | \"closed\" | \"invalidated\";\n\nexport type RiskLevel = \"safe\" | \"caution\" | \"danger\" | \"critical\";\n\nexport interface Position {\n id: number;\n signal_id: string;\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level: number | null;\n status: PositionStatus;\n opened_at: string;\n closed_at: string | null;\n close_price: number | null;\n}\n\nexport interface RiskHistoryEntry {\n id: number;\n position_id: number;\n timestamp: string;\n risk_score: number; // 0-100\n risk_level: RiskLevel;\n current_price: number;\n distance_to_sl: number; // percent\n distance_to_tp: number; // percent\n dxy_value: number | null;\n notes: string | null;\n}\n\nexport interface RiskScoreInput {\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level: number | null;\n current_price: number;\n dxy_value: number | null;\n prev_price: number | null; // for momentum\n}\n\nexport interface RiskScoreResult {\n score: number; // 0-100\n level: RiskLevel;\n distance_to_sl: number; // percent\n distance_to_tp: number; // percent\n notes: string[];\n}\n\nexport interface DemoAccount {\n id: number;\n starting_balance: number;\n balance: number;\n equity: number;\n total_trades: number;\n wins: number;\n losses: number;\n}\n\nexport interface DemoTrade {\n id: number;\n position_id: number | null;\n direction: Direction;\n entry_price: number;\n lot_size: number;\n sl_price: number;\n tp_price: number;\n status: \"open\" | \"closed\";\n open_time: string;\n close_time: string | null;\n close_price: number | null;\n pnl: number | null;\n}\n\nexport interface ConfirmedSignal {\n signal_id: string;\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level?: number | null;\n status: \"confirmed\" | \"closed\" | \"invalidated\";\n timestamp: string;\n}\n",[],[176,223],"99d8ffe4-af88-4875-bc76-3897cef6004d","telegram.ts","9a67f7f2-798d-11f1-a357-1607ee4eb77e",3,["D",1783378451288],"/**\n * Telegram alert sender for Risk Guardian\n */\n\nexport async function sendTelegramMessage(\n text: string,\n options?: {\n parseMode?: \"HTML\" | \"MarkdownV2\" | \"Markdown\";\n disableNotification?: boolean;\n },\n): Promise {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n if (!token || !chatId) {\n console.log(\n \"[telegram] TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID not set — skipping alert\",\n );\n return false;\n }\n\n try {\n const res = await fetch(\n `https://api.telegram.org/bot${token}/sendMessage`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: options?.parseMode ?? \"HTML\",\n disable_notification: options?.disableNotification ?? false,\n }),\n },\n );\n\n if (!res.ok) {\n const errText = await res.text();\n console.error(`[telegram] API error ${res.status}: ${errText}`);\n return false;\n }\n\n return true;\n } catch (err) {\n console.error(\"[telegram] Failed to send:\", err);\n return false;\n }\n}\n\nexport function formatRiskAlert(\n signalId: string,\n direction: string,\n level: string,\n score: number,\n currentPrice: number,\n notes: string[],\n): string {\n const emoji =\n level === \"critical\"\n ? \"🚨\"\n : level === \"danger\"\n ? \"⚠️\"\n : level === \"caution\"\n ? \"🟡\"\n : \"🟢\";\n\n const notesText = notes.length > 0\n ? notes.map((n) => ` • ${n}`).join(\"\\n\")\n : \" • No specific notes\";\n\n return [\n `${emoji} Risk Guardian Alert`,\n ``,\n `Signal: ${signalId}`,\n `Direction: ${direction}`,\n `Risk Level: ${level.toUpperCase()} (${score}/100)`,\n `Current Price: ${currentPrice}`,\n ``,\n `Details:`,\n notesText,\n ].join(\"\\n\");\n}\n\nexport function formatSignalAlert(\n signalId: string,\n direction: string,\n entry: number,\n sl: number,\n tp: number,\n): string {\n return [\n `🔔 New Position Watched`,\n ``,\n `Signal: ${signalId}`,\n `Direction: ${direction}`,\n `Entry: ${entry}`,\n `SL: ${sl}`,\n `TP: ${tp}`,\n ``,\n `Risk Guardian is now monitoring this trade in real-time.`,\n ].join(\"\\n\");\n}\n\nexport function formatCloseAlert(\n signalId: string,\n direction: string,\n status: string,\n closePrice: number,\n entryPrice: number,\n): string {\n const pnlPercent =\n direction === \"LONG\"\n ? (((closePrice - entryPrice) / entryPrice) * 100).toFixed(2)\n : (((entryPrice - closePrice) / entryPrice) * 100).toFixed(2);\n\n const emoji = status === \"invalidated\" ? \"❌\" : \"✅\";\n\n return [\n `${emoji} Position ${status}`,\n ``,\n `Signal: ${signalId}`,\n `Direction: ${direction}`,\n `Entry: ${entryPrice}`,\n `Close: ${closePrice}`,\n `P&L: ${parseFloat(pnlPercent) >= 0 ? \"+\" : \"\"}${pnlPercent}%`,\n ].join(\"\\n\");\n}\n",[],[176,230],"25f37483-f9ff-4552-9377-c556b5a05799","signal-poller.ts","a96e2d70-798d-11f1-8ab2-1607ee4eb77e",9,["D",1783378848213],"import type { ConfirmedSignal, Position } from \"./types.ts\";\nimport {\n initDB,\n createPosition,\n getPositionBySignal,\n closePosition,\n getActivePositions,\n addAlert,\n openDemoTrade,\n} from \"./db.ts\";\nimport {\n sendTelegramMessage,\n formatSignalAlert,\n formatCloseAlert,\n} from \"./telegram.ts\";\n\n/**\n * Signal Poller — fetches confirmed signals from external gold trading bots\n *\n * Tries multiple signal sources (gold-confirm bot + main signal bot)\n * across several possible API paths, then processes:\n * 1. New confirmed signals → creates a position + demo trade + Telegram alert\n * 2. Signals that changed to closed/invalidated → mirrors that status here\n */\n\n// All known signal sources — tried in order\nconst SIGNAL_SOURCES: string[] = [\n Deno.env.get(\"GOLD_CONFIRM_URL\") ?? \"https://gold-confirm.val.run\",\n Deno.env.get(\"MAIN_SIGNAL_BOT_URL\") ??\n \"https://weruweruu--6836bf0471e311f1af651607ee4eb77e.web.val.run\",\n].filter(Boolean);\n\n// Possible API paths to try on each source\nconst API_PATHS = [\n \"/api/signals\",\n \"/signals\",\n \"/api/confirmed\",\n \"/api/v1/signals\",\n \"/api/signal\",\n \"/api/data\",\n \"/api\",\n];\n\nasync function fetchSignalsFromSources(): Promise<{\n signals: ConfirmedSignal[];\n source: string;\n} | null> {\n for (const baseUrl of SIGNAL_SOURCES) {\n for (const path of API_PATHS) {\n try {\n const url = `${baseUrl}${path}`;\n const res = await fetch(url, {\n headers: { Accept: \"application/json\" },\n signal: AbortSignal.timeout(8000),\n });\n if (!res.ok) continue;\n\n const contentType = res.headers.get(\"content-type\") ?? \"\";\n if (!contentType.includes(\"json\")) continue;\n\n const data = await res.json();\n const signals: ConfirmedSignal[] = Array.isArray(data)\n ? data\n : (data.signals ?? data.data ?? data.confirmed ?? []);\n if (signals.length > 0) {\n console.log(\n `[poller] Found ${signals.length} signals at ${url}`,\n );\n return { signals, source: url };\n }\n } catch {\n continue;\n }\n }\n }\n return null;\n}\n\nexport async function pollSignals(): Promise<{\n newPositions: number;\n closedPositions: number;\n errors: string[];\n source: string | null;\n}> {\n await initDB();\n const errors: string[] = [];\n let newPositions = 0;\n let closedPositions = 0;\n let source: string | null = null;\n\n const result = await fetchSignalsFromSources();\n if (!result) {\n errors.push(\n \"No signal API found on any source. Use POST /api/signals/webhook to inject signals manually.\",\n );\n return { newPositions, closedPositions, errors, source: null };\n }\n\n source = result.source;\n const signals = result.signals;\n\n for (const sig of signals) {\n try {\n const existing = await getPositionBySignal(sig.signal_id);\n\n if (!existing && sig.status === \"confirmed\") {\n const pos = await createPosition(sig);\n newPositions++;\n\n await openDemoTrade(\n pos.id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n );\n\n const msg = formatSignalAlert(\n sig.signal_id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n );\n const sent = await sendTelegramMessage(msg);\n await addAlert(\n pos.id,\n \"new_position\",\n null,\n `New position opened: ${sig.direction} @ ${sig.entry_price}`,\n sent ? 1 : 0,\n );\n } else if (\n existing &&\n existing.status === \"watching\" &&\n (sig.status === \"closed\" || sig.status === \"invalidated\")\n ) {\n const closePrice = sig.entry_price;\n await closePosition(sig.signal_id, closePrice, sig.status);\n closedPositions++;\n\n const msg = formatCloseAlert(\n sig.signal_id,\n existing.direction,\n sig.status,\n closePrice,\n existing.entry_price,\n );\n const sent = await sendTelegramMessage(msg);\n await addAlert(\n existing.id,\n \"position_closed\",\n sig.status,\n `Position ${sig.status}: ${existing.direction} ${sig.signal_id}`,\n sent ? 1 : 0,\n );\n\n const { closeDemoTrade, getOpenDemoTrades } = await import(\"./db.ts\");\n const openTrades = await getOpenDemoTrades();\n const matchingTrade = openTrades.find(\n (t) => t.position_id === existing.id,\n );\n if (matchingTrade) {\n const pnl =\n existing.direction === \"LONG\"\n ? (closePrice - matchingTrade.entry_price) *\n matchingTrade.lot_size * 100\n : (matchingTrade.entry_price - closePrice) *\n matchingTrade.lot_size * 100;\n await closeDemoTrade(matchingTrade.id, closePrice, pnl, pnl > 0);\n }\n }\n } catch (err) {\n errors.push(`Error processing signal ${sig.signal_id}: ${err.message}`);\n }\n }\n\n return { newPositions, closedPositions, errors, source };\n}\n\n/**\n * Webhook receiver — external bots can POST confirmed signals here.\n * Body should be a ConfirmedSignal or array of ConfirmedSignal.\n */\nexport async function receiveWebhookSignal(\n body: ConfirmedSignal | ConfirmedSignal[],\n): Promise<{ received: number; created: number; skipped: number }> {\n await initDB();\n const signals = Array.isArray(body) ? body : [body];\n let created = 0;\n let skipped = 0;\n\n for (const sig of signals) {\n const existing = await getPositionBySignal(sig.signal_id);\n if (existing) {\n skipped++;\n continue;\n }\n\n if (sig.status !== \"confirmed\") {\n skipped++;\n continue;\n }\n\n const pos = await createPosition(sig);\n created++;\n\n await openDemoTrade(\n pos.id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n );\n\n const msg = formatSignalAlert(\n sig.signal_id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n );\n const sent = await sendTelegramMessage(msg);\n await addAlert(\n pos.id,\n \"new_position\",\n null,\n `Webhook position opened: ${sig.direction} @ ${sig.entry_price}`,\n sent ? 1 : 0,\n );\n }\n\n return { received: signals.length, created, skipped };\n}\n\n/**\n * Manual signal injection — allows pushing a signal directly.\n */\nexport async function injectSignal(\n sig: ConfirmedSignal,\n): Promise {\n await initDB();\n const existing = await getPositionBySignal(sig.signal_id);\n if (existing) return existing;\n\n const pos = await createPosition(sig);\n await openDemoTrade(\n pos.id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n );\n\n const msg = formatSignalAlert(\n sig.signal_id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n );\n const sent = await sendTelegramMessage(msg);\n await addAlert(\n pos.id,\n \"new_position\",\n null,\n `Manual position opened: ${sig.direction} @ ${sig.entry_price}`,\n sent ? 1 : 0,\n );\n\n return pos;\n}\n",[],[176,238],"abb692ad-80e0-4fab-a400-b7b7f3c0a9b7","risk.ts","9a759146-798d-11f1-8123-1607ee4eb77e",5,["D",1783378451302],"import type {\n RiskScoreInput,\n RiskScoreResult,\n RiskLevel,\n} from \"./types.ts\";\n\n/**\n * Risk Guardian — Risk Scoring Engine\n *\n * Scores a position 0–100 based on:\n * - Distance to SL (closer = higher risk)\n * - Distance to TP (closer = lower risk)\n * - Price momentum (moving toward SL = higher risk)\n * - DXY correlation (DXY up typically hurts XAU/USD longs)\n * - Invalidation proximity\n *\n * 0 = completely safe, 100 = maximum danger\n */\n\nfunction pctDistance(current: number, target: number): number {\n return Math.abs(((current - target) / current) * 100);\n}\n\nfunction clampScore(score: number): number {\n return Math.max(0, Math.min(100, Math.round(score)));\n}\n\nfunction levelFromScore(score: number): RiskLevel {\n if (score >= 80) return \"critical\";\n if (score >= 60) return \"danger\";\n if (score >= 35) return \"caution\";\n return \"safe\";\n}\n\nexport function calculateRiskScore(input: RiskScoreInput): RiskScoreResult {\n const notes: string[] = [];\n let score = 0;\n\n const { direction, entry_price, sl_price, tp_price, current_price, dxy_value, prev_price, invalidation_level } =\n input;\n\n // 1. Distance to SL — weighted heaviest (40 pts max)\n // If price is within 0.3% of SL, that's near-maximum danger\n const distToSL = pctDistance(current_price, sl_price);\n const slContribution = Math.min(40, (0.5 / Math.max(distToSL, 0.01)) * 8);\n score += slContribution;\n if (distToSL < 0.3) {\n notes.push(`⚠️ Price within ${distToSL.toFixed(3)}% of SL — imminent risk`);\n } else if (distToSL < 0.7) {\n notes.push(`Price ${distToSL.toFixed(2)}% from SL — approaching danger zone`);\n }\n\n // 2. Distance to TP — inverse (closer to TP = safer) (15 pts max negative)\n const distToTP = pctDistance(current_price, tp_price);\n if (distToTP < 0.5) {\n score -= 15;\n notes.push(`✅ Near TP (${distToTP.toFixed(2)}% away) — strong position`);\n } else if (distToTP < 1.5) {\n score -= 8;\n notes.push(`Approaching TP (${distToTP.toFixed(2)}% away)`);\n }\n\n // 3. Momentum — is price moving toward SL? (25 pts max)\n if (prev_price !== null && prev_price !== undefined) {\n const priceChange = current_price - prev_price;\n const movingTowardSL =\n (direction === \"LONG\" && priceChange < 0) ||\n (direction === \"SHORT\" && priceChange > 0);\n\n if (movingTowardSL) {\n const momentumStrength = Math.abs(priceChange / prev_price) * 100;\n const momentumScore = Math.min(25, momentumStrength * 100);\n score += momentumScore;\n if (momentumStrength > 0.1) {\n notes.push(\n `📉 Momentum against position: ${momentumStrength.toFixed(3)}% move toward SL`,\n );\n } else {\n notes.push(`Slight adverse momentum detected`);\n }\n } else {\n const momentumStrength = Math.abs(priceChange / prev_price) * 100;\n score -= Math.min(10, momentumStrength * 50);\n if (momentumStrength > 0.1) {\n notes.push(\n `📈 Momentum favorable: ${momentumStrength.toFixed(3)}% move toward TP`,\n );\n }\n }\n }\n\n // 4. DXY Correlation (15 pts max)\n // DXY up → XAU/USD down (typically). Hurts longs, helps shorts.\n if (dxy_value !== null && dxy_value !== undefined) {\n // We don't have a baseline DXY, so we use a simple heuristic:\n // DXY above 104 = dollar strength, below 103 = dollar weakness\n if (direction === \"LONG\") {\n if (dxy_value > 105) {\n score += 15;\n notes.push(`💵 DXY at ${dxy_value.toFixed(2)} — strong headwind for longs`);\n } else if (dxy_value > 104) {\n score += 8;\n notes.push(`DXY at ${dxy_value.toFixed(2)} — moderate headwind for longs`);\n }\n } else {\n // SHORT\n if (dxy_value < 102) {\n score += 15;\n notes.push(`💵 DXY at ${dxy_value.toFixed(2)} — weak dollar, headwind for shorts`);\n } else if (dxy_value < 103) {\n score += 8;\n notes.push(`DXY at ${dxy_value.toFixed(2)} — slight headwind for shorts`);\n }\n }\n }\n\n // 5. Invalidation level proximity (10 pts max)\n if (invalidation_level !== null && invalidation_level !== undefined) {\n const distToInvalidation = pctDistance(current_price, invalidation_level);\n if (distToInvalidation < 0.3) {\n score += 10;\n notes.push(\n `🚨 Within ${distToInvalidation.toFixed(3)}% of invalidation level`,\n );\n } else if (distToInvalidation < 0.7) {\n score += 5;\n notes.push(`Approaching invalidation level (${distToInvalidation.toFixed(2)}%)`);\n }\n }\n\n // 6. Unrealized P&L factor — if deeply underwater, risk increases\n const pnlPercent =\n direction === \"LONG\"\n ? ((current_price - entry_price) / entry_price) * 100\n : ((entry_price - current_price) / entry_price) * 100;\n\n if (pnlPercent < -0.5) {\n score += Math.min(15, Math.abs(pnlPercent) * 10);\n notes.push(`📉 Position underwater: ${pnlPercent.toFixed(2)}% unrealized loss`);\n } else if (pnlPercent > 1.0) {\n score -= 5;\n notes.push(`💰 Position in profit: +${pnlPercent.toFixed(2)}%`);\n }\n\n const finalScore = clampScore(score);\n const level = levelFromScore(finalScore);\n\n return {\n score: finalScore,\n level,\n distance_to_sl: parseFloat(distToSL.toFixed(3)),\n distance_to_tp: parseFloat(distToTP.toFixed(3)),\n notes,\n };\n}\n\n// Threshold for sending a Telegram alert\nexport function shouldAlert(\n result: RiskScoreResult,\n prevLevel: RiskLevel | null,\n): boolean {\n const levelOrder: RiskLevel[] = [\"safe\", \"caution\", \"danger\", \"critical\"];\n const currentIdx = levelOrder.indexOf(result.level);\n const prevIdx = prevLevel ? levelOrder.indexOf(prevLevel) : -1;\n\n // Alert if level escalated, or if critical\n return currentIdx > prevIdx || result.level === \"critical\";\n}\n",[],[176,246],"ed40dc6d-5a27-426c-9273-ccd5174667e8","price.ts","7840a60a-798e-11f1-b895-1607ee4eb77e",8,["D",1783378823490],"/**\n * XAU/USD Price Feed\n *\n * Fetches the current gold spot price from free APIs.\n * Tries multiple sources for redundancy.\n */\n\ninterface PriceResult {\n price: number;\n source: string;\n timestamp: string;\n}\n\nconst SOURCES = [\n {\n name: \"gold-api.com\",\n url: \"https://api.gold-api.com/price/XAU\",\n parse: (data: any) => data?.price,\n },\n {\n name: \"metals.live\",\n url: \"https://api.metals.dev/v1/latest?api_key=demo¤cy=USD&unit=toz\",\n parse: (data: any) => data?.metals?.gold,\n },\n];\n\nexport async function getGoldPrice(): Promise {\n for (const source of SOURCES) {\n try {\n const res = await fetch(source.url, {\n headers: { Accept: \"application/json\" },\n signal: AbortSignal.timeout(8000),\n });\n if (!res.ok) continue;\n const data = await res.json();\n const price = source.parse(data);\n if (typeof price === \"number\" && price > 0) {\n return {\n price,\n source: source.name,\n timestamp: new Date().toISOString(),\n };\n }\n } catch (err) {\n console.log(`[price] ${source.name} failed: ${err.message}`);\n continue;\n }\n }\n console.error(\"[price] All price sources failed\");\n return null;\n}\n\n/**\n * Get DXY (US Dollar Index) — used by the risk engine.\n * Uses a simple free forex API as a proxy.\n */\nexport async function getDXY(): Promise {\n try {\n const res = await fetch(\n \"https://api.exchangerate.host/latest?base=USD&symbols=EUR,GBP,JPY,CAD,CHF,SEK\",\n { signal: AbortSignal.timeout(8000) },\n );\n if (!res.ok) return null;\n const data = await res.json();\n // Approximate DXY from exchange rates (simplified)\n const rates = data.rates;\n if (!rates) return null;\n // DXY weights: EUR 57.6%, JPY 13.6%, GBP 11.9%, CAD 9.1%, SEK 4.2%, CHF 3.6%\n const dxy =\n 50.14348112 *\n (Math.pow(rates.EUR, -0.576) *\n Math.pow(rates.JPY, -0.136) *\n Math.pow(rates.GBP, -0.119) *\n Math.pow(rates.CAD, -0.091) *\n Math.pow(rates.SEK, -0.042) *\n Math.pow(rates.CHF, -0.036));\n return parseFloat(dxy.toFixed(2));\n } catch (err) {\n console.log(`[price] DXY fetch failed: ${err.message}`);\n return null;\n }\n}\n",[],[176,254],"cd178bc0-6908-4515-a480-f56b8420e250","demo.ts","abbde99e-798d-11f1-8123-1607ee4eb77e",7,["D",1783378480365],"import {\n initDB,\n getDemoAccount,\n updateDemoAccount,\n getOpenDemoTrades,\n closeDemoTrade,\n getAllDemoTrades,\n getActivePositions,\n} from \"./db.ts\";\nimport type { DemoAccount, DemoTrade, Position } from \"./types.ts\";\n\n/**\n * Demo Account — fully automatic paper trading\n *\n * When a signal is detected → a demo trade auto-opens\n * When a position is closed/invalidated → the demo trade auto-closes\n * When SL or TP is hit by the live price → the demo trade auto-closes\n *\n * This module provides utilities for updating demo equity in real-time\n * and auto-closing trades when SL/TP is breached.\n */\n\n// XAU/USD contract: 1 lot = 100 oz, $1 move = $100 per lot\nconst CONTRACT_SIZE = 100;\nconst PIP_VALUE_PER_LOT = 100;\n\nexport function calculatePnL(\n direction: string,\n entryPrice: number,\n currentPrice: number,\n lotSize: number,\n): number {\n const priceDiff =\n direction === \"LONG\"\n ? currentPrice - entryPrice\n : entryPrice - currentPrice;\n return priceDiff * lotSize * CONTRACT_SIZE;\n}\n\nexport async function updateDemoEquity(currentPrice: number): Promise<{\n balance: number;\n equity: number;\n unrealizedPnL: number;\n}> {\n await initDB();\n const acct = await getDemoAccount();\n const openTrades = await getOpenDemoTrades();\n\n let unrealizedPnL = 0;\n for (const trade of openTrades) {\n unrealizedPnL += calculatePnL(\n trade.direction,\n trade.entry_price,\n currentPrice,\n trade.lot_size,\n );\n }\n\n const equity = acct.balance + unrealizedPnL;\n await updateDemoAccount({ equity });\n\n return {\n balance: acct.balance,\n equity,\n unrealizedPnL,\n };\n}\n\n/**\n * Check if any open demo trades have hit SL or TP\n * Called by the VPS worker on every tick with the current price\n */\nexport async function checkDemoSLTP(currentPrice: number): Promise<{\n closed: Array<{ trade: DemoTrade; pnl: number; reason: string }>;\n}> {\n await initDB();\n const openTrades = await getOpenDemoTrades();\n const closed: Array<{ trade: DemoTrade; pnl: number; reason: string }> = [];\n\n for (const trade of openTrades) {\n let hit = false;\n let reason = \"\";\n\n if (trade.direction === \"LONG\") {\n if (currentPrice <= trade.sl_price) {\n hit = true;\n reason = \"SL hit\";\n } else if (currentPrice >= trade.tp_price) {\n hit = true;\n reason = \"TP hit\";\n }\n } else {\n if (currentPrice >= trade.sl_price) {\n hit = true;\n reason = \"SL hit\";\n } else if (currentPrice <= trade.tp_price) {\n hit = true;\n reason = \"TP hit\";\n }\n }\n\n if (hit) {\n const pnl = calculatePnL(\n trade.direction,\n trade.entry_price,\n currentPrice,\n trade.lot_size,\n );\n await closeDemoTrade(trade.id, currentPrice, pnl, pnl > 0);\n closed.push({ trade, pnl, reason });\n }\n }\n\n return { closed };\n}\n\nexport async function getDemoStats() {\n await initDB();\n const [acct, openTrades, allTrades, activePositions] = await Promise.all([\n getDemoAccount(),\n getOpenDemoTrades(),\n getAllDemoTrades(100),\n getActivePositions(),\n ]);\n\n const winRate = acct.total_trades > 0\n ? (acct.wins / acct.total_trades) * 100\n : 0;\n\n const totalPnL = acct.balance - acct.starting_balance;\n const closedTrades = allTrades.filter((t) => t.status === \"closed\");\n const avgWin = acct.wins > 0\n ? closedTrades.filter((t) => (t.pnl ?? 0) > 0).reduce(\n (sum, t) => sum + (t.pnl ?? 0),\n 0,\n ) / acct.wins\n : 0;\n const avgLoss = acct.losses > 0\n ? closedTrades.filter((t) => (t.pnl ?? 0) < 0).reduce(\n (sum, t) => sum + (t.pnl ?? 0),\n 0,\n ) / acct.losses\n : 0;\n\n return {\n ...acct,\n winRate: parseFloat(winRate.toFixed(1)),\n totalPnL: parseFloat(totalPnL.toFixed(2)),\n openTrades: openTrades.length,\n avgWin: parseFloat(avgWin.toFixed(2)),\n avgLoss: parseFloat(avgLoss.toFixed(2)),\n profitFactor: avgLoss !== 0\n ? parseFloat((avgWin / Math.abs(avgLoss)).toFixed(2))\n : 0,\n };\n}\n",[],[176,262],"45f75799-29a4-40f7-a946-04a75e9bfd2d","db.ts","9a6ebd3a-798d-11f1-bab7-1607ee4eb77e",4,["D",1783378451294],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type {\n Position,\n RiskHistoryEntry,\n DemoAccount,\n DemoTrade,\n ConfirmedSignal,\n} from \"./types.ts\";\n\n// ── Schema Setup ──────────────────────────────────────────────\nexport async function initDB() {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS positions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n signal_id TEXT UNIQUE NOT NULL,\n direction TEXT NOT NULL,\n entry_price REAL NOT NULL,\n sl_price REAL NOT NULL,\n tp_price REAL NOT NULL,\n invalidation_level REAL,\n status TEXT NOT NULL DEFAULT 'watching',\n opened_at TEXT NOT NULL DEFAULT (datetime('now')),\n closed_at TEXT,\n close_price REAL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS risk_history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n position_id INTEGER NOT NULL,\n timestamp TEXT NOT NULL DEFAULT (datetime('now')),\n risk_score REAL NOT NULL,\n risk_level TEXT NOT NULL,\n current_price REAL NOT NULL,\n distance_to_sl REAL NOT NULL,\n distance_to_tp REAL NOT NULL,\n dxy_value REAL,\n notes TEXT,\n FOREIGN KEY (position_id) REFERENCES positions(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS demo_account (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n starting_balance REAL NOT NULL DEFAULT 10000,\n balance REAL NOT NULL DEFAULT 10000,\n equity REAL NOT NULL DEFAULT 10000,\n total_trades INTEGER NOT NULL DEFAULT 0,\n wins INTEGER NOT NULL DEFAULT 0,\n losses INTEGER NOT NULL DEFAULT 0\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS demo_trades (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n position_id INTEGER,\n direction TEXT NOT NULL,\n entry_price REAL NOT NULL,\n lot_size REAL NOT NULL DEFAULT 0.1,\n sl_price REAL NOT NULL,\n tp_price REAL NOT NULL,\n status TEXT NOT NULL DEFAULT 'open',\n open_time TEXT NOT NULL DEFAULT (datetime('now')),\n close_time TEXT,\n close_price REAL,\n pnl REAL,\n FOREIGN KEY (position_id) REFERENCES positions(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS alerts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n position_id INTEGER,\n timestamp TEXT NOT NULL DEFAULT (datetime('now')),\n alert_type TEXT NOT NULL,\n risk_level TEXT,\n message TEXT NOT NULL,\n sent_telegram INTEGER NOT NULL DEFAULT 0,\n FOREIGN KEY (position_id) REFERENCES positions(id)\n )`,\n },\n // Seed demo account if not exists\n {\n sql: `INSERT OR IGNORE INTO demo_account (id) VALUES (1)`,\n },\n ]);\n}\n\n// ── Positions ─────────────────────────────────────────────────\nexport async function createPosition(\n sig: ConfirmedSignal,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO positions (signal_id, direction, entry_price, sl_price, tp_price, invalidation_level)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [\n sig.signal_id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n sig.invalidation_level ?? null,\n ],\n });\n const result = await sqlite.execute({\n sql: `SELECT * FROM positions WHERE signal_id = ?`,\n args: [sig.signal_id],\n });\n return result.rows[0] as unknown as Position;\n}\n\nexport async function getPositionBySignal(\n signalId: string,\n): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM positions WHERE signal_id = ?`,\n args: [signalId],\n });\n return (result.rows[0] as unknown as Position) ?? null;\n}\n\nexport async function getActivePositions(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM positions WHERE status = 'watching' ORDER BY opened_at DESC`,\n );\n return result.rows as unknown as Position[];\n}\n\nexport async function getAllPositions(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM positions ORDER BY opened_at DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows as unknown as Position[];\n}\n\nexport async function closePosition(\n signalId: string,\n closePrice: number,\n status: \"closed\" | \"invalidated\",\n): Promise {\n await sqlite.execute({\n sql: `UPDATE positions SET status = ?, closed_at = datetime('now'), close_price = ? WHERE signal_id = ?`,\n args: [status, closePrice, signalId],\n });\n}\n\n// ── Risk History ──────────────────────────────────────────────\nexport async function addRiskHistory(\n entry: Omit,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO risk_history (position_id, risk_score, risk_level, current_price, distance_to_sl, distance_to_tp, dxy_value, notes)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n entry.position_id,\n entry.risk_score,\n entry.risk_level,\n entry.current_price,\n entry.distance_to_sl,\n entry.distance_to_tp,\n entry.dxy_value,\n entry.notes,\n ],\n });\n}\n\nexport async function getRiskHistory(\n positionId: number,\n limit = 100,\n): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM risk_history WHERE position_id = ? ORDER BY timestamp DESC LIMIT ?`,\n args: [positionId, limit],\n });\n return result.rows as unknown as RiskHistoryEntry[];\n}\n\nexport async function getRecentRiskHistory(\n limit = 50,\n): Promise {\n const result = await sqlite.execute({\n sql: `SELECT rh.*, p.signal_id, p.direction FROM risk_history rh\n JOIN positions p ON rh.position_id = p.id\n ORDER BY rh.timestamp DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows as unknown as (RiskHistoryEntry & {\n signal_id: string;\n direction: string;\n })[];\n}\n\n// ── Alerts ────────────────────────────────────────────────────\nexport async function addAlert(\n positionId: number | null,\n alertType: string,\n riskLevel: string | null,\n message: string,\n sentTelegram = 0,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO alerts (position_id, alert_type, risk_level, message, sent_telegram)\n VALUES (?, ?, ?, ?, ?)`,\n args: [positionId, alertType, riskLevel, message, sentTelegram],\n });\n}\n\nexport async function getRecentAlerts(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: `SELECT a.*, p.signal_id, p.direction FROM alerts a\n LEFT JOIN positions p ON a.position_id = p.id\n ORDER BY a.timestamp DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows;\n}\n\n// ── Demo Account ──────────────────────────────────────────────\nexport async function getDemoAccount(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM demo_account WHERE id = 1`,\n );\n return result.rows[0] as unknown as DemoAccount;\n}\n\nexport async function updateDemoAccount(\n updates: Partial,\n): Promise {\n const fields: string[] = [];\n const values: any[] = [];\n for (const [key, val] of Object.entries(updates)) {\n fields.push(`${key} = ?`);\n values.push(val);\n }\n if (fields.length === 0) return;\n await sqlite.execute({\n sql: `UPDATE demo_account SET ${fields.join(\", \")} WHERE id = 1`,\n args: values,\n });\n}\n\nexport async function openDemoTrade(\n positionId: number,\n direction: string,\n entryPrice: number,\n slPrice: number,\n tpPrice: number,\n lotSize = 0.1,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO demo_trades (position_id, direction, entry_price, lot_size, sl_price, tp_price)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [positionId, direction, entryPrice, lotSize, slPrice, tpPrice],\n });\n const result = await sqlite.execute(\n `SELECT * FROM demo_trades ORDER BY id DESC LIMIT 1`,\n );\n return result.rows[0] as unknown as DemoTrade;\n}\n\nexport async function closeDemoTrade(\n tradeId: number,\n closePrice: number,\n pnl: number,\n won: boolean,\n): Promise {\n await sqlite.batch([\n {\n sql: `UPDATE demo_trades SET status = 'closed', close_time = datetime('now'), close_price = ?, pnl = ? WHERE id = ?`,\n args: [closePrice, pnl, tradeId],\n },\n {\n sql: `UPDATE demo_account SET \n balance = balance + ?,\n total_trades = total_trades + 1,\n ${won ? \"wins = wins + 1\" : \"losses = losses + 1\"}\n WHERE id = 1`,\n args: [pnl],\n },\n ]);\n}\n\nexport async function getOpenDemoTrades(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM demo_trades WHERE status = 'open' ORDER BY open_time DESC`,\n );\n return result.rows as unknown as DemoTrade[];\n}\n\nexport async function getAllDemoTrades(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM demo_trades ORDER BY open_time DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows as unknown as DemoTrade[];\n}\n\n// ── Stats ─────────────────────────────────────────────────────\nexport async function getStats() {\n const [positions, activeCount, demoAcct, recentAlerts] = await Promise.all([\n sqlite.execute(`SELECT COUNT(*) as count FROM positions`),\n sqlite.execute(\n `SELECT COUNT(*) as count FROM positions WHERE status = 'watching'`,\n ),\n getDemoAccount(),\n sqlite.execute(\n `SELECT COUNT(*) as count FROM alerts WHERE sent_telegram = 1`,\n ),\n ]);\n return {\n total_positions: (positions.rows[0] as any).count,\n active_positions: (activeCount.rows[0] as any).count,\n demo_balance: demoAcct.balance,\n demo_equity: demoAcct.equity,\n demo_total_trades: demoAcct.total_trades,\n demo_wins: demoAcct.wins,\n demo_losses: demoAcct.losses,\n total_alerts: (recentAlerts.rows[0] as any).count,\n };\n}\n",[],[176,270],["D",1783377986977],[206,207,208,209,210,211,212],[176],"005ad02a-2766-4515-835d-db5276613cee","index.tsx","019f399c-53b8-772f-829b-41904fe42d5b",12,["D",1783379135898],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./components/App.tsx\";\n\nconst root = document.getElementById(\"root\");\nif (!root) throw new Error(\"No root element\");\n\ncreateRoot(root).render();\n",[],[183,281],"9846e998-1065-44d8-88fc-24baff2502b8","index.html","019f399c-53b8-772f-829b-3e8fb19d5c60",11,["D",1783379135188],"\n\n \n \n \n 🛡️ Risk Guardian — XAU/USD Monitor\n \n \n \n \n

\n \n \n \n\n",[],[183,289],"9c5a4fc4-e85b-49b0-943f-601582dcd343","favicon.svg","019f399c-53b8-772f-829b-3bc087a76447",["D",1783377974103],"\n",[],[183,297],"5184cd26-6554-4886-bed2-882e5d90ddfb","019f399c-53b8-772f-829b-356993744ac6",["D",1783379177499],[],[183,308,38],"components","7cf1b057-9b48-403c-b14d-051cab3c3438","Counter.tsx","019f399c-53b8-772f-829b-311e83ada280",["D",1783377974103],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\n\nexport function Counter() {\n const [count, setCount] = useState(0);\n return (\n

\n Clicked\n setCount((c) => c + 1)}\n class=\"bg-blue-500 hover:bg-blue-600 text-white font-medium px-4 py-2 rounded-lg transition-colors cursor-pointer\"\n >\n {count}\n \n times\n

\n );\n}\n",[],[183,308,310],"f3de35bb-de82-467f-b270-fda60cff369a","App.tsx","019f399c-53b8-772f-829b-2e007a6a5e28",13,["D",1783379177467],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState, useEffect, useCallback } from \"https://esm.sh/react@18.2.0\";\nimport { RiskCard } from \"./RiskCard.tsx\";\nimport { StatsBar } from \"./StatsBar.tsx\";\nimport { AlertFeed } from \"./AlertFeed.tsx\";\nimport { DemoPanel } from \"./DemoPanel.tsx\";\n\ntype Tab = \"dashboard\" | \"positions\" | \"alerts\" | \"demo\";\n\nexport function App() {\n const [tab, setTab] = useState(\"dashboard\");\n const [price, setPrice] = useState(null);\n const [risk, setRisk] = useState(null);\n const [stats, setStats] = useState(null);\n const [alerts, setAlerts] = useState([]);\n const [demo, setDemo] = useState(null);\n const [demoTrades, setDemoTrades] = useState([]);\n const [positions, setPositions] = useState([]);\n const [loading, setLoading] = useState(true);\n const [error, setError] = useState(null);\n\n const api = (path: string) => fetch(path).then((r) => r.ok ? r.json() : null).catch(() => null);\n\n const refresh = useCallback(async () => {\n const [p, r, s, a, d, dt, pos] = await Promise.all([\n api(\"/api/price\"),\n api(\"/api/risk\"),\n api(\"/api/stats\"),\n api(\"/api/alerts\"),\n api(\"/api/demo\"),\n api(\"/api/demo/trades\"),\n api(\"/api/positions\"),\n ]);\n setPrice(p);\n setRisk(r);\n setStats(s);\n setAlerts(a ?? []);\n setDemo(d);\n setDemoTrades(dt ?? []);\n setPositions(pos ?? []);\n setLoading(false);\n setError(null);\n }, []);\n\n useEffect(() => {\n refresh();\n const id = setInterval(refresh, 15000);\n return () => clearInterval(id);\n }, [refresh]);\n\n const tabs: { key: Tab; label: string; icon: string }[] = [\n { key: \"dashboard\", label: \"Dashboard\", icon: \"📊\" },\n { key: \"positions\", label: \"Positions\", icon: \"📈\" },\n { key: \"alerts\", label: \"Alerts\", icon: \"🔔\" },\n { key: \"demo\", label: \"Demo Account\", icon: \"💰\" },\n ];\n\n if (loading) {\n return (\n

🛡️ Loading Risk Guardian…

\n );\n }\n\n return (\n

\n {/* Header */}\n

\n 🛡️\n

Risk Guardian

XAU/USD Signal Monitoring & Risk Engine

\n {price && (\n

Gold (XAU/USD)

${price.gold?.toFixed(2)}

\n {price.dxy && (\n

DXY

{price.dxy?.toFixed(2)}

\n )}\n 🔄\n

\n )}\n

\n\n {/* Tabs */}\n \n\n {/* Content */}\n {tab === \"dashboard\" && (\n

\n \n

Active Positions — Live Risk

\n {risk?.positions?.length > 0 ? (\n

\n {risk.positions.map((p: any) => (\n \n ))}\n

\n ) : (\n

📭 No active positions being monitored

\n Signals from gold-confirm and main signal bot will appear here automatically.\n

\n Or POST a signal to /api/signals/webhook\n

\n )}\n

Recent Alerts

\n \n

\n )}\n\n {tab === \"positions\" && (\n

All Positions ({positions.length})

\n \n \n \n \n \n \n \n \n \n \n \n \n \n {positions.map((p: any) => (\n \n \n \n \n \n \n \n \n \n ))}\n \n

Signal ID	Direction	Entry	SL	TP	Status	Opened
{p.signal_id}	\n \n {p.direction === \"LONG\" ? \"🟢 LONG\" : \"🔴 SHORT\"}\n \n	{p.entry_price?.toFixed(2)}	{p.sl_price?.toFixed(2)}	{p.tp_price?.toFixed(2)}	\n {p.status}\n	{p.opened_at}

\n )}\n\n {tab === \"alerts\" && (\n

Alert History

\n \n

\n )}\n\n {tab === \"demo\" && (\n \n )}\n\n {/* Footer */}\n \n

\n );\n}\n",[],[183,308,317],"aca8e727-efad-4577-9fa8-a29735808a6a",["D",1783377974103],[199,200,201],[183,308],["D",1783377974103],[198,202,203,204],[183],["D",1783377974103],["D",1789525245864],{"_110":109,"_118":114},{"_110":109,"_111":112,"_113":114,"_19":61,"_115":116,"_117":30},{"_13":95,"_37":96,"_48":47,"_97":49,"_98":99,"_100":101,"_102":55,"_103":104,"_105":106,"_107":50,"_108":109},"ctx",{"_88":-5,"_140":369,"_370":371,"_372":373,"_374":30,"_375":30,"_376":30,"_377":65,"_378":-5,"_379":-7,"_380":-7,"_381":69,"_382":30,"_383":30,"_384":-5,"_385":30,"_386":30,"_387":30,"_388":-5},"ENV",{"_340":341,"_342":343,"_344":96,"_345":346,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368},"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"]

Diff · v14