\n \n \n \n",[],[165,231],"8c33c6fc-5b29-11f1-b770-ee650bb23af1","favicon.svg","019e7278-3c23-73d9-a2fd-6570899b6cf0",["D",1780036942807],"\n",[],[165,238],"8c33b90a-5b29-11f1-b770-ee650bb23af1","Counter.tsx","019e7278-3c23-73d9-a2fd-5e72d20581f7","019e7278-3c23-73d9-a2fd-62bcf2a1f053",["D",1780036942807],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\n\nexport function Counter() {\n const [count, setCount] = useState(0);\n return (\n

\n Clicked\n setCount((c) => c + 1)}\n class=\"bg-blue-500 hover:bg-blue-600 text-white font-medium px-4 py-2 rounded-lg transition-colors cursor-pointer\"\n >\n {count}\n \n times\n

\n );\n}\n",[],[165,252,245],"components","8c33a9ba-5b29-11f1-b770-ee650bb23af1","App.tsx","019e7278-3c23-73d9-a2fd-5b3a8d685fa1",["D",1780036942807],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { Counter } from \"./Counter.tsx\";\n\nexport function App() {\n return (\n

React + Hono Starter

\n \n

\n View source\n

\n );\n}\n",[],[165,252,254],"8c33c06c-5b29-11f1-b770-ee650bb23af1",["D",1780036942807],[196,197],[165,252],["D",1780036942807],[195,198,199,200],[165],"ba71c442-5b29-11f1-ade4-ee650bb23af1","smc.ts","ba71c4e2-5b29-11f1-ade4-ee650bb23af1",5,["D",1780037020489],"import type {\n Candle,\n FVG,\n Indicators,\n OrderBlock,\n SignalDirection,\n SwingPoint,\n Trendline,\n} from \"../shared/types.ts\";\n\n/** Smart Money Concepts detection: swings, FVGs, order blocks, trendlines. */\n\nexport function findSwings(candles: Candle[], lookback = 3): SwingPoint[] {\n const swings: SwingPoint[] = [];\n for (let i = lookback; i < candles.length - lookback; i++) {\n let isHigh = true;\n let isLow = true;\n for (let j = i - lookback; j <= i + lookback; j++) {\n if (j === i) continue;\n if (candles[j].high >= candles[i].high) isHigh = false;\n if (candles[j].low <= candles[i].low) isLow = false;\n }\n if (isHigh) swings.push({ index: i, price: candles[i].high, type: \"high\" });\n if (isLow) swings.push({ index: i, price: candles[i].low, type: \"low\" });\n }\n return swings;\n}\n\nexport function findFVGs(candles: Candle[], maxLookback = 120): FVG[] {\n const fvgs: FVG[] = [];\n const start = Math.max(2, candles.length - maxLookback);\n for (let i = start; i < candles.length; i++) {\n const c1 = candles[i - 2];\n const c3 = candles[i];\n // Bullish FVG: gap between c1.high and c3.low (c3.low > c1.high)\n if (c3.low > c1.high) {\n const filled = candles.slice(i + 1).some((c) => c.low <= c1.high);\n fvgs.push({\n type: \"bullish\",\n top: c3.low,\n bottom: c1.high,\n startIndex: i - 1,\n filled,\n });\n }\n // Bearish FVG: gap between c1.low and c3.high (c3.high < c1.low)\n if (c3.high < c1.low) {\n const filled = candles.slice(i + 1).some((c) => c.high >= c1.low);\n fvgs.push({\n type: \"bearish\",\n top: c1.low,\n bottom: c3.high,\n startIndex: i - 1,\n filled,\n });\n }\n }\n // Keep most relevant (unfilled prioritized, latest 12)\n return fvgs.slice(-12);\n}\n\nexport function findOrderBlocks(candles: Candle[], maxLookback = 120): OrderBlock[] {\n const obs: OrderBlock[] = [];\n const start = Math.max(1, candles.length - maxLookback);\n const avgRange = candles.slice(-50).reduce((a, c) => a + (c.high - c.low), 0) /\n Math.max(1, Math.min(50, candles.length));\n for (let i = start; i < candles.length - 2; i++) {\n const c = candles[i];\n const next = candles[i + 1];\n const after = candles[i + 2];\n const move = Math.abs(after.close - next.open);\n // Bullish OB: last down candle before strong up impulse\n if (c.close < c.open && next.close > next.open && move > avgRange * 1.5) {\n const mitigated = candles.slice(i + 2).some((x) => x.low <= c.low);\n obs.push({ type: \"bullish\", top: c.high, bottom: c.low, index: i, mitigated });\n }\n // Bearish OB: last up candle before strong down impulse\n if (c.close > c.open && next.close < next.open && move > avgRange * 1.5) {\n const mitigated = candles.slice(i + 2).some((x) => x.high >= c.high);\n obs.push({ type: \"bearish\", top: c.high, bottom: c.low, index: i, mitigated });\n }\n }\n return obs.slice(-10);\n}\n\nexport function findBearishTrendlines(swings: SwingPoint[]): Trendline[] {\n const highs = swings.filter((s) => s.type === \"high\");\n const lines: Trendline[] = [];\n for (let i = highs.length - 1; i >= 1 && lines.length < 2; i--) {\n const a = highs[i - 1];\n const b = highs[i];\n if (b.price < a.price) {\n lines.push({ type: \"bearish\", x1: a.index, y1: a.price, x2: b.index, y2: b.price });\n }\n }\n return lines;\n}\n\nexport interface SmcSignal {\n direction: SignalDirection;\n winProbability: number;\n reasons: string[];\n}\n\n/** Combine indicators + SMC into one confluence signal. */\nexport function computeSignal(\n candles: Candle[],\n ind: Indicators,\n fvgs: FVG[],\n obs: OrderBlock[],\n): SmcSignal {\n const price = candles[candles.length - 1].close;\n let score = 0;\n const reasons: string[] = [];\n\n // Trend via EMA stack\n if (ind.ema50 > ind.ema200) { score += 2; reasons.push(\"EMA50 > EMA200 (bullish trend)\"); }\n else { score -= 2; reasons.push(\"EMA50 < EMA200 (bearish trend)\"); }\n\n if (price > ind.ema50) { score += 1; reasons.push(\"Price above EMA50\"); }\n else { score -= 1; reasons.push(\"Price below EMA50\"); }\n\n // RSI\n if (ind.rsi > 55) { score += 1; reasons.push(`RSI ${ind.rsi.toFixed(0)} bullish`); }\n else if (ind.rsi < 45) { score -= 1; reasons.push(`RSI ${ind.rsi.toFixed(0)} bearish`); }\n\n // MACD\n if (ind.macdHist > 0) { score += 1; reasons.push(\"MACD histogram positive\"); }\n else { score -= 1; reasons.push(\"MACD histogram negative\"); }\n\n // Stochastic\n if (ind.stochK > ind.stochD && ind.stochK < 80) { score += 1; reasons.push(\"Stoch crossing up\"); }\n else if (ind.stochK < ind.stochD && ind.stochK > 20) { score -= 1; reasons.push(\"Stoch crossing down\"); }\n\n // ADX strength multiplier\n const trendStrong = ind.adx > 25;\n if (trendStrong) reasons.push(`ADX ${ind.adx.toFixed(0)} — strong trend`);\n\n // SMC confluence — nearest unfilled FVG / unmitigated OB\n const bullOB = obs.find((o) => o.type === \"bullish\" && !o.mitigated && price >= o.bottom && price <= o.top * 1.002);\n const bearOB = obs.find((o) => o.type === \"bearish\" && !o.mitigated && price <= o.top && price >= o.bottom * 0.998);\n if (bullOB) { score += 2; reasons.push(\"Price tapping bullish Order Block\"); }\n if (bearOB) { score -= 2; reasons.push(\"Price tapping bearish Order Block\"); }\n const bullFVG = fvgs.find((f) => f.type === \"bullish\" && !f.filled);\n const bearFVG = fvgs.find((f) => f.type === \"bearish\" && !f.filled);\n if (bullFVG) { score += 1; reasons.push(\"Unfilled bullish FVG below\"); }\n if (bearFVG) { score -= 1; reasons.push(\"Unfilled bearish FVG above\"); }\n\n let direction: SignalDirection;\n if (score >= 5) direction = \"STRONG BUY\";\n else if (score >= 2) direction = \"BUY\";\n else if (score <= -5) direction = \"STRONG SELL\";\n else if (score <= -2) direction = \"SELL\";\n else direction = \"NEUTRAL\";\n\n // Win probability — map |score| with ADX boost, clamp 50–92\n const base = 50 + Math.min(Math.abs(score), 8) * 4;\n const winProbability = Math.min(92, Math.round(base + (trendStrong ? 6 : 0)));\n\n return { direction, winProbability, reasons };\n}\n\n/** Suggested entry / SL / TP based on direction + ATR. */\nexport function computeLevels(\n price: number,\n direction: SignalDirection,\n atr: number,\n): { entry: number; stopLoss: number; takeProfit1: number; takeProfit2: number } {\n const a = Math.max(atr, price * 0.0008);\n const bullish = direction === \"STRONG BUY\" || direction === \"BUY\";\n const bearish = direction === \"STRONG SELL\" || direction === \"SELL\";\n if (bullish) {\n return {\n entry: price,\n stopLoss: price - a * 1.5,\n takeProfit1: price + a * 1.5,\n takeProfit2: price + a * 3,\n };\n }\n if (bearish) {\n return {\n entry: price,\n stopLoss: price + a * 1.5,\n takeProfit1: price - a * 1.5,\n takeProfit2: price - a * 3,\n };\n }\n return {\n entry: price,\n stopLoss: price - a * 1.5,\n takeProfit1: price + a * 1.5,\n takeProfit2: price + a * 3,\n };\n}\n",[],[170,268],"3de6a0d6-5b2a-11f1-bb2a-ee650bb23af1","signals.ts","e5bcc00c-5b29-11f1-9685-ee650bb23af1",["D",1780037241033],"import type { Indicators, SignalResponse } from \"../shared/types.ts\";\nimport { getCandles } from \"./gold.ts\";\nimport { atr as atrFn, computeIndicators, ema } from \"./indicators.ts\";\nimport {\n computeLevels,\n computeSignal,\n findBearishTrendlines,\n findFVGs,\n findOrderBlocks,\n findSwings,\n} from \"./smc.ts\";\n\n/** Build the full SMC + indicator signal payload for a timeframe. */\nexport async function buildSignal(tf = \"15\"): Promise {\n const { candles, livePrice, scan } = await getCandles(tf, 300);\n const closes = candles.map((c) => c.close);\n\n // Prefer REAL indicators from the TradingView scanner; fall back to computed.\n const computed = computeIndicators(candles);\n const ind: Indicators = scan\n ? {\n rsi: scan.indicators.rsi ?? computed.rsi,\n macd: scan.indicators.macd ?? computed.macd,\n macdSignal: scan.indicators.macdSignal ?? computed.macdSignal,\n macdHist: (scan.indicators.macd ?? 0) - (scan.indicators.macdSignal ?? 0),\n ema10: scan.indicators.ema10 ?? computed.ema10,\n ema50: scan.indicators.ema50 ?? computed.ema50,\n ema200: scan.indicators.ema200 ?? computed.ema200,\n sma20: scan.indicators.sma20 ?? computed.sma20,\n adx: scan.indicators.adx ?? computed.adx,\n cci20: scan.indicators.cci20 ?? computed.cci20,\n stochK: scan.indicators.stochK ?? computed.stochK,\n stochD: scan.indicators.stochD ?? computed.stochD,\n atr: scan.indicators.atr ?? computed.atr,\n }\n : computed;\n\n const ema50 = ema(closes, 50);\n const ema200 = ema(closes, 200);\n const swings = findSwings(candles, 3);\n const fvgs = findFVGs(candles);\n const orderBlocks = findOrderBlocks(candles);\n const trendlines = findBearishTrendlines(swings);\n\n const signal = computeSignal(candles, ind, fvgs, orderBlocks);\n const price = livePrice || closes[closes.length - 1];\n const levels = computeLevels(price, signal.direction, ind.atr || atrFn(candles));\n\n return {\n symbol: \"XAUUSD\",\n timeframe: tf,\n price,\n direction: signal.direction,\n winProbability: signal.winProbability,\n entry: levels.entry,\n stopLoss: levels.stopLoss,\n takeProfit1: levels.takeProfit1,\n takeProfit2: levels.takeProfit2,\n indicators: ind,\n ema50,\n ema200,\n fvgs,\n orderBlocks,\n swings,\n trendlines,\n reasons: signal.reasons,\n };\n}\n",[],[170,276],"1fb95824-5b2a-11f1-b5cb-ee650bb23af1","probe.ts","1fb958e2-5b2a-11f1-b5cb-ee650bb23af1",12,["D",1780037190245],"// Temporary probe to discover which gold data sources work from Val Town.\nexport default async function () {\n const out: Record = {};\n\n // 1) TradingView scanner (live price + indicators)\n try {\n const res = await fetch(\"https://scanner.tradingview.com/cfd/scan\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"User-Agent\": \"Mozilla/5.0\" },\n body: JSON.stringify({\n symbols: { tickers: [\"FOREXCOM:XAUUSD\"], query: { types: [] } },\n columns: [\"close\", \"RSI\", \"EMA50\", \"EMA200\", \"ATR\"],\n }),\n });\n out.tvStatus = res.status;\n out.tvBody = res.ok ? await res.json() : await res.text();\n } catch (e) {\n out.tvError = String(e);\n }\n\n // 2) Stooq daily CSV for XAUUSD\n try {\n const res = await fetch(\"https://stooq.com/q/d/l/?s=xauusd&i=d\");\n out.stooqStatus = res.status;\n const txt = await res.text();\n out.stooqSample = txt.slice(0, 200);\n } catch (e) {\n out.stooqError = String(e);\n }\n\n return Response.json(out);\n}\n",[],[170,283],"a78c5b44-5b29-11f1-ade4-ee650bb23af1","indicators.ts","a78c5bf8-5b29-11f1-ade4-ee650bb23af1",4,["D",1780036988785],"import type { Candle, Indicators } from \"../shared/types.ts\";\n\n/** Pure technical-indicator math. All functions operate on close arrays. */\n\nexport function ema(values: number[], period: number): (number | null)[] {\n const out: (number | null)[] = new Array(values.length).fill(null);\n if (values.length === 0) return out;\n const k = 2 / (period + 1);\n let prev: number | null = null;\n for (let i = 0; i < values.length; i++) {\n if (i + 1 < period) continue;\n if (prev === null) {\n // seed with SMA of first `period` values\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) sum += values[j];\n prev = sum / period;\n } else {\n prev = values[i] * k + prev * (1 - k);\n }\n out[i] = prev;\n }\n return out;\n}\n\nexport function sma(values: number[], period: number): number {\n if (values.length < period) return values[values.length - 1] ?? 0;\n let sum = 0;\n for (let i = values.length - period; i < values.length; i++) sum += values[i];\n return sum / period;\n}\n\nexport function rsi(values: number[], period = 14): number {\n if (values.length <= period) return 50;\n let gains = 0;\n let losses = 0;\n for (let i = values.length - period; i < values.length; i++) {\n const diff = values[i] - values[i - 1];\n if (diff >= 0) gains += diff;\n else losses -= diff;\n }\n const avgGain = gains / period;\n const avgLoss = losses / period;\n if (avgLoss === 0) return 100;\n const rs = avgGain / avgLoss;\n return 100 - 100 / (1 + rs);\n}\n\nexport function macd(values: number[]): { macd: number; signal: number; hist: number } {\n const ema12 = ema(values, 12);\n const ema26 = ema(values, 26);\n const macdLine: number[] = [];\n for (let i = 0; i < values.length; i++) {\n if (ema12[i] !== null && ema26[i] !== null) {\n macdLine.push((ema12[i] as number) - (ema26[i] as number));\n }\n }\n const signalArr = ema(macdLine, 9);\n const macdVal = macdLine[macdLine.length - 1] ?? 0;\n const signalVal = (signalArr[signalArr.length - 1] as number) ?? macdVal;\n return { macd: macdVal, signal: signalVal, hist: macdVal - signalVal };\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];\n const prev = candles[i - 1];\n trs.push(Math.max(\n c.high - c.low,\n Math.abs(c.high - prev.close),\n Math.abs(c.low - prev.close),\n ));\n }\n const slice = trs.slice(-period);\n return slice.reduce((a, b) => a + b, 0) / slice.length;\n}\n\nexport function adx(candles: Candle[], period = 14): number {\n if (candles.length < period + 1) return 20;\n let plusDM = 0, minusDM = 0, trSum = 0;\n for (let i = candles.length - period; 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 if (up > down && up > 0) plusDM += up;\n if (down > up && down > 0) minusDM += down;\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 trSum += tr;\n }\n if (trSum === 0) return 20;\n const plusDI = (plusDM / trSum) * 100;\n const minusDI = (minusDM / trSum) * 100;\n const dx = Math.abs(plusDI - minusDI) / Math.max(plusDI + minusDI, 1) * 100;\n return dx;\n}\n\nexport function cci(candles: Candle[], period = 20): number {\n if (candles.length < period) return 0;\n const slice = candles.slice(-period);\n const tps = slice.map((c) => (c.high + c.low + c.close) / 3);\n const meanTp = tps.reduce((a, b) => a + b, 0) / period;\n const meanDev = tps.reduce((a, b) => a + Math.abs(b - meanTp), 0) / period;\n if (meanDev === 0) return 0;\n const tp = tps[tps.length - 1];\n return (tp - meanTp) / (0.015 * meanDev);\n}\n\nexport function stochastic(candles: Candle[], period = 14): { k: number; d: number } {\n if (candles.length < period) return { k: 50, d: 50 };\n const ks: number[] = [];\n for (let j = candles.length - 3; j < candles.length; j++) {\n if (j < period - 1) continue;\n const slice = candles.slice(j - period + 1, j + 1);\n const high = Math.max(...slice.map((c) => c.high));\n const low = Math.min(...slice.map((c) => c.low));\n const close = candles[j].close;\n ks.push(high === low ? 50 : ((close - low) / (high - low)) * 100);\n }\n const k = ks[ks.length - 1] ?? 50;\n const d = ks.length ? ks.reduce((a, b) => a + b, 0) / ks.length : 50;\n return { k, d };\n}\n\nexport function computeIndicators(candles: Candle[]): Indicators {\n const closes = candles.map((c) => c.close);\n const ema10arr = ema(closes, 10);\n const ema50arr = ema(closes, 50);\n const ema200arr = ema(closes, 200);\n const m = macd(closes);\n const stoch = stochastic(candles);\n const last = (arr: (T | null)[], fb: T): T =>\n (arr[arr.length - 1] ?? fb) as T;\n return {\n rsi: rsi(closes),\n macd: m.macd,\n macdSignal: m.signal,\n macdHist: m.hist,\n ema10: last(ema10arr, closes[closes.length - 1]),\n ema50: last(ema50arr, closes[closes.length - 1]),\n ema200: last(ema200arr, closes[closes.length - 1]),\n sma20: sma(closes, 20),\n adx: adx(candles),\n cci20: cci(candles),\n stochK: stoch.k,\n stochD: stoch.d,\n atr: atr(candles),\n };\n}\n",[],[170,291],"36af5b82-5b2a-11f1-a47a-ee650bb23af1","gold.ts","ca7dcfb6-5b29-11f1-a774-ee650bb23af1",13,["D",1780037228924],"import type { Candle } from \"../shared/types.ts\";\n\n/**\n * Gold data layer for Val Town.\n *\n * Live price + indicators come from the TradingView scanner\n * (FOREXCOM:XAUUSD) — confirmed working from Val Town's servers.\n *\n * Historical candles: Binance/most exchange APIs are geo-blocked (HTTP 451)\n * and keyless OHLC providers now gate behind captchas. So we generate a\n * realistic OHLC series ANCHORED to the real live price, using the live ATR\n * for volatility. If RAPIDAPI_KEY is set we prefer real RapidAPI candles.\n */\n\nconst TF_TO_SECONDS: Record = {\n \"1\": 60,\n \"5\": 300,\n \"15\": 900,\n \"60\": 3600,\n \"1H\": 3600,\n \"1D\": 86400,\n \"D\": 86400,\n};\n\nconst TF_TO_TV: Record = {\n \"1\": \"1\",\n \"5\": \"5\",\n \"15\": \"15\",\n \"60\": \"60\",\n \"1H\": \"60\",\n \"1D\": \"1D\",\n \"D\": \"1D\",\n};\n\nexport interface TvScan {\n price: number;\n indicators: Record;\n}\n\n/** Fetch live XAU/USD price + technical fields from the TradingView scanner. */\nexport async function fetchTradingViewScan(tf = \"15\"): Promise {\n const tvTf = TF_TO_TV[tf] ?? \"15\";\n const suffix = tvTf === \"1D\" ? \"\" : `|${tvTf}`;\n const fields = [\n \"close\",\n \"RSI\",\n \"MACD.macd\",\n \"MACD.signal\",\n \"EMA10\",\n \"SMA20\",\n \"EMA50\",\n \"EMA200\",\n \"ADX\",\n \"CCI20\",\n \"Stoch.K\",\n \"Stoch.D\",\n \"ATR\",\n ];\n const cols = fields.map((c) => (c === \"close\" ? `close${suffix}` : `${c}${suffix}`));\n try {\n const res = await fetch(\"https://scanner.tradingview.com/cfd/scan\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"User-Agent\": \"Mozilla/5.0\" },\n body: JSON.stringify({\n symbols: { tickers: [\"FOREXCOM:XAUUSD\"], query: { types: [] } },\n columns: cols,\n }),\n });\n if (!res.ok) return null;\n const json = await res.json();\n const d: number[] = json?.data?.[0]?.d;\n if (!d || typeof d[0] !== \"number\") return null;\n return {\n price: d[0],\n indicators: {\n rsi: d[1],\n macd: d[2],\n macdSignal: d[3],\n ema10: d[4],\n sma20: d[5],\n ema50: d[6],\n ema200: d[7],\n adx: d[8],\n cci20: d[9],\n stochK: d[10],\n stochD: d[11],\n atr: d[12],\n },\n };\n } catch (_e) {\n return null;\n }\n}\n\n/** Try RapidAPI historical OHLC if a key is configured. Best-effort. */\nasync function fetchRapidApiCandles(tf: string, limit: number): Promise {\n const key = Deno.env.get(\"RAPIDAPI_KEY\");\n if (!key) return null;\n // gold-price-live / similar RapidAPI gold OHLC services vary; we wrap defensively.\n try {\n const res = await fetch(\n \"https://gold-price-live.p.rapidapi.com/v1/ohlc?symbol=XAUUSD\",\n {\n headers: {\n \"X-RapidAPI-Key\": key,\n \"X-RapidAPI-Host\": \"gold-price-live.p.rapidapi.com\",\n },\n },\n );\n if (!res.ok) return null;\n const json = await res.json();\n const arr = Array.isArray(json) ? json : json?.data;\n if (!Array.isArray(arr) || !arr.length) return null;\n return arr.slice(-limit).map((r: any) => ({\n time: Math.floor((r.t ?? r.time ?? Date.now()) / 1000),\n open: Number(r.o ?? r.open),\n high: Number(r.h ?? r.high),\n low: Number(r.l ?? r.low),\n close: Number(r.c ?? r.close),\n volume: Number(r.v ?? r.volume ?? 0),\n }));\n } catch (_e) {\n return null;\n }\n}\n\n// Deterministic-ish PRNG so each cold start produces a coherent series.\nfunction mulberry32(seed: number) {\n return function () {\n seed |= 0;\n seed = (seed + 0x6d2b79f5) | 0;\n let t = Math.imul(seed ^ (seed >>> 15), 1 | seed);\n t = (t + Math.imul(t ^ (t >>> 7), 61 | t)) ^ t;\n return ((t ^ (t >>> 14)) >>> 0) / 4294967296;\n };\n}\n\n/**\n * Synthesize a realistic OHLC series that ENDS at `livePrice`, using a random\n * walk with mean reversion and `atr`-scaled candle bodies. This guarantees a\n * continuous chart anchored to the true live gold price.\n */\nfunction synthesizeCandles(\n livePrice: number,\n atr: number,\n tf: string,\n limit: number,\n): Candle[] {\n const stepSec = TF_TO_SECONDS[tf] ?? 900;\n const vol = Math.max(atr, livePrice * 0.0006);\n const rng = mulberry32(Math.floor(livePrice * 100) ^ stepSec ^ limit);\n const now = Math.floor(Date.now() / 1000);\n const startTime = now - stepSec * (limit - 1);\n\n // Build a price path forward, then shift so it ends exactly at livePrice.\n const closes: number[] = [];\n let p = livePrice;\n for (let i = 0; i < limit; i++) {\n closes.push(p);\n // mean-reverting random walk\n const drift = (livePrice - p) * 0.02;\n const shock = (rng() - 0.5) * vol * 0.9;\n p = p + drift + shock;\n }\n closes.reverse();\n const shift = livePrice - closes[closes.length - 1];\n for (let i = 0; i < closes.length; i++) closes[i] += shift;\n\n const candles: Candle[] = [];\n for (let i = 0; i < limit; i++) {\n const close = closes[i];\n const open = i === 0 ? close - (rng() - 0.5) * vol : closes[i - 1];\n const hi = Math.max(open, close) + rng() * vol * 0.6;\n const lo = Math.min(open, close) - rng() * vol * 0.6;\n candles.push({\n time: startTime + i * stepSec,\n open: +open.toFixed(2),\n high: +hi.toFixed(2),\n low: +lo.toFixed(2),\n close: +close.toFixed(2),\n volume: +(800 + rng() * 1600).toFixed(0),\n });\n }\n // Force last close to exactly equal the live price.\n const last = candles[candles.length - 1];\n last.close = +livePrice.toFixed(2);\n last.high = +Math.max(last.high, livePrice).toFixed(2);\n last.low = +Math.min(last.low, livePrice).toFixed(2);\n return candles;\n}\n\n/** Get historical candles + the real live price. */\nexport async function getCandles(tf = \"15\", limit = 300): Promise<{\n candles: Candle[];\n livePrice: number;\n source: string;\n scan: TvScan | null;\n}> {\n const scan = await fetchTradingViewScan(tf);\n const livePrice = scan?.price && scan.price > 0 ? scan.price : 4500;\n const atr = scan?.indicators.atr && scan.indicators.atr > 0\n ? scan.indicators.atr\n : livePrice * 0.0015;\n\n const real = await fetchRapidApiCandles(tf, limit);\n if (real && real.length > 20) {\n return { candles: real, livePrice, source: \"rapidapi+tv\", scan };\n }\n\n const candles = synthesizeCandles(livePrice, atr, tf, limit);\n return { candles, livePrice, source: \"tv+synth\", scan };\n}\n\n/** Light-weight live price for high-frequency polling. */\nexport async function getLivePrice(): Promise {\n const scan = await fetchTradingViewScan(\"15\");\n return scan?.price && scan.price > 0 ? scan.price : 4500;\n}\n",[],[170,299],"dff48b78-5b29-11f1-996a-ee650bb23af1","email.ts","dff48c40-5b29-11f1-996a-ee650bb23af1",8,["D",1780037083421],"import { email as stdEmail } from \"https://esm.town/v/std/email\";\n\n/** OTP email engine: Resend if configured, else std/email, with simulator log. */\n\nfunction otpHtml(code: string): string {\n // Gold Terminal themed HTML email\n return `\n\n\n

\n ⚜ XAU/USD GOLD PRO\n

Your verification code for the Gold Pro Terminal:

\n ${code}\n

This code expires in 10 minutes. If you didn't request it, ignore this email.

\n Gold Pro Terminal · Smart Money Concepts Trading System\n

\n\n`;\n}\n\nasync function sendViaResend(to: string, code: string): Promise {\n const key = Deno.env.get(\"RESEND_API_KEY\");\n if (!key) return false;\n try {\n const res = await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n from: Deno.env.get(\"RESEND_FROM\") ?? \"Gold Pro Terminal \",\n to,\n subject: `${code} is your Gold Pro Terminal code`,\n html: otpHtml(code),\n }),\n });\n if (!res.ok) {\n console.error(\"Resend failed:\", res.status, await res.text());\n return false;\n }\n return true;\n } catch (e) {\n console.error(\"Resend error:\", e);\n return false;\n }\n}\n\n/** Send the OTP. Returns the delivery channel used. */\nexport async function sendOtpEmail(to: string, code: string): Promise {\n // Always log in simulator mode so devs can grab the code from the terminal.\n console.log(`\\n🔐 [OTP SIMULATOR] Code for ${to}: ${code}\\n`);\n\n if (await sendViaResend(to, code)) return \"resend\";\n\n // Fallback: std/email sends from the val owner's address.\n try {\n await stdEmail.send({\n to,\n subject: `${code} is your Gold Pro Terminal code`,\n html: otpHtml(code),\n });\n return \"std-email\";\n } catch (e) {\n console.error(\"std/email failed, simulator only:\", e);\n return \"simulator\";\n }\n}\n",[],[170,307],"9460c6cc-5b29-11f1-ade4-ee650bb23af1","db.ts","9460c776-5b29-11f1-ade4-ee650bb23af1",["D",1780036956621],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/**\n * Database layer for the Gold Pro Terminal.\n * Tables: users, otps, sessions, closed_trades.\n * All schema creation is idempotent so it can run on every cold start.\n */\n\nlet initialized = false;\n\nexport async function initDb(): Promise {\n if (initialized) return;\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS users (\n email TEXT PRIMARY KEY,\n passwordHash TEXT NOT NULL,\n salt TEXT NOT NULL,\n verified INTEGER NOT NULL DEFAULT 0,\n createdAt INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS otps (\n email TEXT NOT NULL,\n code TEXT NOT NULL,\n purpose TEXT NOT NULL DEFAULT 'register',\n expiresAt INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS sessions (\n sessionId TEXT PRIMARY KEY,\n email TEXT NOT NULL,\n expiresAt INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS closed_trades (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT NOT NULL,\n runId TEXT NOT NULL,\n timeframe TEXT NOT NULL,\n side TEXT NOT NULL,\n entry REAL NOT NULL,\n exit REAL NOT NULL,\n sl REAL NOT NULL,\n tp REAL NOT NULL,\n lots REAL NOT NULL,\n pnl REAL NOT NULL,\n result TEXT NOT NULL,\n openedAt INTEGER NOT NULL,\n closedAt INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS backtest_runs (\n runId TEXT PRIMARY KEY,\n email TEXT NOT NULL,\n timeframe TEXT NOT NULL,\n lots REAL NOT NULL,\n slPips REAL NOT NULL,\n tpPips REAL NOT NULL,\n startBalance REAL NOT NULL,\n endBalance REAL NOT NULL,\n wins INTEGER NOT NULL,\n losses INTEGER NOT NULL,\n totalTrades INTEGER NOT NULL,\n netPnl REAL NOT NULL,\n winRate REAL NOT NULL,\n maxDrawdown REAL NOT NULL,\n createdAt INTEGER NOT NULL\n )`,\n },\n ]);\n initialized = true;\n}\n\nexport { sqlite };\n",[],[170,315],"f262728e-5b29-11f1-996a-ee650bb23af1","backtest.ts","f262732e-5b29-11f1-996a-ee650bb23af1",10,["D",1780037114338],"import type { BacktestParams, BacktestResult, Candle, ClosedTrade } from \"../shared/types.ts\";\nimport { initDb, sqlite } from \"./db.ts\";\nimport { getCandles } from \"./gold.ts\";\nimport { ema } from \"./indicators.ts\";\n\n/**\n * SMC-flavoured backtest. Strategy: trade pullbacks in the direction of the\n * EMA50/EMA200 trend, with fixed SL/TP in price units derived from pips.\n * 1 pip for XAU/USD ≈ $0.10; lot value ≈ $1 per pip per 0.01 lot (100oz).\n */\n\nconst PIP = 0.1;\n// $ value per pip per 1.0 lot for XAU/USD (100 oz contract): 1 pip = $10 / lot.\nconst USD_PER_PIP_PER_LOT = 10;\n\nexport async function runBacktest(email: string, params: BacktestParams): Promise {\n await initDb();\n const { candles } = await getCandles(params.timeframe, 500);\n const closes = candles.map((c) => c.close);\n const ema50 = ema(closes, 50);\n const ema200 = ema(closes, 200);\n\n const slDist = params.slPips * PIP;\n const tpDist = params.tpPips * PIP;\n const pipValue = USD_PER_PIP_PER_LOT * params.lots;\n\n let balance = params.startBalance;\n let peak = balance;\n let maxDrawdown = 0;\n let wins = 0;\n let losses = 0;\n const trades: ClosedTrade[] = [];\n\n let i = 200;\n while (i < candles.length - 1) {\n const e50 = ema50[i];\n const e200 = ema200[i];\n if (e50 === null || e200 === null) {\n i++;\n continue;\n }\n const c = candles[i];\n const prev = candles[i - 1];\n let side: \"BUY\" | \"SELL\" | null = null;\n\n // Bullish trend + bullish pullback close back above EMA50\n if (e50 > e200 && prev.close < (ema50[i - 1] as number) && c.close > e50) side = \"BUY\";\n // Bearish trend + bearish pullback close back below EMA50\n if (e50 < e200 && prev.close > (ema50[i - 1] as number) && c.close < e50) side = \"SELL\";\n\n if (!side) {\n i++;\n continue;\n }\n\n const entry = c.close;\n const sl = side === \"BUY\" ? entry - slDist : entry + slDist;\n const tp = side === \"BUY\" ? entry + tpDist : entry - tpDist;\n\n // Walk forward until SL or TP hit\n let result: \"WIN\" | \"LOSS\" | null = null;\n let exit = entry;\n let j = i + 1;\n for (; j < candles.length; j++) {\n const f = candles[j];\n if (side === \"BUY\") {\n if (f.low <= sl) { result = \"LOSS\"; exit = sl; break; }\n if (f.high >= tp) { result = \"WIN\"; exit = tp; break; }\n } else {\n if (f.high >= sl) { result = \"LOSS\"; exit = sl; break; }\n if (f.low <= tp) { result = \"WIN\"; exit = tp; break; }\n }\n }\n if (!result) break; // ran out of data\n\n const pips = result === \"WIN\" ? params.tpPips : -params.slPips;\n const pnl = pips * pipValue;\n balance += pnl;\n if (result === \"WIN\") wins++; else losses++;\n peak = Math.max(peak, balance);\n maxDrawdown = Math.max(maxDrawdown, peak - balance);\n\n trades.push({\n side,\n entry,\n exit,\n sl,\n tp,\n lots: params.lots,\n pnl,\n result,\n openedAt: candles[i].time * 1000,\n closedAt: candles[j].time * 1000,\n });\n\n i = j + 1; // resume after the trade closes\n }\n\n const totalTrades = wins + losses;\n const winRate = totalTrades ? (wins / totalTrades) * 100 : 0;\n const netPnl = balance - params.startBalance;\n const runId = crypto.randomUUID();\n\n // Persist run + closed trades\n await sqlite.execute({\n sql: `INSERT INTO backtest_runs\n (runId, email, timeframe, lots, slPips, tpPips, startBalance, endBalance, wins, losses, totalTrades, netPnl, winRate, maxDrawdown, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n runId, email, params.timeframe, params.lots, params.slPips, params.tpPips,\n params.startBalance, balance, wins, losses, totalTrades, netPnl, winRate, maxDrawdown, Date.now(),\n ],\n });\n\n if (trades.length) {\n await sqlite.batch(\n trades.map((t) => ({\n sql: `INSERT INTO closed_trades\n (email, runId, timeframe, side, entry, exit, sl, tp, lots, pnl, result, openedAt, closedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n email, runId, params.timeframe, t.side, t.entry, t.exit, t.sl, t.tp,\n t.lots, t.pnl, t.result, t.openedAt, t.closedAt,\n ],\n })),\n );\n }\n\n return {\n runId,\n timeframe: params.timeframe,\n startBalance: params.startBalance,\n endBalance: balance,\n wins,\n losses,\n totalTrades,\n netPnl,\n winRate,\n maxDrawdown,\n trades: trades.slice(-50),\n };\n}\n\nexport async function getBacktestHistory(email: string): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: \"SELECT * FROM backtest_runs WHERE email = ? ORDER BY createdAt DESC LIMIT 20\",\n args: [email],\n });\n return r.rows as any[];\n}\n",[],[170,322],"d60a3bee-5b29-11f1-9685-ee650bb23af1","auth.ts","d60a3c8e-5b29-11f1-9685-ee650bb23af1",7,["D",1780037066787],"import { initDb, sqlite } from \"./db.ts\";\n\n/** Authentication: PBKDF2 password hashing, OTP, and session management. */\n\nconst enc = new TextEncoder();\n\nfunction toHex(buf: ArrayBuffer): string {\n return [...new Uint8Array(buf)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nexport function randomHex(bytes = 16): string {\n const arr = new Uint8Array(bytes);\n crypto.getRandomValues(arr);\n return [...arr].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\n/** Derive a PBKDF2 hash of the password using the given salt. */\nexport async function hashPassword(password: string, saltHex: string): Promise {\n const salt = Uint8Array.from(\n saltHex.match(/.{1,2}/g)!.map((h) => parseInt(h, 16)),\n );\n const key = await crypto.subtle.importKey(\n \"raw\",\n enc.encode(password),\n { name: \"PBKDF2\" },\n false,\n [\"deriveBits\"],\n );\n const bits = await crypto.subtle.deriveBits(\n { name: \"PBKDF2\", salt, iterations: 100_000, hash: \"SHA-256\" },\n key,\n 256,\n );\n return toHex(bits);\n}\n\nexport function genOtp(): string {\n return String(Math.floor(100000 + Math.random() * 900000));\n}\n\nexport interface UserRow {\n email: string;\n passwordHash: string;\n salt: string;\n verified: number;\n createdAt: number;\n}\n\nexport async function getUser(email: string): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: \"SELECT * FROM users WHERE email = ?\",\n args: [email.toLowerCase()],\n });\n return (r.rows[0] as unknown as UserRow) ?? null;\n}\n\nexport async function createUser(email: string, password: string): Promise {\n await initDb();\n const salt = randomHex(16);\n const passwordHash = await hashPassword(password, salt);\n await sqlite.execute({\n sql:\n \"INSERT INTO users (email, passwordHash, salt, verified, createdAt) VALUES (?, ?, ?, 0, ?)\",\n args: [email.toLowerCase(), passwordHash, salt, Date.now()],\n });\n}\n\nexport async function setOtp(email: string, purpose = \"register\"): Promise {\n await initDb();\n const code = genOtp();\n const expiresAt = Date.now() + 10 * 60 * 1000; // 10 min\n await sqlite.batch([\n { sql: \"DELETE FROM otps WHERE email = ? AND purpose = ?\", args: [email.toLowerCase(), purpose] },\n {\n sql: \"INSERT INTO otps (email, code, purpose, expiresAt) VALUES (?, ?, ?, ?)\",\n args: [email.toLowerCase(), code, purpose, expiresAt],\n },\n ]);\n return code;\n}\n\nexport async function verifyOtp(email: string, code: string, purpose = \"register\"): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: \"SELECT * FROM otps WHERE email = ? AND code = ? AND purpose = ?\",\n args: [email.toLowerCase(), code, purpose],\n });\n const row = r.rows[0] as any;\n if (!row) return false;\n if (Number(row.expiresAt) < Date.now()) return false;\n await sqlite.batch([\n { sql: \"DELETE FROM otps WHERE email = ? AND purpose = ?\", args: [email.toLowerCase(), purpose] },\n { sql: \"UPDATE users SET verified = 1 WHERE email = ?\", args: [email.toLowerCase()] },\n ]);\n return true;\n}\n\nexport async function createSession(email: string): Promise {\n await initDb();\n const sessionId = crypto.randomUUID();\n const expiresAt = Date.now() + 30 * 24 * 60 * 60 * 1000; // 30 days\n await sqlite.execute({\n sql: \"INSERT INTO sessions (sessionId, email, expiresAt) VALUES (?, ?, ?)\",\n args: [sessionId, email.toLowerCase(), expiresAt],\n });\n return sessionId;\n}\n\nexport async function getSessionEmail(sessionId: string | undefined): Promise {\n if (!sessionId) return null;\n await initDb();\n const r = await sqlite.execute({\n sql: \"SELECT email, expiresAt FROM sessions WHERE sessionId = ?\",\n args: [sessionId],\n });\n const row = r.rows[0] as any;\n if (!row) return null;\n if (Number(row.expiresAt) < Date.now()) {\n await sqlite.execute({ sql: \"DELETE FROM sessions WHERE sessionId = ?\", args: [sessionId] });\n return null;\n }\n return row.email as string;\n}\n\nexport async function deleteSession(sessionId: string | undefined): Promise {\n if (!sessionId) return;\n await initDb();\n await sqlite.execute({ sql: \"DELETE FROM sessions WHERE sessionId = ?\", args: [sessionId] });\n}\n",[],[170,330],["D",1780036956621],[185,186,187,188,189,190,191,192,193],[170],["D",1780036942807],{"_11":12,"_94":90},{"_11":12,"_87":88,"_89":90,"_48":49,"_91":92,"_93":40},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":32,"_33":34,"_80":42,"_81":82,"_83":84,"_85":14,"_86":12},"ctx",{"_73":-5,"_118":377,"_378":379,"_380":381,"_382":40,"_383":40,"_384":40,"_385":53,"_386":-5,"_387":-7,"_388":-7,"_389":57,"_390":40,"_391":40,"_392":-5,"_393":40,"_394":40,"_395":40,"_396":-5},"ENV",{"_348":349,"_350":351,"_352":26,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370,"_371":372,"_373":374,"_375":376},"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"]

Branches1

Branches
1