\n \n\n\n","label",[155,156,64],"src","frontend","pulls","branches",1,"forks","envVars",{"_165":26,"_167":26},"connections",{"_165":26,"_166":26},"count","unfilledCount","emptyCount",{"_32":423,"_13":422,"_62":415,"_42":-5,"_34":35,"_148":416,"_149":84,"_36":424,"_38":26,"_65":299,"_151":-5,"_66":24,"_153":-5,"_206":425,"_17":426},{"_32":412,"_13":413,"_62":414,"_42":415,"_34":35,"_148":416,"_149":84,"_36":417,"_38":26,"_65":418,"_151":419,"_66":24,"_153":-5,"_206":420,"_17":421},{"_32":408,"_13":155,"_62":297,"_42":-5,"_34":35,"_148":203,"_149":84,"_36":409,"_38":26,"_65":299,"_151":-5,"_66":24,"_153":-5,"_206":410,"_17":411},{"_32":404,"_13":156,"_62":147,"_42":297,"_34":35,"_148":387,"_149":84,"_36":405,"_38":26,"_65":299,"_151":-5,"_66":24,"_153":-5,"_206":406,"_17":407},{"_32":400,"_13":392,"_62":386,"_42":147,"_34":35,"_148":387,"_149":84,"_36":401,"_38":26,"_65":299,"_151":-5,"_66":24,"_153":-5,"_206":402,"_17":403},{"_32":393,"_13":394,"_62":395,"_42":386,"_34":35,"_148":387,"_149":84,"_36":396,"_38":26,"_65":222,"_151":397,"_66":24,"_153":-5,"_206":398,"_17":399},{"_32":383,"_13":384,"_62":385,"_42":386,"_34":35,"_148":387,"_149":84,"_36":388,"_38":26,"_65":222,"_151":389,"_66":24,"_153":-5,"_206":390,"_17":391},{"_32":379,"_13":338,"_62":332,"_42":147,"_34":35,"_148":358,"_149":84,"_36":380,"_38":26,"_65":299,"_151":-5,"_66":24,"_153":-5,"_206":381,"_17":382},{"_32":371,"_13":372,"_62":373,"_42":332,"_34":35,"_148":374,"_149":84,"_36":375,"_38":26,"_65":222,"_151":376,"_66":24,"_153":-5,"_206":377,"_17":378},{"_32":363,"_13":364,"_62":365,"_42":332,"_34":35,"_148":366,"_149":84,"_36":367,"_38":26,"_65":222,"_151":368,"_66":24,"_153":-5,"_206":369,"_17":370},{"_32":355,"_13":356,"_62":357,"_42":332,"_34":35,"_148":358,"_149":84,"_36":359,"_38":26,"_65":222,"_151":360,"_66":24,"_153":-5,"_206":361,"_17":362},{"_32":347,"_13":348,"_62":349,"_42":332,"_34":35,"_148":350,"_149":84,"_36":351,"_38":26,"_65":222,"_151":352,"_66":24,"_153":-5,"_206":353,"_17":354},{"_32":339,"_13":340,"_62":341,"_42":332,"_34":35,"_148":342,"_149":84,"_36":343,"_38":26,"_65":222,"_151":344,"_66":24,"_153":-5,"_206":345,"_17":346},{"_32":329,"_13":330,"_62":331,"_42":332,"_34":35,"_148":333,"_149":84,"_36":334,"_38":26,"_65":222,"_151":335,"_66":24,"_153":-5,"_206":336,"_17":337},{"_32":321,"_13":322,"_62":323,"_42":147,"_34":35,"_148":324,"_149":84,"_36":325,"_38":26,"_65":222,"_151":326,"_66":24,"_153":-5,"_206":327,"_17":328},{"_32":313,"_13":314,"_62":315,"_42":147,"_34":35,"_148":316,"_149":84,"_36":317,"_38":26,"_65":222,"_151":318,"_66":24,"_153":-5,"_206":319,"_17":320},{"_32":146,"_13":64,"_62":63,"_42":147,"_34":35,"_148":39,"_149":84,"_36":310,"_38":26,"_65":21,"_151":152,"_66":24,"_153":-5,"_206":311,"_17":312},{"_32":302,"_13":303,"_62":304,"_42":147,"_34":35,"_148":305,"_149":84,"_36":306,"_38":26,"_65":222,"_151":307,"_66":24,"_153":-5,"_206":308,"_17":309},{"_32":296,"_13":226,"_62":219,"_42":297,"_34":35,"_148":203,"_149":84,"_36":298,"_38":26,"_65":299,"_151":-5,"_66":24,"_153":-5,"_206":300,"_17":301},{"_32":288,"_13":289,"_62":290,"_42":219,"_34":35,"_148":291,"_149":84,"_36":292,"_38":26,"_65":222,"_151":293,"_66":24,"_153":-5,"_206":294,"_17":295},{"_32":280,"_13":281,"_62":282,"_42":219,"_34":35,"_148":283,"_149":84,"_36":284,"_38":26,"_65":222,"_151":285,"_66":24,"_153":-5,"_206":286,"_17":287},{"_32":272,"_13":273,"_62":274,"_42":219,"_34":35,"_148":275,"_149":84,"_36":276,"_38":26,"_65":222,"_151":277,"_66":24,"_153":-5,"_206":278,"_17":279},{"_32":265,"_13":266,"_62":267,"_42":219,"_34":35,"_148":203,"_149":84,"_36":268,"_38":26,"_65":222,"_151":269,"_66":24,"_153":-5,"_206":270,"_17":271},{"_32":258,"_13":259,"_62":260,"_42":219,"_34":35,"_148":203,"_149":84,"_36":261,"_38":26,"_65":222,"_151":262,"_66":24,"_153":-5,"_206":263,"_17":264},{"_32":251,"_13":252,"_62":253,"_42":219,"_34":35,"_148":203,"_149":84,"_36":254,"_38":26,"_65":222,"_151":255,"_66":24,"_153":-5,"_206":256,"_17":257},{"_32":243,"_13":244,"_62":245,"_42":219,"_34":35,"_148":246,"_149":84,"_36":247,"_38":26,"_65":222,"_151":248,"_66":24,"_153":-5,"_206":249,"_17":250},{"_32":235,"_13":236,"_62":237,"_42":219,"_34":35,"_148":238,"_149":84,"_36":239,"_38":26,"_65":222,"_151":240,"_66":24,"_153":-5,"_206":241,"_17":242},{"_32":227,"_13":228,"_62":229,"_42":219,"_34":35,"_148":230,"_149":84,"_36":231,"_38":26,"_65":222,"_151":232,"_66":24,"_153":-5,"_206":233,"_17":234},{"_32":216,"_13":217,"_62":218,"_42":219,"_34":35,"_148":220,"_149":84,"_36":221,"_38":26,"_65":222,"_151":223,"_66":24,"_153":-5,"_206":224,"_17":225},{"_32":209,"_13":210,"_62":211,"_42":-5,"_34":35,"_148":110,"_149":84,"_36":212,"_38":26,"_65":21,"_151":213,"_66":24,"_153":-5,"_206":214,"_17":215},{"_32":199,"_13":200,"_62":82,"_42":-5,"_34":35,"_148":201,"_149":84,"_36":202,"_38":203,"_65":204,"_151":205,"_66":24,"_153":-5,"_206":207,"_17":208},"d3704d3f-5c45-4e21-9292-005e4bcffcb4","main.ts",13,["D",1783808408215],2,"http","// Gold Protection Bot — HTTP API + dashboard server.\nimport { Hono } from \"npm:hono@4\";\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { fetchCandles, fetchQuote, INTERVALS, type Interval } from \"./src/lib/market.ts\";\nimport { runProtectionPipeline, checkOpenTrades } from \"./src/lib/pipeline.ts\";\nimport { sendTelegramMessage } from \"./src/lib/telegram.ts\";\nimport { generateBotResponse } from \"./src/lib/chat.ts\";\nimport { runProtection } from \"./src/lib/protection.ts\";\nimport { analyze } from \"./src/lib/analysis.ts\";\nimport {\n getSettings, getTelegram, listSignals, listProtection,\n listTrades, getOpenTrades, openTrade, closeTrade,\n saveChat, listChat, updateSettings,\n} from \"./src/lib/db.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst json = (data: unknown, status = 200) =>\n new Response(JSON.stringify(data), { status, headers: { \"Content-Type\": \"application/json\" } });\n\n// ---------- Market data ----------\napp.get(\"/api/market-data\", async (c) => {\n const settings = await getSettings();\n if (!settings.hasApiKey) return json({ error: \"No API key configured\" }, 400);\n const interval = (c.req.query(\"interval\") ?? \"5min\") as Interval;\n const what = c.req.query(\"type\") ?? \"candles\";\n try {\n if (what === \"quote\") return json(await fetchQuote(settings.apiKey));\n const outputsize = Number(c.req.query(\"outputsize\") ?? \"200\");\n const candles = await fetchCandles(settings.apiKey, interval, outputsize);\n return json({ interval, candles });\n } catch (e) {\n return json({ error: String(e) }, 502);\n }\n});\n\napp.get(\"/api/intervals\", (c) => json([...INTERVALS]));\n\n// ---------- Protection check ----------\napp.post(\"/api/protect\", async (c) => {\n const r = await runProtectionPipeline();\n return json(r, r.ok ? 200 : 400);\n});\n\n// ---------- Source bot signals (fetch from external URL) ----------\napp.get(\"/api/source-signals\", async (c) => {\n const settings = await getSettings();\n if (!settings.sourceBotUrl) return json([]);\n try {\n const res = await fetch(`${settings.sourceBotUrl}/api/bot/signals?limit=10`);\n if (!res.ok) return json([]);\n const data = await res.json();\n return json(data);\n } catch {\n return json([]);\n }\n});\n\n// ---------- Signals ----------\napp.get(\"/api/signals\", async (c) => {\n const limit = Number(c.req.query(\"limit\") ?? \"50\");\n return json(await listSignals(limit));\n});\n\n// ---------- Protection alerts ----------\napp.get(\"/api/protection\", async (c) => {\n const limit = Number(c.req.query(\"limit\") ?? \"50\");\n return json(await listProtection(limit));\n});\n\n// ---------- Demo trades ----------\napp.get(\"/api/trades\", async (c) => {\n return json(await listTrades(100));\n});\n\napp.get(\"/api/trades/open\", async (c) => {\n return json(await getOpenTrades());\n});\n\napp.post(\"/api/trades/open\", async (c) => {\n const b = await c.req.json();\n const settings = await getSettings();\n const id = await openTrade({\n direction: b.direction,\n entry: b.entry,\n stopLoss: b.stopLoss,\n takeProfit: b.takeProfit,\n size: Number(b.size ?? 0.1),\n source: b.source ?? \"MANUAL\",\n note: b.note ?? \"\",\n });\n return json({ id });\n});\n\napp.post(\"/api/trades/:id/close\", async (c) => {\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const settings = await getSettings();\n let closePrice = b.price;\n if (!closePrice && settings.hasApiKey) {\n const q = await fetchQuote(settings.apiKey).catch(() => null);\n if (q) closePrice = q.price;\n }\n if (!closePrice) return json({ error: \"No close price available\" }, 400);\n await closeTrade(id, closePrice, b.status ?? \"CLOSED_MANUAL\");\n return json({ ok: true, closePrice });\n});\n\napp.post(\"/api/trades/check\", async (c) => {\n const r = await checkOpenTrades();\n return json(r);\n});\n\n// ---------- Chat ----------\napp.get(\"/api/chat\", async (c) => {\n return json(await listChat(100));\n});\n\napp.post(\"/api/chat\", async (c) => {\n const b = await c.req.json();\n const userText = b.text as string;\n if (!userText?.trim()) return json({ error: \"Empty message\" }, 400);\n\n // Save user message\n await saveChat(\"user\", userText);\n\n // Build chat context\n const settings = await getSettings();\n let candles: any[] = [];\n let candles1h: any[] = [];\n let protection: any = null;\n let sourceSignals: any[] = [];\n\n if (settings.hasApiKey) {\n try {\n [candles, candles1h] = await Promise.all([\n fetchCandles(settings.apiKey, \"5min\", 250),\n fetchCandles(settings.apiKey, \"1h\", 150),\n ]);\n } catch {}\n }\n\n const openTrades = await getOpenTrades();\n const recentSignals = await listSignals(1);\n const latestSignal = recentSignals[0];\n\n // Fetch source signals\n if (settings.sourceBotUrl) {\n try {\n const res = await fetch(`${settings.sourceBotUrl}/api/bot/signals?limit=5`);\n if (res.ok) sourceSignals = await res.json();\n } catch {}\n }\n\n // Run protection if we have data\n if (candles.length >= 60) {\n protection = runProtection(candles, candles1h, {\n openTrades,\n signalDirection: latestSignal?.direction ?? \"NEUTRAL\",\n signalEntry: latestSignal?.entry ?? 0,\n signalSL: latestSignal?.stopLoss ?? 0,\n });\n }\n\n const botReply = generateBotResponse(userText, {\n candles, candles1h, openTrades, protection,\n signalDirection: latestSignal?.direction ?? \"NEUTRAL\",\n signalEntry: latestSignal?.entry ?? 0,\n signalSL: latestSignal?.stopLoss ?? 0,\n sourceSignals,\n });\n\n await saveChat(\"bot\", botReply);\n return json({ reply: botReply });\n});\n\n// ---------- Settings ----------\napp.get(\"/api/settings\", async (c) => {\n const s = await getSettings();\n const { apiKey: _omit, ...safe } = s;\n return json(safe);\n});\n\napp.patch(\"/api/settings\", async (c) => {\n await updateSettings(await c.req.json());\n return json({ ok: true });\n});\n\n// ---------- Telegram ----------\napp.get(\"/api/telegram\", async (c) => {\n const t = await getTelegram();\n const { botToken: _omit, ...safe } = t;\n return json(safe);\n});\n\napp.patch(\"/api/telegram\", async (c) => {\n const { updateTelegram } = await import(\"./src/lib/db.ts\");\n await updateTelegram(await c.req.json());\n return json({ ok: true });\n});\n\napp.post(\"/api/telegram/test\", async (c) => {\n const t = await getTelegram();\n if (!t.hasToken || !t.chatId) return json({ ok: false, error: \"Configure bot token and chat ID first\" }, 400);\n const r = await sendTelegramMessage(\n t.botToken, t.chatId,\n \"🛡️ Gold Protection Bot connected!\\nYou'll receive stop loss reversal alerts here.\",\n );\n return json(r, r.ok ? 200 : 400);\n});\n\n// ---------- View source ----------\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ---------- Static dashboard ----------\napp.get(\"/\", async () => serveFile(\"./src/frontend/index.html\", import.meta.url));\n\nexport default app.fetch;\n","children",[],[200],"d02ac736-7fc2-4fe2-bf69-f9ca956a8438","README.md","20f32994-7d77-11f1-af1a-1607ee4eb77e",["D",1783808603247],"# 🛡️ Gold Protection Bot\n\nA gold trading protection bot built on Val Town that detects early stop loss reversals, provides a live trading demo chat, and minimizes losses through deep multi-layer analysis.\n\n⚠️ For educational and research purposes only. Gold trading carries significant financial risk.\n\n## Features\n\n- **Stop Loss Reversal Detection** — Monitors 7 reversal signal types: SL approach, RSI/MACD divergence, market structure breaks, liquidity sweeps, candlestick reversal patterns, momentum shifts, and EMA trend flips\n- **Live Trading Chat** — Interactive chat assistant that analyzes live market data and gives contextual trade recommendations (auto or manual mode)\n- **Paper Trading Demo** — Open/close simulated trades with live P&L tracking, win/loss stats, and automatic SL/TP monitoring\n- **Source Bot Integration** — Pulls recent signals from the Weru Gold Bot to use as context for protection analysis\n- **Telegram Alerts** — Protection warnings, trade signals, and auto-trade notifications sent to your phone\n- **Auto-Trade Mode** — Automatically opens trades on strong signals and closes them when protection level hits DANGER/CRITICAL\n\n## Getting Started\n\n1. **Settings** → paste your Twelve Data API key (free tier: 800 calls/day)\n2. **Dashboard** → click \"Run Protection Check\" to start analysis\n3. **Live Chat** → type \"scan\", \"price\", \"buy\", or \"risk\" for instant analysis\n4. **Demo Trade** → open paper trades with SL/TP and track P&L\n5. **Telegram** (optional) → add bot token + chat ID for push alerts\n6. **Dashboard** → \"Start Auto-Check\" for 24/7 monitoring (every 15 min)\n\n## Protection Levels\n\n| Level | Score | Action |\n|-------|-------|--------|\n| ✅ SAFE | 0-24 | Hold position |\n| ⚠️ CAUTION | 25-59 | Tighten stop loss |\n| 🛑 DANGER | 60-84 | Close position now |\n| 🚨 CRITICAL | 85-100 | Consider reversing |\n\n## Architecture\n\n```\nfetch → /api/protect → pipeline → protection engine → persist → notify\n ↓\n analysis engine (hybrid)\n ↓\n auto-trade (if enabled)\n```\n\n## File Map\n\n| Path | Purpose |\n|------|---------|\n| `main.ts` | Hono HTTP API + serves dashboard |\n| `cron/autocheck.ts` | Scheduled auto-protection check (every 15 min) |\n| `src/lib/protection.ts` | Stop loss reversal detection engine |\n| `src/lib/chat.ts` | AI-style trading chat assistant |\n| `src/lib/pipeline.ts` | Fetch → protect → persist → notify → auto-trade |\n| `src/lib/analysis.ts` | Hybrid analysis engine (from Weru bot) |\n| `src/lib/indicators.ts` | EMA/RSI/MACD/ATR/swing math |\n| `src/lib/patterns.ts` | Candlestick pattern detection |\n| `src/lib/market.ts` | Twelve Data fetcher |\n| `src/lib/telegram.ts` | Telegram notifier |\n| `src/lib/db.ts` | SQLite schema + helpers (6 tables) |\n| `src/frontend/*` | React dashboard (6 tabs) |\n\n## Notes\n\n- Reuses the Weru Gold Bot's analysis engine for signal generation\n- Source bot URL defaults to the Weru bot endpoint (configurable in Settings)\n- Free Val Town tier enforces 15-minute minimum cron interval\n",[],[210],"333bc296-a2bd-48d5-a192-47eab71ec7da","types.ts","77cdf2f4-7d76-11f1-8014-1607ee4eb77e","019f5341-e82c-752f-ba2a-73c8294ed509",6,["D",1783808319370],"script","// Shared types for the Gold Protection Bot.\n\nexport interface Candle {\n time: number;\n open: number;\n high: number;\n low: number;\n close: number;\n volume: number;\n}\n\nexport type Direction = \"BUY\" | \"SELL\" | \"NEUTRAL\";\n\nexport interface AnalysisFactor {\n name: string;\n side: \"bullish\" | \"bearish\" | \"neutral\";\n weight: number;\n detail: string;\n}\n\nexport type ProtectionLevel = \"SAFE\" | \"CAUTION\" | \"DANGER\" | \"CRITICAL\";\n\nexport type ReversalType =\n | \"SL_APPROACH\" // price heading toward SL\n | \"DIVERGENCE\" // RSI/MACD divergence against position\n | \"STRUCTURE_BREAK\" // market structure broke against position\n | \"LIQUIDITY_SWEEP\" // liquidity swept — reversal likely\n | \"PATTERN_REVERSAL\" // reversal candlestick pattern\n | \"MOMENTUM_SHIFT\" // momentum shifted against position\n | \"TREND_FLIP\"; // EMA trend flipped\n\nexport interface ReversalSignal {\n type: ReversalType;\n severity: ProtectionLevel;\n message: string;\n detail: string;\n}\n\nexport interface ProtectionResult {\n level: ProtectionLevel;\n score: number; // 0-100, higher = more danger\n signals: ReversalSignal[];\n price: number;\n distanceToSL: number | null; // in price units\n distanceToSLPct: number | null; // as % of price\n recommendedAction: \"HOLD\" | \"TIGHTEN_SL\" | \"CLOSE_NOW\" | \"REVERSE\";\n reasoning: string[];\n timestamp: number;\n}\n\nexport interface AnalysisResult {\n direction: Direction;\n confidence: number;\n entry: number;\n stopLoss: number;\n takeProfits: [number, number, number];\n riskRewardRatios: [number, number, number];\n atr: number;\n bullishScore: number;\n bearishScore: number;\n factors: AnalysisFactor[];\n session: TradingSession;\n reasoning: string[];\n timestamp: number;\n}\n\nexport type TradingSession =\n | \"London\"\n | \"NY-London Overlap\"\n | \"New York\"\n | \"Asian/Low Liquidity\";\n\n// ---------- Demo Trading ----------\nexport interface DemoTrade {\n id: number;\n direction: Direction;\n entry: number;\n stopLoss: number;\n takeProfit: number;\n size: number; // lot size\n status: \"OPEN\" | \"CLOSED_WIN\" | \"CLOSED_LOSS\" | \"CLOSED_MANUAL\";\n closePrice: number | null;\n pnl: number | null;\n openedAt: number;\n closedAt: number | null;\n source: \"MANUAL\" | \"AUTO\";\n note: string;\n}\n\n// ---------- Chat ----------\nexport interface ChatMessage {\n id: number;\n role: \"user\" | \"bot\";\n text: string;\n timestamp: number;\n metadata?: string; // JSON string for extra data\n}\n\nexport interface SourceSignal {\n id: number;\n direction: string;\n confidence: number;\n entry: number;\n stopLoss: number;\n takeProfits: number[];\n session: string;\n createdAt: number;\n status: string;\n}\n\nexport interface CustomStrategy {\n id: number;\n name: string;\n description: string;\n side: \"bullish\" | \"bearish\";\n weight: number;\n active: boolean;\n condition: StrategyCondition;\n}\n\nexport interface StrategyCondition {\n indicator: \"rsi\" | \"ema_trend\" | \"macd_hist\" | \"price_vs_ema200\";\n operator: \"<\" | \">\" | \"==\";\n value: number;\n}\n",[],[155,226,217],"lib","9e5cde69-b12b-4906-bb76-58b78a615b44","telegram.ts","77bfa0aa-7d76-11f1-94da-1607ee4eb77e",4,["D",1783808319363],"// Telegram notifier for protection alerts + signals.\nimport type { AnalysisResult, ProtectionResult } from \"./types.ts\";\n\nexport async function sendTelegramMessage(\n botToken: string,\n chatId: string,\n text: string,\n): Promise<{ ok: boolean; error?: string }> {\n if (!botToken || !chatId) return { ok: false, error: \"Missing bot token or chat ID\" };\n try {\n const res = await fetch(`https://api.telegram.org/bot${botToken}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n const json = await res.json();\n if (!json.ok) return { ok: false, error: json.description ?? \"Telegram API error\" };\n return { ok: true };\n } catch (e) {\n return { ok: false, error: String(e) };\n }\n}\n\nexport function formatProtectionMessage(p: ProtectionResult): string {\n const emojis: Record = {\n SAFE: \"✅\", CAUTION: \"⚠️\", DANGER: \"🛑\", CRITICAL: \"🚨\",\n };\n const actions: Record = {\n HOLD: \"HOLD position\", TIGHTEN_SL: \"TIGHTEN stop loss\",\n CLOSE_NOW: \"CLOSE position now\", REVERSE: \"Consider REVERSING\",\n };\n const lines = [\n `${emojis[p.level]} Protection Alert: ${p.level}`,\n `Risk Score: ${p.score}/100`,\n `Action: ${actions[p.recommendedAction]}`,\n ``,\n ];\n if (p.distanceToSLPct !== null) {\n lines.push(`Distance to SL: ${p.distanceToSL.toFixed(2)} (${p.distanceToSLPct.toFixed(2)}%)`);\n }\n lines.push(``, `Warnings:`);\n for (const s of p.signals.slice(0, 6)) {\n lines.push(`• ${s.message}`);\n }\n lines.push(``, `Gold Protection Bot — minimize your losses.`);\n return lines.join(\"\\n\");\n}\n\nexport function formatSignalMessage(a: AnalysisResult): string {\n const emoji = a.direction === \"BUY\" ? \"🟢\" : a.direction === \"SELL\" ? \"🔴\" : \"⚪\";\n const arrow = a.direction === \"BUY\" ? \"▲\" : a.direction === \"SELL\" ? \"▼\" : \"■\";\n const lines = [\n `${emoji} XAU/USD ${a.direction} ${arrow}`,\n `Confidence: ${a.confidence}%`,\n `Session: ${a.session}`,\n ``,\n `Entry: ${a.entry}`,\n `Stop Loss: ${a.stopLoss}`,\n `TP1 (${a.riskRewardRatios[0]}R): ${a.takeProfits[0]}`,\n `TP2 (${a.riskRewardRatios[1]}R): ${a.takeProfits[1]}`,\n `TP3 (${a.riskRewardRatios[2]}R): ${a.takeProfits[2]}`,\n `ATR: ${a.atr}`,\n ``,\n `Score: 🟢 ${a.bullishScore} / 🔴 ${a.bearishScore}`,\n ``,\n `Why:`,\n ...a.reasoning.slice(0, 6).map((r) => `• ${r}`),\n ``,\n `Gold Protection Bot — trade smart.`,\n ];\n return lines.join(\"\\n\");\n}\n",[],[155,226,228],"91e506e3-c026-440d-934d-a2daf81c805f","protection.ts","9a378b5c-7d76-11f1-a4b9-1607ee4eb77e",9,["D",1783808377108],"// Stop Loss Reversal Detection Engine — the core protection logic.\n// Analyzes live candles + open positions to detect early reversal signals.\nimport type {\n Candle, Direction, ProtectionLevel, ProtectionResult,\n ReversalSignal, ReversalType, DemoTrade,\n} from \"./types.ts\";\nimport { atr, ema, last, macd, rsi, swingPoints } from \"./indicators.ts\";\nimport { detectPatterns } from \"./patterns.ts\";\n\nconst SEVERITY: Record = { SAFE: 0, CAUTION: 25, DANGER: 60, CRITICAL: 85 };\n\nfunction levelFromScore(score: number): ProtectionLevel {\n if (score >= 85) return \"CRITICAL\";\n if (score >= 60) return \"DANGER\";\n if (score >= 25) return \"CAUTION\";\n return \"SAFE\";\n}\n\nexport function getSession(date = new Date()) {\n const h = date.getUTCHours();\n if (h >= 13 && h < 16) return \"NY-London Overlap\";\n if (h >= 7 && h < 13) return \"London\";\n if (h >= 16 && h < 21) return \"New York\";\n return \"Asian/Low Liquidity\";\n}\n\ninterface ProtectionContext {\n /** Open demo trades — if any, we check price vs their SL/TP */\n openTrades: DemoTrade[];\n /** Direction of the last signal (from source bot or our own) */\n signalDirection: Direction;\n /** Signal entry + SL from the latest signal */\n signalEntry: number;\n signalSL: number;\n}\n\nexport function runProtection(\n candles: Candle[],\n candles1h: Candle[],\n ctx: ProtectionContext,\n now = new Date(),\n): ProtectionResult {\n const signals: ReversalSignal[] = [];\n let score = 0;\n const closes = candles.map((c) => c.close);\n const price = last(closes);\n const reasoning: string[] = [];\n\n const ema20 = last(ema(closes, 20));\n const ema50 = last(ema(closes, 50));\n const ema200 = last(ema(closes, 200));\n const rsiv = last(rsi(closes, 14));\n const macdArr = macd(closes);\n const mp = last(macdArr);\n const mpPrev = macdArr[macdArr.length - 2];\n const atrv = last(atr(candles, 14)) || price * 0.002;\n const swings = swingPoints(candles, 2);\n\n // Determine the \"position direction\" — either from open trades or the latest signal\n const hasOpenTrades = ctx.openTrades.length > 0;\n const positionDir: Direction = hasOpenTrades\n ? ctx.openTrades[0].direction\n : ctx.signalDirection;\n\n // For open trades, check distance to SL\n let distanceToSL: number | null = null;\n let distanceToSLPct: number | null = null;\n if (hasOpenTrades) {\n const t = ctx.openTrades[0];\n distanceToSL = Math.abs(price - t.stopLoss);\n distanceToSLPct = (distanceToSL / price) * 100;\n // If price is within 0.3% of SL → critical danger\n if (distanceToSLPct < 0.3) {\n score += 85;\n signals.push({ type: \"SL_APPROACH\", severity: \"CRITICAL\",\n message: `Price ${distanceToSLPct.toFixed(2)}% from stop loss (${t.stopLoss})`,\n detail: \"Price is dangerously close to SL — exit or tighten now\" });\n reasoning.push(\"SL_APPROACH: Price within 0.3% of stop loss\");\n } else if (distanceToSLPct < 0.6) {\n score += 50;\n signals.push({ type: \"SL_APPROACH\", severity: \"DANGER\",\n message: `Price ${distanceToSLPct.toFixed(2)}% from stop loss (${t.stopLoss})`,\n detail: \"Price approaching SL — consider tightening\" });\n reasoning.push(\"SL_APPROACH: Price within 0.6% of SL\");\n } else if (distanceToSLPct < 1.0) {\n score += 20;\n signals.push({ type: \"SL_APPROACH\", severity: \"CAUTION\",\n message: `Price ${distanceToSLPct.toFixed(2)}% from stop loss (${t.stopLoss})`,\n detail: \"Monitor closely — price heading toward SL\" });\n reasoning.push(\"SL_APPROACH: Price within 1% of SL\");\n }\n } else if (ctx.signalDirection !== \"NEUTRAL\") {\n // No open trade but we have a signal — check if price is moving against the signal\n distanceToSL = Math.abs(price - ctx.signalSL);\n distanceToSLPct = (distanceToSL / price) * 100;\n }\n\n // --- Trend flip detection ---\n if (!Number.isNaN(ema20) && !Number.isNaN(ema50)) {\n const wasBullish = ema20 > ema50;\n // Check if EMA20 crossed EMA50 recently\n const ema20Arr = ema(closes, 20);\n const ema50Arr = ema(closes, 50);\n const prevDiff = ema20Arr[ema20Arr.length - 3] - ema50Arr[ema50Arr.length - 3];\n const curDiff = ema20 - ema50;\n const crossedDown = prevDiff > 0 && curDiff < 0;\n const crossedUp = prevDiff < 0 && curDiff > 0;\n\n if (positionDir === \"BUY\" && crossedDown) {\n score += 70;\n signals.push({ type: \"TREND_FLIP\", severity: \"DANGER\",\n message: \"EMA20 crossed below EMA50 — trend flipping bearish\",\n detail: \"Bullish trend has reversed to bearish\" });\n reasoning.push(\"TREND_FLIP: EMA20/50 bearish crossover against BUY position\");\n }\n if (positionDir === \"SELL\" && crossedUp) {\n score += 70;\n signals.push({ type: \"TREND_FLIP\", severity: \"DANGER\",\n message: \"EMA20 crossed above EMA50 — trend flipping bullish\",\n detail: \"Bearish trend has reversed to bullish\" });\n reasoning.push(\"TREND_FLIP: EMA20/50 bullish crossover against SELL position\");\n }\n }\n\n // --- EMA 200 bias flip ---\n if (!Number.isNaN(ema200)) {\n if (positionDir === \"BUY\" && price < ema200) {\n score += 30;\n signals.push({ type: \"TREND_FLIP\", severity: \"CAUTION\",\n message: \"Price now below EMA200 — long-term bias turned bearish\",\n detail: \"Price below 200 EMA\" });\n reasoning.push(\"TREND_FLIP: Price below EMA200 against BUY position\");\n }\n if (positionDir === \"SELL\" && price > ema200) {\n score += 30;\n signals.push({ type: \"TREND_FLIP\", severity: \"CAUTION\",\n message: \"Price now above EMA200 — long-term bias turned bullish\",\n detail: \"Price above 200 EMA\" });\n reasoning.push(\"TREND_FLIP: Price above EMA200 against SELL position\");\n }\n }\n\n // --- Momentum shift: MACD histogram changing direction against position ---\n if (mp && !Number.isNaN(mp.histogram) && mpPrev && !Number.isNaN(mpPrev.histogram)) {\n const histDecel = Math.abs(mp.histogram) < Math.abs(mpPrev.histogram);\n const histFlip = (mp.histogram > 0 && mpPrev.histogram <= 0) || (mp.histogram < 0 && mpPrev.histogram >= 0);\n if (positionDir === \"BUY\" && (histDecel && mp.histogram < mpPrev.histogram)) {\n score += 25;\n signals.push({ type: \"MOMENTUM_SHIFT\", severity: \"CAUTION\",\n message: \"MACD histogram decelerating — bullish momentum weakening\",\n detail: `MACD hist: ${mp.histogram.toFixed(3)} (was ${mpPrev.histogram.toFixed(3)})` });\n reasoning.push(\"MOMENTUM_SHIFT: MACD decelerating against BUY\");\n }\n if (positionDir === \"SELL\" && (histDecel && mp.histogram > mpPrev.histogram)) {\n score += 25;\n signals.push({ type: \"MOMENTUM_SHIFT\", severity: \"CAUTION\",\n message: \"MACD histogram rising — bearish momentum weakening\",\n detail: `MACD hist: ${mp.histogram.toFixed(3)} (was ${mpPrev.histogram.toFixed(3)})` });\n reasoning.push(\"MOMENTUM_SHIFT: MACD rising against SELL\");\n }\n if (positionDir === \"BUY\" && histFlip && mp.histogram < 0) {\n score += 40;\n signals.push({ type: \"MOMENTUM_SHIFT\", severity: \"DANGER\",\n message: \"MACD flipped negative — momentum fully reversed\",\n detail: \"MACD histogram crossed below zero\" });\n reasoning.push(\"MOMENTUM_SHIFT: MACD flipped negative against BUY\");\n }\n if (positionDir === \"SELL\" && histFlip && mp.histogram > 0) {\n score += 40;\n signals.push({ type: \"MOMENTUM_SHIFT\", severity: \"DANGER\",\n message: \"MACD flipped positive — momentum fully reversed\",\n detail: \"MACD histogram crossed above zero\" });\n reasoning.push(\"MOMENTUM_SHIFT: MACD flipped positive against SELL\");\n }\n }\n\n // --- RSI divergence: price making new extremes but RSI diverging ---\n if (!Number.isNaN(rsiv) && swings.length >= 4) {\n const rsiArr = rsi(closes, 14);\n if (positionDir === \"BUY\") {\n const lows = swings.filter((s) => s.type === \"low\").slice(-2);\n if (lows.length === 2 && lows[1].price < lows[0].price && rsiArr[lows[1].index] > rsiArr[lows[0].index]) {\n score += 45;\n signals.push({ type: \"DIVERGENCE\", severity: \"DANGER\",\n message: \"Bullish RSI divergence exhausted — price lower lows but RSI higher\",\n detail: \"RSI divergence often precedes reversal\" });\n reasoning.push(\"DIVERGENCE: Bearish RSI divergence against BUY position\");\n }\n }\n if (positionDir === \"SELL\") {\n const highs = swings.filter((s) => s.type === \"high\").slice(-2);\n if (highs.length === 2 && highs[1].price > highs[0].price && rsiArr[highs[1].index] < rsiArr[highs[0].index]) {\n score += 45;\n signals.push({ type: \"DIVERGENCE\", severity: \"DANGER\",\n message: \"Bearish RSI divergence exhausted — price higher highs but RSI lower\",\n detail: \"RSI divergence often precedes reversal\" });\n reasoning.push(\"DIVERGENCE: Bullish RSI divergence against SELL position\");\n }\n }\n // RSI extreme against position\n if (positionDir === \"BUY\" && rsiv > 75) {\n score += 20;\n signals.push({ type: \"MOMENTUM_SHIFT\", severity: \"CAUTION\",\n message: `RSI overbought (${rsiv.toFixed(0)}) — reversal risk`,\n detail: \"RSI above 75\" });\n reasoning.push(\"RSI overbought against BUY position\");\n }\n if (positionDir === \"SELL\" && rsiv < 25) {\n score += 20;\n signals.push({ type: \"MOMENTUM_SHIFT\", severity: \"CAUTION\",\n message: `RSI oversold (${rsiv.toFixed(0)}) — reversal risk`,\n detail: \"RSI below 25\" });\n reasoning.push(\"RSI oversold against SELL position\");\n }\n }\n\n // --- Market structure break ---\n const highs = swings.filter((s) => s.type === \"high\").slice(-3);\n const lows = swings.filter((s) => s.type === \"low\").slice(-3);\n if (highs.length >= 2 && lows.length >= 2) {\n const hh = highs[highs.length - 1].price > highs[highs.length - 2].price;\n const hl = lows[lows.length - 1].price > lows[lows.length - 2].price;\n const lh = highs[highs.length - 1].price < highs[highs.length - 2].price;\n const ll = lows[lows.length - 1].price < lows[lows.length - 2].price;\n if (positionDir === \"BUY\" && lh && ll) {\n score += 55;\n signals.push({ type: \"STRUCTURE_BREAK\", severity: \"DANGER\",\n message: \"Market structure shifted to LH/LL — downtrend confirmed\",\n detail: \"Lower highs + lower lows\" });\n reasoning.push(\"STRUCTURE_BREAK: LH/LL structure against BUY position\");\n }\n if (positionDir === \"SELL\" && hh && hl) {\n score += 55;\n signals.push({ type: \"STRUCTURE_BREAK\", severity: \"DANGER\",\n message: \"Market structure shifted to HH/HL — uptrend confirmed\",\n detail: \"Higher highs + higher lows\" });\n reasoning.push(\"STRUCTURE_BREAK: HH/HL structure against SELL position\");\n }\n }\n\n // --- Liquidity sweep detection ---\n const cur = last(candles);\n const recentHighs = swings.filter((s) => s.type === \"high\").slice(-4);\n const recentLows = swings.filter((s) => s.type === \"low\").slice(-4);\n let bullishSweep = false;\n let bearishSweep = false;\n for (const lo of recentLows) {\n if (cur.low < lo.price && cur.close > lo.price && cur.close > cur.open) bullishSweep = true;\n }\n for (const hi of recentHighs) {\n if (cur.high > hi.price && cur.close < hi.price && cur.close < cur.open) bearishSweep = true;\n }\n if (positionDir === \"BUY\" && bearishSweep) {\n score += 50;\n signals.push({ type: \"LIQUIDITY_SWEEP\", severity: \"DANGER\",\n message: \"Buy-side liquidity swept — price took out highs then reversed down\",\n detail: \"Bearish liquidity sweep\" });\n reasoning.push(\"LIQUIDITY_SWEEP: Buy-side liquidity swept against BUY\");\n }\n if (positionDir === \"SELL\" && bullishSweep) {\n score += 50;\n signals.push({ type: \"LIQUIDITY_SWEEP\", severity: \"DANGER\",\n message: \"Sell-side liquidity swept — price took out lows then reversed up\",\n detail: \"Bullish liquidity sweep\" });\n reasoning.push(\"LIQUIDITY_SWEEP: Sell-side liquidity swept against SELL\");\n }\n\n // --- Reversal candlestick patterns ---\n for (const pat of detectPatterns(candles)) {\n if (positionDir === \"BUY\" && pat.side === \"bearish\") {\n score += 20;\n signals.push({ type: \"PATTERN_REVERSAL\", severity: \"CAUTION\",\n message: `Bearish candlestick pattern: ${pat.name}`,\n detail: `${pat.name} detected` });\n reasoning.push(`PATTERN_REVERSAL: ${pat.name} against BUY position`);\n }\n if (positionDir === \"SELL\" && pat.side === \"bullish\") {\n score += 20;\n signals.push({ type: \"PATTERN_REVERSAL\", severity: \"CAUTION\",\n message: `Bullish candlestick pattern: ${pat.name}`,\n detail: `${pat.name} detected` });\n reasoning.push(`PATTERN_REVERSAL: ${pat.name} against SELL position`);\n }\n }\n\n // --- Higher TF bias conflict ---\n if (candles1h.length >= 50) {\n const h = candles1h.map((c) => c.close);\n const he20 = last(ema(h, 20));\n const he50 = last(ema(h, 50));\n if (!Number.isNaN(he20) && !Number.isNaN(he50)) {\n if (positionDir === \"BUY\" && he20 < he50) {\n score += 25;\n signals.push({ type: \"TREND_FLIP\", severity: \"CAUTION\",\n message: \"1H trend is bearish — conflicts with your BUY position\",\n detail: \"1H EMA20 below EMA50\" });\n reasoning.push(\"1H bias bearish against BUY\");\n }\n if (positionDir === \"SELL\" && he20 > he50) {\n score += 25;\n signals.push({ type: \"TREND_FLIP\", severity: \"CAUTION\",\n message: \"1H trend is bullish — conflicts with your SELL position\",\n detail: \"1H EMA20 above EMA50\" });\n reasoning.push(\"1H bias bullish against SELL\");\n }\n }\n }\n\n // --- Session risk ---\n const session = getSession(now);\n if (session === \"Asian/Low Liquidity\") {\n score += 10;\n reasoning.push(\"Low-liquidity session: increased reversal risk\");\n signals.push({ type: \"MOMENTUM_SHIFT\", severity: \"CAUTION\",\n message: \"Low-liquidity session — moves can be erratic\",\n detail: \"Asian session\" });\n }\n\n // Cap score at 100\n score = Math.min(100, score);\n const level = levelFromScore(score);\n\n // Recommended action\n let action: ProtectionResult[\"recommendedAction\"] = \"HOLD\";\n if (score >= 85) action = \"REVERSE\";\n else if (score >= 60) action = \"CLOSE_NOW\";\n else if (score >= 25) action = \"TIGHTEN_SL\";\n\n if (reasoning.length === 0) {\n reasoning.push(\"All clear — no reversal signals detected. Position looks safe.\");\n }\n\n return {\n level, score, signals, price,\n distanceToSL, distanceToSLPct,\n recommendedAction: action,\n reasoning, timestamp: Math.floor(now.getTime() / 1000),\n };\n}\n",[],[155,226,236],"f51f8bc6-47d4-42d1-8c31-20a8d5cf5622","pipeline.ts","9a30b8e0-7d76-11f1-ba0e-1607ee4eb77e",8,["D",1783808377105],"// Full pipeline: fetch data → run protection check → persist → notify → auto-trade.\nimport { runProtection } from \"./protection.ts\";\nimport { fetchCandles, fetchQuote } from \"./market.ts\";\nimport { formatProtectionMessage, sendTelegramMessage, formatSignalMessage } from \"./telegram.ts\";\nimport {\n getSettings, getTelegram, getOpenTrades, saveProtection, saveSignal,\n listSignals, closeTrade, openTrade, saveChat,\n} from \"./db.ts\";\nimport { generateAutoAlert } from \"./chat.ts\";\nimport { analyze } from \"./analysis.ts\";\nimport type { ProtectionResult, AnalysisResult } from \"./types.ts\";\n\nexport interface PipelineResult {\n ok: boolean;\n error?: string;\n protection?: ProtectionResult;\n analysis?: AnalysisResult;\n protectionId?: number;\n signalId?: number;\n telegramSent: boolean;\n telegramError?: string;\n autoTraded: boolean;\n}\n\nconst LEVEL_ORDER = [\"SAFE\", \"CAUTION\", \"DANGER\", \"CRITICAL\"];\n\nexport async function runProtectionPipeline(): Promise {\n const settings = await getSettings();\n if (!settings.hasApiKey) {\n return { ok: false, error: \"No Twelve Data API key configured\", telegramSent: false, autoTraded: false };\n }\n\n let c5, c1h;\n try {\n [c5, c1h] = await Promise.all([\n fetchCandles(settings.apiKey, \"5min\", 250),\n fetchCandles(settings.apiKey, \"1h\", 150),\n ]);\n } catch (e) {\n return { ok: false, error: String(e), telegramSent: false, autoTraded: false };\n }\n if (c5.length < 60) {\n return { ok: false, error: \"Not enough 5min candles returned\", telegramSent: false, autoTraded: false };\n }\n\n // Get context: open trades + latest signal\n const openTrades = await getOpenTrades();\n const recentSignals = await listSignals(1);\n const latestSignal = recentSignals[0];\n\n // Run analysis (reuse the hybrid engine)\n const analysis = analyze(c5, c1h, { riskReward: settings.riskReward });\n\n // Run protection check\n const protection = runProtection(c5, c1h, {\n openTrades,\n signalDirection: latestSignal?.direction ?? analysis.direction,\n signalEntry: latestSignal?.entry ?? analysis.entry,\n signalSL: latestSignal?.stopLoss ?? analysis.stopLoss,\n });\n\n // Save protection alert\n const tg = await getTelegram();\n let telegramSent = false;\n let telegramError: string | undefined;\n\n // Check if this alert level meets the notification threshold\n const meetsThreshold = LEVEL_ORDER.indexOf(protection.level) >= LEVEL_ORDER.indexOf(tg.minAlertLevel);\n if (tg.hasToken && tg.chatId && tg.notifyProtection && meetsThreshold) {\n const r = await sendTelegramMessage(tg.botToken, tg.chatId, formatProtectionMessage(protection));\n telegramSent = r.ok;\n telegramError = r.error;\n }\n\n const protectionId = await saveProtection(protection, telegramSent);\n\n // Auto-chat: log critical alerts to chat\n if (protection.level === \"DANGER\" || protection.level === \"CRITICAL\") {\n await saveChat(\"bot\", generateAutoAlert(protection));\n }\n\n // Auto-trade logic: if auto-trade is on, close losing positions or open new ones\n let autoTraded = false;\n if (settings.autoTrade) {\n // Close open trades if protection is DANGER/CRITICAL\n if (openTrades.length > 0 && (protection.level === \"DANGER\" || protection.level === \"CRITICAL\")) {\n const t = openTrades[0];\n const quote = await fetchQuote(settings.apiKey).catch(() => null);\n if (quote) {\n await closeTrade(t.id, quote.price, \"CLOSED_LOSS\");\n await saveChat(\"bot\", `🤖 AUTO-CLOSED trade #${t.id} at ${quote.price.toFixed(2)} — protection level ${protection.level}`);\n autoTraded = true;\n }\n }\n // Open a new trade if no open positions and we have a strong signal\n if (openTrades.length === 0 && analysis.direction !== \"NEUTRAL\" && analysis.confidence >= 60 && protection.score < 25) {\n const risk = Math.abs(analysis.entry - analysis.stopLoss);\n const tp = analysis.direction === \"BUY\"\n ? analysis.entry + risk * settings.riskReward[0]\n : analysis.entry - risk * settings.riskReward[0];\n const id = await openTrade({\n direction: analysis.direction,\n entry: analysis.entry,\n stopLoss: analysis.stopLoss,\n takeProfit: tp,\n size: 0.1,\n source: \"AUTO\",\n note: `Auto-opened: ${analysis.confidence}% confidence, protection score ${protection.score}`,\n });\n await saveChat(\"bot\", `🤖 AUTO-OPENED ${analysis.direction} trade #${id} at ${analysis.entry} — SL ${analysis.stopLoss}, TP ${tp.toFixed(2)}`);\n if (tg.hasToken && tg.chatId && tg.notifyTrades) {\n await sendTelegramMessage(tg.botToken, tg.chatId,\n `🤖 Auto-trade opened: ${analysis.direction} at ${analysis.entry} (SL: ${analysis.stopLoss}, TP: ${tp.toFixed(2)})`);\n }\n autoTraded = true;\n }\n }\n\n // Also save the signal\n let signalId: number | undefined;\n let signalTelegramSent = false;\n if (analysis.direction !== \"NEUTRAL\") {\n if (tg.hasToken && tg.chatId && tg.notifySignals) {\n const r = await sendTelegramMessage(tg.botToken, tg.chatId, formatSignalMessage(analysis));\n signalTelegramSent = r.ok;\n }\n signalId = await saveSignal(analysis, signalTelegramSent);\n }\n\n return {\n ok: true, protection, analysis, protectionId, signalId,\n telegramSent: telegramSent || signalTelegramSent,\n telegramError, autoTraded,\n };\n}\n\n// Check open trades against live price — auto-close if SL or TP hit\nexport async function checkOpenTrades(): Promise<{ closed: number; messages: string[] }> {\n const settings = await getSettings();\n if (!settings.hasApiKey) return { closed: 0, messages: [] };\n const openTrades = await getOpenTrades();\n if (openTrades.length === 0) return { closed: 0, messages: [] };\n\n let quote;\n try {\n quote = await fetchQuote(settings.apiKey);\n } catch {\n return { closed: 0, messages: [] };\n }\n\n const price = quote.price;\n let closed = 0;\n const messages: string[] = [];\n\n for (const t of openTrades) {\n let hitSL = false;\n let hitTP = false;\n if (t.direction === \"BUY\") {\n if (price <= t.stopLoss) hitSL = true;\n else if (price >= t.takeProfit) hitTP = true;\n } else {\n if (price >= t.stopLoss) hitSL = true;\n else if (price <= t.takeProfit) hitTP = true;\n }\n if (hitSL) {\n await closeTrade(t.id, t.stopLoss, \"CLOSED_LOSS\");\n messages.push(`📉 Trade #${t.id} hit stop loss at ${t.stopLoss}`);\n closed++;\n } else if (hitTP) {\n await closeTrade(t.id, t.takeProfit, \"CLOSED_WIN\");\n messages.push(`📈 Trade #${t.id} hit take profit at ${t.takeProfit}`);\n closed++;\n }\n }\n\n return { closed, messages };\n}\n",[],[155,226,244],"84c75377-6d4e-4f30-8879-8060d93d9513","patterns.ts","019f5341-e82c-752f-ba2a-7b0c15e4a4bb",["D",1783808256047],"// Candlestick pattern detection (11 patterns) on the most recent candles.\nimport type { Candle } from \"./types.ts\";\n\nexport interface PatternHit {\n name: string;\n side: \"bullish\" | \"bearish\";\n}\n\nconst body = (c: Candle) => Math.abs(c.close - c.open);\nconst range = (c: Candle) => c.high - c.low || 1e-9;\nconst upperWick = (c: Candle) => c.high - Math.max(c.open, c.close);\nconst lowerWick = (c: Candle) => Math.min(c.open, c.close) - c.low;\nconst isBull = (c: Candle) => c.close > c.open;\nconst isBear = (c: Candle) => c.close < c.open;\n\n// Evaluate patterns ending at the last candle.\nexport function detectPatterns(candles: Candle[]): PatternHit[] {\n const hits: PatternHit[] = [];\n const n = candles.length;\n if (n < 3) return hits;\n const c = candles[n - 1];\n const p = candles[n - 2];\n const p2 = candles[n - 3];\n const b = body(c);\n const r = range(c);\n\n // Doji\n if (b <= r * 0.1) hits.push({ name: \"Doji\", side: isBull(c) ? \"bullish\" : \"bearish\" });\n\n // Hammer (bullish): small body up top, long lower wick\n if (lowerWick(c) >= b * 2 && upperWick(c) <= b * 0.6 && b > 0) {\n hits.push({ name: \"Hammer\", side: \"bullish\" });\n }\n\n // Shooting Star (bearish): small body down low, long upper wick\n if (upperWick(c) >= b * 2 && lowerWick(c) <= b * 0.6 && b > 0) {\n hits.push({ name: \"Shooting Star\", side: \"bearish\" });\n }\n\n // Pin Bar (either side) — wick >= 66% of range\n if (lowerWick(c) >= r * 0.66) hits.push({ name: \"Bullish Pin Bar\", side: \"bullish\" });\n if (upperWick(c) >= r * 0.66) hits.push({ name: \"Bearish Pin Bar\", side: \"bearish\" });\n\n // Marubozu — body is nearly the whole range\n if (b >= r * 0.9) {\n hits.push({ name: \"Marubozu\", side: isBull(c) ? \"bullish\" : \"bearish\" });\n }\n\n // Bullish Engulfing\n if (isBear(p) && isBull(c) && c.close >= p.open && c.open <= p.close) {\n hits.push({ name: \"Bullish Engulfing\", side: \"bullish\" });\n }\n // Bearish Engulfing\n if (isBull(p) && isBear(c) && c.open >= p.close && c.close <= p.open) {\n hits.push({ name: \"Bearish Engulfing\", side: \"bearish\" });\n }\n\n // Morning Star (bullish reversal): big bear, small body, big bull\n if (\n isBear(p2) && body(p2) > range(p2) * 0.5 &&\n body(p) < range(p) * 0.4 &&\n isBull(c) && body(c) > range(c) * 0.5 &&\n c.close > (p2.open + p2.close) / 2\n ) {\n hits.push({ name: \"Morning Star\", side: \"bullish\" });\n }\n // Evening Star (bearish reversal)\n if (\n isBull(p2) && body(p2) > range(p2) * 0.5 &&\n body(p) < range(p) * 0.4 &&\n isBear(c) && body(c) > range(c) * 0.5 &&\n c.close < (p2.open + p2.close) / 2\n ) {\n hits.push({ name: \"Evening Star\", side: \"bearish\" });\n }\n\n return hits;\n}\n",[],[155,226,252],"468d57ff-f237-4d2a-aef6-d210df6853bb","market.ts","019f5341-e82c-752f-ba2a-7ff15818049f",["D",1783808256047],"// Twelve Data market-data fetcher for XAU/USD.\nimport type { Candle } from \"./types.ts\";\n\nconst BASE = \"https://api.twelvedata.com\";\nexport const SYMBOL = \"XAU/USD\";\n\nexport const INTERVALS = [\"1min\", \"5min\", \"15min\", \"30min\", \"1h\", \"1day\"] as const;\nexport type Interval = (typeof INTERVALS)[number];\n\nexport interface Quote {\n symbol: string;\n price: number;\n change: number;\n percentChange: number;\n timestamp: number;\n}\n\ninterface TDError {\n status?: string;\n code?: number;\n message?: string;\n}\n\nfunction assertOk(json: any) {\n if (json && (json.status === \"error\" || json.code >= 400)) {\n const e = json as TDError;\n throw new Error(`Twelve Data error${e.code ? ` (${e.code})` : \"\"}: ${e.message ?? \"unknown\"}`);\n }\n}\n\nexport async function fetchCandles(\n apiKey: string,\n interval: Interval = \"5min\",\n outputsize = 250,\n): Promise {\n const url = `${BASE}/time_series?symbol=${encodeURIComponent(SYMBOL)}&interval=${interval}` +\n `&outputsize=${outputsize}&order=ASC&apikey=${encodeURIComponent(apiKey)}`;\n const res = await fetch(url);\n const json = await res.json();\n assertOk(json);\n if (!json.values) return [];\n return (json.values as any[]).map((v) => ({\n time: Math.floor(new Date(v.datetime.replace(\" \", \"T\") + \"Z\").getTime() / 1000),\n open: parseFloat(v.open),\n high: parseFloat(v.high),\n low: parseFloat(v.low),\n close: parseFloat(v.close),\n volume: v.volume ? parseFloat(v.volume) : 0,\n }));\n}\n\nexport async function fetchQuote(apiKey: string): Promise {\n const url = `${BASE}/quote?symbol=${encodeURIComponent(SYMBOL)}&apikey=${encodeURIComponent(apiKey)}`;\n const res = await fetch(url);\n const json = await res.json();\n assertOk(json);\n return {\n symbol: SYMBOL,\n price: parseFloat(json.close ?? json.price ?? \"0\"),\n change: parseFloat(json.change ?? \"0\"),\n percentChange: parseFloat(json.percent_change ?? \"0\"),\n timestamp: json.timestamp ? Number(json.timestamp) : Math.floor(Date.now() / 1000),\n };\n}\n",[],[155,226,259],"5f976a88-550b-42a9-a7ed-1546fb31563f","indicators.ts","019f5341-e82c-752f-ba2a-7474cc7d27c1",["D",1783808256047],"// Pure technical-indicator math. No I/O, fully unit-testable.\nimport type { Candle } from \"./types.ts\";\n\nexport function sma(values: number[], period: number): number[] {\n const out: number[] = [];\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) {\n out.push(NaN);\n continue;\n }\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) sum += values[j];\n out.push(sum / period);\n }\n return out;\n}\n\nexport function ema(values: number[], period: number): number[] {\n const out: number[] = [];\n const k = 2 / (period + 1);\n let prev = NaN;\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) {\n out.push(NaN);\n continue;\n }\n if (Number.isNaN(prev)) {\n // seed with SMA of first `period` values\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) sum += values[j];\n prev = sum / period;\n } else {\n prev = values[i] * k + prev * (1 - k);\n }\n out.push(prev);\n }\n return out;\n}\n\nexport function rsi(values: number[], period = 14): number[] {\n const out: number[] = new Array(values.length).fill(NaN);\n if (values.length <= period) return out;\n let gain = 0;\n let loss = 0;\n for (let i = 1; i <= period; i++) {\n const diff = values[i] - values[i - 1];\n if (diff >= 0) gain += diff;\n else loss -= diff;\n }\n let avgGain = gain / period;\n let avgLoss = loss / period;\n out[period] = avgLoss === 0 ? 100 : 100 - 100 / (1 + avgGain / avgLoss);\n for (let i = period + 1; i < values.length; i++) {\n const diff = values[i] - values[i - 1];\n const up = diff >= 0 ? diff : 0;\n const down = diff < 0 ? -diff : 0;\n avgGain = (avgGain * (period - 1) + up) / period;\n avgLoss = (avgLoss * (period - 1) + down) / period;\n out[i] = avgLoss === 0 ? 100 : 100 - 100 / (1 + avgGain / avgLoss);\n }\n return out;\n}\n\nexport interface MacdPoint {\n macd: number;\n signal: number;\n histogram: number;\n}\n\nexport function macd(\n values: number[],\n fast = 12,\n slow = 26,\n signalPeriod = 9,\n): MacdPoint[] {\n const emaFast = ema(values, fast);\n const emaSlow = ema(values, slow);\n const macdLine = values.map((_, i) => emaFast[i] - emaSlow[i]);\n // signal = EMA of macdLine (ignoring leading NaNs)\n const cleanIdx = macdLine.findIndex((v) => !Number.isNaN(v));\n const signalRaw = ema(\n macdLine.map((v) => (Number.isNaN(v) ? 0 : v)),\n signalPeriod,\n );\n return values.map((_, i) => {\n const m = macdLine[i];\n const s = i >= cleanIdx ? signalRaw[i] : NaN;\n return { macd: m, signal: s, histogram: m - s };\n });\n}\n\nexport function atr(candles: Candle[], period = 14): number[] {\n const out: number[] = new Array(candles.length).fill(NaN);\n if (candles.length < 2) return out;\n const trs: number[] = [0];\n for (let i = 1; i < candles.length; i++) {\n const h = candles[i].high;\n const l = candles[i].low;\n const pc = candles[i - 1].close;\n trs.push(Math.max(h - l, Math.abs(h - pc), Math.abs(l - pc)));\n }\n let sum = 0;\n for (let i = 1; i <= period && i < trs.length; i++) sum += trs[i];\n let prev = sum / period;\n out[period] = prev;\n for (let i = period + 1; i < candles.length; i++) {\n prev = (prev * (period - 1) + trs[i]) / period;\n out[i] = prev;\n }\n return out;\n}\n\nexport interface SwingPoint {\n index: number;\n price: number;\n type: \"high\" | \"low\";\n}\n\n// Find swing highs/lows using a left/right window (fractal-style).\nexport function swingPoints(candles: Candle[], window = 2): SwingPoint[] {\n const out: SwingPoint[] = [];\n for (let i = window; i < candles.length - window; i++) {\n let isHigh = true;\n let isLow = true;\n for (let j = i - window; j <= i + window; j++) {\n if (j === i) continue;\n if (candles[j].high >= candles[i].high) isHigh = false;\n if (candles[j].low <= candles[i].low) isLow = false;\n }\n if (isHigh) out.push({ index: i, price: candles[i].high, type: \"high\" });\n if (isLow) out.push({ index: i, price: candles[i].low, type: \"low\" });\n }\n return out;\n}\n\nexport const last = (arr: T[]): T => arr[arr.length - 1];\n",[],[155,226,266],"d96254ce-84de-47bc-811d-639ba0002e1a","db.ts","77c6dc1c-7d76-11f1-a1f2-1607ee4eb77e",5,["D",1783808319375],"// Data layer: SQLite schema + typed helpers for the gold protection bot.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { AnalysisResult, ChatMessage, DemoTrade, ProtectionResult } from \"./types.ts\";\n\nconst PREFIX = \"gold_prot\";\nexport const T = {\n signals: `${PREFIX}_signals`,\n protection: `${PREFIX}_alerts`,\n trades: `${PREFIX}_demo_trades`,\n chat: `${PREFIX}_chat`,\n telegram: `${PREFIX}_telegram_config`,\n settings: `${PREFIX}_bot_settings`,\n};\n\nlet initialized = false;\nexport async function initDb() {\n if (initialized) return;\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.signals} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n direction TEXT NOT NULL,\n confidence INTEGER NOT NULL,\n entry REAL NOT NULL,\n stop_loss REAL NOT NULL,\n tp1 REAL NOT NULL, tp2 REAL NOT NULL, tp3 REAL NOT NULL,\n atr REAL NOT NULL,\n bullish_score REAL NOT NULL,\n bearish_score REAL NOT NULL,\n session TEXT NOT NULL,\n reasoning TEXT NOT NULL,\n factors TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'open',\n telegram_sent INTEGER NOT NULL DEFAULT 0,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.protection} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n level TEXT NOT NULL,\n score INTEGER NOT NULL,\n price REAL NOT NULL,\n signals TEXT NOT NULL,\n reasoning TEXT NOT NULL,\n action TEXT NOT NULL,\n telegram_sent INTEGER NOT NULL DEFAULT 0,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.trades} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n direction TEXT NOT NULL,\n entry REAL NOT NULL,\n stop_loss REAL NOT NULL,\n take_profit REAL NOT NULL,\n size REAL NOT NULL DEFAULT 0.1,\n status TEXT NOT NULL DEFAULT 'OPEN',\n close_price REAL,\n pnl REAL,\n opened_at INTEGER NOT NULL,\n closed_at INTEGER,\n source TEXT NOT NULL DEFAULT 'MANUAL',\n note TEXT DEFAULT ''\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.chat} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n role TEXT NOT NULL,\n text TEXT NOT NULL,\n metadata TEXT,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.telegram} (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n bot_token TEXT DEFAULT '',\n chat_id TEXT DEFAULT '',\n notify_protection INTEGER NOT NULL DEFAULT 1,\n notify_signals INTEGER NOT NULL DEFAULT 1,\n notify_trades INTEGER NOT NULL DEFAULT 0,\n min_alert_level TEXT NOT NULL DEFAULT 'CAUTION'\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.settings} (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n api_key TEXT DEFAULT '',\n risk_per_trade REAL NOT NULL DEFAULT 1,\n rr1 REAL NOT NULL DEFAULT 1.5,\n rr2 REAL NOT NULL DEFAULT 2.5,\n rr3 REAL NOT NULL DEFAULT 4.0,\n scan_interval_min INTEGER NOT NULL DEFAULT 15,\n bot_running INTEGER NOT NULL DEFAULT 0,\n auto_trade INTEGER NOT NULL DEFAULT 0,\n source_bot_url TEXT DEFAULT 'https://weruweruu--6836bf0471e311f1af651607ee4eb77e.web.val.run'\n )`,\n },\n { sql: `INSERT OR IGNORE INTO ${T.telegram} (id) VALUES (1)` },\n { sql: `INSERT OR IGNORE INTO ${T.settings} (id) VALUES (1)` },\n ]);\n initialized = true;\n}\n\n// ---------- Settings ----------\nexport interface BotSettings {\n apiKey: string;\n hasApiKey: boolean;\n riskPerTrade: number;\n riskReward: [number, number, number];\n scanIntervalMin: number;\n botRunning: boolean;\n autoTrade: boolean;\n sourceBotUrl: string;\n}\n\nexport async function getSettings(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.settings} WHERE id = 1`);\n const row = r.rows[0] as Record;\n return {\n apiKey: String(row.api_key ?? \"\"),\n hasApiKey: !!row.api_key,\n riskPerTrade: Number(row.risk_per_trade),\n riskReward: [Number(row.rr1), Number(row.rr2), Number(row.rr3)],\n scanIntervalMin: Number(row.scan_interval_min),\n botRunning: !!row.bot_running,\n autoTrade: !!row.auto_trade,\n sourceBotUrl: String(row.source_bot_url ?? \"\"),\n };\n}\n\nexport async function updateSettings(p: Partial) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.apiKey !== undefined && p.apiKey !== \"\") { sets.push(\"api_key = ?\"); args.push(p.apiKey); }\n if (p.riskPerTrade !== undefined) { sets.push(\"risk_per_trade = ?\"); args.push(p.riskPerTrade); }\n if (p.riskReward) { sets.push(\"rr1 = ?\", \"rr2 = ?\", \"rr3 = ?\"); args.push(...p.riskReward); }\n if (p.scanIntervalMin !== undefined) { sets.push(\"scan_interval_min = ?\"); args.push(p.scanIntervalMin); }\n if (p.botRunning !== undefined) { sets.push(\"bot_running = ?\"); args.push(p.botRunning ? 1 : 0); }\n if (p.autoTrade !== undefined) { sets.push(\"auto_trade = ?\"); args.push(p.autoTrade ? 1 : 0); }\n if (p.sourceBotUrl !== undefined) { sets.push(\"source_bot_url = ?\"); args.push(p.sourceBotUrl); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.settings} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Telegram config ----------\nexport interface TelegramConfig {\n botToken: string;\n hasToken: boolean;\n chatId: string;\n notifyProtection: boolean;\n notifySignals: boolean;\n notifyTrades: boolean;\n minAlertLevel: string;\n}\n\nexport async function getTelegram(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.telegram} WHERE id = 1`);\n const row = r.rows[0] as Record;\n return {\n botToken: String(row.bot_token ?? \"\"),\n hasToken: !!row.bot_token,\n chatId: String(row.chat_id ?? \"\"),\n notifyProtection: !!row.notify_protection,\n notifySignals: !!row.notify_signals,\n notifyTrades: !!row.notify_trades,\n minAlertLevel: String(row.min_alert_level ?? \"CAUTION\"),\n };\n}\n\nexport async function updateTelegram(p: Partial) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.botToken !== undefined && p.botToken !== \"\") { sets.push(\"bot_token = ?\"); args.push(p.botToken); }\n if (p.chatId !== undefined) { sets.push(\"chat_id = ?\"); args.push(p.chatId); }\n if (p.notifyProtection !== undefined) { sets.push(\"notify_protection = ?\"); args.push(p.notifyProtection ? 1 : 0); }\n if (p.notifySignals !== undefined) { sets.push(\"notify_signals = ?\"); args.push(p.notifySignals ? 1 : 0); }\n if (p.notifyTrades !== undefined) { sets.push(\"notify_trades = ?\"); args.push(p.notifyTrades ? 1 : 0); }\n if (p.minAlertLevel !== undefined) { sets.push(\"min_alert_level = ?\"); args.push(p.minAlertLevel); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.telegram} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Signals ----------\nexport interface SignalRow extends AnalysisResult {\n id: number;\n status: \"open\" | \"tp_hit\" | \"sl_hit\" | \"cancelled\";\n telegramSent: boolean;\n createdAt: number;\n}\n\nexport async function saveSignal(a: AnalysisResult, telegramSent: boolean): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.signals}\n (direction, confidence, entry, stop_loss, tp1, tp2, tp3, atr, bullish_score, bearish_score, session, reasoning, factors, status, telegram_sent, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'open', ?, ?)`,\n args: [a.direction, a.confidence, a.entry, a.stopLoss, a.takeProfits[0], a.takeProfits[1], a.takeProfits[2],\n a.atr, a.bullishScore, a.bearishScore, a.session, JSON.stringify(a.reasoning), JSON.stringify(a.factors),\n telegramSent ? 1 : 0, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function listSignals(limit = 50): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT * FROM ${T.signals} ORDER BY id DESC LIMIT ?`, args: [limit] });\n return r.rows.map(rowToSignal);\n}\n\nfunction rowToSignal(row: any): SignalRow {\n return {\n id: Number(row.id), direction: row.direction, confidence: Number(row.confidence),\n entry: Number(row.entry), stopLoss: Number(row.stop_loss),\n takeProfits: [Number(row.tp1), Number(row.tp2), Number(row.tp3)],\n riskRewardRatios: [1.5, 2.5, 4.0], atr: Number(row.atr),\n bullishScore: Number(row.bullish_score), bearishScore: Number(row.bearish_score),\n session: row.session, reasoning: JSON.parse(row.reasoning || \"[]\"),\n factors: JSON.parse(row.factors || \"[]\"),\n timestamp: Math.floor(Number(row.created_at) / 1000),\n status: row.status, telegramSent: !!row.telegram_sent, createdAt: Number(row.created_at),\n } as SignalRow;\n}\n\n// ---------- Protection Alerts ----------\nexport interface ProtectionRow {\n id: number;\n level: string;\n score: number;\n price: number;\n signals: any[];\n reasoning: string[];\n action: string;\n telegramSent: boolean;\n createdAt: number;\n}\n\nexport async function saveProtection(p: ProtectionResult, telegramSent: boolean): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.protection} (level, score, price, signals, reasoning, action, telegram_sent, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [p.level, p.score, p.price, JSON.stringify(p.signals), JSON.stringify(p.reasoning),\n p.recommendedAction, telegramSent ? 1 : 0, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function listProtection(limit = 50): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT * FROM ${T.protection} ORDER BY id DESC LIMIT ?`, args: [limit] });\n return r.rows.map((row: any) => ({\n id: Number(row.id), level: row.level, score: Number(row.score), price: Number(row.price),\n signals: JSON.parse(row.signals || \"[]\"), reasoning: JSON.parse(row.reasoning || \"[]\"),\n action: row.action, telegramSent: !!row.telegram_sent, createdAt: Number(row.created_at),\n }));\n}\n\n// ---------- Demo Trades ----------\nexport async function openTrade(t: {\n direction: string; entry: number; stopLoss: number; takeProfit: number;\n size: number; source: string; note: string;\n}): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.trades} (direction, entry, stop_loss, take_profit, size, status, opened_at, source, note)\n VALUES (?, ?, ?, ?, ?, 'OPEN', ?, ?, ?)`,\n args: [t.direction, t.entry, t.stopLoss, t.takeProfit, t.size, Date.now(), t.source, t.note],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function closeTrade(id: number, closePrice: number, status: string) {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT * FROM ${T.trades} WHERE id = ?`, args: [id] });\n const row = r.rows[0] as any;\n if (!row) return;\n const entry = Number(row.entry);\n const size = Number(row.size);\n const dir = row.direction;\n const pnl = dir === \"BUY\" ? (closePrice - entry) * size * 100 : (entry - closePrice) * size * 100;\n await sqlite.execute({\n sql: `UPDATE ${T.trades} SET status = ?, close_price = ?, pnl = ?, closed_at = ? WHERE id = ?`,\n args: [status, closePrice, pnl, Date.now(), id],\n });\n}\n\nexport async function listTrades(limit = 100): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT * FROM ${T.trades} ORDER BY id DESC LIMIT ?`, args: [limit] });\n return r.rows.map((row: any) => ({\n id: Number(row.id), direction: row.direction, entry: Number(row.entry),\n stopLoss: Number(row.stop_loss), takeProfit: Number(row.take_profit),\n size: Number(row.size), status: row.status,\n closePrice: row.close_price ? Number(row.close_price) : null,\n pnl: row.pnl !== null ? Number(row.pnl) : null,\n openedAt: Number(row.opened_at), closedAt: row.closed_at ? Number(row.closed_at) : null,\n source: row.source, note: row.note ?? \"\",\n }));\n}\n\nexport async function getOpenTrades(): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT * FROM ${T.trades} WHERE status = 'OPEN' ORDER BY id DESC` });\n return r.rows.map((row: any) => ({\n id: Number(row.id), direction: row.direction, entry: Number(row.entry),\n stopLoss: Number(row.stop_loss), takeProfit: Number(row.take_profit),\n size: Number(row.size), status: row.status,\n closePrice: null, pnl: null,\n openedAt: Number(row.opened_at), closedAt: null,\n source: row.source, note: row.note ?? \"\",\n }));\n}\n\n// ---------- Chat ----------\nexport async function saveChat(role: string, text: string, metadata?: string): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.chat} (role, text, metadata, created_at) VALUES (?, ?, ?, ?)`,\n args: [role, text, metadata ?? null, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function listChat(limit = 100): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `SELECT * FROM ${T.chat} ORDER BY id DESC LIMIT ?`,\n args: [limit],\n });\n return r.rows.map((row: any) => ({\n id: Number(row.id), role: row.role, text: row.text,\n metadata: row.metadata ?? undefined, timestamp: Number(row.created_at),\n })).reverse();\n}\n",[],[155,226,273],"44c1f62a-b7b6-4d16-a983-3fe8f535aed3","chat.ts","9a285376-7d76-11f1-b139-1607ee4eb77e",7,["D",1783808377096],"// AI-style chat assistant for trading guidance.\n// Analyzes the market context and generates contextual responses.\nimport type { Candle, ProtectionResult, DemoTrade } from \"./types.ts\";\nimport { runProtection } from \"./protection.ts\";\nimport { getSession } from \"./protection.ts\";\nimport { last, ema, rsi, macd, atr } from \"./indicators.ts\";\n\nexport interface ChatContext {\n candles: Candle[];\n candles1h: Candle[];\n openTrades: DemoTrade[];\n protection: ProtectionResult | null;\n signalDirection: string;\n signalEntry: number;\n signalSL: number;\n sourceSignals: any[];\n}\n\nexport function generateBotResponse(userText: string, ctx: ChatContext): string {\n const text = userText.toLowerCase().trim();\n const price = ctx.candles.length ? last(ctx.candles.map((c) => c.close)) : 0;\n const session = getSession();\n\n // --- Command: scan / check ---\n if (text.match(/scan|check|analy|status|protect/)) {\n if (ctx.protection) {\n const p = ctx.protection;\n let msg = `🛡️ Protection Check:\\n`;\n msg += `Level: ${p.level} (score ${p.score}/100)\\n`;\n msg += `Action: ${p.recommendedAction}\\n`;\n if (p.distanceToSLPct !== null) {\n msg += `Distance to SL: ${p.distanceToSLPct.toFixed(2)}%\\n`;\n }\n if (p.signals.length > 0) {\n msg += `\\n⚠️ Active warnings:\\n`;\n for (const s of p.signals.slice(0, 5)) {\n msg += `• ${s.message}\\n`;\n }\n } else {\n msg += `\\n✅ No reversal signals detected. Position is safe.\\n`;\n }\n return msg;\n }\n return \"No protection data available yet. Click 'Run Protection Check' on the dashboard first.\";\n }\n\n // --- Command: open / buy / sell / trade ---\n if (text.match(/open|buy|sell|trade|enter|long|short/)) {\n if (ctx.signalDirection === \"NEUTRAL\") {\n return \"⚠️ No clear signal right now — direction is NEUTRAL. Wait for a stronger signal before entering a trade.\";\n }\n const dir = ctx.signalDirection;\n const entry = ctx.signalEntry;\n const sl = ctx.signalSL;\n const risk = Math.abs(entry - sl);\n const tp1 = dir === \"BUY\" ? entry + risk * 1.5 : entry - risk * 1.5;\n let msg = `📊 Based on current analysis:\\n`;\n msg += `Direction: ${dir} at ${entry.toFixed(2)}\\n`;\n msg += `Stop Loss: ${sl.toFixed(2)}\\n`;\n msg += `TP1 (1.5R): ${tp1.toFixed(2)}\\n`;\n msg += `Risk: ${risk.toFixed(2)} points\\n`;\n if (ctx.protection && ctx.protection.score > 40) {\n msg += `\\n⚠️ WARNING: Protection score is ${ctx.protection.score}/100. Consider waiting for a better entry.\\n`;\n } else {\n msg += `\\n✅ Protection score is ${ctx.protection?.score ?? 0}/100 — looks safe to enter.\\n`;\n }\n msg += `\\nGo to the Demo Trade tab to execute this as a paper trade.`;\n return msg;\n }\n\n // --- Command: close / exit ---\n if (text.match(/close|exit|stop/)) {\n if (ctx.openTrades.length === 0) {\n return \"No open trades to close.\";\n }\n const t = ctx.openTrades[0];\n const pnl = t.direction === \"BUY\" ? (price - t.entry) * t.size * 100 : (t.entry - price) * t.size * 100;\n let msg = `📉 Closing trade #${t.id}:\\n`;\n msg += `Direction: ${t.direction}\\n`;\n msg += `Entry: ${t.entry} → Current: ${price.toFixed(2)}\\n`;\n msg += `Unrealized P&L: ${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(2)}\\n`;\n if (ctx.protection && ctx.protection.score > 60) {\n msg += `\\n🛑 Protection alert: ${ctx.protection.level}. Closing now would limit losses.`;\n }\n return msg;\n }\n\n // --- Command: price / quote ---\n if (text.match(/price|quote|current|now/)) {\n const closes = ctx.candles.map((c) => c.close);\n const ema20 = last(ema(closes, 20));\n const ema50 = last(ema(closes, 50));\n const rsiv = last(rsi(closes, 14));\n const mp = last(macd(closes));\n const atrv = last(atr(ctx.candles, 14));\n let msg = `💹 XAU/USD Live:\\n`;\n msg += `Price: ${price.toFixed(2)}\\n`;\n msg += `EMA20: ${ema20.toFixed(2)} | EMA50: ${ema50.toFixed(2)}\\n`;\n msg += `RSI: ${rsiv.toFixed(1)}\\n`;\n msg += `MACD Hist: ${mp?.histogram.toFixed(3) ?? \"—\"}\\n`;\n msg += `ATR: ${atrv.toFixed(2)}\\n`;\n msg += `Session: ${session}\\n`;\n if (price > ema20 && ema20 > ema50) msg += `Trend: 🟢 Bullish`;\n else if (price < ema20 && ema20 < ema50) msg += `Trend: 🔴 Bearish`;\n else msg += `Trend: ⚪ Mixed`;\n return msg;\n }\n\n // --- Command: help ---\n if (text.match(/help|what|how|guide/)) {\n return `🤖 Gold Protection Bot Commands:\\n\\n` +\n `• \"scan\" or \"check\" — Run protection analysis\\n` +\n `• \"price\" — Get live XAU/USD quote + indicators\\n` +\n `• \"buy\" or \"sell\" — Get trade recommendation\\n` +\n `• \"close\" — Check open trade status\\n` +\n `• \"risk\" — Get risk assessment\\n` +\n `• \"signal\" — View latest source bot signal\\n\\n` +\n `I monitor your positions 24/7 and alert you before your stop loss gets hit.`;\n }\n\n // --- Command: risk ---\n if (text.match(/risk|danger|safe/)) {\n if (ctx.protection) {\n const p = ctx.protection;\n let msg = `🛡️ Risk Assessment:\\n`;\n msg += `Protection Level: ${p.level}\\n`;\n msg += `Risk Score: ${p.score}/100\\n`;\n msg += `Recommended: ${p.recommendedAction}\\n`;\n if (p.signals.length > 0) {\n msg += `\\nActive Risk Factors:\\n`;\n for (const s of p.signals) {\n msg += ` ${s.severity === \"CRITICAL\" ? \"🚨\" : s.severity === \"DANGER\" ? \"🛑\" : \"⚠️\"} ${s.message}\\n`;\n }\n }\n return msg;\n }\n return \"Run a protection check first to get risk assessment.\";\n }\n\n // --- Command: signal / source ---\n if (text.match(/signal|source|weru/)) {\n if (ctx.sourceSignals && ctx.sourceSignals.length > 0) {\n const s = ctx.sourceSignals[0];\n let msg = `📡 Latest Signal from Source Bot:\\n`;\n msg += `Direction: ${s.direction} @ ${s.confidence}%\\n`;\n msg += `Entry: ${s.entry}\\n`;\n msg += `SL: ${s.stopLoss}\\n`;\n msg += `Session: ${s.session}\\n`;\n msg += `Status: ${s.status}\\n`;\n return msg;\n }\n return \"No signals available from the source bot yet. Make sure the source bot URL is configured in Settings.\";\n }\n\n // --- Default response ---\n let msg = `I'm your gold protection assistant. I can help you:\\n`;\n msg += `• Check protection status (type \"scan\")\\n`;\n msg += `• Get live price (type \"price\")\\n`;\n msg += `• Get trade recommendations (type \"buy\" or \"sell\")\\n`;\n msg += `• Assess risk (type \"risk\")\\n`;\n msg += `• View source signals (type \"signal\")\\n\\n`;\n msg += `Current protection score: ${ctx.protection?.score ?? \"—\"}/100`;\n return msg;\n}\n\n// Generate auto-message when protection level changes\nexport function generateAutoAlert(p: ProtectionResult): string {\n const emojis: Record = { SAFE: \"✅\", CAUTION: \"⚠️\", DANGER: \"🛑\", CRITICAL: \"🚨\" };\n let msg = `${emojis[p.level]} AUTO-ALERT: Protection level is ${p.level}\\n`;\n msg += `Risk score: ${p.score}/100\\n`;\n msg += `Action recommended: ${p.recommendedAction}\\n`;\n if (p.signals.length > 0) {\n msg += `\\nTriggered by:\\n`;\n for (const s of p.signals.slice(0, 3)) {\n msg += `• ${s.message}\\n`;\n }\n }\n return msg;\n}\n",[],[155,226,281],"be8a2340-94ca-4acd-91a9-fa8b675c2d71","analysis.ts","019f5343-cc6e-7159-988d-5e677730bc54",10,["D",1783808380019],"// Ultimate Hybrid Gold Trading Strategy — pure analysis engine.\n// Input: 5min candles (primary) + 1h candles (higher-TF bias). Output: AnalysisResult.\nimport type {\n AnalysisFactor,\n AnalysisResult,\n Candle,\n CustomStrategy,\n Direction,\n TradingSession,\n} from \"./types.ts\";\nimport { atr, ema, last, macd, rsi, swingPoints } from \"./indicators.ts\";\nimport { detectPatterns } from \"./patterns.ts\";\n\ninterface Scored {\n bullish: number;\n bearish: number;\n factors: AnalysisFactor[];\n reasoning: string[];\n}\n\nfunction add(\n s: Scored,\n name: string,\n side: \"bullish\" | \"bearish\" | \"neutral\",\n weight: number,\n detail: string,\n) {\n s.factors.push({ name, side, weight, detail });\n if (side === \"bullish\") s.bullish += weight;\n else if (side === \"bearish\") s.bearish += weight;\n if (side !== \"neutral\") s.reasoning.push(`${detail} (${side} +${weight})`);\n}\n\n// --- Trading session (UTC hours) ---\nexport function getSession(date = new Date()): TradingSession {\n const h = date.getUTCHours();\n if (h >= 13 && h < 16) return \"NY-London Overlap\"; // highest liquidity\n if (h >= 7 && h < 13) return \"London\";\n if (h >= 16 && h < 21) return \"New York\";\n return \"Asian/Low Liquidity\";\n}\n\n// --- ICT: detect last bullish/bearish order block ---\nfunction orderBlocks(c: Candle[]) {\n let bullish: number | null = null;\n let bearish: number | null = null;\n for (let i = c.length - 3; i >= Math.max(1, c.length - 30); i--) {\n // bullish OB: down candle followed by strong up move\n if (c[i].close < c[i].open && c[i + 1].close > c[i + 1].open &&\n c[i + 1].close > c[i].high && bullish === null) {\n bullish = (c[i].open + c[i].close) / 2;\n }\n if (c[i].close > c[i].open && c[i + 1].close < c[i + 1].open &&\n c[i + 1].close < c[i].low && bearish === null) {\n bearish = (c[i].open + c[i].close) / 2;\n }\n }\n return { bullish, bearish };\n}\n\n// --- ICT: Fair Value Gaps (3-candle imbalance) on recent candles ---\nfunction fairValueGaps(c: Candle[]) {\n let bullish = false;\n let bearish = false;\n for (let i = c.length - 2; i >= Math.max(2, c.length - 20); i--) {\n if (c[i - 1].high < c[i + 1].low) bullish = true; // gap up\n if (c[i - 1].low > c[i + 1].high) bearish = true; // gap down\n }\n return { bullish, bearish };\n}\n\n// --- Liquidity sweep: wick takes out a recent swing then closes back ---\nfunction liquiditySweep(c: Candle[], swings: ReturnType) {\n const cur = last(c);\n const recentHighs = swings.filter((s) => s.type === \"high\").slice(-4);\n const recentLows = swings.filter((s) => s.type === \"low\").slice(-4);\n let bullishSweep = false; // swept lows then closed up = bullish\n let bearishSweep = false; // swept highs then closed down = bearish\n for (const lo of recentLows) {\n if (cur.low < lo.price && cur.close > lo.price && cur.close > cur.open) bullishSweep = true;\n }\n for (const hi of recentHighs) {\n if (cur.high > hi.price && cur.close < hi.price && cur.close < cur.open) bearishSweep = true;\n }\n return { bullishSweep, bearishSweep };\n}\n\n// --- Market structure: HH/HL vs LH/LL + BOS/CHoCH ---\nfunction marketStructure(swings: ReturnType) {\n const highs = swings.filter((s) => s.type === \"high\").slice(-3);\n const lows = swings.filter((s) => s.type === \"low\").slice(-3);\n let trend: \"up\" | \"down\" | \"range\" = \"range\";\n if (highs.length >= 2 && lows.length >= 2) {\n const hh = highs[highs.length - 1].price > highs[highs.length - 2].price;\n const hl = lows[lows.length - 1].price > lows[lows.length - 2].price;\n const lh = highs[highs.length - 1].price < highs[highs.length - 2].price;\n const ll = lows[lows.length - 1].price < lows[lows.length - 2].price;\n if (hh && hl) trend = \"up\";\n else if (lh && ll) trend = \"down\";\n }\n return { trend };\n}\n\n// --- Dynamic S/R from swing points nearest to price ---\nfunction nearestSR(price: number, swings: ReturnType) {\n let support = -Infinity;\n let resistance = Infinity;\n for (const s of swings) {\n if (s.price <= price && s.price > support) support = s.price;\n if (s.price >= price && s.price < resistance) resistance = s.price;\n }\n return {\n support: Number.isFinite(support) ? support : price * 0.995,\n resistance: Number.isFinite(resistance) ? resistance : price * 1.005,\n };\n}\n\nexport interface AnalyzeOptions {\n strategies?: CustomStrategy[];\n now?: Date;\n riskReward?: [number, number, number]; // defaults 1.5, 2.5, 4.0\n}\n\nexport function analyze(\n c5: Candle[],\n c1h: Candle[],\n opts: AnalyzeOptions = {},\n): AnalysisResult {\n const s: Scored = { bullish: 0, bearish: 0, factors: [], reasoning: [] };\n const closes = c5.map((x) => x.close);\n const price = last(closes);\n\n // EMAs on 5m\n const ema20 = last(ema(closes, 20));\n const ema50 = last(ema(closes, 50));\n const ema200 = last(ema(closes, 200));\n if (!Number.isNaN(ema20) && !Number.isNaN(ema50)) {\n if (ema20 > ema50 && price > ema20) add(s, \"EMA Trend (20/50)\", \"bullish\", 2, \"Price above rising 20/50 EMA\");\n else if (ema20 < ema50 && price < ema20) add(s, \"EMA Trend (20/50)\", \"bearish\", 2, \"Price below falling 20/50 EMA\");\n }\n if (!Number.isNaN(ema200)) {\n if (price > ema200) add(s, \"EMA 200 Bias\", \"bullish\", 1, \"Price above 200 EMA\");\n else add(s, \"EMA 200 Bias\", \"bearish\", 1, \"Price below 200 EMA\");\n }\n\n // Higher-TF (1h) bias\n if (c1h.length >= 50) {\n const h = c1h.map((x) => x.close);\n const e20 = last(ema(h, 20));\n const e50 = last(ema(h, 50));\n if (e20 > e50) add(s, \"1H Trend Bias\", \"bullish\", 2, \"1H EMA trend up\");\n else if (e20 < e50) add(s, \"1H Trend Bias\", \"bearish\", 2, \"1H EMA trend down\");\n }\n\n // RSI\n const rsiv = last(rsi(closes, 14));\n if (!Number.isNaN(rsiv)) {\n if (rsiv < 30) add(s, \"RSI\", \"bullish\", 2, `RSI oversold (${rsiv.toFixed(0)})`);\n else if (rsiv > 70) add(s, \"RSI\", \"bearish\", 2, `RSI overbought (${rsiv.toFixed(0)})`);\n else if (rsiv > 50) add(s, \"RSI\", \"bullish\", 1, `RSI bullish (${rsiv.toFixed(0)})`);\n else if (rsiv < 50) add(s, \"RSI\", \"bearish\", 1, `RSI bearish (${rsiv.toFixed(0)})`);\n }\n\n // MACD histogram momentum\n const macdArr = macd(closes);\n const mp = last(macdArr);\n const mpPrev = macdArr[macdArr.length - 2];\n if (mp && !Number.isNaN(mp.histogram)) {\n const rising = mpPrev && mp.histogram > mpPrev.histogram;\n if (mp.histogram > 0 && rising) add(s, \"MACD\", \"bullish\", 2, \"MACD histogram positive & rising\");\n else if (mp.histogram < 0 && !rising) add(s, \"MACD\", \"bearish\", 2, \"MACD histogram negative & falling\");\n else if (mp.histogram > 0) add(s, \"MACD\", \"bullish\", 1, \"MACD histogram positive\");\n else if (mp.histogram < 0) add(s, \"MACD\", \"bearish\", 1, \"MACD histogram negative\");\n }\n\n // Market structure\n const swings = swingPoints(c5, 2);\n const ms = marketStructure(swings);\n if (ms.trend === \"up\") add(s, \"Market Structure\", \"bullish\", 2, \"HH/HL structure (uptrend)\");\n else if (ms.trend === \"down\") add(s, \"Market Structure\", \"bearish\", 2, \"LH/LL structure (downtrend)\");\n\n // ICT order blocks\n const ob = orderBlocks(c5);\n if (ob.bullish !== null && price >= ob.bullish * 0.999 && price <= ob.bullish * 1.002) {\n add(s, \"Order Block\", \"bullish\", 2, \"Price at bullish order block\");\n }\n if (ob.bearish !== null && price <= ob.bearish * 1.001 && price >= ob.bearish * 0.998) {\n add(s, \"Order Block\", \"bearish\", 2, \"Price at bearish order block\");\n }\n\n // Fair Value Gaps\n const fvg = fairValueGaps(c5);\n if (fvg.bullish) add(s, \"Fair Value Gap\", \"bullish\", 1, \"Bullish FVG present\");\n if (fvg.bearish) add(s, \"Fair Value Gap\", \"bearish\", 1, \"Bearish FVG present\");\n\n // Liquidity sweep — highest weighted\n const sweep = liquiditySweep(c5, swings);\n if (sweep.bullishSweep) add(s, \"Liquidity Sweep\", \"bullish\", 3, \"Swept sell-side liquidity & reversed up\");\n if (sweep.bearishSweep) add(s, \"Liquidity Sweep\", \"bearish\", 3, \"Swept buy-side liquidity & reversed down\");\n\n // SMT divergence: price vs RSI\n const rsiArr = rsi(closes, 14);\n if (swings.length >= 4) {\n const lows = swings.filter((x) => x.type === \"low\").slice(-2);\n const highs = swings.filter((x) => x.type === \"high\").slice(-2);\n if (lows.length === 2) {\n const priceLower = lows[1].price < lows[0].price;\n const rsiHigher = rsiArr[lows[1].index] > rsiArr[lows[0].index];\n if (priceLower && rsiHigher) add(s, \"SMT Divergence\", \"bullish\", 2, \"Bullish RSI divergence\");\n }\n if (highs.length === 2) {\n const priceHigher = highs[1].price > highs[0].price;\n const rsiLower = rsiArr[highs[1].index] < rsiArr[highs[0].index];\n if (priceHigher && rsiLower) add(s, \"SMT Divergence\", \"bearish\", 2, \"Bearish RSI divergence\");\n }\n }\n\n // Candlestick patterns\n for (const pat of detectPatterns(c5)) {\n add(s, `Pattern: ${pat.name}`, pat.side, 1, `${pat.name} candlestick`);\n }\n\n // Custom user strategies\n for (const strat of opts.strategies ?? []) {\n if (!strat.active) continue;\n const v = strategyValue(strat.condition.indicator, { rsiv, ema20, ema50, ema200, price, macdHist: mp?.histogram ?? 0 });\n if (v === null) continue;\n const { operator, value } = strat.condition;\n const ok = operator === \"<\" ? v < value : operator === \">\" ? v > value : Math.abs(v - value) < 0.0001;\n if (ok) add(s, `Custom: ${strat.name}`, strat.side, strat.weight, strat.description || strat.name);\n }\n\n // Session filter — reduce conviction in low liquidity\n const session = getSession(opts.now ?? new Date());\n if (session === \"Asian/Low Liquidity\") {\n s.bullish *= 0.7;\n s.bearish *= 0.7;\n s.reasoning.push(\"Low-liquidity session: scores reduced 30%\");\n }\n\n // Direction needs a 2-point lead to avoid weak NEUTRAL signals\n const lead = Math.abs(s.bullish - s.bearish);\n let direction: Direction = \"NEUTRAL\";\n if (lead >= 2 && s.bullish > s.bearish) direction = \"BUY\";\n else if (lead >= 2 && s.bearish > s.bullish) direction = \"SELL\";\n\n const total = s.bullish + s.bearish || 1;\n const winner = Math.max(s.bullish, s.bearish);\n const confidence = direction === \"NEUTRAL\" ? 0 : Math.round((winner / total) * 100);\n\n // Risk levels\n const atrv = last(atr(c5, 14)) || price * 0.002;\n const sr = nearestSR(price, swings);\n const rr = opts.riskReward ?? [1.5, 2.5, 4.0];\n let stopLoss: number;\n let takeProfits: [number, number, number];\n if (direction === \"SELL\") {\n stopLoss = Math.max(sr.resistance, price + atrv * 1.5);\n const risk = stopLoss - price;\n takeProfits = [price - risk * rr[0], price - risk * rr[1], price - risk * rr[2]];\n } else {\n // BUY or NEUTRAL (still compute illustrative long levels)\n stopLoss = Math.min(sr.support, price - atrv * 1.5);\n const risk = price - stopLoss;\n takeProfits = [price + risk * rr[0], price + risk * rr[1], price + risk * rr[2]];\n }\n\n return {\n direction,\n confidence,\n entry: round(price),\n stopLoss: round(stopLoss),\n takeProfits: takeProfits.map(round) as [number, number, number],\n riskRewardRatios: rr,\n atr: round(atrv),\n bullishScore: round1(s.bullish),\n bearishScore: round1(s.bearish),\n factors: s.factors,\n session,\n reasoning: s.reasoning,\n timestamp: Math.floor((opts.now ?? new Date()).getTime() / 1000),\n };\n}\n\nfunction strategyValue(\n indicator: string,\n v: { rsiv: number; ema20: number; ema50: number; ema200: number; price: number; macdHist: number },\n): number | null {\n switch (indicator) {\n case \"rsi\": return Number.isNaN(v.rsiv) ? null : v.rsiv;\n case \"macd_hist\": return v.macdHist;\n case \"ema_trend\": return v.ema20 - v.ema50;\n case \"price_vs_ema200\": return v.price - v.ema200;\n default: return null;\n }\n}\n\nconst round = (n: number) => Math.round(n * 100) / 100;\nconst round1 = (n: number) => Math.round(n * 10) / 10;\n",[],[155,226,289],"0a9a6342-60a0-46c2-afe9-76623c79f17c","019f5341-e82c-752f-ba2a-6d25eefed0a2",["D",1783808256047],"directory",[187,188,189,190,191,192,193,194,195,196],[155,226],"72aa5c41-1f1d-4a50-934f-e142f5ebebc5","main.tsx","b7b040c0-7d76-11f1-a19f-1607ee4eb77e",15,["D",1783808426606],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./App.tsx\";\n\ncreateRoot(document.getElementById(\"root\")!).render();\n",[],[155,156,303],["D",1783808426587],[],[155,156,64],"a66c8206-fa10-44af-aa5b-3b27311ba5a2","api.ts","b7b64d62-7d76-11f1-8014-1607ee4eb77e",16,["D",1783808426608],"// Tiny typed fetch client for the protection bot dashboard.\nasync function req(url: string, opts?: RequestInit): Promise {\n const res = await fetch(url, {\n ...opts,\n headers: { \"Content-Type\": \"application/json\", ...(opts?.headers ?? {}) },\n });\n const text = await res.text();\n const data = text ? JSON.parse(text) : {};\n if (!res.ok) throw new Error(data.error || `HTTP ${res.status}`);\n return data as T;\n}\n\nexport interface Candle { time: number; open: number; high: number; low: number; close: number; volume: number; }\nexport interface Quote { symbol: string; price: number; change: number; percentChange: number; timestamp: number; }\nexport interface Factor { name: string; side: string; weight: number; detail: string; }\n\nexport interface ProtectionAlert {\n id: number; level: string; score: number; price: number;\n signals: { type: string; severity: string; message: string; detail: string }[];\n reasoning: string[]; action: string; telegramSent: boolean; createdAt: number;\n}\n\nexport interface Signal {\n id: number; direction: string; confidence: number; entry: number; stopLoss: number;\n takeProfits: number[]; riskRewardRatios: number[]; atr: number;\n bullishScore: number; bearishScore: number; session: string;\n reasoning: string[]; factors: Factor[]; status: string; telegramSent: boolean; createdAt: number;\n}\n\nexport interface Trade {\n id: number; direction: string; entry: number; stopLoss: number; takeProfit: number;\n size: number; status: string; closePrice: number | null; pnl: number | null;\n openedAt: number; closedAt: number | null; source: string; note: string;\n}\n\nexport interface ChatMsg { id: number; role: string; text: string; timestamp: number; metadata?: string; }\n\nexport interface Settings {\n hasApiKey: boolean; riskPerTrade: number; riskReward: number[];\n scanIntervalMin: number; botRunning: boolean; autoTrade: boolean; sourceBotUrl: string;\n}\n\nexport interface Telegram {\n hasToken: boolean; chatId: string; notifyProtection: boolean; notifySignals: boolean;\n notifyTrades: boolean; minAlertLevel: string;\n}\n\nexport const api = {\n candles: (interval: string, outputsize = 200) =>\n req<{ interval: string; candles: Candle[] }>(`/api/market-data?type=candles&interval=${interval}&outputsize=${outputsize}`),\n quote: () => req(`/api/market-data?type=quote`),\n\n protect: () => req<{ ok: boolean; protection?: any; analysis?: any; error?: string; autoTraded: boolean; telegramSent: boolean }>(`/api/protect`, { method: \"POST\" }),\n\n sourceSignals: () => req(`/api/source-signals`),\n signals: (limit = 50) => req(`/api/signals?limit=${limit}`),\n protection: (limit = 50) => req(`/api/protection?limit=${limit}`),\n\n trades: () => req(`/api/trades`),\n openTrades: () => req(`/api/trades/open`),\n openTrade: (t: Partial) => req<{ id: number }>(`/api/trades/open`, { method: \"POST\", body: JSON.stringify(t) }),\n closeTrade: (id: number, price?: number) => req(`/api/trades/${id}/close`, { method: \"POST\", body: JSON.stringify({ price }) }),\n checkTrades: () => req<{ closed: number; messages: string[] }>(`/api/trades/check`, { method: \"POST\" }),\n\n chat: () => req(`/api/chat`),\n sendChat: (text: string) => req<{ reply: string }>(`/api/chat`, { method: \"POST\", body: JSON.stringify({ text }) }),\n\n settings: () => req(`/api/settings`),\n updateSettings: (s: Partial) => req(`/api/settings`, { method: \"PATCH\", body: JSON.stringify(s) }),\n\n telegram: () => req(`/api/telegram`),\n updateTelegram: (t: Partial) => req(`/api/telegram`, { method: \"PATCH\", body: JSON.stringify(t) }),\n testTelegram: () => req<{ ok: boolean; error?: string }>(`/api/telegram/test`, { method: \"POST\" }),\n};\n",[],[155,156,314],"4c9e39f9-7508-40c6-b3c4-c448d6f0892a","App.tsx","b7c47d10-7d76-11f1-a32d-1607ee4eb77e",17,["D",1783808426611],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0\";\nimport { Dashboard } from \"./tabs/Dashboard.tsx\";\nimport { LiveChat } from \"./tabs/LiveChat.tsx\";\nimport { Protection } from \"./tabs/Protection.tsx\";\nimport { DemoTrade } from \"./tabs/DemoTrade.tsx\";\nimport { SettingsTab } from \"./tabs/SettingsTab.tsx\";\nimport { TelegramTab } from \"./tabs/TelegramTab.tsx\";\n\nconst TABS = [\n { id: \"dashboard\", label: \"Dashboard\", icon: \"📊\" },\n { id: \"chat\", label: \"Live Chat\", icon: \"💬\" },\n { id: \"protection\", label: \"Protection\", icon: \"🛡️\" },\n { id: \"trades\", label: \"Demo Trade\", icon: \"📈\" },\n { id: \"settings\", label: \"Settings\", icon: \"⚙️\" },\n { id: \"telegram\", label: \"Telegram\", icon: \"✈️\" },\n];\n\nexport function App() {\n const [tab, setTab] = useState(\"dashboard\");\n return (\n

\n 🛡️\n

Gold Protection Bot

Stop Loss Reversal Detection + Live Trading Chat

\n view source\n

\n \n

\n\n

\n {tab === \"dashboard\" && }\n {tab === \"chat\" && }\n {tab === \"protection\" && }\n {tab === \"trades\" && }\n {tab === \"settings\" && }\n {tab === \"telegram\" && }\n

\n\n \n

\n );\n}\n",[],[155,156,322],"9e404d6c-7166-4e18-b672-ff0d57ab490e","TelegramTab.tsx","14789564-7d77-11f1-b951-1607ee4eb77e","d8b3e3f1-585d-4d56-945a-59be456a06bc",21,["D",1783808582220],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Telegram } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\nfunction Toggle({ label, checked, onChange }: { label: string; checked: boolean; onChange: (v: boolean) => void }) {\n return (\n \n {label}\n \n \n );\n}\n\nconst LEVELS = [\"SAFE\", \"CAUTION\", \"DANGER\", \"CRITICAL\"];\n\nexport function TelegramTab() {\n const [t, setT] = useState(null);\n const [botToken, setBotToken] = useState(\"\");\n const [msg, setMsg] = useState<{ ok: boolean; text: string } | null>(null);\n\n useEffect(() => { api.telegram().then(setT).catch(() => {}); }, []);\n\n async function save() {\n if (!t) return;\n await api.updateTelegram({\n botToken: botToken || undefined as any,\n chatId: t.chatId, notifyProtection: t.notifyProtection,\n notifySignals: t.notifySignals, notifyTrades: t.notifyTrades,\n minAlertLevel: t.minAlertLevel,\n });\n setBotToken(\"\");\n setT(await api.telegram());\n setMsg({ ok: true, text: \"Saved\" });\n setTimeout(() => setMsg(null), 2500);\n }\n\n async function test() {\n setMsg(null);\n const r = await api.testTelegram().catch((e) => ({ ok: false, error: String(e.message) }));\n setMsg(r.ok ? { ok: true, text: \"Test message sent! Check Telegram.\" } : { ok: false, text: r.error || \"Failed\" });\n }\n\n if (!t) return

Loading…

;\n\n return (\n

\n \n

Open Telegram and message @BotFather
Send /newbot and follow the prompts to get a bot token
Message @userinfobot to get your numeric chat ID
Start a chat with your new bot (send it any message) so it can reply to you
Paste both below, save, then hit Send Test Message

\n \n\n \n Bot Token {t.hasToken && ✓ saved}\n setBotToken(e.target.value)} className=\"mt-1 mb-3\" />\n Chat ID\n setT({ ...t, chatId: e.target.value })} className=\"mt-1\" />\n

\n Save\n Send Test Message\n

\n {msg &&

{msg.ok ? \"✓ \" : \"✕ \"}{msg.text}

}\n \n\n \n setT({ ...t, notifyProtection: v })} />\n setT({ ...t, notifySignals: v })} />\n setT({ ...t, notifyTrades: v })} />\n

\n Minimum alert level to notify\n

\n {LEVELS.map((l) => (\n \n ))}\n

\n Save Settings\n \n

\n );\n}\n",[],[155,156,338,330],"tabs","7f81a06d-631e-46da-b472-7785c7186338","SettingsTab.tsx","146bc2c6-7d77-11f1-b9c9-1607ee4eb77e",19,["D",1783808582219],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Settings } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\nexport function SettingsTab() {\n const [s, setS] = useState(null);\n const [apiKey, setApiKey] = useState(\"\");\n const [saved, setSaved] = useState(false);\n\n useEffect(() => { api.settings().then(setS).catch(() => {}); }, []);\n\n async function save() {\n if (!s) return;\n await api.updateSettings({\n apiKey: apiKey || undefined as any,\n riskPerTrade: s.riskPerTrade,\n riskReward: s.riskReward,\n scanIntervalMin: s.scanIntervalMin,\n sourceBotUrl: s.sourceBotUrl,\n });\n setApiKey(\"\");\n setSaved(true);\n setS(await api.settings());\n setTimeout(() => setSaved(false), 2500);\n }\n\n if (!s) return

Loading…

;\n\n return (\n

\n \n API Key {s.hasApiKey && ✓ saved}\n setApiKey(e.target.value)} className=\"mt-1\" />\n

\n Get a free key (800 calls/day) at{\" \"}\n twelvedata.com.\n

\n \n\n \n Risk per trade (%)\n setS({ ...s, riskPerTrade: Number(e.target.value) })} className=\"mt-1 mb-3\" />\n Risk : Reward ratios (TP1 / TP2 / TP3)\n

\n {s.riskReward.map((r, i) => (\n {\n const rr = [...s.riskReward]; rr[i] = Number(e.target.value); setS({ ...s, riskReward: rr });\n }} />\n ))}\n

\n Auto-check interval (minutes)\n setS({ ...s, scanIntervalMin: Number(e.target.value) })} className=\"mt-1\" />\n

Free Val Town tier enforces a 15-minute minimum.

\n \n\n \n Source Bot URL (Weru Gold Bot)\n setS({ ...s, sourceBotUrl: e.target.value })} className=\"mt-1\" />\n

The protection bot fetches recent signals from this URL to use as context for protection analysis.

\n \n\n

\n Save Settings\n {saved && ✓ Saved}\n

\n );\n}\n",[],[155,156,338,340],"273f3f57-248e-4515-bbc1-1a77843a89f4","Protection.tsx","14873934-7d77-11f1-9101-1607ee4eb77e",22,["D",1783808582231],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type ProtectionAlert } from \"../api.ts\";\nimport { Card, Btn } from \"../components/ui.tsx\";\n\nconst LEVEL_STYLES: Record = {\n SAFE: \"bg-emerald-500/15 text-emerald-400 border-emerald-500/30\",\n CAUTION: \"bg-amber-500/15 text-amber-400 border-amber-500/30\",\n DANGER: \"bg-red-500/15 text-red-400 border-red-500/30\",\n CRITICAL: \"bg-red-600/30 text-red-300 border-red-600/50\",\n};\nconst SEVERITY_ICON: Record = { SAFE: \"✅\", CAUTION: \"⚠️\", DANGER: \"🛑\", CRITICAL: \"🚨\" };\nconst ACTION_LABELS: Record = {\n HOLD: \"✅ Hold Position\", TIGHTEN_SL: \"⚠️ Tighten Stop Loss\",\n CLOSE_NOW: \"🛑 Close Position Now\", REVERSE: \"🚨 Consider Reversing\",\n};\n\nexport function Protection() {\n const [alerts, setAlerts] = useState([]);\n const [loading, setLoading] = useState(true);\n const [scanning, setScanning] = useState(false);\n const [msg, setMsg] = useState(null);\n\n async function load() {\n setLoading(true);\n setAlerts(await api.protection(50).catch(() => []));\n setLoading(false);\n }\n useEffect(() => { load(); }, []);\n\n async function runCheck() {\n setScanning(true); setMsg(null);\n try {\n const r = await api.protect();\n if (!r.ok) setMsg(\"Check failed: \" + r.error);\n else setMsg(`Protection: ${r.protection.level} (${r.protection.score}/100) — ${r.protection.recommendedAction}`);\n await load();\n } catch (e) { setMsg(String((e as Error).message)); }\n finally { setScanning(false); }\n }\n\n const stats = alerts.reduce((acc, a) => { acc[a.level] = (acc[a.level] ?? 0) + 1; return acc; }, {} as Record);\n\n return (\n

🛡️ Stop Loss Reversal Detection

\n {scanning ? \"Checking…\" : \"🛡️ Run Protection Check\"}\n

\n\n {msg &&

{msg}

}\n\n

\n {[\"SAFE\", \"CAUTION\", \"DANGER\", \"CRITICAL\"].map((level) => (\n

{stats[level] ?? 0}

{SEVERITY_ICON[level]} {level}

\n ))}\n

\n\n \n {loading ?

Loading…

:\n alerts.length === 0 ?

No protection alerts yet. Click Run Protection Check to start monitoring.

: (\n

\n {alerts.map((a) => (\n

\n {SEVERITY_ICON[a.level]} {a.level}\n {a.score}/100\n {ACTION_LABELS[a.action] ?? a.action}\n

{a.telegramSent && \"📨 \"}{new Date(a.createdAt).toLocaleString()}

Price

{a.price}

Signals

{a.signals.length}

Action

{a.action}

\n {a.signals.length > 0 && (\n

\n {a.signals.map((s, i) => (\n

\n {SEVERITY_ICON[s.severity]}\n

{s.message}({s.type})

\n ))}\n

\n )}\n {a.reasoning.length > 0 && (\n

Show reasoning

• {r}

\n )}\n

\n ))}\n

\n )}\n \n

\n );\n}\n",[],[155,156,338,348],"1f6930cb-2456-4e5e-9a00-bbaf2b24108d","LiveChat.tsx","d5e6b600-7d76-11f1-af2b-1607ee4eb77e",18,["D",1783808477314],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState, useRef } from \"https://esm.sh/react@18.2.0\";\nimport { api, type ChatMsg } from \"../api.ts\";\nimport { Card, Btn } from \"../components/ui.tsx\";\n\nconst QUICK_CMDS = [\n { label: \"🔍 Scan\", text: \"scan\" },\n { label: \"💹 Price\", text: \"price\" },\n { label: \"📊 Buy/Sell\", text: \"buy\" },\n { label: \"🛡️ Risk\", text: \"risk\" },\n { label: \"📡 Signal\", text: \"signal\" },\n { label: \"❓ Help\", text: \"help\" },\n];\n\nexport function LiveChat() {\n const [messages, setMessages] = useState([]);\n const [input, setInput] = useState(\"\");\n const [sending, setSending] = useState(false);\n const [autoMode, setAutoMode] = useState(false);\n const endRef = useRef(null);\n\n async function load() {\n setMessages(await api.chat().catch(() => []));\n }\n\n useEffect(() => { load(); }, []);\n useEffect(() => { endRef.current?.scrollIntoView({ behavior: \"smooth\" }); }, [messages]);\n\n async function send(text?: string) {\n const msg = (text ?? input).trim();\n if (!msg || sending) return;\n setInput(\"\");\n setSending(true);\n try {\n const r = await api.sendChat(msg);\n await load();\n } catch (e) {\n // Still reload to show the saved messages\n await load();\n } finally {\n setSending(false);\n }\n }\n\n return (\n

\n {/* Chat panel */}\n

\n {/* Header */}\n

\n 💬\n Trading Assistant Chat\n

\n \n

\n\n {/* Messages */}\n

\n {messages.length === 0 && (\n

🛡️

Chat with your Gold Protection Bot.

Type \"help\" to see available commands.

\n )}\n {messages.map((m) => (\n

\n {m.role === \"bot\" &&

🤖 Protection Bot

}\n {m.text}\n

\n {new Date(m.timestamp).toLocaleTimeString()}\n

\n ))}\n {sending && (\n

\n 🤖 analyzing...\n

\n )}\n

\n\n {/* Input */}\n

\n setInput(e.target.value)}\n onKeyDown={(e) => e.key === \"Enter\" && send()}\n placeholder=\"Type a message or command...\"\n className=\"flex-1 bg-slate-950 border border-slate-700 rounded-lg px-3 py-2 text-sm focus:outline-none focus:border-amber-500\"\n />\n send()} disabled={sending || !input.trim()}>\n Send\n \n

\n {QUICK_CMDS.map((c) => (\n \n ))}\n

\n\n {/* Side panel */}\n

\n \n

\n The chat assistant analyzes live market data and your open positions in real-time.\n It can recommend trades, check protection status, and alert you to stop loss reversal risks.\n

\n {autoMode && (\n

\n 🤖 Auto Mode: The bot will automatically execute trades and log alerts to this chat.\n

\n )}\n \n \n

scan — Run protection analysis
price — Live XAU/USD quote
buy/sell — Trade recommendation
close — Check open trade
risk — Risk assessment
signal — Source bot signal

\n \n

\n );\n}\n",[],[155,156,338,356],"8401bec3-abfe-4d66-b947-4f18ad9c8c81","DemoTrade.tsx","14a0848e-7d77-11f1-a443-1607ee4eb77e",23,["D",1783808582235],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Trade, type Quote } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\nexport function DemoTrade() {\n const [trades, setTrades] = useState([]);\n const [quote, setQuote] = useState(null);\n const [loading, setLoading] = useState(true);\n const [msg, setMsg] = useState(null);\n\n // New trade form\n const [dir, setDir] = useState(\"BUY\");\n const [entry, setEntry] = useState(\"\");\n const [sl, setSl] = useState(\"\");\n const [tp, setTp] = useState(\"\");\n const [size, setSize] = useState(\"0.1\");\n\n async function load() {\n setLoading(true);\n setTrades(await api.trades().catch(() => []));\n setQuote(await api.quote().catch(() => null));\n setLoading(false);\n }\n useEffect(() => { load(); }, []);\n\n async function openNew() {\n if (!entry || !sl || !tp) { setMsg(\"Fill in entry, SL, and TP\"); return; }\n try {\n await api.openTrade({ direction: dir, entry: Number(entry), stopLoss: Number(sl), takeProfit: Number(tp), size: Number(size), source: \"MANUAL\", note: \"\" });\n setMsg(`✅ Opened ${dir} trade at ${entry}`);\n setEntry(\"\"); setSl(\"\"); setTp(\"\");\n await load();\n } catch (e) { setMsg(String((e as Error).message)); }\n }\n\n async function closeTrade(id: number) {\n try {\n await api.closeTrade(id);\n setMsg(`Closed trade #${id}`);\n await load();\n } catch (e) { setMsg(String((e as Error).message)); }\n }\n\n async function checkTrades() {\n const r = await api.checkTrades();\n setMsg(r.closed > 0 ? `${r.closed} trade(s) auto-closed` : \"No trades needed closing\");\n await load();\n }\n\n const openTrades = trades.filter((t) => t.status === \"OPEN\");\n const closedTrades = trades.filter((t) => t.status !== \"OPEN\");\n const totalPnl = closedTrades.reduce((sum, t) => sum + (t.pnl ?? 0), 0);\n const wins = closedTrades.filter((t) => (t.pnl ?? 0) > 0).length;\n const losses = closedTrades.filter((t) => (t.pnl ?? 0) <= 0).length;\n const price = quote?.price ?? 0;\n\n return (\n

\n {msg &&

{msg}

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

{openTrades.length}

Open Trades

= 0 ? \"text-emerald-400\" : \"text-red-400\"}`}>\n {totalPnl >= 0 ? \"+\" : \"\"}{totalPnl.toFixed(2)}\n

Total P&L

{wins}

Wins

{losses}

Losses

\n\n

\n {/* Open new trade */}\n \n

\n {price > 0 &&

Live Price: {price.toFixed(2)}

}\n

\n \n \n

\n setEntry(e.target.value)} />\n setSl(e.target.value)} />\n setTp(e.target.value)} />\n setSize(e.target.value)} />\n Open Trade\n Check SL/TP Hits\n

\n \n\n {/* Open positions */}\n \n {openTrades.length === 0 ?

No open trades.

: (\n

\n {openTrades.map((t) => {\n const unrealizedPnl = t.direction === \"BUY\" ? (price - t.entry) * t.size * 100 : (t.entry - price) * t.size * 100;\n return (\n

\n {t.direction}\n {t.entry}\n {t.source === \"AUTO\" ? \"🤖 auto\" : \"👤 manual\"}\n

\n closeTrade(t.id)} className=\"text-xs px-2 py-1\">Close\n

SL: {t.stopLoss}

TP: {t.takeProfit}

Size: {t.size}

P&L: = 0 ? \"text-emerald-400\" : \"text-red-400\"}`}>{unrealizedPnl >= 0 ? \"+\" : \"\"}{unrealizedPnl.toFixed(2)}

\n {t.note &&

{t.note}

}\n

\n );\n })}\n

\n )}\n \n

\n\n {/* Trade history */}\n \n {loading ?

Loading…

:\n closedTrades.length === 0 ?

No closed trades yet.

: (\n

\n {closedTrades.slice(0, 20).map((t) => (\n

\n {t.direction}\n Entry: {t.entry}\n Close: {t.closePrice?.toFixed(2) ?? \"—\"}\n = 0 ? \"text-emerald-400\" : \"text-red-400\"}`}>\n {(t.pnl ?? 0) >= 0 ? \"+\" : \"\"}{(t.pnl ?? 0).toFixed(2)}\n \n {t.status.replace(\"CLOSED_\", \"\")}\n {t.closedAt ? new Date(t.closedAt).toLocaleString() : \"\"}\n

\n ))}\n

\n )}\n \n

\n );\n}\n",[],[155,156,338,364],"7ee9b568-c100-447e-9295-7defb3146ba7","Dashboard.tsx","1472f94c-7d77-11f1-a19f-1607ee4eb77e",20,["D",1783808582225],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Candle, type Quote, type Settings, type Signal, type ProtectionAlert } from \"../api.ts\";\nimport { Card, Btn } from \"../components/ui.tsx\";\nimport { CandleChart } from \"../components/Chart.tsx\";\n\nconst TIMEFRAMES = [\"1min\", \"5min\", \"15min\", \"30min\", \"1h\", \"1day\"];\n\nconst LEVEL_STYLES: Record = {\n SAFE: \"bg-emerald-500/15 text-emerald-400 border-emerald-500/30\",\n CAUTION: \"bg-amber-500/15 text-amber-400 border-amber-500/30\",\n DANGER: \"bg-red-500/15 text-red-400 border-red-500/30\",\n CRITICAL: \"bg-red-600/30 text-red-300 border-red-600/50\",\n};\n\nexport function Dashboard() {\n const [tf, setTf] = useState(\"5min\");\n const [candles, setCandles] = useState([]);\n const [quote, setQuote] = useState(null);\n const [signals, setSignals] = useState([]);\n const [alerts, setAlerts] = useState([]);\n const [sourceSignals, setSourceSignals] = useState([]);\n const [settings, setSettings] = useState(null);\n const [loading, setLoading] = useState(false);\n const [scanning, setScanning] = useState(false);\n const [msg, setMsg] = useState(null);\n\n async function loadChart(interval = tf) {\n setLoading(true);\n try {\n const [c, q] = await Promise.all([api.candles(interval), api.quote().catch(() => null)]);\n setCandles(c.candles);\n if (q) setQuote(q);\n } catch (e) { setMsg(String((e as Error).message)); }\n finally { setLoading(false); }\n }\n\n async function loadMeta() {\n setSignals(await api.signals(5).catch(() => []));\n setAlerts(await api.protection(5).catch(() => []));\n setSourceSignals(await api.sourceSignals().catch(() => []));\n setSettings(await api.settings().catch(() => null));\n }\n\n useEffect(() => { loadMeta(); }, []);\n useEffect(() => { loadChart(tf); }, [tf]);\n\n async function protectNow() {\n setScanning(true); setMsg(null);\n try {\n const r = await api.protect();\n if (!r.ok) setMsg(\"Protection check failed: \" + r.error);\n else setMsg(`🛡️ Protection: ${r.protection.level} (${r.protection.score}/100) — ${r.protection.recommendedAction}${r.autoTraded ? \" | auto-traded!\" : \"\"}${r.telegramSent ? \" | sent to Telegram\" : \"\"}`);\n await loadMeta(); await loadChart();\n } catch (e) { setMsg(String((e as Error).message)); }\n finally { setScanning(false); }\n }\n\n async function toggleBot() {\n if (!settings) return;\n await api.updateSettings({ botRunning: !settings.botRunning });\n setSettings({ ...settings, botRunning: !settings.botRunning });\n }\n\n async function toggleAutoTrade() {\n if (!settings) return;\n await api.updateSettings({ autoTrade: !settings.autoTrade });\n setSettings({ ...settings, autoTrade: !settings.autoTrade });\n }\n\n const up = (quote?.change ?? 0) >= 0;\n const latestAlert = alerts[0];\n\n return (\n

\n {!settings?.hasApiKey && (\n

\n ⚠️ No Twelve Data API key set. Go to Settings and add your key to load live data.\n

\n )}\n\n {latestAlert && (\n

\n {latestAlert.level}\n Risk Score: {latestAlert.score}/100\n Action: {latestAlert.action}\n

\n {new Date(latestAlert.createdAt).toLocaleTimeString()}\n

\n {latestAlert.signals.length > 0 && (\n

\n {latestAlert.signals.slice(0, 3).map((s, i) =>

• {s.message}

)}\n

\n )}\n

\n )}\n\n

\n \n

XAU/USD

{quote ? quote.price.toFixed(2) : \"—\"}

\n {quote && (\n

\n {up ? \"▲\" : \"▼\"} {quote.change.toFixed(2)} ({quote.percentChange.toFixed(2)}%)\n

\n )}\n

\n \n {scanning ? \"Checking…\" : \"🛡️ Run Protection Check\"}\n \n \n {settings?.botRunning ? \"⏹ Stop Auto-Check\" : \"▶ Start Auto-Check\"}\n \n \n {settings?.autoTrade ? \"🤖 Auto-Trade: ON\" : \"🤖 Auto-Trade: OFF\"}\n \n {settings && (\n

\n Auto-check every {settings.scanIntervalMin} min · {settings.botRunning ? \"🟢 running\" : \"⚪ stopped\"}\n

\n )}\n

\n \n\n \n

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

\n {loading ? (\n

Loading chart…

\n ) : candles.length ? (\n \n ) : (\n

No data yet

\n )}\n \n

\n\n {msg &&

{msg}

}\n\n {sourceSignals.length > 0 && (\n \n

\n {sourceSignals.slice(0, 3).map((s) => (\n

\n {s.direction}\n {s.confidence}%\n Entry: {s.entry}\n SL: {s.stopLoss}\n {new Date(s.createdAt).toLocaleString()}\n

\n ))}\n

\n \n )}\n\n

\n \n {alerts.length === 0 ?

No alerts yet. Click Run Protection Check to start.

: (\n

\n {alerts.slice(0, 5).map((a) => (\n

\n {a.level} ({a.score}/100)\n {new Date(a.createdAt).toLocaleTimeString()}\n

{a.signals.length} signals · {a.action}

\n ))}\n

\n )}\n \n \n {signals.length === 0 ?

No signals yet.

: (\n

\n {signals.slice(0, 5).map((s) => (\n

\n {s.direction}\n {s.confidence}%\n {s.session}\n {new Date(s.createdAt).toLocaleTimeString()}\n

\n ))}\n

\n )}\n \n

\n );\n}\n",[],[155,156,338,372],"8a3e1ac9-3072-4b74-9ef5-e522d7f75594",["D",1783808477314],[176,177,178,179,180,181],[155,156,338],"401c84f5-e42b-43a8-a706-d853a4358a4f","ui.tsx","019f5342-05a5-715f-a222-19c594e830be","019f5342-05a5-715f-a222-170acb53569c",3,["D",1783808263592],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0\";\nimport type { Signal } from \"../api.ts\";\n\nexport function Card({ title, children, className = \"\" }: { title?: string; children: React.ReactNode; className?: string }) {\n return (\n

\n {title &&

{title}

}\n {children}\n

\n );\n}\n\nexport function Btn({ children, onClick, variant = \"primary\", disabled, className = \"\" }: {\n children: React.ReactNode; onClick?: () => void; variant?: \"primary\" | \"ghost\" | \"danger\" | \"success\"; disabled?: boolean; className?: string;\n}) {\n const styles: Record = {\n primary: \"bg-amber-500 hover:bg-amber-400 text-slate-950\",\n success: \"bg-emerald-600 hover:bg-emerald-500 text-white\",\n danger: \"bg-red-600 hover:bg-red-500 text-white\",\n ghost: \"bg-slate-800 hover:bg-slate-700 text-slate-200\",\n };\n return (\n \n );\n}\n\nexport function Input(props: React.InputHTMLAttributes) {\n return ;\n}\n\nexport function DirBadge({ dir }: { dir: string }) {\n const map: Record = {\n BUY: \"bg-emerald-500/15 text-emerald-400 border-emerald-500/30\",\n SELL: \"bg-red-500/15 text-red-400 border-red-500/30\",\n NEUTRAL: \"bg-slate-500/15 text-slate-400 border-slate-500/30\",\n };\n return {dir};\n}\n\nexport function StatusBadge({ status }: { status: string }) {\n const map: Record = {\n open: [\"Open\", \"bg-blue-500/15 text-blue-400\"],\n tp_hit: [\"Hit TP\", \"bg-emerald-500/15 text-emerald-400\"],\n sl_hit: [\"Hit SL\", \"bg-red-500/15 text-red-400\"],\n cancelled: [\"Cancelled\", \"bg-slate-600/20 text-slate-400\"],\n };\n const [label, cls] = map[status] ?? map.open;\n return {label};\n}\n\nexport function SignalCard({ s, onStatus }: { s: Signal; onStatus?: (status: string) => void }) {\n const [open, setOpen] = useState(false);\n const time = new Date(s.createdAt).toLocaleString();\n return (\n

\n \n {s.confidence}%\n \n

\n {s.telegramSent ? 📨 : null}\n {time}\n

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

\n 🟢 {s.bullishScore} / 🔴 {s.bearishScore} · {s.session} · ATR {s.atr}\n

\n \n

\n {open && (\n

• {r}

\n {onStatus && s.status === \"open\" && (\n

\n onStatus(\"tp_hit\")}>Hit TP\n onStatus(\"sl_hit\")}>Hit SL\n onStatus(\"cancelled\")}>Cancel\n

\n )}\n

\n );\n}\n\nfunction Stat({ label, value, cls = \"\" }: { label: string; value: number; cls?: string }) {\n return (\n

{label}

{value}

\n );\n}\n",[],[155,156,392,384],"components","d55e0e00-1592-4c73-87cd-95514c6b4538","Chart.tsx","019f5342-05a5-715f-a222-1df467ae274e",["D",1783808263592],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useRef } from \"https://esm.sh/react@18.2.0\";\nimport type { Candle } from \"../api.ts\";\n\nexport function CandleChart({ candles }: { candles: Candle[] }) {\n const ref = useRef(null);\n\n useEffect(() => {\n const canvas = ref.current;\n if (!canvas || candles.length === 0) return;\n const dpr = window.devicePixelRatio || 1;\n const W = canvas.clientWidth;\n const H = canvas.clientHeight;\n canvas.width = W * dpr;\n canvas.height = H * dpr;\n const ctx = canvas.getContext(\"2d\")!;\n ctx.scale(dpr, dpr);\n ctx.clearRect(0, 0, W, H);\n\n const priceH = H * 0.78;\n const volH = H * 0.22;\n const padR = 56;\n const plotW = W - padR;\n\n const data = candles.slice(-120);\n const highs = data.map((c) => c.high);\n const lows = data.map((c) => c.low);\n const maxP = Math.max(...highs);\n const minP = Math.min(...lows);\n const range = maxP - minP || 1;\n const maxV = Math.max(...data.map((c) => c.volume), 1);\n\n const cw = plotW / data.length;\n const bodyW = Math.max(1, cw * 0.6);\n const yP = (p: number) => 6 + (priceH - 12) * (1 - (p - minP) / range);\n\n // grid + price axis\n ctx.font = \"10px ui-monospace, monospace\";\n ctx.textBaseline = \"middle\";\n for (let i = 0; i <= 4; i++) {\n const p = minP + (range * i) / 4;\n const y = yP(p);\n ctx.strokeStyle = \"rgba(148,163,184,0.12)\";\n ctx.beginPath();\n ctx.moveTo(0, y);\n ctx.lineTo(plotW, y);\n ctx.stroke();\n ctx.fillStyle = \"rgba(148,163,184,0.8)\";\n ctx.fillText(p.toFixed(2), plotW + 6, y);\n }\n\n // candles\n data.forEach((c, i) => {\n const x = i * cw + cw / 2;\n const up = c.close >= c.open;\n const color = up ? \"#22c55e\" : \"#ef4444\";\n ctx.strokeStyle = color;\n ctx.fillStyle = color;\n // wick\n ctx.beginPath();\n ctx.moveTo(x, yP(c.high));\n ctx.lineTo(x, yP(c.low));\n ctx.stroke();\n // body\n const yo = yP(c.open);\n const yc = yP(c.close);\n const top = Math.min(yo, yc);\n const h = Math.max(1, Math.abs(yc - yo));\n ctx.fillRect(x - bodyW / 2, top, bodyW, h);\n // volume\n const vh = (c.volume / maxV) * (volH - 6);\n ctx.globalAlpha = 0.5;\n ctx.fillRect(x - bodyW / 2, H - vh, bodyW, vh);\n ctx.globalAlpha = 1;\n });\n }, [candles]);\n\n return (\n \n );\n}\n",[],[155,156,392,394],"4fd9465d-b58d-4bf5-ae04-ebc646247020",["D",1783808263592],[173,174],[155,156,392],"30ce04f6-d815-4074-800c-88f6e59ae45e",["D",1783808263592],[172,175,182,183,184,185],[155,156],"f79a2034-d13e-4f9e-878e-b91462e29fde",["D",1783808256047],[171,186],[155],"8f3b0d37-7d45-47c5-b561-37f0f3f47623","autocheck.ts","a9cc91fc-7d76-11f1-a32d-1607ee4eb77e","a343a3ea-ca39-43a8-8e0e-037067adfdd9",12,["D",1783808403250],"interval","// Scheduled auto-protection check. Runs every 15 min (free-tier minimum).\n// Runs protection pipeline + checks open trades for SL/TP hits.\nimport { getSettings } from \"../src/lib/db.ts\";\nimport { runProtectionPipeline, checkOpenTrades } from \"../src/lib/pipeline.ts\";\nimport { saveChat } from \"../src/lib/db.ts\";\n\nexport default async function () {\n const settings = await getSettings();\n if (!settings.botRunning) {\n console.log(\"Auto-check skipped: bot is stopped.\");\n return;\n }\n if (!settings.hasApiKey) {\n console.log(\"Auto-check skipped: no API key.\");\n return;\n }\n\n // First, check if any open trades hit SL/TP\n const tradeCheck = await checkOpenTrades();\n for (const msg of tradeCheck.messages) {\n console.log(\"Trade event:\", msg);\n await saveChat(\"bot\", msg);\n }\n\n // Run the full protection pipeline\n const r = await runProtectionPipeline();\n if (!r.ok) {\n console.error(\"Auto-check failed:\", r.error);\n return;\n }\n console.log(\n `Auto-check: protection ${r.protection!.level} (${r.protection!.score}/100)` +\n ` | signal ${r.analysis!.direction} @ ${r.analysis!.confidence}%` +\n (r.telegramSent ? \" (sent to Telegram)\" : \"\") +\n (r.autoTraded ? \" (auto-traded)\" : \"\"),\n );\n}\n",[],[422,413],"cron","0f64bb7d-ea76-4862-b611-785a735c1e51",["D",1783808403250],[169],[422],["D",1783808251262],["D",1789526460011],{"_11":12,"_124":69},{"_11":12,"_119":120,"_68":69,"_30":67,"_121":122,"_123":24},{"_38":110,"_13":16,"_32":35,"_111":71,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":14,"_118":12},"ctx",{"_52":-5,"_143":465,"_466":467,"_468":469,"_470":24,"_471":24,"_472":24,"_473":84,"_474":-5,"_475":-7,"_476":-7,"_477":26,"_478":24,"_479":24,"_480":-5,"_481":24,"_482":24,"_483":24,"_484":-5},"ENV",{"_436":437,"_438":439,"_440":16,"_441":442,"_443":444,"_445":446,"_447":448,"_449":450,"_451":452,"_453":454,"_455":456,"_457":458,"_459":460,"_461":462,"_463":464},"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"]

History · index.html