[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_272":273,"_274":275},"routes/_app.x.$handle.$name",{"_110":109,"_38":57,"_119":100,"_33":65,"_13":14,"_120":-5,"_11":121,"_122":123,"_124":125,"_126":127,"_128":129,"_27":-5,"_130":-5,"_131":-5,"_132":31,"_133":134,"_135":31,"_136":-5,"_137":-5,"_138":139},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_55":56,"_38":57,"_44":58,"_59":-5,"_60":31,"_61":62,"_63":62,"_64":65,"_66":-5,"_19":67,"_68":-5,"_69":31,"_70":-5,"_71":-5,"_72":73,"_74":75,"_76":77,"_78":79,"_80":81,"_82":-5,"_83":84,"_85":84,"_86":87,"_88":87,"_89":87,"_90":84,"_91":84,"_92":93,"_94":95,"_96":97,"_98":31},"version",16,"changes",[25,26],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","11f92429-042b-495b-aee8-854f308e2247","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_27":49,"_29":-7,"_30":31,"_32":31,"_33":50,"_35":50},{"_27":28,"_29":-7,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous","deleted",false,"deletedHere","path","backend/backtest/engine.ts","latestPath","fileId","f6e54054-5b2c-11f1-ad82-ee650bb23af1","name","engine.ts","fileType","script","content","// Chronological backtest engine using a sliding window (no look-ahead bias).\n// Persists closed trades to SQLite. (The original CSV/JSON file export is\n// replaced by DB storage since Val Town has no writable filesystem; the\n// /backtest endpoints can serialize to CSV/JSON on demand.)\n\nimport type { Candle, Timeframe } from \"../types.ts\";\nimport { analyzeSignals } from \"../signals.ts\";\nimport { getGoldChartData } from \"../api.ts\";\nimport { type ClosedTrade, clearClosedTrades, getClosedTrades, saveClosedTrade } from \"../db.ts\";\n\nconst LOT_BY_TF: Record = {\n \"1\": 0.1, \"5\": 0.2, \"15\": 0.5, \"60\": 1.0, \"1D\": 2.0,\n};\n\n// 1 lot of gold moving $1 == $100 P/L (standard 100oz contract).\nconst USD_PER_DOLLAR_PER_LOT = 100;\n\nconst TIMEFRAMES: Timeframe[] = [\"1\", \"5\", \"15\", \"60\", \"1D\"];\n\nfunction simulateTimeframe(candles: Candle[], tf: Timeframe): ClosedTrade[] {\n const trades: ClosedTrade[] = [];\n const lot = LOT_BY_TF[tf];\n let i = 50;\n\n while (i < candles.length - 1) {\n const window = candles.slice(0, i + 1); // trader stands at candle i\n const sig = analyzeSignals(window, tf);\n\n if (sig.type === \"NEUTRAL\") { i++; continue; }\n\n const side = sig.type;\n const entry = sig.entry;\n const openedAt = candles[i].time;\n\n // walk forward to resolve the trade\n let resolved: ClosedTrade | null = null;\n let stop = sig.stopLoss;\n let tp1Hit = false;\n\n for (let j = i + 1; j < candles.length; j++) {\n const c = candles[j];\n if (side === \"BUY\") {\n // SL first check\n if (!tp1Hit && c.low <= stop) {\n resolved = mkTrade(tf, side, entry, stop, sig, \"SL\", lot, openedAt, c.time); break;\n }\n if (tp1Hit && c.low <= stop) { // breakeven hit after tp1\n resolved = mkTrade(tf, side, entry, stop, sig, \"TP1\", lot, openedAt, c.time); break;\n }\n if (!tp1Hit && c.high >= sig.takeProfit1) {\n tp1Hit = true; stop = entry; // move to breakeven\n if (c.high >= sig.takeProfit2) {\n resolved = mkTrade(tf, side, entry, sig.takeProfit2, sig, \"TP2\", lot, openedAt, c.time); break;\n }\n continue;\n }\n if (tp1Hit && c.high >= sig.takeProfit2) {\n resolved = mkTrade(tf, side, entry, sig.takeProfit2, sig, \"TP2\", lot, openedAt, c.time); break;\n }\n } else { // SELL\n if (!tp1Hit && c.high >= stop) {\n resolved = mkTrade(tf, side, entry, stop, sig, \"SL\", lot, openedAt, c.time); break;\n }\n if (tp1Hit && c.high >= stop) {\n resolved = mkTrade(tf, side, entry, stop, sig, \"TP1\", lot, openedAt, c.time); break;\n }\n if (!tp1Hit && c.low <= sig.takeProfit1) {\n tp1Hit = true; stop = entry;\n if (c.low <= sig.takeProfit2) {\n resolved = mkTrade(tf, side, entry, sig.takeProfit2, sig, \"TP2\", lot, openedAt, c.time); break;\n }\n continue;\n }\n if (tp1Hit && c.low <= sig.takeProfit2) {\n resolved = mkTrade(tf, side, entry, sig.takeProfit2, sig, \"TP2\", lot, openedAt, c.time); break;\n }\n }\n }\n\n if (resolved) {\n trades.push(resolved);\n // jump past the trade close to avoid overlapping positions\n const closeIdx = candles.findIndex((c) => c.time === resolved!.closedAt);\n i = closeIdx > i ? closeIdx + 1 : i + 1;\n } else {\n i++;\n }\n }\n return trades;\n}\n\nfunction mkTrade(\n tf: Timeframe, side: \"BUY\" | \"SELL\", entry: number, exit: number,\n sig: { stopLoss: number; takeProfit1: number; takeProfit2: number },\n result: \"SL\" | \"TP1\" | \"TP2\", lot: number, openedAt: number, closedAt: number,\n): ClosedTrade {\n // For a partial TP1 close we book half the position to TP1 and exit is entry (breakeven on rest)\n let priceMove: number;\n if (result === \"TP1\") {\n // half position reached TP1, the rest closed at breakeven\n priceMove = side === \"BUY\"\n ? (sig.takeProfit1 - entry) * 0.5\n : (entry - sig.takeProfit1) * 0.5;\n } else {\n priceMove = side === \"BUY\" ? exit - entry : entry - exit;\n }\n const pips = priceMove * 10; // $1 gold == 10 pips\n const profitUsd = priceMove * lot * USD_PER_DOLLAR_PER_LOT;\n return {\n id: `${tf}-${openedAt}-${crypto.randomUUID().slice(0, 8)}`,\n timeframe: tf, side, entry: round2(entry), exit: round2(exit),\n stopLoss: round2(sig.stopLoss), tp1: round2(sig.takeProfit1), tp2: round2(sig.takeProfit2),\n result, pips: round2(pips), profitUsd: round2(profitUsd), lot, openedAt, closedAt,\n };\n}\n\n/** Run a full backtest across all timeframes, persisting results. */\nexport async function runBacktest(): Promise<{ total: number; perTf: Record }> {\n await clearClosedTrades();\n const perTf: Record = {};\n let total = 0;\n\n for (const tf of TIMEFRAMES) {\n let candles: Candle[];\n try {\n candles = await getGoldChartData(tf);\n } catch {\n perTf[tf] = 0;\n continue;\n }\n const trades = simulateTimeframe(candles, tf);\n for (const t of trades) await saveClosedTrade(t);\n perTf[tf] = trades.length;\n total += trades.length;\n }\n return { total, perTf };\n}\n\nexport interface BacktestStats {\n trades: ClosedTrade[];\n winRate: number;\n totalPips: number;\n totalProfitUsd: number;\n wins: number;\n losses: number;\n}\n\nexport function computeStats(trades: ClosedTrade[]): BacktestStats {\n let wins = 0, losses = 0, totalPips = 0, totalProfitUsd = 0;\n for (const t of trades) {\n if (t.result === \"SL\") losses++; else wins++;\n totalPips += t.pips;\n totalProfitUsd += t.profitUsd;\n }\n const n = trades.length || 1;\n return {\n trades,\n winRate: Math.round((wins / n) * 1000) / 10,\n totalPips: round2(totalPips),\n totalProfitUsd: round2(totalProfitUsd),\n wins, losses,\n };\n}\n\nexport function tradesToCsv(trades: ClosedTrade[]): string {\n const header = \"id,timeframe,side,entry,exit,stopLoss,tp1,tp2,result,pips,profitUsd,lot,openedAt,closedAt\";\n const lines = trades.map((t) =>\n [t.id, t.timeframe, t.side, t.entry, t.exit, t.stopLoss, t.tp1, t.tp2, t.result, t.pips, t.profitUsd, t.lot,\n new Date(t.openedAt * 1000).toISOString(), new Date(t.closedAt * 1000).toISOString()].join(\",\"));\n return [header, ...lines].join(\"\\n\");\n}\n\nexport async function getHistoryEnsured(): Promise {\n let trades = await getClosedTrades();\n if (trades.length === 0) {\n await runBacktest();\n trades = await getClosedTrades();\n }\n return trades;\n}\n\nfunction round2(n: number): number {\n return Math.round(n * 100) / 100;\n}\n","createdAt",["D",1780038410242],"branchVersion","branchId","965de890-5b2b-11f1-858a-ee650bb23af1",{"_36":51,"_38":52,"_40":53,"_42":-5,"_44":54,"_46":14,"_47":48,"_30":31},"backend/backtest","c62f720d-665e-4ff0-ab42-090d25c3acd0","backtest","directory",["D",1780038410242],"id","965d4d18-5b2b-11f1-858a-ee650bb23af1","minhmmo1",["D",1780037818961],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","f5941096-d705-4659-aab6-4989a891ae97","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e7285-1c55-722e-b465-29c0e6152543","tursoName","965d4d185b2b11f1858aee650bb23af1","tursoHostname","965d4d185b2b11f1858aee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789441243316],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_110":109,"_118":114},"org",{"_110":109,"_111":112,"_113":114,"_19":67,"_115":116,"_117":31},"branch",{"_13":99,"_38":100,"_55":48,"_101":56,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":57,"_108":109},"isOwned",20,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","phillisbranch","handle","displayName","Phillis Branch","avatar","https://lh3.googleusercontent.com/a/ACg8ocLFhJb4ygtL2TzCyJZMpqclRbFqf8-vaYbCu-s30Tb0kK2maQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_55":56,"_38":57,"_44":267,"_59":-5,"_60":31,"_61":62,"_63":62,"_64":65,"_66":-5,"_19":67,"_68":-5,"_69":31,"_70":-5,"_71":-5,"_72":73,"_74":75,"_76":77,"_78":79,"_80":268,"_82":-5,"_83":84,"_85":84,"_86":87,"_88":87,"_89":87,"_90":84,"_91":84,"_92":269,"_94":270,"_96":271,"_98":31},"tree",[168,180],"files",[168,169,170,171,172,173,174,175,176,177,178,179,180],"counts",{"_158":73,"_159":146,"_160":146,"_161":162,"_163":164},"contents",[140,141],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_55":151,"_38":152,"_36":153,"_145":-5,"_47":48,"_46":154,"_147":155,"_44":156,"_13":73,"_40":53,"_42":-5,"_30":31,"_149":-5,"_33":157},{"_55":142,"_38":143,"_36":144,"_145":-5,"_47":48,"_46":146,"_147":31,"_44":148,"_13":73,"_40":41,"_42":65,"_30":31,"_149":-5,"_33":150},"9660592c-5b2b-11f1-858a-ee650bb23af1","main.ts","966059fe-5b2b-11f1-858a-ee650bb23af1","parentId",1,"latest",["D",1780037818973],"label",[143],"57756c42-5b2c-11f1-b3d6-ee650bb23af1","backend","19932e97-20f9-4a08-87b1-8f0fc96fb433",6,true,["D",1780038142906],[152],"pulls","branches","forks","envVars",{"_165":73,"_167":73},"connections",{"_165":73,"_166":73},"count","unfilledCount","emptyCount",{"_55":151,"_38":152,"_36":153,"_145":-5,"_47":48,"_46":154,"_147":155,"_44":264,"_13":73,"_40":53,"_42":-5,"_30":31,"_149":-5,"_182":265,"_33":266},{"_55":260,"_38":52,"_36":51,"_145":153,"_47":48,"_46":14,"_147":155,"_44":261,"_13":73,"_40":53,"_42":-5,"_30":31,"_149":-5,"_182":262,"_33":263},{"_55":256,"_38":39,"_36":37,"_145":51,"_47":48,"_46":14,"_147":155,"_44":257,"_13":73,"_40":41,"_42":43,"_30":31,"_149":-5,"_182":258,"_33":259},{"_55":248,"_38":249,"_36":250,"_145":153,"_47":48,"_46":251,"_147":31,"_44":252,"_13":146,"_40":41,"_42":253,"_30":31,"_149":-5,"_182":254,"_33":255},{"_55":240,"_38":241,"_36":242,"_145":153,"_47":48,"_46":243,"_147":155,"_44":244,"_13":73,"_40":41,"_42":245,"_30":31,"_149":-5,"_182":246,"_33":247},{"_55":232,"_38":233,"_36":234,"_145":153,"_47":48,"_46":235,"_147":155,"_44":236,"_13":73,"_40":41,"_42":237,"_30":31,"_149":-5,"_182":238,"_33":239},{"_55":224,"_38":225,"_36":226,"_145":153,"_47":48,"_46":227,"_147":155,"_44":228,"_13":73,"_40":41,"_42":229,"_30":31,"_149":-5,"_182":230,"_33":231},{"_55":216,"_38":217,"_36":218,"_145":153,"_47":48,"_46":219,"_147":155,"_44":220,"_13":73,"_40":41,"_42":221,"_30":31,"_149":-5,"_182":222,"_33":223},{"_55":208,"_38":209,"_36":210,"_145":153,"_47":48,"_46":211,"_147":155,"_44":212,"_13":73,"_40":41,"_42":213,"_30":31,"_149":-5,"_182":214,"_33":215},{"_55":200,"_38":201,"_36":202,"_145":153,"_47":48,"_46":203,"_147":155,"_44":204,"_13":73,"_40":41,"_42":205,"_30":31,"_149":-5,"_182":206,"_33":207},{"_55":192,"_38":193,"_36":194,"_145":153,"_47":48,"_46":195,"_147":155,"_44":196,"_13":73,"_40":41,"_42":197,"_30":31,"_149":-5,"_182":198,"_33":199},{"_55":185,"_38":186,"_36":187,"_145":153,"_47":48,"_46":154,"_147":155,"_44":188,"_13":73,"_40":41,"_42":189,"_30":31,"_149":-5,"_182":190,"_33":191},{"_55":142,"_38":143,"_36":144,"_145":-5,"_47":48,"_46":146,"_147":31,"_44":181,"_13":73,"_40":41,"_42":65,"_30":31,"_149":-5,"_182":183,"_33":184},["D",1780037818973],"children",[],[143],"57753f38-5b2c-11f1-b3d6-ee650bb23af1","types.ts","57754014-5b2c-11f1-b3d6-ee650bb23af1",["D",1780038142906],"// Shared types for the XAU/USD Gold Terminal\n\nexport interface Candle {\n time: number; // unix seconds (candle open time)\n open: number;\n high: number;\n low: number;\n close: number;\n volume: number;\n}\n\nexport type Timeframe = \"1\" | \"5\" | \"15\" | \"60\" | \"1D\";\n\nexport interface RealtimeQuote {\n price: number;\n changePercent: number;\n change: number;\n high: number;\n low: number;\n // technical indicators (from TradingView scanner)\n rsi?: number;\n ema10?: number;\n ema20?: number;\n ema50?: number;\n ema100?: number;\n ema200?: number;\n sma20?: number;\n adx?: number;\n cci20?: number;\n stochK?: number;\n stochD?: number;\n atr?: number;\n macd?: number;\n macdSignal?: number;\n recommendation?: number; // -1..1 overall TV recommendation\n}\n\nexport type SignalType = \"BUY\" | \"SELL\" | \"NEUTRAL\";\n\nexport interface SwingPoint {\n index: number;\n time: number;\n price: number;\n type: \"high\" | \"low\";\n}\n\nexport interface StructureBreak {\n index: number;\n time: number;\n price: number;\n kind: \"BOS\" | \"CHoCH\";\n direction: \"bullish\" | \"bearish\";\n}\n\nexport interface FVG {\n index: number;\n time: number;\n top: number;\n bottom: number;\n direction: \"bullish\" | \"bearish\";\n mitigated: boolean;\n}\n\nexport interface OrderBlock {\n index: number;\n time: number;\n top: number;\n bottom: number;\n direction: \"bullish\" | \"bearish\";\n mitigated: boolean;\n}\n\nexport interface LiquiditySweep {\n index: number;\n time: number;\n price: number;\n kind: \"BSL\" | \"SSL\"; // buy-side / sell-side liquidity swept\n}\n\nexport interface CandlePattern {\n index: number;\n time: number;\n name: string;\n direction: \"bullish\" | \"bearish\" | \"neutral\";\n}\n\nexport interface SMCAnalysis {\n swings: SwingPoint[];\n structureBreaks: StructureBreak[];\n fvgs: FVG[];\n orderBlocks: OrderBlock[];\n sweeps: LiquiditySweep[];\n patterns: CandlePattern[];\n}\n\nexport interface TradeSignal {\n type: SignalType;\n score: number; // 0..100 strength of dominant side\n buyScore: number;\n sellScore: number;\n entry: number;\n stopLoss: number;\n takeProfit1: number;\n takeProfit2: number;\n riskRewardTp1: number;\n riskRewardTp2: number;\n entryReason: string;\n slReason: string;\n tpReason: string;\n atr: number;\n}\n",[],[152,186],"a6f70424-5b2c-11f1-be55-ee650bb23af1","signals.ts","a6f704f6-5b2c-11f1-be55-ee650bb23af1",11,["D",1780038276293],"// Trade signal generator with momentum/trend scoring, SMC entry confluence,\n// and volatility-based SL/TP tuned per timeframe for gold.\n\nimport type { Candle, SignalType, Timeframe, TradeSignal } from \"./types.ts\";\nimport { atr, bollinger, closes, ema, rsi } from \"./indicators.ts\";\nimport { findFVGs, findOrderBlocks } from \"./advanced_analysis.ts\";\n\n// per-timeframe SL/TP tuning (in dollars of gold price). [min, max] SL + fixed TP targets.\nconst TF_CONFIG: Record = {\n \"1\": { slMin: 3.0, slMax: 5.0, tp1: 5.0, tp2: 12.0 },\n \"5\": { slMin: 6.0, slMax: 8.0, tp1: 10.0, tp2: 20.0 },\n \"15\": { slMin: 8.0, slMax: 15.0, tp1: 15.0, tp2: 35.0 },\n \"60\": { slMin: 30.0, slMax: 50.0, tp1: 80.0, tp2: 180.0 },\n \"1D\": { slMin: 30.0, slMax: 50.0, tp1: 80.0, tp2: 180.0 },\n};\n\nfunction clamp(v: number, lo: number, hi: number) {\n return Math.max(lo, Math.min(hi, v));\n}\n\nexport function analyzeSignals(candles: Candle[], tf: Timeframe): TradeSignal {\n const cls = closes(candles);\n const last = cls[cls.length - 1];\n const ema9 = ema(cls, 9);\n const ema21 = ema(cls, 21);\n const ema50 = ema(cls, 50);\n const rsiArr = rsi(cls, 14);\n const bb = bollinger(cls, 20, 2);\n const a = atr(candles, 14) || 1;\n\n const i = cls.length - 1;\n const curRsi = rsiArr[i] ?? 50;\n const macroUp = last > ema50[i];\n\n let buy = 0, sell = 0;\n\n // macro trend (±25)\n if (macroUp) buy += 25; else sell += 25;\n\n // momentum cross EMA9 vs EMA21 (±15)\n if (ema9[i] > ema21[i]) buy += 15; else sell += 15;\n\n // RSI logic\n if (macroUp) {\n if (curRsi > 55) buy += 15;\n else if (curRsi < 40) buy += 12; // buy the dip\n } else {\n if (curRsi > 60) sell += 15; // sell the rally\n else if (curRsi < 45) sell += 8;\n }\n if (curRsi > 80) { sell += 10; buy = Math.max(0, buy - 5); } // overbought reversal\n if (curRsi < 20) { buy += 10; sell = Math.max(0, sell - 5); } // oversold reversal\n\n // Bollinger position (±10)\n const upper = bb.upper[i], lower = bb.lower[i];\n if (!isNaN(lower) && last <= lower) buy += 10;\n if (!isNaN(upper) && last >= upper) sell += 10;\n\n // volume trend (±10)\n const recentVol = candles.slice(-5).reduce((s, c) => s + c.volume, 0) / 5;\n const priorVol = candles.slice(-15, -5).reduce((s, c) => s + c.volume, 0) / 10 || recentVol;\n if (recentVol > priorVol * 1.2) {\n if (macroUp) buy += 10; else sell += 10;\n }\n\n const total = buy + sell || 1;\n const buyPct = (buy / total) * 100;\n const sellPct = (sell / total) * 100;\n\n let type: SignalType = \"NEUTRAL\";\n if (buyPct > 55) type = \"BUY\";\n else if (sellPct > 55) type = \"SELL\";\n\n const score = Math.round(Math.max(buyPct, sellPct));\n\n // ---- SMC entry confluence ----\n const cfg = TF_CONFIG[tf];\n const obs = findOrderBlocks(candles).filter((o) => !o.mitigated);\n const fvgs = findFVGs(candles).filter((f) => !f.mitigated);\n\n let entry = last;\n let entryConfluence = \"\";\n\n if (type === \"BUY\") {\n const ob = obs.filter((o) => o.direction === \"bullish\" && o.top < last).pop();\n const fvg = fvgs.filter((f) => f.direction === \"bullish\" && f.top < last).pop();\n const zone = ob ?? fvg;\n if (zone) {\n entry = zone.top;\n entryConfluence = ob ? \"Bullish Order Block\" : \"Bullish FVG\";\n // if zone too deep (>2.5*ATR away), pull entry up toward price\n if (last - entry > 2.5 * a) {\n entry = last - 0.2 * a;\n entryConfluence += \" (kéo gần giá hiện tại do vùng quá sâu)\";\n }\n } else {\n entry = last - 0.2 * a;\n }\n } else if (type === \"SELL\") {\n const ob = obs.filter((o) => o.direction === \"bearish\" && o.bottom > last).pop();\n const fvg = fvgs.filter((f) => f.direction === \"bearish\" && f.bottom > last).pop();\n const zone = ob ?? fvg;\n if (zone) {\n entry = zone.bottom;\n entryConfluence = ob ? \"Bearish Order Block\" : \"Bearish FVG\";\n if (entry - last > 2.5 * a) {\n entry = last + 0.2 * a;\n entryConfluence += \" (kéo gần giá hiện tại do vùng quá sâu)\";\n }\n } else {\n entry = last + 0.2 * a;\n }\n }\n\n // ---- volatility-based SL/TP ----\n const slDist = clamp(a, cfg.slMin, cfg.slMax);\n let stopLoss: number, tp1: number, tp2: number;\n if (type === \"SELL\") {\n stopLoss = entry + slDist;\n tp1 = entry - cfg.tp1;\n tp2 = entry - cfg.tp2;\n } else {\n // BUY or NEUTRAL (still produce reference levels)\n stopLoss = entry - slDist;\n tp1 = entry + cfg.tp1;\n tp2 = entry + cfg.tp2;\n }\n\n const rrTp1 = Math.abs(tp1 - entry) / slDist;\n const rrTp2 = Math.abs(tp2 - entry) / slDist;\n\n return {\n type,\n score,\n buyScore: Math.round(buyPct),\n sellScore: Math.round(sellPct),\n entry: round2(entry),\n stopLoss: round2(stopLoss),\n takeProfit1: round2(tp1),\n takeProfit2: round2(tp2),\n riskRewardTp1: Math.round(rrTp1 * 100) / 100,\n riskRewardTp2: Math.round(rrTp2 * 100) / 100,\n atr: Math.round(a * 100) / 100,\n entryReason: buildEntryReason(type, entryConfluence, curRsi, macroUp),\n slReason: buildSlReason(type, slDist, a),\n tpReason: buildTpReason(type, cfg.tp1, cfg.tp2),\n };\n}\n\nfunction dir(type: SignalType) {\n return type === \"BUY\" ? \"MUA\" : type === \"SELL\" ? \"BÁN\" : \"ĐỨNG NGOÀI\";\n}\n\nfunction buildEntryReason(type: SignalType, conf: string, rsiVal: number, macroUp: boolean): string {\n if (type === \"NEUTRAL\") {\n return \"Thị trường chưa có hợp lưu rõ ràng. Các chỉ báo xu hướng và động lượng đang giằng co, khuyến nghị đứng ngoài bảo toàn vốn cho đến khi xuất hiện tín hiệu phá vỡ cấu trúc rõ ràng.\";\n }\n const trend = macroUp ? \"xu hướng tăng vĩ mô (giá trên EMA50)\" : \"xu hướng giảm vĩ mô (giá dưới EMA50)\";\n const zone = conf ? `Điểm vào lệnh được đặt tại biên ${conf} chưa bị chạm để tối ưu tỷ lệ R:R.` :\n \"Chưa tìm thấy vùng SMC chưa chạm phía dưới/trên, điểm vào lệnh được đặt sát giá hiện tại.\";\n return `Tín hiệu ${dir(type)} dựa trên ${trend}, RSI = ${rsiVal.toFixed(1)} ủng hộ hướng vào lệnh. ${zone}`;\n}\n\nfunction buildSlReason(type: SignalType, slDist: number, a: number): string {\n if (type === \"NEUTRAL\") return \"Không có lệnh nên không thiết lập cắt lỗ.\";\n return `Cắt lỗ được đặt cách điểm vào ${slDist.toFixed(1)} giá (≈ ${(slDist * 10).toFixed(0)} pips), co giãn động theo ATR hiện tại (${a.toFixed(1)}). Mức này nằm ngoài vùng nhiễu thông thường nhằm tránh bị săn thanh khoản (Stop Hunt) trước khi giá đi đúng hướng.`;\n}\n\nfunction buildTpReason(type: SignalType, tp1: number, tp2: number): string {\n if (type === \"NEUTRAL\") return \"Không có lệnh nên không thiết lập chốt lời.\";\n return `Chiến lược chia vốn 2 chặng: TP1 (+${tp1} giá) để bỏ túi lợi nhuận an toàn và dời SL về hòa vốn; TP2 (+${tp2} giá) hướng tới các bể thanh khoản lớn (đỉnh/đáy lịch sử) cho phần vị thế còn lại.`;\n}\n\nfunction round2(n: number): number {\n return Math.round(n * 100) / 100;\n}\n",[],[152,193],"e48c4a2e-5b2c-11f1-8f7e-ee650bb23af1","market_outlook.ts","e48c4ae2-5b2c-11f1-8f7e-ee650bb23af1",15,["D",1780038379617],"// H1 market outlook report: Dow Theory + SMC + Price Action + synthesis.\nimport type { Candle } from \"./types.ts\";\nimport { analyzeAdvanced } from \"./advanced_analysis.ts\";\nimport { analyzeSignals } from \"./signals.ts\";\nimport { atr } from \"./indicators.ts\";\n\nexport interface MarketOutlook {\n dow: {\n primaryTrend: \"TĂNG\" | \"GIẢM\" | \"ĐI NGANG\";\n secondaryTrend: string;\n text: string;\n resistance: number;\n support: number;\n };\n smc: {\n structure: string;\n bullishOB: { top: number; bottom: number } | null;\n bearishOB: { top: number; bottom: number } | null;\n bullishFvgDist: number | null;\n bearishFvgDist: number | null;\n sweeps: string;\n text: string;\n };\n priceAction: {\n patterns: { name: string; direction: string }[];\n sentiment: \"TÍCH CỰC\" | \"TIÊU CỰC\" | \"TRUNG LẬP\";\n advice: string;\n };\n summary: {\n score: number; // 5..95\n bias: \"BUY\" | \"SELL\" | \"HOLD\";\n target: number;\n stopLoss: number;\n text: string;\n };\n}\n\nexport function buildMarketOutlook(candles: Candle[]): MarketOutlook {\n const closed = candles.slice(0, -1);\n const last = closed[closed.length - 1].close;\n const smc = analyzeAdvanced(closed);\n const sig = analyzeSignals(closed, \"60\");\n const a = atr(closed, 14) || 1;\n\n // ---- Dow Theory ----\n const highs = smc.swings.filter((s) => s.type === \"high\").slice(-3);\n const lows = smc.swings.filter((s) => s.type === \"low\").slice(-3);\n let primaryTrend: \"TĂNG\" | \"GIẢM\" | \"ĐI NGANG\" = \"ĐI NGANG\";\n let dowText = \"\";\n if (highs.length >= 2 && lows.length >= 2) {\n const hh = highs[highs.length - 1].price > highs[highs.length - 2].price;\n const hl = lows[lows.length - 1].price > lows[lows.length - 2].price;\n const lh = highs[highs.length - 1].price < highs[highs.length - 2].price;\n const ll = lows[lows.length - 1].price < lows[lows.length - 2].price;\n if (hh && hl) {\n primaryTrend = \"TĂNG\";\n dowText = `Theo lý thuyết Dow, thị trường đang trong xu hướng TĂNG: đỉnh gần nhất (${highs[highs.length - 1].price.toFixed(2)}) cao hơn đỉnh trước (${highs[highs.length - 2].price.toFixed(2)}), đồng thời đáy gần nhất (${lows[lows.length - 1].price.toFixed(2)}) cũng cao hơn đáy trước (${lows[lows.length - 2].price.toFixed(2)}) — cấu trúc Higher High & Higher Low rõ ràng.`;\n } else if (lh && ll) {\n primaryTrend = \"GIẢM\";\n dowText = `Theo lý thuyết Dow, thị trường đang trong xu hướng GIẢM: đỉnh gần nhất (${highs[highs.length - 1].price.toFixed(2)}) thấp hơn đỉnh trước (${highs[highs.length - 2].price.toFixed(2)}), đáy gần nhất (${lows[lows.length - 1].price.toFixed(2)}) thấp hơn đáy trước (${lows[lows.length - 2].price.toFixed(2)}) — cấu trúc Lower High & Lower Low.`;\n } else {\n dowText = `Thị trường ĐI NGANG / tích lũy: các đỉnh đáy chưa hình thành cấu trúc tăng hoặc giảm rõ ràng. Nên chờ phá vỡ biên độ trước khi giao dịch.`;\n }\n } else {\n dowText = \"Chưa đủ dữ liệu đỉnh/đáy sóng để xác định xu hướng theo lý thuyết Dow.\";\n }\n const resistance = highs.length ? Math.max(...highs.map((h) => h.price)) : last + a;\n const support = lows.length ? Math.min(...lows.map((l) => l.price)) : last - a;\n const secondaryTrend = primaryTrend === \"TĂNG\"\n ? \"Sóng hồi điều chỉnh giảm ngắn hạn trong xu hướng tăng chính.\"\n : primaryTrend === \"GIẢM\"\n ? \"Sóng hồi phục tăng ngắn hạn trong xu hướng giảm chính.\"\n : \"Dao động trong biên độ hẹp.\";\n\n // ---- SMC ----\n const lastBreak = smc.structureBreaks[smc.structureBreaks.length - 1];\n const bullOB = smc.orderBlocks.filter((o) => o.direction === \"bullish\" && !o.mitigated).pop() ?? null;\n const bearOB = smc.orderBlocks.filter((o) => o.direction === \"bearish\" && !o.mitigated).pop() ?? null;\n const bullFvg = smc.fvgs.filter((f) => f.direction === \"bullish\" && !f.mitigated).pop() ?? null;\n const bearFvg = smc.fvgs.filter((f) => f.direction === \"bearish\" && !f.mitigated).pop() ?? null;\n const recentSweeps = smc.sweeps.slice(-3);\n const smcStructure = lastBreak\n ? `Lần phá vỡ cấu trúc gần nhất là ${lastBreak.kind} hướng ${lastBreak.direction === \"bullish\" ? \"TĂNG\" : \"GIẢM\"} tại mức ${lastBreak.price.toFixed(2)}.`\n : \"Chưa ghi nhận phá vỡ cấu trúc rõ ràng gần đây.\";\n\n let smcText = smcStructure + \" \";\n if (bullOB) smcText += `Khối OB Cầu (Bullish OB) chưa chạm tại vùng ${bullOB.bottom.toFixed(2)}–${bullOB.top.toFixed(2)} là điểm canh mua tiềm năng. `;\n if (bearOB) smcText += `Khối OB Cung (Bearish OB) chưa chạm tại vùng ${bearOB.bottom.toFixed(2)}–${bearOB.top.toFixed(2)} là điểm canh bán tiềm năng. `;\n if (recentSweeps.length) {\n smcText += `Vừa ghi nhận quét thanh khoản: ${recentSweeps.map((s) => s.kind).join(\", \")}.`;\n }\n\n // ---- Price Action ----\n const recentPatterns = smc.patterns.slice(-4);\n let bull = 0, bear = 0;\n for (const p of recentPatterns) {\n if (p.direction === \"bullish\") bull++;\n else if (p.direction === \"bearish\") bear++;\n }\n const sentiment: \"TÍCH CỰC\" | \"TIÊU CỰC\" | \"TRUNG LẬP\" =\n bull > bear ? \"TÍCH CỰC\" : bear > bull ? \"TIÊU CỰC\" : \"TRUNG LẬP\";\n const advice = sentiment === \"TÍCH CỰC\"\n ? `Tâm lý tích cực. Cân nhắc canh lệnh Buy Limit quanh vùng hỗ trợ ${(bullOB?.top ?? support).toFixed(2)} thay vì mua đuổi.`\n : sentiment === \"TIÊU CỰC\"\n ? `Tâm lý tiêu cực. Cân nhắc canh lệnh Sell Limit quanh vùng kháng cự ${(bearOB?.bottom ?? resistance).toFixed(2)}.`\n : \"Tâm lý trung lập, các mô hình nến chưa nghiêng hẳn về bên nào — ưu tiên bảo toàn vốn, đứng ngoài quan sát.\";\n\n // ---- Summary ----\n let score = sig.type === \"BUY\" ? 50 + sig.score / 3 : sig.type === \"SELL\" ? 50 - sig.score / 3 : 50;\n if (primaryTrend === \"TĂNG\") score += 8;\n if (primaryTrend === \"GIẢM\") score -= 8;\n if (sentiment === \"TÍCH CỰC\") score += 5;\n if (sentiment === \"TIÊU CỰC\") score -= 5;\n score = Math.max(5, Math.min(95, Math.round(score)));\n\n const bias: \"BUY\" | \"SELL\" | \"HOLD\" = score >= 60 ? \"BUY\" : score <= 40 ? \"SELL\" : \"HOLD\";\n const summaryText = bias === \"BUY\"\n ? `Tổng hợp các góc nhìn nghiêng về phe MUA (điểm kỹ thuật ${score}/95). Xu hướng chính ${primaryTrend}, hợp lưu SMC và Price Action ủng hộ. Mục tiêu ${sig.takeProfit1.toFixed(2)}, cắt lỗ ${sig.stopLoss.toFixed(2)}.`\n : bias === \"SELL\"\n ? `Tổng hợp nghiêng về phe BÁN (điểm kỹ thuật ${score}/95). Xu hướng chính ${primaryTrend}. Mục tiêu ${sig.takeProfit1.toFixed(2)}, cắt lỗ ${sig.stopLoss.toFixed(2)}.`\n : `Các tín hiệu đang giằng co (điểm ${score}/95). Khuyến nghị HOLD — chờ thị trường xác lập xu hướng rõ ràng trước khi vào lệnh.`;\n\n return {\n dow: { primaryTrend, secondaryTrend, text: dowText, resistance: round2(resistance), support: round2(support) },\n smc: {\n structure: smcStructure,\n bullishOB: bullOB ? { top: round2(bullOB.top), bottom: round2(bullOB.bottom) } : null,\n bearishOB: bearOB ? { top: round2(bearOB.top), bottom: round2(bearOB.bottom) } : null,\n bullishFvgDist: bullFvg ? round2(Math.abs(last - bullFvg.top)) : null,\n bearishFvgDist: bearFvg ? round2(Math.abs(bearFvg.bottom - last)) : null,\n sweeps: recentSweeps.map((s) => s.kind).join(\", \") || \"Không có\",\n text: smcText,\n },\n priceAction: {\n patterns: recentPatterns.map((p) => ({ name: p.name, direction: p.direction })),\n sentiment,\n advice,\n },\n summary: { score, bias, target: sig.takeProfit1, stopLoss: sig.stopLoss, text: summaryText },\n };\n}\n\nfunction round2(n: number): number {\n return Math.round(n * 100) / 100;\n}\n",[],[152,201],"8ddf75b6-5b2c-11f1-b673-ee650bb23af1","indicators.ts","8ddf7688-5b2c-11f1-b673-ee650bb23af1",10,["D",1780038234194],"// Technical indicator helpers computed locally from candle arrays.\nimport type { Candle } from \"./types.ts\";\n\nexport function ema(values: number[], period: number): number[] {\n if (values.length === 0) return [];\n const k = 2 / (period + 1);\n const out: number[] = [];\n let prev = values[0];\n out.push(prev);\n for (let i = 1; i < values.length; i++) {\n prev = values[i] * k + prev * (1 - k);\n out.push(prev);\n }\n return out;\n}\n\nexport function sma(values: number[], period: number): number[] {\n const out: number[] = [];\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) { out.push(NaN); continue; }\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) sum += values[j];\n out.push(sum / period);\n }\n return out;\n}\n\nexport function rsi(values: number[], period = 14): number[] {\n const out: number[] = new Array(values.length).fill(NaN);\n if (values.length <= period) return out;\n let gain = 0, loss = 0;\n for (let i = 1; i <= period; i++) {\n const diff = values[i] - values[i - 1];\n if (diff >= 0) gain += diff; else loss -= diff;\n }\n let avgGain = gain / period, avgLoss = loss / period;\n out[period] = 100 - 100 / (1 + (avgLoss === 0 ? 100 : avgGain / avgLoss));\n for (let i = period + 1; i < values.length; i++) {\n const diff = values[i] - values[i - 1];\n const g = diff > 0 ? diff : 0;\n const l = diff < 0 ? -diff : 0;\n avgGain = (avgGain * (period - 1) + g) / period;\n avgLoss = (avgLoss * (period - 1) + l) / period;\n out[i] = 100 - 100 / (1 + (avgLoss === 0 ? 100 : avgGain / avgLoss));\n }\n return out;\n}\n\nexport function atr(candles: Candle[], period = 14): number {\n if (candles.length < 2) return 0;\n const trs: number[] = [];\n for (let i = 1; i < candles.length; i++) {\n const c = candles[i], p = candles[i - 1];\n trs.push(Math.max(c.high - c.low, Math.abs(c.high - p.close), Math.abs(c.low - p.close)));\n }\n const slice = trs.slice(-period);\n return slice.reduce((a, b) => a + b, 0) / slice.length;\n}\n\nexport function bollinger(values: number[], period = 20, mult = 2) {\n const mid = sma(values, period);\n const upper: number[] = [], lower: number[] = [];\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) { upper.push(NaN); lower.push(NaN); continue; }\n let sumSq = 0;\n for (let j = i - period + 1; j <= i; j++) sumSq += (values[j] - mid[i]) ** 2;\n const sd = Math.sqrt(sumSq / period);\n upper.push(mid[i] + mult * sd);\n lower.push(mid[i] - mult * sd);\n }\n return { mid, upper, lower };\n}\n\nexport function closes(candles: Candle[]): number[] {\n return candles.map((c) => c.close);\n}\n",[],[152,209],"cabd67a4-5b2c-11f1-b2b2-ee650bb23af1","email.ts","cabd684e-5b2c-11f1-b2b2-ee650bb23af1",14,["D",1780038336312],"// OTP email delivery.\n// Priority: Resend API (if RESEND_API_KEY set) -> Val Town std/email -> dev mode.\n// In dev mode (no delivery configured), the OTP is surfaced in the API response\n// so you can copy-paste it during testing.\n\nexport interface SendResult {\n delivered: boolean;\n devOtp?: string; // present when not actually emailed\n}\n\nexport async function sendOtpEmail(email: string, code: string): Promise {\n const resendKey = Deno.env.get(\"RESEND_API_KEY\");\n\n const subject = \"Mã xác thực XAU/USD Gold Terminal\";\n const text = `Mã OTP của bạn là: ${code}\\n\\nMã có hiệu lực trong 5 phút. Không chia sẻ mã này với bất kỳ ai.`;\n const html =\n `

XAU/USD Gold Terminal

Mã xác thực của bạn:

${code}

Mã có hiệu lực trong 5 phút. Không chia sẻ mã này với bất kỳ ai.

`;\n\n // 1) Resend (can deliver to ANY recipient)\n if (resendKey) {\n try {\n const r = await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: { Authorization: `Bearer ${resendKey}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n from: \"Gold Terminal \",\n to: [email],\n subject,\n html,\n }),\n });\n if (r.ok) return { delivered: true };\n } catch {\n // fall through\n }\n }\n\n // 2) Val Town std/email (delivers to the val owner's account email only)\n try {\n const { email: sendEmail } = await import(\"https://esm.town/v/std/email\");\n await sendEmail({ subject: `${subject} (cho ${email})`, text, html });\n // Still surface the code for dev convenience since it only reaches the owner.\n return { delivered: true, devOtp: code };\n } catch {\n // 3) Dev mode\n return { delivered: false, devOtp: code };\n }\n}\n",[],[152,217],"c1708046-5b2c-11f1-98bf-ee650bb23af1","db.ts","c1708136-5b2c-11f1-98bf-ee650bb23af1",13,["D",1780038320713],"// Data layer backed by Val Town SQLite (replaces Deno KV from the original spec).\n// Handles users, OTPs, sessions, and backtest closed-trade history.\n// Password hashing uses PBKDF2 (100k rounds, SHA-256) via Web Crypto.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst PBKDF2_ROUNDS = 100_000;\n\nlet initialized = false;\nexport async function initDb() {\n if (initialized) return;\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS gt_users (\n email TEXT PRIMARY KEY,\n salt TEXT NOT NULL,\n hash TEXT NOT NULL,\n verified INTEGER NOT NULL DEFAULT 0,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS gt_otps (\n email TEXT PRIMARY KEY,\n code TEXT NOT NULL,\n expires_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS gt_sessions (\n session_id TEXT PRIMARY KEY,\n email TEXT NOT NULL,\n expires_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS gt_closed_trades (\n id TEXT PRIMARY KEY,\n timeframe TEXT NOT NULL,\n side TEXT NOT NULL,\n entry REAL NOT NULL,\n exit REAL NOT NULL,\n stop_loss REAL NOT NULL,\n tp1 REAL NOT NULL,\n tp2 REAL NOT NULL,\n result TEXT NOT NULL,\n pips REAL NOT NULL,\n profit_usd REAL NOT NULL,\n lot REAL NOT NULL,\n opened_at INTEGER NOT NULL,\n closed_at INTEGER NOT NULL\n )`,\n },\n { sql: `CREATE INDEX IF NOT EXISTS idx_trades_tf ON gt_closed_trades(timeframe, closed_at DESC)` },\n ]);\n initialized = true;\n}\n\n// ---------- password hashing ----------\nexport function generateSalt(): string {\n const bytes = new Uint8Array(16);\n crypto.getRandomValues(bytes);\n return [...bytes].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nexport async function hashPassword(password: string, salt: string): Promise {\n const enc = new TextEncoder();\n const keyMaterial = await crypto.subtle.importKey(\n \"raw\", enc.encode(password), { name: \"PBKDF2\" }, false, [\"deriveBits\"],\n );\n const bits = await crypto.subtle.deriveBits(\n { name: \"PBKDF2\", salt: enc.encode(salt), iterations: PBKDF2_ROUNDS, hash: \"SHA-256\" },\n keyMaterial, 256,\n );\n return [...new Uint8Array(bits)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nexport async function verifyPassword(password: string, salt: string, hash: string): Promise {\n const computed = await hashPassword(password, salt);\n // constant-time-ish compare\n if (computed.length !== hash.length) return false;\n let diff = 0;\n for (let i = 0; i < computed.length; i++) diff |= computed.charCodeAt(i) ^ hash.charCodeAt(i);\n return diff === 0;\n}\n\n// ---------- users ----------\nexport interface User {\n email: string;\n salt: string;\n hash: string;\n verified: boolean;\n createdAt: number;\n}\n\nexport async function getUser(email: string): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: \"SELECT * FROM gt_users WHERE email = ?\", args: [email] });\n const row = r.rows[0] as any;\n if (!row) return null;\n return { email: row.email, salt: row.salt, hash: row.hash, verified: !!row.verified, createdAt: row.created_at };\n}\n\nexport async function createUser(email: string, salt: string, hash: string): Promise {\n await initDb();\n await sqlite.execute({\n sql: \"INSERT INTO gt_users (email, salt, hash, verified, created_at) VALUES (?, ?, ?, 0, ?)\",\n args: [email, salt, hash, Date.now()],\n });\n}\n\nexport async function setUserVerified(email: string): Promise {\n await initDb();\n await sqlite.execute({ sql: \"UPDATE gt_users SET verified = 1 WHERE email = ?\", args: [email] });\n}\n\n// ---------- OTPs (auto-expire after 5 min) ----------\nexport async function saveOtp(email: string, code: string, expiresAfterMs = 5 * 60 * 1000): Promise {\n await initDb();\n await sqlite.execute({\n sql: \"INSERT INTO gt_otps (email, code, expires_at) VALUES (?, ?, ?) ON CONFLICT(email) DO UPDATE SET code=excluded.code, expires_at=excluded.expires_at\",\n args: [email, code, Date.now() + expiresAfterMs],\n });\n}\n\nexport async function getOtp(email: string): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: \"SELECT code, expires_at FROM gt_otps WHERE email = ?\", args: [email] });\n const row = r.rows[0] as any;\n if (!row) return null;\n if (Date.now() > row.expires_at) {\n await sqlite.execute({ sql: \"DELETE FROM gt_otps WHERE email = ?\", args: [email] });\n return null;\n }\n return row.code;\n}\n\nexport async function deleteOtp(email: string): Promise {\n await initDb();\n await sqlite.execute({ sql: \"DELETE FROM gt_otps WHERE email = ?\", args: [email] });\n}\n\n// ---------- sessions (auto-expire after 7 days) ----------\nexport async function createSession(email: string): Promise {\n await initDb();\n const sessionId = crypto.randomUUID();\n const expiresAt = Date.now() + 7 * 24 * 3600 * 1000;\n await sqlite.execute({\n sql: \"INSERT INTO gt_sessions (session_id, email, expires_at) VALUES (?, ?, ?)\",\n args: [sessionId, email, expiresAt],\n });\n return sessionId;\n}\n\nexport async function getSession(sessionId: string): Promise<{ email: string } | null> {\n await initDb();\n const r = await sqlite.execute({ sql: \"SELECT email, expires_at FROM gt_sessions WHERE session_id = ?\", args: [sessionId] });\n const row = r.rows[0] as any;\n if (!row) return null;\n if (Date.now() > row.expires_at) {\n await deleteSession(sessionId);\n return null;\n }\n return { email: row.email };\n}\n\nexport async function deleteSession(sessionId: string): Promise {\n await initDb();\n await sqlite.execute({ sql: \"DELETE FROM gt_sessions WHERE session_id = ?\", args: [sessionId] });\n}\n\n// ---------- backtest closed trades ----------\nexport interface ClosedTrade {\n id: string;\n timeframe: string;\n side: \"BUY\" | \"SELL\";\n entry: number;\n exit: number;\n stopLoss: number;\n tp1: number;\n tp2: number;\n result: \"SL\" | \"TP1\" | \"TP2\";\n pips: number;\n profitUsd: number;\n lot: number;\n openedAt: number;\n closedAt: number;\n}\n\nexport async function saveClosedTrade(t: ClosedTrade): Promise {\n await initDb();\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO gt_closed_trades\n (id, timeframe, side, entry, exit, stop_loss, tp1, tp2, result, pips, profit_usd, lot, opened_at, closed_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [t.id, t.timeframe, t.side, t.entry, t.exit, t.stopLoss, t.tp1, t.tp2, t.result, t.pips, t.profitUsd, t.lot, t.openedAt, t.closedAt],\n });\n}\n\nexport async function getClosedTrades(timeframe?: string): Promise {\n await initDb();\n const r = timeframe\n ? await sqlite.execute({ sql: \"SELECT * FROM gt_closed_trades WHERE timeframe = ? ORDER BY closed_at DESC\", args: [timeframe] })\n : await sqlite.execute(\"SELECT * FROM gt_closed_trades ORDER BY closed_at DESC\");\n return (r.rows as any[]).map((row) => ({\n id: row.id, timeframe: row.timeframe, side: row.side, entry: row.entry, exit: row.exit,\n stopLoss: row.stop_loss, tp1: row.tp1, tp2: row.tp2, result: row.result, pips: row.pips,\n profitUsd: row.profit_usd, lot: row.lot, openedAt: row.opened_at, closedAt: row.closed_at,\n }));\n}\n\nexport async function clearClosedTrades(): Promise {\n await initDb();\n await sqlite.execute(\"DELETE FROM gt_closed_trades\");\n}\n\nexport async function countClosedTrades(): Promise {\n await initDb();\n const r = await sqlite.execute(\"SELECT COUNT(*) as n FROM gt_closed_trades\");\n return (r.rows[0] as any).n;\n}\n",[],[152,225],"69e56382-5b2c-11f1-8ca8-ee650bb23af1","api.ts","69e56440-5b2c-11f1-8ca8-ee650bb23af1",7,["D",1780038173837],"// Market data layer for XAU/USD — verified working from Val Town.\n// Sources:\n// - Chart OHLC candles: Yahoo Finance (GC=F gold futures), normalized to spot\n// - Realtime price + indicators: TradingView Scanner (FOREXCOM:XAUUSD spot)\n// - Fallback spot price: gold-api.com\n// NOTE: Binance/PAXGUSDT is geo-blocked (HTTP 451) from Val Town infra, so the\n// PAXG path from the original spec is replaced by Yahoo futures + spread delta.\n\nimport type { Candle, RealtimeQuote, Timeframe } from \"./types.ts\";\n\nconst UA = \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120 Safari/537.36\";\n\n// ---- timeframe mapping (terminal tf -> yahoo range/interval) ----\nfunction yahooParams(tf: Timeframe): { range: string; interval: string } {\n switch (tf) {\n case \"1\": return { range: \"1d\", interval: \"1m\" };\n case \"5\": return { range: \"5d\", interval: \"5m\" };\n case \"15\": return { range: \"5d\", interval: \"15m\" };\n case \"60\": return { range: \"1mo\", interval: \"1h\" };\n case \"1D\": return { range: \"1y\", interval: \"1d\" };\n default: return { range: \"1mo\", interval: \"1h\" };\n }\n}\n\n// candle open-time bucket length in seconds (for cache-boundary bypass)\nfunction tfSeconds(tf: Timeframe): number {\n switch (tf) {\n case \"1\": return 60;\n case \"5\": return 300;\n case \"15\": return 900;\n case \"60\": return 3600;\n case \"1D\": return 86400;\n default: return 3600;\n }\n}\n\n// ---------- in-memory caches ----------\ninterface ChartCacheEntry { candles: Candle[]; boundary: number; }\nconst chartCache = new Map();\n\nlet quoteCache: { quote: RealtimeQuote; ts: number } | null = null;\n\n// ---------- realtime spot price (used for normalization + quote) ----------\nconst TV_FIELDS = [\n \"close\", \"change\", \"high\", \"low\",\n \"RSI\", \"EMA10\", \"EMA20\", \"EMA50\", \"EMA100\", \"EMA200\", \"SMA20\",\n \"ADX\", \"CCI20\", \"Stoch.K\", \"Stoch.D\", \"ATR\",\n \"MACD.macd\", \"MACD.signal\", \"Recommend.All\",\n];\n\nasync function fetchTradingView(): Promise {\n const url = `https://scanner.tradingview.com/symbol?symbol=FOREXCOM%3AXAUUSD&fields=${TV_FIELDS.join(\",\")}&no_404=true`;\n try {\n const r = await fetch(url, { headers: { \"User-Agent\": UA, Accept: \"application/json\" } });\n if (!r.ok) return null;\n const d = await r.json();\n if (typeof d.close !== \"number\") return null;\n return {\n price: d.close,\n change: d.change ?? 0,\n changePercent: d.close && d.change ? (d.change / (d.close - d.change)) * 100 : 0,\n high: d.high ?? d.close,\n low: d.low ?? d.close,\n rsi: d.RSI,\n ema10: d.EMA10, ema20: d.EMA20, ema50: d.EMA50, ema100: d.EMA100, ema200: d.EMA200,\n sma20: d.SMA20, adx: d.ADX, cci20: d.CCI20,\n stochK: d[\"Stoch.K\"], stochD: d[\"Stoch.D\"], atr: d.ATR,\n macd: d[\"MACD.macd\"], macdSignal: d[\"MACD.signal\"],\n recommendation: d[\"Recommend.All\"],\n };\n } catch {\n return null;\n }\n}\n\nasync function fetchGoldApiSpot(): Promise {\n try {\n const r = await fetch(\"https://api.gold-api.com/price/XAU\");\n if (!r.ok) return null;\n const d = await r.json();\n return typeof d.price === \"number\" ? d.price : null;\n } catch {\n return null;\n }\n}\n\n/** Realtime quote with indicators. Cached 1s to protect upstream IP. */\nexport async function getGoldRealtimePrice(): Promise {\n const now = Date.now();\n if (quoteCache && now - quoteCache.ts < 1000) return quoteCache.quote;\n\n let quote = await fetchTradingView();\n if (!quote) {\n const spot = await fetchGoldApiSpot();\n quote = {\n price: spot ?? 0,\n change: 0,\n changePercent: 0,\n high: spot ?? 0,\n low: spot ?? 0,\n };\n }\n quoteCache = { quote, ts: now };\n return quote;\n}\n\n/** Lightweight price-only probe for ultra-fast polling (500ms). */\nexport async function getGoldPriceOnly(): Promise<{ price: number; changePercent: number }> {\n const q = await getGoldRealtimePrice();\n return { price: q.price, changePercent: q.changePercent };\n}\n\n/**\n * Apply micro-fluctuations (-0.15..+0.15) to simulate a live ticker,\n * clamped within the day's high/low.\n */\nexport function applyWiggle(q: RealtimeQuote): number {\n const wiggle = (Math.random() - 0.5) * 0.3; // -0.15 .. +0.15\n let p = q.price + wiggle;\n if (q.high && p > q.high) p = q.high;\n if (q.low && p < q.low) p = q.low;\n return Math.round(p * 100) / 100;\n}\n\n// ---------- chart candles ----------\nasync function fetchYahooCandles(tf: Timeframe): Promise {\n const { range, interval } = yahooParams(tf);\n const url = `https://query1.finance.yahoo.com/v8/finance/chart/GC%3DF?range=${range}&interval=${interval}`;\n const r = await fetch(url, { headers: { \"User-Agent\": UA } });\n if (!r.ok) throw new Error(`Yahoo HTTP ${r.status}`);\n const data = await r.json();\n const result = data?.chart?.result?.[0];\n if (!result?.timestamp) throw new Error(\"Yahoo: no data\");\n const ts: number[] = result.timestamp;\n const q = result.indicators.quote[0];\n const candles: Candle[] = [];\n for (let i = 0; i < ts.length; i++) {\n const o = q.open[i], h = q.high[i], l = q.low[i], c = q.close[i];\n if (o == null || h == null || l == null || c == null) continue;\n candles.push({\n time: ts[i],\n open: o, high: h, low: l, close: c,\n volume: q.volume?.[i] ?? 0,\n });\n }\n return candles;\n}\n\n/**\n * Get normalized gold chart candles.\n * Yahoo GC=F is futures (carries a premium vs spot), so we shift the whole\n * series by the spread delta (live spot - last futures close) to align with\n * the FOREXCOM:XAUUSD spot price the rest of the terminal uses.\n */\nexport async function getGoldChartData(tf: Timeframe): Promise {\n const now = Math.floor(Date.now() / 1000);\n const bucket = tfSeconds(tf);\n const currentBoundary = Math.floor(now / bucket) * bucket;\n\n const cached = chartCache.get(tf);\n if (cached && cached.boundary === currentBoundary) {\n return cached.candles;\n }\n\n const [raw, quote] = await Promise.all([fetchYahooCandles(tf), getGoldRealtimePrice()]);\n\n // spread normalization\n let candles = raw;\n if (quote.price && raw.length) {\n const lastFutures = raw[raw.length - 1].close;\n const delta = quote.price - lastFutures;\n if (Math.abs(delta) > 0.01 && Math.abs(delta) < 200) {\n candles = raw.map((cd) => ({\n time: cd.time,\n open: round2(cd.open + delta),\n high: round2(cd.high + delta),\n low: round2(cd.low + delta),\n close: round2(cd.close + delta),\n volume: cd.volume,\n }));\n }\n }\n\n chartCache.set(tf, { candles, boundary: currentBoundary });\n return candles;\n}\n\nfunction round2(n: number): number {\n return Math.round(n * 100) / 100;\n}\n",[],[152,233],"85c6724e-5b2c-11f1-a562-ee650bb23af1","advanced_analysis.ts","85c67316-5b2c-11f1-a562-ee650bb23af1",9,["D",1780038220615],"// Smart Money Concepts + Price Action engine.\n// Pure functions over a closed-candle array. No network calls.\n\nimport type {\n Candle, CandlePattern, FVG, LiquiditySweep, OrderBlock,\n SMCAnalysis, StructureBreak, SwingPoint,\n} from \"./types.ts\";\n\n// ---- 1. Swing highs / lows (5-candle window: 2 left, center, 2 right) ----\nexport function findSwings(candles: Candle[]): SwingPoint[] {\n const swings: SwingPoint[] = [];\n for (let i = 2; i < candles.length - 2; i++) {\n const c = candles[i];\n const isHigh =\n c.high > candles[i - 1].high && c.high > candles[i - 2].high &&\n c.high > candles[i + 1].high && c.high > candles[i + 2].high;\n const isLow =\n c.low < candles[i - 1].low && c.low < candles[i - 2].low &&\n c.low < candles[i + 1].low && c.low < candles[i + 2].low;\n if (isHigh) swings.push({ index: i, time: c.time, price: c.high, type: \"high\" });\n if (isLow) swings.push({ index: i, time: c.time, price: c.low, type: \"low\" });\n }\n return swings;\n}\n\n// ---- 2. Structure breaks: BOS / CHoCH ----\nexport function findStructureBreaks(candles: Candle[], swings: SwingPoint[]): StructureBreak[] {\n const breaks: StructureBreak[] = [];\n let lastDirection: \"bullish\" | \"bearish\" | null = null;\n\n // track the most recent confirmed swing high & low as the candles advance\n for (let i = 0; i < candles.length; i++) {\n const close = candles[i].close;\n\n // most recent swing high/low that occurred strictly before candle i\n let activeHigh: SwingPoint | undefined;\n let activeLow: SwingPoint | undefined;\n for (const s of swings) {\n if (s.index >= i) break;\n if (s.type === \"high\") activeHigh = s;\n else activeLow = s;\n }\n\n if (activeHigh && close > activeHigh.price) {\n const direction = \"bullish\";\n const kind = lastDirection === \"bearish\" ? \"CHoCH\" : \"BOS\";\n breaks.push({ index: i, time: candles[i].time, price: activeHigh.price, kind, direction });\n lastDirection = direction;\n // prevent duplicate detection on the same swing: bump it out\n activeHigh.price = Infinity;\n } else if (activeLow && close < activeLow.price) {\n const direction = \"bearish\";\n const kind = lastDirection === \"bullish\" ? \"CHoCH\" : \"BOS\";\n breaks.push({ index: i, time: candles[i].time, price: activeLow.price, kind, direction });\n lastDirection = direction;\n activeLow.price = -Infinity;\n }\n }\n return breaks;\n}\n\n// ---- 3. Fair Value Gaps ----\nexport function findFVGs(candles: Candle[]): FVG[] {\n const fvgs: FVG[] = [];\n for (let i = 2; i < candles.length; i++) {\n const c1 = candles[i - 2], c3 = candles[i];\n // bullish FVG: 3rd low > 1st high\n if (c3.low > c1.high) {\n const fvg: FVG = {\n index: i - 1, time: candles[i - 1].time,\n top: c3.low, bottom: c1.high, direction: \"bullish\", mitigated: false,\n };\n for (let j = i + 1; j < candles.length; j++) {\n if (candles[j].low <= fvg.bottom) { fvg.mitigated = true; break; }\n }\n fvgs.push(fvg);\n } else if (c3.high < c1.low) {\n // bearish FVG: 3rd high < 1st low\n const fvg: FVG = {\n index: i - 1, time: candles[i - 1].time,\n top: c1.low, bottom: c3.high, direction: \"bearish\", mitigated: false,\n };\n for (let j = i + 1; j < candles.length; j++) {\n if (candles[j].high >= fvg.top) { fvg.mitigated = true; break; }\n }\n fvgs.push(fvg);\n }\n }\n return fvgs;\n}\n\n// ---- 4. Order Blocks ----\nexport function findOrderBlocks(candles: Candle[]): OrderBlock[] {\n const obs: OrderBlock[] = [];\n for (let i = 1; i < candles.length; i++) {\n const prev = candles[i - 1], cur = candles[i];\n const prevBody = Math.abs(prev.close - prev.open);\n const curBody = Math.abs(cur.close - cur.open);\n const curRange = cur.high - cur.low;\n const impulsive = curBody > prevBody * 1.8 || curRange > 4.5;\n if (!impulsive) continue;\n\n const bullishImpulse = cur.close > cur.open;\n // opposite-color candle immediately before the impulse\n if (bullishImpulse && prev.close < prev.open) {\n const ob: OrderBlock = {\n index: i - 1, time: prev.time,\n top: prev.high, bottom: prev.low, direction: \"bullish\", mitigated: false,\n };\n for (let j = i + 1; j < candles.length; j++) {\n if (candles[j].low <= ob.top && candles[j].low >= ob.bottom) { ob.mitigated = true; break; }\n }\n obs.push(ob);\n } else if (!bullishImpulse && prev.close > prev.open) {\n const ob: OrderBlock = {\n index: i - 1, time: prev.time,\n top: prev.high, bottom: prev.low, direction: \"bearish\", mitigated: false,\n };\n for (let j = i + 1; j < candles.length; j++) {\n if (candles[j].high >= ob.bottom && candles[j].high <= ob.top) { ob.mitigated = true; break; }\n }\n obs.push(ob);\n }\n }\n return obs;\n}\n\n// ---- 5. Liquidity sweeps (stop hunts) ----\nexport function findSweeps(candles: Candle[]): LiquiditySweep[] {\n const sweeps: LiquiditySweep[] = [];\n const lookback = 20;\n for (let i = lookback; i < candles.length; i++) {\n const window = candles.slice(i - lookback, i);\n const highestHigh = Math.max(...window.map((c) => c.high));\n const lowestLow = Math.min(...window.map((c) => c.low));\n const c = candles[i];\n // BSL swept: wick above prior high but closes back below it\n if (c.high > highestHigh && c.close < highestHigh) {\n sweeps.push({ index: i, time: c.time, price: c.high, kind: \"BSL\" });\n }\n // SSL swept: wick below prior low but closes back above it\n if (c.low < lowestLow && c.close > lowestLow) {\n sweeps.push({ index: i, time: c.time, price: c.low, kind: \"SSL\" });\n }\n }\n return sweeps;\n}\n\n// ---- 6. Candle patterns ----\nexport function findPatterns(candles: Candle[]): CandlePattern[] {\n const patterns: CandlePattern[] = [];\n for (let i = 1; i < candles.length; i++) {\n const c = candles[i], p = candles[i - 1];\n const range = c.high - c.low;\n if (range <= 0) continue;\n const body = Math.abs(c.close - c.open);\n const upperWick = c.high - Math.max(c.open, c.close);\n const lowerWick = Math.min(c.open, c.close) - c.low;\n\n // Hammer\n if (lowerWick >= range * 0.6 && body <= range * 0.3) {\n patterns.push({ index: i, time: c.time, name: \"Hammer (Búa)\", direction: \"bullish\" });\n } // Shooting Star\n else if (upperWick >= range * 0.6 && body <= range * 0.3) {\n patterns.push({ index: i, time: c.time, name: \"Shooting Star (Sao băng)\", direction: \"bearish\" });\n }\n\n // Engulfing\n const pBody = Math.abs(p.close - p.open);\n if (c.close > c.open && p.close < p.open && c.close >= p.open && c.open <= p.close && body > pBody) {\n patterns.push({ index: i, time: c.time, name: \"Bullish Engulfing (Nhấn chìm tăng)\", direction: \"bullish\" });\n } else if (c.close < c.open && p.close > p.open && c.open >= p.close && c.close <= p.open && body > pBody) {\n patterns.push({ index: i, time: c.time, name: \"Bearish Engulfing (Nhấn chìm giảm)\", direction: \"bearish\" });\n }\n\n // Inside Bar\n if (c.high < p.high && c.low > p.low) {\n patterns.push({ index: i, time: c.time, name: \"Inside Bar (Nén lò xo)\", direction: \"neutral\" });\n }\n }\n return patterns;\n}\n\nexport function analyzeAdvanced(candles: Candle[]): SMCAnalysis {\n const swings = findSwings(candles);\n // clone swings for break detection (it mutates prices)\n const swingsForBreaks = swings.map((s) => ({ ...s }));\n return {\n swings,\n structureBreaks: findStructureBreaks(candles, swingsForBreaks),\n fvgs: findFVGs(candles),\n orderBlocks: findOrderBlocks(candles),\n sweeps: findSweeps(candles),\n patterns: findPatterns(candles),\n };\n}\n",[],[152,241],"abdcfe30-5b2c-11f1-b2b2-ee650bb23af1","_test_api.ts","6e1916c4-5b2c-11f1-8af1-ee650bb23af1",12,["D",1780038284510],"import { getGoldChartData } from \"./api.ts\";\nimport { analyzeAdvanced } from \"./advanced_analysis.ts\";\nimport { analyzeSignals } from \"./signals.ts\";\n\nfor (const tf of [\"5\", \"15\", \"60\"] as const) {\n const candles = await getGoldChartData(tf);\n // analyze on closed candles only (drop the still-forming last candle)\n const closed = candles.slice(0, -1);\n const smc = analyzeAdvanced(closed);\n const sig = analyzeSignals(closed, tf);\n console.log(`\\n=== TF ${tf} (${closed.length} closed candles) ===`);\n console.log(`SMC: swings=${smc.swings.length} breaks=${smc.structureBreaks.length} fvg=${smc.fvgs.length} ob=${smc.orderBlocks.length} sweeps=${smc.sweeps.length} patterns=${smc.patterns.length}`);\n console.log(`Signal: ${sig.type} score=${sig.score} (buy=${sig.buyScore} sell=${sig.sellScore})`);\n console.log(` entry=${sig.entry} SL=${sig.stopLoss} TP1=${sig.takeProfit1} TP2=${sig.takeProfit2} RR1=${sig.riskRewardTp1} ATR=${sig.atr}`);\n console.log(` entryReason: ${sig.entryReason.slice(0, 120)}...`);\n}\nconsole.log(\"\\n--- ok ---\");\n",[],[152,249],"f6e53f8c-5b2c-11f1-ad82-ee650bb23af1",["D",1780038410242],[],[152,52,39],"f6e58154-5b2c-11f1-ad82-ee650bb23af1",["D",1780038410242],[170],[152,52],["D",1780038142906],[169,171,172,173,174,175,176,177,178,179],[152],["D",1780037818961],["D",1789441243316],{"_110":109,"_118":114},{"_110":109,"_111":112,"_113":114,"_19":67,"_115":116,"_117":31},{"_13":99,"_38":100,"_55":48,"_101":56,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":57,"_108":109},"ctx",{"_92":-5,"_137":305,"_306":307,"_308":309,"_310":31,"_311":31,"_312":31,"_313":155,"_314":-5,"_315":-7,"_316":-7,"_317":73,"_318":31,"_319":31,"_320":-5,"_321":31,"_322":31,"_323":31,"_324":-5},"ENV",{"_276":277,"_278":279,"_280":100,"_281":282,"_283":284,"_285":286,"_287":288,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304},"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 · v16