[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_253":254,"_255":256},"routes/_app.x.$handle.$name",{"_101":100,"_38":50,"_109":91,"_33":103,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_26":-5,"_120":-5,"_121":-5,"_122":31,"_123":124,"_125":64,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_48":49,"_38":50,"_43":51,"_52":-5,"_53":31,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":31},"version",15,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","e70a73a1-ad82-4fee-a65d-940e4b61e149","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":26,"_40":42,"_43":44,"_45":14,"_46":47,"_30":31},"previous",{"_36":37,"_38":34,"_39":26,"_40":41},"deleted",false,"deletedHere","path","README.md","latestPath","fileId","54803b52-544c-11f1-acbb-ee650bb23af1","name","fileType","content","# 🤖 BotTrader2 — High-Frequency Binance Testnet Trading Bot\n\nA professional-grade high-frequency scalping bot for Binance Spot Testnet using **VSA (Volume Spread Analysis)** and **Liquidity Grab** strategies.\n\n## Architecture\n\n```mermaid\ngraph TD\n A[main.ts - HTTP Server] --> B[strategy.ts - Market Scanner]\n A --> C[dashboard.tsx - Live UI]\n A --> D[telegram.ts - Alerts]\n B --> E[exchange.ts - CCXT Binance]\n B --> F[indicators.ts - RSI/VSA/Liquidity]\n E --> G[Binance Testnet API]\n D --> H[Telegram Bot]\n B --> I[types.ts - Type Definitions]\n```\n\n## Strategy\n\n1. **Liquidity Filter**: Only trades pairs with 24h volume > 500,000 USDT\n2. **VSA Volume Spike**: Current candle volume must be > 1.5x the 10-candle average\n3. **Liquidity Grab**: Detects price wicks below recent support followed by recovery\n4. **RSI Reversal**: RSI(7) must be reversing from oversold (< 30) territory\n5. **Timeframe**: 5-minute candles for fast sniping\n\n## Trading Parameters\n\n| Parameter | Value |\n|-----------|-------|\n| Position Size | Balance / 50 |\n| Max Concurrent | 50 trades |\n| Take Profit | 0.7% |\n| Stop Loss | 0.7% |\n| Scan Interval | 15 seconds |\n| Monitor Interval | 5 seconds |\n\n## API Endpoints\n\n| Endpoint | Method | Description |\n|----------|--------|-------------|\n| `/` | GET | Live dashboard (auto-refreshes) |\n| `/start` | POST | Start the bot |\n| `/stop` | POST | Stop the bot |\n| `/status` | GET | Bot status JSON |\n| `/trades` | GET | Active & completed trades |\n| `/source` | GET | View source code |\n\n## Telegram Reports\n\n- **Instant BUY/SELL alerts** with RSI, Volume data, TP/SL levels\n- **15-minute summary** with Active Trades, PnL, Capital Utilization, Daily Count\n\n## Safety\n\n- Runs on **Binance Testnet** only (sandbox mode)\n- Built-in retry mechanism for rate limits and network errors\n- Geographic restriction handling via CCXT headers\n","# 🤖 BotTrader2 — High-Frequency Binance Testnet Trading Bot\n\nA professional-grade high-frequency scalping bot for **Binance Spot Testnet** using **VSA (Volume Spread Analysis)** and **Liquidity Grab** strategies with real-time Telegram alerts.\n\n## Architecture\n\n```mermaid\ngraph TD\n A[main.ts — HTTP Server + Bot Engine] --> B[strategy.ts — Market Scanner & Execution]\n A --> C[dashboard.tsx — Live Web Dashboard]\n A --> D[telegram.ts — Alerts & Reports]\n B --> E[exchange.ts — CCXT + Retry + Anti-Block]\n B --> F[indicators.ts — RSI / VSA / Liquidity Grab]\n E --> G[Binance Testnet API]\n D --> H[Telegram Bot API]\n I[config.ts — All Parameters] --> A\n J[types.ts — TypeScript Interfaces] --> B\n```\n\n## Strategy\n\n| Step | Filter | Description |\n|------|--------|-------------|\n| 1 | **Liquidity Filter** | Only pairs with 24h volume > 500,000 USDT |\n| 2 | **VSA Volume Spike** | Current 5m candle volume > 1.5× average of last 10 candles |\n| 3 | **Liquidity Grab** | Price wicked below recent support then recovered |\n| 4 | **RSI Reversal** | RSI(7) reversing from oversold territory (< 30) |\n| 5 | **Entry** | Market buy with balance/50 position sizing |\n| 6 | **Exit** | Auto-sell at 0.7% TP or 0.7% SL |\n\n## Trading Parameters\n\n| Parameter | Value |\n|-----------|-------|\n| Position Size | Balance ÷ 50 |\n| Max Concurrent | 50 trades |\n| Take Profit | 0.7% |\n| Stop Loss | 0.7% |\n| Scan Interval | 15 seconds |\n| TP/SL Monitor | 5 seconds |\n| Telegram Summary | Every 15 minutes |\n\n## API Endpoints\n\n| Endpoint | Method | Description |\n|----------|--------|-------------|\n| `/` | GET | Live dashboard (auto-refreshes every 15s) |\n| `/start` | POST | Start the bot |\n| `/stop` | POST | Stop the bot |\n| `/status` | GET | Bot status JSON |\n| `/trades` | GET | Active & completed trades JSON |\n| `/test-connection` | GET | Test Binance connectivity |\n| `/source` | GET | View source code |\n\n## Telegram Reports\n\n- 🟢 **Instant BUY alerts** — Price, Qty, RSI, Volume Ratio, TP/SL levels\n- 🔴 **Instant SELL alerts** — Entry/Exit, PnL, Reason (TP/SL)\n- 📊 **15-min summary** — Active Trades, Total PnL, Capital Utilization %, Daily Count\n\n## ⚠️ Geo-Restriction Note\n\nBinance Testnet (`testnet.binance.vision`) blocks requests from many cloud server IPs with HTTP 451. If you see this error:\n\n1. Set the `HTTPS_PROXY` environment variable to a residential proxy URL\n2. The bot will automatically route traffic through the proxy\n3. All bot logic (strategy, execution, monitoring, Telegram) is fully operational\n\n## Files\n\n| File | Purpose |\n|------|---------|\n| `config.ts` | Credentials, trading params, timing, retry settings |\n| `types.ts` | TypeScript interfaces (ActiveTrade, BotState, etc.) |\n| `exchange.ts` | CCXT Binance init, sandbox mode, retry with backoff |\n| `indicators.ts` | RSI(7), VSA Volume Spike, Liquidity Grab detection |\n| `strategy.ts` | Market scanner, signal analysis, buy/sell execution |\n| `telegram.ts` | Buy/Sell/Summary Telegram message formatting |\n| `dashboard.tsx` | Server-rendered React dashboard with Twind |\n| `main.ts` | Hono HTTP server, bot loop orchestration |\n","createdAt",["D",1779282634639],"branchVersion","branchId","efeb229c-544b-11f1-873b-ee650bb23af1","id","efea529a-544b-11f1-873b-ee650bb23af1","BotTrader2",["D",1779282054957],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","HF Binance Testnet trading bot - VSA & Liquidity strategy","imageUrl","f7c39efd-b701-4856-917d-f49bb917ae69","pinnedFileId","47dd1924-544c-11f1-8b35-ee650bb23af1","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e4579-0dda-73a9-a074-6ecfb986fe33","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_101":100,"_108":103},"org",{"_101":100,"_102":103,"_104":103,"_19":60,"_105":106,"_107":31},"branch",{"_13":14,"_38":91,"_48":47,"_92":49,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":50,"_99":100},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gazasnip11","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_48":49,"_38":50,"_43":249,"_52":-5,"_53":31,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":250,"_86":251,"_88":252,"_90":31},"tree",[212,213,214,215,216,217,218,219,220],"files",[212,213,214,215,216,217,218,219,220],"counts",{"_202":68,"_203":190,"_204":68,"_205":206,"_207":208},"contents",[130,131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_48":199,"_38":34,"_36":37,"_142":-5,"_46":47,"_45":14,"_144":64,"_43":200,"_13":190,"_39":26,"_40":42,"_30":31,"_148":-5,"_33":201},{"_48":193,"_38":194,"_36":195,"_142":-5,"_46":47,"_45":190,"_144":64,"_43":196,"_13":68,"_39":146,"_40":197,"_30":31,"_148":-5,"_33":198},{"_48":185,"_38":186,"_36":187,"_142":-5,"_46":47,"_45":188,"_144":64,"_43":189,"_13":190,"_39":146,"_40":191,"_30":31,"_148":-5,"_33":192},{"_48":178,"_38":179,"_36":180,"_142":-5,"_46":47,"_45":181,"_144":64,"_43":182,"_13":143,"_39":146,"_40":183,"_30":31,"_148":-5,"_33":184},{"_48":171,"_38":172,"_36":173,"_142":-5,"_46":47,"_45":174,"_144":64,"_43":175,"_13":68,"_39":146,"_40":176,"_30":31,"_148":-5,"_33":177},{"_48":164,"_38":165,"_36":62,"_142":-5,"_46":47,"_45":166,"_144":64,"_43":167,"_13":143,"_39":168,"_40":169,"_30":31,"_148":-5,"_33":170},{"_48":157,"_38":158,"_36":159,"_142":-5,"_46":47,"_45":160,"_144":64,"_43":161,"_13":68,"_39":146,"_40":162,"_30":31,"_148":-5,"_33":163},{"_48":150,"_38":151,"_36":152,"_142":-5,"_46":47,"_45":153,"_144":64,"_43":154,"_13":68,"_39":146,"_40":155,"_30":31,"_148":-5,"_33":156},{"_48":139,"_38":140,"_36":141,"_142":-5,"_46":47,"_45":143,"_144":64,"_43":145,"_13":68,"_39":146,"_40":147,"_30":31,"_148":-5,"_33":149},"fc38d74c-544b-11f1-8a21-ee650bb23af1","types.ts","fc38d814-544b-11f1-8a21-ee650bb23af1","parentId",2,"latest",["D",1779282075594],"script","export interface ActiveTrade {\n id: string;\n symbol: string;\n entryPrice: number;\n quantity: number;\n costUsdt: number;\n entryTime: number;\n takeProfitPrice: number;\n stopLossPrice: number;\n rsiAtEntry: number;\n volumeRatio: number;\n}\n\nexport interface TradeResult {\n symbol: string;\n entryPrice: number;\n exitPrice: number;\n pnl: number;\n pnlPct: number;\n reason: \"TP\" | \"SL\";\n duration: number;\n}\n\nexport interface BotState {\n activeTrades: Map;\n completedTrades: TradeResult[];\n dailyTradeCount: number;\n totalPnl: number;\n startTime: number;\n isRunning: boolean;\n}\n\nexport interface MarketSignal {\n symbol: string;\n rsi: number;\n volumeRatio: number;\n currentPrice: number;\n recentLow: number;\n liquidityGrab: boolean;\n}\n","label",[140],"03d20c08-544c-11f1-a713-ee650bb23af1","telegram.ts","03d20cb2-544c-11f1-a713-ee650bb23af1",3,["D",1779282088344],"import { TELEGRAM_TOKEN, CHAT_ID } from \"./config.ts\";\n\nconst BASE_URL = `https://api.telegram.org/bot${TELEGRAM_TOKEN}`;\n\nexport async function sendTelegram(text: string): Promise {\n try {\n await fetch(`${BASE_URL}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: CHAT_ID,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n } catch (e) {\n console.error(\"Telegram send failed:\", e);\n }\n}\n\nexport async function sendBuyAlert(\n symbol: string,\n price: number,\n qty: number,\n rsi: number,\n volRatio: number,\n tp: number,\n sl: number,\n) {\n const msg = `🟢 BUY ${symbol}\n💰 Price: ${price.toFixed(6)}\n📊 Qty: ${qty}\n📈 RSI(7): ${rsi.toFixed(1)}\n🔊 Vol Ratio: ${volRatio.toFixed(2)}x\n🎯 TP: ${tp.toFixed(6)} | SL: ${sl.toFixed(6)}\n⏰ ${new Date().toISOString()}`;\n await sendTelegram(msg);\n}\n\nexport async function sendSellAlert(\n symbol: string,\n entryPrice: number,\n exitPrice: number,\n pnl: number,\n pnlPct: number,\n reason: \"TP\" | \"SL\",\n rsi: number,\n volRatio: number,\n) {\n const emoji = reason === \"TP\" ? \"🟢\" : \"🔴\";\n const msg = `${emoji} SELL ${symbol} [${reason}]\n📥 Entry: ${entryPrice.toFixed(6)}\n📤 Exit: ${exitPrice.toFixed(6)}\n💵 PnL: ${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(4)} USDT (${(pnlPct * 100).toFixed(2)}%)\n📈 RSI at Entry: ${rsi.toFixed(1)}\n🔊 Vol Ratio: ${volRatio.toFixed(2)}x\n⏰ ${new Date().toISOString()}`;\n await sendTelegram(msg);\n}\n\nexport async function sendSummaryReport(\n activeCount: number,\n totalPnl: number,\n capitalUtil: number,\n dailyCount: number,\n balance: number,\n) {\n const msg = `📊 15-MIN SUMMARY REPORT\n━━━━━━━━━━━━━━━━━━━\n🔄 Active Trades: ${activeCount}\n💰 Total PnL: ${totalPnl >= 0 ? \"+\" : \"\"}${totalPnl.toFixed(4)} USDT\n📊 Capital Utilization: ${(capitalUtil * 100).toFixed(1)}%\n📈 Daily Trade Count: ${dailyCount}\n💵 Current Balance: ${balance.toFixed(2)} USDT\n⏰ ${new Date().toISOString()}`;\n await sendTelegram(msg);\n}\n",[151],"26fa3d9a-544c-11f1-83c7-ee650bb23af1","strategy.ts","26fa3e58-544c-11f1-83c7-ee650bb23af1",6,["D",1779282147325],"import { getExchange, withRetry } from \"./exchange.ts\";\nimport { calculateRSI, checkVolumeSpike, detectLiquidityGrab } from \"./indicators.ts\";\nimport {\n MIN_24H_VOLUME_USDT,\n CANDLE_TIMEFRAME,\n CANDLE_LIMIT,\n RSI_OVERSOLD,\n POSITION_DIVISOR,\n TAKE_PROFIT_PCT,\n STOP_LOSS_PCT,\n MAX_CONCURRENT_TRADES,\n} from \"./config.ts\";\nimport type { ActiveTrade, BotState, MarketSignal } from \"./types.ts\";\nimport { sendBuyAlert, sendSellAlert } from \"./telegram.ts\";\n\n/**\n * Fetch high-volume USDT pairs from testnet\n */\nexport async function getEligiblePairs(): Promise {\n const exchange = getExchange();\n const tickers = await withRetry(() => exchange.fetchTickers(), \"fetchTickers\");\n if (!tickers) return [];\n\n const eligible: string[] = [];\n for (const [symbol, ticker] of Object.entries(tickers)) {\n if (!symbol.endsWith(\"/USDT\")) continue;\n if (symbol.includes(\":\")) continue; // skip futures\n const vol = (ticker.quoteVolume ?? 0) as number;\n if (vol >= MIN_24H_VOLUME_USDT) {\n eligible.push(symbol);\n }\n }\n\n console.log(`[Strategy] Found ${eligible.length} eligible pairs (vol > ${MIN_24H_VOLUME_USDT} USDT)`);\n return eligible;\n}\n\n/**\n * Analyze a single pair for entry signals\n */\nexport async function analyzeSymbol(symbol: string): Promise {\n const exchange = getExchange();\n\n const ohlcv = await withRetry(\n () => exchange.fetchOHLCV(symbol, CANDLE_TIMEFRAME, undefined, CANDLE_LIMIT),\n `ohlcv:${symbol}`,\n );\n if (!ohlcv || ohlcv.length < 20) return null;\n\n const closes = ohlcv.map((c) => c[4] as number);\n const lows = ohlcv.map((c) => c[3] as number);\n const volumes = ohlcv.map((c) => c[5] as number);\n const currentPrice = closes[closes.length - 1];\n\n // 1. RSI check\n const rsi = calculateRSI(closes);\n\n // 2. Volume Spike (VSA)\n const { isSpike, ratio: volumeRatio } = checkVolumeSpike(volumes);\n if (!isSpike) return null;\n\n // 3. Liquidity Grab detection\n const { isGrab, recentLow } = detectLiquidityGrab(lows, closes, currentPrice);\n if (!isGrab) return null;\n\n // 4. RSI must be reversing from oversold\n if (rsi > RSI_OVERSOLD + 10) return null; // allow slight buffer above 30\n\n return {\n symbol,\n rsi,\n volumeRatio,\n currentPrice,\n recentLow,\n liquidityGrab: true,\n };\n}\n\n/**\n * Execute a buy order\n */\nexport async function executeBuy(\n signal: MarketSignal,\n state: BotState,\n): Promise {\n const exchange = getExchange();\n\n // Get current balance\n const balance = await withRetry(() => exchange.fetchBalance(), \"fetchBalance\");\n if (!balance) return null;\n\n const freeUsdt = (balance.free?.USDT ?? 0) as number;\n const tradeSize = freeUsdt / POSITION_DIVISOR;\n\n if (tradeSize < 10) {\n console.log(`[Buy] Insufficient funds: ${freeUsdt.toFixed(2)} USDT`);\n return null;\n }\n\n // Load market for precision\n await withRetry(() => exchange.loadMarkets(), \"loadMarkets\");\n const market = exchange.markets[signal.symbol];\n if (!market) return null;\n\n // Calculate quantity\n let quantity = tradeSize / signal.currentPrice;\n quantity = exchange.amountToPrecision(signal.symbol, quantity) as unknown as number;\n quantity = Number(quantity);\n\n if (quantity <= 0) return null;\n\n // Check minimum notional\n const minNotional = market.limits?.cost?.min ?? 10;\n if (quantity * signal.currentPrice < minNotional) {\n console.log(`[Buy] Below min notional for ${signal.symbol}`);\n return null;\n }\n\n // Place market buy\n const order = await withRetry(\n () => exchange.createMarketBuyOrder(signal.symbol, quantity),\n `buy:${signal.symbol}`,\n );\n if (!order) return null;\n\n const filledPrice = order.average ?? order.price ?? signal.currentPrice;\n const filledQty = order.filled ?? quantity;\n\n const trade: ActiveTrade = {\n id: order.id ?? `${Date.now()}-${signal.symbol}`,\n symbol: signal.symbol,\n entryPrice: filledPrice,\n quantity: filledQty,\n costUsdt: filledPrice * filledQty,\n entryTime: Date.now(),\n takeProfitPrice: filledPrice * (1 + TAKE_PROFIT_PCT),\n stopLossPrice: filledPrice * (1 - STOP_LOSS_PCT),\n rsiAtEntry: signal.rsi,\n volumeRatio: signal.volumeRatio,\n };\n\n console.log(\n `[BUY] ${signal.symbol} @ ${filledPrice.toFixed(6)} | Qty: ${filledQty} | TP: ${trade.takeProfitPrice.toFixed(6)} | SL: ${trade.stopLossPrice.toFixed(6)}`,\n );\n\n await sendBuyAlert(\n signal.symbol,\n filledPrice,\n filledQty,\n signal.rsi,\n signal.volumeRatio,\n trade.takeProfitPrice,\n trade.stopLossPrice,\n );\n\n return trade;\n}\n\n/**\n * Monitor and close trades that hit TP or SL\n */\nexport async function monitorTrades(state: BotState): Promise {\n const exchange = getExchange();\n if (state.activeTrades.size === 0) return;\n\n const symbols = [...new Set([...state.activeTrades.values()].map((t) => t.symbol))];\n\n // Fetch current prices for all active symbols\n const tickers = await withRetry(\n () => exchange.fetchTickers(symbols),\n \"monitorTickers\",\n );\n if (!tickers) return;\n\n for (const [tradeId, trade] of state.activeTrades.entries()) {\n const ticker = tickers[trade.symbol];\n if (!ticker?.last) continue;\n\n const currentPrice = ticker.last;\n let reason: \"TP\" | \"SL\" | null = null;\n\n if (currentPrice >= trade.takeProfitPrice) {\n reason = \"TP\";\n } else if (currentPrice <= trade.stopLossPrice) {\n reason = \"SL\";\n }\n\n if (!reason) continue;\n\n // Execute sell\n const order = await withRetry(\n () => exchange.createMarketSellOrder(trade.symbol, trade.quantity),\n `sell:${trade.symbol}`,\n );\n\n if (!order) continue;\n\n const exitPrice = order.average ?? order.price ?? currentPrice;\n const pnl = (exitPrice - trade.entryPrice) * trade.quantity;\n const pnlPct = (exitPrice - trade.entryPrice) / trade.entryPrice;\n\n console.log(\n `[SELL:${reason}] ${trade.symbol} @ ${exitPrice.toFixed(6)} | PnL: ${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(4)} USDT (${(pnlPct * 100).toFixed(2)}%)`,\n );\n\n await sendSellAlert(\n trade.symbol,\n trade.entryPrice,\n exitPrice,\n pnl,\n pnlPct,\n reason,\n trade.rsiAtEntry,\n trade.volumeRatio,\n );\n\n state.activeTrades.delete(tradeId);\n state.completedTrades.push({\n symbol: trade.symbol,\n entryPrice: trade.entryPrice,\n exitPrice,\n pnl,\n pnlPct,\n reason,\n duration: Date.now() - trade.entryTime,\n });\n state.totalPnl += pnl;\n }\n}\n",[158],"3a07262c-544d-11f1-b01d-ee650bb23af1","main.ts",14,["D",1779282608778],"http","import { Hono } from \"npm:hono@4\";\nimport { getExchange, withRetry } from \"./exchange.ts\";\nimport {\n getEligiblePairs,\n analyzeSymbol,\n executeBuy,\n monitorTrades,\n} from \"./strategy.ts\";\nimport { sendTelegram, sendSummaryReport } from \"./telegram.ts\";\nimport { renderDashboard } from \"./dashboard.tsx\";\nimport {\n MAX_CONCURRENT_TRADES,\n SCAN_INTERVAL_MS,\n MONITOR_INTERVAL_MS,\n REPORT_INTERVAL_MS,\n} from \"./config.ts\";\nimport type { BotState } from \"./types.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\n\n// ─── Global Bot State ───\nconst state: BotState = {\n activeTrades: new Map(),\n completedTrades: [],\n dailyTradeCount: 0,\n totalPnl: 0,\n startTime: Date.now(),\n isRunning: false,\n};\n\nlet scanTimer: number | null = null;\nlet monitorTimer: number | null = null;\nlet reportTimer: number | null = null;\nlet lastError: string | null = null;\n\n// ─── Core Bot Loop ───\nasync function scanMarkets() {\n if (!state.isRunning) return;\n\n try {\n if (state.activeTrades.size >= MAX_CONCURRENT_TRADES) {\n console.log(`[Scan] Max concurrent trades reached (${MAX_CONCURRENT_TRADES}), skipping`);\n return;\n }\n\n const pairs = await getEligiblePairs();\n if (pairs.length === 0) {\n console.log(\"[Scan] No eligible pairs found this cycle\");\n return;\n }\n\n const activeSymbols = new Set([...state.activeTrades.values()].map((t) => t.symbol));\n const candidates = pairs.filter((p) => !activeSymbols.has(p));\n let newTrades = 0;\n\n for (const symbol of candidates) {\n if (state.activeTrades.size >= MAX_CONCURRENT_TRADES) break;\n\n const signal = await analyzeSymbol(symbol);\n if (!signal) continue;\n\n console.log(\n `[Signal] ${symbol} | RSI: ${signal.rsi.toFixed(1)} | Vol: ${signal.volumeRatio.toFixed(2)}x | LiqGrab: ${signal.liquidityGrab}`,\n );\n\n const trade = await executeBuy(signal, state);\n if (trade) {\n state.activeTrades.set(trade.id, trade);\n state.dailyTradeCount++;\n newTrades++;\n }\n\n // Delay between analyses to avoid rate limits\n await new Promise((r) => setTimeout(r, 300));\n }\n\n if (newTrades > 0) {\n console.log(`[Scan] Opened ${newTrades} new trade(s). Total active: ${state.activeTrades.size}`);\n }\n lastError = null;\n } catch (err: any) {\n lastError = err?.message ?? String(err);\n console.error(\"[Scan] Error:\", lastError);\n }\n}\n\nasync function monitorLoop() {\n if (!state.isRunning) return;\n try {\n await monitorTrades(state);\n } catch (err: any) {\n console.error(\"[Monitor] Error:\", err?.message ?? err);\n }\n}\n\nasync function reportLoop() {\n if (!state.isRunning) return;\n try {\n const exchange = getExchange();\n const balance = await withRetry(() => exchange.fetchBalance(), \"reportBalance\");\n const freeUsdt = (balance?.free?.USDT ?? 0) as number;\n const capitalUsed = [...state.activeTrades.values()].reduce(\n (sum, t) => sum + t.costUsdt,\n 0,\n );\n const totalCapital = freeUsdt + capitalUsed;\n const capitalUtil = totalCapital > 0 ? capitalUsed / totalCapital : 0;\n\n await sendSummaryReport(\n state.activeTrades.size,\n state.totalPnl,\n capitalUtil,\n state.dailyTradeCount,\n freeUsdt,\n );\n } catch (err: any) {\n console.error(\"[Report] Error:\", err?.message ?? err);\n }\n}\n\nfunction startBot() {\n if (state.isRunning) return \"already_running\";\n state.isRunning = true;\n state.startTime = Date.now();\n\n console.log(\"🚀 Bot started!\");\n\n // Start loops\n scanTimer = setInterval(scanMarkets, SCAN_INTERVAL_MS) as unknown as number;\n monitorTimer = setInterval(monitorLoop, MONITOR_INTERVAL_MS) as unknown as number;\n reportTimer = setInterval(reportLoop, REPORT_INTERVAL_MS) as unknown as number;\n\n // Run first scan immediately\n scanMarkets();\n sendTelegram(\"🚀 BotTrader2 Started!\\nHigh-Frequency Binance Testnet Bot is now active.\\n\\n📊 Strategy: VSA + Liquidity Grab\\n⏱ Timeframe: 5m\\n🎯 TP/SL: 0.7%\\n💰 Position Size: Balance/50\\n📈 Max Trades: 50\");\n\n return \"started\";\n}\n\nfunction stopBot() {\n state.isRunning = false;\n if (scanTimer) clearInterval(scanTimer);\n if (monitorTimer) clearInterval(monitorTimer);\n if (reportTimer) clearInterval(reportTimer);\n scanTimer = null;\n monitorTimer = null;\n reportTimer = null;\n console.log(\"🛑 Bot stopped!\");\n sendTelegram(\"🛑 BotTrader2 Stopped!\");\n return \"stopped\";\n}\n\n// ─── Fetch USDT balance safely ───\nasync function getBalance(): Promise {\n try {\n const exchange = getExchange();\n const balance = await withRetry(() => exchange.fetchBalance(), \"dashBalance\");\n return (balance?.free?.USDT ?? 0) as number;\n } catch {\n return 0;\n }\n}\n\n// ─── HTTP Server ───\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\napp.get(\"/\", async (c) => {\n const balance = await getBalance();\n // Quick connection test for dashboard status\n let connStatus: { ok: boolean; error?: string } = { ok: true };\n try {\n const ex = getExchange();\n await ex.fetchTime();\n } catch (e: any) {\n connStatus = { ok: false, error: e?.message?.slice(0, 200) ?? \"Unknown\" };\n }\n return c.html(renderDashboard(state, balance, connStatus));\n});\n\napp.post(\"/start\", async (c) => {\n const result = startBot();\n return c.json({ status: result, activeTrades: state.activeTrades.size });\n});\n\napp.post(\"/stop\", async (c) => {\n const result = stopBot();\n return c.json({ status: result });\n});\n\napp.get(\"/status\", (c) => {\n return c.json({\n isRunning: state.isRunning,\n activeTrades: state.activeTrades.size,\n completedTrades: state.completedTrades.length,\n dailyTradeCount: state.dailyTradeCount,\n totalPnl: state.totalPnl,\n uptimeMs: Date.now() - state.startTime,\n lastError,\n });\n});\n\napp.get(\"/trades\", (c) => {\n return c.json({\n active: [...state.activeTrades.values()],\n completed: state.completedTrades.slice(-50),\n });\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ─── Test exchange connection ───\napp.get(\"/test-connection\", async (c) => {\n try {\n const exchange = getExchange();\n const start = Date.now();\n\n // Try loading markets (public endpoint, no auth needed)\n await exchange.loadMarkets();\n const marketCount = Object.keys(exchange.markets).length;\n\n // Try fetching balance (authenticated)\n let balanceInfo: any = null;\n try {\n const balance = await exchange.fetchBalance();\n balanceInfo = {\n USDT: balance?.free?.USDT ?? 0,\n BTC: balance?.free?.BTC ?? 0,\n BNB: balance?.free?.BNB ?? 0,\n };\n } catch (e: any) {\n balanceInfo = { error: e?.message?.slice(0, 200) };\n }\n\n return c.json({\n ok: true,\n latencyMs: Date.now() - start,\n sandbox: exchange.sandbox,\n markets: marketCount,\n balance: balanceInfo,\n urls: exchange.urls?.api,\n });\n } catch (e: any) {\n return c.json({\n ok: false,\n error: e?.message?.slice(0, 300),\n }, 500);\n }\n});\n\nexport default app.fetch;\n",[165],"157e8ff8-544c-11f1-8b35-ee650bb23af1","indicators.ts","157e90d4-544c-11f1-8b35-ee650bb23af1",5,["D",1779282117994],"import { RSI_PERIOD, VSA_VOLUME_MULTIPLIER } from \"./config.ts\";\n\n/**\n * Calculate RSI (Relative Strength Index)\n * @param closes Array of closing prices (oldest first)\n * @param period RSI period (default from config)\n */\nexport function calculateRSI(closes: number[], period: number = RSI_PERIOD): number {\n if (closes.length < period + 1) return 50; // neutral fallback\n\n let gains = 0;\n let losses = 0;\n\n // Initial average gain/loss\n for (let i = 1; i <= period; i++) {\n const diff = closes[i] - closes[i - 1];\n if (diff > 0) gains += diff;\n else losses += Math.abs(diff);\n }\n\n let avgGain = gains / period;\n let avgLoss = losses / period;\n\n // Smoothed RSI\n for (let i = period + 1; i < closes.length; i++) {\n const diff = closes[i] - closes[i - 1];\n if (diff > 0) {\n avgGain = (avgGain * (period - 1) + diff) / period;\n avgLoss = (avgLoss * (period - 1)) / period;\n } else {\n avgGain = (avgGain * (period - 1)) / period;\n avgLoss = (avgLoss * (period - 1) + Math.abs(diff)) / period;\n }\n }\n\n if (avgLoss === 0) return 100;\n const rs = avgGain / avgLoss;\n return 100 - (100 / (1 + rs));\n}\n\n/**\n * Check for Volume Spike (VSA)\n * Current candle volume > 1.5x average of last 10 candles\n */\nexport function checkVolumeSpike(volumes: number[]): { isSpike: boolean; ratio: number } {\n if (volumes.length < 11) return { isSpike: false, ratio: 0 };\n\n const currentVol = volumes[volumes.length - 1];\n const avgVol = volumes.slice(-11, -1).reduce((a, b) => a + b, 0) / 10;\n\n if (avgVol === 0) return { isSpike: false, ratio: 0 };\n\n const ratio = currentVol / avgVol;\n return {\n isSpike: ratio >= VSA_VOLUME_MULTIPLIER,\n ratio,\n };\n}\n\n/**\n * Detect liquidity grab pattern:\n * Price dipped below recent lows then reversed with RSI coming up from < 30\n */\nexport function detectLiquidityGrab(\n lows: number[],\n closes: number[],\n currentPrice: number,\n): { isGrab: boolean; recentLow: number } {\n if (lows.length < 15) return { isGrab: false, recentLow: 0 };\n\n // Find the lowest low in candles [-15 to -3] (the \"support zone\")\n const supportLows = lows.slice(-15, -2);\n const recentLow = Math.min(...supportLows);\n\n // Check if any of the last 2 candles wicked below this level\n const lastTwoLows = lows.slice(-2);\n const brokeBelow = lastTwoLows.some((l) => l < recentLow);\n\n // Check if current price recovered back above the low\n const recovered = currentPrice > recentLow;\n\n // Calculate RSI for the last few candles to see reversal\n const rsiNow = calculateRSI(closes);\n const rsiPrev = calculateRSI(closes.slice(0, -1));\n\n // Liquidity grab: broke below support, recovered, RSI reversing from oversold\n const isGrab = brokeBelow && recovered && rsiPrev < 30 && rsiNow > rsiPrev;\n\n return { isGrab, recentLow };\n}\n",[172],"1b72d53a-544d-11f1-bb67-ee650bb23af1","exchange.ts","0b994f50-544c-11f1-8b35-ee650bb23af1",12,["D",1779282557473],"import * as ccxt from \"npm:ccxt@4\";\nimport { API_KEY, SECRET_KEY, MAX_RETRIES, RETRY_DELAY_MS } from \"./config.ts\";\n\nlet exchangeInstance: ccxt.binance | null = null;\n\n/**\n * Initialize Binance exchange with testnet + anti-geo-block settings.\n *\n * Binance testnet (testnet.binance.vision) blocks many cloud IPs with\n * a 451 \"Unavailable For Legal Reasons\" response. We configure CCXT with:\n * - Residential-looking User-Agent and headers\n * - CCXT built-in proxy/httpProxy if a proxy is provided via env\n * - Increased timeouts and rate-limit awareness\n */\nexport function getExchange(): ccxt.binance {\n if (!exchangeInstance) {\n // Check if user set a proxy in env (optional)\n const proxyUrl = typeof Deno !== \"undefined\"\n ? Deno.env.get(\"HTTPS_PROXY\") || Deno.env.get(\"HTTP_PROXY\") || \"\"\n : \"\";\n\n const config: any = {\n apiKey: API_KEY,\n secret: SECRET_KEY,\n enableRateLimit: true,\n rateLimit: 250,\n timeout: 30000,\n options: {\n defaultType: \"spot\",\n adjustForTimeDifference: true,\n recvWindow: 60000,\n warnOnFetchOpenOrdersWithoutSymbol: false,\n },\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36\",\n \"Accept\": \"text/html,application/xhtml+xml,application/xml;q=0.9,application/json,*/*;q=0.8\",\n \"Accept-Language\": \"en-US,en;q=0.9\",\n \"Accept-Encoding\": \"gzip, deflate, br\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n },\n };\n\n // If proxy is available, use it to bypass geo restrictions\n if (proxyUrl) {\n config.httpProxy = proxyUrl;\n console.log(\"[Exchange] Using proxy:\", proxyUrl.slice(0, 30) + \"...\");\n }\n\n exchangeInstance = new ccxt.binance(config);\n\n // Enable sandbox/testnet mode\n exchangeInstance.setSandboxMode(true);\n\n console.log(\"[Exchange] Initialized Binance Testnet (sandbox mode)\");\n console.log(\"[Exchange] Sandbox:\", exchangeInstance.sandbox);\n\n // Log the resolved API URLs\n const apiUrls = exchangeInstance.urls?.api;\n if (typeof apiUrls === \"object\") {\n console.log(\"[Exchange] Public URL:\", (apiUrls as any).public || \"default\");\n console.log(\"[Exchange] Private URL:\", (apiUrls as any).private || \"default\");\n }\n }\n return exchangeInstance;\n}\n\n/**\n * Reset exchange instance (useful after geo-block or auth errors)\n */\nexport function resetExchange(): void {\n exchangeInstance = null;\n console.log(\"[Exchange] Instance reset — will reinitialize on next call\");\n}\n\n/**\n * Retry wrapper with intelligent error categorization and backoff.\n * Handles rate limits, geo-blocks, network errors, and exchange errors.\n */\nexport async function withRetry(\n fn: () => Promise,\n label: string,\n): Promise {\n for (let attempt = 1; attempt <= MAX_RETRIES; attempt++) {\n try {\n return await fn();\n } catch (err: any) {\n const msg = err?.message ?? String(err);\n const code = err?.httpStatusCode || 0;\n\n // ── Categorize the error ──\n const isRateLimit = err instanceof ccxt.RateLimitExceeded\n || err instanceof ccxt.DDoSProtection\n || code === 429\n || msg.includes(\"429\")\n || msg.includes(\"Too many\")\n || msg.includes(\"rate limit\");\n\n const isGeoBlock = code === 451\n || msg.includes(\"451\")\n || msg.includes(\"geographic\")\n || msg.includes(\"restricted location\")\n || msg.includes(\"Unavailable For Legal Reasons\")\n || msg.includes(\"Service unavailable from a restricted\");\n\n const isNetworkError = err instanceof ccxt.NetworkError\n || err instanceof ccxt.RequestTimeout\n || msg.includes(\"ETIMEDOUT\")\n || msg.includes(\"ECONNREFUSED\")\n || msg.includes(\"ECONNRESET\")\n || msg.includes(\"fetch failed\");\n\n const isExchangeDown = err instanceof ccxt.ExchangeNotAvailable\n || code === 503\n || code === 502;\n\n // ── Handle each category ──\n if (isGeoBlock) {\n console.warn(\n `[${label}] ⚠️ GEO-BLOCKED (451) — Binance testnet is blocking this server's IP. ` +\n `Set HTTPS_PROXY env var to route through a proxy. (attempt ${attempt}/${MAX_RETRIES})`,\n );\n // No point retrying geo-blocks without a proxy change\n if (attempt >= 2) {\n console.error(`[${label}] Geo-block persists. Giving up.`);\n return null;\n }\n resetExchange();\n await sleep(RETRY_DELAY_MS * 2);\n } else if (isRateLimit) {\n const wait = RETRY_DELAY_MS * attempt * 3;\n console.warn(`[${label}] Rate limited, backing off ${wait}ms (attempt ${attempt}/${MAX_RETRIES})`);\n await sleep(wait);\n } else if (isExchangeDown) {\n const wait = RETRY_DELAY_MS * attempt * 2;\n console.warn(`[${label}] Exchange unavailable, retrying in ${wait}ms (attempt ${attempt}/${MAX_RETRIES})`);\n await sleep(wait);\n } else if (isNetworkError) {\n const wait = RETRY_DELAY_MS * attempt;\n console.warn(`[${label}] Network error: ${msg.slice(0, 80)}, retrying in ${wait}ms (attempt ${attempt}/${MAX_RETRIES})`);\n await sleep(wait);\n } else {\n console.error(`[${label}] Unhandled error (attempt ${attempt}/${MAX_RETRIES}): ${msg.slice(0, 200)}`);\n if (attempt === MAX_RETRIES) return null;\n await sleep(RETRY_DELAY_MS);\n }\n }\n }\n console.error(`[${label}] All ${MAX_RETRIES} attempts exhausted`);\n return null;\n}\n\nfunction sleep(ms: number): Promise {\n return new Promise((r) => setTimeout(r, ms));\n}\n",[179],"361f6b00-544d-11f1-b01d-ee650bb23af1","dashboard.tsx","382448e0-544c-11f1-873b-ee650bb23af1",13,["D",1779282602225],1,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { renderToString } from \"https://esm.sh/react-dom@18.2.0/server\";\nimport type { BotState } from \"./types.ts\";\n\nexport function renderDashboard(\n state: BotState,\n balance: number,\n connectionStatus?: { ok: boolean; error?: string },\n): string {\n const uptimeMs = Date.now() - state.startTime;\n const uptimeMin = Math.floor(uptimeMs / 60000);\n const uptimeHr = Math.floor(uptimeMin / 60);\n\n const activeTrades = [...state.activeTrades.values()];\n const capitalUsed = activeTrades.reduce((sum, t) => sum + t.costUsdt, 0);\n const totalCapital = balance + capitalUsed;\n const capitalUtil = totalCapital > 0 ? (capitalUsed / totalCapital) * 100 : 0;\n\n const wins = state.completedTrades.filter((t) => t.pnl > 0).length;\n const losses = state.completedTrades.filter((t) => t.pnl <= 0).length;\n const winRate = state.completedTrades.length > 0\n ? ((wins / state.completedTrades.length) * 100).toFixed(1)\n : \"0.0\";\n\n const isGeoBlocked = connectionStatus && !connectionStatus.ok\n && connectionStatus.error?.includes(\"451\");\n\n const html = renderToString(\n \n \n BotTrader2 Dashboard\n \n \n \n \n

🤖 BotTrader2 — HF Scalping Bot

\n Binance Testnet | VSA + Liquidity Grab | 5m Timeframe | TP/SL 0.7%\n

\n Uptime: {uptimeHr}h {uptimeMin % 60}m |{\" \"}\n {state.isRunning ? \"🟢 Running\" : \"🔴 Stopped\"}\n

\n\n {/* Geo-Block Warning */}\n {isGeoBlocked && (\n

⚠️ Geographic Restriction Detected

\n Binance Testnet is blocking requests from this server's IP (HTTP 451).\n To fix this, set the HTTPS_PROXY environment\n variable to a residential proxy URL. The bot logic is fully operational\n and will auto-connect once the proxy is configured.\n

\n )}\n\n {/* Controls */}\n

\n location.reload())\"\n className=\"bg-green-700 hover:bg-green-600 px-4 py-2 rounded font-bold text-sm\"\n >\n ▶ Start Bot\n \n location.reload())\"\n className=\"bg-red-700 hover:bg-red-600 px-4 py-2 rounded font-bold text-sm\"\n >\n ⏹ Stop Bot\n \n \n 📡 API Status\n \n \n 🔌 Test Connection\n \n \n 📝 View Source\n \n

\n\n {/* Stats Grid */}\n

\n \n = 0 ? \"+\" : \"\"}${state.totalPnl.toFixed(4)} USDT`}\n color={state.totalPnl >= 0 ? \"green\" : \"red\"}\n />\n \n \n \n \n \n \n

\n\n {/* Strategy Info */}\n

📋 Strategy Configuration

\n 🔊 VSA: Vol > 1.5x Avg(10)\n 💧 Liquidity Grab: Below lows + RSI reversal\n 📈 RSI(7) < 30 reversal\n ⏱ Timeframe: 5m candles\n 🎯 TP: 0.7% | SL: 0.7%\n 💰 Size: Balance / 50\n 📊 Max: 50 concurrent\n 🔍 Min Vol: 500K USDT/24h\n

\n\n {/* Active Trades */}\n

📊 Active Trades

\n {activeTrades.length === 0 ? (\n

No active trades

\n ) : (\n

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n {activeTrades.map((t) => (\n \n \n \n \n \n \n \n \n \n \n \n ))}\n \n

Symbol	Entry	Qty	Cost	TP	SL	RSI	Vol Ratio	Age
{t.symbol}	{t.entryPrice.toFixed(6)}	{t.quantity}	{t.costUsdt.toFixed(2)}	{t.takeProfitPrice.toFixed(6)}	{t.stopLossPrice.toFixed(6)}	{t.rsiAtEntry.toFixed(1)}	{t.volumeRatio.toFixed(2)}x	{Math.floor((Date.now() - t.entryTime) / 60000)}m

\n )}\n\n {/* Recent Closed Trades */}\n

📜 Recent Closed Trades

\n {state.completedTrades.length === 0 ? (\n

No completed trades yet

\n ) : (\n

\n \n \n \n \n \n \n \n \n \n \n \n \n \n {state.completedTrades.slice(-20).reverse().map((t, i) => (\n \n \n \n \n \n \n \n \n \n ))}\n \n

Symbol	Entry	Exit	PnL	PnL %	Reason	Duration
{t.symbol}	{t.entryPrice.toFixed(6)}	{t.exitPrice.toFixed(6)}	= 0 ? \"text-green-400\" : \"text-red-400\"}`}>\n {t.pnl >= 0 ? \"+\" : \"\"}{t.pnl.toFixed(4)}\n	= 0 ? \"text-green-400\" : \"text-red-400\"}`}>\n {(t.pnlPct * 100).toFixed(2)}%\n	{t.reason === \"TP\" ? \"🟢 TP\" : \"🔴 SL\"}	{Math.floor(t.duration / 60000)}m

\n )}\n\n \n

\n\n {/* Inline script for button actions */}\n

Diff · v15