[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_173":174,"_175":176},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_103":86,"_27":54,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":49,"_117":118,"_119":49,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":49,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":49,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":49},"version",29,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",true,"deletedHere","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\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: ${esc(symbol)}`,\n `📊 RSI(14): ${esc(rsi.toFixed(2))}`,\n `💰 Entry Price: ${esc(price.toFixed(6))}`,\n `📦 Quantity: ${esc(qty)}`,\n ``,\n `🎯 Take Profit (1%): ${esc(tp.toFixed(6))}`,\n `🛡️ Stop Loss (1%): ${esc(sl.toFixed(6))}`,\n `📋 Order ID: ${esc(orderId)}`,\n ``,\n `⏰ ${esc(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: ${esc(totalPairs)}`,\n `🕌 Halal Filtered: ${esc(halalPairs)}`,\n `📊 RSI Analyzed: ${esc(scanned)}`,\n ``,\n `⚡ Strong Buy Signals: ${esc(signals)}`,\n `✅ Successful Trades: ${esc(successful)}`,\n `❌ Failed Trades: ${esc(failed)}`,\n ``,\n `💼 Account Balance:`,\n balance,\n ``,\n `⏰ ${esc(new Date().toUTCString())}`,\n ];\n if (errors.length > 0) {\n lines.push(``, `⚠️ Errors:`);\n errors.slice(0, 5).forEach((e) => lines.push(`• ${esc(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",1779250630974],"branchVersion","branchId","38e019e4-5401-11f1-8e10-ee650bb23af1","id","38df400a-5401-11f1-8e10-ee650bb23af1","FinalTestSuccess",["D",1779249965104],"deletedAt","legacyEnvVars",false,"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",{"_96":95,"_102":54},"org",{"_96":95,"_97":54,"_98":54,"_18":56,"_99":100,"_101":49},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",31,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gazasnip1","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":169,"_47":-5,"_48":49,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":49,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":170,"_80":171,"_82":172,"_84":49},"tree",[146],"files",[146,147,148],"counts",{"_135":62,"_136":137,"_138":62,"_139":140,"_141":142},"contents",[124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":125,"_32":126,"_30":127,"_128":-5,"_41":42,"_40":129,"_130":25,"_38":131,"_13":62,"_34":132,"_36":-5,"_24":49,"_133":-5,"_27":134},"472a6644-5401-11f1-9f8d-ee650bb23af1","lib","472a66f8-5401-11f1-9f8d-ee650bb23af1","parentId",2,"latest",["D",1779249989078],"directory","label",[126],"pulls","branches",1,"forks","envVars",{"_143":62,"_145":62},"connections",{"_143":62,"_144":62},"count","unfilledCount","emptyCount",{"_43":125,"_32":126,"_30":127,"_128":-5,"_41":42,"_40":129,"_130":25,"_38":166,"_13":62,"_34":132,"_36":-5,"_24":49,"_133":-5,"_155":167,"_27":168},{"_43":158,"_32":159,"_30":160,"_128":127,"_41":42,"_40":161,"_130":49,"_38":162,"_13":62,"_34":35,"_36":163,"_24":49,"_133":-5,"_155":164,"_27":165},{"_43":149,"_32":150,"_30":151,"_128":127,"_41":42,"_40":152,"_130":49,"_38":153,"_13":62,"_34":35,"_36":154,"_24":49,"_133":-5,"_155":156,"_27":157},"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","children",[],[126,150],"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",[],[126,159],["D",1779249989078],[147,148],[126],["D",1779249965104],{"_96":95,"_102":54},{"_96":95,"_97":54,"_98":54,"_18":56,"_99":100,"_101":49},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_121":206,"_207":208,"_209":210,"_211":49,"_212":49,"_213":49,"_214":25,"_215":-5,"_216":-7,"_217":-7,"_218":62,"_219":49,"_220":49,"_221":-5,"_222":49,"_223":49,"_224":49,"_225":-5},"ENV",{"_177":178,"_179":180,"_181":86,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205},"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 · v29