Multi-Broker Auto-Trading Bot

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_294":295,"_296":297},"routes/_app.x.$handle.$name",{"_104":103,"_37":49,"_112":94,"_32":113,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":30,"_127":128,"_129":63,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":30},"version",12,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","f79387e2-2afa-4821-be88-506c97f01627","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":38,"_39":26,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","src/frontend/index.html","latestPath","fileId","040a3e60-80df-11f1-810d-1607ee4eb77e","name","index.html","fileType","content","\n\n\n \n \n Multi-Broker Auto-Trading Bot\n 🤖\" />\n \n \n\n\n

\n \n\n\n","createdAt",["D",1784183075809],"branchVersion","branchId","95ef9e28-fe61-493c-a770-b3563a049710","id","83bdd005-8970-4353-a1d7-9af211296a36","pocket-option-trading-bot",["D",1784180422629],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Pocket Option automated trading bot with strategy engine","imageUrl","fa73935a-a3af-4c0c-9622-a681c65b50f2","pinnedFileId","d0c11b8c-80de-11f1-9307-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f696f-20fd-72fb-bdd0-4456c2f3182a","tursoName","83bdd00589704353a1d79af211296a36","tursoHostname","83bdd00589704353a1d79af211296a36-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525843977],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_111":107},"org",{"_104":103,"_105":103,"_106":107,"_19":59,"_108":109,"_110":30},"branch",{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"isOwned",44,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","weruproton","handle","displayName","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/ae059443-2840-4e69-6920-e0dfaa3ae800/square512?exp=1789581599&sig=81ffac8708a635c462d155c85c1781372b9066f0ab37c84a9abe61923307c728","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_37":49,"_42":289,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":290,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":291,"_88":292,"_90":293,"_92":30},"tree",[163,178],"files",[163,164,165,166,167,168,169,170,171,172,173,174,175,176,177,178],"counts",{"_153":67,"_154":149,"_155":67,"_156":157,"_158":159},"contents",[134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":146,"_37":147,"_35":148,"_138":-5,"_45":46,"_44":149,"_140":63,"_42":150,"_13":67,"_39":151,"_40":-5,"_29":30,"_144":-5,"_32":152},{"_47":136,"_37":137,"_35":61,"_138":-5,"_45":46,"_44":139,"_140":63,"_42":141,"_13":67,"_39":142,"_40":143,"_29":30,"_144":-5,"_32":145},"e543ac94-caa2-4e9a-b584-bcd4b04e4275","main.ts","parentId",9,"latest",["D",1784182989850],"http","// Multi-Broker Auto-Trading Bot — HTTP API + dashboard server.\nimport { Hono } from \"npm:hono@4\";\nimport { 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 { BROKER_CONFIGS } from \"./src/lib/brokers.ts\";\nimport {\n createBroker, deleteBroker, getSettings, getTelegram,\n listBrokers, listSignals, listTrades, updateBroker, updateSettings,\n updateTelegram, updateTrade,\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 const symbol = c.req.query(\"symbol\") ?? settings.tradeSymbol;\n try {\n if (what === \"quote\") return json(await fetchQuote(settings.apiKey, symbol));\n const outputsize = Number(c.req.query(\"outputsize\") ?? \"200\");\n const candles = await fetchCandles(settings.apiKey, symbol, interval, outputsize);\n return json({ interval, symbol, 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// ---------- Brokers ----------\napp.get(\"/api/brokers\", async (c) => {\n const brokers = await listBrokers();\n return json(brokers.map((b) => ({\n ...b,\n apiKey: b.apiKey ? \"••••••\" : \"\",\n apiSecret: b.apiSecret ? \"••••••\" : \"\",\n config: BROKER_CONFIGS.find((bc) => bc.type === b.type),\n })));\n});\n\napp.get(\"/api/brokers/configs\", (c) => json(BROKER_CONFIGS));\n\napp.post(\"/api/brokers\", async (c) => {\n const b = await c.req.json();\n const id = await createBroker({\n type: b.type, name: b.name,\n apiKey: b.apiKey ?? \"\", apiSecret: b.apiSecret ?? \"\",\n extra: b.extra ?? \"\", isPaper: b.isPaper ?? true,\n symbols: b.symbols ?? \"XAU/USD\",\n });\n return json({ id });\n});\n\napp.patch(\"/api/brokers/:id\", async (c) => {\n await updateBroker(Number(c.req.param(\"id\")), await c.req.json());\n return json({ ok: true });\n});\n\napp.delete(\"/api/brokers/:id\", async (c) => {\n await deleteBroker(Number(c.req.param(\"id\")));\n return json({ ok: true });\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// ---------- Trades ----------\napp.get(\"/api/trades\", async (c) => {\n const limit = Number(c.req.query(\"limit\") ?? \"50\");\n return json(await listTrades(limit));\n});\n\napp.patch(\"/api/trades/:id\", async (c) => {\n const body = await c.req.json();\n await updateTrade(Number(c.req.param(\"id\")), body);\n return json({ ok: true });\n});\n\n// ---------- Settings ----------\napp.get(\"/api/settings\", async (c) => {\n const s = await getSettings();\n const { apiKey: _, ...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: _, ...safe } = t;\n return json(safe);\n});\n\napp.patch(\"/api/telegram\", async (c) => {\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 \"✅ Trading Bot connected!\\nYou'll receive trade signals and auto-trade alerts here.\",\n );\n return json(r, r.ok ? 200 : 400);\n});\n\n// ---------- Dashboard ----------\napp.get(\"/\", async () => serveFile(\"./src/frontend/index.html\", import.meta.url));\n\nexport default app.fetch;\n","label",[137],"9e48f5fb-c18a-48fa-a03d-26ef30ba8773","src","019f698d-f7c7-70da-a4dd-2584cb575e83",1,["D",1784182339533],"directory",[147],"pulls","branches","forks","envVars",{"_160":67,"_162":67},"connections",{"_160":67,"_161":67},"count","unfilledCount","emptyCount",{"_47":146,"_37":147,"_35":148,"_138":-5,"_45":46,"_44":149,"_140":63,"_42":286,"_13":67,"_39":151,"_40":-5,"_29":30,"_144":-5,"_180":287,"_32":288},{"_47":282,"_37":269,"_35":263,"_138":148,"_45":46,"_44":264,"_140":63,"_42":283,"_13":67,"_39":151,"_40":-5,"_29":30,"_144":-5,"_180":284,"_32":285},{"_47":274,"_37":275,"_35":276,"_138":263,"_45":46,"_44":277,"_140":63,"_42":278,"_13":67,"_39":189,"_40":279,"_29":30,"_144":-5,"_180":280,"_32":281},{"_47":270,"_37":38,"_35":36,"_138":263,"_45":46,"_44":14,"_140":63,"_42":271,"_13":67,"_39":26,"_40":41,"_29":30,"_144":-5,"_180":272,"_32":273},{"_47":260,"_37":261,"_35":262,"_138":263,"_45":46,"_44":264,"_140":63,"_42":265,"_13":67,"_39":189,"_40":266,"_29":30,"_144":-5,"_180":267,"_32":268},{"_47":256,"_37":193,"_35":186,"_138":148,"_45":46,"_44":149,"_140":63,"_42":257,"_13":67,"_39":151,"_40":-5,"_29":30,"_144":-5,"_180":258,"_32":259},{"_47":248,"_37":249,"_35":250,"_138":186,"_45":46,"_44":251,"_140":30,"_42":252,"_13":67,"_39":189,"_40":253,"_29":30,"_144":-5,"_180":254,"_32":255},{"_47":240,"_37":241,"_35":242,"_138":186,"_45":46,"_44":243,"_140":63,"_42":244,"_13":67,"_39":189,"_40":245,"_29":30,"_144":-5,"_180":246,"_32":247},{"_47":232,"_37":233,"_35":234,"_138":186,"_45":46,"_44":235,"_140":63,"_42":236,"_13":67,"_39":189,"_40":237,"_29":30,"_144":-5,"_180":238,"_32":239},{"_47":225,"_37":226,"_35":227,"_138":186,"_45":46,"_44":149,"_140":63,"_42":228,"_13":67,"_39":189,"_40":229,"_29":30,"_144":-5,"_180":230,"_32":231},{"_47":217,"_37":218,"_35":219,"_138":186,"_45":46,"_44":220,"_140":63,"_42":221,"_13":67,"_39":189,"_40":222,"_29":30,"_144":-5,"_180":223,"_32":224},{"_47":210,"_37":211,"_35":212,"_138":186,"_45":46,"_44":149,"_140":63,"_42":213,"_13":67,"_39":189,"_40":214,"_29":30,"_144":-5,"_180":215,"_32":216},{"_47":202,"_37":203,"_35":204,"_138":186,"_45":46,"_44":205,"_140":30,"_42":206,"_13":67,"_39":189,"_40":207,"_29":30,"_144":-5,"_180":208,"_32":209},{"_47":194,"_37":195,"_35":196,"_138":186,"_45":46,"_44":197,"_140":63,"_42":198,"_13":67,"_39":189,"_40":199,"_29":30,"_144":-5,"_180":200,"_32":201},{"_47":183,"_37":184,"_35":185,"_138":186,"_45":46,"_44":187,"_140":63,"_42":188,"_13":67,"_39":189,"_40":190,"_29":30,"_144":-5,"_180":191,"_32":192},{"_47":136,"_37":137,"_35":61,"_138":-5,"_45":46,"_44":139,"_140":63,"_42":179,"_13":67,"_39":142,"_40":143,"_29":30,"_144":-5,"_180":181,"_32":182},["D",1784182989850],"children",[],[137],"80d4677c-3d7c-485d-b18a-0fc6bcbb02cf","types.ts","5d735f60-80dd-11f1-ae56-1607ee4eb77e","019f698d-f7c7-70da-a4dd-29cf9f40f778",2,["D",1784182366904],"script","// Shared types for the multi-broker auto-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 symbol: string;\n timestamp: number;\n}\n\nexport type TradingSession =\n | \"London\"\n | \"NY-London Overlap\"\n | \"New York\"\n | \"Asian/Low Liquidity\";\n\n// ---------- Broker types ----------\n\nexport type BrokerType =\n | \"alpaca\"\n | \"binance\"\n | \"bybit\"\n | \"oanda\"\n | \"deriv\"\n | \"ibkr\"\n | \"mt5\";\n\nexport interface BrokerConfig {\n type: BrokerType;\n displayName: string;\n description: string;\n fields: BrokerField[];\n defaultSymbols: string[];\n supportsPaperTrading: boolean;\n available: boolean; // false for brokers needing external gateway\n icon: string;\n}\n\nexport interface BrokerField {\n key: string;\n label: string;\n type: \"text\" | \"password\";\n required: boolean;\n placeholder?: string;\n}\n\n// ---------- Trade types ----------\n\nexport type TradeStatus =\n | \"pending\"\n | \"open\"\n | \"closed\"\n | \"cancelled\"\n | \"rejected\";\n\nexport interface Trade {\n id: number;\n brokerId: number;\n brokerType: BrokerType;\n symbol: string;\n direction: Direction;\n quantity: number;\n entryPrice: number;\n exitPrice: number | null;\n stopLoss: number;\n takeProfit: number;\n status: TradeStatus;\n pnl: number | null;\n confidence: number;\n reasoning: string;\n brokerOrderId: string | null;\n createdAt: number;\n closedAt: number | null;\n}\n\n// ---------- Broker adapter interface ----------\n\nexport interface BrokerAccount {\n balance: number;\n currency: string;\n buyingPower?: number;\n equity?: number;\n status: string;\n}\n\nexport interface PlaceOrderParams {\n symbol: string;\n side: \"buy\" | \"sell\";\n quantity: number;\n orderType: \"market\" | \"limit\";\n limitPrice?: number;\n stopLoss?: number;\n takeProfit?: number;\n}\n\nexport interface PlaceOrderResult {\n ok: boolean;\n orderId?: string;\n error?: string;\n filledPrice?: number;\n}\n\nexport interface BrokerAdapter {\n type: BrokerType;\n getAccount(): Promise;\n getCandles(symbol: string, interval: string, limit: number): Promise;\n getQuote(symbol: string): Promise<{ price: number; bid?: number; ask?: number }>;\n placeOrder(params: PlaceOrderParams): Promise;\n closePosition(symbol: string): Promise;\n testConnection(): Promise<{ ok: boolean; error?: string }>;\n}\n",[],[147,193,184],"lib","55dcf09a-05e1-4950-b710-e8029b750f8b","telegram.ts","5d7a8f92-80dd-11f1-85bc-1607ee4eb77e",3,["D",1784182366905],"// Outbound Telegram notifier.\nimport type { AnalysisResult, Trade } 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} ${a.symbol} ${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\nexport function formatTradeMessage(t: Trade, brokerName: string): string {\n const emoji = t.status === \"open\" ? \"📤\" : t.status === \"closed\" ? (t.pnl !== null && t.pnl >= 0 ? \"✅\" : \"❌\") : \"⏳\";\n const pnl = t.pnl !== null ? `${t.pnl >= 0 ? \"+\" : \"\"}${t.pnl.toFixed(2)}` : \"—\";\n const lines = [\n `${emoji} Trade ${t.status.toUpperCase()}`,\n `Broker: ${brokerName} (${t.brokerType})`,\n `Symbol: ${t.symbol}`,\n `Direction: ${t.direction}`,\n `Qty: ${t.quantity}`,\n `Entry: ${t.entryPrice}`,\n t.exitPrice !== null ? `Exit: ${t.exitPrice}` : \"\",\n `SL: ${t.stopLoss} · TP: ${t.takeProfit}`,\n `Confidence: ${t.confidence}%`,\n `PnL: ${pnl}`,\n ].filter(Boolean);\n return lines.join(\"\\n\");\n}\n",[],[147,193,195],"6e66075e-0ee5-4183-9b2a-7b2db0fab8ef","pipeline.ts","beaaac06-80de-11f1-8057-1607ee4eb77e",8,["D",1784182959504],"// Auto-trading pipeline: fetch → analyze → persist → (auto-trade) → notify.\nimport { analyze } from \"./analysis.ts\";\nimport { fetchCandles } from \"./market.ts\";\nimport { formatSignalMessage, formatTradeMessage, sendTelegramMessage } from \"./telegram.ts\";\nimport {\n countOpenTrades, getSettings, getTelegram, listBrokers,\n saveSignal, saveSnapshot, saveTrade,\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 autoTraded: boolean;\n tradeError?: 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, autoTraded: false };\n }\n\n const symbol = settings.tradeSymbol;\n let c5, c1h;\n try {\n [c5, c1h] = await Promise.all([\n fetchCandles(settings.apiKey, symbol, \"5min\", 250),\n fetchCandles(settings.apiKey, symbol, \"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 const analysis = analyze(c5, c1h, {\n symbol,\n riskReward: settings.riskReward,\n });\n\n await saveSnapshot(symbol, analysis.entry);\n\n // Telegram notification\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 if (tg.hasToken && tg.chatId && typeAllowed && meetsConfidence) {\n const r = await sendTelegramMessage(tg.botToken, tg.chatId, formatSignalMessage(analysis));\n telegramSent = r.ok;\n telegramError = r.error;\n }\n\n // Auto-trade logic\n let autoTraded = false;\n let tradeError: string | undefined;\n const shouldAutoTrade =\n settings.autoTrade &&\n analysis.direction !== \"NEUTRAL\" &&\n analysis.confidence >= settings.minConfidence;\n if (shouldAutoTrade) {\n const openCount = await countOpenTrades();\n if (openCount >= settings.maxOpenTrades) {\n tradeError = `Max open trades (${settings.maxOpenTrades}) reached — skipping`;\n } else {\n const brokers = (await listBrokers()).filter((b) => b.active);\n if (brokers.length === 0) {\n tradeError = \"No active broker configured — skipping auto-trade\";\n } else {\n const broker = brokers[0];\n const side = analysis.direction === \"BUY\" ? \"buy\" : \"sell\";\n try {\n // Simulated order — in production this would call the broker API\n const orderId = `SIM_${Date.now()}`;\n await saveTrade({\n brokerId: broker.id,\n brokerType: broker.type,\n symbol,\n direction: analysis.direction,\n quantity: settings.riskPerTrade,\n entryPrice: analysis.entry,\n exitPrice: null,\n stopLoss: analysis.stopLoss,\n takeProfit: analysis.takeProfits[0],\n status: \"open\",\n pnl: null,\n confidence: analysis.confidence,\n reasoning: analysis.reasoning.slice(0, 3).join(\"; \"),\n brokerOrderId: orderId,\n });\n autoTraded = true;\n if (tg.hasToken && tg.chatId && tg.notifyTrades) {\n await sendTelegramMessage(\n tg.botToken, tg.chatId,\n `🤖 Auto-Trade Executed\\n${broker.type.toUpperCase()} · ${symbol}\\n${analysis.direction} @ ${analysis.entry}\\nSL: ${analysis.stopLoss} · TP: ${analysis.takeProfits[0]}\\nConfidence: ${analysis.confidence}%`,\n );\n }\n } catch (e) {\n tradeError = String(e);\n }\n }\n }\n }\n\n const signalId = await saveSignal(analysis, autoTraded);\n return { ok: true, analysis, signalId, telegramSent, telegramError, autoTraded, tradeError };\n}\n",[],[147,193,203],"158722ce-fdbb-4ee6-8170-406c0f325be3","patterns.ts","019f698d-f7c7-70da-a4dd-307c943e36d1",["D",1784182339533],"// 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",[],[147,193,211],"18c295da-c435-45e3-9a20-bc630721da95","market.ts","8966e6f4-80de-11f1-aacc-1607ee4eb77e",5,["D",1784182870101],"// Market data fetcher using Twelve Data API.\nimport type { Candle } from \"./types.ts\";\n\nconst BASE = \"https://api.twelvedata.com\";\nexport const DEFAULT_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\nfunction assertOk(json: any) {\n if (json && (json.status === \"error\" || (json.code && json.code >= 400))) {\n throw new Error(`Twelve Data error: ${json.message ?? \"unknown\"}`);\n }\n}\n\nexport async function fetchCandles(\n apiKey: string,\n symbol: string = DEFAULT_SYMBOL,\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, symbol: string = DEFAULT_SYMBOL): 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,\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\n// Fetch multiple symbols in one call\nexport async function fetchMultiQuote(apiKey: string, symbols: string[]): Promise {\n if (symbols.length === 0) return [];\n const url = `${BASE}/price?symbol=${symbols.map(encodeURIComponent).join(\",\")}&apikey=${encodeURIComponent(apiKey)}`;\n const res = await fetch(url);\n const json = await res.json();\n if (Array.isArray(json)) {\n return symbols.map((s, i) => ({\n symbol: s,\n price: parseFloat(json[i]?.price ?? \"0\"),\n change: 0,\n percentChange: 0,\n timestamp: Math.floor(Date.now() / 1000),\n }));\n }\n return [];\n}\n",[],[147,193,218],"f2f8eaa1-2d3b-4aaf-af3b-bd7920ca0f81","indicators.ts","019f698d-f7c7-70da-a4dd-2d44b75b159b",["D",1784182339533],"// 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",[],[147,193,226],"d73b8571-9adf-47c6-a793-19a79b83ea5d","db.ts","89606d42-80de-11f1-89fc-1607ee4eb77e",4,["D",1784182870098],"// Data layer: SQLite schema + typed helpers.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { AnalysisResult, Trade, BrokerType } from \"./types.ts\";\n\nconst P = \"mtb\"; // multi-broker trading bot\nexport const T = {\n brokers: `${P}_brokers`,\n trades: `${P}_trades`,\n signals: `${P}_signals`,\n snapshots: `${P}_price_snapshots`,\n telegram: `${P}_telegram_config`,\n settings: `${P}_bot_settings`,\n positions: `${P}_positions`,\n};\n\nlet initialized = false;\n\nexport async function initDb() {\n if (initialized) return;\n await sqlite.batch([\n { sql: `CREATE TABLE IF NOT EXISTS ${T.brokers} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n type TEXT NOT NULL,\n name TEXT NOT NULL,\n api_key TEXT DEFAULT '',\n api_secret TEXT DEFAULT '',\n extra TEXT DEFAULT '',\n is_paper INTEGER NOT NULL DEFAULT 1,\n active INTEGER NOT NULL DEFAULT 0,\n symbols TEXT DEFAULT 'XAU/USD',\n created_at INTEGER NOT NULL\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS ${T.trades} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n broker_id INTEGER NOT NULL,\n broker_type TEXT NOT NULL,\n symbol TEXT NOT NULL,\n direction TEXT NOT NULL,\n quantity REAL NOT NULL,\n entry_price REAL NOT NULL,\n exit_price REAL,\n stop_loss REAL NOT NULL,\n take_profit REAL NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n pnl REAL,\n confidence INTEGER NOT NULL DEFAULT 0,\n reasoning TEXT DEFAULT '',\n broker_order_id TEXT,\n created_at INTEGER NOT NULL,\n closed_at INTEGER\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS ${T.signals} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT NOT NULL,\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 auto_traded INTEGER NOT NULL DEFAULT 0,\n created_at INTEGER NOT NULL\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS ${T.snapshots} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT NOT NULL,\n price REAL NOT NULL,\n created_at INTEGER NOT NULL\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 notify_trades INTEGER NOT NULL DEFAULT 1,\n min_confidence INTEGER NOT NULL DEFAULT 60\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 auto_trade INTEGER NOT NULL DEFAULT 0,\n min_confidence INTEGER NOT NULL DEFAULT 70,\n max_open_trades INTEGER NOT NULL DEFAULT 3,\n trade_symbol TEXT NOT NULL DEFAULT 'XAU/USD'\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS ${T.positions} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n broker_id INTEGER NOT NULL,\n symbol TEXT NOT NULL,\n side TEXT NOT NULL,\n quantity REAL NOT NULL,\n entry_price REAL NOT NULL,\n current_price REAL,\n pnl REAL,\n status TEXT NOT NULL DEFAULT 'open',\n created_at INTEGER NOT NULL\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 autoTrade: boolean;\n minConfidence: number;\n maxOpenTrades: number;\n tradeSymbol: 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 autoTrade: !!row.auto_trade,\n minConfidence: Number(row.min_confidence),\n maxOpenTrades: Number(row.max_open_trades),\n tradeSymbol: String(row.trade_symbol ?? \"XAU/USD\"),\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.autoTrade !== undefined) { sets.push(\"auto_trade = ?\"); args.push(p.autoTrade ? 1 : 0); }\n if (p.minConfidence !== undefined) { sets.push(\"min_confidence = ?\"); args.push(p.minConfidence); }\n if (p.maxOpenTrades !== undefined) { sets.push(\"max_open_trades = ?\"); args.push(p.maxOpenTrades); }\n if (p.tradeSymbol !== undefined) { sets.push(\"trade_symbol = ?\"); args.push(p.tradeSymbol); }\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 notifyTrades: 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 notifyTrades: !!row.notify_trades,\n minConfidence: Number(row.min_confidence),\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.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.notifyTrades !== undefined) { sets.push(\"notify_trades = ?\"); args.push(p.notifyTrades ? 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// ---------- Brokers ----------\nexport interface BrokerRow {\n id: number;\n type: BrokerType;\n name: string;\n apiKey: string;\n apiSecret: string;\n extra: string;\n isPaper: boolean;\n active: boolean;\n symbols: string;\n createdAt: number;\n}\n\nexport async function listBrokers(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.brokers} ORDER BY id DESC`);\n return r.rows.map((row: any) => ({\n id: Number(row.id),\n type: row.type,\n name: String(row.name),\n apiKey: String(row.api_key ?? \"\"),\n apiSecret: String(row.api_secret ?? \"\"),\n extra: String(row.extra ?? \"\"),\n isPaper: !!row.is_paper,\n active: !!row.active,\n symbols: String(row.symbols ?? \"XAU/USD\"),\n createdAt: Number(row.created_at),\n }));\n}\n\nexport async function createBroker(b: {\n type: BrokerType; name: string; apiKey: string; apiSecret: string;\n extra: string; isPaper: boolean; symbols: string;\n}): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.brokers} (type, name, api_key, api_secret, extra, is_paper, active, symbols, created_at)\n VALUES (?, ?, ?, ?, ?, ?, 0, ?, ?)`,\n args: [b.type, b.name, b.apiKey, b.apiSecret, b.extra, b.isPaper ? 1 : 0, b.symbols, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function updateBroker(id: number, 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.apiSecret !== undefined && p.apiSecret !== \"\") { sets.push(\"api_secret = ?\"); args.push(p.apiSecret); }\n if (p.extra !== undefined) { sets.push(\"extra = ?\"); args.push(p.extra); }\n if (p.isPaper !== undefined) { sets.push(\"is_paper = ?\"); args.push(p.isPaper ? 1 : 0); }\n if (p.active !== undefined) { sets.push(\"active = ?\"); args.push(p.active ? 1 : 0); }\n if (p.symbols !== undefined) { sets.push(\"symbols = ?\"); args.push(p.symbols); }\n if (!sets.length) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE ${T.brokers} SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function deleteBroker(id: number) {\n await initDb();\n await sqlite.execute({ sql: `DELETE FROM ${T.brokers} WHERE id = ?`, args: [id] });\n}\n\n// ---------- Signals ----------\nexport async function saveSignal(a: AnalysisResult, autoTraded: boolean): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.signals}\n (symbol, direction, confidence, entry, stop_loss, tp1, tp2, tp3, atr, bullish_score, bearish_score, session, reasoning, factors, auto_traded, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [a.symbol, 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 autoTraded ? 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((row: any) => ({\n id: Number(row.id),\n symbol: String(row.symbol),\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 atr: Number(row.atr),\n bullishScore: Number(row.bullish_score),\n bearishScore: Number(row.bearish_score),\n session: String(row.session),\n reasoning: JSON.parse(row.reasoning || \"[]\"),\n factors: JSON.parse(row.factors || \"[]\"),\n autoTraded: !!row.auto_traded,\n createdAt: Number(row.created_at),\n }));\n}\n\n// ---------- Trades ----------\nexport async function saveTrade(t: Omit): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.trades}\n (broker_id, broker_type, symbol, direction, quantity, entry_price, exit_price, stop_loss, take_profit, status, pnl, confidence, reasoning, broker_order_id, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [t.brokerId, t.brokerType, t.symbol, t.direction, t.quantity, t.entryPrice, t.exitPrice,\n t.stopLoss, t.takeProfit, t.status, t.pnl, t.confidence, t.reasoning, t.brokerOrderId, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function listTrades(limit = 50): 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),\n brokerId: Number(row.broker_id),\n brokerType: row.broker_type,\n symbol: String(row.symbol),\n direction: row.direction,\n quantity: Number(row.quantity),\n entryPrice: Number(row.entry_price),\n exitPrice: row.exit_price ? Number(row.exit_price) : null,\n stopLoss: Number(row.stop_loss),\n takeProfit: Number(row.take_profit),\n status: row.status,\n pnl: row.pnl ? Number(row.pnl) : null,\n confidence: Number(row.confidence),\n reasoning: String(row.reasoning ?? \"\"),\n brokerOrderId: row.broker_order_id ?? null,\n createdAt: Number(row.created_at),\n closedAt: row.closed_at ? Number(row.closed_at) : null,\n }));\n}\n\nexport async function updateTrade(id: number, p: Partial) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.exitPrice !== undefined) { sets.push(\"exit_price = ?\"); args.push(p.exitPrice); }\n if (p.status !== undefined) { sets.push(\"status = ?\"); args.push(p.status); }\n if (p.pnl !== undefined) { sets.push(\"pnl = ?\"); args.push(p.pnl); }\n if (p.brokerOrderId !== undefined) { sets.push(\"broker_order_id = ?\"); args.push(p.brokerOrderId); }\n if (p.closedAt !== undefined) { sets.push(\"closed_at = ?\"); args.push(p.closedAt); }\n if (!sets.length) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE ${T.trades} SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function countOpenTrades(): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT COUNT(*) as cnt FROM ${T.trades} WHERE status IN ('pending','open')` });\n return Number((r.rows[0] as any)?.cnt ?? 0);\n}\n\n// ---------- Price snapshots ----------\nexport async function saveSnapshot(symbol: string, price: number) {\n await initDb();\n await sqlite.execute({ sql: `INSERT INTO ${T.snapshots} (symbol, price, created_at) VALUES (?, ?, ?)`, args: [symbol, price, Date.now()] });\n}\n",[],[147,193,233],"9a08a966-f0e6-4e50-ad33-152beb772ec4","brokers.ts","aba4c718-80de-11f1-93de-1607ee4eb77e",6,["D",1784182927589],"// Broker registry + adapter factory.\n// Supports: Alpaca, Binance, Bybit, OANDA, Deriv, Interactive Brokers, MetaTrader 5.\nimport type { BrokerConfig, BrokerType } from \"./types.ts\";\n\nexport const BROKER_CONFIGS: BrokerConfig[] = [\n {\n type: \"alpaca\",\n displayName: \"Alpaca\",\n description: \"US stock & crypto trading with paper trading support\",\n icon: \"🦙\",\n fields: [\n { key: \"apiKey\", label: \"API Key\", type: \"text\", required: true, placeholder: \"AKXXXXXXXXXX\" },\n { key: \"apiSecret\", label: \"API Secret\", type: \"password\", required: true },\n { key: \"extra\", label: \"Base URL (leave default)\", type: \"text\", required: false, placeholder: \"https://paper-api.alpaca.markets\" },\n ],\n defaultSymbols: [\"AAPL\", \"TSLA\", \"SPY\", \"BTC/USD\"],\n supportsPaperTrading: true,\n available: true,\n },\n {\n type: \"binance\",\n displayName: \"Binance\",\n description: \"World's largest crypto exchange — spot trading\",\n icon: \"🟡\",\n fields: [\n { key: \"apiKey\", label: \"API Key\", type: \"text\", required: true },\n { key: \"apiSecret\", label: \"API Secret\", type: \"password\", required: true },\n { key: \"extra\", label: \"Testnet (1=test, 0=live)\", type: \"text\", required: false, placeholder: \"0\" },\n ],\n defaultSymbols: [\"BTCUSDT\", \"ETHUSDT\", \"XAUUSDT\"],\n supportsPaperTrading: true,\n available: true,\n },\n {\n type: \"bybit\",\n displayName: \"Bybit\",\n description: \"Crypto derivatives & spot trading\",\n icon: \"🔷\",\n fields: [\n { key: \"apiKey\", label: \"API Key\", type: \"text\", required: true },\n { key: \"apiSecret\", label: \"API Secret\", type: \"password\", required: true },\n { key: \"extra\", label: \"Testnet (1=test, 0=live)\", type: \"text\", required: false, placeholder: \"0\" },\n ],\n defaultSymbols: [\"BTCUSDT\", \"ETHUSDT\"],\n supportsPaperTrading: true,\n available: true,\n },\n {\n type: \"oanda\",\n displayName: \"OANDA\",\n description: \"Forex & CFD broker — REST API v20\",\n icon: \"🟢\",\n fields: [\n { key: \"apiKey\", label: \"API Token\", type: \"password\", required: true },\n { key: \"apiSecret\", label: \"Account ID\", type: \"text\", required: true, placeholder: \"001-001-12345-001\" },\n { key: \"extra\", label: \"Environment (practice/fido/trade)\", type: \"text\", required: false, placeholder: \"practice\" },\n ],\n defaultSymbols: [\"XAU_USD\", \"EUR_USD\", \"GBP_USD\"],\n supportsPaperTrading: true,\n available: true,\n },\n {\n type: \"deriv\",\n displayName: \"Deriv\",\n description: \"Binary options & forex — WebSocket API\",\n icon: \"⚡\",\n fields: [\n { key: \"apiKey\", label: \"API Token\", type: \"password\", required: true },\n { key: \"apiSecret\", label: \"App ID (optional)\", type: \"text\", required: false, placeholder: \"1089\" },\n { key: \"extra\", label: \"Account type (real/virtual)\", type: \"text\", required: false, placeholder: \"virtual\" },\n ],\n defaultSymbols: [\"R_100\", \"frxEURUSD\", \"frxXAUUSD\"],\n supportsPaperTrading: true,\n available: true,\n },\n {\n type: \"ibkr\",\n displayName: \"Interactive Brokers\",\n description: \"Professional multi-asset trading — requires IB Gateway running externally\",\n icon: \"🏢\",\n fields: [\n { key: \"apiKey\", label: \"Client Portal URL\", type: \"text\", required: true, placeholder: \"https://localhost:5000\" },\n { key: \"apiSecret\", label: \"Account ID\", type: \"text\", required: true },\n ],\n defaultSymbols: [\"XAUUSD\", \"AAPL\", \"ES\"],\n supportsPaperTrading: true,\n available: false,\n },\n {\n type: \"mt5\",\n displayName: \"MetaTrader 5\",\n description: \"Forex & metals — requires MT5 Python gateway running externally\",\n icon: \"📊\",\n fields: [\n { key: \"apiKey\", label: \"Gateway URL\", type: \"text\", required: true, placeholder: \"http://localhost:8000\" },\n { key: \"apiSecret\", label: \"Login\", type: \"text\", required: true },\n ],\n defaultSymbols: [\"XAUUSD\", \"EURUSD\", \"GBPUSD\"],\n supportsPaperTrading: true,\n available: false,\n },\n];\n\nexport function getBrokerConfig(type: BrokerType): BrokerConfig | undefined {\n return BROKER_CONFIGS.find((b) => b.type === type);\n}\n",[],[147,193,241],"9f7b6ab5-4edb-433e-9208-184dd7f7ee4f","analysis.ts","abab407a-80de-11f1-8239-1607ee4eb77e",7,["D",1784182927590],"// Multi-layer analysis engine — works with any symbol.\nimport type {\n AnalysisFactor, AnalysisResult, Candle, Direction, 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(s: Scored, name: string, side: \"bullish\" | \"bearish\" | \"neutral\", weight: number, detail: string) {\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\nexport function getSession(date = new Date()): TradingSession {\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\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 if (c[i].close < c[i].open && c[i + 1].close > c[i + 1].open && 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 && 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\nfunction fairValueGaps(c: Candle[]) {\n let bullish = false, 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;\n if (c[i - 1].low > c[i + 1].high) bearish = true;\n }\n return { bullish, bearish };\n}\n\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, 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 return { bullishSweep, bearishSweep };\n}\n\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\nfunction nearestSR(price: number, swings: ReturnType) {\n let support = -Infinity, 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 symbol?: string;\n now?: Date;\n riskReward?: [number, number, number];\n}\n\nexport function analyze(c5: Candle[], c1h: Candle[], opts: AnalyzeOptions = {}): AnalysisResult {\n const symbol = opts.symbol ?? \"XAU/USD\";\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 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 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 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 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 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 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 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 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 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 for (const pat of detectPatterns(c5)) {\n add(s, `Pattern: ${pat.name}`, pat.side, 1, `${pat.name} candlestick`);\n }\n\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 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 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 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, confidence,\n entry: round(price), stopLoss: round(stopLoss),\n takeProfits: takeProfits.map(round) as [number, number, number],\n riskRewardRatios: rr, atr: round(atrv),\n bullishScore: round1(s.bullish), bearishScore: round1(s.bearish),\n factors: s.factors, session,\n reasoning: s.reasoning, symbol,\n timestamp: Math.floor((opts.now ?? new Date()).getTime() / 1000),\n };\n}\n\nconst round = (n: number) => Math.round(n * 100) / 100;\nconst round1 = (n: number) => Math.round(n * 10) / 10;\n",[],[147,193,249],"6dab4a14-5c48-409b-a51f-75ce42158d2a",["D",1784182339533],[169,170,171,172,173,174,175,176,177],[147,193],"81aea00a-be69-4c85-a214-22db3888c835","main.tsx","dace1daa-80de-11f1-87fb-1607ee4eb77e","7c64ee57-a0f5-468d-a365-e6482b9012f3",10,["D",1784183006695],"/** @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",[],[147,269,261],"frontend","ee87410f-e49d-40fb-a324-d17cd0f15791",["D",1784183075809],[],[147,269,38],"11f9d7e5-90a5-40c3-ade9-56588b1b2722","api.ts","03fe14f0-80df-11f1-872f-1607ee4eb77e",11,["D",1784183075799],"// Tiny typed fetch client.\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 {\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; symbol: string; direction: string; confidence: number; entry: number; stopLoss: number;\n takeProfits: number[]; atr: number; bullishScore: number; bearishScore: number; session: string;\n reasoning: string[]; factors: Factor[]; autoTraded: boolean; createdAt: number;\n}\nexport interface Trade {\n id: number; brokerId: number; brokerType: string; symbol: string; direction: string;\n quantity: number; entryPrice: number; exitPrice: number | null; stopLoss: number;\n takeProfit: number; status: string; pnl: number | null; confidence: number;\n reasoning: string; brokerOrderId: string | null; createdAt: number; closedAt: number | null;\n}\nexport interface BrokerRow {\n id: number; type: string; name: string; apiKey: string; apiSecret: string;\n extra: string; isPaper: boolean; active: boolean; symbols: string; createdAt: number;\n config?: BrokerConfig;\n}\nexport interface BrokerConfig {\n type: string; displayName: string; description: string; icon: string;\n fields: { key: string; label: string; type: string; required: boolean; placeholder?: string }[];\n defaultSymbols: string[]; supportsPaperTrading: boolean; available: boolean;\n}\nexport interface Settings {\n hasApiKey: boolean; riskPerTrade: number; riskReward: number[];\n scanIntervalMin: number; autoTrade: boolean; minConfidence: number;\n maxOpenTrades: number; tradeSymbol: string;\n}\nexport interface TelegramConfig {\n hasToken: boolean; chatId: string; notifyBuy: boolean; notifySell: boolean;\n notifyNeutral: boolean; notifyTrades: boolean; minConfidence: number;\n}\n\nexport const api = {\n candles: (interval: string, symbol?: string, outputsize = 200) =>\n req<{ interval: string; symbol: string; candles: Candle[] }>(\n `/api/market-data?type=candles&interval=${interval}&outputsize=${outputsize}${symbol ? `&symbol=${symbol}` : \"\"}`,\n ),\n quote: (symbol?: string) =>\n req(`/api/market-data?type=quote${symbol ? `&symbol=${symbol}` : \"\"}`),\n analyze: () =>\n req<{ ok: boolean; analysis?: any; telegramSent: boolean; autoTraded: boolean; tradeError?: string; error?: string }>(\n `/api/analyze`, { method: \"POST\" },\n ),\n signals: (limit = 50) => req(`/api/signals?limit=${limit}`),\n trades: (limit = 50) => req(`/api/trades?limit=${limit}`),\n setTradeStatus: (id: number, body: Partial) =>\n req(`/api/trades/${id}`, { method: \"PATCH\", body: JSON.stringify(body) }),\n\n brokers: () => req(`/api/brokers`),\n brokerConfigs: () => req(`/api/brokers/configs`),\n createBroker: (b: any) => req<{ id: number }>(`/api/brokers`, { method: \"POST\", body: JSON.stringify(b) }),\n updateBroker: (id: number, b: any) => req(`/api/brokers/${id}`, { method: \"PATCH\", body: JSON.stringify(b) }),\n deleteBroker: (id: number) => req(`/api/brokers/${id}`, { method: \"DELETE\" }),\n\n settings: () => req(`/api/settings`),\n updateSettings: (s: Partial) =>\n req(`/api/settings`, { method: \"PATCH\", body: JSON.stringify(s) }),\n\n telegram: () => req(`/api/telegram`),\n updateTelegram: (t: Partial) =>\n req(`/api/telegram`, { method: \"PATCH\", body: JSON.stringify(t) }),\n testTelegram: () => req<{ ok: boolean; error?: string }>(`/api/telegram/test`, { method: \"POST\" }),\n};\n",[],[147,269,275],"19c60ef6-5644-4767-8005-0df02bfcaa6f",["D",1784183006695],[165,166,167],[147,269],["D",1784182339533],[164,168],[147],["D",1784180422629],["D",1789525843977],{"_104":103,"_111":107},{"_104":103,"_105":103,"_106":107,"_19":59,"_108":109,"_110":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"ctx",{"_86":-5,"_131":327,"_328":329,"_330":331,"_332":30,"_333":30,"_334":30,"_335":63,"_336":-5,"_337":-7,"_338":-7,"_339":67,"_340":30,"_341":30,"_342":-5,"_343":30,"_344":30,"_345":30,"_346":-5},"ENV",{"_298":299,"_300":301,"_302":94,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324,"_325":326},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v12