[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_371":372,"_373":374},"routes/_app.x.$handle.$name",{"_110":109,"_38":51,"_119":96,"_33":120,"_13":14,"_121":-5,"_11":122,"_123":124,"_125":126,"_127":128,"_129":130,"_26":-5,"_131":132,"_133":134,"_135":31,"_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",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":61,"_19":62,"_63":37,"_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":31},"version",25,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","5ac2f9cf-b1d1-4562-b0bb-14fe4e7eb04a","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","index.ts","latestPath","fileId","019f399c-53b9-739a-90ff-bb0a30775a63","name","fileType","http","content","import { parseVal, staticHTTPServer } 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// ── Source redirect ────────────────────────────────────────────\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\n// Wrap Hono so 404s fall through to staticHTTPServer for frontend files\nexport default staticHTTPServer(import.meta.url, async (req) => {\n const res = await app.fetch(req);\n if (res.status === 404) return undefined;\n return res;\n});\n","import { parseVal, serveFile, staticHTTPServer } 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// ── Source redirect ────────────────────────────────────────────\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\n// Wrap Hono so 404s fall through to staticHTTPServer for frontend files\nexport default staticHTTPServer(import.meta.url, async (req) => {\n const res = await app.fetch(req);\n if (res.status === 404) return undefined;\n return res;\n});\n","createdAt",["D",1783379528702],"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=1789549199&sig=78a5bc27f03474c98a49b09a954e18cc6dd63f22ba19ce3e096717a88d3522b5","ed44d53c-06eb-4d40-875e-31a1ddc3df9e","pinnedFileId","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":62,"_115":116,"_117":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":99,"_100":101,"_102":56,"_103":104,"_105":106,"_107":51,"_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",{"_49":50,"_38":51,"_44":366,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":61,"_19":62,"_63":37,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":367,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":368,"_90":369,"_92":370,"_94":31},"tree",[204,214,222,223,224],"files",[204,205,206,207,208,209,210,211,212,213,214,215,216,217,218,219,220,221,222,223,224],"counts",{"_194":69,"_195":179,"_196":69,"_197":198,"_199":200},"contents",[154,155,156,157,158],"upstreamProject",{"_49":104,"_38":150,"_58":151,"_60":61,"_55":56,"_88":152},"upstreamBranch",{"_49":99,"_44":143,"_144":145,"_38":96,"_97":104,"_13":146,"_98":-5,"_100":-5,"_147":148,"_53":-5,"_94":31,"_55":56,"_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=1789549199&sig=85ec03bbe2ae9af315fa5e89fceebe840b59020b3ec43df39e2ab37ef0d215ad",{"_49":189,"_38":190,"_36":191,"_160":-5,"_47":48,"_46":179,"_161":65,"_44":192,"_13":69,"_39":187,"_41":-5,"_30":31,"_164":-5,"_33":193},{"_49":182,"_38":183,"_36":184,"_160":-5,"_47":48,"_46":185,"_161":65,"_44":186,"_13":69,"_39":187,"_41":-5,"_30":31,"_164":-5,"_33":188},{"_49":174,"_38":175,"_36":176,"_160":-5,"_47":48,"_46":177,"_161":65,"_44":178,"_13":179,"_39":26,"_41":180,"_30":31,"_164":-5,"_33":181},{"_49":166,"_38":167,"_36":168,"_160":-5,"_47":48,"_46":169,"_161":65,"_44":170,"_13":69,"_39":171,"_41":172,"_30":31,"_164":-5,"_33":173},{"_49":159,"_38":34,"_36":37,"_160":-5,"_47":48,"_46":14,"_161":31,"_44":162,"_13":163,"_39":40,"_41":43,"_30":31,"_164":51,"_33":165},"f9eaabb0-e3a4-4701-add5-20f611a5c371","parentId","latest",["D",1783379528702],6,"label",[34],"8465f44c-05ef-40f6-8275-3a54d85e0a0d","cron.ts","5ccd1af6-798f-11f1-9022-1607ee4eb77e",18,["D",1783379206933],"interval","/**\n * Risk Guardian — Automated Cron Monitor\n *\n * Runs every 15 minutes to:\n * 1. Poll gold-confirm + main signal bot for new/closed signals\n * 2. Fetch live XAU/USD price + DXY\n * 3. Update demo equity\n * 4. Check SL/TP on open demo trades\n * 5. Calculate risk scores for all active positions\n * 6. Send Telegram alerts on risk escalation\n */\n\nimport { pollSignals } from \"./lib/signal-poller.ts\";\nimport { getGoldPrice, getDXY } from \"./lib/price.ts\";\nimport { calculateRiskScore, shouldAlert } from \"./lib/risk.ts\";\nimport { sendTelegramMessage, formatRiskAlert } from \"./lib/telegram.ts\";\nimport { updateDemoEquity, checkDemoSLTP } from \"./lib/demo.ts\";\nimport {\n initDB,\n getActivePositions,\n getRiskHistory,\n addRiskHistory,\n addAlert,\n} from \"./lib/db.ts\";\n\nexport default async function () {\n console.log(\"[cron] Risk Guardian monitor started at\", new Date().toISOString());\n\n await initDB();\n\n // 1. Poll for new/closed signals\n const pollResult = await pollSignals();\n console.log(\"[cron] Poll result:\", pollResult);\n\n // 2. Get live price\n const [gold, dxy] = await Promise.all([getGoldPrice(), getDXY()]);\n if (!gold) {\n console.error(\"[cron] Price fetch failed — skipping risk assessment\");\n return;\n }\n console.log(`[cron] Gold: $${gold.price} | DXY: ${dxy ?? \"N/A\"}`);\n\n // 3. Update demo equity\n await updateDemoEquity(gold.price);\n\n // 4. Check SL/TP on demo trades\n const sltp = await checkDemoSLTP(gold.price);\n if (sltp.closed.length > 0) {\n console.log(`[cron] ${sltp.closed.length} demo trades hit SL/TP`);\n }\n\n // 5. Assess risk on all active positions\n const positions = await getActivePositions();\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 console.log(`[cron] Alert sent for ${pos.signal_id}: ${result.level} (${result.score})`);\n }\n }\n\n console.log(`[cron] Done. ${positions.length} active positions assessed.`);\n}\n",[167],"03a38720-2429-410a-b0e9-c2c4b6075cae","README.md","019f399c-53b8-772f-829b-4a24b1f70d71",20,["D",1783379224306],1,"# 🛡️ Risk Guardian — XAU/USD Signal Monitor\n\nReal-time risk monitoring system for XAU/USD (Gold) trading signals. Connects to\nyour gold-confirm and main signal bots, tracks positions, scores risk, and sends\nTelegram alerts when risk escalates.\n\n**🔗 Live Dashboard:** \n\n## Features\n\n- **Live Gold Price** — fetches XAU/USD spot price + DXY from multiple free APIs\n- **Signal Polling** — auto-discovers signal APIs from gold-confirm + main signal bots\n- **Webhook Receiver** — external bots can POST signals directly to `/api/signals/webhook`\n- **Risk Scoring Engine** — 0–100 score based on SL distance, TP distance, momentum, DXY, P&L\n- **Demo Paper Trading** — auto-opens/closes trades, tracks balance, equity, win rate\n- **Telegram Alerts** — new positions, risk escalations, and position closures\n- **Dashboard UI** — live risk cards, stats bar, alert feed, demo account panel\n- **Cron Monitor** — runs every 15 min to poll signals, assess risk, and update demo\n\n## Architecture\n\n```mermaid\ngraph TB\n SignalBot[\"Signal Bots
(gold-confirm + main)\"]\n Webhook[\"POST /api/signals/webhook\"]\n Cron[\"cron.ts
(every 15 min)\"]\n PriceAPI[\"Price APIs
(gold-api, metals.dev)\"]\n\n SignalBot -->|poll| Cron\n SignalBot -->|POST| Webhook\n Cron -->|fetch| PriceAPI\n\n Cron --> DB[\"SQLite DB
(positions, trades, alerts)\"]\n Webhook --> DB\n\n Cron --> RiskEngine[\"Risk Engine
(SL, TP, momentum, DXY)\"]\n RiskEngine --> Telegram[\"Telegram Alerts\"]\n RiskEngine --> DB\n\n Dashboard[\"React Dashboard
(risk-guardian.val.run)\"]\n Dashboard -->|fetch| API[\"Hono API
(index.ts)\"]\n API --> DB\n API --> PriceAPI\n```\n\n## File Structure\n\n```\nindex.ts ← Hono API server (all routes)\ncron.ts ← Interval cron (auto-monitor every 15 min)\nlib/\n types.ts ← Shared TypeScript interfaces\n db.ts ← SQLite database layer\n risk.ts ← Risk scoring engine (0–100)\n price.ts ← XAU/USD + DXY price feeds\n telegram.ts ← Telegram alert sender + formatters\n signal-poller.ts ← Multi-source signal polling + webhook\n demo.ts ← Paper trading engine (auto open/close)\nfrontend/\n index.html ← HTML shell (Twind + React)\n index.tsx ← React entrypoint\n components/\n App.tsx ← Root dashboard (tabs + live data)\n RiskCard.tsx ← Per-position risk card with score bar\n StatsBar.tsx ← Summary stats row\n AlertFeed.tsx ← Alert history list\n DemoPanel.tsx ← Demo account + trade tables\n```\n\n## API Endpoints\n\n| Method | Path | Description |\n|--------|------|-------------|\n| GET | `/api/health` | Health check |\n| GET | `/api/stats` | Dashboard summary stats |\n| GET | `/api/price` | Live gold price + DXY |\n| GET | `/api/risk` | Live risk assessment for all active positions |\n| GET | `/api/risk/history` | Recent risk history entries |\n| GET | `/api/risk/:id` | Risk history for specific position |\n| GET | `/api/positions` | All positions |\n| GET | `/api/positions/active` | Active (watching) positions only |\n| GET | `/api/alerts` | Recent alerts |\n| GET | `/api/demo` | Demo account stats |\n| GET | `/api/demo/trades` | All demo trades |\n| GET | `/api/demo/open` | Open demo trades |\n| POST | `/api/poll` | Manually trigger signal polling |\n| POST | `/api/signals/webhook` | Receive signals from external bots |\n| POST | `/api/signals/inject` | Manually inject a signal |\n| POST | `/api/monitor` | Full monitor cycle (poll + risk + demo) |\n\n## Webhook Format\n\nPOST to `/api/signals/webhook`:\n\n```json\n{\n \"signal_id\": \"sig-2024-001\",\n \"direction\": \"LONG\",\n \"entry_price\": 2380.50,\n \"sl_price\": 2370.00,\n \"tp_price\": 2400.00,\n \"invalidation_level\": 2365.00,\n \"status\": \"confirmed\",\n \"timestamp\": \"2024-07-01T12:00:00Z\"\n}\n```\n\n## Environment Variables\n\n| Key | Required | Description |\n|-----|----------|-------------|\n| `TELEGRAM_BOT_TOKEN` | No* | Telegram bot token for alerts |\n| `TELEGRAM_CHAT_ID` | No* | Telegram chat ID for alerts |\n\n*Without Telegram credentials, alerts are logged but not sent.\n\n👉 Add TELEGRAM_BOT_TOKEN here: https://www.val.town/x/Hunter5/risk-guardian/environment-variables?key=TELEGRAM_BOT_TOKEN\n👉 Add TELEGRAM_CHAT_ID here: https://www.val.town/x/Hunter5/risk-guardian/environment-variables?key=TELEGRAM_CHAT_ID\n\n## Risk Scoring (0–100)\n\n| Score | Level | Meaning |\n|-------|-------|---------|\n| 0–34 | 🟢 Safe | Position is healthy |\n| 35–59 | 🟡 Caution | Monitor closely |\n| 60–79 | ⚠️ Danger | Consider action |\n| 80–100 | 🚨 Critical | Immediate attention needed |\n\nFactors: SL distance (40pts), momentum (25pts), DXY correlation (15pts),\nunrealized P&L (15pts), invalidation proximity (10pts), TP proximity (-15pts).\n",[175],"c973a0a3-2142-4571-b5da-46d4c1bcdd97","lib","bd4d577a-c696-45e0-a725-3df4ce483845",2,["D",1783377986977],"directory",[183],"2a74a97c-04f1-415b-9032-c043670177a4","frontend","019f399c-53b8-772f-829b-46f036e99f2c",["D",1783377974103],[190],"pulls","branches","forks","envVars",{"_201":69,"_203":69},"connections",{"_201":69,"_202":69},"count","unfilledCount","emptyCount",{"_49":189,"_38":190,"_36":191,"_160":-5,"_47":48,"_46":179,"_161":65,"_44":363,"_13":69,"_39":187,"_41":-5,"_30":31,"_164":-5,"_226":364,"_33":365},{"_49":359,"_38":326,"_36":320,"_160":191,"_47":48,"_46":179,"_161":65,"_44":360,"_13":69,"_39":187,"_41":-5,"_30":31,"_164":-5,"_226":361,"_33":362},{"_49":351,"_38":352,"_36":353,"_160":320,"_47":48,"_46":354,"_161":65,"_44":355,"_13":69,"_39":239,"_41":356,"_30":31,"_164":-5,"_226":357,"_33":358},{"_49":343,"_38":344,"_36":345,"_160":320,"_47":48,"_46":346,"_161":31,"_44":347,"_13":179,"_39":239,"_41":348,"_30":31,"_164":-5,"_226":349,"_33":350},{"_49":335,"_38":336,"_36":337,"_160":320,"_47":48,"_46":338,"_161":65,"_44":339,"_13":69,"_39":239,"_41":340,"_30":31,"_164":-5,"_226":341,"_33":342},{"_49":327,"_38":328,"_36":329,"_160":320,"_47":48,"_46":330,"_161":65,"_44":331,"_13":69,"_39":239,"_41":332,"_30":31,"_164":-5,"_226":333,"_33":334},{"_49":317,"_38":318,"_36":319,"_160":320,"_47":48,"_46":321,"_161":65,"_44":322,"_13":69,"_39":239,"_41":323,"_30":31,"_164":-5,"_226":324,"_33":325},{"_49":310,"_38":311,"_36":312,"_160":191,"_47":48,"_46":179,"_161":65,"_44":313,"_13":69,"_39":26,"_41":314,"_30":31,"_164":-5,"_226":315,"_33":316},{"_49":302,"_38":303,"_36":304,"_160":191,"_47":48,"_46":305,"_161":65,"_44":306,"_13":179,"_39":26,"_41":307,"_30":31,"_164":-5,"_226":308,"_33":309},{"_49":294,"_38":295,"_36":296,"_160":191,"_47":48,"_46":297,"_161":65,"_44":298,"_13":179,"_39":239,"_41":299,"_30":31,"_164":-5,"_226":300,"_33":301},{"_49":182,"_38":183,"_36":184,"_160":-5,"_47":48,"_46":185,"_161":65,"_44":291,"_13":69,"_39":187,"_41":-5,"_30":31,"_164":-5,"_226":292,"_33":293},{"_49":283,"_38":284,"_36":285,"_160":184,"_47":48,"_46":286,"_161":65,"_44":287,"_13":69,"_39":239,"_41":288,"_30":31,"_164":-5,"_226":289,"_33":290},{"_49":275,"_38":276,"_36":277,"_160":184,"_47":48,"_46":278,"_161":65,"_44":279,"_13":69,"_39":239,"_41":280,"_30":31,"_164":-5,"_226":281,"_33":282},{"_49":267,"_38":268,"_36":269,"_160":184,"_47":48,"_46":270,"_161":65,"_44":271,"_13":69,"_39":239,"_41":272,"_30":31,"_164":-5,"_226":273,"_33":274},{"_49":259,"_38":260,"_36":261,"_160":184,"_47":48,"_46":262,"_161":65,"_44":263,"_13":69,"_39":239,"_41":264,"_30":31,"_164":-5,"_226":265,"_33":266},{"_49":251,"_38":252,"_36":253,"_160":184,"_47":48,"_46":254,"_161":65,"_44":255,"_13":179,"_39":239,"_41":256,"_30":31,"_164":-5,"_226":257,"_33":258},{"_49":243,"_38":244,"_36":245,"_160":184,"_47":48,"_46":246,"_161":65,"_44":247,"_13":69,"_39":239,"_41":248,"_30":31,"_164":-5,"_226":249,"_33":250},{"_49":235,"_38":236,"_36":237,"_160":184,"_47":48,"_46":185,"_161":65,"_44":238,"_13":69,"_39":239,"_41":240,"_30":31,"_164":-5,"_226":241,"_33":242},{"_49":174,"_38":175,"_36":176,"_160":-5,"_47":48,"_46":177,"_161":65,"_44":232,"_13":179,"_39":26,"_41":180,"_30":31,"_164":-5,"_226":233,"_33":234},{"_49":166,"_38":167,"_36":168,"_160":-5,"_47":48,"_46":169,"_161":65,"_44":229,"_13":69,"_39":171,"_41":172,"_30":31,"_164":-5,"_226":230,"_33":231},{"_49":159,"_38":34,"_36":37,"_160":-5,"_47":48,"_46":14,"_161":31,"_44":225,"_13":163,"_39":40,"_41":43,"_30":31,"_164":51,"_226":227,"_33":228},["D",1783379528702],"children",[],[34],["D",1783379206933],[],[167],["D",1783379224306],[],[175],"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",[],[183,236],"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",[],[183,244],"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",[],[183,252],"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",[],[183,260],"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",[],[183,268],"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",[],[183,276],"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",[],[183,284],["D",1783377986977],[215,216,217,218,219,220,221],[183],"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",[],[190,295],"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",[],[190,303],"9c5a4fc4-e85b-49b0-943f-601582dcd343","favicon.svg","019f399c-53b8-772f-829b-3bc087a76447",["D",1783377974103],"\n",[],[190,311],"5184cd26-6554-4886-bed2-882e5d90ddfb","StatsBar.tsx","4b4abc8e-798f-11f1-ab32-1607ee4eb77e","019f399c-53b8-772f-829b-356993744ac6",14,["D",1783379177499],"/** @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",[],[190,326,318],"components","98ca2690-67ea-4de4-b943-69030ae0f547","RiskCard.tsx","4b5fc1b0-798f-11f1-8585-1607ee4eb77e",16,["D",1783379177473],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\nconst levelColors: Record = {\n safe: \"text-green-400 bg-green-900/30 border-green-800\",\n caution: \"text-yellow-400 bg-yellow-900/30 border-yellow-800\",\n danger: \"text-orange-400 bg-orange-900/30 border-orange-800\",\n critical: \"text-red-400 bg-red-900/30 border-red-800\",\n};\n\nconst levelEmoji: Record = {\n safe: \"🟢\",\n caution: \"🟡\",\n danger: \"⚠️\",\n critical: \"🚨\",\n};\n\nexport function RiskCard({ data }: { data: any }) {\n const level = data.risk_level ?? \"safe\";\n const pnl = data.unrealized_pnl ?? 0;\n const pnlPositive = pnl >= 0;\n\n return (\n

\n {levelEmoji[level]}\n \n {data.direction}\n \n {data.signal_id}\n

{data.risk_score}

{level}

\n\n

Entry

${data.entry_price?.toFixed(2)}

Current

${data.current_price?.toFixed(2)}

→ SL

{data.distance_to_sl}%

→ TP

{data.distance_to_tp}%

\n\n

\n \n {pnlPositive ? \"+\" : \"\"}${pnl.toFixed(2)} unrealized\n \n {/* Risk bar */}\n

\n \n

\n\n {data.notes?.length > 0 && (\n

\n {data.notes.slice(0, 3).map((note: string, i: number) => (\n

• {note}

\n ))}\n

\n )}\n

\n );\n}\n",[],[190,326,328],"b61ef3da-0edc-449b-b12f-9b505f2148e0","DemoPanel.tsx","5212cd9a-798f-11f1-b62c-1607ee4eb77e",17,["D",1783379188917],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\nexport function DemoPanel({ demo, trades }: { demo: any; trades: any[] }) {\n if (!demo) {\n return (\n

Demo account data unavailable

\n );\n }\n\n const openTrades = trades.filter((t) => t.status === \"open\");\n const closedTrades = trades.filter((t) => t.status === \"closed\");\n\n return (\n

\n {/* Account Summary */}\n

Starting Balance

${demo.starting_balance?.toFixed(2)}

Current Balance

${demo.balance?.toFixed(2)}

Equity

= demo.balance ? \"text-green-400\" : \"text-red-400\"}`}>\n ${demo.equity?.toFixed(2)}\n

Win Rate

= 50 ? \"text-green-400\" : \"text-red-400\"}`}>\n {demo.winRate}%\n

\n\n {/* Trade Stats */}\n

\n \n \n \n \n \n

\n\n {/* Open Trades */}\n

\n Open Trades ({openTrades.length})\n

\n {openTrades.length > 0 ? (\n

\n \n \n \n \n \n \n \n \n \n \n \n \n {openTrades.map((t) => (\n \n \n \n \n \n \n \n \n ))}\n \n

Direction	Entry	SL	TP	Lot	Opened
\n \n {t.direction}\n \n	{t.entry_price?.toFixed(2)}	{t.sl_price?.toFixed(2)}	{t.tp_price?.toFixed(2)}	{t.lot_size}	{t.open_time}

\n ) : (\n

No open trades

\n )}\n

\n\n {/* Closed Trades */}\n

\n Closed Trades ({closedTrades.length})\n

\n {closedTrades.length > 0 ? (\n

\n \n \n \n \n \n \n \n \n \n \n \n {closedTrades.map((t) => (\n \n \n \n \n \n \n \n ))}\n \n

Direction	Entry	Close	P&L	Closed
\n \n {t.direction}\n \n	{t.entry_price?.toFixed(2)}	{t.close_price?.toFixed(2)}	= 0 ? \"text-green-400\" : \"text-red-400\"}`}>\n {(t.pnl ?? 0) >= 0 ? \"+\" : \"\"}${(t.pnl ?? 0).toFixed(2)}\n	{t.close_time}

\n ) : (\n

No closed trades yet

\n )}\n

\n );\n}\n\nfunction StatBox({ label, value, color }: { label: string; value: any; color: string }) {\n return (\n

{label}

{value}

\n );\n}\n",[],[190,326,336],"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",[],[190,326,344],"ff22fe27-53b0-4e3d-85c6-7601b1a51d95","AlertFeed.tsx","4b55ceb2-798f-11f1-932a-1607ee4eb77e",15,["D",1783379177619],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\nconst alertEmoji: Record = {\n new_position: \"🔔\",\n position_closed: \"✅\",\n risk_escalation: \"🚨\",\n};\n\nexport function AlertFeed({ alerts }: { alerts: any[] }) {\n if (!alerts || alerts.length === 0) {\n return (\n

No alerts yet

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

\n {alerts.map((a: any, i: number) => (\n \n \n {alertEmoji[a.alert_type] ?? \"📢\"}\n \n

\n {a.alert_type}\n {a.risk_level && (\n {a.risk_level}\n )}\n {a.sent_telegram === 1 && (\n 📨 Telegram\n )}\n

{a.message}

\n {a.signal_id && (\n

{a.signal_id}

\n )}\n

\n {a.timestamp}\n

\n ))}\n \n );\n}\n",[],[190,326,352],"aca8e727-efad-4577-9fa8-a29735808a6a",["D",1783377974103],[206,207,208,209,210],[190,326],["D",1783377974103],[205,211,212,213],[190],["D",1783377974103],["D",1789525245864],{"_110":109,"_118":114},{"_110":109,"_111":112,"_113":114,"_19":62,"_115":116,"_117":31},{"_13":95,"_38":96,"_49":48,"_97":50,"_98":99,"_100":101,"_102":56,"_103":104,"_105":106,"_107":51,"_108":109},"ctx",{"_88":-5,"_140":404,"_405":406,"_407":408,"_409":31,"_410":31,"_411":31,"_412":65,"_413":-5,"_414":-7,"_415":-7,"_416":69,"_417":31,"_418":31,"_419":-5,"_420":31,"_421":31,"_422":31,"_423":-5},"ENV",{"_375":376,"_377":378,"_379":96,"_380":381,"_382":383,"_384":385,"_386":387,"_388":389,"_390":391,"_392":393,"_394":395,"_396":397,"_398":399,"_400":401,"_402":403},"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 · v25