[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_325":326,"_327":328},"routes/_app.x.$handle.$name",{"_112":111,"_38":52,"_121":98,"_33":122,"_13":14,"_123":-5,"_11":124,"_125":126,"_127":128,"_129":130,"_131":132,"_26":-5,"_133":134,"_135":136,"_137":31,"_138":139,"_140":67,"_141":-5,"_142":-5,"_143":144},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_50":51,"_38":52,"_45":53,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":62,"_19":63,"_64":65,"_66":67,"_68":-5,"_69":-5,"_70":71,"_72":73,"_74":75,"_76":77,"_78":79,"_80":-5,"_81":82,"_83":82,"_84":85,"_86":85,"_87":85,"_88":82,"_89":82,"_90":91,"_92":93,"_94":95,"_96":31},"version",9,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","71cde8aa-e444-43ca-b8db-e1a89240b35d","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":44,"_45":46,"_47":14,"_48":49,"_30":31},"previous",{"_36":37,"_38":39,"_40":41,"_42":43},"deleted",false,"deletedHere","path","lib/signal-poller.ts","latestPath","fileId","a96e2d70-798d-11f1-8ab2-1607ee4eb77e","name","signal-poller.ts","fileType","script","content","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 gold-confirm bot\n *\n * Checks gold-confirm's JSON API endpoint for:\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\nconst GOLD_CONFIRM_URL = Deno.env.get(\"GOLD_CONFIRM_URL\") ??\n \"https://gold-confirm.val.run/api/signals\";\n\nexport async function pollSignals(): Promise<{\n newPositions: number;\n closedPositions: number;\n errors: string[];\n}> {\n await initDB();\n const errors: string[] = [];\n let newPositions = 0;\n let closedPositions = 0;\n\n let signals: ConfirmedSignal[];\n try {\n const res = await fetch(GOLD_CONFIRM_URL, {\n headers: { Accept: \"application/json\" },\n });\n if (!res.ok) {\n throw new Error(`gold-confirm responded ${res.status}`);\n }\n const data = await res.json();\n // Support both array and { signals: [...] } formats\n signals = Array.isArray(data) ? data : (data.signals ?? []);\n } catch (err) {\n errors.push(`Failed to fetch gold-confirm: ${err.message}`);\n return { newPositions, closedPositions, errors };\n }\n\n // Process each signal\n for (const sig of signals) {\n try {\n const existing = await getPositionBySignal(sig.signal_id);\n\n if (!existing && sig.status === \"confirmed\") {\n // New confirmed signal — create position\n const pos = await createPosition(sig);\n newPositions++;\n\n // Open demo trade\n await openDemoTrade(\n pos.id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n );\n\n // Telegram alert\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 // Signal closed or invalidated — mirror it\n const closePrice = sig.entry_price; // fallback if no close price provided\n await closePosition(sig.signal_id, closePrice, sig.status);\n closedPositions++;\n\n // Telegram alert\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 // Close demo trade too\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) * matchingTrade.lot_size * 100\n : (matchingTrade.entry_price - closePrice) * matchingTrade.lot_size * 100;\n const won = pnl > 0;\n await closeDemoTrade(matchingTrade.id, closePrice, pnl, won);\n }\n }\n } catch (err) {\n errors.push(`Error processing signal ${sig.signal_id}: ${err.message}`);\n }\n }\n\n return { newPositions, closedPositions, errors };\n}\n\n/**\n * Manual signal injection — allows the VPS worker or user to\n * push a signal directly if gold-confirm is unavailable.\n */\nexport async function injectSignal(\n sig: ConfirmedSignal,\n): Promise {\n await initDB();\n const existing = await getPositionBySignal(sig.signal_id);\n if (existing) {\n return existing;\n }\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","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","createdAt",["D",1783378848213],"branchVersion","branchId","7c7585b6-26ec-4b48-a71e-b55cd6373bb7","id","ffcf456e-ea1b-45b3-ae3b-4aa3f7336137","risk-guardian",["D",1783377974103],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","XAU/USD Risk Guardian — risk scoring, alerts, paper trading","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/64dc00cc-94d9-47dd-81b1-dde02610d900/square512?exp=1789541999&sig=8fad4d8ed521ff338d1e7bb443f46241d1f9e0e657d24a41f82306e6eb92823c","ed44d53c-06eb-4d40-875e-31a1ddc3df9e","pinnedFileId","019f399c-53b9-739a-90ff-bb0a30775a63","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f3991-9a05-72bb-a327-cf5b31f62d93","tursoName","ffcf456eea1b45b3ae3b4aa3f7336137","tursoHostname","ffcf456eea1b45b3ae3b4aa3f7336137-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_112":111,"_120":116},"org",{"_112":111,"_113":114,"_115":116,"_19":63,"_117":118,"_119":31},"branch",{"_13":97,"_38":98,"_50":49,"_99":51,"_100":101,"_102":103,"_104":57,"_105":106,"_107":108,"_109":52,"_110":111},"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",{"_50":51,"_38":52,"_45":320,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":62,"_19":63,"_64":65,"_66":67,"_68":-5,"_69":-5,"_70":71,"_72":73,"_74":75,"_76":77,"_78":321,"_80":-5,"_81":82,"_83":82,"_84":85,"_86":85,"_87":85,"_88":82,"_89":82,"_90":322,"_92":323,"_94":324,"_96":31},"tree",[198,205,213,214],"files",[198,199,200,201,202,203,204,205,206,207,208,209,210,211,212,213,214],"counts",{"_188":71,"_189":163,"_190":71,"_191":192,"_193":194},"contents",[156,157,158,159],"upstreamProject",{"_50":106,"_38":152,"_59":153,"_61":62,"_56":57,"_90":154},"upstreamBranch",{"_50":101,"_45":145,"_146":147,"_38":98,"_99":106,"_13":148,"_100":-5,"_102":-5,"_149":150,"_54":-5,"_96":31,"_56":57,"_110":151,"_72":108,"_109":152},"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",{"_112":151,"_120":155},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789541999&sig=156ae2b8ac752fc06f52d45eab428b512e0d31e2aab99a830d8bb32149c64f0f",{"_50":183,"_38":184,"_36":185,"_162":-5,"_48":49,"_47":163,"_164":67,"_45":186,"_13":71,"_40":181,"_42":-5,"_30":31,"_168":-5,"_33":187},{"_50":176,"_38":177,"_36":178,"_162":-5,"_48":49,"_47":179,"_164":67,"_45":180,"_13":71,"_40":181,"_42":-5,"_30":31,"_168":-5,"_33":182},{"_50":170,"_38":171,"_36":172,"_162":-5,"_48":49,"_47":163,"_164":31,"_45":173,"_13":71,"_40":26,"_42":174,"_30":31,"_168":-5,"_33":175},{"_50":160,"_38":161,"_36":65,"_162":-5,"_48":49,"_47":163,"_164":31,"_45":165,"_13":71,"_40":166,"_42":167,"_30":31,"_168":52,"_33":169},"d76ce09a-a761-4ce8-8b0f-bc5ec15e1ae7","index.ts","parentId",1,"latest",["D",1783377974103],"http","import { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\n// Serve index.html at the root /\napp.get(\"/\", () => serveFile(\"/frontend/index.html\"));\n\n// Serve all /frontend files\napp.get(\"/frontend/**/*\", (c) => serveFile(c.req.path));\n\n// View source redirect\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// Add your API routes here\n// app.get(\"/api/data\", c => c.json({ hello: \"world\" }));\n\n// Unwrap and rethrow Hono errors as the original error\n// If you delete this, all errors will be \"Internal Server Error\"\napp.onError((err) => Promise.reject(err));\n\n// HTTP vals expect an exported \"fetch handler\"\n// This is how you \"run the server\" in Val Town with Hono\nexport default app.fetch;\n","label",[161],"9600efcd-06e8-4c04-94fe-be81dc8e7a98","README.md","019f399c-53b8-772f-829b-4a24b1f70d71",["D",1783377974103],"# React + Hono Starter\n\nA minimal starter template for building client-side React apps with a Hono\nbackend on Val Town. Click **Remix** to get your own copy.\n\n## Picking a starter\n\n| Starter | When to pick it |\n| --- | --- |\n| [`basic-html-starter`](https://www.val.town/x/templates/basic-html-starter) | Static HTML pages. Sprinkle of vanilla JS. No server-side rendering. |\n| [`hono-jsx-starter`](https://www.val.town/x/templates/hono-jsx-starter) | Dynamic server-rendered HTML with JSX. API routes. No React, no SPA. |\n| **[`react-hono-starter`](https://www.val.town/x/templates/react-hono-starter)** *(you're here)* | Client-side React SPA with a Hono API backend. |\n\n**Want to build UI?** Start writing React components in\n[`frontend/components/`](/frontend/components/). Import them into `App.tsx` and\nyou're good to go. Styling is [Twind](https://twind.style/) — just use Tailwind\nutility classes, zero config.\n\n**Want to add an API?** Add routes in [`index.ts`](/index.ts) (there's a\ncommented-out example). Fetch them from your React components.\n\n## Architecture\n\n```mermaid\ngraph LR\n Browser -->|\"GET /\"| Hono[\"index.ts
(Hono server)\"]\n Hono -->|serves| HTML[\"index.html\"]\n HTML -->|loads| Entry[\"index.tsx\"]\n Entry -->|renders| App[\"App.tsx\"]\n App -->|renders| Counter[\"Counter.tsx\"]\n```\n\n## File structure\n\n```\nindex.ts ← Hono backend (serves frontend + API routes)\nfrontend/\n index.html ← HTML shell (loads Twind + React)\n index.tsx ← React entrypoint (mounts )\n favicon.svg ← App icon\n components/\n App.tsx ← Root component (layout + view source link)\n Counter.tsx ← Example component with state\n```\n\n## How it works\n\n1. **`index.ts`** is the HTTP entrypoint — a Hono server that serves the\n frontend and any API routes you add.\n2. **`frontend/index.html`** loads Twind and the React entrypoint.\n3. **`frontend/index.tsx`** mounts the React app.\n4. **`frontend/components/App.tsx`** is the root layout — add new components\n alongside it.\n5. **`frontend/components/Counter.tsx`** is an example stateful component —\n replace it with your own!\n\n## Next steps\n\n- Add API routes in `index.ts`\n- Add new components in `frontend/components/`\n- Add a SQLite database — see the\n [React Hono Example](https://www.val.town/x/stevekrouse/reactHonoExample) for\n a full-stack example with database, queries, and shared types\n",[171],"c973a0a3-2142-4571-b5da-46d4c1bcdd97","lib","bd4d577a-c696-45e0-a725-3df4ce483845",2,["D",1783377986977],"directory",[177],"2a74a97c-04f1-415b-9032-c043670177a4","frontend","019f399c-53b8-772f-829b-46f036e99f2c",["D",1783377974103],[184],"pulls","branches","forks","envVars",{"_195":71,"_197":71},"connections",{"_195":71,"_196":71},"count","unfilledCount","emptyCount",{"_50":183,"_38":184,"_36":185,"_162":-5,"_48":49,"_47":163,"_164":67,"_45":317,"_13":71,"_40":181,"_42":-5,"_30":31,"_168":-5,"_216":318,"_33":319},{"_50":313,"_38":305,"_36":300,"_162":185,"_48":49,"_47":163,"_164":67,"_45":314,"_13":71,"_40":181,"_42":-5,"_30":31,"_168":-5,"_216":315,"_33":316},{"_50":306,"_38":307,"_36":308,"_162":300,"_48":49,"_47":163,"_164":31,"_45":309,"_13":71,"_40":41,"_42":310,"_30":31,"_168":-5,"_216":311,"_33":312},{"_50":297,"_38":298,"_36":299,"_162":300,"_48":49,"_47":163,"_164":31,"_45":301,"_13":71,"_40":41,"_42":302,"_30":31,"_168":-5,"_216":303,"_33":304},{"_50":290,"_38":291,"_36":292,"_162":185,"_48":49,"_47":163,"_164":67,"_45":293,"_13":71,"_40":26,"_42":294,"_30":31,"_168":-5,"_216":295,"_33":296},{"_50":283,"_38":284,"_36":285,"_162":185,"_48":49,"_47":163,"_164":31,"_45":286,"_13":71,"_40":26,"_42":287,"_30":31,"_168":-5,"_216":288,"_33":289},{"_50":276,"_38":277,"_36":278,"_162":185,"_48":49,"_47":163,"_164":31,"_45":279,"_13":71,"_40":41,"_42":280,"_30":31,"_168":-5,"_216":281,"_33":282},{"_50":176,"_38":177,"_36":178,"_162":-5,"_48":49,"_47":179,"_164":67,"_45":273,"_13":71,"_40":181,"_42":-5,"_30":31,"_168":-5,"_216":274,"_33":275},{"_50":265,"_38":266,"_36":267,"_162":178,"_48":49,"_47":268,"_164":67,"_45":269,"_13":71,"_40":41,"_42":270,"_30":31,"_168":-5,"_216":271,"_33":272},{"_50":257,"_38":258,"_36":259,"_162":178,"_48":49,"_47":260,"_164":67,"_45":261,"_13":71,"_40":41,"_42":262,"_30":31,"_168":-5,"_216":263,"_33":264},{"_50":249,"_38":250,"_36":251,"_162":178,"_48":49,"_47":252,"_164":67,"_45":253,"_13":71,"_40":41,"_42":254,"_30":31,"_168":-5,"_216":255,"_33":256},{"_50":241,"_38":242,"_36":243,"_162":178,"_48":49,"_47":244,"_164":67,"_45":245,"_13":71,"_40":41,"_42":246,"_30":31,"_168":-5,"_216":247,"_33":248},{"_50":237,"_38":39,"_36":37,"_162":178,"_48":49,"_47":14,"_164":67,"_45":238,"_13":163,"_40":41,"_42":44,"_30":31,"_168":-5,"_216":239,"_33":240},{"_50":229,"_38":230,"_36":231,"_162":178,"_48":49,"_47":232,"_164":67,"_45":233,"_13":71,"_40":41,"_42":234,"_30":31,"_168":-5,"_216":235,"_33":236},{"_50":222,"_38":223,"_36":224,"_162":178,"_48":49,"_47":179,"_164":67,"_45":225,"_13":71,"_40":41,"_42":226,"_30":31,"_168":-5,"_216":227,"_33":228},{"_50":170,"_38":171,"_36":172,"_162":-5,"_48":49,"_47":163,"_164":31,"_45":219,"_13":71,"_40":26,"_42":174,"_30":31,"_168":-5,"_216":220,"_33":221},{"_50":160,"_38":161,"_36":65,"_162":-5,"_48":49,"_47":163,"_164":31,"_45":215,"_13":71,"_40":166,"_42":167,"_30":31,"_168":52,"_216":217,"_33":218},["D",1783377974103],"children",[],[161],["D",1783377974103],[],[171],"34a3721c-75f6-45cc-a840-88ef40c75370","types.ts","85a83dbe-798c-11f1-87d2-1607ee4eb77e",["D",1783377986977],"// Shared types for Risk Guardian\n\nexport type Direction = \"LONG\" | \"SHORT\";\n\nexport type PositionStatus = \"watching\" | \"closed\" | \"invalidated\";\n\nexport type RiskLevel = \"safe\" | \"caution\" | \"danger\" | \"critical\";\n\nexport interface Position {\n id: number;\n signal_id: string;\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level: number | null;\n status: PositionStatus;\n opened_at: string;\n closed_at: string | null;\n close_price: number | null;\n}\n\nexport interface RiskHistoryEntry {\n id: number;\n position_id: number;\n timestamp: string;\n risk_score: number; // 0-100\n risk_level: RiskLevel;\n current_price: number;\n distance_to_sl: number; // percent\n distance_to_tp: number; // percent\n dxy_value: number | null;\n notes: string | null;\n}\n\nexport interface RiskScoreInput {\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level: number | null;\n current_price: number;\n dxy_value: number | null;\n prev_price: number | null; // for momentum\n}\n\nexport interface RiskScoreResult {\n score: number; // 0-100\n level: RiskLevel;\n distance_to_sl: number; // percent\n distance_to_tp: number; // percent\n notes: string[];\n}\n\nexport interface DemoAccount {\n id: number;\n starting_balance: number;\n balance: number;\n equity: number;\n total_trades: number;\n wins: number;\n losses: number;\n}\n\nexport interface DemoTrade {\n id: number;\n position_id: number | null;\n direction: Direction;\n entry_price: number;\n lot_size: number;\n sl_price: number;\n tp_price: number;\n status: \"open\" | \"closed\";\n open_time: string;\n close_time: string | null;\n close_price: number | null;\n pnl: number | null;\n}\n\nexport interface ConfirmedSignal {\n signal_id: string;\n direction: Direction;\n entry_price: number;\n sl_price: number;\n tp_price: number;\n invalidation_level?: number | null;\n status: \"confirmed\" | \"closed\" | \"invalidated\";\n timestamp: string;\n}\n",[],[177,223],"99d8ffe4-af88-4875-bc76-3897cef6004d","telegram.ts","9a67f7f2-798d-11f1-a357-1607ee4eb77e",3,["D",1783378451288],"/**\n * Telegram alert sender for Risk Guardian\n */\n\nexport async function sendTelegramMessage(\n text: string,\n options?: {\n parseMode?: \"HTML\" | \"MarkdownV2\" | \"Markdown\";\n disableNotification?: boolean;\n },\n): Promise {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n if (!token || !chatId) {\n console.log(\n \"[telegram] TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID not set — skipping alert\",\n );\n return false;\n }\n\n try {\n const res = await fetch(\n `https://api.telegram.org/bot${token}/sendMessage`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: options?.parseMode ?? \"HTML\",\n disable_notification: options?.disableNotification ?? false,\n }),\n },\n );\n\n if (!res.ok) {\n const errText = await res.text();\n console.error(`[telegram] API error ${res.status}: ${errText}`);\n return false;\n }\n\n return true;\n } catch (err) {\n console.error(\"[telegram] Failed to send:\", err);\n return false;\n }\n}\n\nexport function formatRiskAlert(\n signalId: string,\n direction: string,\n level: string,\n score: number,\n currentPrice: number,\n notes: string[],\n): string {\n const emoji =\n level === \"critical\"\n ? \"🚨\"\n : level === \"danger\"\n ? \"⚠️\"\n : level === \"caution\"\n ? \"🟡\"\n : \"🟢\";\n\n const notesText = notes.length > 0\n ? notes.map((n) => ` • ${n}`).join(\"\\n\")\n : \" • No specific notes\";\n\n return [\n `${emoji} Risk Guardian Alert`,\n ``,\n `Signal: ${signalId}`,\n `Direction: ${direction}`,\n `Risk Level: ${level.toUpperCase()} (${score}/100)`,\n `Current Price: ${currentPrice}`,\n ``,\n `Details:`,\n notesText,\n ].join(\"\\n\");\n}\n\nexport function formatSignalAlert(\n signalId: string,\n direction: string,\n entry: number,\n sl: number,\n tp: number,\n): string {\n return [\n `🔔 New Position Watched`,\n ``,\n `Signal: ${signalId}`,\n `Direction: ${direction}`,\n `Entry: ${entry}`,\n `SL: ${sl}`,\n `TP: ${tp}`,\n ``,\n `Risk Guardian is now monitoring this trade in real-time.`,\n ].join(\"\\n\");\n}\n\nexport function formatCloseAlert(\n signalId: string,\n direction: string,\n status: string,\n closePrice: number,\n entryPrice: number,\n): string {\n const pnlPercent =\n direction === \"LONG\"\n ? (((closePrice - entryPrice) / entryPrice) * 100).toFixed(2)\n : (((entryPrice - closePrice) / entryPrice) * 100).toFixed(2);\n\n const emoji = status === \"invalidated\" ? \"❌\" : \"✅\";\n\n return [\n `${emoji} Position ${status}`,\n ``,\n `Signal: ${signalId}`,\n `Direction: ${direction}`,\n `Entry: ${entryPrice}`,\n `Close: ${closePrice}`,\n `P&L: ${parseFloat(pnlPercent) >= 0 ? \"+\" : \"\"}${pnlPercent}%`,\n ].join(\"\\n\");\n}\n",[],[177,230],"25f37483-f9ff-4552-9377-c556b5a05799",["D",1783378848213],[],[177,39],"abb692ad-80e0-4fab-a400-b7b7f3c0a9b7","risk.ts","9a759146-798d-11f1-8123-1607ee4eb77e",5,["D",1783378451302],"import type {\n RiskScoreInput,\n RiskScoreResult,\n RiskLevel,\n} from \"./types.ts\";\n\n/**\n * Risk Guardian — Risk Scoring Engine\n *\n * Scores a position 0–100 based on:\n * - Distance to SL (closer = higher risk)\n * - Distance to TP (closer = lower risk)\n * - Price momentum (moving toward SL = higher risk)\n * - DXY correlation (DXY up typically hurts XAU/USD longs)\n * - Invalidation proximity\n *\n * 0 = completely safe, 100 = maximum danger\n */\n\nfunction pctDistance(current: number, target: number): number {\n return Math.abs(((current - target) / current) * 100);\n}\n\nfunction clampScore(score: number): number {\n return Math.max(0, Math.min(100, Math.round(score)));\n}\n\nfunction levelFromScore(score: number): RiskLevel {\n if (score >= 80) return \"critical\";\n if (score >= 60) return \"danger\";\n if (score >= 35) return \"caution\";\n return \"safe\";\n}\n\nexport function calculateRiskScore(input: RiskScoreInput): RiskScoreResult {\n const notes: string[] = [];\n let score = 0;\n\n const { direction, entry_price, sl_price, tp_price, current_price, dxy_value, prev_price, invalidation_level } =\n input;\n\n // 1. Distance to SL — weighted heaviest (40 pts max)\n // If price is within 0.3% of SL, that's near-maximum danger\n const distToSL = pctDistance(current_price, sl_price);\n const slContribution = Math.min(40, (0.5 / Math.max(distToSL, 0.01)) * 8);\n score += slContribution;\n if (distToSL < 0.3) {\n notes.push(`⚠️ Price within ${distToSL.toFixed(3)}% of SL — imminent risk`);\n } else if (distToSL < 0.7) {\n notes.push(`Price ${distToSL.toFixed(2)}% from SL — approaching danger zone`);\n }\n\n // 2. Distance to TP — inverse (closer to TP = safer) (15 pts max negative)\n const distToTP = pctDistance(current_price, tp_price);\n if (distToTP < 0.5) {\n score -= 15;\n notes.push(`✅ Near TP (${distToTP.toFixed(2)}% away) — strong position`);\n } else if (distToTP < 1.5) {\n score -= 8;\n notes.push(`Approaching TP (${distToTP.toFixed(2)}% away)`);\n }\n\n // 3. Momentum — is price moving toward SL? (25 pts max)\n if (prev_price !== null && prev_price !== undefined) {\n const priceChange = current_price - prev_price;\n const movingTowardSL =\n (direction === \"LONG\" && priceChange < 0) ||\n (direction === \"SHORT\" && priceChange > 0);\n\n if (movingTowardSL) {\n const momentumStrength = Math.abs(priceChange / prev_price) * 100;\n const momentumScore = Math.min(25, momentumStrength * 100);\n score += momentumScore;\n if (momentumStrength > 0.1) {\n notes.push(\n `📉 Momentum against position: ${momentumStrength.toFixed(3)}% move toward SL`,\n );\n } else {\n notes.push(`Slight adverse momentum detected`);\n }\n } else {\n const momentumStrength = Math.abs(priceChange / prev_price) * 100;\n score -= Math.min(10, momentumStrength * 50);\n if (momentumStrength > 0.1) {\n notes.push(\n `📈 Momentum favorable: ${momentumStrength.toFixed(3)}% move toward TP`,\n );\n }\n }\n }\n\n // 4. DXY Correlation (15 pts max)\n // DXY up → XAU/USD down (typically). Hurts longs, helps shorts.\n if (dxy_value !== null && dxy_value !== undefined) {\n // We don't have a baseline DXY, so we use a simple heuristic:\n // DXY above 104 = dollar strength, below 103 = dollar weakness\n if (direction === \"LONG\") {\n if (dxy_value > 105) {\n score += 15;\n notes.push(`💵 DXY at ${dxy_value.toFixed(2)} — strong headwind for longs`);\n } else if (dxy_value > 104) {\n score += 8;\n notes.push(`DXY at ${dxy_value.toFixed(2)} — moderate headwind for longs`);\n }\n } else {\n // SHORT\n if (dxy_value < 102) {\n score += 15;\n notes.push(`💵 DXY at ${dxy_value.toFixed(2)} — weak dollar, headwind for shorts`);\n } else if (dxy_value < 103) {\n score += 8;\n notes.push(`DXY at ${dxy_value.toFixed(2)} — slight headwind for shorts`);\n }\n }\n }\n\n // 5. Invalidation level proximity (10 pts max)\n if (invalidation_level !== null && invalidation_level !== undefined) {\n const distToInvalidation = pctDistance(current_price, invalidation_level);\n if (distToInvalidation < 0.3) {\n score += 10;\n notes.push(\n `🚨 Within ${distToInvalidation.toFixed(3)}% of invalidation level`,\n );\n } else if (distToInvalidation < 0.7) {\n score += 5;\n notes.push(`Approaching invalidation level (${distToInvalidation.toFixed(2)}%)`);\n }\n }\n\n // 6. Unrealized P&L factor — if deeply underwater, risk increases\n const pnlPercent =\n direction === \"LONG\"\n ? ((current_price - entry_price) / entry_price) * 100\n : ((entry_price - current_price) / entry_price) * 100;\n\n if (pnlPercent < -0.5) {\n score += Math.min(15, Math.abs(pnlPercent) * 10);\n notes.push(`📉 Position underwater: ${pnlPercent.toFixed(2)}% unrealized loss`);\n } else if (pnlPercent > 1.0) {\n score -= 5;\n notes.push(`💰 Position in profit: +${pnlPercent.toFixed(2)}%`);\n }\n\n const finalScore = clampScore(score);\n const level = levelFromScore(finalScore);\n\n return {\n score: finalScore,\n level,\n distance_to_sl: parseFloat(distToSL.toFixed(3)),\n distance_to_tp: parseFloat(distToTP.toFixed(3)),\n notes,\n };\n}\n\n// Threshold for sending a Telegram alert\nexport function shouldAlert(\n result: RiskScoreResult,\n prevLevel: RiskLevel | null,\n): boolean {\n const levelOrder: RiskLevel[] = [\"safe\", \"caution\", \"danger\", \"critical\"];\n const currentIdx = levelOrder.indexOf(result.level);\n const prevIdx = prevLevel ? levelOrder.indexOf(prevLevel) : -1;\n\n // Alert if level escalated, or if critical\n return currentIdx > prevIdx || result.level === \"critical\";\n}\n",[],[177,242],"ed40dc6d-5a27-426c-9273-ccd5174667e8","price.ts","7840a60a-798e-11f1-b895-1607ee4eb77e",8,["D",1783378823490],"/**\n * XAU/USD Price Feed\n *\n * Fetches the current gold spot price from free APIs.\n * Tries multiple sources for redundancy.\n */\n\ninterface PriceResult {\n price: number;\n source: string;\n timestamp: string;\n}\n\nconst SOURCES = [\n {\n name: \"gold-api.com\",\n url: \"https://api.gold-api.com/price/XAU\",\n parse: (data: any) => data?.price,\n },\n {\n name: \"metals.live\",\n url: \"https://api.metals.dev/v1/latest?api_key=demo¤cy=USD&unit=toz\",\n parse: (data: any) => data?.metals?.gold,\n },\n];\n\nexport async function getGoldPrice(): Promise {\n for (const source of SOURCES) {\n try {\n const res = await fetch(source.url, {\n headers: { Accept: \"application/json\" },\n signal: AbortSignal.timeout(8000),\n });\n if (!res.ok) continue;\n const data = await res.json();\n const price = source.parse(data);\n if (typeof price === \"number\" && price > 0) {\n return {\n price,\n source: source.name,\n timestamp: new Date().toISOString(),\n };\n }\n } catch (err) {\n console.log(`[price] ${source.name} failed: ${err.message}`);\n continue;\n }\n }\n console.error(\"[price] All price sources failed\");\n return null;\n}\n\n/**\n * Get DXY (US Dollar Index) — used by the risk engine.\n * Uses a simple free forex API as a proxy.\n */\nexport async function getDXY(): Promise {\n try {\n const res = await fetch(\n \"https://api.exchangerate.host/latest?base=USD&symbols=EUR,GBP,JPY,CAD,CHF,SEK\",\n { signal: AbortSignal.timeout(8000) },\n );\n if (!res.ok) return null;\n const data = await res.json();\n // Approximate DXY from exchange rates (simplified)\n const rates = data.rates;\n if (!rates) return null;\n // DXY weights: EUR 57.6%, JPY 13.6%, GBP 11.9%, CAD 9.1%, SEK 4.2%, CHF 3.6%\n const dxy =\n 50.14348112 *\n (Math.pow(rates.EUR, -0.576) *\n Math.pow(rates.JPY, -0.136) *\n Math.pow(rates.GBP, -0.119) *\n Math.pow(rates.CAD, -0.091) *\n Math.pow(rates.SEK, -0.042) *\n Math.pow(rates.CHF, -0.036));\n return parseFloat(dxy.toFixed(2));\n } catch (err) {\n console.log(`[price] DXY fetch failed: ${err.message}`);\n return null;\n }\n}\n",[],[177,250],"cd178bc0-6908-4515-a480-f56b8420e250","demo.ts","abbde99e-798d-11f1-8123-1607ee4eb77e",7,["D",1783378480365],"import {\n initDB,\n getDemoAccount,\n updateDemoAccount,\n getOpenDemoTrades,\n closeDemoTrade,\n getAllDemoTrades,\n getActivePositions,\n} from \"./db.ts\";\nimport type { DemoAccount, DemoTrade, Position } from \"./types.ts\";\n\n/**\n * Demo Account — fully automatic paper trading\n *\n * When a signal is detected → a demo trade auto-opens\n * When a position is closed/invalidated → the demo trade auto-closes\n * When SL or TP is hit by the live price → the demo trade auto-closes\n *\n * This module provides utilities for updating demo equity in real-time\n * and auto-closing trades when SL/TP is breached.\n */\n\n// XAU/USD contract: 1 lot = 100 oz, $1 move = $100 per lot\nconst CONTRACT_SIZE = 100;\nconst PIP_VALUE_PER_LOT = 100;\n\nexport function calculatePnL(\n direction: string,\n entryPrice: number,\n currentPrice: number,\n lotSize: number,\n): number {\n const priceDiff =\n direction === \"LONG\"\n ? currentPrice - entryPrice\n : entryPrice - currentPrice;\n return priceDiff * lotSize * CONTRACT_SIZE;\n}\n\nexport async function updateDemoEquity(currentPrice: number): Promise<{\n balance: number;\n equity: number;\n unrealizedPnL: number;\n}> {\n await initDB();\n const acct = await getDemoAccount();\n const openTrades = await getOpenDemoTrades();\n\n let unrealizedPnL = 0;\n for (const trade of openTrades) {\n unrealizedPnL += calculatePnL(\n trade.direction,\n trade.entry_price,\n currentPrice,\n trade.lot_size,\n );\n }\n\n const equity = acct.balance + unrealizedPnL;\n await updateDemoAccount({ equity });\n\n return {\n balance: acct.balance,\n equity,\n unrealizedPnL,\n };\n}\n\n/**\n * Check if any open demo trades have hit SL or TP\n * Called by the VPS worker on every tick with the current price\n */\nexport async function checkDemoSLTP(currentPrice: number): Promise<{\n closed: Array<{ trade: DemoTrade; pnl: number; reason: string }>;\n}> {\n await initDB();\n const openTrades = await getOpenDemoTrades();\n const closed: Array<{ trade: DemoTrade; pnl: number; reason: string }> = [];\n\n for (const trade of openTrades) {\n let hit = false;\n let reason = \"\";\n\n if (trade.direction === \"LONG\") {\n if (currentPrice <= trade.sl_price) {\n hit = true;\n reason = \"SL hit\";\n } else if (currentPrice >= trade.tp_price) {\n hit = true;\n reason = \"TP hit\";\n }\n } else {\n if (currentPrice >= trade.sl_price) {\n hit = true;\n reason = \"SL hit\";\n } else if (currentPrice <= trade.tp_price) {\n hit = true;\n reason = \"TP hit\";\n }\n }\n\n if (hit) {\n const pnl = calculatePnL(\n trade.direction,\n trade.entry_price,\n currentPrice,\n trade.lot_size,\n );\n await closeDemoTrade(trade.id, currentPrice, pnl, pnl > 0);\n closed.push({ trade, pnl, reason });\n }\n }\n\n return { closed };\n}\n\nexport async function getDemoStats() {\n await initDB();\n const [acct, openTrades, allTrades, activePositions] = await Promise.all([\n getDemoAccount(),\n getOpenDemoTrades(),\n getAllDemoTrades(100),\n getActivePositions(),\n ]);\n\n const winRate = acct.total_trades > 0\n ? (acct.wins / acct.total_trades) * 100\n : 0;\n\n const totalPnL = acct.balance - acct.starting_balance;\n const closedTrades = allTrades.filter((t) => t.status === \"closed\");\n const avgWin = acct.wins > 0\n ? closedTrades.filter((t) => (t.pnl ?? 0) > 0).reduce(\n (sum, t) => sum + (t.pnl ?? 0),\n 0,\n ) / acct.wins\n : 0;\n const avgLoss = acct.losses > 0\n ? closedTrades.filter((t) => (t.pnl ?? 0) < 0).reduce(\n (sum, t) => sum + (t.pnl ?? 0),\n 0,\n ) / acct.losses\n : 0;\n\n return {\n ...acct,\n winRate: parseFloat(winRate.toFixed(1)),\n totalPnL: parseFloat(totalPnL.toFixed(2)),\n openTrades: openTrades.length,\n avgWin: parseFloat(avgWin.toFixed(2)),\n avgLoss: parseFloat(avgLoss.toFixed(2)),\n profitFactor: avgLoss !== 0\n ? parseFloat((avgWin / Math.abs(avgLoss)).toFixed(2))\n : 0,\n };\n}\n",[],[177,258],"45f75799-29a4-40f7-a946-04a75e9bfd2d","db.ts","9a6ebd3a-798d-11f1-bab7-1607ee4eb77e",4,["D",1783378451294],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type {\n Position,\n RiskHistoryEntry,\n DemoAccount,\n DemoTrade,\n ConfirmedSignal,\n} from \"./types.ts\";\n\n// ── Schema Setup ──────────────────────────────────────────────\nexport async function initDB() {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS positions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n signal_id TEXT UNIQUE NOT NULL,\n direction TEXT NOT NULL,\n entry_price REAL NOT NULL,\n sl_price REAL NOT NULL,\n tp_price REAL NOT NULL,\n invalidation_level REAL,\n status TEXT NOT NULL DEFAULT 'watching',\n opened_at TEXT NOT NULL DEFAULT (datetime('now')),\n closed_at TEXT,\n close_price REAL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS risk_history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n position_id INTEGER NOT NULL,\n timestamp TEXT NOT NULL DEFAULT (datetime('now')),\n risk_score REAL NOT NULL,\n risk_level TEXT NOT NULL,\n current_price REAL NOT NULL,\n distance_to_sl REAL NOT NULL,\n distance_to_tp REAL NOT NULL,\n dxy_value REAL,\n notes TEXT,\n FOREIGN KEY (position_id) REFERENCES positions(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS demo_account (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n starting_balance REAL NOT NULL DEFAULT 10000,\n balance REAL NOT NULL DEFAULT 10000,\n equity REAL NOT NULL DEFAULT 10000,\n total_trades INTEGER NOT NULL DEFAULT 0,\n wins INTEGER NOT NULL DEFAULT 0,\n losses INTEGER NOT NULL DEFAULT 0\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS demo_trades (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n position_id INTEGER,\n direction TEXT NOT NULL,\n entry_price REAL NOT NULL,\n lot_size REAL NOT NULL DEFAULT 0.1,\n sl_price REAL NOT NULL,\n tp_price REAL NOT NULL,\n status TEXT NOT NULL DEFAULT 'open',\n open_time TEXT NOT NULL DEFAULT (datetime('now')),\n close_time TEXT,\n close_price REAL,\n pnl REAL,\n FOREIGN KEY (position_id) REFERENCES positions(id)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS alerts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n position_id INTEGER,\n timestamp TEXT NOT NULL DEFAULT (datetime('now')),\n alert_type TEXT NOT NULL,\n risk_level TEXT,\n message TEXT NOT NULL,\n sent_telegram INTEGER NOT NULL DEFAULT 0,\n FOREIGN KEY (position_id) REFERENCES positions(id)\n )`,\n },\n // Seed demo account if not exists\n {\n sql: `INSERT OR IGNORE INTO demo_account (id) VALUES (1)`,\n },\n ]);\n}\n\n// ── Positions ─────────────────────────────────────────────────\nexport async function createPosition(\n sig: ConfirmedSignal,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO positions (signal_id, direction, entry_price, sl_price, tp_price, invalidation_level)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [\n sig.signal_id,\n sig.direction,\n sig.entry_price,\n sig.sl_price,\n sig.tp_price,\n sig.invalidation_level ?? null,\n ],\n });\n const result = await sqlite.execute({\n sql: `SELECT * FROM positions WHERE signal_id = ?`,\n args: [sig.signal_id],\n });\n return result.rows[0] as unknown as Position;\n}\n\nexport async function getPositionBySignal(\n signalId: string,\n): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM positions WHERE signal_id = ?`,\n args: [signalId],\n });\n return (result.rows[0] as unknown as Position) ?? null;\n}\n\nexport async function getActivePositions(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM positions WHERE status = 'watching' ORDER BY opened_at DESC`,\n );\n return result.rows as unknown as Position[];\n}\n\nexport async function getAllPositions(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM positions ORDER BY opened_at DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows as unknown as Position[];\n}\n\nexport async function closePosition(\n signalId: string,\n closePrice: number,\n status: \"closed\" | \"invalidated\",\n): Promise {\n await sqlite.execute({\n sql: `UPDATE positions SET status = ?, closed_at = datetime('now'), close_price = ? WHERE signal_id = ?`,\n args: [status, closePrice, signalId],\n });\n}\n\n// ── Risk History ──────────────────────────────────────────────\nexport async function addRiskHistory(\n entry: Omit,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO risk_history (position_id, risk_score, risk_level, current_price, distance_to_sl, distance_to_tp, dxy_value, notes)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n entry.position_id,\n entry.risk_score,\n entry.risk_level,\n entry.current_price,\n entry.distance_to_sl,\n entry.distance_to_tp,\n entry.dxy_value,\n entry.notes,\n ],\n });\n}\n\nexport async function getRiskHistory(\n positionId: number,\n limit = 100,\n): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM risk_history WHERE position_id = ? ORDER BY timestamp DESC LIMIT ?`,\n args: [positionId, limit],\n });\n return result.rows as unknown as RiskHistoryEntry[];\n}\n\nexport async function getRecentRiskHistory(\n limit = 50,\n): Promise {\n const result = await sqlite.execute({\n sql: `SELECT rh.*, p.signal_id, p.direction FROM risk_history rh\n JOIN positions p ON rh.position_id = p.id\n ORDER BY rh.timestamp DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows as unknown as (RiskHistoryEntry & {\n signal_id: string;\n direction: string;\n })[];\n}\n\n// ── Alerts ────────────────────────────────────────────────────\nexport async function addAlert(\n positionId: number | null,\n alertType: string,\n riskLevel: string | null,\n message: string,\n sentTelegram = 0,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO alerts (position_id, alert_type, risk_level, message, sent_telegram)\n VALUES (?, ?, ?, ?, ?)`,\n args: [positionId, alertType, riskLevel, message, sentTelegram],\n });\n}\n\nexport async function getRecentAlerts(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: `SELECT a.*, p.signal_id, p.direction FROM alerts a\n LEFT JOIN positions p ON a.position_id = p.id\n ORDER BY a.timestamp DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows;\n}\n\n// ── Demo Account ──────────────────────────────────────────────\nexport async function getDemoAccount(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM demo_account WHERE id = 1`,\n );\n return result.rows[0] as unknown as DemoAccount;\n}\n\nexport async function updateDemoAccount(\n updates: Partial,\n): Promise {\n const fields: string[] = [];\n const values: any[] = [];\n for (const [key, val] of Object.entries(updates)) {\n fields.push(`${key} = ?`);\n values.push(val);\n }\n if (fields.length === 0) return;\n await sqlite.execute({\n sql: `UPDATE demo_account SET ${fields.join(\", \")} WHERE id = 1`,\n args: values,\n });\n}\n\nexport async function openDemoTrade(\n positionId: number,\n direction: string,\n entryPrice: number,\n slPrice: number,\n tpPrice: number,\n lotSize = 0.1,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO demo_trades (position_id, direction, entry_price, lot_size, sl_price, tp_price)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [positionId, direction, entryPrice, lotSize, slPrice, tpPrice],\n });\n const result = await sqlite.execute(\n `SELECT * FROM demo_trades ORDER BY id DESC LIMIT 1`,\n );\n return result.rows[0] as unknown as DemoTrade;\n}\n\nexport async function closeDemoTrade(\n tradeId: number,\n closePrice: number,\n pnl: number,\n won: boolean,\n): Promise {\n await sqlite.batch([\n {\n sql: `UPDATE demo_trades SET status = 'closed', close_time = datetime('now'), close_price = ?, pnl = ? WHERE id = ?`,\n args: [closePrice, pnl, tradeId],\n },\n {\n sql: `UPDATE demo_account SET \n balance = balance + ?,\n total_trades = total_trades + 1,\n ${won ? \"wins = wins + 1\" : \"losses = losses + 1\"}\n WHERE id = 1`,\n args: [pnl],\n },\n ]);\n}\n\nexport async function getOpenDemoTrades(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM demo_trades WHERE status = 'open' ORDER BY open_time DESC`,\n );\n return result.rows as unknown as DemoTrade[];\n}\n\nexport async function getAllDemoTrades(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM demo_trades ORDER BY open_time DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows as unknown as DemoTrade[];\n}\n\n// ── Stats ─────────────────────────────────────────────────────\nexport async function getStats() {\n const [positions, activeCount, demoAcct, recentAlerts] = await Promise.all([\n sqlite.execute(`SELECT COUNT(*) as count FROM positions`),\n sqlite.execute(\n `SELECT COUNT(*) as count FROM positions WHERE status = 'watching'`,\n ),\n getDemoAccount(),\n sqlite.execute(\n `SELECT COUNT(*) as count FROM alerts WHERE sent_telegram = 1`,\n ),\n ]);\n return {\n total_positions: (positions.rows[0] as any).count,\n active_positions: (activeCount.rows[0] as any).count,\n demo_balance: demoAcct.balance,\n demo_equity: demoAcct.equity,\n demo_total_trades: demoAcct.total_trades,\n demo_wins: demoAcct.wins,\n demo_losses: demoAcct.losses,\n total_alerts: (recentAlerts.rows[0] as any).count,\n };\n}\n",[],[177,266],["D",1783377986977],[206,207,208,209,210,211,212],[177],"47b99117-7059-4e9e-b3f9-e5a420af5ef0","index.tsx","019f399c-53b8-772f-829b-41904fe42d5b",["D",1783377974103],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./components/App.tsx\";\n\nconst root = document.getElementById(\"root\");\nif (!root) {\n throw new Error(\"No root element found\");\n}\n\ncreateRoot(root).render();",[],[184,277],"3c962e87-f5cd-4a76-97da-38abbc26f7db","index.html","019f399c-53b8-772f-829b-3e8fb19d5c60",["D",1783377974103],"\n\n \n \n \n React Hono Val Town Starter\n \n \n \n \n

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

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

\n );\n}\n",[],[184,305,298],"components","928fa12c-0586-4062-89cd-2b1deff42f1f","App.tsx","019f399c-53b8-772f-829b-2e007a6a5e28",["D",1783377974103],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { Counter } from \"./Counter.tsx\";\n\nexport function App() {\n return (\n

React + Hono Starter

\n \n

\n View source\n

\n );\n}\n",[],[184,305,307],"aca8e727-efad-4577-9fa8-a29735808a6a",["D",1783377974103],[200,201],[184,305],["D",1783377974103],[199,202,203,204],[184],["D",1783377974103],["D",1789525245864],{"_112":111,"_120":116},{"_112":111,"_113":114,"_115":116,"_19":63,"_117":118,"_119":31},{"_13":97,"_38":98,"_50":49,"_99":51,"_100":101,"_102":103,"_104":57,"_105":106,"_107":108,"_109":52,"_110":111},"ctx",{"_90":-5,"_142":358,"_359":360,"_361":362,"_363":31,"_364":31,"_365":31,"_366":67,"_367":-5,"_368":-7,"_369":-7,"_370":71,"_371":31,"_372":31,"_373":-5,"_374":31,"_375":31,"_376":31,"_377":-5},"ENV",{"_329":330,"_331":332,"_333":98,"_334":335,"_336":337,"_338":339,"_340":341,"_342":343,"_344":345,"_346":347,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357},"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 · v9