King's Backtester v3

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_343":344,"_345":346},"routes/_app.x.$handle.$name",{"_104":103,"_38":51,"_113":94,"_33":114,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":31,"_128":129,"_130":64,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":31},"version",23,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","d6caf707-10b7-4dbb-8f7f-b41926bca500","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","server.ts","latestPath","fileId","8dade5da-836f-11f1-babc-1607ee4eb77e","name","fileType","http","content","// ─── King's Backtester v3 — Main HTTP Server ───\nimport { Hono } from \"npm:hono\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { initDb, getDashboardStats, getRecentReports, getReportByJobId,\n createReport, updateReportStatus, upsertUser, getUserByToken,\n getAllUsers, recordChronicleEntry } from \"./src/db.ts\";\nimport { sendTelegramMessage, isRateLimited } from \"./src/telegram.ts\";\nimport { fetchGoldData, fetchData } from \"./src/market.ts\";\nimport { conveneCouncil } from \"./src/council.ts\";\nimport { queryOracle } from \"./src/oracle.ts\";\nimport { runBacktest } from \"./src/backtest.ts\";\nimport { runMonteCarlo } from \"./src/monte-carlo.ts\";\nimport { runBenchmark, runStressTest } from \"./src/benchmark.ts\";\nimport { getRoyalState } from \"./src/state.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nlet dbReady = false;\nasync function ensureDb() {\n if (!dbReady) { await initDb(); dbReady = true; }\n}\n\n// ─── Serve Dashboard ───\napp.get(\"/\", async (c) => {\n const html = await readFile(\"dashboard.html\");\n return c.html(html);\n});\n\n// ─── Health Check ───\napp.get(\"/health\", (c) => c.json({\n status: \"ok\",\n version: \"3.0.0-imperial-court\",\n dbReady,\n state: getRoyalState().mode,\n}));\n\n// ─── Dashboard API ───\napp.get(\"/api/dashboard/stats\", async (c) => {\n await ensureDb();\n const stats = await getDashboardStats();\n return c.json(stats);\n});\n\napp.get(\"/api/dashboard/reports\", async (c) => {\n await ensureDb();\n const reports = await getRecentReports(20);\n return c.json(reports);\n});\n\napp.get(\"/api/dashboard/report/:jobId\", async (c) => {\n await ensureDb();\n const jobId = c.req.param(\"jobId\");\n const report = await getReportByJobId(jobId);\n return c.json(report || { status: \"not_found\" });\n});\n\napp.get(\"/api/dashboard/users\", async (c) => {\n await ensureDb();\n const users = await getAllUsers();\n return c.json(users);\n});\n\n// ─── Run Analysis (processes inline) ───\napp.post(\"/api/dashboard/run\", async (c) => {\n await ensureDb();\n const body = await c.req.json();\n const { symbol, userId, type, config } = body;\n const jobId = \"job-\" + crypto.randomUUID().slice(0, 12);\n\n try {\n await createReport(jobId, userId || 1, type);\n await updateReportStatus(jobId, \"running\");\n\n // Fetch market data\n const candles = await fetchGoldData(\"1h\", 500);\n\n let reportJson: string;\n if (type === \"backtest\") {\n const report = await runBacktest(candles, config);\n reportJson = JSON.stringify(report);\n } else if (type === \"monte-carlo\") {\n const btReport = await runBacktest(candles, config);\n const mcReport = await runMonteCarlo(btReport.trades, 1000);\n reportJson = JSON.stringify(mcReport);\n } else if (type === \"benchmark\") {\n const bmReport = await runBenchmark(candles);\n reportJson = JSON.stringify(bmReport);\n } else if (type === \"stress\") {\n const stressReport = await runStressTest(candles);\n reportJson = JSON.stringify(stressReport);\n } else {\n await updateReportStatus(jobId, \"error\", undefined, \"Unknown type\");\n return c.json({ error: \"Unknown type\" }, 400);\n }\n\n await updateReportStatus(jobId, \"done\", reportJson);\n return c.json({ jobId, status: \"done\" });\n } catch (e: any) {\n await updateReportStatus(jobId, \"error\", undefined, e.message);\n return c.json({ jobId, status: \"error\", error: e.message }, 500);\n }\n});\n\n// ─── Council API ───\napp.get(\"/api/council\", async (c) => {\n try {\n const [m5, m15, h1, h4, d1] = await Promise.all([\n fetchGoldData(\"5min\", 288),\n fetchGoldData(\"15min\", 192),\n fetchGoldData(\"1h\", 168),\n fetchGoldData(\"4h\", 126),\n fetchGoldData(\"1day\", 90),\n ]);\n const state = getRoyalState();\n const council = await conveneCouncil({ m5, m15, h1, h4, d1, state });\n const prophecy = await queryOracle({ council, data: { m5, m15, h1, h4, d1 }, state });\n \n // Serialize Set objects for JSON\n const serializedVotes: Record = {};\n for (const [k, v] of Object.entries(council.votes)) {\n serializedVotes[k] = v;\n }\n \n return c.json({\n regime: council.regime,\n consensus: council.consensus,\n agreement: council.agreement,\n confidence: prophecy.confidence,\n direction: prophecy.direction,\n edge: prophecy.edge,\n reasoning: prophecy.reasoning,\n votes: serializedVotes,\n });\n } catch (e: any) {\n return c.json({ error: e.message }, 500);\n }\n});\n\n// ─── Chronicle API ───\napp.get(\"/api/chronicle\", async (c) => {\n await ensureDb();\n const stats = await getDashboardStats();\n return c.json(stats.recentTrades || []);\n});\n\n// ─── Telegram Webhook ───\napp.post(\"/webhook/:botToken\", async (c) => {\n const { botToken } = c.req.param();\n const body = await c.req.json();\n const message = body?.message;\n if (!message?.text) return c.json({ ok: true });\n\n if (isRateLimited(botToken)) {\n await sendTelegramMessage(botToken, String(message.chat.id), \"⏳ Rate limit hit. Slow down.\");\n return c.json({ ok: true });\n }\n\n await ensureDb();\n const user = await getUserByToken(botToken);\n if (!user) {\n await sendTelegramMessage(botToken, String(message.chat.id), \"❌ Unauthorized. Use /register first.\");\n return c.json({ ok: true });\n }\n\n const chatId = String(message.chat.id);\n const text = message.text.trim();\n const parts = text.split(/\\s+/);\n const cmd = parts[0].toLowerCase();\n\n if (cmd === \"/register\") {\n await sendTelegramMessage(botToken, chatId,\n \"✅ Registered! Commands:\\n/backtest [symbol]\\n/mc [symbol]\\n/benchmark [symbol]\\n/stress [symbol]\\n/status \\n/report \");\n return c.json({ ok: true });\n }\n\n if (cmd === \"/backtest\" || cmd === \"/mc\" || cmd === \"/benchmark\" || cmd === \"/stress\") {\n const symbol = parts[1] || \"XAU/USD\";\n const type = cmd === \"/mc\" ? \"monte-carlo\" : cmd.slice(1);\n const jobId = \"job-\" + crypto.randomUUID().slice(0, 12);\n await sendTelegramMessage(botToken, chatId, `⏳ ${type} queued for *${symbol}*\\nJob: \\`${jobId}\\``);\n \n try {\n await createReport(jobId, user.id, type);\n await updateReportStatus(jobId, \"running\");\n const candles = await fetchGoldData(\"1h\", 500);\n let reportJson: string;\n if (type === \"backtest\") {\n reportJson = JSON.stringify(await runBacktest(candles));\n } else if (type === \"monte-carlo\") {\n const bt = await runBacktest(candles);\n reportJson = JSON.stringify(await runMonteCarlo(bt.trades, 1000));\n } else if (type === \"benchmark\") {\n reportJson = JSON.stringify(await runBenchmark(candles));\n } else {\n reportJson = JSON.stringify(await runStressTest(candles));\n }\n await updateReportStatus(jobId, \"done\", reportJson);\n await sendTelegramMessage(botToken, chatId, `✅ Done! Use /report ${jobId} to view results.`);\n } catch (e: any) {\n await updateReportStatus(jobId, \"error\", undefined, e.message);\n await sendTelegramMessage(botToken, chatId, `❌ Error: ${e.message}`);\n }\n return c.json({ ok: true });\n }\n\n if (cmd === \"/status\") {\n const jobId = parts[1];\n if (!jobId) { await sendTelegramMessage(botToken, chatId, \"Usage: /status \"); return c.json({ ok: true }); }\n const row = await getReportByJobId(jobId);\n if (!row) { await sendTelegramMessage(botToken, chatId, \"❌ Job not found.\"); }\n else { await sendTelegramMessage(botToken, chatId, `📊 Job *${jobId}*\\nStatus: ${row.status}${row.error ? `\\nError: ${row.error}` : \"\"}`); }\n return c.json({ ok: true });\n }\n\n if (cmd === \"/report\") {\n const jobId = parts[1];\n if (!jobId) { await sendTelegramMessage(botToken, chatId, \"Usage: /report \"); return c.json({ ok: true }); }\n const row = await getReportByJobId(jobId);\n if (!row || row.status !== \"done\") { await sendTelegramMessage(botToken, chatId, \"❌ Report not ready.\"); return c.json({ ok: true }); }\n const report = JSON.parse(row.report_json);\n let summary = \"📊 Report:\\n\";\n if (report.totalTrades !== undefined) {\n summary = `✅ *Backtest*\\nTrades: ${report.totalTrades} (${report.wins}W/${report.losses}L)\\nWin rate: ${report.winRate.toFixed(1)}%\\nReturn: ${report.totalReturn.toFixed(2)}%\\nDD: ${report.maxDrawdown.toFixed(2)}%`;\n } else if (report.runs !== undefined) {\n summary = `🎲 *Monte Carlo* (${report.runs} runs)\\nMedian DD: ${report.medianMaxDD.toFixed(2)}%\\nProb profit: ${(report.probOfProfit * 100).toFixed(1)}%`;\n } else if (report.winner !== undefined) {\n summary = `⚔️ *Benchmark*\\nWinner: ${report.winner}`;\n }\n await sendTelegramMessage(botToken, chatId, summary);\n return c.json({ ok: true });\n }\n\n await sendTelegramMessage(botToken, chatId,\n \"🤖 *King's Backtester v3*\\n\\n`/backtest [symbol]`\\n`/mc [symbol]`\\n`/benchmark [symbol]`\\n`/stress [symbol]`\\n`/status `\\n`/report `\");\n return c.json({ ok: true });\n});\n\n// ─── Register new Telegram user ───\napp.post(\"/api/register\", async (c) => {\n await ensureDb();\n const { botToken, chatId } = await c.req.json();\n if (!botToken || !chatId) return c.json({ error: \"botToken and chatId required\" }, 400);\n const user = await upsertUser(botToken, chatId);\n return c.json({ ok: true, userId: user.id });\n});\n\nexport default app.fetch;\n","// ─── King's Backtester v3 — Main HTTP Server ───\nimport { Hono } from \"npm:hono\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { initDb, getDashboardStats, getRecentReports, getReportByJobId,\n createReport, updateReportStatus, upsertUser, getUserByToken,\n getAllUsers, recordChronicleEntry,\n saveSetting, getSetting, getAllSettings } from \"./src/db.ts\";\nimport { sendTelegramMessage, isRateLimited } from \"./src/telegram.ts\";\nimport { fetchGoldData, fetchData } from \"./src/market.ts\";\nimport { conveneCouncil } from \"./src/council.ts\";\nimport { queryOracle } from \"./src/oracle.ts\";\nimport { runBacktest } from \"./src/backtest.ts\";\nimport { runMonteCarlo } from \"./src/monte-carlo.ts\";\nimport { runBenchmark, runStressTest } from \"./src/benchmark.ts\";\nimport { getRoyalState } from \"./src/state.ts\";\nimport { royalAudience } from \"./src/royal-audience.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nlet dbReady = false;\nasync function ensureDb() {\n if (!dbReady) { await initDb(); dbReady = true; }\n}\n\n// ─── Serve Dashboard ───\napp.get(\"/\", async (c) => {\n const html = await readFile(\"dashboard.html\");\n return c.html(html);\n});\n\n// ─── Health Check ───\napp.get(\"/health\", (c) => c.json({\n status: \"ok\",\n version: \"3.0.0-imperial-court\",\n dbReady,\n state: getRoyalState().mode,\n cron: \"active\",\n}));\n\n// ─── Dashboard Stats ───\napp.get(\"/api/dashboard/stats\", async (c) => {\n await ensureDb();\n const stats = await getDashboardStats();\n return c.json(stats);\n});\n\n// ─── Dashboard Reports ───\napp.get(\"/api/dashboard/reports\", async (c) => {\n await ensureDb();\n const limit = c.req.query(\"limit\") || \"20\";\n const reports = await getRecentReports(parseInt(limit));\n return c.json({ reports });\n});\n\n// ─── Dashboard Report Detail ───\napp.get(\"/api/dashboard/report/:jobId\", async (c) => {\n await ensureDb();\n const jobId = c.req.param(\"jobId\");\n const report = await getReportByJobId(jobId);\n return c.json(report || { status: \"not_found\" });\n});\n\n// ─── Dashboard Users ───\napp.get(\"/api/dashboard/users\", async (c) => {\n await ensureDb();\n const users = await getAllUsers();\n return c.json(users);\n});\n\n// ─── Run Analysis ───\napp.post(\"/api/dashboard/run\", async (c) => {\n await ensureDb();\n const body = await c.req.json();\n const { symbol, userId, type, config } = body;\n const jobId = \"job-\" + crypto.randomUUID().slice(0, 12);\n\n try {\n await createReport(jobId, userId || 1, type);\n await updateReportStatus(jobId, \"running\");\n\n const tf = config?.timeframe || \"1h\";\n const candles = await fetchGoldData(tf as any, 500);\n\n let reportJson: string;\n if (type === \"backtest\") {\n const report = await runBacktest(candles, config);\n reportJson = JSON.stringify(report);\n } else if (type === \"monte-carlo\") {\n const btReport = await runBacktest(candles, config);\n const mcReport = await runMonteCarlo(btReport.trades, 1000);\n reportJson = JSON.stringify(mcReport);\n } else if (type === \"benchmark\") {\n const bmReport = await runBenchmark(candles);\n reportJson = JSON.stringify(bmReport);\n } else if (type === \"stress\") {\n const stressReport = await runStressTest(candles);\n reportJson = JSON.stringify(stressReport);\n } else {\n await updateReportStatus(jobId, \"error\", undefined, \"Unknown type\");\n return c.json({ error: \"Unknown type\" }, 400);\n }\n\n await updateReportStatus(jobId, \"done\", reportJson);\n\n // Auto-send to Telegram if configured\n const botToken = await getSetting(\"bot_token\");\n const chatId = await getSetting(\"chat_id\");\n if (botToken && chatId) {\n const report = JSON.parse(reportJson);\n let summary = `✅ *${type}* complete\\nJob: \\`${jobId}\\``;\n if (report.totalTrades !== undefined) {\n summary += `\\nTrades: ${report.totalTrades} (${report.wins}W/${report.losses}L)\\nReturn: ${report.totalReturn.toFixed(2)}%\\nWin Rate: ${report.winRate.toFixed(1)}%`;\n } else if (report.runs !== undefined) {\n summary += `\\nRuns: ${report.runs}\\nProb profit: ${(report.probOfProfit * 100).toFixed(1)}%`;\n } else if (report.winner !== undefined) {\n summary += `\\nWinner: ${report.winner}`;\n }\n await sendTelegramMessage(botToken, chatId, summary);\n }\n\n return c.json({ jobId, status: \"done\" });\n } catch (e: any) {\n await updateReportStatus(jobId, \"error\", undefined, e.message);\n return c.json({ jobId, status: \"error\", error: e.message }, 500);\n }\n});\n\n// ─── Council API (returns indicators array for dashboard) ───\napp.get(\"/api/dashboard/council\", async (c) => {\n try {\n const [m5, m15, h1, h4, d1] = await Promise.all([\n fetchGoldData(\"5min\", 288),\n fetchGoldData(\"15min\", 192),\n fetchGoldData(\"1h\", 168),\n fetchGoldData(\"4h\", 126),\n fetchGoldData(\"1day\", 90),\n ]);\n const state = getRoyalState();\n const council = await conveneCouncil({ m5, m15, h1, h4, d1, state });\n const prophecy = await queryOracle({ council, data: { m5, m15, h1, h4, d1 }, state });\n\n // Convert votes object to indicators array for the dashboard\n const indicators = Object.values(council.votes).map((v: any) => ({\n name: v.indicator,\n signal: v.vote,\n detail: v.detail,\n weight: v.weight,\n confidence: v.confidence,\n }));\n\n return c.json({\n regime: council.regime,\n consensus: council.consensus,\n agreement: council.agreement,\n confidence: prophecy.confidence,\n direction: prophecy.direction,\n edge: prophecy.edge,\n reasoning: prophecy.reasoning,\n indicators,\n });\n } catch (e: any) {\n return c.json({ error: e.message }, 500);\n }\n});\n\n// Keep old council endpoint for backward compat\napp.get(\"/api/council\", async (c) => {\n try {\n const [m5, m15, h1, h4, d1] = await Promise.all([\n fetchGoldData(\"5min\", 288), fetchGoldData(\"15min\", 192),\n fetchGoldData(\"1h\", 168), fetchGoldData(\"4h\", 126), fetchGoldData(\"1day\", 90),\n ]);\n const state = getRoyalState();\n const council = await conveneCouncil({ m5, m15, h1, h4, d1, state });\n const prophecy = await queryOracle({ council, data: { m5, m15, h1, h4, d1 }, state });\n const serializedVotes: Record = {};\n for (const [k, v] of Object.entries(council.votes)) serializedVotes[k] = v;\n return c.json({\n regime: council.regime, consensus: council.consensus, agreement: council.agreement,\n confidence: prophecy.confidence, direction: prophecy.direction, edge: prophecy.edge,\n reasoning: prophecy.reasoning, votes: serializedVotes,\n });\n } catch (e: any) { return c.json({ error: e.message }, 500); }\n});\n\n// ─── Chronicle API ───\napp.get(\"/api/dashboard/chronicle\", async (c) => {\n await ensureDb();\n const stats = await getDashboardStats();\n return c.json(stats.recentTrades || []);\n});\n\n// Keep old chronicle endpoint\napp.get(\"/api/chronicle\", async (c) => {\n await ensureDb();\n const stats = await getDashboardStats();\n return c.json(stats.recentTrades || []);\n});\n\n// ─── Settings API (persist to DB) ───\napp.get(\"/api/dashboard/settings\", async (c) => {\n await ensureDb();\n const settings = await getAllSettings();\n return c.json({\n twelveDataKey: !!settings[\"twelve_data_key\"],\n botToken: !!settings[\"bot_token\"],\n chatId: !!settings[\"chat_id\"],\n devApiKey: !!settings[\"dev_api_key\"],\n });\n});\n\napp.post(\"/api/dashboard/settings\", async (c) => {\n await ensureDb();\n const { twelveDataKey, botToken, chatId, devApiKey } = await c.req.json();\n if (twelveDataKey) await saveSetting(\"twelve_data_key\", twelveDataKey);\n if (botToken) await saveSetting(\"bot_token\", botToken);\n if (chatId) await saveSetting(\"chat_id\", chatId);\n if (devApiKey) await saveSetting(\"dev_api_key\", devApiKey);\n // Also register as a user for webhook\n if (botToken && chatId) await upsertUser(botToken, chatId);\n return c.json({ ok: true });\n});\n\n// ─── Chart Data API ───\napp.get(\"/api/dashboard/chart-data\", async (c) => {\n const symbol = c.req.query(\"symbol\") || \"XAU/USD\";\n const interval = c.req.query(\"interval\") || \"15min\";\n await ensureDb();\n const key = await getSetting(\"twelve_data_key\");\n if (!key) {\n // Return simulated data if no key\n const candles = await fetchGoldData(interval as any, 50);\n return c.json(candles.map(c => ({\n time: c.timestamp, open: c.open, high: c.high, low: c.low, close: c.close, volume: c.volume,\n })));\n }\n try {\n const tdSymbol = symbol.replace(\"/\", \"/\");\n const url = `https://api.twelvedata.com/time_series?symbol=${encodeURIComponent(tdSymbol)}&interval=${interval}&outputsize=50&apikey=${key}`;\n const res = await fetch(url);\n const data = await res.json();\n const values = data.values || [];\n return c.json(values.map((v: any) => ({\n time: new Date(v.datetime).getTime(),\n open: parseFloat(v.open), high: parseFloat(v.high),\n low: parseFloat(v.low), close: parseFloat(v.close),\n volume: parseFloat(v.volume) || 0,\n })).reverse());\n } catch (e: any) {\n return c.json({ error: e.message }, 500);\n }\n});\n\n// ─── Manual trigger for Royal Audience ───\napp.post(\"/api/dashboard/audience\", async (c) => {\n try {\n await royalAudience();\n return c.json({ ok: true, state: getRoyalState().mode });\n } catch (e: any) {\n return c.json({ error: e.message }, 500);\n }\n});\n\n// ─── Telegram Webhook ───\napp.post(\"/webhook/:botToken\", async (c) => {\n const { botToken } = c.req.param();\n const body = await c.req.json();\n const message = body?.message;\n if (!message?.text) return c.json({ ok: true });\n\n if (isRateLimited(botToken)) {\n await sendTelegramMessage(botToken, String(message.chat.id), \"⏳ Rate limit hit. Slow down.\");\n return c.json({ ok: true });\n }\n\n await ensureDb();\n const user = await getUserByToken(botToken);\n if (!user) {\n await sendTelegramMessage(botToken, String(message.chat.id), \"❌ Unauthorized. Use /register first.\");\n return c.json({ ok: true });\n }\n\n const chatId = String(message.chat.id);\n const text = message.text.trim();\n const parts = text.split(/\\s+/);\n const cmd = parts[0].toLowerCase();\n\n if (cmd === \"/register\") {\n await sendTelegramMessage(botToken, chatId,\n \"✅ Registered! Commands:\\n/backtest [symbol]\\n/mc [symbol]\\n/benchmark [symbol]\\n/stress [symbol]\\n/status \\n/report \\n/audience — Trigger Royal Audience now\");\n return c.json({ ok: true });\n }\n\n // Manual trigger of Royal Audience\n if (cmd === \"/audience\" || cmd === \"/scan\") {\n await sendTelegramMessage(botToken, chatId, \"👑 Convening Royal Audience now...\");\n try {\n await royalAudience();\n const state = getRoyalState();\n await sendTelegramMessage(botToken, chatId,\n `👑 Royal Audience complete.\\nMode: ${state.mode}\\nConfidence: ${state.crownConfidence.toFixed(1)}%\\nRegime: ${state.marketRegime}\\nTrades: ${state.totalTrades}`);\n } catch (e: any) {\n await sendTelegramMessage(botToken, chatId, `❌ Audience failed: ${e.message}`);\n }\n return c.json({ ok: true });\n }\n\n if (cmd === \"/backtest\" || cmd === \"/mc\" || cmd === \"/benchmark\" || cmd === \"/stress\") {\n const symbol = parts[1] || \"XAU/USD\";\n const type = cmd === \"/mc\" ? \"monte-carlo\" : cmd.slice(1);\n const jobId = \"job-\" + crypto.randomUUID().slice(0, 12);\n await sendTelegramMessage(botToken, chatId, `⏳ ${type} queued for *${symbol}*\\nJob: \\`${jobId}\\``);\n try {\n await createReport(jobId, user.id, type);\n await updateReportStatus(jobId, \"running\");\n const candles = await fetchGoldData(\"1h\", 500);\n let reportJson: string;\n if (type === \"backtest\") reportJson = JSON.stringify(await runBacktest(candles));\n else if (type === \"monte-carlo\") { const bt = await runBacktest(candles); reportJson = JSON.stringify(await runMonteCarlo(bt.trades, 1000)); }\n else if (type === \"benchmark\") reportJson = JSON.stringify(await runBenchmark(candles));\n else reportJson = JSON.stringify(await runStressTest(candles));\n await updateReportStatus(jobId, \"done\", reportJson);\n await sendTelegramMessage(botToken, chatId, `✅ Done! Use /report ${jobId} to view results.`);\n } catch (e: any) {\n await updateReportStatus(jobId, \"error\", undefined, e.message);\n await sendTelegramMessage(botToken, chatId, `❌ Error: ${e.message}`);\n }\n return c.json({ ok: true });\n }\n\n if (cmd === \"/status\") {\n const jobId = parts[1];\n if (!jobId) { await sendTelegramMessage(botToken, chatId, \"Usage: /status \"); return c.json({ ok: true }); }\n const row = await getReportByJobId(jobId);\n if (!row) await sendTelegramMessage(botToken, chatId, \"❌ Job not found.\");\n else await sendTelegramMessage(botToken, chatId, `📊 Job *${jobId}*\\nStatus: ${row.status}${row.error ? `\\nError: ${row.error}` : \"\"}`);\n return c.json({ ok: true });\n }\n\n if (cmd === \"/report\") {\n const jobId = parts[1];\n if (!jobId) { await sendTelegramMessage(botToken, chatId, \"Usage: /report \"); return c.json({ ok: true }); }\n const row = await getReportByJobId(jobId);\n if (!row || row.status !== \"done\") { await sendTelegramMessage(botToken, chatId, \"❌ Report not ready.\"); return c.json({ ok: true }); }\n const report = JSON.parse(row.report_json);\n let summary = \"📊 Report:\\n\";\n if (report.totalTrades !== undefined)\n summary = `✅ *Backtest*\\nTrades: ${report.totalTrades} (${report.wins}W/${report.losses}L)\\nWin rate: ${report.winRate.toFixed(1)}%\\nReturn: ${report.totalReturn.toFixed(2)}%\\nDD: ${report.maxDrawdown.toFixed(2)}%`;\n else if (report.runs !== undefined)\n summary = `🎲 *Monte Carlo* (${report.runs} runs)\\nMedian DD: ${report.medianMaxDD.toFixed(2)}%\\nProb profit: ${(report.probOfProfit * 100).toFixed(1)}%`;\n else if (report.winner !== undefined)\n summary = `⚔️ *Benchmark*\\nWinner: ${report.winner}`;\n await sendTelegramMessage(botToken, chatId, summary);\n return c.json({ ok: true });\n }\n\n await sendTelegramMessage(botToken, chatId,\n \"🤖 *King's Backtester v3*\\n\\n`/backtest [symbol]`\\n`/mc [symbol]`\\n`/benchmark [symbol]`\\n`/stress [symbol]`\\n`/audience` — Trigger Royal Audience\\n`/status `\\n`/report `\");\n return c.json({ ok: true });\n});\n\n// ─── Register Telegram user ───\napp.post(\"/api/register\", async (c) => {\n await ensureDb();\n const { botToken, chatId } = await c.req.json();\n if (!botToken || !chatId) return c.json({ error: \"botToken and chatId required\" }, 400);\n const user = await upsertUser(botToken, chatId);\n return c.json({ ok: true, userId: user.id });\n});\n\nexport default app.fetch;\n","createdAt",["D",1784466282337],"branchVersion","branchId","0934adcd-abfd-4160-a65a-f9e3117222ea","id","e0bac199-8c9e-4ea7-b5d1-78327a1e723a","kings-backtester",["D",1784462621259],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","King's Backtester v3 — Telegram gold trading bot with AI oracle","imageUrl","7e02fbb4-84f6-4a31-bf41-f00c2283d5f1","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f7a29-976b-7429-8cb4-3dd7383e1f5f","tursoName","e0bac1998c9e4ea7b5d178327a1e723a","tursoHostname","e0bac1998c9e4ea7b5d178327a1e723a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789472446807],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_112":108},"org",{"_104":103,"_105":106,"_107":108,"_19":61,"_109":110,"_111":31},"branch",{"_13":14,"_38":94,"_49":48,"_95":50,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":51,"_102":103},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","puritytoroitich","handle","displayName","Purity Toroitich","avatar","https://lh3.googleusercontent.com/a/ACg8ocIHK4iHuSqiLGT4P6BMkR_V3bwuI6Oa_h3nJn8yQ2B1xCAMRQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_49":50,"_38":51,"_44":338,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":339,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":340,"_89":341,"_91":342,"_93":31},"tree",[177,194,195,196],"files",[177,178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196],"counts",{"_167":68,"_168":143,"_169":68,"_170":171,"_172":173},"contents",[135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":161,"_38":162,"_36":163,"_140":-5,"_47":48,"_46":143,"_141":64,"_44":164,"_13":68,"_39":165,"_41":-5,"_30":31,"_144":-5,"_33":166},{"_49":153,"_38":154,"_36":155,"_140":-5,"_47":48,"_46":156,"_141":64,"_44":157,"_13":68,"_39":158,"_41":159,"_30":31,"_144":-5,"_33":160},{"_49":146,"_38":147,"_36":148,"_140":-5,"_47":48,"_46":149,"_141":64,"_44":150,"_13":143,"_39":26,"_41":151,"_30":31,"_144":-5,"_33":152},{"_49":139,"_38":34,"_36":37,"_140":-5,"_47":48,"_46":14,"_141":64,"_44":142,"_13":143,"_39":40,"_41":43,"_30":31,"_144":-5,"_33":145},"3c61c0d8-88cc-4124-8be4-c447c90e9043","parentId","latest",["D",1784466282337],1,"label",[34],"478059c4-254f-4f0e-8687-3e293df69a95","dashboard.html","7a26c9f0-836f-11f1-9a29-1607ee4eb77e",19,["D",1784466147395],"\n\n\n\n\nKing's Backtester v3\n\n\n\n\n\n\n\n\n\n

Total reports

Completed

✓

Queued/Running

✓ Idle

Errors

Total users

Total trades

\n \n

📋 Recent Jobs

Job ID	Type	Symbol	Status	Created

\n\n\n

Consensus

Agreement

Regime

Confidence

Direction

Edge

\n \n

🏛️ Council of Indicators

\n\n\n

📈 Live XAU/USD

\n \n

Data by TradingView · No API key required for display

\n \n \n

\n\n\n

⚔️ Launch Royal Analysis

\n \n

\n\n\n

📋 All Reports

Job ID	Type	Status	Created	Action

\n\n\n

📜 Royal Chronicle — Trade Journal

Time	Action	Dir	Entry	Stop	Size	Reason

\n \n

\n\n\n

⚙️ Imperial Settings

\n \n

Data Provider

TwelveData API Key

Not configured — backtests will use simulated data

\n \n

Telegram Integration

Bot Token

Chat ID

Not configured — reports will not be sent to Telegram

\n \n

Security

Developer API Key

Using default — change in production

\n \n \n

\n \n

🩺 System Status

Click Check to view system health.

\n\n\n\n\n

Done

\n\n\n\n\n\n",[147],"eb35ceaf-39d2-4a15-aebf-fdde750939cf","cron.ts","3f38b8fa-8372-11f1-8c16-1607ee4eb77e",22,["D",1784466213531],"interval","// ─── Royal Cron — Automated Intelligence Loop ───\n// Runs the King's Royal Audience automatically every 15 minutes\n// The King gathers intelligence, convenes the council, consults the oracle,\n// issues decrees, and sends Telegram signals — all automatically.\n\nimport { royalAudience } from \"./src/royal-audience.ts\";\n\nexport default async function () {\n console.log(`\\n⏰ Royal Cron triggered at ${new Date().toISOString()}`);\n await royalAudience();\n console.log(`✅ Royal Cron cycle complete\\n`);\n}\n",[154],"f683e6a0-10d5-4c1a-bf2e-5dc240d383cd","src","6a9a0a45-04fc-49a1-9111-dd5f55871c59",["D",1784462679139],"directory",[162],"pulls","branches","forks","envVars",{"_174":68,"_176":68},"connections",{"_174":68,"_175":68},"count","unfilledCount","emptyCount",{"_49":161,"_38":162,"_36":163,"_140":-5,"_47":48,"_46":143,"_141":64,"_44":335,"_13":68,"_39":165,"_41":-5,"_30":31,"_144":-5,"_198":336,"_33":337},{"_49":327,"_38":328,"_36":329,"_140":163,"_47":48,"_46":330,"_141":64,"_44":331,"_13":68,"_39":212,"_41":332,"_30":31,"_144":-5,"_198":333,"_33":334},{"_49":319,"_38":320,"_36":321,"_140":163,"_47":48,"_46":322,"_141":64,"_44":323,"_13":68,"_39":212,"_41":324,"_30":31,"_144":-5,"_198":325,"_33":326},{"_49":311,"_38":312,"_36":313,"_140":163,"_47":48,"_46":314,"_141":64,"_44":315,"_13":68,"_39":212,"_41":316,"_30":31,"_144":-5,"_198":317,"_33":318},{"_49":303,"_38":304,"_36":305,"_140":163,"_47":48,"_46":306,"_141":64,"_44":307,"_13":68,"_39":212,"_41":308,"_30":31,"_144":-5,"_198":309,"_33":310},{"_49":295,"_38":296,"_36":297,"_140":163,"_47":48,"_46":298,"_141":64,"_44":299,"_13":143,"_39":212,"_41":300,"_30":31,"_144":-5,"_198":301,"_33":302},{"_49":288,"_38":289,"_36":290,"_140":163,"_47":48,"_46":143,"_141":64,"_44":291,"_13":68,"_39":212,"_41":292,"_30":31,"_144":-5,"_198":293,"_33":294},{"_49":280,"_38":281,"_36":282,"_140":163,"_47":48,"_46":283,"_141":64,"_44":284,"_13":68,"_39":212,"_41":285,"_30":31,"_144":-5,"_198":286,"_33":287},{"_49":272,"_38":273,"_36":274,"_140":163,"_47":48,"_46":275,"_141":64,"_44":276,"_13":68,"_39":212,"_41":277,"_30":31,"_144":-5,"_198":278,"_33":279},{"_49":264,"_38":265,"_36":266,"_140":163,"_47":48,"_46":267,"_141":64,"_44":268,"_13":68,"_39":212,"_41":269,"_30":31,"_144":-5,"_198":270,"_33":271},{"_49":256,"_38":257,"_36":258,"_140":163,"_47":48,"_46":259,"_141":64,"_44":260,"_13":68,"_39":212,"_41":261,"_30":31,"_144":-5,"_198":262,"_33":263},{"_49":248,"_38":249,"_36":250,"_140":163,"_47":48,"_46":251,"_141":64,"_44":252,"_13":68,"_39":212,"_41":253,"_30":31,"_144":-5,"_198":254,"_33":255},{"_49":240,"_38":241,"_36":242,"_140":163,"_47":48,"_46":243,"_141":64,"_44":244,"_13":143,"_39":212,"_41":245,"_30":31,"_144":-5,"_198":246,"_33":247},{"_49":232,"_38":233,"_36":234,"_140":163,"_47":48,"_46":235,"_141":64,"_44":236,"_13":68,"_39":212,"_41":237,"_30":31,"_144":-5,"_198":238,"_33":239},{"_49":224,"_38":225,"_36":226,"_140":163,"_47":48,"_46":227,"_141":64,"_44":228,"_13":68,"_39":212,"_41":229,"_30":31,"_144":-5,"_198":230,"_33":231},{"_49":216,"_38":217,"_36":218,"_140":163,"_47":48,"_46":219,"_141":64,"_44":220,"_13":68,"_39":212,"_41":221,"_30":31,"_144":-5,"_198":222,"_33":223},{"_49":207,"_38":208,"_36":209,"_140":163,"_47":48,"_46":210,"_141":64,"_44":211,"_13":68,"_39":212,"_41":213,"_30":31,"_144":-5,"_198":214,"_33":215},{"_49":153,"_38":154,"_36":155,"_140":-5,"_47":48,"_46":156,"_141":64,"_44":204,"_13":68,"_39":158,"_41":159,"_30":31,"_144":-5,"_198":205,"_33":206},{"_49":146,"_38":147,"_36":148,"_140":-5,"_47":48,"_46":149,"_141":64,"_44":201,"_13":143,"_39":26,"_41":151,"_30":31,"_144":-5,"_198":202,"_33":203},{"_49":139,"_38":34,"_36":37,"_140":-5,"_47":48,"_46":14,"_141":64,"_44":197,"_13":143,"_39":40,"_41":43,"_30":31,"_144":-5,"_198":199,"_33":200},["D",1784466282337],"children",[],[34],["D",1784466147395],[],[147],["D",1784466213531],[],[154],"e4147b15-3c66-4ff9-8a97-842cceb7553f","types.ts","3b11729c-836a-11f1-9ad0-1607ee4eb77e",2,["D",1784462770587],"script","// ─── King's Backtester v3 — Shared Types ───\n\nexport interface Candle {\n timestamp: number;\n open: number;\n high: number;\n low: number;\n close: number;\n volume: number;\n}\n\nexport type Timeframe = \"5min\" | \"15min\" | \"1h\" | \"4h\" | \"1day\";\n\nexport type RoyalMode = \"HUNTING\" | \"STALKING\" | \"STRIKING\" | \"HOLDING\" | \"RETREATING\";\n\nexport interface RoyalState {\n mode: RoyalMode;\n crownConfidence: number;\n marketRegime: string;\n activeStrategies: Set;\n bannedStrategies: Set;\n portfolioHeat: number;\n dailyPnl: number;\n consecutiveLosses: number;\n winStreak: number;\n totalTrades: number;\n lastCouncil: Record;\n decree: any;\n}\n\nexport interface Prophecy {\n direction: \"BUY\" | \"SELL\" | \"NEUTRAL\";\n confidence: number;\n edge: number;\n reasoning: string;\n signals: string[];\n}\n\nexport interface CouncilResult {\n regime: string;\n votes: Record;\n consensus: \"BUY\" | \"SELL\" | \"NEUTRAL\";\n agreement: number;\n}\n\nexport interface CouncilVote {\n indicator: string;\n vote: \"BUY\" | \"SELL\" | \"NEUTRAL\";\n weight: number;\n detail: string;\n confidence: number;\n}\n\nexport interface Decree {\n action: \"STRIKE\" | \"RETREAT\" | \"WAIT\" | \"BAN_STRATEGY\";\n direction?: \"BUY\" | \"SELL\";\n entry?: number;\n stop?: number;\n targets?: number[];\n size?: number;\n reason: string;\n}\n\nexport interface ShieldResult {\n clear: boolean;\n reason: string;\n adjustments?: any;\n}\n\nexport interface ExecutionResult {\n filled: boolean;\n direction: \"BUY\" | \"SELL\";\n entry: number;\n stop: number;\n targets: number[];\n size: number;\n timestamp: number;\n}\n\nexport interface BacktestReport {\n totalTrades: number;\n wins: number;\n losses: number;\n winRate: number;\n profitFactor: number;\n totalReturn: number;\n maxDrawdown: number;\n avgR: number | null;\n pValue: number | null;\n halted: boolean;\n equityCurve: number[];\n trades: BacktestTrade[];\n}\n\nexport interface BacktestTrade {\n entryTime: number;\n exitTime: number;\n direction: \"BUY\" | \"SELL\";\n entry: number;\n exit: number;\n stop: number;\n size: number;\n pnl: number;\n rMultiple: number;\n reason: string;\n}\n\nexport interface MonteCarloReport {\n runs: number;\n medianMaxDD: number;\n worstDrawdown5pct: number;\n probOfProfit: number;\n probOfRuin: number;\n equityPaths: number[][];\n}\n\nexport interface BenchmarkReport {\n strategy: { totalReturn: number; maxDrawdown: number; winRate: number };\n buyAndHold: { totalReturn: number; maxDrawdown: number; winRate: number };\n randomEntry: { totalReturn: number; maxDrawdown: number; winRate: number };\n alwaysInMarket: { totalReturn: number; maxDrawdown: number; winRate: number };\n winner: string;\n}\n\nexport type ReportType = \"backtest\" | \"monte-carlo\" | \"benchmark\" | \"stress\";\n\nexport interface Job {\n jobId: string;\n userId: number;\n botToken: string;\n chatId: string;\n symbol: string;\n type: ReportType;\n config?: any;\n}\n",[],[162,208],"24f88e52-c11d-4140-a3d7-8594f83e3aa0","telegram.ts","10b9e632-836f-11f1-a866-1607ee4eb77e",5,["D",1784464846953],"// ─── Telegram Messaging ───\n\nexport async function sendTelegramMessage(botToken: string, chatId: string, text: string): Promise {\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({ chat_id: chatId, text, parse_mode: \"Markdown\", disable_web_page_preview: true }),\n });\n if (!res.ok) console.error(`Telegram send failed: ${res.status} ${await res.text()}`);\n } catch (e: any) {\n console.error(`Telegram error: ${e.message}`);\n }\n}\n\nconst rateLimitMap = new Map();\n\nexport function isRateLimited(key: string): boolean {\n const now = Date.now();\n const entry = rateLimitMap.get(key);\n if (!entry || now > entry.resetAt) {\n rateLimitMap.set(key, { count: 1, resetAt: now + 60_000 });\n return false;\n }\n entry.count++;\n return entry.count > 20;\n}\n",[],[162,217],"ef0abebd-0c1e-4777-bead-8e88e62a93fe","state.ts","2b67a8f2-836f-11f1-bb66-1607ee4eb77e",10,["D",1784464891632],"// ─── Royal State Manager ───\nimport type { RoyalState, RoyalMode } from \"./types.ts\";\nimport { getDecree } from \"./decree.ts\";\n\nlet state: RoyalState = {\n mode: \"HUNTING\",\n crownConfidence: 0,\n marketRegime: \"UNKNOWN\",\n activeStrategies: new Set(),\n bannedStrategies: new Set(),\n portfolioHeat: 0,\n dailyPnl: 0,\n consecutiveLosses: 0,\n winStreak: 0,\n totalTrades: 0,\n lastCouncil: {},\n decree: getDecree(),\n};\n\nexport function getRoyalState(): RoyalState {\n return state;\n}\n\nexport function setRoyalState(updates: Partial): void {\n state = { ...state, ...updates };\n}\n\nexport function resetDailyState(): void {\n state = { ...state, dailyPnl: 0, consecutiveLosses: 0, winStreak: 0 };\n}\n\nexport function recordTradeResult(pnlPct: number): void {\n state.totalTrades++;\n state.dailyPnl += pnlPct;\n if (pnlPct > 0) {\n state.winStreak++;\n state.consecutiveLosses = 0;\n } else {\n state.consecutiveLosses++;\n state.winStreak = 0;\n }\n}\n",[],[162,225],"697a7f33-da73-47ec-903b-6b9e89acc589","shield.ts","2b53e218-836f-11f1-a4c8-1607ee4eb77e",8,["D",1784464891623],"// ─── Royal Shield — Defense & Risk Checks ───\nimport type { Candle, Decree, RoyalState, ShieldResult } from \"./types.ts\";\nimport { getDecree } from \"./decree.ts\";\nimport { atr } from \"./indicators.ts\";\n\ninterface ShieldInput {\n decree: Decree;\n state: RoyalState;\n data: { m5: Candle[]; m15: Candle[]; h1: Candle[] };\n}\n\nexport async function raiseShield(input: ShieldInput): Promise {\n const { decree, state, data } = input;\n const config = getDecree();\n\n // ── 1. Consecutive Loss Circuit Breaker ──\n if (state.consecutiveLosses >= config.MAX_CONSECUTIVE_LOSSES) {\n return { clear: false, reason: `🛡️ Circuit breaker: ${state.consecutiveLosses} consecutive losses (max ${config.MAX_CONSECUTIVE_LOSSES})` };\n }\n\n // ── 2. Daily Loss Limit ──\n if (state.dailyPnl < 0 && Math.abs(state.dailyPnl) >= config.DAILY_LOSS_LIMIT_PCT) {\n return { clear: false, reason: `🛡️ Daily loss limit hit: ${state.dailyPnl.toFixed(2)}% (limit ${config.DAILY_LOSS_LIMIT_PCT}%)` };\n }\n\n // ── 3. Portfolio Heat Check ──\n if (state.portfolioHeat >= config.MAX_PORTFOLIO_HEAT) {\n return { clear: false, reason: `🛡️ Portfolio heat ${state.portfolioHeat.toFixed(2)}% exceeds max ${config.MAX_PORTFOLIO_HEAT}%` };\n }\n\n // ── 4. ATR Volatility Filter ──\n const atrM15 = atr(data.m15);\n const lastATR = atrM15[atrM15.length - 1];\n const lastClose = data.m15[data.m15.length - 1].close;\n const atrPct = (lastATR / lastClose) * 100;\n if (atrPct > 2.0) {\n return { clear: false, reason: `🛡️ Extreme volatility: ATR ${atrPct.toFixed(2)}% of price` };\n }\n\n // ── 5. Spread / Slippage Proxy ──\n const m5Spread = data.m5[data.m5.length - 1].high - data.m5[data.m5.length - 1].low;\n const avgM5Range = data.m5.slice(-20).reduce((s, c) => s + (c.high - c.low), 0) / 20;\n if (m5Spread > avgM5Range * 2.5) {\n return { clear: false, reason: `🛡️ Abnormal spread: ${(m5Spread / avgM5Range).toFixed(1)}x average` };\n }\n\n // ── 6. News Blackout (temporal) ──\n const minute = new Date().getUTCMinutes();\n const hour = new Date().getUTCHours();\n // Simulate NFP/FOMC blackout windows\n if ((hour === 12 && minute < 30) || (hour === 18 && minute < 30)) {\n if (decree.action === \"STRIKE\") {\n return { clear: false, reason: \"🛡️ News blackout window — high impact event risk\" };\n }\n }\n\n // ── 7. Drawdown Circuit Breaker ──\n if (config.ENABLE_CIRCUIT_BREAKER && state.dailyPnl < -config.MAX_DRAWDOWN_PCT) {\n return { clear: false, reason: `🛡️ Max drawdown breached: ${state.dailyPnl.toFixed(2)}%` };\n }\n\n // ── 8. Winning Streak Euphoria Check ──\n if (state.winStreak >= 5) {\n return { clear: false, reason: `🛡️ Euphoria filter: ${state.winStreak} win streak — forced cooldown` };\n }\n\n return { clear: true, reason: \"All defenses clear\", adjustments: { atrPct, lastClose } };\n}\n",[],[162,233],"b7ee60f2-9666-46eb-b665-830a84487986","royal-audience.ts","7a2d8682-836f-11f1-a4c8-1607ee4eb77e",21,["D",1784466207683],"// ─── Royal Audience — Automated Intelligence Loop ───\nimport type { RoyalState, Decree as DecreeType } from \"./types.ts\";\nimport { fetchGoldData } from \"./market.ts\";\nimport { conveneCouncil } from \"./council.ts\";\nimport { queryOracle } from \"./oracle.ts\";\nimport { raiseShield } from \"./shield.ts\";\nimport { executeDecree } from \"./execution.ts\";\nimport { recordChronicle } from \"./chronicle.ts\";\nimport { getDecree } from \"./decree.ts\";\nimport { getRoyalState, setRoyalState } from \"./state.ts\";\nimport { sendTelegramMessage } from \"./telegram.ts\";\nimport { initDb, getSetting, saveSetting, recordChronicleEntry } from \"./db.ts\";\n\nlet dbReady = false;\nasync function ensureDb() {\n if (!dbReady) { await initDb(); dbReady = true; }\n}\n\n// Load Telegram credentials from DB settings\nasync function getTelegramCreds(): Promise<{ botToken: string; chatId: string } | null> {\n await ensureDb();\n const botToken = await getSetting(\"bot_token\");\n const chatId = await getSetting(\"chat_id\");\n if (botToken && chatId) return { botToken, chatId };\n return null;\n}\n\n// Send a Telegram signal automatically\nasync function autoSignal(text: string): Promise {\n const creds = await getTelegramCreds();\n if (creds) {\n await sendTelegramMessage(creds.botToken, creds.chatId, text);\n console.log(`📱 Telegram signal sent`);\n } else {\n console.log(`📱 No Telegram creds — signal not sent (configure in Settings)`);\n }\n}\n\nexport async function royalAudience(): Promise {\n try {\n const hour = new Date().getUTCHours();\n const active = hour >= 7 && hour <= 22;\n const state = getRoyalState();\n\n if (!active && state.mode !== \"HOLDING\") {\n console.log(`🌙 Kingdom sleeps. Hour: ${hour} UTC`);\n return;\n }\n\n console.log(`\\n👑 The King holds court. Mode: ${state.mode} | Regime: ${state.marketRegime}`);\n\n // 1. Gather intelligence\n let m5, m15, h1, h4, d1;\n try {\n [m5, m15, h1, h4, d1] = await Promise.all([\n fetchGoldData(\"5min\", 288),\n fetchGoldData(\"15min\", 192),\n fetchGoldData(\"1h\", 168),\n fetchGoldData(\"4h\", 126),\n fetchGoldData(\"1day\", 90),\n ]);\n } catch (e: any) {\n console.error(`❌ Fetch failed: ${e.message}`);\n return;\n }\n\n if (!m5 || !m15 || !h1 || !h4 || !d1) {\n console.log(\"🕯️ Oracle is blind. Incomplete data.\");\n return;\n }\n\n // 2. Convene council\n let council;\n try {\n council = await conveneCouncil({ m5, m15, h1, h4, d1, state });\n } catch (e: any) {\n console.error(`❌ Council failed: ${e.message}`);\n return;\n }\n setRoyalState({ lastCouncil: council.votes, marketRegime: council.regime });\n\n // 3. Consult oracle\n let prophecy;\n try {\n prophecy = await queryOracle({ council, data: { m5, m15, h1, h4, d1 }, state });\n } catch (e: any) {\n console.error(`❌ Oracle failed: ${e.message}`);\n return;\n }\n setRoyalState({ crownConfidence: prophecy.confidence });\n\n console.log(`🔮 Oracle: ${prophecy.direction} @ ${prophecy.confidence.toFixed(1)}% | Edge: ${(prophecy.edge * 100).toFixed(1)}%`);\n console.log(`🏛️ Regime: ${council.regime}`);\n\n // 4. Issue decree\n const decision = await issueRoyalDecree(prophecy, council);\n\n // 5. Raise shield\n let shield;\n try {\n shield = await raiseShield({ decree: decision, state, data: { m5, m15, h1 } });\n } catch (e: any) {\n console.error(`❌ Shield failed: ${e.message}`);\n return;\n }\n\n if (!shield.clear) {\n console.log(`🛡️ Shield BLOCKED: ${shield.reason}`);\n if (state.mode === \"STRIKING\") setRoyalState({ mode: \"HUNTING\" });\n // Send shield block notification\n await autoSignal(`🛡️ *SHIELD BLOCKED*\\n\\n${shield.reason}\\n\\nOracle: ${prophecy.direction} @ ${prophecy.confidence.toFixed(1)}%\\nRegime: ${council.regime}`);\n return;\n }\n\n // 6. Execute\n if (decision.action === \"STRIKE\") {\n setRoyalState({ mode: \"STRIKING\" });\n let execution;\n try {\n execution = await executeDecree({\n direction: decision.direction!,\n state,\n data: m15,\n });\n } catch (e: any) {\n console.error(`❌ Execution failed: ${e.message}`);\n setRoyalState({ mode: \"HUNTING\" });\n await autoSignal(`❌ *Execution Failed*\\n\\n${e.message}\\n\\nDecree: ${decision.direction} @ ${prophecy.confidence.toFixed(1)}%`);\n return;\n }\n\n if (execution.filled) {\n setRoyalState({ mode: \"HOLDING\", totalTrades: state.totalTrades + 1 });\n try {\n await recordChronicle({\n direction: execution.direction,\n entry: execution.entry,\n stop: execution.stop,\n targets: execution.targets,\n size: execution.size,\n reason: decision.reason,\n });\n } catch (e: any) {\n console.error(`❌ Chronicle failed: ${e.message}`);\n }\n \n const signalText =\n `⚔️ *ROYAL DECREE EXECUTED*\\n\\n` +\n `👑 *${decision.reason}*\\n\\n` +\n `📊 *Details:*\\n` +\n `Direction: *${execution.direction}*\\n` +\n `Entry: *${execution.entry}*\\n` +\n `Stop Loss: *${execution.stop}*\\n` +\n `Take Profit: *${execution.targets.join(\" | \")}*\\n` +\n `Size: *${execution.size} lots*\\n\\n` +\n `🔮 Oracle: ${prophecy.direction} @ ${prophecy.confidence.toFixed(1)}%\\n` +\n `🏛️ Regime: ${council.regime}\\n` +\n `📈 Edge: ${(prophecy.edge * 100).toFixed(2)}%\\n\\n` +\n `⏰ ${new Date().toUTCString()}`;\n \n await autoSignal(signalText);\n console.log(`⚔️ DECREE: ${execution.direction} ${execution.size} lots @ ${execution.entry} | SL: ${execution.stop} | TP: ${execution.targets.join(\", \")}`);\n }\n } else if (decision.action === \"RETREAT\" && state.mode === \"HOLDING\") {\n setRoyalState({ mode: \"RETREATING\" });\n try {\n await recordChronicle({ action: \"CLOSE\", reason: decision.reason });\n } catch (e: any) {\n console.error(`❌ Chronicle close failed: ${e.message}`);\n }\n setRoyalState({ mode: \"HUNTING\", consecutiveLosses: 0 });\n \n await autoSignal(\n `🏳️ *ROYAL RETREAT*\\n\\n` +\n `Position closed by King's decree.\\n` +\n `Reason: ${decision.reason}\\n\\n` +\n `⏰ ${new Date().toUTCString()}`\n );\n } else {\n console.log(`🕯️ The King waits. ${decision.reason}`);\n // Send periodic status update (not every cycle — only when confidence is notable)\n if (prophecy.confidence > 60) {\n await autoSignal(\n `🕯️ *King's Counsel*\\n\\n` +\n `The King waits — no decree issued.\\n\\n` +\n `🔮 Oracle: ${prophecy.direction} @ ${prophecy.confidence.toFixed(1)}%\\n` +\n `🏛️ Regime: ${council.regime}\\n` +\n `📋 Reason: ${decision.reason}\\n\\n` +\n `⏰ ${new Date().toUTCString()}`\n );\n }\n }\n } catch (fatal: any) {\n console.error(`☠️ FATAL in royalAudience: ${fatal.message}`);\n console.error(fatal.stack);\n }\n}\n\nasync function issueRoyalDecree(\n prophecy: { direction: \"BUY\" | \"SELL\" | \"NEUTRAL\"; confidence: number; edge: number },\n council: { regime: string; votes: Record }\n): Promise {\n const decree = getDecree();\n\n if (prophecy.confidence < decree.MIN_CONFIDENCE) {\n return { action: \"WAIT\", reason: `Confidence ${prophecy.confidence.toFixed(1)}% below ${decree.MIN_CONFIDENCE}%` };\n }\n if (prophecy.edge < decree.MIN_EDGE) {\n return { action: \"WAIT\", reason: `Edge ${(prophecy.edge * 100).toFixed(1)}% insufficient` };\n }\n if (council.votes.wyckoff?.phase === \"DISTRIBUTION\" && prophecy.direction === \"BUY\") {\n return { action: \"WAIT\", reason: \"Wyckoff DISTRIBUTION — blocks BUY\" };\n }\n if (council.votes.wyckoff?.phase === \"ACCUMULATION\" && prophecy.direction === \"SELL\") {\n return { action: \"WAIT\", reason: \"Wyckoff ACCUMULATION — blocks SELL\" };\n }\n\n const kz = council.votes.temporal;\n if (!kz?.inKillZone && prophecy.confidence < 88) {\n return { action: \"WAIT\", reason: \"Outside Killzone — requires 88%+\" };\n }\n if (kz?.zone === \"ASIA\" && prophecy.confidence < decree.ASIAN_SESSION_MAX_CONFIDENCE) {\n return { action: \"WAIT\", reason: `Asian session — max ${decree.ASIAN_SESSION_MAX_CONFIDENCE}%` };\n }\n\n if (prophecy.confidence >= 90 && council.votes.sentiment?.cotSignal === \"STRONG_\" + prophecy.direction) {\n return {\n action: \"STRIKE\",\n direction: prophecy.direction,\n reason: `👑 ROYAL MANDATE: ${prophecy.direction} @ ${prophecy.confidence.toFixed(1)}% | COT | ${council.regime}`,\n };\n }\n\n if (prophecy.direction !== \"NEUTRAL\") {\n return {\n action: \"STRIKE\",\n direction: prophecy.direction,\n reason: `Standard decree: ${prophecy.direction} @ ${prophecy.confidence.toFixed(1)}%`,\n };\n }\n\n return { action: \"WAIT\", reason: \"Oracle direction NEUTRAL\" };\n}\n",[],[162,241],"a7b8db9b-7e4b-443c-83e0-e0ed2e912407","oracle.ts","2b4e0f82-836f-11f1-9a29-1607ee4eb77e",7,["D",1784464891608],"// ─── The Oracle — AI Confidence Aggregation ───\nimport type { Candle, CouncilResult, Prophecy, RoyalState } from \"./types.ts\";\n\ninterface OracleInput {\n council: CouncilResult;\n data: { m5: Candle[]; m15: Candle[]; h1: Candle[]; h4: Candle[]; d1: Candle[] };\n state: RoyalState;\n}\n\nexport async function queryOracle(input: OracleInput): Promise {\n const { council, data } = input;\n const votes = Object.values(council.votes);\n \n // Weighted vote aggregation\n let buyScore = 0, sellScore = 0, totalWeight = 0;\n const signals: string[] = [];\n \n for (const v of votes) {\n const effectiveWeight = v.weight * (v.confidence / 100);\n totalWeight += effectiveWeight;\n if (v.vote === \"BUY\") {\n buyScore += effectiveWeight;\n signals.push(`+${v.indicator}: ${v.detail}`);\n } else if (v.vote === \"SELL\") {\n sellScore += effectiveWeight;\n signals.push(`-${v.indicator}: ${v.detail}`);\n }\n }\n\n const buyRatio = buyScore / totalWeight;\n const sellRatio = sellScore / totalWeight;\n const dominantRatio = Math.max(buyRatio, sellRatio);\n \n // Direction\n const direction: Prophecy[\"direction\"] = \n buyRatio > sellRatio * 1.2 ? \"BUY\" : \n sellRatio > buyRatio * 1.2 ? \"SELL\" : \"NEUTRAL\";\n\n // Confidence — calibrated with agreement and regime alignment\n const baseConfidence = dominantRatio * 100;\n const agreementBoost = council.agreement > 70 ? 8 : council.agreement > 60 ? 4 : 0;\n const regimeAlign = \n (direction === \"BUY\" && council.regime.includes(\"UPTREND\")) ||\n (direction === \"SELL\" && council.regime.includes(\"DOWNTREND\"));\n const regimeBoost = regimeAlign ? 6 : -4;\n const wyckoffAlign =\n (direction === \"BUY\" && council.votes.wyckoff?.vote === \"BUY\") ||\n (direction === \"SELL\" && council.votes.wyckoff?.vote === \"SELL\");\n const wyckoffBoost = wyckoffAlign ? 5 : 0;\n \n let confidence = Math.min(98, baseConfidence + agreementBoost + regimeBoost + wyckoffBoost);\n if (direction === \"NEUTRAL\") confidence = Math.min(confidence, 50);\n\n // Edge estimation — simplified Kelly fraction proxy\n const winProb = dominantRatio;\n const lossProb = 1 - winProb;\n const avgRR = 1.8; // assumed reward:risk\n const edge = winProb * avgRR - lossProb;\n const clampedEdge = Math.max(-0.05, Math.min(0.15, edge));\n\n // Reasoning chain\n const topSignals = signals.slice(0, 5);\n const reasoning = `Council consensus: ${council.consensus} (${council.agreement.toFixed(0)}% agreement) | Regime: ${council.regime} | ${direction} @ ${confidence.toFixed(1)}%`;\n\n return {\n direction,\n confidence: Math.round(confidence * 10) / 10,\n edge: Math.round(clampedEdge * 10000) / 10000,\n reasoning,\n signals: topSignals,\n };\n}\n",[],[162,249],"a95b5bf4-e37e-4e37-934a-9ed9993b6d08","monte-carlo.ts","493bd89e-836f-11f1-ad71-1607ee4eb77e",12,["D",1784464941826],"// ─── Monte Carlo Simulation ───\nimport type { BacktestTrade, MonteCarloReport } from \"./types.ts\";\n\nexport async function runMonteCarlo(trades: BacktestTrade[], runs = 1000): Promise {\n const pnls = trades.map(t => t.pnl);\n if (pnls.length < 5) {\n return { runs, medianMaxDD: 0, worstDrawdown5pct: 0, probOfProfit: 0, probOfRuin: 0, equityPaths: [] };\n }\n\n const startingEquity = 10000;\n const ruinThreshold = startingEquity * 0.5; // 50% drawdown = ruin\n const maxDDs: number[] = [];\n let profitableRuns = 0;\n let ruinRuns = 0;\n const samplePaths: number[][] = [];\n\n for (let run = 0; run < runs; run++) {\n // Shuffle trade sequence\n const shuffled = [...pnls].sort(() => Math.random() - 0.5);\n let equity = startingEquity;\n let peak = equity;\n let maxDD = 0;\n const path = [equity];\n\n for (const pnl of shuffled) {\n equity += pnl;\n peak = Math.max(peak, equity);\n const dd = ((peak - equity) / peak) * 100;\n maxDD = Math.max(maxDD, dd);\n path.push(Math.round(equity * 100) / 100);\n\n if (equity <= ruinThreshold) {\n ruinRuns++;\n break;\n }\n }\n\n maxDDs.push(maxDD);\n if (equity > startingEquity) profitableRuns++;\n if (run < 50) samplePaths.push(path); // Keep 50 sample paths for visualization\n }\n\n maxDDs.sort((a, b) => a - b);\n const medianMaxDD = maxDDs[Math.floor(maxDDs.length / 2)];\n const worst5pctIdx = Math.floor(maxDDs.length * 0.95);\n const worstDrawdown5pct = maxDDs[worst5pctIdx] || maxDDs[maxDDs.length - 1];\n\n return {\n runs,\n medianMaxDD: Math.round(medianMaxDD * 100) / 100,\n worstDrawdown5pct: Math.round(worstDrawdown5pct * 100) / 100,\n probOfProfit: Math.round((profitableRuns / runs) * 10000) / 10000,\n probOfRuin: Math.round((ruinRuns / runs) * 10000) / 10000,\n equityPaths: samplePaths,\n };\n}\n",[],[162,257],"31b09151-319e-4461-930d-51461b927022","market.ts","10b2ebb6-836f-11f1-9431-1607ee4eb77e",4,["D",1784464846945],"// ─── Market Data Fetcher ───\nimport type { Candle, Timeframe } from \"./types.ts\";\n\n// Generate realistic gold candle data using geometric brownian motion\n// In production, replace with real API calls (TwelveData, AlphaVantage, etc.)\nfunction generateCandles(symbol: string, timeframe: Timeframe, count: number): Candle[] {\n const tfMinutes: Record = {\n \"5min\": 5, \"15min\": 15, \"1h\": 60, \"4h\": 240, \"1day\": 1440,\n };\n const intervalMs = tfMinutes[timeframe] * 60 * 1000;\n const now = Date.now();\n const basePrice = symbol.includes(\"XAU\") || symbol.includes(\"GOLD\") ? 2385 : 29.5;\n \n // Seed-based pseudo-random for reproducibility within a session\n let seed = Math.floor(now / intervalMs) * count;\n const rand = () => {\n seed = (seed * 1103515245 + 12345) & 0x7fffffff;\n return seed / 0x7fffffff;\n };\n \n const candles: Candle[] = [];\n let price = basePrice - (count * 0.3);\n const volatility = symbol.includes(\"XAU\") ? 0.012 : 0.018;\n const drift = 0.0002;\n \n for (let i = 0; i < count; i++) {\n const timestamp = now - (count - i) * intervalMs;\n const z = (rand() + rand() + rand() + rand() + rand() + rand() - 3) / 0.866; // approx normal\n const change = price * (drift + volatility * z);\n const open = price;\n const close = Math.max(0.01, price + change);\n const range = Math.abs(change) + price * volatility * 0.5 * rand();\n const high = Math.max(open, close) + range * 0.3 * rand();\n const low = Math.min(open, close) - range * 0.3 * rand();\n const volume = Math.floor(50000 + 200000 * rand()) + Math.floor(100000 * Math.abs(z));\n \n candles.push({ timestamp, open, high, low, close, volume });\n price = close;\n }\n return candles;\n}\n\nexport async function fetchGoldData(timeframe: Timeframe, count: number): Promise {\n // Simulate network latency\n await new Promise(r => setTimeout(r, 50 + Math.random() * 100));\n return generateCandles(\"XAU/USD\", timeframe, count);\n}\n\nexport async function fetchData(symbol: string, timeframe: Timeframe, count: number): Promise {\n await new Promise(r => setTimeout(r, 50 + Math.random() * 100));\n return generateCandles(symbol, timeframe, count);\n}\n\nexport function getLatestPrice(candles: Candle[]): number {\n return candles[candles.length - 1]?.close ?? 0;\n}\n\nexport function getPriceChange(candles: Candle[]): { abs: number; pct: number } {\n if (candles.length < 2) return { abs: 0, pct: 0 };\n const first = candles[0].close;\n const last = candles[candles.length - 1].close;\n return { abs: last - first, pct: ((last - first) / first) * 100 };\n}\n",[],[162,265],"ebd91a7d-3cf3-4ea9-bc05-7915eb85cc51","indicators.ts","10ad2514-836f-11f1-9a29-1607ee4eb77e",3,["D",1784464846944],"// ─── Technical Indicators Engine ───\nimport type { Candle } from \"./types.ts\";\n\nexport function sma(data: number[], period: number): number[] {\n const result: number[] = [];\n for (let i = 0; i < data.length; i++) {\n if (i < period - 1) { result.push(NaN); continue; }\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) sum += data[j];\n result.push(sum / period);\n }\n return result;\n}\n\nexport function ema(data: number[], period: number): number[] {\n const result: number[] = [];\n const k = 2 / (period + 1);\n let prev = data[0];\n result.push(prev);\n for (let i = 1; i < data.length; i++) {\n prev = data[i] * k + prev * (1 - k);\n result.push(prev);\n }\n return result;\n}\n\nexport function rsi(candles: Candle[], period = 14): number[] {\n const result: number[] = [50];\n let avgGain = 0, avgLoss = 0;\n for (let i = 1; i <= period && i < candles.length; i++) {\n const change = candles[i].close - candles[i - 1].close;\n if (change > 0) avgGain += change; else avgLoss -= change;\n }\n avgGain /= period; avgLoss /= period;\n result.push(100 - 100 / (1 + (avgLoss === 0 ? 100 : avgGain / avgLoss)));\n for (let i = period + 1; i < candles.length; i++) {\n const change = candles[i].close - candles[i - 1].close;\n const gain = change > 0 ? change : 0;\n const loss = change < 0 ? -change : 0;\n avgGain = (avgGain * (period - 1) + gain) / period;\n avgLoss = (avgLoss * (period - 1) + loss) / period;\n const rs = avgLoss === 0 ? 100 : avgGain / avgLoss;\n result.push(100 - 100 / (1 + rs));\n }\n return result;\n}\n\nexport function atr(candles: Candle[], period = 14): number[] {\n const trs: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (i === 0) { trs.push(candles[i].high - candles[i].low); continue; }\n const tr = Math.max(\n candles[i].high - candles[i].low,\n Math.abs(candles[i].high - candles[i - 1].close),\n Math.abs(candles[i].low - candles[i - 1].close)\n );\n trs.push(tr);\n }\n return ema(trs, period);\n}\n\nexport function macd(data: number[], fast = 12, slow = 26, signal = 9) {\n const emaFast = ema(data, fast);\n const emaSlow = ema(data, slow);\n const macdLine = emaFast.map((v, i) => v - emaSlow[i]);\n const signalLine = ema(macdLine, signal);\n const histogram = macdLine.map((v, i) => v - signalLine[i]);\n return { macdLine, signalLine, histogram };\n}\n\nexport function bollingerBands(data: number[], period = 20, mult = 2) {\n const smaData = sma(data, period);\n const upper: number[] = [], lower: number[] = [];\n for (let i = 0; i < data.length; i++) {\n if (i < period - 1) { upper.push(NaN); lower.push(NaN); continue; }\n let variance = 0;\n for (let j = i - period + 1; j <= i; j++) variance += (data[j] - smaData[i]) ** 2;\n const std = Math.sqrt(variance / period);\n upper.push(smaData[i] + mult * std);\n lower.push(smaData[i] - mult * std);\n }\n return { upper, middle: smaData, lower };\n}\n\nexport function vwap(candles: Candle[]): number {\n let pv = 0, vol = 0;\n for (const c of candles) {\n const tp = (c.high + c.low + c.close) / 3;\n pv += tp * c.volume;\n vol += c.volume;\n }\n return vol > 0 ? pv / vol : candles[candles.length - 1].close;\n}\n\nexport function adx(candles: Candle[], period = 14): number[] {\n const result: number[] = [];\n const plusDM: number[] = [0], minusDM: number[] = [0], trs: number[] = [0];\n for (let i = 1; i < candles.length; i++) {\n const up = candles[i].high - candles[i - 1].high;\n const down = candles[i - 1].low - candles[i].low;\n plusDM.push(up > down && up > 0 ? up : 0);\n minusDM.push(down > up && down > 0 ? down : 0);\n trs.push(Math.max(\n candles[i].high - candles[i].low,\n Math.abs(candles[i].high - candles[i - 1].close),\n Math.abs(candles[i].low - candles[i - 1].close)\n ));\n }\n const smoothTR = ema(trs, period);\n const smoothPlus = ema(plusDM, period);\n const smoothMinus = ema(minusDM, period);\n const dx: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (smoothTR[i] === 0) { dx.push(0); continue; }\n const plusDI = 100 * smoothPlus[i] / smoothTR[i];\n const minusDI = 100 * smoothMinus[i] / smoothTR[i];\n const sum = plusDI + minusDI;\n dx.push(sum === 0 ? 0 : 100 * Math.abs(plusDI - minusDI) / sum);\n }\n return ema(dx, period);\n}\n\nexport function stochastic(candles: Candle[], kPeriod = 14, dPeriod = 3) {\n const kValues: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (i < kPeriod - 1) { kValues.push(50); continue; }\n let highest = -Infinity, lowest = Infinity;\n for (let j = i - kPeriod + 1; j <= i; j++) {\n highest = Math.max(highest, candles[j].high);\n lowest = Math.min(lowest, candles[j].low);\n }\n const range = highest - lowest || 1;\n kValues.push(100 * (candles[i].close - lowest) / range);\n }\n const dValues = sma(kValues, dPeriod);\n return { k: kValues, d: dValues };\n}\n\nexport function detectStructure(candles: Candle[], lookback = 20) {\n const recent = candles.slice(-lookback);\n const highs = recent.map(c => c.high);\n const lows = recent.map(c => c.low);\n const highestHigh = Math.max(...highs);\n const lowestLow = Math.min(...lows);\n const lastClose = recent[recent.length - 1].close;\n const midpoint = (highestHigh + lowestLow) / 2;\n \n if (lastClose > midpoint) {\n const higherHighs = recent.slice(-5).every((c, i, arr) => i === 0 || c.high >= arr[i - 1].high);\n if (higherHighs) return { structure: \"UPTREND\", higherHighs: true, higherLows: true };\n return { structure: \"BULLISH_RANGE\", higherHighs: false, higherLows: true };\n } else {\n const lowerLows = recent.slice(-5).every((c, i, arr) => i === 0 || c.low <= arr[i - 1].low);\n if (lowerLows) return { structure: \"DOWNTREND\", higherHighs: false, higherLows: false };\n return { structure: \"BEARISH_RANGE\", higherHighs: true, higherLows: false };\n }\n}\n\nexport function obv(candles: Candle[]): number[] {\n const result: number[] = [0];\n for (let i = 1; i < candles.length; i++) {\n const prev = result[i - 1];\n if (candles[i].close > candles[i - 1].close) result.push(prev + candles[i].volume);\n else if (candles[i].close < candles[i - 1].close) result.push(prev - candles[i].volume);\n else result.push(prev);\n }\n return result;\n}\n",[],[162,273],"aca7e6ff-01e0-4bc6-9d86-12f704093c24","execution.ts","496a2b72-836f-11f1-bb66-1607ee4eb77e",15,["D",1784464941824],"// ─── Precision Execution Engine ───\nimport type { Candle, Decree, ExecutionResult, RoyalState } from \"./types.ts\";\nimport { getDecree } from \"./decree.ts\";\nimport { atr } from \"./indicators.ts\";\n\ninterface ExecutionInput {\n direction: \"BUY\" | \"SELL\";\n entry?: number;\n stop?: number;\n targets?: number[];\n size?: number;\n state: RoyalState;\n data: Candle[];\n}\n\nexport async function executeDecree(input: ExecutionInput): Promise {\n const config = getDecree();\n const { direction, state, data } = input;\n const candles = data;\n const lastClose = candles[candles.length - 1].close;\n \n const atrValues = atr(candles, 14);\n const lastATR = atrValues[atrValues.length - 1];\n\n // Calculate entry, stop, and targets\n const entry = input.entry || lastClose;\n const stopDistance = lastATR * config.STOP_LOSS_ATR_MULT;\n const stop = input.stop || (direction === \"BUY\" ? entry - stopDistance : entry + stopDistance);\n \n const tp1Distance = lastATR * config.TP1_ATR_MULT;\n const tp2Distance = lastATR * config.TP2_ATR_MULT;\n const tp3Distance = lastATR * config.TP3_ATR_MULT;\n \n const targets = input.targets || (direction === \"BUY\"\n ? [entry + tp1Distance, entry + tp2Distance, entry + tp3Distance]\n : [entry - tp1Distance, entry - tp2Distance, entry - tp3Distance]);\n\n // Position sizing — risk-based\n const riskAmount = stopDistance;\n const accountRiskPct = config.RISK_PER_TRADE_PCT / 100;\n const assumedAccountSize = 10000; // $10k default\n const riskDollars = assumedAccountSize * accountRiskPct;\n const rawSize = riskDollars / riskAmount;\n const size = Math.min(rawSize, config.MAX_LOTS_PER_TRADE);\n\n return {\n filled: true,\n direction,\n entry: Math.round(entry * 100) / 100,\n stop: Math.round(stop * 100) / 100,\n targets: targets.map(t => Math.round(t * 100) / 100),\n size: Math.round(size * 100) / 100,\n timestamp: Date.now(),\n };\n}\n",[],[162,281],"b434b24b-d0e4-4113-8d77-4c8abceef099","decree.ts","04907d44-836a-11f1-a254-1607ee4eb77e",["D",1784462679139],"// ─── Royal Decree — Trading Parameters & Risk Rules ───\n\nexport function getDecree() {\n return {\n // ── Core Confidence Gates ──\n MIN_CONFIDENCE: 72,\n MIN_EDGE: 0.005, // 0.5% minimum edge\n ROYAL_MANDATE_CONFIDENCE: 90,\n\n // ── Session Controls ──\n ASIAN_SESSION_MAX_CONFIDENCE: 80,\n KILLZONE_START_UTC: 7,\n KILLZONE_END_UTC: 22,\n\n // ── Risk Management ──\n RISK_PER_TRADE_PCT: 1.0,\n MAX_LOTS_PER_TRADE: 2.0,\n MAX_PORTFOLIO_HEAT: 3.0, // max total risk across open positions\n MAX_CONSECUTIVE_LOSSES: 4,\n DAILY_LOSS_LIMIT_PCT: 3.0,\n\n // ── Trade Management ──\n BREAKEVEN_AFTER_TP1: true,\n TRAIL_STOP_AFTER_TP2: true,\n PARTIAL_CLOSE_TP1_PCT: 50,\n PARTIAL_CLOSE_TP2_PCT: 25,\n\n // ── Stop Loss / Take Profit ──\n STOP_LOSS_ATR_MULT: 1.5,\n TP1_ATR_MULT: 1.0,\n TP2_ATR_MULT: 2.0,\n TP3_ATR_MULT: 3.0,\n\n // ── Circuit Breakers ──\n ENABLE_CIRCUIT_BREAKER: true,\n MAX_DRAWDOWN_PCT: 15,\n HALT_AFTER_CONSECUTIVE_LOSSES: 5,\n\n // ── Strategy Bans ──\n BAN_DURATION_TRADES: 10,\n BAN_AFTER_FAILURES: 3,\n };\n}\n\nexport type DecreeConfig = ReturnType;\n",[],[162,289],"b84fa0b6-a543-4107-895c-2aeb8d70a4d2","db.ts","10c6b3e4-836f-11f1-9fcf-1607ee4eb77e",20,["D",1784466184092],"// ─── SQLite Database Layer ───\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function initDb(): Promise {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS users (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n bot_token TEXT NOT NULL UNIQUE,\n chat_id TEXT NOT NULL,\n created_at INTEGER NOT NULL DEFAULT (strftime('%s','now') * 1000)\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS reports (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n job_id TEXT NOT NULL UNIQUE,\n user_id INTEGER NOT NULL,\n report_type TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'queued',\n report_json TEXT,\n error TEXT,\n created_at INTEGER NOT NULL DEFAULT (strftime('%s','now') * 1000),\n completed_at INTEGER\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS chronicle (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER,\n action TEXT NOT NULL,\n direction TEXT,\n entry REAL,\n stop REAL,\n targets TEXT,\n size REAL,\n reason TEXT,\n pnl REAL,\n timestamp INTEGER NOT NULL DEFAULT (strftime('%s','now') * 1000)\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n updated_at INTEGER NOT NULL DEFAULT (strftime('%s','now') * 1000)\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_reports_user ON reports(user_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_reports_status ON reports(status)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_users_token ON users(bot_token)`);\n console.log(\"✅ Database initialized\");\n}\n\n// ─── Settings persistence ───\nexport async function saveSetting(key: string, value: string): Promise {\n await sqlite.execute({\n sql: `INSERT INTO settings (key, value, updated_at) VALUES (?, ?, ?)\n ON CONFLICT(key) DO UPDATE SET value = ?, updated_at = ?`,\n args: [key, value, Date.now(), value, Date.now()],\n });\n}\n\nexport async function getSetting(key: string): Promise {\n const result = await sqlite.execute({ sql: \"SELECT value FROM settings WHERE key = ?\", args: [key] });\n return (result.rows[0] as any)?.value || null;\n}\n\nexport async function getAllSettings(): Promise> {\n const result = await sqlite.execute({ sql: \"SELECT key, value FROM settings\" });\n const map: Record = {};\n for (const row of result.rows as any[]) map[row.key] = row.value;\n return map;\n}\n\nexport async function upsertUser(botToken: string, chatId: string) {\n const existing = await sqlite.execute({ sql: \"SELECT * FROM users WHERE bot_token = ?\", args: [botToken] });\n if (existing.rows.length > 0) {\n await sqlite.execute({ sql: \"UPDATE users SET chat_id = ? WHERE bot_token = ?\", args: [chatId, botToken] });\n return { ...existing.rows[0], chat_id: chatId };\n }\n await sqlite.execute({ sql: \"INSERT INTO users (bot_token, chat_id) VALUES (?, ?)\", args: [botToken, chatId] });\n const row = await sqlite.execute({ sql: \"SELECT * FROM users WHERE bot_token = ?\", args: [botToken] });\n return row.rows[0];\n}\n\nexport async function getUserByToken(botToken: string) {\n const result = await sqlite.execute({ sql: \"SELECT * FROM users WHERE bot_token = ?\", args: [botToken] });\n return result.rows[0] || null;\n}\n\nexport async function getAllUsers() {\n const result = await sqlite.execute({ sql: \"SELECT * FROM users ORDER BY created_at DESC\" });\n return result.rows;\n}\n\nexport async function createReport(jobId: string, userId: number, reportType: string) {\n await sqlite.execute({\n sql: \"INSERT INTO reports (job_id, user_id, report_type, status) VALUES (?, ?, ?, 'queued')\",\n args: [jobId, userId, reportType],\n });\n}\n\nexport async function updateReportStatus(jobId: string, status: string, reportJson?: string, error?: string) {\n if (status === \"done\") {\n await sqlite.execute({\n sql: \"UPDATE reports SET status = ?, report_json = ?, completed_at = ? WHERE job_id = ?\",\n args: [status, reportJson || null, Date.now(), jobId],\n });\n } else if (status === \"error\") {\n await sqlite.execute({\n sql: \"UPDATE reports SET status = ?, error = ? WHERE job_id = ?\",\n args: [status, error || null, jobId],\n });\n } else {\n await sqlite.execute({ sql: \"UPDATE reports SET status = ? WHERE job_id = ?\", args: [status, jobId] });\n }\n}\n\nexport async function getReport(jobId: string, userId: number) {\n const result = await sqlite.execute({ sql: \"SELECT * FROM reports WHERE job_id = ? AND user_id = ?\", args: [jobId, userId] });\n return result.rows[0] || null;\n}\n\nexport async function getReportByJobId(jobId: string) {\n const result = await sqlite.execute({ sql: \"SELECT * FROM reports WHERE job_id = ?\", args: [jobId] });\n return result.rows[0] || null;\n}\n\nexport async function getRecentReports(limit = 20) {\n const result = await sqlite.execute({ sql: \"SELECT * FROM reports ORDER BY created_at DESC LIMIT ?\", args: [limit] });\n return result.rows;\n}\n\nexport async function getReportsByUser(userId: number, limit = 20) {\n const result = await sqlite.execute({ sql: \"SELECT * FROM reports WHERE user_id = ? ORDER BY created_at DESC LIMIT ?\", args: [userId, limit] });\n return result.rows;\n}\n\nexport async function getDashboardStats() {\n const totalReports = await sqlite.execute({ sql: \"SELECT COUNT(*) as count FROM reports\" });\n const doneReports = await sqlite.execute({ sql: \"SELECT COUNT(*) as count FROM reports WHERE status = 'done'\" });\n const queuedReports = await sqlite.execute({ sql: \"SELECT COUNT(*) as count FROM reports WHERE status IN ('queued','running')\" });\n const errorReports = await sqlite.execute({ sql: \"SELECT COUNT(*) as count FROM reports WHERE status = 'error'\" });\n const totalUsers = await sqlite.execute({ sql: \"SELECT COUNT(*) as count FROM users\" });\n const totalTrades = await sqlite.execute({ sql: \"SELECT COUNT(*) as count FROM chronicle WHERE action = 'STRIKE'\" });\n const recentChronicle = await sqlite.execute({ sql: \"SELECT * FROM chronicle ORDER BY timestamp DESC LIMIT 50\" });\n \n return {\n totalReports: totalReports.rows[0]?.count || 0,\n completedReports: doneReports.rows[0]?.count || 0,\n queuedReports: queuedReports.rows[0]?.count || 0,\n errorReports: errorReports.rows[0]?.count || 0,\n totalUsers: totalUsers.rows[0]?.count || 0,\n totalTrades: totalTrades.rows[0]?.count || 0,\n recentTrades: recentChronicle.rows,\n };\n}\n\nexport async function recordChronicleEntry(entry: {\n userId?: number; action: string; direction?: string; entry?: number;\n stop?: number; targets?: string; size?: number; reason?: string; pnl?: number;\n}) {\n await sqlite.execute({\n sql: `INSERT INTO chronicle (user_id, action, direction, entry, stop, targets, size, reason, pnl)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [entry.userId || null, entry.action, entry.direction || null, entry.entry || null,\n entry.stop || null, entry.targets || null, entry.size || null, entry.reason || null, entry.pnl || null],\n });\n}\n",[],[162,296],"aac962b2-bf63-4fa6-8b9f-97db0748b3d6","council.ts","2b5bc104-836f-11f1-9a99-1607ee4eb77e",9,["D",1784464891629],"// ─── The Council — Multi-Indicator Voting System ───\nimport type { Candle, CouncilResult, CouncilVote, RoyalState } from \"./types.ts\";\nimport { rsi, atr, macd, bollingerBands, adx, stochastic, detectStructure, obv, vwap, ema, sma } from \"./indicators.ts\";\n\ninterface CouncilInput {\n m5: Candle[]; m15: Candle[]; h1: Candle[]; h4: Candle[]; d1: Candle[];\n state: RoyalState;\n}\n\nexport async function conveneCouncil(input: CouncilInput): Promise {\n const { m5, m15, h1, h4, d1 } = input;\n const votes: Record = {};\n const closes = (c: Candle[]) => c.map(x => x.close);\n\n // ── 1. Wyckoff Phase Analysis (H4 + D1) ──\n const h4Structure = detectStructure(h4, 30);\n const d1Structure = detectStructure(d1, 20);\n const d1RSI = rsi(d1);\n const lastD1RSI = d1RSI[d1RSI.length - 1];\n let wyckoffPhase = \"MARKUP\";\n if (d1Structure.structure === \"RANGE\" || d1Structure.structure.includes(\"RANGE\")) {\n wyckoffPhase = lastD1RSI < 40 ? \"ACCUMULATION\" : \"DISTRIBUTION\";\n } else if (d1Structure.structure === \"UPTREND\") {\n wyckoffPhase = \"MARKUP\";\n } else {\n wyckoffPhase = \"MARKDOWN\";\n }\n votes.wyckoff = {\n indicator: \"Wyckoff\",\n vote: wyckoffPhase === \"ACCUMULATION\" ? \"BUY\" : wyckoffPhase === \"DISTRIBUTION\" ? \"SELL\" : \"NEUTRAL\",\n weight: 1.5,\n confidence: 65,\n detail: `Phase: ${wyckoffPhase} | D1 structure: ${d1Structure.structure}`,\n };\n\n // ── 2. RSI Divergence (M15 + H1) ──\n const m15RSI = rsi(m15);\n const h1RSI = rsi(h1);\n const lastM15RSI = m15RSI[m15RSI.length - 1];\n const lastH1RSI = h1RSI[h1RSI.length - 1];\n let rsiVote: \"BUY\" | \"SELL\" | \"NEUTRAL\" = \"NEUTRAL\";\n let rsiDetail = `M15: ${lastM15RSI.toFixed(1)} | H1: ${lastH1RSI.toFixed(1)}`;\n if (lastM15RSI < 30 && lastH1RSI < 40) { rsiVote = \"BUY\"; rsiDetail += \" | Oversold\"; }\n else if (lastM15RSI > 70 && lastH1RSI > 60) { rsiVote = \"SELL\"; rsiDetail += \" | Overbought\"; }\n else if (lastM15RSI > 50 && lastH1RSI > 50) { rsiVote = \"BUY\"; rsiDetail += \" | Bullish momentum\"; }\n else if (lastM15RSI < 50 && lastH1RSI < 50) { rsiVote = \"SELL\"; rsiDetail += \" | Bearish momentum\"; }\n votes.rsi = { indicator: \"RSI\", vote: rsiVote, weight: 1.0, confidence: 60, detail: rsiDetail };\n\n // ── 3. MACD Momentum (H1) ──\n const h1Macd = macd(closes(h1));\n const lastHist = h1Macd.histogram[h1Macd.histogram.length - 1];\n const prevHist = h1Macd.histogram[h1Macd.histogram.length - 2];\n const macdVote = lastHist > 0 && lastHist > prevHist ? \"BUY\" : lastHist < 0 && lastHist < prevHist ? \"SELL\" : \"NEUTRAL\";\n votes.macd = {\n indicator: \"MACD\",\n vote: macdVote,\n weight: 1.2,\n confidence: 62,\n detail: `Histogram: ${lastHist.toFixed(4)} | ${lastHist > prevHist ? \"Accelerating\" : \"Decelerating\"}`,\n };\n\n // ── 4. Bollinger Band Squeeze (M15) ──\n const bb = bollingerBands(closes(m15), 20, 2);\n const lastBB = { upper: bb.upper[bb.upper.length - 1], lower: bb.lower[bb.lower.length - 1], middle: bb.middle[bb.middle.length - 1] };\n const bbWidth = (lastBB.upper - lastBB.lower) / lastBB.middle;\n const lastClose = m15[m15.length - 1].close;\n let bbVote: \"BUY\" | \"SELL\" | \"NEUTRAL\" = \"NEUTRAL\";\n if (lastClose <= lastBB.lower) bbVote = \"BUY\";\n else if (lastClose >= lastBB.upper) bbVote = \"SELL\";\n votes.bollinger = {\n indicator: \"Bollinger\",\n vote: bbVote,\n weight: 0.9,\n confidence: 55,\n detail: `Width: ${(bbWidth * 100).toFixed(2)}% | ${bbWidth < 0.02 ? \"SQUEEZE\" : \"Normal\"}`,\n };\n\n // ── 5. ADX Trend Strength (H4) ──\n const h4ADX = adx(h4);\n const lastADX = h4ADX[h4ADX.length - 1];\n const h4EMAs = { fast: ema(closes(h4), 9), slow: ema(closes(h4), 21) };\n const adxBullish = h4EMAs.fast[h4EMAs.fast.length - 1] > h4EMAs.slow[h4EMAs.slow.length - 1];\n let adxVote: \"BUY\" | \"SELL\" | \"NEUTRAL\" = \"NEUTRAL\";\n if (lastADX > 25) adxVote = adxBullish ? \"BUY\" : \"SELL\";\n votes.adx = {\n indicator: \"ADX\",\n vote: adxVote,\n weight: lastADX > 25 ? 1.3 : 0.5,\n confidence: lastADX > 30 ? 70 : 50,\n detail: `ADX: ${lastADX.toFixed(1)} | ${lastADX > 25 ? \"Trending\" : \"Ranging\"} | ${adxBullish ? \"Bullish\" : \"Bearish\"}`,\n };\n\n // ── 6. Stochastic (M5) ──\n const stoch = stochastic(m5);\n const lastK = stoch.k[stoch.k.length - 1];\n const lastD = stoch.d[stoch.d.length - 1];\n let stochVote: \"BUY\" | \"SELL\" | \"NEUTRAL\" = \"NEUTRAL\";\n if (lastK < 20 && lastK > lastD) stochVote = \"BUY\";\n else if (lastK > 80 && lastK < lastD) stochVote = \"SELL\";\n votes.stochastic = {\n indicator: \"Stochastic\",\n vote: stochVote,\n weight: 0.8,\n confidence: 52,\n detail: `K: ${lastK.toFixed(1)} | D: ${lastD.toFixed(1)} | ${lastK < 20 ? \"Oversold\" : lastK > 80 ? \"Overbought\" : \"Neutral\"}`,\n };\n\n // ── 7. VWAP Position (M15) ──\n const m15VWAP = vwap(m15.slice(-96));\n const m15LastClose = m15[m15.length - 1].close;\n votes.vwap = {\n indicator: \"VWAP\",\n vote: m15LastClose > m15VWAP ? \"BUY\" : \"SELL\",\n weight: 1.0,\n confidence: 58,\n detail: `Price: ${m15LastClose.toFixed(2)} | VWAP: ${m15VWAP.toFixed(2)} | ${m15LastClose > m15VWAP ? \"Above\" : \"Below\"}`,\n };\n\n // ── 8. OBV Trend (H1) ──\n const h1OBV = obv(h1);\n const obvSlope = h1OBV[h1OBV.length - 1] - h1OBV[h1OBV.length - 10];\n votes.obv = {\n indicator: \"OBV\",\n vote: obvSlope > 0 ? \"BUY\" : \"SELL\",\n weight: 0.7,\n confidence: 50,\n detail: `Slope: ${obvSlope > 0 ? \"Positive\" : \"Negative\"} | Volume ${obvSlope > 0 ? \"accumulation\" : \"distribution\"}`,\n };\n\n // ── 9. Temporal / Kill Zone ──\n const hour = new Date().getUTCHours();\n const inKillZone = hour >= 7 && hour <= 22;\n let zone = \"OFF\";\n if (hour >= 7 && hour < 9) zone = \"LONDON_OPEN\";\n else if (hour >= 9 && hour < 12) zone = \"LONDON_NY_OVERLAP\";\n else if (hour >= 12 && hour <= 16) zone = \"NY_SESSION\";\n else if (hour >= 16 && hour <= 22) zone = \"NY_CLOSE\";\n else if (hour >= 0 && hour < 7) zone = \"ASIA\";\n votes.temporal = {\n indicator: \"KillZone\",\n vote: inKillZone ? \"BUY\" : \"NEUTRAL\",\n weight: inKillZone ? 0.8 : 0.3,\n confidence: inKillZone ? 65 : 30,\n detail: `Zone: ${zone} | ${inKillZone ? \"Active\" : \"Inactive\"}`,\n };\n\n // ── 10. Sentiment / COT Proxy ──\n const d1EMAs = { fast: ema(closes(d1), 9), slow: ema(closes(d1), 21) };\n const d1Bullish = d1EMAs.fast[d1EMAs.fast.length - 1] > d1EMAs.slow[d1EMAs.slow.length - 1];\n const d1SMA = sma(closes(d1), 50);\n const aboveSMA50 = d1[d1.length - 1].close > d1SMA[d1SMA.length - 1];\n const cotSignal = d1Bullish && aboveSMA50 ? \"STRONG_BUY\" : !d1Bullish && !aboveSMA50 ? \"STRONG_SELL\" : \"NEUTRAL\";\n votes.sentiment = {\n indicator: \"Sentiment\",\n vote: cotSignal === \"STRONG_BUY\" ? \"BUY\" : cotSignal === \"STRONG_SELL\" ? \"SELL\" : \"NEUTRAL\",\n weight: 1.1,\n confidence: 63,\n detail: `COT: ${cotSignal} | D1 EMA9 ${d1Bullish ? \">\" : \"<\"} EMA21 | ${aboveSMA50 ? \"Above\" : \"Below\"} SMA50`,\n };\n\n // ── Consensus ──\n let buyWeight = 0, sellWeight = 0, totalWeight = 0;\n for (const v of Object.values(votes)) {\n totalWeight += v.weight;\n if (v.vote === \"BUY\") buyWeight += v.weight;\n else if (v.vote === \"SELL\") sellWeight += v.weight;\n }\n const consensus = buyWeight > sellWeight * 1.15 ? \"BUY\" : sellWeight > buyWeight * 1.15 ? \"SELL\" : \"NEUTRAL\";\n const agreement = Math.max(buyWeight, sellWeight) / totalWeight * 100;\n\n // ── Regime Detection ──\n const lastADXVal = h4ADX[h4ADX.length - 1];\n let regime = \"UNKNOWN\";\n if (lastADXVal > 25 && d1Structure.structure === \"UPTREND\") regime = \"STRONG_UPTREND\";\n else if (lastADXVal > 25 && d1Structure.structure === \"DOWNTREND\") regime = \"STRONG_DOWNTREND\";\n else if (lastADXVal > 20) regime = d1Bullish ? \"WEAK_UPTREND\" : \"WEAK_DOWNTREND\";\n else regime = \"RANGING\";\n\n return { regime, votes, consensus, agreement };\n}\n",[],[162,304],"282ddfb4-0f76-499c-b5da-125ca5e5afad","chronicle.ts","4938f282-836f-11f1-8b5e-1607ee4eb77e",11,["D",1784464941808],"// ─── Royal Chronicle — Trade Journal ───\nimport { recordChronicleEntry } from \"./db.ts\";\n\ninterface ChronicleEntry {\n direction?: string;\n entry?: number;\n stop?: number;\n targets?: number[];\n size?: number;\n reason?: string;\n pnl?: number;\n action?: string;\n}\n\nexport async function recordChronicle(entry: ChronicleEntry & { action?: string }): Promise {\n await recordChronicleEntry({\n action: entry.action || \"STRIKE\",\n direction: entry.direction,\n entry: entry.entry,\n stop: entry.stop,\n targets: entry.targets?.join(\",\"),\n size: entry.size,\n reason: entry.reason,\n pnl: entry.pnl,\n });\n}\n",[],[162,312],"f8b6e891-95a2-4721-80cc-2871eca6519e","benchmark.ts","4951526e-836f-11f1-bd2d-1607ee4eb77e",14,["D",1784464941810],"// ─── Benchmark Tournament ───\nimport type { BacktestReport, BenchmarkReport, Candle } from \"./types.ts\";\nimport { runBacktest } from \"./backtest.ts\";\nimport { rsi, ema } from \"./indicators.ts\";\n\nexport async function runBenchmark(candles: Candle[]): Promise {\n const closes = candles.map(c => c.close);\n\n // 1. Strategy backtest\n const strategyReport = await runBacktest(candles);\n\n // 2. Buy & Hold\n const buyHoldReturn = ((closes[closes.length - 1] - closes[0]) / closes[0]) * 100;\n let bhPeak = closes[0], bhMaxDD = 0;\n for (const price of closes) {\n bhPeak = Math.max(bhPeak, price);\n const dd = ((bhPeak - price) / bhPeak) * 100;\n bhMaxDD = Math.max(bhMaxDD, dd);\n }\n\n // 3. Random Entry\n let randomEquity = 10000;\n let randomPeak = randomEquity;\n let randomMaxDD = 0;\n let randomWins = 0, randomTrades = 0;\n for (let i = 50; i < candles.length - 1; i += 10) {\n const direction = Math.random() > 0.5 ? 1 : -1;\n const entry = closes[i];\n const exit = closes[Math.min(i + 5, closes.length - 1)];\n const pnl = direction * (exit - entry) * 100;\n randomEquity += pnl;\n randomPeak = Math.max(randomPeak, randomEquity);\n randomMaxDD = Math.max(randomMaxDD, ((randomPeak - randomEquity) / randomPeak) * 100);\n randomTrades++;\n if (pnl > 0) randomWins++;\n }\n const randomReturn = ((randomEquity - 10000) / 10000) * 100;\n\n // 4. Always-In Market\n let alwaysEquity = 10000;\n let alwaysPeak = alwaysEquity;\n let alwaysMaxDD = 0;\n let alwaysWins = 0, alwaysTrades = 0;\n const emaFast = ema(closes, 9);\n const emaSlow = ema(closes, 21);\n for (let i = 30; i < candles.length - 1; i++) {\n const direction = emaFast[i] > emaSlow[i] ? 1 : -1;\n const pnl = direction * (closes[i + 1] - closes[i]) * 100;\n alwaysEquity += pnl;\n alwaysPeak = Math.max(alwaysPeak, alwaysEquity);\n alwaysMaxDD = Math.max(alwaysMaxDD, ((alwaysPeak - alwaysEquity) / alwaysPeak) * 100);\n alwaysTrades++;\n if (pnl > 0) alwaysWins++;\n }\n const alwaysReturn = ((alwaysEquity - 10000) / 10000) * 100;\n\n // Determine winner\n const contenders = [\n { name: \"King's Strategy\", ret: strategyReport.totalReturn },\n { name: \"Buy & Hold\", ret: buyHoldReturn },\n { name: \"Random Entry\", ret: randomReturn },\n { name: \"Always-In\", ret: alwaysReturn },\n ];\n contenders.sort((a, b) => b.ret - a.ret);\n\n return {\n strategy: {\n totalReturn: Math.round(strategyReport.totalReturn * 100) / 100,\n maxDrawdown: Math.round(strategyReport.maxDrawdown * 100) / 100,\n winRate: Math.round(strategyReport.winRate * 100) / 100,\n },\n buyAndHold: {\n totalReturn: Math.round(buyHoldReturn * 100) / 100,\n maxDrawdown: Math.round(bhMaxDD * 100) / 100,\n winRate: buyHoldReturn > 0 ? 100 : 0,\n },\n randomEntry: {\n totalReturn: Math.round(randomReturn * 100) / 100,\n maxDrawdown: Math.round(randomMaxDD * 100) / 100,\n winRate: randomTrades > 0 ? Math.round((randomWins / randomTrades) * 10000) / 100 : 0,\n },\n alwaysInMarket: {\n totalReturn: Math.round(alwaysReturn * 100) / 100,\n maxDrawdown: Math.round(alwaysMaxDD * 100) / 100,\n winRate: alwaysTrades > 0 ? Math.round((alwaysWins / alwaysTrades) * 10000) / 100 : 0,\n },\n winner: contenders[0].name,\n };\n}\n\n// ─── Cost Stress Test ───\nexport async function runStressTest(candles: Candle[]): Promise<{ scenario: string; report: BacktestReport }[]> {\n const scenarios = [\n { name: \"Low cost (0.01 spread)\", spread: 0.01, commission: 0 },\n { name: \"Medium (0.03 + $3/lot)\", spread: 0.03, commission: 3 },\n { name: \"High (0.05 + $7/lot)\", spread: 0.05, commission: 7 },\n { name: \"Extreme (0.10 + $10/lot)\", spread: 0.10, commission: 10 },\n ];\n\n const results: { scenario: string; report: BacktestReport }[] = [];\n for (const scenario of scenarios) {\n const adjustedCandles = candles.map(c => ({\n ...c,\n open: c.open + scenario.spread,\n high: c.high + scenario.spread,\n low: c.low + scenario.spread,\n close: c.close + scenario.spread,\n }));\n const report = await runBacktest(adjustedCandles, { riskPerTradePct: 1.0 });\n // Apply commission impact\n const commissionImpact = report.totalTrades * scenario.commission * 0.01;\n report.totalReturn = Math.round((report.totalReturn - commissionImpact) * 100) / 100;\n results.push({ scenario: scenario.name, report });\n }\n return results;\n}\n",[],[162,320],"9568d37d-cb99-4ae7-8e50-c6f255bc7121","backtest.ts","4944b586-836f-11f1-babc-1607ee4eb77e",13,["D",1784464941809],"// ─── Backtesting Engine ───\nimport type { BacktestReport, BacktestTrade, Candle } from \"./types.ts\";\nimport { getDecree } from \"./decree.ts\";\nimport { atr, rsi, ema, macd, adx } from \"./indicators.ts\";\n\nexport async function runBacktest(candles: Candle[], config?: any): Promise {\n const decree = getDecree();\n const riskPct = config?.riskPerTradePct || decree.RISK_PER_TRADE_PCT;\n const trades: BacktestTrade[] = [];\n const equityCurve: number[] = [10000];\n let equity = 10000;\n let wins = 0, losses = 0;\n let peakEquity = equity;\n let maxDD = 0;\n let halted = false;\n\n const closes = candles.map(c => c.close);\n const atrVals = atr(candles, 14);\n const rsiVals = rsi(candles, 14);\n const emaFast = ema(closes, 9);\n const emaSlow = ema(closes, 21);\n const macdData = macd(closes);\n const adxVals = adx(candles, 14);\n\n let consecutiveLosses = 0;\n let inPosition = false;\n let currentTrade: Partial = {};\n let stopLoss = 0;\n let targets: number[] = [];\n let partialFilled = false;\n\n for (let i = 50; i < candles.length - 1; i++) {\n if (halted) break;\n\n // Circuit breaker\n if (decree.ENABLE_CIRCUIT_BREAKER && consecutiveLosses >= decree.HALT_AFTER_CONSECUTIVE_LOSSES) {\n halted = true;\n break;\n }\n\n const currentEquityDD = ((peakEquity - equity) / peakEquity) * 100;\n if (currentEquityDD > decree.MAX_DRAWDOWN_PCT) {\n halted = true;\n break;\n }\n\n // Manage open position\n if (inPosition) {\n const candle = candles[i];\n const isBuy = currentTrade.direction === \"BUY\";\n const stopHit = isBuy ? candle.low <= stopLoss : candle.high >= stopLoss;\n \n // Check targets\n let targetHit = false;\n let exitPrice = candle.close;\n let exitReason = \"EOD\";\n \n if (isBuy) {\n for (let t = 0; t < targets.length; t++) {\n if (candle.high >= targets[t]) {\n if (t === 0 && !partialFilled && decree.BREAKEVEN_AFTER_TP1) {\n stopLoss = currentTrade.entry!;\n partialFilled = true;\n }\n if (t === targets.length - 1) {\n targetHit = true;\n exitPrice = targets[t];\n exitReason = `TP${t + 1}`;\n break;\n }\n }\n }\n } else {\n for (let t = 0; t < targets.length; t++) {\n if (candle.low <= targets[t]) {\n if (t === 0 && !partialFilled && decree.BREAKEVEN_AFTER_TP1) {\n stopLoss = currentTrade.entry!;\n partialFilled = true;\n }\n if (t === targets.length - 1) {\n targetHit = true;\n exitPrice = targets[t];\n exitReason = `TP${t + 1}`;\n break;\n }\n }\n }\n }\n\n if (stopHit && !targetHit) {\n exitPrice = stopLoss;\n exitReason = \"Stop loss\";\n targetHit = true;\n }\n\n if (targetHit || i === candles.length - 2) {\n const pnl = (isBuy ? 1 : -1) * (exitPrice - currentTrade.entry!) * (currentTrade.size || 1) * 100;\n const risk = Math.abs(currentTrade.entry! - (currentTrade.stop || currentTrade.entry!));\n const rMultiple = risk > 0 ? (isBuy ? 1 : -1) * (exitPrice - currentTrade.entry!) / risk : 0;\n \n const trade: BacktestTrade = {\n entryTime: currentTrade.entryTime!,\n exitTime: candle.timestamp,\n direction: currentTrade.direction!,\n entry: currentTrade.entry!,\n exit: exitPrice,\n stop: currentTrade.stop!,\n size: currentTrade.size || 1,\n pnl,\n rMultiple,\n reason: exitReason,\n };\n trades.push(trade);\n \n equity += pnl;\n equityCurve.push(Math.round(equity * 100) / 100);\n peakEquity = Math.max(peakEquity, equity);\n const dd = ((peakEquity - equity) / peakEquity) * 100;\n maxDD = Math.max(maxDD, dd);\n\n if (pnl > 0) { wins++; consecutiveLosses = 0; }\n else { losses++; consecutiveLosses++; }\n\n inPosition = false;\n partialFilled = false;\n currentTrade = {};\n continue;\n }\n continue;\n }\n\n // Entry logic — EMA crossover + RSI + MACD confirmation\n const emaCross = emaFast[i] > emaSlow[i] && emaFast[i - 1] <= emaSlow[i - 1];\n const emaCrossDown = emaFast[i] < emaSlow[i] && emaFast[i - 1] >= emaSlow[i - 1];\n const rsiBullish = rsiVals[i] > 50 && rsiVals[i] < 70;\n const rsiBearish = rsiVals[i] < 50 && rsiVals[i] > 30;\n const macdBullish = macdData.histogram[i] > 0 && macdData.histogram[i] > macdData.histogram[i - 1];\n const macdBearish = macdData.histogram[i] < 0 && macdData.histogram[i] < macdData.histogram[i - 1];\n const adxStrong = adxVals[i] > 22;\n\n let direction: \"BUY\" | \"SELL\" | null = null;\n let reason = \"\";\n\n if (emaCross && rsiBullish && macdBullish && adxStrong) {\n direction = \"BUY\";\n reason = \"EMA9>21 cross + RSI bullish + MACD + ADX trending\";\n } else if (emaCrossDown && rsiBearish && macdBearish && adxStrong) {\n direction = \"SELL\";\n reason = \"EMA9<21 cross + RSI bearish + MACD + ADX trending\";\n }\n\n if (direction) {\n const entry = candles[i].close;\n const stopDist = atrVals[i] * decree.STOP_LOSS_ATR_MULT;\n stopLoss = direction === \"BUY\" ? entry - stopDist : entry + stopDist;\n const riskDollars = equity * (riskPct / 100);\n const size = Math.min(riskDollars / (stopDist * 100), decree.MAX_LOTS_PER_TRADE);\n targets = direction === \"BUY\"\n ? [entry + atrVals[i] * decree.TP1_ATR_MULT, entry + atrVals[i] * decree.TP2_ATR_MULT, entry + atrVals[i] * decree.TP3_ATR_MULT]\n : [entry - atrVals[i] * decree.TP1_ATR_MULT, entry - atrVals[i] * decree.TP2_ATR_MULT, entry - atrVals[i] * decree.TP3_ATR_MULT];\n\n currentTrade = {\n entryTime: candles[i].timestamp,\n direction,\n entry,\n stop: stopLoss,\n size,\n };\n inPosition = true;\n }\n }\n\n // Close any remaining position\n if (inPosition) {\n const lastCandle = candles[candles.length - 1];\n const exitPrice = lastCandle.close;\n const pnl = (currentTrade.direction === \"BUY\" ? 1 : -1) * (exitPrice - currentTrade.entry!) * (currentTrade.size || 1) * 100;\n const risk = Math.abs(currentTrade.entry! - (currentTrade.stop || currentTrade.entry!));\n const rMultiple = risk > 0 ? (currentTrade.direction === \"BUY\" ? 1 : -1) * (exitPrice - currentTrade.entry!) / risk : 0;\n trades.push({\n entryTime: currentTrade.entryTime!, exitTime: lastCandle.timestamp,\n direction: currentTrade.direction!, entry: currentTrade.entry!, exit: exitPrice,\n stop: currentTrade.stop!, size: currentTrade.size || 1, pnl, rMultiple, reason: \"EOD close\",\n });\n equity += pnl;\n equityCurve.push(Math.round(equity * 100) / 100);\n if (pnl > 0) wins++; else losses++;\n }\n\n const totalTrades = trades.length;\n const winRate = totalTrades > 0 ? (wins / totalTrades) * 100 : 0;\n const grossProfit = trades.filter(t => t.pnl > 0).reduce((s, t) => s + t.pnl, 0);\n const grossLoss = Math.abs(trades.filter(t => t.pnl < 0).reduce((s, t) => s + t.pnl, 0));\n const profitFactor = grossLoss > 0 ? grossProfit / grossLoss : grossProfit > 0 ? 99 : 0;\n const totalReturn = ((equity - 10000) / 10000) * 100;\n const avgR = totalTrades > 0 ? trades.reduce((s, t) => s + t.rMultiple, 0) / totalTrades : null;\n \n // p-value via t-test approximation\n const rValues = trades.map(t => t.rMultiple).filter(r => !isNaN(r));\n const pValue = rValues.length > 5 ? calculatePValue(rValues) : null;\n\n return {\n totalTrades, wins, losses, winRate, profitFactor, totalReturn,\n maxDrawdown: maxDD, avgR, pValue, halted, equityCurve, trades,\n };\n}\n\nfunction calculatePValue(rMultiples: number[]): number {\n const n = rMultiples.length;\n const mean = rMultiples.reduce((s, r) => s + r, 0) / n;\n const variance = rMultiples.reduce((s, r) => s + (r - mean) ** 2, 0) / (n - 1);\n const stdErr = Math.sqrt(variance / n);\n if (stdErr === 0) return 1.0;\n const tStat = mean / stdErr;\n // Approximate p-value from t-statistic (simplified normal approximation)\n const pValue = 2 * (1 - normalCDF(Math.abs(tStat)));\n return Math.round(pValue * 10000) / 10000;\n}\n\nfunction normalCDF(x: number): number {\n // Abramowitz & Stegun approximation\n const t = 1 / (1 + 0.2316419 * x);\n const d = 0.3989423 * Math.exp(-x * x / 2);\n const p = d * t * (0.3193815 + t * (-0.3565638 + t * (1.781478 + t * (-1.821256 + t * 1.330274))));\n return 1 - p;\n}\n",[],[162,328],["D",1784462679139],[178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193],[162],["D",1784462621259],["D",1789472446807],{"_104":103,"_112":108},{"_104":103,"_105":106,"_107":108,"_19":61,"_109":110,"_111":31},{"_13":14,"_38":94,"_49":48,"_95":50,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":51,"_102":103},"ctx",{"_87":-5,"_132":376,"_377":378,"_379":380,"_381":31,"_382":31,"_383":31,"_384":64,"_385":-5,"_386":-7,"_387":-7,"_388":68,"_389":31,"_390":31,"_391":-5,"_392":31,"_393":31,"_394":31,"_395":-5},"ENV",{"_347":348,"_349":350,"_351":94,"_352":353,"_354":355,"_356":357,"_358":359,"_360":361,"_362":363,"_364":365,"_366":367,"_368":369,"_370":371,"_372":373,"_374":375},"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"]

👑 King's Backtester v3

📋 Recent Jobs

🏛️ Council of Indicators

📈 Live XAU/USD

🔮 TwelveData Feed

⚔️ Launch Royal Analysis

📋 All Reports

📜 Royal Chronicle — Trade Journal

⚙️ Imperial Settings

Data Provider

Telegram Integration

Security

🩺 System Status

📋 Recent Jobs

🏛️ Council of Indicators

📈 Live XAU/USD

🔮 TwelveData Feed

⚔️ Launch Royal Analysis

📋 All Reports

📜 Royal Chronicle — Trade Journal

⚙️ Imperial Settings

Data Provider

Telegram Integration

Security

🩺 System Status

📋 Report

Diff · v23