[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_228":229,"_230":231},"routes/_app.x.$handle.$name",{"_101":100,"_37":49,"_109":91,"_32":103,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_26":-5,"_120":-5,"_121":-5,"_122":30,"_123":124,"_125":30,"_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",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":30},"version",7,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","e973bb0f-3839-460c-b328-7eb388f0a512","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","reporter.ts","latestPath","fileId","e6ad32fa-5a50-11f1-a615-ee650bb23af1","name","fileType","script","content","// Telegram report generator — sends detailed 15-min reports\nimport * as ccxt from \"npm:ccxt@4\";\nimport { CONFIG } from \"./config.ts\";\nimport { sendTelegram, formatUSD, formatPct } from \"./telegram.ts\";\nimport { loadTrades, loadClosedTrades, getAllocatedCapital } from \"./trade-manager.ts\";\nimport { withRetry } from \"./exchange.ts\";\nimport type { ScanResult } from \"./scanner.ts\";\n\nexport async function sendDetailedReport(\n exchange: ccxt.binance,\n scanResults: ScanResult[],\n): Promise {\n try {\n // 1. Fetch account balance\n const balance = await withRetry(exchange, () => exchange.fetchBalance());\n const usdtBalance = balance.total?.USDT || 0;\n const usdtFree = balance.free?.USDT || 0;\n\n // 2. Load trade data\n const activeTrades = await loadTrades();\n const closedTrades = await loadClosedTrades();\n const allocated = getAllocatedCapital(activeTrades);\n const freeCapital = CONFIG.TOTAL_TRADING_BUDGET - allocated;\n const activeCount = activeTrades.filter(t => t.status === \"active\").length;\n\n // 3. Calculate PnL summary\n const recentClosed = closedTrades.slice(-10); // last 10 closed\n const totalPnL = recentClosed.reduce((s, t) => s + (t.pnl || 0), 0);\n const wins = recentClosed.filter(t => (t.pnl || 0) > 0).length;\n const losses = recentClosed.filter(t => (t.pnl || 0) < 0).length;\n const winRate = recentClosed.length > 0 ? (wins / recentClosed.length * 100).toFixed(1) : \"N/A\";\n\n // 4. Build active trades section\n let activeTradeLines = \"\";\n for (const trade of activeTrades.filter(t => t.status === \"active\")) {\n try {\n const ticker = await withRetry(exchange, () =>\n exchange.fetchTicker(trade.symbol)\n );\n const currPrice = ticker.last || 0;\n const unrealizedPnL = (currPrice - trade.entryPrice) * trade.quantity;\n const pnlPct = ((currPrice - trade.entryPrice) / trade.entryPrice * 100).toFixed(2);\n const emoji = unrealizedPnL >= 0 ? \"📈\" : \"📉\";\n activeTradeLines += `\\n${emoji} ${trade.symbol}\n Entry: ${formatUSD(trade.entryPrice)} → Now: ${formatUSD(currPrice)}\n PnL: ${formatUSD(unrealizedPnL)} (${pnlPct}%)\n TP: ${formatUSD(trade.takeProfitPrice)} | SL: ${formatUSD(trade.stopLossPrice)}`;\n } catch {\n activeTradeLines += `\\n⚠️ ${trade.symbol} — price fetch failed`;\n }\n }\n if (!activeTradeLines) activeTradeLines = \"\\n No active trades\";\n\n // 5. Scan summary\n const signals = scanResults.filter(r => r.signal);\n const nearOversold = scanResults.filter(r => r.rsi < 40 && !r.signal);\n\n let scanSummary = `📡 Scanned: ${scanResults.length} pairs`;\n if (signals.length > 0) {\n scanSummary += `\\n🚨 Signals: ${signals.map(s => `${s.symbol} (RSI:${s.rsi})`).join(\", \")}`;\n } else {\n scanSummary += `\\n No entry signals detected`;\n }\n if (nearOversold.length > 0) {\n scanSummary += `\\n👀 Watchlist (RSI<40): ${nearOversold.slice(0, 5).map(s => `${s.symbol}:${s.rsi}`).join(\", \")}`;\n }\n\n // 6. Compose full report\n const report = `📊 BOT STATUS REPORT\n━━━━━━━━━━━━━━━━━━\n⏰ ${new Date().toISOString()}\n\n💰 ACCOUNT BALANCE\n Total USDT: ${formatUSD(usdtBalance)}\n Available: ${formatUSD(usdtFree)}\n\n💼 BUDGET STATUS\n Budget: ${formatUSD(CONFIG.TOTAL_TRADING_BUDGET)}\n Locked: ${formatUSD(allocated)} (${activeCount} trades)\n Free: ${formatUSD(freeCapital)}\n Slots: ${5 - activeCount}/5 available\n\n📈 ACTIVE TRADES${activeTradeLines}\n\n📋 RECENT PERFORMANCE\n Total PnL (last 10): ${formatUSD(totalPnL)}\n Win/Loss: ${wins}W / ${losses}L (${winRate}%)\n\n${scanSummary}\n━━━━━━━━━━━━━━━━━━\n🤖 Next scan in ~5 min | Next report in ~15 min`;\n\n await sendTelegram(report);\n console.log(\"📊 Detailed report sent to Telegram\");\n } catch (err: any) {\n console.error(\"Failed to send report:\", err.message);\n await sendTelegram(`⚠️ Report generation failed: ${err.message}`);\n }\n}\n","createdAt",["D",1779943893907],"branchVersion","branchId","98d049c8-5a50-11f1-a4ad-ee650bb23af1","id","98cf523e-5a50-11f1-a4ad-ee650bb23af1","binance-testnet-bot",["D",1779943763280],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Binance Testnet CCXT bot with momentum scalping & Telegram","imageUrl","ee0b46f1-52b5-44dd-bbe0-00bbfbb15e28","pinnedFileId","00c05e1a-5a51-11f1-a21b-ee650bb23af1","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e679a-b021-738e-8abd-9bbcaf722270","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":59,"_105":106,"_107":30},"branch",{"_13":90,"_37":91,"_47":46,"_92":48,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":49,"_99":100},"isOwned",10,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gazasnip11jfjfx","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_47":48,"_37":49,"_42":224,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":225,"_85":226,"_87":227,"_89":30},"tree",[195,196,197,198,199,200,201],"files",[195,196,197,198,199,200,201],"counts",{"_185":67,"_186":181,"_187":67,"_188":189,"_190":191},"contents",[130,131,132,133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":178,"_37":179,"_35":180,"_140":-5,"_45":46,"_44":181,"_142":63,"_42":182,"_13":67,"_38":39,"_40":183,"_29":30,"_145":-5,"_32":184},{"_47":171,"_37":172,"_35":173,"_140":-5,"_45":46,"_44":174,"_142":63,"_42":175,"_13":67,"_38":39,"_40":176,"_29":30,"_145":-5,"_32":177},{"_47":164,"_37":165,"_35":166,"_140":-5,"_45":46,"_44":167,"_142":63,"_42":168,"_13":67,"_38":39,"_40":169,"_29":30,"_145":-5,"_32":170},{"_47":161,"_37":33,"_35":36,"_140":-5,"_45":46,"_44":14,"_142":63,"_42":162,"_13":67,"_38":39,"_40":41,"_29":30,"_145":-5,"_32":163},{"_47":154,"_37":155,"_35":156,"_140":-5,"_45":46,"_44":157,"_142":63,"_42":158,"_13":67,"_38":39,"_40":159,"_29":30,"_145":-5,"_32":160},{"_47":147,"_37":148,"_35":149,"_140":-5,"_45":46,"_44":150,"_142":63,"_42":151,"_13":67,"_38":39,"_40":152,"_29":30,"_145":-5,"_32":153},{"_47":137,"_37":138,"_35":139,"_140":-5,"_45":46,"_44":141,"_142":63,"_42":143,"_13":67,"_38":39,"_40":144,"_29":30,"_145":-5,"_32":146},"cdff1d72-5a50-11f1-bf3f-ee650bb23af1","trade-manager.ts","cdff1e26-5a50-11f1-bf3f-ee650bb23af1","parentId",5,"latest",["D",1779943852497],"// Trade management: tracking, TP/SL monitoring, PnL\nimport * as ccxt from \"npm:ccxt@4\";\nimport { CONFIG, type ActiveTrade } from \"./config.ts\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sendTelegram, formatUSD, formatPct } from \"./telegram.ts\";\nimport { withRetry } from \"./exchange.ts\";\n\nconst TRADES_KEY = \"binance_bot_active_trades\";\nconst CLOSED_KEY = \"binance_bot_closed_trades\";\n\nexport async function loadTrades(): Promise {\n try {\n return (await blob.getJSON(TRADES_KEY)) as ActiveTrade[] || [];\n } catch {\n return [];\n }\n}\n\nexport async function saveTrades(trades: ActiveTrade[]): Promise {\n await blob.setJSON(TRADES_KEY, trades);\n}\n\nexport async function loadClosedTrades(): Promise {\n try {\n return (await blob.getJSON(CLOSED_KEY)) as ActiveTrade[] || [];\n } catch {\n return [];\n }\n}\n\nasync function appendClosedTrade(trade: ActiveTrade): Promise {\n const closed = await loadClosedTrades();\n closed.push(trade);\n // Keep last 100 closed trades\n if (closed.length > 100) closed.splice(0, closed.length - 100);\n await blob.setJSON(CLOSED_KEY, closed);\n}\n\nexport function getAllocatedCapital(trades: ActiveTrade[]): number {\n return trades\n .filter(t => t.status === \"active\")\n .reduce((sum, t) => sum + t.allocation, 0);\n}\n\nexport function canOpenNewTrade(trades: ActiveTrade[]): boolean {\n const allocated = getAllocatedCapital(trades);\n return allocated + CONFIG.ALLOCATION_PER_TRADE <= CONFIG.TOTAL_TRADING_BUDGET;\n}\n\nexport async function openTrade(\n exchange: ccxt.binance,\n symbol: string,\n currentPrice: number,\n): Promise {\n const trades = await loadTrades();\n\n // Check if already in this symbol\n if (trades.some(t => t.symbol === symbol && t.status === \"active\")) {\n console.log(`Already have active trade in ${symbol}, skipping`);\n return null;\n }\n\n if (!canOpenNewTrade(trades)) {\n console.log(\"Max allocation reached, cannot open new trade\");\n return null;\n }\n\n const allocation = CONFIG.ALLOCATION_PER_TRADE;\n const quantity = allocation / currentPrice;\n\n try {\n const order = await withRetry(exchange, () =>\n exchange.createMarketBuyOrder(symbol, quantity)\n );\n\n const filledPrice = order.average || order.price || currentPrice;\n const filledQty = order.filled || quantity;\n\n const trade: ActiveTrade = {\n id: order.id || `${Date.now()}-${symbol}`,\n symbol,\n side: \"buy\",\n entryPrice: filledPrice,\n quantity: filledQty,\n allocation,\n takeProfitPrice: filledPrice * (1 + CONFIG.TAKE_PROFIT_PCT),\n stopLossPrice: filledPrice * (1 - CONFIG.STOP_LOSS_PCT),\n entryTime: Date.now(),\n status: \"active\",\n };\n\n trades.push(trade);\n await saveTrades(trades);\n\n const msg = `🟢 NEW TRADE OPENED\n━━━━━━━━━━━━━━━━━━\n📊 Symbol: ${symbol}\n💰 Entry: ${formatUSD(filledPrice)}\n📦 Qty: ${filledQty.toFixed(6)}\n💵 Allocation: ${formatUSD(allocation)}\n🎯 TP: ${formatUSD(trade.takeProfitPrice)} (+${formatPct(CONFIG.TAKE_PROFIT_PCT)})\n🛑 SL: ${formatUSD(trade.stopLossPrice)} (-${formatPct(CONFIG.STOP_LOSS_PCT)})\n⏰ Time: ${new Date().toISOString()}`;\n\n await sendTelegram(msg);\n console.log(`✅ Opened trade: ${symbol} @ ${filledPrice}`);\n return trade;\n } catch (err: any) {\n console.error(`Failed to open trade ${symbol}:`, err.message);\n await sendTelegram(`❌ Failed to open ${symbol}: ${err.message}`);\n return null;\n }\n}\n\nexport async function monitorTrades(exchange: ccxt.binance): Promise {\n const trades = await loadTrades();\n const activeTrades = trades.filter(t => t.status === \"active\");\n\n if (activeTrades.length === 0) return;\n\n for (const trade of activeTrades) {\n try {\n const ticker = await withRetry(exchange, () =>\n exchange.fetchTicker(trade.symbol)\n );\n const currentPrice = ticker.last || ticker.close || 0;\n if (!currentPrice) continue;\n\n // Check Take Profit\n if (currentPrice >= trade.takeProfitPrice) {\n await closeTrade(exchange, trade, currentPrice, \"tp_hit\");\n }\n // Check Stop Loss\n else if (currentPrice <= trade.stopLossPrice) {\n await closeTrade(exchange, trade, currentPrice, \"sl_hit\");\n }\n } catch (err: any) {\n console.error(`Error monitoring ${trade.symbol}:`, err.message);\n }\n }\n}\n\nasync function closeTrade(\n exchange: ccxt.binance,\n trade: ActiveTrade,\n currentPrice: number,\n reason: \"tp_hit\" | \"sl_hit\" | \"closed\",\n): Promise {\n try {\n // Sell the position\n await withRetry(exchange, () =>\n exchange.createMarketSellOrder(trade.symbol, trade.quantity)\n );\n } catch (err: any) {\n console.error(`Failed to sell ${trade.symbol}:`, err.message);\n // Still mark as closed to avoid stuck trades\n }\n\n trade.status = reason;\n trade.exitPrice = currentPrice;\n trade.exitTime = Date.now();\n trade.pnl = (currentPrice - trade.entryPrice) * trade.quantity;\n\n // Update storage\n const trades = await loadTrades();\n const idx = trades.findIndex(t => t.id === trade.id);\n if (idx >= 0) trades[idx] = trade;\n const stillActive = trades.filter(t => t.status === \"active\");\n await saveTrades(stillActive);\n await appendClosedTrade(trade);\n\n const emoji = reason === \"tp_hit\" ? \"🎯✅\" : \"🛑❌\";\n const pnlEmoji = (trade.pnl || 0) >= 0 ? \"📈\" : \"📉\";\n\n const msg = `${emoji} TRADE ${reason === \"tp_hit\" ? \"TP HIT\" : \"SL HIT\"}\n━━━━━━━━━━━━━━━━━━\n📊 Symbol: ${trade.symbol}\n💰 Entry: ${formatUSD(trade.entryPrice)}\n💸 Exit: ${formatUSD(currentPrice)}\n${pnlEmoji} PnL: ${formatUSD(trade.pnl || 0)}\n⏱ Duration: ${Math.round((Date.now() - trade.entryTime) / 60000)} min`;\n\n await sendTelegram(msg);\n console.log(`${reason}: ${trade.symbol} PnL: ${trade.pnl?.toFixed(2)}`);\n}\n","label",[138],"b0e6de8c-5a50-11f1-8cc0-ee650bb23af1","telegram.ts","b0e6df68-5a50-11f1-8cc0-ee650bb23af1",3,["D",1779943803688],"// Telegram notification helper\nimport { CONFIG } from \"./config.ts\";\n\nexport async function sendTelegram(message: string): Promise {\n try {\n const url = `https://api.telegram.org/bot${CONFIG.TELEGRAM_TOKEN}/sendMessage`;\n const resp = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: CONFIG.CHAT_ID,\n text: message,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n\n if (!resp.ok) {\n console.error(\"Telegram send failed:\", resp.status, await resp.text());\n return false;\n }\n return true;\n } catch (err) {\n console.error(\"Telegram error:\", err);\n return false;\n }\n}\n\nexport function formatUSD(n: number): string {\n return `$${n.toFixed(2)}`;\n}\n\nexport function formatPct(n: number): string {\n return `${(n * 100).toFixed(2)}%`;\n}\n",[148],"d8a968c2-5a50-11f1-9621-ee650bb23af1","scanner.ts","d8a9698a-5a50-11f1-9621-ee650bb23af1",6,["D",1779943870392],"// Market scanner: scans USDT pairs for momentum + volume signals\nimport * as ccxt from \"npm:ccxt@4\";\nimport { CONFIG } from \"./config.ts\";\nimport { calculateRSI, calculateMACD, detectVolumeSpike } from \"./indicators.ts\";\nimport { withRetry } from \"./exchange.ts\";\n\nexport interface ScanResult {\n symbol: string;\n price: number;\n rsi: number;\n macdBullishCross: boolean;\n volumeSpike: boolean;\n signal: boolean;\n volume24h: number;\n}\n\n// Top USDT pairs typically available on Binance testnet\nconst TESTNET_PAIRS = [\n \"BTC/USDT\", \"ETH/USDT\", \"BNB/USDT\", \"XRP/USDT\", \"SOL/USDT\",\n \"ADA/USDT\", \"DOGE/USDT\", \"DOT/USDT\", \"LTC/USDT\", \"LINK/USDT\",\n \"AVAX/USDT\", \"MATIC/USDT\", \"UNI/USDT\", \"ATOM/USDT\", \"ETC/USDT\",\n \"FIL/USDT\", \"TRX/USDT\", \"NEAR/USDT\", \"APT/USDT\", \"ARB/USDT\",\n];\n\nexport async function scanMarkets(exchange: ccxt.binance): Promise {\n const results: ScanResult[] = [];\n const scannedCount = { total: 0, errors: 0 };\n\n // Load available markets first\n await withRetry(exchange, () => exchange.loadMarkets());\n\n // Filter to pairs that exist on testnet\n const availablePairs = TESTNET_PAIRS.filter(p => exchange.markets[p]);\n console.log(`Scanning ${availablePairs.length} USDT pairs...`);\n\n for (const symbol of availablePairs) {\n try {\n scannedCount.total++;\n\n // Fetch OHLCV data (1h candles, last 50)\n const ohlcv = await withRetry(exchange, () =>\n exchange.fetchOHLCV(symbol, \"1h\", undefined, 50)\n );\n\n if (!ohlcv || ohlcv.length < 30) {\n console.log(`${symbol}: insufficient OHLCV data (${ohlcv?.length || 0} candles)`);\n continue;\n }\n\n const closes = ohlcv.map(c => c[4] as number);\n const volumes = ohlcv.map(c => c[5] as number);\n const currentPrice = closes[closes.length - 1];\n\n // Calculate indicators\n const rsi = calculateRSI(closes, CONFIG.RSI_PERIOD);\n const macd = calculateMACD(closes, CONFIG.MACD_FAST, CONFIG.MACD_SLOW, CONFIG.MACD_SIGNAL);\n const volumeSpike = detectVolumeSpike(volumes, CONFIG.VOLUME_SPIKE_MULTIPLIER);\n\n // Entry signal: RSI oversold + Bullish MACD crossover + Volume spike\n const signal = rsi < CONFIG.RSI_OVERSOLD && macd.bullishCrossover && volumeSpike;\n\n const result: ScanResult = {\n symbol,\n price: currentPrice,\n rsi: Math.round(rsi * 100) / 100,\n macdBullishCross: macd.bullishCrossover,\n volumeSpike,\n signal,\n volume24h: volumes[volumes.length - 1],\n };\n\n results.push(result);\n\n if (signal) {\n console.log(`🚨 SIGNAL: ${symbol} — RSI: ${rsi.toFixed(1)}, MACD cross: ✅, Volume spike: ✅`);\n }\n\n // Rate limiting between symbols\n await new Promise(r => setTimeout(r, 500));\n } catch (err: any) {\n scannedCount.errors++;\n console.warn(`Failed to scan ${symbol}: ${err.message}`);\n }\n }\n\n console.log(`Scan complete: ${scannedCount.total} pairs, ${scannedCount.errors} errors, ${results.filter(r => r.signal).length} signals`);\n return results;\n}\n",[155],"e6ad3232-5a50-11f1-a615-ee650bb23af1",["D",1779943893907],[33],"ad2a17fa-5a50-11f1-9621-ee650bb23af1","indicators.ts","ad2a18c2-5a50-11f1-9621-ee650bb23af1",2,["D",1779943797414],"// Technical indicators: RSI, MACD, Volume analysis\n\nexport function calculateRSI(closes: number[], period = 14): number {\n if (closes.length < period + 1) return 50; // neutral if not enough data\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 using Wilder's method\n for (let i = period + 1; i < closes.length; i++) {\n const diff = closes[i] - closes[i - 1];\n const gain = diff > 0 ? diff : 0;\n const loss = diff < 0 ? Math.abs(diff) : 0;\n avgGain = (avgGain * (period - 1) + gain) / period;\n avgLoss = (avgLoss * (period - 1) + loss) / period;\n }\n\n if (avgLoss === 0) return 100;\n const rs = avgGain / avgLoss;\n return 100 - 100 / (1 + rs);\n}\n\nexport function calculateEMA(data: number[], period: number): number[] {\n const ema: number[] = [];\n const multiplier = 2 / (period + 1);\n\n // Start with SMA for the first EMA value\n let sum = 0;\n for (let i = 0; i < period; i++) {\n sum += data[i];\n }\n ema.push(sum / period);\n\n for (let i = period; i < data.length; i++) {\n ema.push((data[i] - ema[ema.length - 1]) * multiplier + ema[ema.length - 1]);\n }\n return ema;\n}\n\nexport interface MACDResult {\n macdLine: number;\n signalLine: number;\n histogram: number;\n prevHistogram: number;\n bullishCrossover: boolean;\n}\n\nexport function calculateMACD(\n closes: number[],\n fastPeriod = 12,\n slowPeriod = 26,\n signalPeriod = 9,\n): MACDResult {\n const emaFast = calculateEMA(closes, fastPeriod);\n const emaSlow = calculateEMA(closes, slowPeriod);\n\n // Align arrays — EMA slow starts later\n const offset = slowPeriod - fastPeriod;\n const macdLine: number[] = [];\n for (let i = 0; i < emaSlow.length; i++) {\n macdLine.push(emaFast[i + offset] - emaSlow[i]);\n }\n\n if (macdLine.length < signalPeriod + 1) {\n return { macdLine: 0, signalLine: 0, histogram: 0, prevHistogram: 0, bullishCrossover: false };\n }\n\n const signalLineArr = calculateEMA(macdLine, signalPeriod);\n\n const currentMACD = macdLine[macdLine.length - 1];\n const currentSignal = signalLineArr[signalLineArr.length - 1];\n const histogram = currentMACD - currentSignal;\n\n // Previous histogram for crossover detection\n const prevIdx = macdLine.length - 2;\n const sigOffset = signalLineArr.length - macdLine.length + signalPeriod - 1;\n const prevSignal = signalLineArr.length >= 2 ? signalLineArr[signalLineArr.length - 2] : currentSignal;\n const prevMACD = macdLine[prevIdx] ?? currentMACD;\n const prevHistogram = prevMACD - prevSignal;\n\n // Bullish crossover: histogram crosses from negative to positive\n const bullishCrossover = prevHistogram < 0 && histogram >= 0;\n\n return { macdLine: currentMACD, signalLine: currentSignal, histogram, prevHistogram, bullishCrossover };\n}\n\nexport function detectVolumeSpike(volumes: number[], multiplier = 1.5): boolean {\n if (volumes.length < 21) return false;\n\n // Average of previous 20 candles (excluding the most recent)\n const recentVolumes = volumes.slice(-21, -1);\n const avgVolume = recentVolumes.reduce((a, b) => a + b, 0) / recentVolumes.length;\n const currentVolume = volumes[volumes.length - 1];\n\n return currentVolume > avgVolume * multiplier;\n}\n",[165],"b84230c8-5a50-11f1-a615-ee650bb23af1","exchange.ts","b842317c-5a50-11f1-a615-ee650bb23af1",4,["D",1779943816031],"// CCXT exchange initialization with anti-block & geo-bypass logic\nimport * as ccxt from \"npm:ccxt@4\";\nimport { CONFIG } from \"./config.ts\";\n\nlet currentUAIndex = 0;\n\nfunction getNextUserAgent(): string {\n const ua = CONFIG.USER_AGENTS[currentUAIndex % CONFIG.USER_AGENTS.length];\n currentUAIndex++;\n return ua;\n}\n\nexport function createExchange(): ccxt.binance {\n const exchange = new ccxt.binance({\n apiKey: CONFIG.API_KEY,\n secret: CONFIG.SECRET_KEY,\n options: {\n defaultType: \"spot\",\n adjustForTimeDifference: true,\n },\n headers: {\n \"User-Agent\": getNextUserAgent(),\n \"Accept-Language\": \"en-US,en;q=0.9\",\n \"Accept\": \"application/json\",\n },\n timeout: 30000,\n enableRateLimit: true,\n });\n\n // CRITICAL: enable sandbox/testnet mode\n exchange.setSandboxMode(true);\n\n return exchange;\n}\n\n// Retry wrapper with UA rotation for geo-block bypass\nexport async function withRetry(\n exchange: ccxt.binance,\n fn: () => Promise,\n maxRetries = 3,\n): Promise {\n let lastError: Error | null = null;\n\n for (let attempt = 0; attempt < maxRetries; attempt++) {\n try {\n return await fn();\n } catch (err: any) {\n lastError = err;\n const msg = err?.message || \"\";\n const isGeoBlock = err instanceof ccxt.PermissionDenied\n || err instanceof ccxt.ExchangeError\n || msg.includes(\"451\")\n || msg.includes(\"Restricted\")\n || msg.includes(\"restricted location\")\n || msg.includes(\"geo\");\n\n if (isGeoBlock && attempt < maxRetries - 1) {\n console.warn(`⚠️ Geo-block detected (attempt ${attempt + 1}/${maxRetries}). Rotating headers...`);\n // Rotate User-Agent\n exchange.headers = {\n ...exchange.headers,\n \"User-Agent\": getNextUserAgent(),\n \"X-Forwarded-For\": `${Math.floor(Math.random() * 255)}.${Math.floor(Math.random() * 255)}.${Math.floor(Math.random() * 255)}.${Math.floor(Math.random() * 255)}`,\n };\n // Small delay before retry\n await new Promise(r => setTimeout(r, 2000 * (attempt + 1)));\n continue;\n }\n\n // For non-geo errors or exhausted retries, throw\n throw err;\n }\n }\n\n throw lastError;\n}\n",[172],"a3044fc0-5a50-11f1-a615-ee650bb23af1","config.ts","a3045074-5a50-11f1-a615-ee650bb23af1",1,["D",1779943780393],"// Configuration — all secrets read from environment variables\nexport const CONFIG = {\n API_KEY: Deno.env.get(\"BINANCE_API_KEY\") || \"\",\n SECRET_KEY: Deno.env.get(\"BINANCE_SECRET_KEY\") || \"\",\n TELEGRAM_TOKEN: Deno.env.get(\"TELEGRAM_TOKEN\") || \"\",\n CHAT_ID: Deno.env.get(\"TELEGRAM_CHAT_ID\") || \"\",\n\n // Capital allocation\n TOTAL_TRADING_BUDGET: 100, // $100 USDT max\n ALLOCATION_PER_TRADE: 20, // $20 per trade (max 5 simultaneous)\n\n // Risk management\n TAKE_PROFIT_PCT: 0.02, // 2% TP\n STOP_LOSS_PCT: 0.01, // 1% SL\n\n // Strategy parameters\n RSI_PERIOD: 14,\n RSI_OVERSOLD: 30,\n MACD_FAST: 12,\n MACD_SLOW: 26,\n MACD_SIGNAL: 9,\n VOLUME_SPIKE_MULTIPLIER: 1.5, // volume must be 1.5x average\n\n // Timing\n SCAN_INTERVAL_MS: 5 * 60 * 1000, // scan every 5 min\n REPORT_INTERVAL_MS: 15 * 60 * 1000, // report every 15 min\n\n // Anti-block: rotating user agents\n USER_AGENTS: [\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/125.0.0.0 Safari/537.36\",\n \"Mozilla/5.0 (Macintosh; Intel Mac OS X 14_5) AppleWebKit/605.1.15 Safari/605.1.15\",\n \"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 Chrome/124.0.0.0 Safari/537.36\",\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:126.0) Gecko/20100101 Firefox/126.0\",\n \"Mozilla/5.0 (Macintosh; Intel Mac OS X 14_5) AppleWebKit/537.36 Chrome/125.0.0.0 Safari/537.36\",\n ],\n};\n\nexport interface ActiveTrade {\n id: string;\n symbol: string;\n side: \"buy\";\n entryPrice: number;\n quantity: number;\n allocation: number;\n takeProfitPrice: number;\n stopLossPrice: number;\n entryTime: number;\n status: \"active\" | \"tp_hit\" | \"sl_hit\" | \"closed\";\n exitPrice?: number;\n exitTime?: number;\n pnl?: number;\n}\n",[179],"pulls","branches","forks","envVars",{"_192":174,"_194":67},"connections",{"_192":67,"_193":67},"count","unfilledCount","emptyCount",{"_47":178,"_37":179,"_35":180,"_140":-5,"_45":46,"_44":181,"_142":63,"_42":221,"_13":67,"_38":39,"_40":183,"_29":30,"_145":-5,"_203":222,"_32":223},{"_47":171,"_37":172,"_35":173,"_140":-5,"_45":46,"_44":174,"_142":63,"_42":218,"_13":67,"_38":39,"_40":176,"_29":30,"_145":-5,"_203":219,"_32":220},{"_47":164,"_37":165,"_35":166,"_140":-5,"_45":46,"_44":167,"_142":63,"_42":215,"_13":67,"_38":39,"_40":169,"_29":30,"_145":-5,"_203":216,"_32":217},{"_47":161,"_37":33,"_35":36,"_140":-5,"_45":46,"_44":14,"_142":63,"_42":212,"_13":67,"_38":39,"_40":41,"_29":30,"_145":-5,"_203":213,"_32":214},{"_47":154,"_37":155,"_35":156,"_140":-5,"_45":46,"_44":157,"_142":63,"_42":209,"_13":67,"_38":39,"_40":159,"_29":30,"_145":-5,"_203":210,"_32":211},{"_47":147,"_37":148,"_35":149,"_140":-5,"_45":46,"_44":150,"_142":63,"_42":206,"_13":67,"_38":39,"_40":152,"_29":30,"_145":-5,"_203":207,"_32":208},{"_47":137,"_37":138,"_35":139,"_140":-5,"_45":46,"_44":141,"_142":63,"_42":202,"_13":67,"_38":39,"_40":144,"_29":30,"_145":-5,"_203":204,"_32":205},["D",1779943852497],"children",[],[138],["D",1779943803688],[],[148],["D",1779943870392],[],[155],["D",1779943893907],[],[33],["D",1779943797414],[],[165],["D",1779943816031],[],[172],["D",1779943780393],[],[179],["D",1779943763280],{"_101":100,"_108":103},{"_101":100,"_102":103,"_104":103,"_19":59,"_105":106,"_107":30},{"_13":90,"_37":91,"_47":46,"_92":48,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":49,"_99":100},"ctx",{"_83":-5,"_127":261,"_262":263,"_264":265,"_266":30,"_267":30,"_268":30,"_269":63,"_270":-5,"_271":-7,"_272":-7,"_273":67,"_274":30,"_275":30,"_276":-5,"_277":30,"_278":30,"_279":30,"_280":-5},"ENV",{"_232":233,"_234":235,"_236":91,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260},"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 · v7