[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_234":235,"_236":237},"routes/_app.x.$handle.$name",{"_105":104,"_37":50,"_114":95,"_32":115,"_13":14,"_116":-5,"_11":117,"_118":119,"_120":121,"_122":123,"_124":125,"_26":-5,"_126":-5,"_127":-5,"_128":30,"_129":130,"_131":30,"_132":-5,"_133":-5,"_134":135},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_48":49,"_37":50,"_43":51,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":62,"_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":30},"version",8,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","402aae0a-e92a-4305-a1f7-dac919d99d80","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":14,"_46":47,"_29":30},"previous","deleted",false,"deletedHere","path","src/shield.ts","latestPath","fileId","2b53e218-836f-11f1-a4c8-1607ee4eb77e","name","shield.ts","fileType","script","content","// ─── 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","createdAt",["D",1784464891623],"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","8dade5da-836f-11f1-babc-1607ee4eb77e","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",{"_105":104,"_113":109},"org",{"_105":104,"_106":107,"_108":109,"_19":60,"_110":111,"_112":30},"branch",{"_13":94,"_37":95,"_48":47,"_96":49,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":50,"_103":104},"isOwned",23,"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",{"_48":49,"_37":50,"_43":229,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":230,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":231,"_89":232,"_91":233,"_93":30},"tree",[157],"files",[157,158,159,160,161,162,163,164,165],"counts",{"_147":68,"_148":141,"_149":68,"_150":151,"_152":153},"contents",[136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_48":137,"_37":138,"_35":139,"_140":-5,"_46":47,"_45":141,"_142":64,"_43":143,"_13":68,"_39":144,"_41":-5,"_29":30,"_145":-5,"_32":146},"f683e6a0-10d5-4c1a-bf2e-5dc240d383cd","src","6a9a0a45-04fc-49a1-9111-dd5f55871c59","parentId",1,"latest",["D",1784462679139],"directory","label",[138],"pulls","branches","forks","envVars",{"_154":68,"_156":68},"connections",{"_154":68,"_155":68},"count","unfilledCount","emptyCount",{"_48":137,"_37":138,"_35":139,"_140":-5,"_46":47,"_45":141,"_142":64,"_43":226,"_13":68,"_39":144,"_41":-5,"_29":30,"_145":-5,"_172":227,"_32":228},{"_48":218,"_37":219,"_35":220,"_140":139,"_46":47,"_45":221,"_142":30,"_43":222,"_13":68,"_39":40,"_41":223,"_29":30,"_145":-5,"_172":224,"_32":225},{"_48":211,"_37":212,"_35":213,"_140":139,"_46":47,"_45":141,"_142":64,"_43":214,"_13":68,"_39":40,"_41":215,"_29":30,"_145":-5,"_172":216,"_32":217},{"_48":203,"_37":204,"_35":205,"_140":139,"_46":47,"_45":206,"_142":64,"_43":207,"_13":68,"_39":40,"_41":208,"_29":30,"_145":-5,"_172":209,"_32":210},{"_48":195,"_37":196,"_35":197,"_140":139,"_46":47,"_45":198,"_142":64,"_43":199,"_13":68,"_39":40,"_41":200,"_29":30,"_145":-5,"_172":201,"_32":202},{"_48":187,"_37":188,"_35":189,"_140":139,"_46":47,"_45":190,"_142":64,"_43":191,"_13":68,"_39":40,"_41":192,"_29":30,"_145":-5,"_172":193,"_32":194},{"_48":183,"_37":38,"_35":36,"_140":139,"_46":47,"_45":14,"_142":64,"_43":184,"_13":68,"_39":40,"_41":42,"_29":30,"_145":-5,"_172":185,"_32":186},{"_48":175,"_37":176,"_35":177,"_140":139,"_46":47,"_45":178,"_142":64,"_43":179,"_13":68,"_39":40,"_41":180,"_29":30,"_145":-5,"_172":181,"_32":182},{"_48":166,"_37":167,"_35":168,"_140":139,"_46":47,"_45":169,"_142":64,"_43":170,"_13":68,"_39":40,"_41":171,"_29":30,"_145":-5,"_172":173,"_32":174},"e4147b15-3c66-4ff9-8a97-842cceb7553f","types.ts","3b11729c-836a-11f1-9ad0-1607ee4eb77e",2,["D",1784462770587],"// ─── 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","children",[],[138,167],"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",[],[138,176],"697a7f33-da73-47ec-903b-6b9e89acc589",["D",1784464891623],[],[138,38],"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",[],[138,188],"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",[],[138,196],"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",[],[138,204],"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",[],[138,212],"0af22da0-9a4a-4511-8a66-2c22e4f3d64c","db.ts","10c6b3e4-836f-11f1-9fcf-1607ee4eb77e",6,["D",1784464846955],"// ─── 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(`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\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",[],[138,219],["D",1784462679139],[158,159,160,161,162,163,164,165],[138],["D",1784462621259],["D",1789472446807],{"_105":104,"_113":109},{"_105":104,"_106":107,"_108":109,"_19":60,"_110":111,"_112":30},{"_13":94,"_37":95,"_48":47,"_96":49,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":50,"_103":104},"ctx",{"_87":-5,"_133":267,"_268":269,"_270":271,"_272":30,"_273":30,"_274":30,"_275":64,"_276":-5,"_277":-7,"_278":-7,"_279":68,"_280":30,"_281":30,"_282":-5,"_283":30,"_284":30,"_285":30,"_286":-5},"ENV",{"_238":239,"_240":241,"_242":95,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8