[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_254":255,"_256":257},"routes/_app.x.$handle.$name",{"_103":102,"_38":51,"_111":93,"_33":105,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_26":-5,"_122":-5,"_123":-5,"_124":31,"_125":126,"_127":65,"_128":-5,"_129":-5,"_130":131},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":31},"version",10,"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":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","exchange.ts","latestPath","fileId","0b994f50-544c-11f1-8b35-ee650bb23af1","name","fileType","script","content","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\nexport function getExchange(): ccxt.binance {\n if (!exchangeInstance) {\n exchangeInstance = new ccxt.binance({\n apiKey: API_KEY,\n secret: SECRET_KEY,\n sandbox: true,\n enableRateLimit: true,\n rateLimit: 100,\n options: {\n defaultType: \"spot\",\n adjustForTimeDifference: true,\n recvWindow: 60000,\n },\n headers: {\n \"User-Agent\": \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36\",\n },\n });\n // Force testnet URLs\n exchangeInstance.urls[\"api\"] = {\n ...(exchangeInstance.urls[\"api\"] as Record),\n public: \"https://testnet.binance.vision/api/v3\",\n private: \"https://testnet.binance.vision/api/v3\",\n };\n exchangeInstance.setSandboxMode(true);\n }\n return exchangeInstance;\n}\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 isRateLimit = err instanceof ccxt.RateLimitExceeded\n || err instanceof ccxt.DDoSProtection\n || (err.message && err.message.includes(\"429\"));\n const isGeoBlock = err.message?.includes(\"geographic\")\n || err.message?.includes(\"restricted\");\n const isNetworkError = err instanceof ccxt.NetworkError\n || err instanceof ccxt.RequestTimeout;\n\n if (isRateLimit) {\n const wait = RETRY_DELAY_MS * attempt * 2;\n console.warn(`[${label}] Rate limited, waiting ${wait}ms (attempt ${attempt})`);\n await sleep(wait);\n } else if (isGeoBlock) {\n console.error(`[${label}] Geographic restriction detected`);\n await sleep(RETRY_DELAY_MS * attempt);\n } else if (isNetworkError) {\n console.warn(`[${label}] Network error, retrying in ${RETRY_DELAY_MS * attempt}ms`);\n await sleep(RETRY_DELAY_MS * attempt);\n } else {\n console.error(`[${label}] Error (attempt ${attempt}/${MAX_RETRIES}):`, err.message);\n if (attempt === MAX_RETRIES) return null;\n await sleep(RETRY_DELAY_MS);\n }\n }\n }\n return null;\n}\n\nfunction sleep(ms: number): Promise {\n return new Promise((r) => setTimeout(r, ms));\n}\n","import * as ccxt from \"npm:ccxt@4\";\nimport { API_KEY, SECRET_KEY, MAX_RETRIES, RETRY_DELAY_MS } from \"./config.ts\";\n\nlet exchangeInstance: ccxt.pro.binance | null = null;\n\nexport function getExchange(): ccxt.pro.binance {\n if (!exchangeInstance) {\n exchangeInstance = new ccxt.pro.binance({\n apiKey: API_KEY,\n secret: SECRET_KEY,\n enableRateLimit: true,\n rateLimit: 200,\n options: {\n defaultType: \"spot\",\n adjustForTimeDifference: true,\n recvWindow: 60000,\n },\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n \"Accept\": \"application/json\",\n \"Accept-Language\": \"en-US,en;q=0.9\",\n },\n });\n\n // Enable sandbox/testnet mode using CCXT's built-in method\n exchangeInstance.setSandboxMode(true);\n\n console.log(\"[Exchange] Initialized Binance Testnet (sandbox mode)\");\n console.log(\"[Exchange] API Base:\", JSON.stringify(exchangeInstance.urls?.api));\n }\n return exchangeInstance;\n}\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\n const isRateLimit = err instanceof ccxt.RateLimitExceeded\n || err instanceof ccxt.DDoSProtection\n || msg.includes(\"429\")\n || msg.includes(\"Too many\");\n\n const isGeoBlock = msg.includes(\"geographic\")\n || msg.includes(\"restricted\")\n || msg.includes(\"banned\")\n || msg.includes(\"403\")\n || msg.includes(\"Service unavailable\");\n\n const isNetworkError = err instanceof ccxt.NetworkError\n || err instanceof ccxt.RequestTimeout\n || msg.includes(\"ETIMEDOUT\")\n || msg.includes(\"ECONNREFUSED\")\n || msg.includes(\"fetch failed\");\n\n const isExchangeError = err instanceof ccxt.ExchangeNotAvailable\n || err instanceof ccxt.ExchangeError;\n\n if (isRateLimit) {\n const wait = RETRY_DELAY_MS * attempt * 3;\n console.warn(`[${label}] Rate limited, waiting ${wait}ms (attempt ${attempt}/${MAX_RETRIES})`);\n await sleep(wait);\n } else if (isGeoBlock) {\n const wait = RETRY_DELAY_MS * attempt * 2;\n console.warn(`[${label}] Geographic restriction, retrying in ${wait}ms (attempt ${attempt}/${MAX_RETRIES})`);\n // Reset exchange instance to force new connection\n if (attempt === MAX_RETRIES) {\n exchangeInstance = null;\n }\n await sleep(wait);\n } else if (isNetworkError || isExchangeError) {\n const wait = RETRY_DELAY_MS * attempt;\n console.warn(`[${label}] Network/Exchange error: ${msg.slice(0, 100)}, retrying in ${wait}ms (attempt ${attempt}/${MAX_RETRIES})`);\n await sleep(wait);\n } else {\n console.error(`[${label}] 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 failed`);\n return null;\n}\n\nfunction sleep(ms: number): Promise {\n return new Promise((r) => setTimeout(r, ms));\n}\n","createdAt",["D",1779282489434],"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",{"_103":102,"_110":105},"org",{"_103":102,"_104":105,"_106":105,"_19":61,"_107":108,"_109":31},"branch",{"_13":92,"_38":93,"_49":48,"_94":50,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":51,"_101":102},"isOwned",15,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gazasnip11","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":250,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":251,"_87":252,"_89":253,"_91":31},"tree",[213,214,215,216,217,218,219,220,221],"files",[213,214,215,216,217,218,219,220,221],"counts",{"_203":69,"_204":181,"_205":69,"_206":207,"_208":209},"contents",[132,133,134,135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":196,"_38":197,"_36":198,"_144":-5,"_47":48,"_46":199,"_146":31,"_44":200,"_13":69,"_39":26,"_41":201,"_30":31,"_149":-5,"_33":202},{"_49":190,"_38":191,"_36":192,"_144":-5,"_47":48,"_46":181,"_146":65,"_44":193,"_13":69,"_39":40,"_41":194,"_30":31,"_149":-5,"_33":195},{"_49":183,"_38":184,"_36":185,"_144":-5,"_47":48,"_46":186,"_146":31,"_44":187,"_13":69,"_39":40,"_41":188,"_30":31,"_149":-5,"_33":189},{"_49":179,"_38":34,"_36":37,"_144":-5,"_47":48,"_46":14,"_146":31,"_44":180,"_13":181,"_39":40,"_41":43,"_30":31,"_149":-5,"_33":182},{"_49":172,"_38":173,"_36":174,"_144":-5,"_47":48,"_46":175,"_146":65,"_44":176,"_13":69,"_39":40,"_41":177,"_30":31,"_149":-5,"_33":178},{"_49":165,"_38":166,"_36":63,"_144":-5,"_47":48,"_46":167,"_146":31,"_44":168,"_13":69,"_39":169,"_41":170,"_30":31,"_149":-5,"_33":171},{"_49":158,"_38":159,"_36":160,"_144":-5,"_47":48,"_46":161,"_146":65,"_44":162,"_13":69,"_39":40,"_41":163,"_30":31,"_149":-5,"_33":164},{"_49":151,"_38":152,"_36":153,"_144":-5,"_47":48,"_46":154,"_146":65,"_44":155,"_13":69,"_39":40,"_41":156,"_30":31,"_149":-5,"_33":157},{"_49":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":65,"_44":147,"_13":69,"_39":40,"_41":148,"_30":31,"_149":-5,"_33":150},"fc38d74c-544b-11f1-8a21-ee650bb23af1","types.ts","fc38d814-544b-11f1-8a21-ee650bb23af1","parentId",2,"latest",["D",1779282075594],"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",[142],"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",[152],"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",[159],"47dd1884-544c-11f1-8b35-ee650bb23af1","main.ts",8,["D",1779282202494],"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;\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})`);\n return;\n }\n\n const pairs = await getEligiblePairs();\n const activeSymbols = new Set([...state.activeTrades.values()].map((t) => t.symbol));\n\n // Analyze pairs in batches to avoid rate limits\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 // Small delay between analyses\n await new Promise((r) => setTimeout(r, 200));\n }\n\n if (newTrades > 0) {\n console.log(`[Scan] Opened ${newTrades} new trades. Total active: ${state.activeTrades.size}`);\n }\n } catch (err) {\n console.error(\"[Scan] Error:\", err);\n }\n}\n\nasync function monitorLoop() {\n if (!state.isRunning) return;\n try {\n await monitorTrades(state);\n } catch (err) {\n console.error(\"[Monitor] Error:\", 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) {\n console.error(\"[Report] Error:\", err);\n }\n}\n\nfunction startBot() {\n if (state.isRunning) return;\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 immediately\n scanMarkets();\n sendTelegram(\"🚀 BotTrader2 Started!\\nHigh-Frequency Binance Testnet Bot is now active.\");\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}\n\n// ─── HTTP Server (Dashboard + Controls) ───\nconst app = new Hono();\n\napp.onError((err) => Promise.reject(err));\n\napp.get(\"/\", async (c) => {\n const exchange = getExchange();\n let balance = 0;\n try {\n const bal = await withRetry(() => exchange.fetchBalance(), \"dashBalance\");\n balance = (bal?.free?.USDT ?? 0) as number;\n } catch (_) { /* ignore */ }\n return c.html(renderDashboard(state, balance));\n});\n\napp.post(\"/start\", async (c) => {\n startBot();\n return c.json({ status: \"started\", activeTrades: state.activeTrades.size });\n});\n\napp.post(\"/stop\", async (c) => {\n stopBot();\n return c.json({ status: \"stopped\" });\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 });\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// Auto-start the bot when the val is first hit\nlet autoStarted = false;\napp.use(\"*\", async (c, next) => {\n if (!autoStarted) {\n autoStarted = true;\n startBot();\n }\n await next();\n});\n\nexport default app.fetch;\n",[166],"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",[173],"f2f12b02-544c-11f1-add3-ee650bb23af1",["D",1779282489434],1,[34],"382447f0-544c-11f1-873b-ee650bb23af1","dashboard.tsx","382448e0-544c-11f1-873b-ee650bb23af1",7,["D",1779282176122],"/** @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(state: BotState, balance: number): 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 html = renderToString(\n \n \n BotTrader2 Dashboard\n \n \n \n \n

🤖 BotTrader2 Dashboard

\n Binance Testnet HF Bot | Uptime: {uptimeHr}h {uptimeMin % 60}m |{\" \"}\n {state.isRunning ? \"🟢 Running\" : \"🔴 Stopped\"}\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 {/* 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)}	\n {t.takeProfitPrice.toFixed(6)}\n	\n {t.stopLossPrice.toFixed(6)}\n	{t.rsiAtEntry.toFixed(1)}	{t.volumeRatio.toFixed(2)}x	\n {Math.floor((Date.now() - t.entryTime) / 60000)}m\n

\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	\n {t.reason === \"TP\" ? \"🟢 TP\" : \"🔴 SL\"}\n	\n {Math.floor(t.duration / 60000)}m\n

\n )}\n

\n \n ,\n );\n\n return \"\" + html;\n}\n\nfunction StatCard({ label, value, color }: { label: string; value: string; color: string }) {\n const colorClasses: Record = {\n blue: \"bg-blue-900/40 border-blue-700\",\n green: \"bg-green-900/40 border-green-700\",\n red: \"bg-red-900/40 border-red-700\",\n yellow: \"bg-yellow-900/40 border-yellow-700\",\n purple: \"bg-purple-900/40 border-purple-700\",\n cyan: \"bg-cyan-900/40 border-cyan-700\",\n gray: \"bg-gray-800 border-gray-600\",\n };\n return (\n

{label}

{value}

\n );\n}\n",[184],"f87a9550-544b-11f1-8a21-ee650bb23af1","config.ts","f87a9640-544b-11f1-8a21-ee650bb23af1",["D",1779282069314],"// ─── Credentials ───\nexport const API_KEY = \"ewwkWZthamOF33QQYnIXSe4rXzVuy10RfcgK3tFAvlVJk3ZBDgwyjvi0tmcWwIKQ\";\nexport const SECRET_KEY = \"3toyhde8OakFCU395avTRaIpmUTIuFDW1C89BVdVPDr8O0wYf22LeemgUySK1cHT\";\nexport const TELEGRAM_TOKEN = \"8729238573:AAEV7knszIW9OkPAKABNmhsdbyNmvaiGjlU\";\nexport const CHAT_ID = \"1838167986\";\n\n// ─── Trading Parameters ───\nexport const POSITION_DIVISOR = 50; // Divide balance by 50 per trade\nexport const MAX_CONCURRENT_TRADES = 50;\nexport const TAKE_PROFIT_PCT = 0.007; // 0.7%\nexport const STOP_LOSS_PCT = 0.007; // 0.7%\n\n// ─── Strategy Parameters ───\nexport const MIN_24H_VOLUME_USDT = 500_000;\nexport const VSA_VOLUME_MULTIPLIER = 1.5; // Current vol > 1.5x avg(10)\nexport const RSI_PERIOD = 7;\nexport const RSI_OVERSOLD = 30;\nexport const CANDLE_TIMEFRAME = \"5m\";\nexport const CANDLE_LIMIT = 50; // Candles to fetch for analysis\n\n// ─── Timing ───\nexport const SCAN_INTERVAL_MS = 15_000; // Scan markets every 15s\nexport const MONITOR_INTERVAL_MS = 5_000; // Check open trades every 5s\nexport const REPORT_INTERVAL_MS = 900_000; // Telegram summary every 15min\n\n// ─── Anti-Block / Retry ───\nexport const MAX_RETRIES = 3;\nexport const RETRY_DELAY_MS = 2_000;\n",[191],"54803a6c-544c-11f1-acbb-ee650bb23af1","README.md","54803b52-544c-11f1-acbb-ee650bb23af1",9,["D",1779282223701],"# 🤖 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",[197],"pulls","branches","forks","envVars",{"_210":69,"_212":69},"connections",{"_210":69,"_211":69},"count","unfilledCount","emptyCount",{"_49":196,"_38":197,"_36":198,"_144":-5,"_47":48,"_46":199,"_146":31,"_44":247,"_13":69,"_39":26,"_41":201,"_30":31,"_149":-5,"_223":248,"_33":249},{"_49":190,"_38":191,"_36":192,"_144":-5,"_47":48,"_46":181,"_146":65,"_44":244,"_13":69,"_39":40,"_41":194,"_30":31,"_149":-5,"_223":245,"_33":246},{"_49":183,"_38":184,"_36":185,"_144":-5,"_47":48,"_46":186,"_146":31,"_44":241,"_13":69,"_39":40,"_41":188,"_30":31,"_149":-5,"_223":242,"_33":243},{"_49":179,"_38":34,"_36":37,"_144":-5,"_47":48,"_46":14,"_146":31,"_44":238,"_13":181,"_39":40,"_41":43,"_30":31,"_149":-5,"_223":239,"_33":240},{"_49":172,"_38":173,"_36":174,"_144":-5,"_47":48,"_46":175,"_146":65,"_44":235,"_13":69,"_39":40,"_41":177,"_30":31,"_149":-5,"_223":236,"_33":237},{"_49":165,"_38":166,"_36":63,"_144":-5,"_47":48,"_46":167,"_146":31,"_44":232,"_13":69,"_39":169,"_41":170,"_30":31,"_149":-5,"_223":233,"_33":234},{"_49":158,"_38":159,"_36":160,"_144":-5,"_47":48,"_46":161,"_146":65,"_44":229,"_13":69,"_39":40,"_41":163,"_30":31,"_149":-5,"_223":230,"_33":231},{"_49":151,"_38":152,"_36":153,"_144":-5,"_47":48,"_46":154,"_146":65,"_44":226,"_13":69,"_39":40,"_41":156,"_30":31,"_149":-5,"_223":227,"_33":228},{"_49":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":65,"_44":222,"_13":69,"_39":40,"_41":148,"_30":31,"_149":-5,"_223":224,"_33":225},["D",1779282075594],"children",[],[142],["D",1779282088344],[],[152],["D",1779282147325],[],[159],["D",1779282202494],[],[166],["D",1779282117994],[],[173],["D",1779282489434],[],[34],["D",1779282176122],[],[184],["D",1779282069314],[],[191],["D",1779282223701],[],[197],["D",1779282054957],{"_103":102,"_110":105},{"_103":102,"_104":105,"_106":105,"_19":61,"_107":108,"_109":31},{"_13":92,"_38":93,"_49":48,"_94":50,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":51,"_101":102},"ctx",{"_85":-5,"_129":287,"_288":289,"_290":291,"_292":31,"_293":31,"_294":31,"_295":65,"_296":-5,"_297":-7,"_298":-7,"_299":69,"_300":31,"_301":31,"_302":-5,"_303":31,"_304":31,"_305":31,"_306":-5},"ENV",{"_258":259,"_260":261,"_262":93,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286},"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 · v10