\n \n \n \n\n",[121,135],"f5a3889f3afde88749d7e6e9c81dd0525b641cc84dd22f279ba7513d5b5dbc97","5c059140-3996-11f1-a04c-42b51c65c3df","5404b440-f52b-11ef-99f0-569c3dd06744",74,["D",1776345337676],8,"\n\n \n \n \n React Hono Val Town Starter\n \n \n \n \n

\n \n \n \n",[121,135],"1ea8b3da4e18d579298229ba24af91b14b14ae02565f57c996f9acaa1f8333bc","frontend/components/App.tsx",{"_32":163,"_13":155,"_82":164,"_84":165,"_85":33,"_86":166,"_87":26,"_34":167,"_40":168,"_90":117,"_92":169,"_66":48,"_94":-5,"_95":-7,"_75":170,"_97":171},{"_32":154,"_13":155,"_82":156,"_84":157,"_85":58,"_86":57,"_87":26,"_34":158,"_40":22,"_90":117,"_92":159,"_66":48,"_94":-5,"_95":-7,"_75":160,"_97":161},"48ae2808-8392-4143-82a2-0a99be5ffe21","App.tsx","019f399c-53b8-772f-829b-2e007a6a5e28","019f399c-53b8-772f-829b-356993744ac6",["D",1783379899297],"/** @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, { signal: AbortSignal.timeout(5000) }).then((r) => r.ok ? r.json() : null).catch(() => null);\n\n const refresh = useCallback(async () => {\n const results = await Promise.allSettled([\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 const val = (i: number) => results[i].status === \"fulfilled\" ? results[i].value : null;\n setPrice(val(0));\n setRisk(val(1));\n setStats(val(2));\n setAlerts(val(3) ?? []);\n setDemo(val(4));\n setDemoTrades(val(5) ?? []);\n setPositions(val(6) ?? []);\n setLoading(false);\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",[121,162,155],"ee59f213dcaadba4ce810fa8c767eb7ae1e2a8f828e4c764e5399a149c4361aa","components","5d7e5e30-3996-11f1-bbdd-42b51c65c3df","6e585892-f52b-11ef-a8e1-569c3dd06744","69ed66bc-f52b-11ef-9dac-569c3dd06744",75,["D",1776345339930],5,"/** @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",[121,162,155],"de0a7e5fc76c6fd6135aff964af1a5835e04e2758b23f3d0c7d9fabffe514df7","README.md",{"_32":182,"_13":172,"_82":183,"_84":-5,"_85":33,"_86":60,"_87":48,"_34":184,"_40":185,"_90":139,"_92":186,"_66":48,"_94":-5,"_95":-7,"_75":187,"_97":188},{"_32":175,"_13":172,"_82":176,"_84":-5,"_85":58,"_86":177,"_87":26,"_34":178,"_40":116,"_90":139,"_92":179,"_66":48,"_94":-5,"_95":-7,"_75":180,"_97":181},"03a38720-2429-410a-b0e9-c2c4b6075cae","019f399c-53b8-772f-829b-4a24b1f70d71",20,["D",1783379224306],"# 🛡️ 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",[172],"d5041645caf15a1a72e20396a8999c9776ae8283f142decf6ef14c14e6ffb0ad","b9c749c0-59e1-11f1-bb5f-ee650bb23af1","a50c3760-f53e-11ef-bd6d-569c3dd06744",["D",1779896144390],31,"# 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",[172],"aaa4f5cc8e5bd01528335cdd2066e164bf95353ce2fe37c616b3e6406f49331e",{"_75":190,"_77":191,"_79":-7},"frontend/components/Counter.tsx",{"_32":192,"_13":193,"_82":194,"_84":165,"_85":33,"_86":195,"_87":26,"_34":196,"_40":197,"_90":117,"_92":198,"_66":48,"_94":-5,"_95":-7,"_75":199,"_97":200},"57a8cc52-3996-11f1-8db6-42b51c65c3df","Counter.tsx","57a8cd2e-3996-11f1-8db6-42b51c65c3df",73,["D",1776345330366],0,"/** @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",[121,162,193],"10ce4fbd7e41af337e504c3877201698031249b437d941845f0f7cdc52a79e66",{"_75":325,"_77":-7,"_79":326},{"_75":316,"_77":-7,"_79":317},{"_75":306,"_77":-7,"_79":307},{"_75":296,"_77":-7,"_79":297},{"_75":286,"_77":-7,"_79":287},{"_75":224,"_77":-7,"_79":281},{"_75":271,"_77":-7,"_79":272},{"_75":262,"_77":-7,"_79":263},{"_75":253,"_77":-7,"_79":254},{"_75":244,"_77":-7,"_79":245},{"_75":234,"_77":-7,"_79":235},{"_75":225,"_77":-7,"_79":226},{"_75":214,"_77":-7,"_79":215},"lib/types.ts",{"_32":216,"_13":217,"_82":218,"_84":219,"_85":58,"_86":22,"_87":26,"_34":220,"_40":197,"_90":117,"_92":221,"_66":48,"_94":-5,"_95":-7,"_75":222,"_97":223},"34a3721c-75f6-45cc-a840-88ef40c75370","types.ts","85a83dbe-798c-11f1-87d2-1607ee4eb77e","bd4d577a-c696-45e0-a725-3df4ce483845",["D",1783377986977],"// Shared types for Risk Guardian\n\nexport type Direction = \"LONG\" | \"SHORT\";\n\nexport type PositionStatus = \"watching\" | \"closed\" | \"invalidated\";\n\nexport type RiskLevel = \"safe\" | \"caution\" | \"danger\" | \"critical\";\n\nexport interface Position {\n id: number;\n signal_id: string;\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level: number | null;\n status: PositionStatus;\n opened_at: string;\n closed_at: string | null;\n close_price: number | null;\n}\n\nexport interface RiskHistoryEntry {\n id: number;\n position_id: number;\n timestamp: string;\n risk_score: number; // 0-100\n risk_level: RiskLevel;\n current_price: number;\n distance_to_sl: number; // percent\n distance_to_tp: number; // percent\n dxy_value: number | null;\n notes: string | null;\n}\n\nexport interface RiskScoreInput {\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level: number | null;\n current_price: number;\n dxy_value: number | null;\n prev_price: number | null; // for momentum\n}\n\nexport interface RiskScoreResult {\n score: number; // 0-100\n level: RiskLevel;\n distance_to_sl: number; // percent\n distance_to_tp: number; // percent\n notes: string[];\n}\n\nexport interface DemoAccount {\n id: number;\n starting_balance: number;\n balance: number;\n equity: number;\n total_trades: number;\n wins: number;\n losses: number;\n}\n\nexport interface DemoTrade {\n id: number;\n position_id: number | null;\n direction: Direction;\n entry_price: number;\n lot_size: number;\n sl_price: number;\n tp_price: number;\n status: \"open\" | \"closed\";\n open_time: string;\n close_time: string | null;\n close_price: number | null;\n pnl: number | null;\n}\n\nexport interface ConfirmedSignal {\n signal_id: string;\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level?: number | null;\n status: \"confirmed\" | \"closed\" | \"invalidated\";\n timestamp: string;\n}\n",[224,217],"bc8dec8c71aa5c2d06f5a3fb176c715a943c38a714d4badfed5143de006f33d3","lib","lib/telegram.ts",{"_32":227,"_13":228,"_82":229,"_84":219,"_85":58,"_86":127,"_87":26,"_34":230,"_40":197,"_90":117,"_92":231,"_66":48,"_94":-5,"_95":-7,"_75":232,"_97":233},"99d8ffe4-af88-4875-bc76-3897cef6004d","telegram.ts","9a67f7f2-798d-11f1-a357-1607ee4eb77e",["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",[224,228],"9c1ba80cbaff8c3495988575941825f57ac5bfb825fec41ef0a81d477490bea7","lib/signal-poller.ts",{"_32":236,"_13":237,"_82":238,"_84":219,"_85":58,"_86":239,"_87":26,"_34":240,"_40":116,"_90":117,"_92":241,"_66":48,"_94":-5,"_95":-7,"_75":242,"_97":243},"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",[224,237],"5a9f7ddb16cdea90189271ea4b5a49353c141e90cb50f0f1977d5f43fb81d48e","lib/risk.ts",{"_32":246,"_13":247,"_82":248,"_84":219,"_85":58,"_86":168,"_87":26,"_34":249,"_40":197,"_90":117,"_92":250,"_66":48,"_94":-5,"_95":-7,"_75":251,"_97":252},"abb692ad-80e0-4fab-a400-b7b7f3c0a9b7","risk.ts","9a759146-798d-11f1-8123-1607ee4eb77e",["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",[224,247],"db7f282de90dfb15b5dd0e6007dba8b60a630651a4f48d66aa4b83fa86d90266","lib/price.ts",{"_32":255,"_13":256,"_82":257,"_84":219,"_85":58,"_86":147,"_87":26,"_34":258,"_40":197,"_90":117,"_92":259,"_66":48,"_94":-5,"_95":-7,"_75":260,"_97":261},"ed40dc6d-5a27-426c-9273-ccd5174667e8","price.ts","7840a60a-798e-11f1-b895-1607ee4eb77e",["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",[224,256],"45670a5cacf4364fc8f7c9be1addf891a1dd79ca01f29cad72eac0f71cf67e03","lib/demo.ts",{"_32":264,"_13":265,"_82":266,"_84":219,"_85":58,"_86":89,"_87":26,"_34":267,"_40":197,"_90":117,"_92":268,"_66":48,"_94":-5,"_95":-7,"_75":269,"_97":270},"cd178bc0-6908-4515-a480-f56b8420e250","demo.ts","abbde99e-798d-11f1-8123-1607ee4eb77e",["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",[224,265],"da3e35e650a693d4884e06d4b12dbe77209aa22487718308a825233a4c55cce1","lib/db.ts",{"_32":273,"_13":274,"_82":275,"_84":219,"_85":58,"_86":276,"_87":26,"_34":277,"_40":197,"_90":117,"_92":278,"_66":48,"_94":-5,"_95":-7,"_75":279,"_97":280},"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",[224,274],"46aa5aa68484207b07bc866279bb6acecf87be847e980aef2d1868e0e09fc524",{"_32":282,"_13":224,"_82":219,"_84":-5,"_85":58,"_86":22,"_87":26,"_34":283,"_40":197,"_90":284,"_92":-5,"_66":48,"_94":-5,"_95":-7,"_75":285,"_97":-5},"c973a0a3-2142-4571-b5da-46d4c1bcdd97",["D",1783377986977],"directory",[224],"frontend/components/StatsBar.tsx",{"_32":288,"_13":289,"_82":290,"_84":157,"_85":58,"_86":291,"_87":26,"_34":292,"_40":197,"_90":117,"_92":293,"_66":48,"_94":-5,"_95":-7,"_75":294,"_97":295},"5184cd26-6554-4886-bed2-882e5d90ddfb","StatsBar.tsx","4b4abc8e-798f-11f1-ab32-1607ee4eb77e",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",[121,162,289],"b9cc3f9cd70755b66a0671a3aba951949b833b332d3bb3ffe648d4650fc861d8","frontend/components/RiskCard.tsx",{"_32":298,"_13":299,"_82":300,"_84":157,"_85":58,"_86":301,"_87":26,"_34":302,"_40":197,"_90":117,"_92":303,"_66":48,"_94":-5,"_95":-7,"_75":304,"_97":305},"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",[121,162,299],"7ae6c73ad9aa2fdf3e6c3270546240fab5acb0fa0058a5f917b1803bf0ff4c72","frontend/components/DemoPanel.tsx",{"_32":308,"_13":309,"_82":310,"_84":157,"_85":58,"_86":311,"_87":26,"_34":312,"_40":197,"_90":117,"_92":313,"_66":48,"_94":-5,"_95":-7,"_75":314,"_97":315},"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",[121,162,309],"849235438089dde94fbd4c6bde137c6a65d2bb788bcc07c40a0bce8b6c7d7a15","frontend/components/AlertFeed.tsx",{"_32":318,"_13":319,"_82":320,"_84":157,"_85":58,"_86":103,"_87":26,"_34":321,"_40":197,"_90":117,"_92":322,"_66":48,"_94":-5,"_95":-7,"_75":323,"_97":324},"ff22fe27-53b0-4e3d-85c6-7601b1a51d95","AlertFeed.tsx","4b55ceb2-798f-11f1-932a-1607ee4eb77e",["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",[121,162,319],"648dbc89e2aef5e9472118fddbd8e927b4aa5d3383e7cf11223c2c34f42b8f44","cron.ts",{"_32":327,"_13":325,"_82":328,"_84":-5,"_85":58,"_86":329,"_87":26,"_34":330,"_40":197,"_90":331,"_92":332,"_66":48,"_94":-5,"_95":-7,"_75":333,"_97":334},"8465f44c-05ef-40f6-8275-3a54d85e0a0d","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",[325],"967f145ce604a992ab897af7e5b0aeb7c00f77af8ebba25c108c9350ee56ae5f",["D",1783377974103],"legacyEnvVars","httpPrivacy","description","XAU/USD Risk Guardian — risk scoring, alerts, paper trading","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/64dc00cc-94d9-47dd-81b1-dde02610d900/square512?exp=1789545599&sig=91cfcc631bd9f3dd8274549c04838d172adf2572755982193460d49bfd04bd62","userId","ed44d53c-06eb-4d40-875e-31a1ddc3df9e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_378":374},"org",{"_11":12,"_371":372,"_373":374,"_342":343,"_375":376,"_377":48},"branch","displayName","Francis Ngugi","avatar","https://lh3.googleusercontent.com/a/ACg8ocK4Afj4B1r5sKudXPEQcQec_doIzFyxxVnr6ivB6YdptbXKMQ=s96-c","tier","free","canRestrictVals","profileImageUrl","","adoptOrgId",{"_32":59,"_13":14,"_34":504,"_46":-5,"_336":48,"_49":50,"_337":50,"_338":339,"_340":341,"_342":343,"_344":83,"_345":26,"_346":-5,"_347":-5,"_348":197,"_53":349,"_350":351,"_352":353,"_354":505,"_356":-5,"_357":358,"_359":358,"_360":361,"_362":361,"_363":361,"_364":358,"_365":358,"_366":506,"_368":507,"_370":508,"_47":48},"tree",[433,443,451,452,453],"files",[433,434,435,436,437,438,439,440,441,442,443,444,445,446,447,448,449,450,451,452,453],"counts",{"_423":197,"_424":116,"_425":197,"_426":427,"_428":429},"contents",[407,408,409,410,411],"upstreamProject",{"_32":39,"_13":56,"_338":404,"_340":341,"_49":50,"_366":405},"upstreamBranch",{"_32":33,"_34":402,"_36":403,"_13":16,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1740674013689],["D",1785420707976],"Starter template with client-side React & Hono server",{"_11":52,"_378":406},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789545599&sig=2316df07e67031dd48e537f6ce0c4c14b92716fed790ec83ecf27974cc65aa31",{"_32":420,"_13":121,"_82":113,"_84":-5,"_85":58,"_86":116,"_87":26,"_34":421,"_40":197,"_90":284,"_92":-5,"_66":48,"_94":-5,"_75":422},{"_32":282,"_13":224,"_82":219,"_84":-5,"_85":58,"_86":22,"_87":26,"_34":418,"_40":197,"_90":284,"_92":-5,"_66":48,"_94":-5,"_75":419},{"_32":175,"_13":172,"_82":176,"_84":-5,"_85":58,"_86":177,"_87":26,"_34":416,"_40":116,"_90":139,"_92":179,"_66":48,"_94":-5,"_75":417},{"_32":327,"_13":325,"_82":328,"_84":-5,"_85":58,"_86":329,"_87":26,"_34":414,"_40":197,"_90":331,"_92":332,"_66":48,"_94":-5,"_75":415},{"_32":81,"_13":76,"_82":83,"_84":-5,"_85":58,"_86":20,"_87":26,"_34":412,"_40":89,"_90":91,"_92":93,"_66":48,"_94":14,"_75":413},["D",1783379546403],[76],["D",1783379206933],[325],["D",1783379224306],[172],["D",1783377986977],[224],"2a74a97c-04f1-415b-9032-c043670177a4",["D",1783377974103],[121],"pulls","branches","forks","envVars",{"_430":197,"_432":197},"connections",{"_430":197,"_431":197},"count","unfilledCount","emptyCount",{"_32":420,"_13":121,"_82":113,"_84":-5,"_85":58,"_86":116,"_87":26,"_34":501,"_40":197,"_90":284,"_92":-5,"_66":48,"_94":-5,"_95":502,"_75":503},{"_32":497,"_13":162,"_82":157,"_84":113,"_85":58,"_86":116,"_87":26,"_34":498,"_40":197,"_90":284,"_92":-5,"_66":48,"_94":-5,"_95":499,"_75":500},{"_32":318,"_13":319,"_82":320,"_84":157,"_85":58,"_86":103,"_87":26,"_34":321,"_40":197,"_90":117,"_92":322,"_66":48,"_94":-5,"_95":495,"_75":496},{"_32":154,"_13":155,"_82":156,"_84":157,"_85":58,"_86":57,"_87":26,"_34":158,"_40":22,"_90":117,"_92":159,"_66":48,"_94":-5,"_95":493,"_75":494},{"_32":308,"_13":309,"_82":310,"_84":157,"_85":58,"_86":311,"_87":26,"_34":312,"_40":197,"_90":117,"_92":313,"_66":48,"_94":-5,"_95":491,"_75":492},{"_32":298,"_13":299,"_82":300,"_84":157,"_85":58,"_86":301,"_87":26,"_34":302,"_40":197,"_90":117,"_92":303,"_66":48,"_94":-5,"_95":489,"_75":490},{"_32":288,"_13":289,"_82":290,"_84":157,"_85":58,"_86":291,"_87":26,"_34":292,"_40":197,"_90":117,"_92":293,"_66":48,"_94":-5,"_95":487,"_75":488},{"_32":480,"_13":481,"_82":482,"_84":113,"_85":58,"_86":116,"_87":26,"_34":483,"_40":197,"_90":139,"_92":484,"_66":48,"_94":-5,"_95":485,"_75":486},{"_32":134,"_13":135,"_82":136,"_84":113,"_85":58,"_86":137,"_87":26,"_34":138,"_40":116,"_90":139,"_92":140,"_66":48,"_94":-5,"_95":478,"_75":479},{"_32":110,"_13":111,"_82":112,"_84":113,"_85":58,"_86":114,"_87":26,"_34":115,"_40":116,"_90":117,"_92":118,"_66":48,"_94":-5,"_95":476,"_75":477},{"_32":282,"_13":224,"_82":219,"_84":-5,"_85":58,"_86":22,"_87":26,"_34":283,"_40":197,"_90":284,"_92":-5,"_66":48,"_94":-5,"_95":474,"_75":475},{"_32":273,"_13":274,"_82":275,"_84":219,"_85":58,"_86":276,"_87":26,"_34":277,"_40":197,"_90":117,"_92":278,"_66":48,"_94":-5,"_95":472,"_75":473},{"_32":264,"_13":265,"_82":266,"_84":219,"_85":58,"_86":89,"_87":26,"_34":267,"_40":197,"_90":117,"_92":268,"_66":48,"_94":-5,"_95":470,"_75":471},{"_32":255,"_13":256,"_82":257,"_84":219,"_85":58,"_86":147,"_87":26,"_34":258,"_40":197,"_90":117,"_92":259,"_66":48,"_94":-5,"_95":468,"_75":469},{"_32":246,"_13":247,"_82":248,"_84":219,"_85":58,"_86":168,"_87":26,"_34":249,"_40":197,"_90":117,"_92":250,"_66":48,"_94":-5,"_95":466,"_75":467},{"_32":236,"_13":237,"_82":238,"_84":219,"_85":58,"_86":239,"_87":26,"_34":240,"_40":116,"_90":117,"_92":241,"_66":48,"_94":-5,"_95":464,"_75":465},{"_32":227,"_13":228,"_82":229,"_84":219,"_85":58,"_86":127,"_87":26,"_34":230,"_40":197,"_90":117,"_92":231,"_66":48,"_94":-5,"_95":462,"_75":463},{"_32":216,"_13":217,"_82":218,"_84":219,"_85":58,"_86":22,"_87":26,"_34":220,"_40":197,"_90":117,"_92":221,"_66":48,"_94":-5,"_95":460,"_75":461},{"_32":175,"_13":172,"_82":176,"_84":-5,"_85":58,"_86":177,"_87":26,"_34":178,"_40":116,"_90":139,"_92":179,"_66":48,"_94":-5,"_95":458,"_75":459},{"_32":327,"_13":325,"_82":328,"_84":-5,"_85":58,"_86":329,"_87":26,"_34":330,"_40":197,"_90":331,"_92":332,"_66":48,"_94":-5,"_95":456,"_75":457},{"_32":81,"_13":76,"_82":83,"_84":-5,"_85":58,"_86":20,"_87":26,"_34":88,"_40":89,"_90":91,"_92":93,"_66":48,"_94":14,"_95":454,"_75":455},[],[76],[],[325],[],[172],[],[224,217],[],[224,228],[],[224,237],[],[224,247],[],[224,256],[],[224,265],[],[224,274],[444,445,446,447,448,449,450],[224],[],[121,111],[],[121,135],"9c5a4fc4-e85b-49b0-943f-601582dcd343","favicon.svg","019f399c-53b8-772f-829b-3bc087a76447",["D",1783377974103],"\n",[],[121,481],[],[121,162,289],[],[121,162,299],[],[121,162,309],[],[121,162,155],[],[121,162,319],"aca8e727-efad-4577-9fa8-a29735808a6a",["D",1783377974103],[435,436,437,438,439],[121,162],["D",1783377974103],[434,440,441,442],[121],["D",1783377974103],["D",1789525245864],{"_11":12,"_378":374},{"_11":12,"_371":372,"_373":374,"_342":343,"_375":376,"_377":48},{"_40":57,"_13":16,"_32":58,"_38":59,"_42":33,"_43":60,"_61":50,"_62":39,"_63":54,"_55":14,"_51":12},"ctx",{"_366":-5,"_399":542,"_543":544,"_545":546,"_547":48,"_548":48,"_549":48,"_550":26,"_551":-5,"_552":-7,"_553":-7,"_554":197,"_555":48,"_556":48,"_557":-5,"_558":48,"_559":48,"_560":48,"_561":-5},"ENV",{"_513":514,"_515":516,"_517":16,"_518":519,"_520":521,"_522":523,"_524":525,"_526":527,"_528":529,"_530":531,"_532":533,"_534":535,"_536":537,"_538":539,"_540":541},"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"]

Compare

MergeHunter5/mainintotemplates/main

README.md+111-44

frontend/components/App.tsx+203-7

frontend/index.html+3-3

frontend/index.tsx+2-4

Hindex.ts+258-14

Ccron.ts+105-0

frontend/components/AlertFeed.tsx+53-0

frontend/components/DemoPanel.tsx+142-0

frontend/components/RiskCard.tsx+86-0

frontend/components/StatsBar.tsx+60-0

lib

lib/db.ts+322-0

lib/demo.ts+156-0

lib/price.ts+82-0

lib/risk.ts+168-0

lib/signal-poller.ts+272-0

lib/telegram.ts+127-0

lib/types.ts+89-0

frontend/components/Counter.tsx+0-18