\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",[183,184,87,74],"c4c6d646-1faa-4f6e-b15b-9246049add66",["D",1784220647036],"/** @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",[183,184,87,85],"pulls","branches","forks","envVars",{"_81":40,"_203":26},"connections",{"_81":40,"_202":40},"unfilledCount","emptyCount",{"_33":431,"_13":430,"_72":424,"_43":-5,"_35":36,"_177":40,"_178":24,"_37":432,"_39":26,"_75":88,"_180":-5,"_77":30,"_181":-5,"_241":433,"_17":434},{"_33":421,"_13":422,"_72":423,"_43":424,"_35":36,"_177":40,"_178":24,"_37":425,"_39":26,"_75":426,"_180":427,"_77":30,"_181":-5,"_241":428,"_17":429},{"_33":417,"_13":183,"_72":320,"_43":-5,"_35":36,"_177":40,"_178":24,"_37":418,"_39":26,"_75":88,"_180":-5,"_77":30,"_181":-5,"_241":419,"_17":420},{"_33":413,"_13":184,"_72":176,"_43":320,"_35":36,"_177":40,"_178":24,"_37":414,"_39":26,"_75":88,"_180":-5,"_77":30,"_181":-5,"_241":415,"_17":416},{"_33":175,"_13":87,"_72":86,"_43":176,"_35":36,"_177":40,"_178":24,"_37":410,"_39":26,"_75":88,"_180":-5,"_77":30,"_181":-5,"_241":411,"_17":412},{"_33":191,"_13":85,"_72":84,"_43":86,"_35":36,"_177":40,"_178":24,"_37":407,"_39":26,"_75":76,"_180":193,"_77":30,"_181":-5,"_241":408,"_17":409},{"_33":187,"_13":74,"_72":73,"_43":86,"_35":36,"_177":40,"_178":24,"_37":404,"_39":26,"_75":76,"_180":189,"_77":30,"_181":-5,"_241":405,"_17":406},{"_33":400,"_13":364,"_72":358,"_43":176,"_35":36,"_177":40,"_178":24,"_37":401,"_39":26,"_75":88,"_180":-5,"_77":30,"_181":-5,"_241":402,"_17":403},{"_33":393,"_13":394,"_72":395,"_43":358,"_35":36,"_177":40,"_178":24,"_37":396,"_39":26,"_75":76,"_180":397,"_77":30,"_181":-5,"_241":398,"_17":399},{"_33":386,"_13":387,"_72":388,"_43":358,"_35":36,"_177":40,"_178":24,"_37":389,"_39":26,"_75":76,"_180":390,"_77":30,"_181":-5,"_241":391,"_17":392},{"_33":379,"_13":380,"_72":381,"_43":358,"_35":36,"_177":40,"_178":24,"_37":382,"_39":26,"_75":76,"_180":383,"_77":30,"_181":-5,"_241":384,"_17":385},{"_33":372,"_13":373,"_72":374,"_43":358,"_35":36,"_177":40,"_178":24,"_37":375,"_39":26,"_75":76,"_180":376,"_77":30,"_181":-5,"_241":377,"_17":378},{"_33":365,"_13":366,"_72":367,"_43":358,"_35":36,"_177":40,"_178":24,"_37":368,"_39":26,"_75":76,"_180":369,"_77":30,"_181":-5,"_241":370,"_17":371},{"_33":355,"_13":356,"_72":357,"_43":358,"_35":36,"_177":359,"_178":24,"_37":360,"_39":26,"_75":76,"_180":361,"_77":30,"_181":-5,"_241":362,"_17":363},{"_33":347,"_13":348,"_72":349,"_43":176,"_35":36,"_177":350,"_178":24,"_37":351,"_39":82,"_75":76,"_180":352,"_77":30,"_181":-5,"_241":353,"_17":354},{"_33":338,"_13":339,"_72":340,"_43":176,"_35":36,"_177":341,"_178":24,"_37":342,"_39":343,"_75":76,"_180":344,"_77":30,"_181":-5,"_241":345,"_17":346},{"_33":331,"_13":332,"_72":333,"_43":176,"_35":36,"_177":82,"_178":24,"_37":334,"_39":40,"_75":21,"_180":335,"_77":30,"_181":-5,"_241":336,"_17":337},{"_33":324,"_13":325,"_72":326,"_43":176,"_35":36,"_177":40,"_178":24,"_37":327,"_39":26,"_75":76,"_180":328,"_77":30,"_181":-5,"_241":329,"_17":330},{"_33":319,"_13":259,"_72":254,"_43":320,"_35":36,"_177":40,"_178":24,"_37":321,"_39":26,"_75":88,"_180":-5,"_77":30,"_181":-5,"_241":322,"_17":323},{"_33":311,"_13":312,"_72":313,"_43":254,"_35":36,"_177":314,"_178":24,"_37":315,"_39":40,"_75":76,"_180":316,"_77":30,"_181":-5,"_241":317,"_17":318},{"_33":304,"_13":305,"_72":306,"_43":254,"_35":36,"_177":127,"_178":24,"_37":307,"_39":238,"_75":76,"_180":308,"_77":30,"_181":-5,"_241":309,"_17":310},{"_33":297,"_13":298,"_72":299,"_43":254,"_35":36,"_177":40,"_178":24,"_37":300,"_39":26,"_75":76,"_180":301,"_77":30,"_181":-5,"_241":302,"_17":303},{"_33":290,"_13":291,"_72":292,"_43":254,"_35":36,"_177":40,"_178":24,"_37":293,"_39":26,"_75":76,"_180":294,"_77":30,"_181":-5,"_241":295,"_17":296},{"_33":283,"_13":284,"_72":285,"_43":254,"_35":36,"_177":40,"_178":24,"_37":286,"_39":26,"_75":76,"_180":287,"_77":30,"_181":-5,"_241":288,"_17":289},{"_33":275,"_13":276,"_72":277,"_43":254,"_35":36,"_177":278,"_178":24,"_37":279,"_39":82,"_75":76,"_180":280,"_77":30,"_181":-5,"_241":281,"_17":282},{"_33":267,"_13":268,"_72":269,"_43":254,"_35":36,"_177":270,"_178":24,"_37":271,"_39":40,"_75":76,"_180":272,"_77":30,"_181":-5,"_241":273,"_17":274},{"_33":260,"_13":261,"_72":262,"_43":254,"_35":36,"_177":40,"_178":24,"_37":263,"_39":26,"_75":76,"_180":264,"_77":30,"_181":-5,"_241":265,"_17":266},{"_33":251,"_13":252,"_72":253,"_43":254,"_35":36,"_177":40,"_178":24,"_37":255,"_39":26,"_75":76,"_180":256,"_77":30,"_181":-5,"_241":257,"_17":258},{"_33":244,"_13":245,"_72":246,"_43":-5,"_35":36,"_177":40,"_178":24,"_37":247,"_39":26,"_75":21,"_180":248,"_77":30,"_181":-5,"_241":249,"_17":250},{"_33":234,"_13":235,"_72":100,"_43":-5,"_35":36,"_177":236,"_178":24,"_37":237,"_39":238,"_75":239,"_180":240,"_77":30,"_181":-5,"_241":242,"_17":243},"b159b979-2851-46f5-905f-808be282be71","main.ts",14,["D",1784221702228],4,"http","// XAU/USD Gold Trading 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 { runAnalysisPipeline } from \"./src/lib/pipeline.ts\";\nimport { sendTelegramMessage } from \"./src/lib/telegram.ts\";\nimport {\n createStrategy,\n deleteStrategy,\n getSettings,\n getTelegram,\n listSignals,\n listStrategies,\n updateSettings,\n updateSignalStatus,\n updateStrategy,\n updateTelegram,\n} from \"./src/lib/db.ts\";\nimport { extractStrategiesFromVideo } from \"./src/lib/strategy-extractor.ts\";\n\nconst app = new Hono();\napp.onError((err, c) => {\n console.error(\"Unhandled error:\", err);\n return c.json({ error: String(err.message ?? err) }, 500);\n});\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// ---------- Analyze ----------\napp.post(\"/api/analyze\", async (c) => {\n const r = await runAnalysisPipeline();\n return json(r, r.ok ? 200 : 400);\n});\n\n// ---------- Bot CRUD ----------\napp.get(\"/api/bot/signals\", async (c) => {\n const limit = Number(c.req.query(\"limit\") ?? \"50\");\n return json(await listSignals(limit));\n});\n\napp.patch(\"/api/bot/signals/:id\", async (c) => {\n const id = Number(c.req.param(\"id\"));\n const body = await c.req.json();\n if (body.status) await updateSignalStatus(id, body.status);\n return json({ ok: true });\n});\n\napp.get(\"/api/bot/strategies\", async (c) => json(await listStrategies()));\n\napp.post(\"/api/bot/strategies\", async (c) => {\n const b = await c.req.json();\n const id = await createStrategy({\n name: b.name,\n description: b.description ?? \"\",\n side: b.side,\n weight: Number(b.weight ?? 1),\n active: b.active ?? true,\n condition: b.condition,\n });\n return json({ id });\n});\n\napp.patch(\"/api/bot/strategies/:id\", async (c) => {\n await updateStrategy(Number(c.req.param(\"id\")), await c.req.json());\n return json({ ok: true });\n});\n\napp.delete(\"/api/bot/strategies/:id\", async (c) => {\n await deleteStrategy(Number(c.req.param(\"id\")));\n return json({ ok: true });\n});\n\napp.get(\"/api/bot/settings\", async (c) => {\n const s = await getSettings();\n const { apiKey: _omit, ...safe } = s; // never leak the key\n return json(safe);\n});\n\napp.patch(\"/api/bot/settings\", async (c) => {\n await updateSettings(await c.req.json());\n return json({ ok: true });\n});\n\napp.get(\"/api/bot/telegram\", async (c) => {\n const t = await getTelegram();\n const { botToken: _omit, ...safe } = t; // never leak the token\n return json(safe);\n});\n\napp.patch(\"/api/bot/telegram\", async (c) => {\n await updateTelegram(await c.req.json());\n return json({ ok: true });\n});\n\napp.post(\"/api/bot/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,\n t.chatId,\n \"✅ Gold Bot connected!\\nYou'll receive XAU/USD trade signals 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\n// ---------- Video Strategy Extractor ----------\napp.post(\"/api/bot/extract-strategy\", async (c) => {\n const body = await c.req.parseBody();\n const file = body[\"file\"];\n if (!file || !(file instanceof File)) {\n return json({ error: \"No file uploaded. Use multipart form data with a 'file' field.\" }, 400);\n }\n // Groq Whisper limit is 25MB\n if (file.size > 25 * 1024 * 1024) {\n return json({ error: `File too large (${(file.size / 1024 / 1024).toFixed(1)}MB). Groq Whisper limit is 25MB. Try trimming or compressing the video.` }, 413);\n }\n try {\n const result = await extractStrategiesFromVideo(file, file.name);\n return json(result);\n } catch (e) {\n return json({ error: String(e) }, 500);\n }\n});\n\nexport default app.fetch;\n","children",[],[235],"d618035b-9a81-4a7a-add3-637112526f4c","README.md","019f6bd6-7eb6-76fd-8047-0070cf6fc9f1",["D",1784220647036],"# 🥇 XAU/USD Gold Trading Bot\n\nA gold scalping bot and trading dashboard built on Val Town, implementing the\n**Ultimate Hybrid Gold Trading Strategy**. It fetches live XAU/USD data from\nTwelve Data, runs a multi-layer technical analysis engine, generates trade\nsignals with risk-managed levels, and (optionally) delivers alerts via Telegram.\n\n> ⚠️ **For educational and research purposes only. Gold trading carries\n> significant financial risk.**\n\n## Getting started\n\n1. **Settings tab** → paste your [Twelve Data API key](https://twelvedata.com)\n (free tier: 800 calls/day). It's stored server-side and never returned to the browser.\n2. **Dashboard** → click **Scan Now** to run the first analysis and populate the chart.\n3. **Telegram tab** (optional) → add a bot token + chat ID, then send a test message.\n4. **Strategy Intelligence tab** → add custom rules that score alongside the built-in engine.\n5. **Dashboard** → **Start Auto-Scan** to enable scheduled scanning (every 15 min on free tier).\n\n## Architecture\n\n```mermaid\nflowchart TD\n UI[\"React dashboard
(5 tabs)\"] -->|fetch| API[\"main.ts
Hono HTTP API\"]\n CRON[\"cron/autoscan.ts
every 15 min\"] --> PIPE\n API -->|/api/analyze| PIPE[\"pipeline.ts\"]\n API -->|/api/market-data| MKT[\"market.ts
Twelve Data\"]\n PIPE --> MKT\n PIPE --> ENG[\"analysis.ts
hybrid engine\"]\n ENG --> IND[\"indicators.ts\"]\n ENG --> PAT[\"patterns.ts\"]\n PIPE --> DB[(\"SQLite
db.ts\")]\n PIPE --> TG[\"telegram.ts
sendMessage\"]\n API --> DB\n```\n\n## The analysis engine (`src/lib/analysis.ts`)\n\nA pure-TypeScript library combining many methodologies, each contributing a\nweighted bullish/bearish score:\n\n- **EMA trend** (20/50/200) + **higher-timeframe (1H) bias**\n- **Market structure**: HH/HL vs LH/LL (trend detection)\n- **RSI (14)** and **MACD (12/26/9)** histogram momentum\n- **ICT Order Blocks** (bullish/bearish) and **Fair Value Gaps**\n- **Liquidity Sweep** detection — highest weight (3 points)\n- **SMT Divergence** (price vs RSI)\n- **Candlestick patterns** (Hammer, Shooting Star, Engulfing, Pin Bar, Marubozu, Morning/Evening Star, Doji)\n- **Dynamic Support & Resistance** via swing points\n- **Trading session filter** (scores reduced 30% in low-liquidity hours)\n\nDirection requires a **2-point lead** over the opposite side (avoids weak NEUTRAL\nsignals). Confidence = winning side ÷ total score. Stop-loss = ATR × 1.5 anchored\nto nearest S/R; take-profits at the configured 1.5R / 2.5R / 4.0R.\n\n## File map\n\n| Path | Purpose |\n| --- | --- |\n| `main.ts` | Hono HTTP API + serves the dashboard |\n| `cron/autoscan.ts` | Scheduled auto-scan (interval) |\n| `src/lib/analysis.ts` | Hybrid analysis engine |\n| `src/lib/indicators.ts` | EMA/RSI/MACD/ATR/swing math |\n| `src/lib/patterns.ts` | Candlestick patterns |\n| `src/lib/market.ts` | Twelve Data fetcher |\n| `src/lib/telegram.ts` | Outbound Telegram notifier |\n| `src/lib/pipeline.ts` | fetch → analyze → persist → notify |\n| `src/lib/db.ts` | SQLite schema + helpers (5 tables) |\n| `src/frontend/*` | React dashboard (Twind styling) |\n\n## Notes for Val Town\n\n- Twelve Data API key and Telegram credentials are stored in **SQLite**\n (configured via the dashboard) — not env vars — so no setup outside the app is needed.\n- The free tier enforces a **15-minute minimum** cron interval. Upgrade for tighter scheduling.\n- This was adapted from a Netlify/Postgres design to Val Town's Deno runtime\n (HTTP vals, project SQLite, interval cron).\n",[],[245],"1bb0e991-c9ac-411d-9bac-60ae858348a1","types.ts","019f6bd6-7eb6-76fd-8046-f428fa3d0e3f","019f6bd6-7eb6-76fd-8046-f827f18c49c6",["D",1784220647036],"// Shared types for the XAU/USD gold trading bot.\n\nexport interface Candle {\n time: number; // unix seconds\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 interface AnalysisResult {\n direction: Direction;\n confidence: number; // 0-100\n entry: number;\n stopLoss: number;\n takeProfits: [number, number, number]; // 1.5R, 2.5R, 4.0R\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\nexport interface CustomStrategy {\n id: number;\n name: string;\n description: string;\n side: \"bullish\" | \"bearish\";\n weight: number;\n active: boolean;\n // A simple, safe expression-free rule set (evaluated in analysis.ts):\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",[],[183,259,252],"lib","04a4d2a1-7fe5-4e21-a363-955fb6eb8382","telegram.ts","019f6bd6-7eb6-76fd-8046-f1a19a1d9abf",["D",1784220647036],"// Outbound-only Telegram notifier (sendMessage). Token/chatId come from the DB.\nimport type { AnalysisResult } 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 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 `Educational only. Trade at your own risk.`,\n ];\n return lines.join(\"\\n\");\n}\n",[],[183,259,261],"5ffe84ab-7f57-45d5-8f5e-f3f9e685d2bb","strategy-extractor.ts","93783122-8136-11f1-85f8-1607ee4eb77e",18,["D",1784221808233],"// Strategy extractor: transcribe video/audio with Groq Whisper, then\n// extract structured trading strategies from the transcript using Groq LLM.\n\nconst GROQ_TRANSCRIPTION_URL = \"https://api.groq.com/openai/v1/audio/transcriptions\";\nconst GROQ_CHAT_URL = \"https://api.groq.com/openai/v1/chat/completions\";\nconst WHISPER_MODEL = \"whisper-large-v3\";\nconst LLM_MODEL = \"llama-3.3-70b-versatile\";\n\nexport interface ExtractedStrategy {\n name: string;\n description: string;\n side: \"bullish\" | \"bearish\";\n weight: number;\n indicator: \"rsi\" | \"ema_trend\" | \"macd_hist\" | \"price_vs_ema200\";\n operator: \"<\" | \">\";\n value: number;\n reasoning: string;\n}\n\nexport interface ExtractionResult {\n transcript: string;\n strategies: ExtractedStrategy[];\n summary: string;\n}\n\nfunction getApiKey(): string {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) throw new Error(\"GROQ_API_KEY env var not set. Add it in the val settings.\");\n return key;\n}\n\n/** Transcribe an audio/video file using Groq Whisper API. */\nexport async function transcribeMedia(file: Blob, filename: string): Promise {\n const apiKey = getApiKey();\n const form = new FormData();\n form.append(\"file\", file, filename);\n form.append(\"model\", WHISPER_MODEL);\n form.append(\"response_format\", \"json\");\n\n const res = await fetch(GROQ_TRANSCRIPTION_URL, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${apiKey}` },\n body: form,\n });\n\n if (!res.ok) {\n const err = await res.text();\n throw new Error(`Groq Whisper error (${res.status}): ${err}`);\n }\n\n const data = await res.json();\n return data.text as string;\n}\n\n/** Extract structured trading strategies from a transcript using Groq LLM. */\nexport async function extractStrategiesFromTranscript(\n transcript: string,\n): Promise<{ strategies: ExtractedStrategy[]; summary: string }> {\n const apiKey = getApiKey();\n\n const systemPrompt = `You are an expert trading strategy analyst. You receive a transcript of a trading educational video (likely about XAU/USD gold trading). Your job is to extract actionable trading strategies from it.\n\nYou must respond with ONLY valid JSON (no markdown, no code fences) in this exact format:\n{\n \"summary\": \"Brief 1-2 sentence summary of the video's main strategy\",\n \"strategies\": [\n {\n \"name\": \"Short strategy name\",\n \"description\": \"1-2 sentence description of when to apply it\",\n \"side\": \"bullish\" or \"bearish\",\n \"weight\": number (1-3, how important this signal is),\n \"indicator\": one of \"rsi\", \"ema_trend\", \"macd_hist\", \"price_vs_ema200\",\n \"operator\": \"<\" or \">\",\n \"value\": number (the threshold value for the indicator),\n \"reasoning\": \"Why this rule makes sense based on the video\"\n }\n ]\n}\n\nIndicator mapping:\n- \"rsi\": RSI (14) — value range 0-100 (e.g., <30 oversold, >70 overbought)\n- \"ema_trend\": EMA20 minus EMA50 — positive means bullish trend (e.g., >0 bullish)\n- \"macd_hist\": MACD histogram — positive means bullish momentum (e.g., >0 bullish)\n- \"price_vs_ema200\": Price minus EMA200 — positive means above long-term trend (e.g., >0 bullish)\n\nOnly extract clear, specific rules from the video. If the video is vague or doesn't contain specific rules, return an empty strategies array with a summary. Do NOT invent rules not mentioned in the transcript.`;\n\n const res = await fetch(GROQ_CHAT_URL, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: LLM_MODEL,\n messages: [\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: `Transcript:\\n\\n${transcript}` },\n ],\n temperature: 0.3,\n max_tokens: 2000,\n }),\n });\n\n if (!res.ok) {\n const err = await res.text();\n throw new Error(`Groq LLM error (${res.status}): ${err}`);\n }\n\n const data = await res.json();\n const content = data.choices?.[0]?.message?.content ?? \"\";\n\n // Parse JSON from the response (strip any markdown fences just in case)\n const cleaned = content.replace(/```json\\s*/gi, \"\").replace(/```\\s*/g, \"\").trim();\n try {\n return JSON.parse(cleaned);\n } catch {\n const match = cleaned.match(/\\{[\\s\\S]*\\}/);\n if (match) return JSON.parse(match[0]);\n throw new Error(\"Failed to parse strategy extraction response as JSON\");\n }\n}\n\n/** Full pipeline: transcribe media file -> extract strategies. */\nexport async function extractStrategiesFromVideo(\n file: Blob,\n filename: string,\n): Promise {\n const transcript = await transcribeMedia(file, filename);\n if (!transcript.trim()) {\n return { transcript: \"\", strategies: [], summary: \"No speech detected in the video.\" };\n }\n const { strategies, summary } = await extractStrategiesFromTranscript(transcript);\n // Sanitize all extracted strategies before returning\n return { transcript, strategies: strategies.map(sanitizeStrategy).filter(Boolean) as ExtractedStrategy[], summary };\n}\n\nconst VALID_INDICATORS = [\"rsi\", \"ema_trend\", \"macd_hist\", \"price_vs_ema200\"];\nconst VALID_OPERATORS = [\"<\", \">\", \"==\"];\nconst VALID_SIDES = [\"bullish\", \"bearish\"];\n\n/** Sanitize a single strategy from LLM output — returns null if invalid. */\nfunction sanitizeStrategy(raw: any): ExtractedStrategy | null {\n if (!raw || typeof raw !== \"object\") return null;\n if (!raw.name || typeof raw.name !== \"string\") return null;\n\n const indicator = VALID_INDICATORS.includes(raw.indicator) ? raw.indicator : \"rsi\";\n const operator = VALID_OPERATORS.includes(raw.operator) ? raw.operator : \">\";\n const side = VALID_SIDES.includes(raw.side) ? raw.side : \"bullish\";\n const weight = Math.max(1, Math.min(3, Number(raw.weight) || 1));\n const value = Number.isFinite(raw.value) ? Number(raw.value) : 0;\n\n return {\n name: String(raw.name).slice(0, 100),\n description: String(raw.description ?? \"\").slice(0, 500),\n side: side as ExtractedStrategy[\"side\"],\n weight,\n indicator: indicator as ExtractedStrategy[\"indicator\"],\n operator: operator as ExtractedStrategy[\"operator\"],\n value,\n reasoning: String(raw.reasoning ?? \"\").slice(0, 500),\n };\n}\n",[],[183,259,268],"7d87b9ce-ce3d-4786-ba41-57cca9db558b","pipeline.ts","019f6bd6-7eb6-76fd-8046-ee997f1620fd",15,["D",1784221717915],"// Full analysis pipeline: fetch data -> analyze -> persist -> notify.\nimport { analyze } from \"./analysis.ts\";\nimport { fetchCandles } from \"./market.ts\";\nimport { formatSignalMessage, sendTelegramMessage } from \"./telegram.ts\";\nimport {\n getSettings,\n getTelegram,\n listSignals,\n listStrategies,\n saveSignal,\n saveSnapshot,\n} from \"./db.ts\";\nimport type { AnalysisResult } from \"./types.ts\";\n\nexport interface PipelineResult {\n ok: boolean;\n error?: string;\n analysis?: AnalysisResult;\n signalId?: number;\n telegramSent: boolean;\n telegramError?: string;\n}\n\nexport async function runAnalysisPipeline(): Promise {\n const settings = await getSettings();\n if (!settings.hasApiKey) {\n return { ok: false, error: \"No Twelve Data API key configured\", telegramSent: 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 };\n }\n if (c5.length < 60) {\n return { ok: false, error: \"Not enough 5min candles returned\", telegramSent: false };\n }\n\n const strategies = await listStrategies();\n\n // Signal memory: load recent signal outcomes so the engine can learn\n let signalHistory: { direction: string; confidence: number; status: string }[] = [];\n try {\n const recentSignals = await listSignals(20);\n signalHistory = recentSignals\n .filter((s) => s.status !== \"open\")\n .map((s) => ({ direction: s.direction, confidence: s.confidence, status: s.status }));\n } catch {\n // non-critical — continue without memory\n }\n\n let analysis: AnalysisResult;\n try {\n analysis = analyze(c5, c1h, {\n strategies,\n riskReward: settings.riskReward,\n signalHistory,\n });\n } catch (e) {\n return { ok: false, error: `Analysis engine error: ${String(e)}`, telegramSent: false };\n }\n\n // Persist snapshot (non-critical if it fails)\n try {\n await saveSnapshot(analysis.entry);\n } catch (e) {\n console.error(\"saveSnapshot failed:\", e);\n }\n\n // Decide whether to notify\n const tg = await getTelegram();\n let telegramSent = false;\n let telegramError: string | undefined;\n const typeAllowed =\n (analysis.direction === \"BUY\" && tg.notifyBuy) ||\n (analysis.direction === \"SELL\" && tg.notifySell) ||\n (analysis.direction === \"NEUTRAL\" && tg.notifyNeutral);\n const meetsConfidence = analysis.confidence >= tg.minConfidence;\n\n if (tg.hasToken && tg.chatId && typeAllowed && meetsConfidence) {\n try {\n const r = await sendTelegramMessage(tg.botToken, tg.chatId, formatSignalMessage(analysis));\n telegramSent = r.ok;\n telegramError = r.error;\n } catch (e) {\n telegramError = String(e);\n }\n }\n\n // Save signal (non-critical if it fails, but we need the ID)\n let signalId: number | undefined;\n try {\n signalId = await saveSignal(analysis, telegramSent);\n } catch (e) {\n console.error(\"saveSignal failed:\", e);\n }\n\n return { ok: true, analysis, signalId, telegramSent, telegramError };\n}\n",[],[183,259,276],"64d9afeb-8446-40ba-87e1-3bf5e781e024","patterns.ts","019f6bd6-7eb6-76fd-8046-eabc34a90932",["D",1784220647036],"// 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",[],[183,259,284],"27927450-8bf8-44e1-b59f-1d46a4e08aec","market.ts","019f6bd6-7eb5-772f-9281-0ac2e0946656",["D",1784220647036],"// 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",[],[183,259,291],"5bfc584a-b185-4c6a-997c-238ca183b4ec","indicators.ts","019f6bd6-7eb5-772f-9281-04cb724a1f08",["D",1784220647036],"// 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",[],[183,259,298],"4cd0a6e7-1cdb-4a86-ac89-3f363dbedbd3","db.ts","019f6bd6-7eb5-772f-9281-02e557c13545",["D",1784221834698],"// Data layer: SQLite schema + typed helpers for the gold bot.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { AnalysisResult, CustomStrategy } from \"./types.ts\";\n\nconst PREFIX = \"gold_bot\";\nexport const T = {\n strategies: `${PREFIX}_strategies`,\n signals: `${PREFIX}_signals`,\n snapshots: `${PREFIX}_price_snapshots`,\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.strategies} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n description TEXT DEFAULT '',\n side TEXT NOT NULL,\n weight REAL NOT NULL DEFAULT 1,\n active INTEGER NOT NULL DEFAULT 1,\n indicator TEXT NOT NULL,\n operator TEXT NOT NULL,\n value REAL NOT NULL,\n created_at INTEGER NOT NULL\n )`,\n },\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 rr1 REAL NOT NULL DEFAULT 1.5, rr2 REAL NOT NULL DEFAULT 2.5, rr3 REAL NOT NULL DEFAULT 4.0,\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.snapshots} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n price REAL NOT NULL,\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_buy INTEGER NOT NULL DEFAULT 1,\n notify_sell INTEGER NOT NULL DEFAULT 1,\n notify_neutral INTEGER NOT NULL DEFAULT 0,\n min_confidence INTEGER NOT NULL DEFAULT 60\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 )`,\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}\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 };\n}\n\nexport async function updateSettings(p: Partial<{\n apiKey: string;\n riskPerTrade: number;\n riskReward: [number, number, number];\n scanIntervalMin: number;\n botRunning: boolean;\n}>) {\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 (!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 notifyBuy: boolean;\n notifySell: boolean;\n notifyNeutral: boolean;\n minConfidence: number;\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 notifyBuy: !!row.notify_buy,\n notifySell: !!row.notify_sell,\n notifyNeutral: !!row.notify_neutral,\n minConfidence: Number(row.min_confidence),\n };\n}\n\nexport async function updateTelegram(p: Partial<{\n botToken: string; chatId: string;\n notifyBuy: boolean; notifySell: boolean; notifyNeutral: boolean; minConfidence: number;\n}>) {\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.notifyBuy !== undefined) { sets.push(\"notify_buy = ?\"); args.push(p.notifyBuy ? 1 : 0); }\n if (p.notifySell !== undefined) { sets.push(\"notify_sell = ?\"); args.push(p.notifySell ? 1 : 0); }\n if (p.notifyNeutral !== undefined) { sets.push(\"notify_neutral = ?\"); args.push(p.notifyNeutral ? 1 : 0); }\n if (p.minConfidence !== undefined) { sets.push(\"min_confidence = ?\"); args.push(p.minConfidence); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.telegram} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Strategies ----------\nexport async function listStrategies(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.strategies} ORDER BY id DESC`);\n return r.rows.map((row: any) => ({\n id: Number(row.id),\n name: String(row.name),\n description: String(row.description ?? \"\"),\n side: row.side,\n weight: Number(row.weight),\n active: !!row.active,\n condition: { indicator: row.indicator, operator: row.operator, value: Number(row.value) },\n }));\n}\n\nexport async function createStrategy(s: Omit): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.strategies} (name, description, side, weight, active, indicator, operator, value, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [s.name, s.description, s.side, s.weight, s.active ? 1 : 0,\n s.condition.indicator, s.condition.operator, s.condition.value, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function updateStrategy(id: number, s: Partial>) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (s.name !== undefined) { sets.push(\"name = ?\"); args.push(s.name); }\n if (s.description !== undefined) { sets.push(\"description = ?\"); args.push(s.description); }\n if (s.side !== undefined) { sets.push(\"side = ?\"); args.push(s.side); }\n if (s.weight !== undefined) { sets.push(\"weight = ?\"); args.push(s.weight); }\n if (s.active !== undefined) { sets.push(\"active = ?\"); args.push(s.active ? 1 : 0); }\n if (s.condition) {\n sets.push(\"indicator = ?\", \"operator = ?\", \"value = ?\");\n args.push(s.condition.indicator, s.condition.operator, s.condition.value);\n }\n if (!sets.length) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE ${T.strategies} SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function deleteStrategy(id: number) {\n await initDb();\n await sqlite.execute({ sql: `DELETE FROM ${T.strategies} WHERE id = ?`, args: [id] });\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\nexport async function updateSignalStatus(id: number, status: SignalRow[\"status\"]) {\n await initDb();\n await sqlite.execute({ sql: `UPDATE ${T.signals} SET status = ? WHERE id = ?`, args: [status, id] });\n}\n\nfunction rowToSignal(row: any): SignalRow {\n return {\n id: Number(row.id),\n direction: row.direction,\n confidence: Number(row.confidence),\n entry: Number(row.entry),\n stopLoss: Number(row.stop_loss),\n takeProfits: [Number(row.tp1), Number(row.tp2), Number(row.tp3)],\n riskRewardRatios: [\n Number(row.rr1 ?? 1.5),\n Number(row.rr2 ?? 2.5),\n Number(row.rr3 ?? 4.0),\n ],\n atr: Number(row.atr),\n bullishScore: Number(row.bullish_score),\n bearishScore: Number(row.bearish_score),\n session: row.session,\n reasoning: JSON.parse(row.reasoning || \"[]\"),\n factors: JSON.parse(row.factors || \"[]\"),\n timestamp: Math.floor(Number(row.created_at) / 1000),\n status: row.status,\n telegramSent: !!row.telegram_sent,\n createdAt: Number(row.created_at),\n } as SignalRow;\n}\n\n// ---------- Price snapshots ----------\nexport async function saveSnapshot(price: number) {\n await initDb();\n await sqlite.execute({ sql: `INSERT INTO ${T.snapshots} (price, created_at) VALUES (?, ?)`, args: [price, Date.now()] });\n}\n",[],[183,259,305],"3d232e1b-000e-49c9-9bdf-673faa0a58f0","analysis.ts","019f6bd6-7eb5-772f-9280-fd8579c8a9ec",16,["D",1784221784907],"// Ultimate Hybrid Gold Trading Strategy — pure analysis engine.\n// Input: 5min candles (primary) + 1h candles (higher-TF bias). Output: AnalysisResult.\n// Features: input validation, strategy contradiction detection, consensus bonus,\n// signal memory (learns from past TP/SL outcomes), NaN safety, crash-proof.\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 SignalHistoryEntry {\n direction: string;\n confidence: number;\n status: string;\n}\n\nexport interface AnalyzeOptions {\n strategies?: CustomStrategy[];\n now?: Date;\n riskReward?: [number, number, number]; // defaults 1.5, 2.5, 4.0\n signalHistory?: SignalHistoryEntry[];\n}\n\n// --- Safe last-value helper: returns NaN if array is empty ---\nfunction safeLast(arr: number[]): number {\n if (arr.length === 0) return NaN;\n return arr[arr.length - 1];\n}\n\nexport function analyze(\n c5: Candle[],\n c1h: Candle[],\n opts: AnalyzeOptions = {},\n): AnalysisResult {\n const rr = opts.riskReward ?? [1.5, 2.5, 4.0];\n const session = getSession(opts.now ?? new Date());\n const now = Math.floor((opts.now ?? new Date()).getTime() / 1000);\n\n // --- Input validation: crash-proof guard ---\n if (!c5 || c5.length < 50) {\n return {\n direction: \"NEUTRAL\",\n confidence: 0,\n entry: c5 && c5.length > 0 ? round(safeLast(c5.map((x) => x.close))) : 0,\n stopLoss: 0,\n takeProfits: [0, 0, 0],\n riskRewardRatios: rr,\n atr: 0,\n bullishScore: 0,\n bearishScore: 0,\n factors: [],\n session,\n reasoning: [\"Insufficient candle data for analysis (need ≥50, got \" + (c5?.length ?? 0) + \")\"],\n timestamp: now,\n };\n }\n\n const s: Scored = { bullish: 0, bearish: 0, factors: [], reasoning: [] };\n const closes = c5.map((x) => x.close);\n const price = safeLast(closes);\n\n // Guard against invalid price data\n if (!Number.isFinite(price) || price <= 0) {\n return {\n direction: \"NEUTRAL\",\n confidence: 0,\n entry: 0,\n stopLoss: 0,\n takeProfits: [0, 0, 0],\n riskRewardRatios: rr,\n atr: 0,\n bullishScore: 0,\n bearishScore: 0,\n factors: [],\n session,\n reasoning: [\"Invalid price data received\"],\n timestamp: now,\n };\n }\n\n // EMAs on 5m\n const ema20 = safeLast(ema(closes, 20));\n const ema50 = safeLast(ema(closes, 50));\n const ema200 = safeLast(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 && c1h.length >= 50) {\n const h = c1h.map((x) => x.close);\n const e20 = safeLast(ema(h, 20));\n const e50 = safeLast(ema(h, 50));\n if (!Number.isNaN(e20) && !Number.isNaN(e50)) {\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\n // RSI\n const rsiv = safeLast(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 = macdArr.length > 0 ? macdArr[macdArr.length - 1] : null;\n const mpPrev = macdArr.length > 1 ? macdArr[macdArr.length - 2] : null;\n if (mp && !Number.isNaN(mp.histogram)) {\n const rising = mpPrev && !Number.isNaN(mpPrev.histogram) && 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 with contradiction detection ---\n const activeStrategies = (opts.strategies ?? []).filter((st) => st.active);\n\n // Detect contradictions: same indicator+operator+value but opposite sides\n const conditionKey = (st: CustomStrategy) =>\n `${st.condition.indicator}:${st.condition.operator}:${st.condition.value}`;\n const conditionGroups = new Map();\n for (const st of activeStrategies) {\n const k = conditionKey(st);\n if (!conditionGroups.has(k)) conditionGroups.set(k, []);\n conditionGroups.get(k)!.push(st);\n }\n const contradicted = new Set();\n for (const [, strats] of conditionGroups) {\n const hasBull = strats.some((st) => st.side === \"bullish\");\n const hasBear = strats.some((st) => st.side === \"bearish\");\n if (hasBull && hasBear) {\n for (const st of strats) contradicted.add(st.name);\n }\n }\n if (contradicted.size > 0) {\n s.reasoning.push(`⚠ Strategy contradiction detected: ${[...contradicted].join(\", \")} — these cancel out and are excluded`);\n }\n\n // Apply non-contradicted strategies\n let bullishFired = 0;\n let bearishFired = 0;\n for (const strat of activeStrategies) {\n if (contradicted.has(strat.name)) continue; // skip contradicted strategies\n const v = strategyValue(strat.condition.indicator, {\n rsiv, ema20, ema50, ema200, price,\n macdHist: mp?.histogram ?? 0,\n });\n if (v === null || Number.isNaN(v)) continue; // NaN safety\n const { operator, value } = strat.condition;\n const ok = operator === \"<\" ? v < value : operator === \">\" ? v > value : Math.abs(v - value) < 0.0001;\n if (ok) {\n add(s, `Custom: ${strat.name}`, strat.side, strat.weight, strat.description || strat.name);\n if (strat.side === \"bullish\") bullishFired++;\n else bearishFired++;\n }\n }\n\n // --- Strategy consensus bonus: multiple strategies agreeing boosts confidence ---\n if (bullishFired >= 3) {\n add(s, \"Strategy Consensus\", \"bullish\", 1, `${bullishFired} custom strategies agree on bullish`);\n }\n if (bearishFired >= 3) {\n add(s, \"Strategy Consensus\", \"bearish\", 1, `${bearishFired} custom strategies agree on bearish`);\n }\n\n // Session filter — reduce conviction in low liquidity\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 let confidence = direction === \"NEUTRAL\" ? 0 : Math.round((winner / total) * 100);\n\n // --- Signal memory: learn from past outcomes ---\n if (opts.signalHistory && opts.signalHistory.length >= 5) {\n const recent = opts.signalHistory.slice(0, 15);\n const tpHits = recent.filter((sig) => sig.status === \"tp_hit\").length;\n const slHits = recent.filter((sig) => sig.status === \"sl_hit\").length;\n const closed = recent.filter((sig) => sig.status !== \"open\" && sig.status !== \"cancelled\").length;\n if (closed >= 3) {\n const winRate = tpHits / closed;\n if (winRate < 0.35 && slHits > tpHits) {\n // Bot has been wrong lately — reduce confidence\n confidence = Math.round(confidence * 0.8);\n s.reasoning.push(`📉 Signal memory: recent win rate ${Math.round(winRate * 100)}% — confidence reduced 20%`);\n } else if (winRate > 0.6) {\n // Bot has been right lately — boost confidence\n confidence = Math.min(100, Math.round(confidence * 1.1));\n s.reasoning.push(`📈 Signal memory: recent win rate ${Math.round(winRate * 100)}% — confidence boosted 10%`);\n }\n }\n }\n\n // Risk levels\n const atrv = safeLast(atr(c5, 14));\n const safeAtr = (Number.isNaN(atrv) || atrv <= 0) ? price * 0.002 : atrv;\n const sr = nearestSR(price, swings);\n let stopLoss: number;\n let takeProfits: [number, number, number];\n if (direction === \"SELL\") {\n stopLoss = Math.max(sr.resistance, price + safeAtr * 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 - safeAtr * 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(safeAtr),\n bullishScore: round1(s.bullish),\n bearishScore: round1(s.bearish),\n factors: s.factors,\n session,\n reasoning: s.reasoning,\n timestamp: now,\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 Number.isNaN(v.macdHist) ? null : v.macdHist;\n case \"ema_trend\": return (Number.isNaN(v.ema20) || Number.isNaN(v.ema50)) ? null : v.ema20 - v.ema50;\n case \"price_vs_ema200\": return Number.isNaN(v.ema200) ? null : 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",[],[183,259,312],"b35f3b41-8408-42ad-8a18-bdaff4528065","019f6bd6-7eb6-76fd-8046-fd89643d1fbf",["D",1784220647036],[223,224,225,226,227,228,229,230,231],[183,259],"c8ba157e-d056-4e2a-ba9c-529499293ee9","main.tsx","019f6bd6-7eb5-772f-9280-f67876154c0c",["D",1784220647036],"/** @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",[],[183,184,325],"2e1ba910-e43c-45fd-9400-92c01abd386c","index.html","019f6bd6-7eb5-772f-9280-f16881651232",["D",1784220682703],"\n\n\n \n \n XAU/USD Gold Trading Bot\n 🥇\" />\n \n \n\n\n

\n \n\n\n",[],[183,184,332],"bb86c695-e3ac-4cb5-b7e5-c70a2df83594","api.ts","019f6bd6-7eb5-772f-9280-eff2b57f5eae",10,["D",1784220743166],3,"// Tiny typed fetch client for the dashboard.\nasync function req(url: string, opts?: RequestInit): Promise {\n const res = await fetch(url, {\n ...opts,\n headers: opts?.body instanceof FormData\n ? { ...(opts?.headers ?? {}) }\n : { \"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 {\n time: number; open: number; high: number; low: number; close: number; volume: number;\n}\nexport interface Quote {\n symbol: string; price: number; change: number; percentChange: number; timestamp: number;\n}\nexport interface Factor { name: string; side: string; weight: number; detail: string; }\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}\nexport interface Strategy {\n id: number; name: string; description: string; side: string; weight: number; active: boolean;\n condition: { indicator: string; operator: string; value: number };\n}\nexport interface Settings {\n hasApiKey: boolean; riskPerTrade: number; riskReward: number[];\n scanIntervalMin: number; botRunning: boolean;\n}\nexport interface Telegram {\n hasToken: boolean; chatId: string; notifyBuy: boolean; notifySell: boolean;\n notifyNeutral: boolean; minConfidence: number;\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 analyze: () => req<{ ok: boolean; analysis?: any; telegramSent: boolean; telegramError?: string; error?: string }>(`/api/analyze`, { method: \"POST\" }),\n\n signals: (limit = 50) => req(`/api/bot/signals?limit=${limit}`),\n setSignalStatus: (id: number, status: string) =>\n req(`/api/bot/signals/${id}`, { method: \"PATCH\", body: JSON.stringify({ status }) }),\n\n strategies: () => req(`/api/bot/strategies`),\n createStrategy: (s: Partial) => req<{ id: number }>(`/api/bot/strategies`, { method: \"POST\", body: JSON.stringify(s) }),\n updateStrategy: (id: number, s: Partial) => req(`/api/bot/strategies/${id}`, { method: \"PATCH\", body: JSON.stringify(s) }),\n deleteStrategy: (id: number) => req(`/api/bot/strategies/${id}`, { method: \"DELETE\" }),\n\n settings: () => req(`/api/bot/settings`),\n updateSettings: (s: Partial) => req(`/api/bot/settings`, { method: \"PATCH\", body: JSON.stringify(s) }),\n\n telegram: () => req(`/api/bot/telegram`),\n updateTelegram: (t: Partial) => req(`/api/bot/telegram`, { method: \"PATCH\", body: JSON.stringify(t) }),\n testTelegram: () => req<{ ok: boolean; error?: string }>(`/api/bot/telegram/test`, { method: \"POST\" }),\n\n extractStrategy: (file: File) => {\n const form = new FormData();\n form.append(\"file\", file);\n return req<{ transcript: string; strategies: any[]; summary: string; error?: string }>(\n `/api/bot/extract-strategy`,\n { method: \"POST\", body: form as any },\n );\n },\n};\n",[],[183,184,339],"0560717c-7a84-463e-8661-f1a05a451bb5","App.tsx","019f6bd6-7eb5-772f-9280-ea5e189a70b3",11,["D",1784220743166],"/** @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 { Signals } from \"./tabs/Signals.tsx\";\nimport { Strategies } from \"./tabs/Strategies.tsx\";\nimport { SettingsTab } from \"./tabs/SettingsTab.tsx\";\nimport { TelegramTab } from \"./tabs/TelegramTab.tsx\";\nimport { VideoStrategy } from \"./tabs/VideoStrategy.tsx\";\n\nconst TABS = [\n { id: \"dashboard\", label: \"Dashboard\", icon: \"📊\" },\n { id: \"video\", label: \"Video Strategy\", icon: \"🎬\" },\n { id: \"signals\", label: \"Signals\", icon: \"📡\" },\n { id: \"strategies\", label: \"Strategy Intelligence\", 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

XAU/USD Gold Bot

Ultimate Hybrid Strategy

\n view source\n

\n \n

\n\n

\n {tab === \"dashboard\" && }\n {tab === \"video\" && }\n {tab === \"signals\" && }\n {tab === \"strategies\" && }\n {tab === \"settings\" && }\n {tab === \"telegram\" && }\n

\n\n \n

\n );\n}\n",[],[183,184,348],"6a41a4f2-204e-4e42-89f7-03aa269beeff","VideoStrategy.tsx","a61aa6a2-8136-11f1-864b-1607ee4eb77e","019f6bd6-7eb5-772f-9280-e6648c342c0a",5,["D",1784220713968],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Strategy } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\ninterface ExtractedStrategy {\n name: string;\n description: string;\n side: \"bullish\" | \"bearish\";\n weight: number;\n indicator: string;\n operator: string;\n value: number;\n reasoning: string;\n}\n\ninterface ExtractionResult {\n transcript: string;\n strategies: ExtractedStrategy[];\n summary: string;\n}\n\nconst MAX_SIZE = 25 * 1024 * 1024; // 25MB Groq limit\nconst ACCEPTED = \".mp4,.mov,.m4a,.mp3,.wav,.webm,.ogg,.flac,.aac,.mkv,.avi\";\n\nexport function VideoStrategy() {\n const [file, setFile] = useState(null);\n const [loading, setLoading] = useState(false);\n const [result, setResult] = useState(null);\n const [error, setError] = useState(\"\");\n const [saved, setSaved] = useState>(new Set());\n\n function onFileChange(e: React.ChangeEvent) {\n const f = e.target.files?.[0];\n if (!f) return;\n if (f.size > MAX_SIZE) {\n setError(`File too large (${(f.size / 1024 / 1024).toFixed(1)}MB). Max 25MB for Groq Whisper.`);\n setFile(null);\n return;\n }\n setError(\"\");\n setFile(f);\n setResult(null);\n setSaved(new Set());\n }\n\n async function extract() {\n if (!file) return;\n setLoading(true);\n setError(\"\");\n setResult(null);\n try {\n const r = await api.extractStrategy(file);\n setResult(r);\n } catch (e: any) {\n setError(e.message || String(e));\n }\n setLoading(false);\n }\n\n async function saveStrategy(s: ExtractedStrategy, idx: number) {\n try {\n await api.createStrategy({\n name: s.name,\n description: s.description,\n side: s.side,\n weight: s.weight,\n active: true,\n condition: { indicator: s.indicator, operator: s.operator, value: s.value },\n } as any);\n setSaved((prev) => new Set(prev).add(idx));\n } catch (e: any) {\n setError(e.message || String(e));\n }\n }\n\n async function saveAll() {\n if (!result) return;\n for (let i = 0; i < result.strategies.length; i++) {\n if (!saved.has(i)) await saveStrategy(result.strategies[i], i);\n }\n }\n\n const fmtSize = (b: number) => b > 1024 * 1024 ? `${(b / 1024 / 1024).toFixed(1)}MB` : `${(b / 1024).toFixed(0)}KB`;\n\n return (\n

\n {/* Upload card */}\n \n

\n Upload a trading strategy video and AI will automatically transcribe it,\n extract the trading rules, and save them as strategies for your bot.\n

\n\n \n

🎬

\n {file ? (\n

{file.name}

{fmtSize(file.size)}

\n ) : (\n

Click to select a video or audio file

MP4, MOV, M4A, MP3, WAV, WebM — max 25MB

\n )}\n

\n \n \n\n {error &&

✕ {error}

}\n\n \n {loading ? \"🔄 Transcribing & extracting...\" : \"Extract Strategies from Video\"}\n \n\n {loading && (\n

\n This can take 30-60 seconds depending on video length.\n

\n )}\n\n

How it works:

Video/audio is transcribed with Groq Whisper (free)
AI extracts trading rules from the transcript
Review extracted strategies and save to your bot

\n \n\n {/* Results card */}\n \n {!result && !loading && (\n

\n Upload a video and click extract to see strategies here.\n

\n )}\n\n {loading && (\n

🤖

\n Processing your video...\n

\n )}\n\n {result && (\n

Summary

{result.summary}

\n\n {result.strategies.length === 0 ? (\n

\n No specific trading rules were found in this video. Try a video that\n explains clear entry/exit conditions.\n

\n ) : (\n <>\n

\n \n {result.strategies.length} strateg{result.strategies.length === 1 ? \"y\" : \"ies\"} found\n \n \n Save All\n \n

\n\n {result.strategies.map((s, i) => (\n

\n \n {s.side}\n \n {s.name}\n w:{s.weight}\n

\n {saved.has(i) ? (\n ✓ Saved\n ) : (\n saveStrategy(s, i)} className=\"text-xs\">\n Save\n \n )}\n

{s.description}

\n {s.indicator} {s.operator} {s.value}\n

{s.reasoning}

\n ))}\n\n

\n View full transcript ({result.transcript.length} chars)\n

\n {result.transcript}\n

\n \n )}\n

\n )}\n \n

\n );\n}\n",[],[183,184,364,356],"tabs","bd6c47ac-372c-4da1-b2eb-5807283c95a3","TelegramTab.tsx","019f6bd6-7eb5-772f-9280-e0750cef63b6",["D",1784220647036],"/** @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\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,\n notifyBuy: t.notifyBuy, notifySell: t.notifySell, notifyNeutral: t.notifyNeutral,\n minConfidence: t.minConfidence,\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, notifyBuy: v })} />\n setT({ ...t, notifySell: v })} />\n setT({ ...t, notifyNeutral: v })} />\n

\n Minimum confidence\n {t.minConfidence}%\n

\n setT({ ...t, minConfidence: Number(e.target.value) })}\n className=\"w-full mt-2 accent-amber-500\" />\n

\n Save Filters\n \n

\n );\n}\n",[],[183,184,364,366],"8e3f9823-e3bb-4f3a-9e6a-605fbd138e24","Strategies.tsx","019f6bd6-7eb5-772f-9280-dce2b1f5a370",["D",1784220647036],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Strategy } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\nconst INDICATORS = [\n { v: \"rsi\", label: \"RSI (14)\" },\n { v: \"macd_hist\", label: \"MACD Histogram\" },\n { v: \"ema_trend\", label: \"EMA20 − EMA50\" },\n { v: \"price_vs_ema200\", label: \"Price − EMA200\" },\n];\n\nconst blank = {\n name: \"\", description: \"\", side: \"bullish\", weight: 1,\n indicator: \"rsi\", operator: \"<\", value: 30,\n};\n\nexport function Strategies() {\n const [list, setList] = useState([]);\n const [form, setForm] = useState({ ...blank });\n const [editId, setEditId] = useState(null);\n const [loading, setLoading] = useState(true);\n\n async function load() {\n setLoading(true);\n setList(await api.strategies().catch(() => []));\n setLoading(false);\n }\n useEffect(() => { load(); }, []);\n\n function reset() { setForm({ ...blank }); setEditId(null); }\n\n async function save() {\n if (!form.name.trim()) return;\n const payload = {\n name: form.name, description: form.description, side: form.side, weight: Number(form.weight),\n active: true,\n condition: { indicator: form.indicator, operator: form.operator, value: Number(form.value) },\n };\n if (editId) await api.updateStrategy(editId, payload as any);\n else await api.createStrategy(payload as any);\n reset();\n await load();\n }\n\n function edit(s: Strategy) {\n setEditId(s.id);\n setForm({\n name: s.name, description: s.description, side: s.side, weight: s.weight,\n indicator: s.condition.indicator, operator: s.condition.operator, value: s.condition.value,\n });\n }\n\n async function toggle(s: Strategy) {\n await api.updateStrategy(s.id, { active: !s.active } as any);\n setList((p) => p.map((x) => x.id === s.id ? { ...x, active: !x.active } : x));\n }\n\n async function remove(id: number) {\n await api.deleteStrategy(id);\n setList((p) => p.filter((x) => x.id !== id));\n }\n\n const sel = \"bg-slate-950 border border-slate-700 rounded-lg px-3 py-2 text-sm w-full\";\n\n return (\n

\n \n

\n setForm({ ...form, name: e.target.value })} />\n setForm({ ...form, description: e.target.value })} />\n

\n \n setForm({ ...form, weight: Number(e.target.value) })} />\n

Rule: when

\n \n \n setForm({ ...form, value: Number(e.target.value) })} />\n

\n {editId ? \"Update\" : \"Add Strategy\"}\n {editId && Cancel}\n

\n \n\n \n {loading ?

Loading…

:\n list.length === 0 ?

No custom strategies yet. Active strategies are evaluated on every scan alongside the built-in engine.

: (\n

\n {list.map((s) => (\n

\n \n {s.name}\n +{s.weight} {s.side}\n

\n {s.condition.indicator} {s.condition.operator} {s.condition.value}\n

\n toggle(s)}>{s.active ? \"Pause\" : \"Activate\"}\n edit(s)}>Edit\n remove(s.id)}>✕\n

\n ))}\n

\n )}\n \n

\n );\n}\n",[],[183,184,364,373],"bb87c728-b5dd-401a-9eb4-25ddd108a738","Signals.tsx","019f6bd6-7eb5-772f-9280-d849d4bda5c4",["D",1784220647036],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Signal } from \"../api.ts\";\nimport { Card, SignalCard } from \"../components/ui.tsx\";\n\nconst FILTERS = [\"all\", \"BUY\", \"SELL\", \"open\", \"tp_hit\", \"sl_hit\"] as const;\nconst LABELS: Record = {\n all: \"All\", BUY: \"Buy\", SELL: \"Sell\", open: \"Open\", tp_hit: \"Hit TP\", sl_hit: \"Hit SL\",\n};\n\nexport function Signals() {\n const [signals, setSignals] = useState([]);\n const [filter, setFilter] = useState(\"all\");\n const [loading, setLoading] = useState(true);\n\n async function load() {\n setLoading(true);\n setSignals(await api.signals(100).catch(() => []));\n setLoading(false);\n }\n useEffect(() => { load(); }, []);\n\n async function setStatus(id: number, status: string) {\n await api.setSignalStatus(id, status);\n setSignals((prev) => prev.map((s) => s.id === id ? { ...s, status } : s));\n }\n\n const filtered = signals.filter((s) => {\n if (filter === \"all\") return true;\n if (filter === \"BUY\" || filter === \"SELL\") return s.direction === filter;\n return s.status === filter;\n });\n\n return (\n \n

\n {FILTERS.map((f) => (\n \n ))}\n {filtered.length} signals\n

\n {loading ? (\n

Loading…

\n ) : filtered.length === 0 ? (\n

No signals match this filter.

\n ) : (\n

\n {filtered.map((s) => setStatus(s.id, st)} />)}\n

\n )}\n \n );\n}\n",[],[183,184,364,380],"5d5c9abe-4ae9-4df2-8f5c-4b1effa89e59","SettingsTab.tsx","019f6bd6-7eb5-772f-9280-d4d813dc7ba3",["D",1784220647036],"/** @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 });\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 Stored securely server-side and never returned to the browser.\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-scan interval (minutes)\n setS({ ...s, scanIntervalMin: Number(e.target.value) })} className=\"mt-1\" />\n

Free Val Town tier enforces a 15-minute minimum on the cron schedule.

\n \n\n

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

\n );\n}\n",[],[183,184,364,387],"af26cbe5-6b6a-413a-8888-9dfddd851c12","Dashboard.tsx","019f6bd6-7eb5-772f-9280-d2ac2820d84b",["D",1784220647036],"/** @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 } from \"../api.ts\";\nimport { Card, Btn, SignalCard } from \"../components/ui.tsx\";\nimport { CandleChart } from \"../components/Chart.tsx\";\n\nconst TIMEFRAMES = [\"1min\", \"5min\", \"15min\", \"30min\", \"1h\", \"1day\"];\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 [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 setMsg(null);\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) {\n setMsg(String((e as Error).message));\n } finally {\n setLoading(false);\n }\n }\n\n async function loadMeta() {\n setSignals(await api.signals(10).catch(() => []));\n setSettings(await api.settings().catch(() => null));\n }\n\n useEffect(() => { loadMeta(); }, []);\n useEffect(() => { loadChart(tf); }, [tf]);\n\n async function scanNow() {\n setScanning(true);\n setMsg(null);\n try {\n const r = await api.analyze();\n if (!r.ok) setMsg(\"Scan failed: \" + r.error);\n else setMsg(`New ${r.analysis.direction} signal @ ${r.analysis.confidence}%${r.telegramSent ? \" · sent to Telegram\" : \"\"}`);\n await loadMeta();\n await loadChart();\n } catch (e) {\n setMsg(String((e as Error).message));\n } finally {\n setScanning(false);\n }\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 const up = (quote?.change ?? 0) >= 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

\n \n

XAU/USD

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

\n {quote && (\n

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

\n )}\n

\n \n {scanning ? \"Scanning…\" : \"🔍 Scan Now\"}\n \n \n {settings?.botRunning ? \"⏹ Stop Auto-Scan\" : \"▶ Start Auto-Scan\"}\n \n {settings && (\n

\n Auto-scan 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 \n {signals.length === 0 ? (\n

No signals yet. Click Scan Now to generate one.

\n ) : (\n

\n {signals.map((s) => )}\n

\n )}\n \n

\n );\n}\n",[],[183,184,364,394],"58ddec71-fe71-410b-a797-f569bb9a3962",["D",1784220647036],[212,213,214,215,216,217],[183,184,364],["D",1784220647036],[],[183,184,87,74],["D",1784220647036],[],[183,184,87,85],["D",1784220647036],[209,210],[183,184,87],"66d54f9d-5c8d-4384-a74b-ef117f2a38b7",["D",1784220647036],[208,211,218,219,220,221],[183,184],"75547b1b-83db-4b4d-83f9-1f23557ddc76",["D",1784220647036],[207,222],[183],"e21ef50f-3030-46be-ab59-84e840ef803e","autoscan.ts","019f6bd6-7eb5-772f-9280-beaa6359782f","019f6bd6-7eb5-772f-9280-c02159548ccc",["D",1784220647036],"interval","// Scheduled auto-scan. Runs every 15 min (free-tier minimum).\n// Only triggers analysis when the bot is marked \"running\" in settings.\nimport { getSettings } from \"../src/lib/db.ts\";\nimport { runAnalysisPipeline } from \"../src/lib/pipeline.ts\";\n\nexport default async function () {\n const settings = await getSettings();\n if (!settings.botRunning) {\n console.log(\"Auto-scan skipped: bot is stopped.\");\n return;\n }\n if (!settings.hasApiKey) {\n console.log(\"Auto-scan skipped: no API key.\");\n return;\n }\n const r = await runAnalysisPipeline();\n if (!r.ok) {\n console.error(\"Auto-scan failed:\", r.error);\n return;\n }\n console.log(\n `Auto-scan: ${r.analysis!.direction} @ ${r.analysis!.confidence}%` +\n (r.telegramSent ? \" (sent to Telegram)\" : r.telegramError ? ` (telegram: ${r.telegramError})` : \"\"),\n );\n}\n",[],[430,422],"cron","6cd9c0d4-d177-404b-b2e9-aff4d543a224",["D",1784220647036],[205],[430],["D",1784220647036],["D",1789472446807],{"_11":12,"_142":80},{"_11":12,"_138":12,"_79":80,"_31":78,"_139":140,"_141":30},{"_39":127,"_13":16,"_33":36,"_128":90,"_129":69,"_130":70,"_131":94,"_132":133,"_134":135,"_136":14,"_137":12},"ctx",{"_52":-5,"_163":473,"_474":475,"_476":477,"_478":30,"_479":30,"_480":30,"_481":24,"_482":-5,"_483":-7,"_484":-7,"_485":26,"_486":30,"_487":30,"_488":-5,"_489":30,"_490":30,"_491":30,"_492":-5},"ENV",{"_444":445,"_446":447,"_448":16,"_449":450,"_451":452,"_453":454,"_455":456,"_457":458,"_459":460,"_461":462,"_463":464,"_465":466,"_467":468,"_469":470,"_471":472},"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 · components