[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_327":328,"_329":330},"routes/_app.x.$handle.$name",{"_111":110,"_38":51,"_120":97,"_33":121,"_13":14,"_122":-5,"_11":123,"_124":125,"_126":127,"_128":129,"_130":131,"_26":-5,"_132":133,"_134":135,"_136":31,"_137":138,"_139":66,"_140":-5,"_141":-5,"_142":143},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":61,"_19":62,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":70,"_71":72,"_73":74,"_75":76,"_77":78,"_79":-5,"_80":81,"_82":81,"_83":84,"_85":84,"_86":84,"_87":81,"_88":81,"_89":90,"_91":92,"_93":94,"_95":31},"version",11,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","bf00e29e-f96a-49ea-97bb-09e0bc60b927","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":26,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":39,"_40":26,"_41":42},"deleted",false,"deletedHere","path","frontend/index.html","latestPath","fileId","019f399c-53b8-772f-829b-3e8fb19d5c60","name","index.html","fileType","content","\n\n \n \n \n React Hono Val Town Starter\n \n \n \n \n

\n \n \n \n","\n\n \n \n \n 🛡️ Risk Guardian — XAU/USD Monitor\n \n \n \n \n

\n \n \n \n\n","createdAt",["D",1783379135188],"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",{"_111":110,"_119":115},"org",{"_111":110,"_112":113,"_114":115,"_19":62,"_116":117,"_118":31},"branch",{"_13":96,"_38":97,"_49":48,"_98":50,"_99":100,"_101":102,"_103":56,"_104":105,"_106":107,"_108":51,"_109":110},"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",{"_49":50,"_38":51,"_44":322,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":61,"_19":62,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":70,"_71":72,"_73":74,"_75":76,"_77":323,"_79":-5,"_80":81,"_82":81,"_83":84,"_85":84,"_86":84,"_87":81,"_88":81,"_89":324,"_91":325,"_93":326,"_95":31},"tree",[198,205,213,214],"files",[198,199,200,201,202,203,204,205,206,207,208,209,210,211,212,213,214],"counts",{"_188":70,"_189":165,"_190":70,"_191":192,"_193":194},"contents",[155,156,157,158],"upstreamProject",{"_49":105,"_38":151,"_58":152,"_60":61,"_55":56,"_89":153},"upstreamBranch",{"_49":100,"_44":144,"_145":146,"_38":97,"_98":105,"_13":147,"_99":-5,"_101":-5,"_148":149,"_53":-5,"_95":31,"_55":56,"_109":150,"_71":107,"_108":151},"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",{"_111":150,"_119":154},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789541999&sig=156ae2b8ac752fc06f52d45eab428b512e0d31e2aab99a830d8bb32149c64f0f",{"_49":183,"_38":184,"_36":185,"_161":-5,"_47":48,"_46":165,"_163":66,"_44":186,"_13":70,"_40":181,"_41":-5,"_30":31,"_168":-5,"_33":187},{"_49":176,"_38":177,"_36":178,"_161":-5,"_47":48,"_46":179,"_163":66,"_44":180,"_13":70,"_40":181,"_41":-5,"_30":31,"_168":-5,"_33":182},{"_49":170,"_38":171,"_36":172,"_161":-5,"_47":48,"_46":165,"_163":31,"_44":173,"_13":70,"_40":26,"_41":174,"_30":31,"_168":-5,"_33":175},{"_49":159,"_38":160,"_36":64,"_161":-5,"_47":48,"_46":162,"_163":31,"_44":164,"_13":165,"_40":166,"_41":167,"_30":31,"_168":51,"_33":169},"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",[160],"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",[171],"c973a0a3-2142-4571-b5da-46d4c1bcdd97","lib","bd4d577a-c696-45e0-a725-3df4ce483845",2,["D",1783377986977],"directory",[177],"2a74a97c-04f1-415b-9032-c043670177a4","frontend","019f399c-53b8-772f-829b-46f036e99f2c",["D",1783377974103],[184],"pulls","branches","forks","envVars",{"_195":70,"_197":70},"connections",{"_195":70,"_196":70},"count","unfilledCount","emptyCount",{"_49":183,"_38":184,"_36":185,"_161":-5,"_47":48,"_46":165,"_163":66,"_44":319,"_13":70,"_40":181,"_41":-5,"_30":31,"_168":-5,"_216":320,"_33":321},{"_49":315,"_38":307,"_36":302,"_161":185,"_47":48,"_46":165,"_163":66,"_44":316,"_13":70,"_40":181,"_41":-5,"_30":31,"_168":-5,"_216":317,"_33":318},{"_49":308,"_38":309,"_36":310,"_161":302,"_47":48,"_46":165,"_163":31,"_44":311,"_13":70,"_40":226,"_41":312,"_30":31,"_168":-5,"_216":313,"_33":314},{"_49":299,"_38":300,"_36":301,"_161":302,"_47":48,"_46":165,"_163":31,"_44":303,"_13":70,"_40":226,"_41":304,"_30":31,"_168":-5,"_216":305,"_33":306},{"_49":292,"_38":293,"_36":294,"_161":185,"_47":48,"_46":165,"_163":66,"_44":295,"_13":70,"_40":26,"_41":296,"_30":31,"_168":-5,"_216":297,"_33":298},{"_49":288,"_38":39,"_36":37,"_161":185,"_47":48,"_46":14,"_163":66,"_44":289,"_13":165,"_40":26,"_41":43,"_30":31,"_168":-5,"_216":290,"_33":291},{"_49":281,"_38":282,"_36":283,"_161":185,"_47":48,"_46":165,"_163":31,"_44":284,"_13":70,"_40":226,"_41":285,"_30":31,"_168":-5,"_216":286,"_33":287},{"_49":176,"_38":177,"_36":178,"_161":-5,"_47":48,"_46":179,"_163":66,"_44":278,"_13":70,"_40":181,"_41":-5,"_30":31,"_168":-5,"_216":279,"_33":280},{"_49":270,"_38":271,"_36":272,"_161":178,"_47":48,"_46":273,"_163":66,"_44":274,"_13":70,"_40":226,"_41":275,"_30":31,"_168":-5,"_216":276,"_33":277},{"_49":262,"_38":263,"_36":264,"_161":178,"_47":48,"_46":265,"_163":66,"_44":266,"_13":70,"_40":226,"_41":267,"_30":31,"_168":-5,"_216":268,"_33":269},{"_49":254,"_38":255,"_36":256,"_161":178,"_47":48,"_46":257,"_163":66,"_44":258,"_13":70,"_40":226,"_41":259,"_30":31,"_168":-5,"_216":260,"_33":261},{"_49":246,"_38":247,"_36":248,"_161":178,"_47":48,"_46":249,"_163":66,"_44":250,"_13":70,"_40":226,"_41":251,"_30":31,"_168":-5,"_216":252,"_33":253},{"_49":238,"_38":239,"_36":240,"_161":178,"_47":48,"_46":241,"_163":66,"_44":242,"_13":165,"_40":226,"_41":243,"_30":31,"_168":-5,"_216":244,"_33":245},{"_49":230,"_38":231,"_36":232,"_161":178,"_47":48,"_46":233,"_163":66,"_44":234,"_13":70,"_40":226,"_41":235,"_30":31,"_168":-5,"_216":236,"_33":237},{"_49":222,"_38":223,"_36":224,"_161":178,"_47":48,"_46":179,"_163":66,"_44":225,"_13":70,"_40":226,"_41":227,"_30":31,"_168":-5,"_216":228,"_33":229},{"_49":170,"_38":171,"_36":172,"_161":-5,"_47":48,"_46":165,"_163":31,"_44":219,"_13":70,"_40":26,"_41":174,"_30":31,"_168":-5,"_216":220,"_33":221},{"_49":159,"_38":160,"_36":64,"_161":-5,"_47":48,"_46":162,"_163":31,"_44":215,"_13":165,"_40":166,"_41":167,"_30":31,"_168":51,"_216":217,"_33":218},["D",1783379133104],"children",[],[160],["D",1783377974103],[],[171],"34a3721c-75f6-45cc-a840-88ef40c75370","types.ts","85a83dbe-798c-11f1-87d2-1607ee4eb77e",["D",1783377986977],"script","// 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",[],[177,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",[],[177,231],"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",[],[177,239],"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",[],[177,247],"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",[],[177,255],"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",[],[177,263],"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",[],[177,271],["D",1783377986977],[206,207,208,209,210,211,212],[177],"47b99117-7059-4e9e-b3f9-e5a420af5ef0","index.tsx","019f399c-53b8-772f-829b-41904fe42d5b",["D",1783377974103],"/** @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) {\n throw new Error(\"No root element found\");\n}\n\ncreateRoot(root).render();",[],[184,282],"9846e998-1065-44d8-88fc-24baff2502b8",["D",1783379135188],[],[184,39],"9c5a4fc4-e85b-49b0-943f-601582dcd343","favicon.svg","019f399c-53b8-772f-829b-3bc087a76447",["D",1783377974103],"\n",[],[184,293],"7cf1b057-9b48-403c-b14d-051cab3c3438","Counter.tsx","019f399c-53b8-772f-829b-311e83ada280","019f399c-53b8-772f-829b-356993744ac6",["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",[],[184,307,300],"components","928fa12c-0586-4062-89cd-2b1deff42f1f","App.tsx","019f399c-53b8-772f-829b-2e007a6a5e28",["D",1783377974103],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { Counter } from \"./Counter.tsx\";\n\nexport function App() {\n return (\n

React + Hono Starter

\n \n

\n View source\n

\n );\n}\n",[],[184,307,309],"aca8e727-efad-4577-9fa8-a29735808a6a",["D",1783377974103],[200,201],[184,307],["D",1783377974103],[199,202,203,204],[184],["D",1783377974103],["D",1789525245864],{"_111":110,"_119":115},{"_111":110,"_112":113,"_114":115,"_19":62,"_116":117,"_118":31},{"_13":96,"_38":97,"_49":48,"_98":50,"_99":100,"_101":102,"_103":56,"_104":105,"_106":107,"_108":51,"_109":110},"ctx",{"_89":-5,"_141":360,"_361":362,"_363":364,"_365":31,"_366":31,"_367":31,"_368":66,"_369":-5,"_370":-7,"_371":-7,"_372":70,"_373":31,"_374":31,"_375":-5,"_376":31,"_377":31,"_378":31,"_379":-5},"ENV",{"_331":332,"_333":334,"_335":97,"_336":337,"_338":339,"_340":341,"_342":343,"_344":345,"_346":347,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357,"_358":359},"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 · v11