[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_249":250,"_251":252},"routes/_app.x.$handle.$name",{"_103":102,"_39":53,"_110":93,"_34":61,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_26":-5,"_121":-5,"_122":-5,"_123":33,"_124":125,"_126":33,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_51":52,"_39":53,"_46":54,"_55":-5,"_56":33,"_57":58,"_59":58,"_60":61,"_62":-5,"_19":63,"_64":-5,"_65":33,"_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":33},"version",18,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","caa23a74-dc46-4265-85b1-3a504513b115","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":33,"_34":35,"_36":35},"file",{"_37":38,"_39":40,"_41":42,"_43":45,"_46":47,"_48":14,"_49":50,"_30":33},"previous",{"_37":38,"_39":40,"_41":42,"_43":44},"deleted",true,"deletedHere",false,"path","lib/telegram.ts","latestPath","fileId","5e17e5d4-5401-11f1-9aa2-ee650bb23af1","name","telegram.ts","fileType","script","content","// ═══════════════════════════════════════════════════════════\n// 📱 TELEGRAM NOTIFICATIONS\n// ═══════════════════════════════════════════════════════════\n\nimport { TELEGRAM_TOKEN, CHAT_ID } from \"./config.ts\";\n\nconst TG_API = `https://api.telegram.org/bot${TELEGRAM_TOKEN}`;\n\nexport async function sendTelegram(text: string): Promise {\n try {\n const res = await fetch(`${TG_API}/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 const data = await res.json();\n if (!data.ok) {\n console.error(\"Telegram error:\", data.description);\n return false;\n }\n return true;\n } catch (err) {\n console.error(\"Telegram send failed:\", err);\n return false;\n }\n}\n\n// ── Formatted Messages ──────────────────────────────────\n\nexport function formatTradeAlert(params: {\n symbol: string;\n rsi: number;\n price: number;\n qty: number;\n tp: number;\n sl: number;\n orderId: string | number;\n}): string {\n const { symbol, rsi, price, qty, tp, sl, orderId } = params;\n return [\n `🟢 HALAL OPPORTUNITY SNIPED`,\n ``,\n `🪙 Symbol: ${symbol}`,\n `📊 RSI(14): ${rsi.toFixed(2)}`,\n `💰 Entry Price: $${price.toFixed(6)}`,\n `📦 Quantity: ${qty}`,\n ``,\n `🎯 Take Profit (1%): $${tp.toFixed(6)}`,\n `🛡️ Stop Loss (1%): $${sl.toFixed(6)}`,\n `📋 Order ID: ${orderId}`,\n ``,\n `⏰ ${new Date().toUTCString()}`,\n ].join(\"\\n\");\n}\n\nexport function formatScanSummary(params: {\n totalPairs: number;\n halalPairs: number;\n scanned: number;\n signals: number;\n successful: number;\n failed: number;\n balance: string;\n errors: string[];\n}): string {\n const { totalPairs, halalPairs, scanned, signals, successful, failed, balance, errors } = params;\n const lines = [\n `📡 15-MIN SCAN SUMMARY`,\n `━━━━━━━━━━━━━━━━━━━━`,\n ``,\n `🔍 Total USDT Pairs: ${totalPairs}`,\n `🕌 Halal Filtered: ${halalPairs}`,\n `📊 RSI Analyzed: ${scanned}`,\n ``,\n `⚡ Strong Buy Signals: ${signals}`,\n `✅ Successful Trades: ${successful}`,\n `❌ Failed Trades: ${failed}`,\n ``,\n `💼 Account Balance:`,\n balance,\n ``,\n `⏰ ${new Date().toUTCString()}`,\n ];\n if (errors.length > 0) {\n lines.push(``, `⚠️ Errors:`);\n errors.slice(0, 5).forEach((e) => lines.push(`• ${e}`));\n }\n return lines.join(\"\\n\");\n}\n\nexport function formatErrorAlert(error: string): string {\n return [\n `🔴 BOT ERROR`,\n ``,\n `${error}`,\n ``,\n `⏰ ${new Date().toUTCString()}`,\n ].join(\"\\n\");\n}\n","// ═══════════════════════════════════════════════════════════\n// 📱 TELEGRAM NOTIFICATIONS\n// ═══════════════════════════════════════════════════════════\n\nimport { TELEGRAM_TOKEN, CHAT_ID } from \"./config.ts\";\n\nconst TG_API = `https://api.telegram.org/bot${TELEGRAM_TOKEN}`;\n\n/** Escape HTML special characters for Telegram HTML parse mode */\nfunction esc(text: string | number): string {\n return String(text)\n .replace(/&/g, \"&\")\n .replace(//g, \">\");\n}\n\nexport async function sendTelegram(text: string): Promise {\n try {\n const res = await fetch(`${TG_API}/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 const data = await res.json();\n if (!data.ok) {\n console.error(\"Telegram error:\", data.description);\n return false;\n }\n return true;\n } catch (err) {\n console.error(\"Telegram send failed:\", err);\n return false;\n }\n}\n\n// ── Formatted Messages ──────────────────────────────────\n\nexport function formatTradeAlert(params: {\n symbol: string;\n rsi: number;\n price: number;\n qty: number;\n tp: number;\n sl: number;\n orderId: string | number;\n}): string {\n const { symbol, rsi, price, qty, tp, sl, orderId } = params;\n return [\n `🟢 HALAL OPPORTUNITY SNIPED`,\n ``,\n `🪙 Symbol: ${symbol}`,\n `📊 RSI(14): ${rsi.toFixed(2)}`,\n `💰 Entry Price: $${price.toFixed(6)}`,\n `📦 Quantity: ${qty}`,\n ``,\n `🎯 Take Profit (1%): $${tp.toFixed(6)}`,\n `🛡️ Stop Loss (1%): $${sl.toFixed(6)}`,\n `📋 Order ID: ${orderId}`,\n ``,\n `⏰ ${new Date().toUTCString()}`,\n ].join(\"\\n\");\n}\n\nexport function formatScanSummary(params: {\n totalPairs: number;\n halalPairs: number;\n scanned: number;\n signals: number;\n successful: number;\n failed: number;\n balance: string;\n errors: string[];\n}): string {\n const { totalPairs, halalPairs, scanned, signals, successful, failed, balance, errors } = params;\n const lines = [\n `📡 15-MIN SCAN SUMMARY`,\n `━━━━━━━━━━━━━━━━━━━━`,\n ``,\n `🔍 Total USDT Pairs: ${totalPairs}`,\n `🕌 Halal Filtered: ${halalPairs}`,\n `📊 RSI Analyzed: ${scanned}`,\n ``,\n `⚡ Strong Buy Signals: ${signals}`,\n `✅ Successful Trades: ${successful}`,\n `❌ Failed Trades: ${failed}`,\n ``,\n `💼 Account Balance:`,\n balance,\n ``,\n `⏰ ${new Date().toUTCString()}`,\n ];\n if (errors.length > 0) {\n lines.push(``, `⚠️ Errors:`);\n errors.slice(0, 5).forEach((e) => lines.push(`• ${e}`));\n }\n return lines.join(\"\\n\");\n}\n\nexport function formatErrorAlert(error: string): string {\n return [\n `🔴 BOT ERROR`,\n ``,\n `${error}`,\n ``,\n `⏰ ${new Date().toUTCString()}`,\n ].join(\"\\n\");\n}\n","createdAt",["D",1779250514925],"branchVersion","branchId","38e019e4-5401-11f1-8e10-ee650bb23af1","id","38df400a-5401-11f1-8e10-ee650bb23af1","FinalTestSuccess",["D",1779249965104],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","f229e767-8e59-4387-8cce-16a509e93302","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e4164-bc26-736d-8288-27a6ada8f2cd","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_103":102,"_109":61},"org",{"_103":102,"_104":61,"_105":61,"_19":63,"_106":107,"_108":33},"branch",{"_13":92,"_39":93,"_51":50,"_94":52,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":53,"_101":102},"isOwned",31,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gazasnip1","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_51":52,"_39":53,"_46":245,"_55":-5,"_56":33,"_57":58,"_59":58,"_60":61,"_62":-5,"_19":63,"_64":-5,"_65":33,"_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":246,"_87":247,"_89":248,"_91":33},"tree",[178,185,186,187],"files",[178,179,180,181,182,183,184,185,186,187],"counts",{"_168":69,"_169":142,"_170":69,"_171":172,"_173":174},"contents",[131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_51":162,"_39":163,"_37":164,"_138":-5,"_49":50,"_48":158,"_140":31,"_46":165,"_13":69,"_41":166,"_43":-5,"_30":33,"_144":-5,"_34":167},{"_51":153,"_39":154,"_37":155,"_138":-5,"_49":50,"_48":156,"_140":33,"_46":157,"_13":158,"_41":159,"_43":160,"_30":33,"_144":-5,"_34":161},{"_51":146,"_39":147,"_37":148,"_138":-5,"_49":50,"_48":149,"_140":33,"_46":150,"_13":69,"_41":42,"_43":151,"_30":33,"_144":-5,"_34":152},{"_51":135,"_39":136,"_37":137,"_138":-5,"_49":50,"_48":139,"_140":33,"_46":141,"_13":142,"_41":42,"_43":143,"_30":33,"_144":-5,"_34":145},"7ab17bb4-5402-11f1-b5e9-ee650bb23af1","test-telegram.ts","7561a6de-5402-11f1-8cd3-ee650bb23af1","parentId",17,"latest",["D",1779250505021],1,"// Quick test: verify Telegram notifications work\nimport { sendTelegram } from \"./lib/telegram.ts\";\n\nconst ok = await sendTelegram([\n `🤖 HALAL MARKET SCANNER — Online!`,\n ``,\n `✅ Bot deployed and running on Val Town`,\n `📡 Scanning Binance USDT pairs every 15 min`,\n `🕌 Halal filter active`,\n `📊 RSI(14) analysis enabled`,\n `💰 Auto-buy on RSI < 30 (20 USDT/trade)`,\n `🎯 TP: +1% / SL: -1%`,\n ``,\n `⏰ ${new Date().toUTCString()}`,\n].join(\"\\n\"));\n\nconsole.log(\"Telegram sent:\", ok);\n","label",[136],"9e337020-5401-11f1-bc92-ee650bb23af1","test-run.ts","9e337138-5401-11f1-bc92-ee650bb23af1",11,["D",1779250135099],"// ═══════════════════════════════════════════════════════════\n// 🧪 MANUAL TEST — Run a single scan cycle\n// Execute this script to test the bot without waiting\n// for the 15-minute interval.\n// ═══════════════════════════════════════════════════════════\n\nimport { runScan } from \"./lib/scanner.ts\";\n\nconsole.log(\"🧪 MANUAL TEST RUN\");\nconsole.log(`⏰ ${new Date().toUTCString()}\\n`);\n\nconst result = await runScan();\n\nconsole.log(\"\\n📋 FINAL RESULTS:\");\nconsole.log(JSON.stringify(result, null, 2));\n",[147],"998179d2-5401-11f1-9aa2-ee650bb23af1","main.ts","38e3c65c-5401-11f1-8e10-ee650bb23af1",10,["D",1779250127189],2,"interval","// ═══════════════════════════════════════════════════════════\n// 🤖 BINANCE SPOT TESTNET — HALAL MARKET SCANNER BOT\n// ═══════════════════════════════════════════════════════════\n//\n// Runs every 15 minutes:\n// 1. Fetches ALL USDT trading pairs from Binance Spot Testnet\n// 2. Filters for Halal-compliant coins\n// 3. Calculates RSI(14) for each pair\n// 4. If RSI < 30 → Market Buy 20 USDT worth\n// 5. Sets 1% Take Profit + 1% Stop Loss\n// 6. Sends Telegram alerts for each trade + summary\n//\n// Endpoints: testnet.binance.vision / api.binance.vision\n// ═══════════════════════════════════════════════════════════\n\nimport { runScan } from \"./lib/scanner.ts\";\n\nexport default async function (interval: Interval) {\n console.log(\"═══════════════════════════════════════════\");\n console.log(\"🤖 HALAL MARKET SCANNER — Cycle Start\");\n console.log(`⏰ ${new Date().toUTCString()}`);\n if (interval.lastRunAt) {\n console.log(`📅 Last run: ${interval.lastRunAt}`);\n }\n console.log(\"═══════════════════════════════════════════\");\n\n const result = await runScan();\n\n console.log(\"\\n📋 RESULTS:\");\n console.log(` Pairs found: ${result.totalPairs}`);\n console.log(` Halal filtered: ${result.halalPairs}`);\n console.log(` RSI analyzed: ${result.scanned}`);\n console.log(` Signals: ${result.signals}`);\n console.log(` Successful: ${result.successful}`);\n console.log(` Failed: ${result.failed}`);\n if (result.errors.length) {\n console.log(` Errors: ${result.errors.length}`);\n }\n console.log(\"═══════════════════════════════════════════\");\n}\n",[154],"472a6644-5401-11f1-9f8d-ee650bb23af1","lib","472a66f8-5401-11f1-9f8d-ee650bb23af1",["D",1779249989078],"directory",[163],"pulls","branches","forks","envVars",{"_175":69,"_177":69},"connections",{"_175":69,"_176":69},"count","unfilledCount","emptyCount",{"_51":162,"_39":163,"_37":164,"_138":-5,"_49":50,"_48":158,"_140":31,"_46":242,"_13":69,"_41":166,"_43":-5,"_30":33,"_144":-5,"_189":243,"_34":244},{"_51":234,"_39":235,"_37":236,"_138":164,"_49":50,"_48":237,"_140":33,"_46":238,"_13":158,"_41":42,"_43":239,"_30":33,"_144":-5,"_189":240,"_34":241},{"_51":226,"_39":227,"_37":228,"_138":164,"_49":50,"_48":229,"_140":33,"_46":230,"_13":158,"_41":42,"_43":231,"_30":33,"_144":-5,"_189":232,"_34":233},{"_51":218,"_39":219,"_37":220,"_138":164,"_49":50,"_48":221,"_140":33,"_46":222,"_13":69,"_41":42,"_43":223,"_30":33,"_144":-5,"_189":224,"_34":225},{"_51":210,"_39":211,"_37":212,"_138":164,"_49":50,"_48":213,"_140":33,"_46":214,"_13":69,"_41":42,"_43":215,"_30":33,"_144":-5,"_189":216,"_34":217},{"_51":206,"_39":40,"_37":38,"_138":164,"_49":50,"_48":14,"_140":33,"_46":207,"_13":142,"_41":42,"_43":45,"_30":33,"_144":-5,"_189":208,"_34":209},{"_51":198,"_39":199,"_37":200,"_138":164,"_49":50,"_48":201,"_140":33,"_46":202,"_13":69,"_41":42,"_43":203,"_30":33,"_144":-5,"_189":204,"_34":205},{"_51":153,"_39":154,"_37":155,"_138":-5,"_49":50,"_48":156,"_140":33,"_46":195,"_13":158,"_41":159,"_43":160,"_30":33,"_144":-5,"_189":196,"_34":197},{"_51":146,"_39":147,"_37":148,"_138":-5,"_49":50,"_48":149,"_140":33,"_46":192,"_13":69,"_41":42,"_43":151,"_30":33,"_144":-5,"_189":193,"_34":194},{"_51":135,"_39":136,"_37":137,"_138":-5,"_49":50,"_48":139,"_140":33,"_46":188,"_13":142,"_41":42,"_43":143,"_30":33,"_144":-5,"_189":190,"_34":191},["D",1779250505021],"children",[],[136],["D",1779250135099],[],[147],["D",1779250127189],[],[154],"813dcd26-5401-11f1-9f8d-ee650bb23af1","trading.ts","813dcde4-5401-11f1-9f8d-ee650bb23af1",7,["D",1779250086515],"// ═══════════════════════════════════════════════════════════\n// 💹 TRADING ENGINE — Order execution & risk management\n// ═══════════════════════════════════════════════════════════\n\nimport {\n TRADE_AMOUNT_USDT,\n TP_PERCENT,\n SL_PERCENT,\n} from \"./config.ts\";\nimport {\n marketBuy,\n limitSell,\n stopLossSell,\n ocoSell,\n getTickerPrice,\n delay,\n} from \"./binance.ts\";\n\nexport interface TradeResult {\n success: boolean;\n symbol: string;\n rsi: number;\n entryPrice: number;\n quantity: number;\n tp: number;\n sl: number;\n orderId: string | number;\n tpOrderId?: string | number;\n slOrderId?: string | number;\n error?: string;\n}\n\n/**\n * Format price to a reasonable number of decimals based on price magnitude.\n */\nfunction formatPrice(price: number): string {\n if (price >= 1000) return price.toFixed(2);\n if (price >= 1) return price.toFixed(4);\n if (price >= 0.01) return price.toFixed(6);\n return price.toFixed(8);\n}\n\n/**\n * Format quantity based on symbol's typical lot size.\n * Testnet is more lenient, but we still round sensibly.\n */\nfunction formatQty(qty: number, price: number): string {\n if (price >= 1000) return qty.toFixed(5);\n if (price >= 1) return qty.toFixed(3);\n if (price >= 0.01) return qty.toFixed(1);\n return qty.toFixed(0);\n}\n\n/**\n * Execute a full trade cycle:\n * 1. Market buy for TRADE_AMOUNT_USDT\n * 2. Place Take Profit (limit sell at +1%)\n * 3. Place Stop Loss (stop-loss limit at -1%)\n */\nexport async function executeTrade(\n symbol: string,\n rsi: number,\n): Promise {\n const result: TradeResult = {\n success: false,\n symbol,\n rsi,\n entryPrice: 0,\n quantity: 0,\n tp: 0,\n sl: 0,\n orderId: \"\",\n };\n\n try {\n // ── Step 1: Get current price ────────────────────────\n const ticker = await getTickerPrice(symbol);\n if (ticker._error) {\n result.error = `Price fetch failed: ${ticker.msg}`;\n return result;\n }\n const currentPrice = parseFloat(ticker.price);\n if (!currentPrice || currentPrice <= 0) {\n result.error = \"Invalid price returned\";\n return result;\n }\n\n // ── Step 2: Market Buy ───────────────────────────────\n const buyOrder = await marketBuy(symbol, TRADE_AMOUNT_USDT);\n await delay(300);\n\n if (buyOrder._error) {\n result.error = `Buy failed [${buyOrder.code}]: ${buyOrder.msg}`;\n return result;\n }\n\n // Parse fill details\n const fills = buyOrder.fills || [];\n let totalQty = 0;\n let totalCost = 0;\n for (const fill of fills) {\n const q = parseFloat(fill.qty);\n const p = parseFloat(fill.price);\n totalQty += q;\n totalCost += q * p;\n }\n\n // Fallback if fills are empty (testnet sometimes)\n if (totalQty === 0) {\n totalQty = parseFloat(buyOrder.executedQty || \"0\");\n totalCost = parseFloat(buyOrder.cummulativeQuoteQty || \"0\");\n }\n\n const avgPrice = totalCost > 0 ? totalCost / totalQty : currentPrice;\n\n result.entryPrice = avgPrice;\n result.quantity = totalQty;\n result.orderId = buyOrder.orderId;\n result.tp = avgPrice * (1 + TP_PERCENT / 100);\n result.sl = avgPrice * (1 - SL_PERCENT / 100);\n\n // ── Step 3: Set Take Profit + Stop Loss ──────────────\n const qtyStr = formatQty(totalQty, avgPrice);\n const tpStr = formatPrice(result.tp);\n const slStr = formatPrice(result.sl);\n // SL limit price slightly below stop trigger\n const slLimitStr = formatPrice(result.sl * 0.999);\n\n // Try OCO order first (TP + SL in one order)\n const ocoResult = await ocoSell(symbol, qtyStr, tpStr, slStr, slLimitStr);\n await delay(300);\n\n if (!ocoResult._error) {\n result.tpOrderId = ocoResult.orderListId;\n result.slOrderId = ocoResult.orderListId;\n result.success = true;\n return result;\n }\n\n // Fallback: place TP and SL separately\n console.warn(`OCO failed for ${symbol}: ${ocoResult.msg}, placing separately...`);\n\n const tpOrder = await limitSell(symbol, qtyStr, tpStr);\n await delay(300);\n if (!tpOrder._error) {\n result.tpOrderId = tpOrder.orderId;\n } else {\n console.warn(`TP order failed: ${tpOrder.msg}`);\n }\n\n const slOrder = await stopLossSell(symbol, qtyStr, slStr, slLimitStr);\n await delay(300);\n if (!slOrder._error) {\n result.slOrderId = slOrder.orderId;\n } else {\n console.warn(`SL order failed: ${slOrder.msg}`);\n }\n\n result.success = true;\n return result;\n } catch (err) {\n result.error = `Exception: ${(err as Error).message}`;\n return result;\n }\n}\n",[],[163,199],"8099182a-5402-11f1-9211-ee650bb23af1",["D",1779250514925],[],[163,40],"914f9c9e-5401-11f1-9aa2-ee650bb23af1","scanner.ts","914f9d48-5401-11f1-9aa2-ee650bb23af1",8,["D",1779250113474],"// ═══════════════════════════════════════════════════════════\n// 🔍 MARKET SCANNER — Core scan loop\n// Fetches all USDT pairs, calculates RSI, executes trades\n// ═══════════════════════════════════════════════════════════\n\nimport {\n KLINE_INTERVAL,\n KLINE_LIMIT,\n MAX_PAIRS_PER_SCAN,\n isHalal,\n} from \"./config.ts\";\nimport {\n getExchangeInfo,\n getKlines,\n getAccountInfo,\n delay,\n} from \"./binance.ts\";\nimport { calculateRSI, extractCloses, isStrongBuy } from \"./rsi.ts\";\nimport { executeTrade, type TradeResult } from \"./trading.ts\";\nimport {\n sendTelegram,\n formatTradeAlert,\n formatScanSummary,\n formatErrorAlert,\n} from \"./telegram.ts\";\n\nexport interface ScanResult {\n totalPairs: number;\n halalPairs: number;\n scanned: number;\n signals: number;\n successful: number;\n failed: number;\n trades: TradeResult[];\n errors: string[];\n}\n\n/**\n * Fetch all USDT trading pairs from the exchange.\n * Filters for SPOT, TRADING status, and USDT quote.\n */\nasync function fetchUSDTPairs(): Promise {\n const info = await getExchangeInfo();\n if (info._error) {\n throw new Error(`Exchange info failed: ${info.msg}`);\n }\n\n const pairs: string[] = info.symbols\n .filter(\n (s: any) =>\n s.quoteAsset === \"USDT\" &&\n s.status === \"TRADING\" &&\n s.isSpotTradingAllowed === true,\n )\n .map((s: any) => s.symbol);\n\n return pairs;\n}\n\n/**\n * Get formatted account balances (non-zero only)\n */\nasync function getBalanceSummary(): Promise {\n const account = await getAccountInfo();\n if (account._error) {\n return `⚠️ Could not fetch balance: ${account.msg}`;\n }\n\n const nonZero = (account.balances || [])\n .filter(\n (b: any) => parseFloat(b.free) > 0 || parseFloat(b.locked) > 0,\n )\n .slice(0, 15); // cap display\n\n if (nonZero.length === 0) return \" No balances found\";\n\n return nonZero\n .map(\n (b: any) =>\n ` • ${b.asset}: ${parseFloat(b.free).toFixed(6)} (locked: ${parseFloat(b.locked).toFixed(6)})`,\n )\n .join(\"\\n\");\n}\n\n/**\n * Run a full market scan cycle.\n */\nexport async function runScan(): Promise {\n const result: ScanResult = {\n totalPairs: 0,\n halalPairs: 0,\n scanned: 0,\n signals: 0,\n successful: 0,\n failed: 0,\n trades: [],\n errors: [],\n };\n\n try {\n // ── Step 1: Fetch all USDT pairs ─────────────────────\n console.log(\"📡 Fetching USDT trading pairs...\");\n const allPairs = await fetchUSDTPairs();\n result.totalPairs = allPairs.length;\n console.log(`Found ${allPairs.length} USDT pairs`);\n\n // ── Step 2: Halal filter ─────────────────────────────\n const halalPairs = allPairs.filter(isHalal);\n result.halalPairs = halalPairs.length;\n console.log(`Halal filtered: ${halalPairs.length} pairs`);\n\n // Cap to avoid rate limits\n const pairsToScan = halalPairs.slice(0, MAX_PAIRS_PER_SCAN);\n\n // ── Step 3: RSI analysis for each pair ───────────────\n console.log(`Scanning ${pairsToScan.length} pairs for RSI signals...`);\n\n for (const symbol of pairsToScan) {\n try {\n const klines = await getKlines(symbol, KLINE_INTERVAL, KLINE_LIMIT);\n await delay(); // rate limit protection\n\n if (klines._error || !Array.isArray(klines) || klines.length === 0) {\n continue; // skip silently — many testnet pairs have no data\n }\n\n const closes = extractCloses(klines);\n const rsi = calculateRSI(closes);\n result.scanned++;\n\n if (isStrongBuy(rsi)) {\n result.signals++;\n console.log(`⚡ SIGNAL: ${symbol} RSI=${rsi.toFixed(2)}`);\n\n // ── Step 4: Execute trade ────────────────────\n const trade = await executeTrade(symbol, rsi);\n result.trades.push(trade);\n\n if (trade.success) {\n result.successful++;\n console.log(`✅ Trade executed: ${symbol}`);\n\n // Send immediate Telegram alert\n await sendTelegram(\n formatTradeAlert({\n symbol: trade.symbol,\n rsi: trade.rsi,\n price: trade.entryPrice,\n qty: trade.quantity,\n tp: trade.tp,\n sl: trade.sl,\n orderId: trade.orderId,\n }),\n );\n } else {\n result.failed++;\n result.errors.push(`${symbol}: ${trade.error}`);\n console.warn(`❌ Trade failed: ${symbol} — ${trade.error}`);\n }\n }\n } catch (err) {\n result.errors.push(`${symbol}: ${(err as Error).message}`);\n }\n }\n\n // ── Step 5: Send summary ─────────────────────────────\n console.log(\"📊 Generating scan summary...\");\n const balance = await getBalanceSummary();\n\n await sendTelegram(\n formatScanSummary({\n totalPairs: result.totalPairs,\n halalPairs: result.halalPairs,\n scanned: result.scanned,\n signals: result.signals,\n successful: result.successful,\n failed: result.failed,\n balance,\n errors: result.errors,\n }),\n );\n\n console.log(\"✅ Scan cycle complete\");\n } catch (err) {\n const errMsg = (err as Error).message;\n result.errors.push(errMsg);\n console.error(\"🔴 Scan error:\", errMsg);\n await sendTelegram(formatErrorAlert(errMsg));\n }\n\n return result;\n}\n",[],[163,211],"745fd6da-5401-11f1-9ba3-ee650bb23af1","rsi.ts","745fd806-5401-11f1-9ba3-ee650bb23af1",6,["D",1779250064926],"// ═══════════════════════════════════════════════════════════\n// 📈 RSI (Relative Strength Index) Calculator\n// Uses Wilder's smoothing method (standard RSI-14)\n// ═══════════════════════════════════════════════════════════\n\nimport { RSI_PERIOD, RSI_STRONG_BUY } from \"./config.ts\";\n\n/**\n * Calculate RSI from an array of closing prices.\n * Returns NaN if insufficient data.\n */\nexport function calculateRSI(closes: number[], period: number = RSI_PERIOD): number {\n if (closes.length < period + 1) return NaN;\n\n // Calculate price changes\n const changes: number[] = [];\n for (let i = 1; i < closes.length; i++) {\n changes.push(closes[i] - closes[i - 1]);\n }\n\n // Initial average gain/loss (simple average of first `period` changes)\n let avgGain = 0;\n let avgLoss = 0;\n for (let i = 0; i < period; i++) {\n if (changes[i] >= 0) avgGain += changes[i];\n else avgLoss += Math.abs(changes[i]);\n }\n avgGain /= period;\n avgLoss /= period;\n\n // Wilder's smoothing for remaining changes\n for (let i = period; i < changes.length; i++) {\n const change = changes[i];\n if (change >= 0) {\n avgGain = (avgGain * (period - 1) + change) / period;\n avgLoss = (avgLoss * (period - 1)) / period;\n } else {\n avgGain = (avgGain * (period - 1)) / period;\n avgLoss = (avgLoss * (period - 1) + Math.abs(change)) / 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 * Extract closing prices from Binance kline data.\n * Kline format: [openTime, open, high, low, close, volume, ...]\n */\nexport function extractCloses(klines: any[]): number[] {\n return klines.map((k: any[]) => parseFloat(k[4]));\n}\n\n/** Determine if RSI indicates a strong buy */\nexport function isStrongBuy(rsi: number): boolean {\n return !isNaN(rsi) && rsi < RSI_STRONG_BUY;\n}\n\n/** Human-readable RSI signal */\nexport function rsiSignal(rsi: number): string {\n if (isNaN(rsi)) return \"⚪ No Data\";\n if (rsi < 20) return \"🟢 Extremely Oversold\";\n if (rsi < 30) return \"🟢 Strong Buy (Oversold)\";\n if (rsi < 45) return \"🟡 Mild Buy\";\n if (rsi < 55) return \"⚪ Neutral\";\n if (rsi < 70) return \"🟡 Mild Sell\";\n if (rsi < 80) return \"🔴 Overbought\";\n return \"🔴 Extremely Overbought\";\n}\n",[],[163,219],"3ac3db96-5402-11f1-862e-ee650bb23af1","config.ts","56163e58-5401-11f1-88c3-ee650bb23af1",14,["D",1779250397766],"// ═══════════════════════════════════════════════════════════\n// 🔧 CONFIGURATION — Binance Spot Testnet Market Scanner\n// ═══════════════════════════════════════════════════════════\n\nexport const API_KEY = \"ewwkWZthamOF33QQYnIXSe4rXzVuy10RfcgK3tFAvlVJk3ZBDgwyjvi0tmcWwIKQ\";\nexport const SECRET_KEY = \"3toyhde8OakFCU395avTRaIpmUTIuFDW1C89BVdVPDr8O0wYf22LeemgUySK1cHT\";\nexport const TELEGRAM_TOKEN = \"8821899430:AAGS0EKYDjom1lr_CIwIfOel6wria_T3NZE\";\nexport const CHAT_ID = \"1838167986\";\n\n// ── Binance Endpoints ──────────────────────────────────\n// data-api.binance.vision bypasses 451 restrictions from Val Town\nexport const PUBLIC_ENDPOINTS = [\n \"https://data-api.binance.vision\",\n \"https://api.binance.com\",\n \"https://api1.binance.com\",\n \"https://api2.binance.com\",\n \"https://api3.binance.com\",\n \"https://api4.binance.com\",\n];\n\n// Signed trading endpoints — testnet\nexport const TRADE_ENDPOINTS = [\n \"https://testnet.binance.vision\",\n];\n\n// Trading parameters\nexport const TRADE_AMOUNT_USDT = 20; // Buy 20 USDT worth per signal\nexport const RSI_PERIOD = 14; // RSI lookback\nexport const RSI_STRONG_BUY = 30; // RSI < 30 = strong buy\nexport const TP_PERCENT = 1.0; // 1% Take Profit\nexport const SL_PERCENT = 1.0; // 1% Stop Loss\nexport const KLINE_INTERVAL = \"15m\"; // Candle interval for RSI\nexport const KLINE_LIMIT = 100; // Number of candles to fetch\n\n// Rate limiting\nexport const RATE_LIMIT_DELAY_MS = 200; // Delay between API calls\nexport const MAX_PAIRS_PER_SCAN = 150; // Cap pairs per scan cycle\n\n// ═══════════════════════════════════════════════════════════\n// 🕌 HALAL FILTER — Exclude known haram/controversial coins\n// Coins associated with gambling, interest-bearing lending\n// protocols, or conventional finance instruments are excluded.\n// This is a best-effort filter — consult a scholar for\n// definitive rulings on specific tokens.\n// ═══════════════════════════════════════════════════════════\nexport const HARAM_COINS: Set = new Set([\n // Gambling / Casino tokens\n \"FUNUSDT\", \"WINKUSDT\", \"BETUSDT\",\n // Interest-bearing / Lending protocol tokens (riba concerns)\n \"COMPUSDT\", \"AAVEUSDT\", \"MKRUSDT\", \"CAKEUSDT\",\n \"VENUSUSDT\", \"CREAMUSDT\", \"ALPACAUSDT\",\n // Privacy coins (used for illicit activities)\n \"XMRUSDT\", \"ZECUSDT\", \"DASHUSDT\",\n // Meme / highly speculative (gharar concerns)\n \"SHIBUSDT\", \"DOGEUSDT\", \"PEPEUSDT\", \"FLOKIUSDT\",\n \"BONKUSDT\", \"BONEUSDT\", \"LEASHUSDT\",\n]);\n\nexport function isHalal(symbol: string): boolean {\n return !HARAM_COINS.has(symbol.toUpperCase());\n}\n",[],[163,227],"4be9771e-5402-11f1-862e-ee650bb23af1","binance.ts","6bb482ce-5401-11f1-b7bd-ee650bb23af1",15,["D",1779250426537],"// ═══════════════════════════════════════════════════════════\n// 🔗 BINANCE API — Dual-endpoint client with smart caching\n// Public data from production, signed trades on testnet\n// Auto-remembers which endpoint works to avoid 451 spam\n// ═══════════════════════════════════════════════════════════\n\nimport {\n API_KEY,\n SECRET_KEY,\n PUBLIC_ENDPOINTS,\n TRADE_ENDPOINTS,\n RATE_LIMIT_DELAY_MS,\n} from \"./config.ts\";\nimport { createHmac } from \"node:crypto\";\n\n// ── Signing ────────────────────────────────────────────\n\nfunction sign(queryString: string): string {\n return createHmac(\"sha256\", SECRET_KEY)\n .update(queryString)\n .digest(\"hex\");\n}\n\n// ── Endpoint caching (remembers what works) ────────────\n\nlet cachedPublicEndpoint: string | null = null;\nlet cachedTradeEndpoint: string | null = null;\n\n// ── Rate-limited fetch with smart endpoint fallback ────\n\nasync function binanceFetch(\n path: string,\n params: Record = {},\n options: {\n signed?: boolean;\n method?: \"GET\" | \"POST\" | \"DELETE\";\n useTradeEndpoints?: boolean;\n } = {},\n): Promise {\n const { signed = false, method = \"GET\", useTradeEndpoints = false } = options;\n\n const qs = new URLSearchParams();\n for (const [k, v] of Object.entries(params)) {\n qs.set(k, String(v));\n }\n\n if (signed) {\n qs.set(\"timestamp\", String(Date.now()));\n qs.set(\"signature\", sign(qs.toString()));\n }\n\n const headers: Record = {\n \"X-MBX-APIKEY\": API_KEY,\n };\n\n // Use cached endpoint first, then fallback to full list\n const allEndpoints = useTradeEndpoints ? TRADE_ENDPOINTS : PUBLIC_ENDPOINTS;\n const cached = useTradeEndpoints ? cachedTradeEndpoint : cachedPublicEndpoint;\n\n const endpoints = cached\n ? [cached, ...allEndpoints.filter((e) => e !== cached)]\n : allEndpoints;\n\n let lastError = \"No endpoints available\";\n\n for (const base of endpoints) {\n try {\n const url =\n method === \"GET\"\n ? `${base}${path}?${qs.toString()}`\n : `${base}${path}`;\n\n const opts: RequestInit = { method, headers };\n if (method !== \"GET\") {\n opts.headers = {\n ...headers,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n };\n opts.body = qs.toString();\n }\n\n const res = await fetch(url, opts);\n\n if (res.status === 451) {\n // Don't spam logs if we already know this fails\n if (base !== cached) continue;\n // Cached endpoint started failing — clear cache\n if (useTradeEndpoints) cachedTradeEndpoint = null;\n else cachedPublicEndpoint = null;\n continue;\n }\n\n const data = await res.json();\n\n if (res.ok) {\n // Cache this working endpoint\n if (useTradeEndpoints) cachedTradeEndpoint = base;\n else cachedPublicEndpoint = base;\n }\n\n if (!res.ok) {\n return { _error: true, code: data.code, msg: data.msg, status: res.status };\n }\n return data;\n } catch (err) {\n lastError = `${base}: ${(err as Error).message}`;\n continue;\n }\n }\n return { _error: true, code: -1, msg: `All endpoints failed. Last: ${lastError}` };\n}\n\n// ── Delay helper ───────────────────────────────────────\n\nexport function delay(ms: number = RATE_LIMIT_DELAY_MS): Promise {\n return new Promise((r) => setTimeout(r, ms));\n}\n\n// ═══════════════════════════════════════════════════════════\n// PUBLIC DATA (production API — no signing needed)\n// ═══════════════════════════════════════════════════════════\n\n/** Fetch all exchange trading pairs */\nexport async function getExchangeInfo(): Promise {\n return binanceFetch(\"/api/v3/exchangeInfo\");\n}\n\n/** Fetch kline/candlestick data */\nexport async function getKlines(\n symbol: string,\n interval: string,\n limit: number,\n): Promise {\n return binanceFetch(\"/api/v3/klines\", { symbol, interval, limit });\n}\n\n/** Get current ticker price */\nexport async function getTickerPrice(symbol: string): Promise {\n return binanceFetch(\"/api/v3/ticker/price\", { symbol });\n}\n\n// ═══════════════════════════════════════════════════════════\n// SIGNED TRADING (testnet endpoint)\n// ═══════════════════════════════════════════════════════════\n\n/** Place a market buy order */\nexport async function marketBuy(\n symbol: string,\n quoteOrderQty: number,\n): Promise {\n return binanceFetch(\n \"/api/v3/order\",\n { symbol, side: \"BUY\", type: \"MARKET\", quoteOrderQty },\n { signed: true, method: \"POST\", useTradeEndpoints: true },\n );\n}\n\n/** Place a limit sell (Take Profit) */\nexport async function limitSell(\n symbol: string,\n quantity: string,\n price: string,\n): Promise {\n return binanceFetch(\n \"/api/v3/order\",\n { symbol, side: \"SELL\", type: \"LIMIT\", timeInForce: \"GTC\", quantity, price },\n { signed: true, method: \"POST\", useTradeEndpoints: true },\n );\n}\n\n/** Place a stop-loss limit sell */\nexport async function stopLossSell(\n symbol: string,\n quantity: string,\n stopPrice: string,\n price: string,\n): Promise {\n return binanceFetch(\n \"/api/v3/order\",\n {\n symbol, side: \"SELL\", type: \"STOP_LOSS_LIMIT\",\n timeInForce: \"GTC\", quantity, stopPrice, price,\n },\n { signed: true, method: \"POST\", useTradeEndpoints: true },\n );\n}\n\n/** Place OCO (One-Cancels-Other) order for TP + SL */\nexport async function ocoSell(\n symbol: string,\n quantity: string,\n tpPrice: string,\n slPrice: string,\n slLimitPrice: string,\n): Promise {\n return binanceFetch(\n \"/api/v3/order/oco\",\n {\n symbol, side: \"SELL\", quantity,\n price: tpPrice, stopPrice: slPrice,\n stopLimitPrice: slLimitPrice, stopLimitTimeInForce: \"GTC\",\n },\n { signed: true, method: \"POST\", useTradeEndpoints: true },\n );\n}\n\n/** Get account balances */\nexport async function getAccountInfo(): Promise {\n return binanceFetch(\n \"/api/v3/account\",\n {},\n { signed: true, useTradeEndpoints: true },\n );\n}\n",[],[163,235],["D",1779249989078],[179,180,181,182,183,184],[163],["D",1779249965104],{"_103":102,"_109":61},{"_103":102,"_104":61,"_105":61,"_19":63,"_106":107,"_108":33},{"_13":92,"_39":93,"_51":50,"_94":52,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":53,"_101":102},"ctx",{"_85":-5,"_128":282,"_283":284,"_285":286,"_287":33,"_288":33,"_289":33,"_290":31,"_291":-5,"_292":-7,"_293":-7,"_294":69,"_295":33,"_296":33,"_297":-5,"_298":33,"_299":33,"_300":33,"_301":-5},"ENV",{"_253":254,"_255":256,"_257":93,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281},"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 · v18