[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","Tringelar","name","binance-arb-paper-bot","path","bot.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/Tringelar/binance-arb-paper-bot/code/bot.ts","extension","id","00ba2cec-5f37-4ffb-be18-25ad4fa29501","fileId","01a0634d-9d8b-740b-a6cc-84f18531dd38","parentId","branchId","706a186d-17b0-49d7-afcd-061e66763458","branchVersion",17,"latest",true,"createdAt",["D",1788373286407],"version",11,"fileType","interval","content","// Binance Triangular Arbitrage Paper Trading Bot (fast, with live alerts)\n// Dynamically discovers top-gainer tokens with active USDT + ETH pairs,\n// computes triangular cross-rates, logs paper trades to SQLite, and:\n// • scans very fast (multiple rounds per cron run, ~4s apart);\n// • sends a real-time Telegram alert for EVERY trade (small or large)\n// including total balance + PnL;\n// • still sends a throttled 10-minute summary.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ---------- Config ----------\n// Binance public market data. api.binance.com geo-blocks some regions (HTTP 451);\n// data-api.binance.vision serves the identical /api/v3 endpoints globally.\nconst BINANCE = \"https://data-api.binance.vision/api/v3\";\nconst FEE_PER_LEG = 0.001; // 0.1% per leg (use 0.00075 for 0.075%)\nconst TRADE_AMOUNT_USDT = 100; // simulated size per triangular loop\nconst MIN_NET_PROFIT_PCT = 0.1; // minimum net profit % to execute\nconst TOP_GAINERS_N = 20; // how many top gainers to consider per scan\nconst REPORT_INTERVAL_MS = 10 * 60 * 1000; // 10 minutes summary (kept, throttled)\nconst REFRESH_GAINERS_MS = 60 * 1000; // refresh the heavy top-gainer list once/min\nconst SCAN_ROUNDS = 12; // scans per cron run\nconst COOLDOWN_MS = 4 * 1000; // 4s between scans → a fast, repeated sweep\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\n// ---------- Cached top-gainer list ----------\n// The /ticker/24hr endpoint is heavy (~1200 weight). Top gainers barely change\n// second to second, so we refresh the candidate list once a minute and reuse it\n// for the fast cheap bookTicker scans in between — letting us scan far more\n// often without tripping Binance rate limits.\nlet cachedGainers: { list: Ticker[]; at: number } | null = null;\n\nasync function getTopGainersCached(n: number): Promise {\n const now = Date.now();\n if (cachedGainers && now - cachedGainers.at < REFRESH_GAINERS_MS) {\n return cachedGainers.list;\n }\n const fresh = await getTopGainers(n);\n cachedGainers = { list: fresh, at: now };\n return fresh;\n}\n\n// ---------- DB ----------\nasync function initDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS paper_wallet (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n balance REAL NOT NULL DEFAULT 1000.0,\n initial_balance REAL NOT NULL DEFAULT 1000.0,\n total_scans INTEGER NOT NULL DEFAULT 0,\n total_trades INTEGER NOT NULL DEFAULT 0,\n winning_trades INTEGER NOT NULL DEFAULT 0,\n last_report_time INTEGER NOT NULL DEFAULT 0\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS paper_trades (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT NOT NULL,\n profit_loss REAL NOT NULL,\n arb_percent REAL NOT NULL,\n route TEXT NOT NULL,\n timestamp INTEGER NOT NULL\n )`);\n await sqlite.execute(\n `INSERT OR IGNORE INTO paper_wallet (id) VALUES (1)`,\n );\n}\n\ninterface Wallet {\n balance: number;\n initial_balance: number;\n total_scans: number;\n total_trades: number;\n winning_trades: number;\n last_report_time: number;\n}\n\nasync function getWallet(): Promise {\n const r = await sqlite.execute(\"SELECT * FROM paper_wallet WHERE id = 1\");\n return r.rows[0] as unknown as Wallet;\n}\n\n// ---------- Binance top-gainer discovery ----------\ninterface Ticker {\n symbol: string;\n priceChangePercent: string;\n}\n\n// Fetch 24h stats, keep only USDT-quoted symbols, return sorted by gain desc.\nasync function getTopGainers(n: number): Promise {\n const res = await fetch(`${BINANCE}/ticker/24hr`);\n if (!res.ok) throw new Error(`24hr ${res.status}`);\n const all = (await res.json()) as Ticker[];\n\n const symbols = new Set(all.map((t) => t.symbol));\n const usdtQuoted = all.filter((t) => t.symbol.endsWith(\"USDT\"));\n\n const candidates: Ticker[] = [];\n for (const t of usdtQuoted) {\n const base = t.symbol.slice(0, -4); // strip \"USDT\"\n if (base === \"ETH\" || base === \"USDT\") continue;\n // Must have an active TOKEN/ETH pair to form a triangle with USDT+ETH.\n if (!symbols.has(`${base}ETH`)) continue;\n candidates.push(t);\n }\n\n candidates.sort(\n (a, b) => parseFloat(b.priceChangePercent) - parseFloat(a.priceChangePercent),\n );\n return candidates.slice(0, n);\n}\n\n// ---------- Order book (best bid/ask) ----------\ninterface Book {\n symbol: string;\n bidPrice: string;\n askPrice: string;\n}\n\nasync function fetchBook(symbol: string): Promise {\n const res = await fetch(`${BINANCE}/ticker/bookTicker?symbol=${symbol}`);\n if (!res.ok) throw new Error(`book ${symbol} ${res.status}`);\n return (await res.json()) as Book;\n}\n\n// ---------- Triangular cross-rate calculation ----------\ninterface ArbResult {\n symbol: string; // target top-gainer token\n arbPercent: number; // gross arbitrage %\n netProfit: number; // net profit in USDT after fees\n route: string; // step-by-step route\n}\n\n// For a token with pairs TOKENUSDT, TOKENETH, ETHUSDT, compute both\n// triangular directions and return the more profitable one.\nasync function checkTriangle(token: string): Promise {\n const symUsdt = `${token}USDT`;\n const symEth = `${token}ETH`;\n\n // Concurrently fetch the 3 legs of the triangle.\n const [u, e, eth] = await Promise.allSettled([\n fetchBook(symUsdt),\n fetchBook(symEth),\n fetchBook(\"ETHUSDT\"),\n ]);\n\n if (u.status !== \"fulfilled\" || e.status !== \"fulfilled\" || eth.status !== \"fulfilled\") {\n throw new Error(\"bookTicker fetch failed\");\n }\n\n const askUsdt = parseFloat(u.value.askPrice); // USDT per TOKEN (buy TOKEN)\n const bidUsdt = parseFloat(u.value.bidPrice); // USDT per TOKEN (sell TOKEN)\n const bidEth = parseFloat(e.value.bidPrice); // ETH per TOKEN (sell TOKEN for ETH)\n const askEth = parseFloat(e.value.askPrice); // ETH per TOKEN (buy TOKEN with ETH)\n const askEthUsdt = parseFloat(eth.value.askPrice); // USDT per ETH (buy ETH)\n const bidEthUsdt = parseFloat(eth.value.bidPrice); // USDT per ETH (sell ETH)\n\n // Guard against missing/zero prices (e.g. iliquid pair momentarily at 0),\n // which would otherwise produce Infinity/NaN that SQLite rejects.\n const prices = [askUsdt, bidUsdt, bidEth, askEth, askEthUsdt, bidEthUsdt];\n if (!prices.every((p) => Number.isFinite(p) && p > 0)) {\n // Iliquid pair momentarily at 0/missing → not a valid triangle.\n return { symbol: token, arbPercent: 0, netProfit: 0, route: \"invalid book\" };\n }\n\n const feeFactor = Math.pow(1 - FEE_PER_LEG, 3);\n\n // Path A: USDT -> TOKEN -> ETH -> USDT\n // final = X / ask(TOKENUSDT) * bid(TOKENETH) * bid(ETHUSDT)\n const aFinal = (TRADE_AMOUNT_USDT / askUsdt) * bidEth * bidEthUsdt;\n const aNet = aFinal * feeFactor;\n\n // Path B: USDT -> ETH -> TOKEN -> USDT\n // final = X * bid(TOKENUSDT) / (ask(ETHUSDT) * ask(TOKENETH))\n const bFinal = (TRADE_AMOUNT_USDT * bidUsdt) / (askEthUsdt * askEth);\n const bNet = bFinal * feeFactor;\n\n if (!Number.isFinite(aNet) || !Number.isFinite(bNet)) {\n return { symbol: token, arbPercent: 0, netProfit: 0, route: \"non-finite\" };\n }\n\n const useA = aNet >= bNet;\n const net = useA ? aNet : bNet;\n const gross = useA ? aFinal : bFinal;\n const route = useA\n ? `USDT → ${token} → ETH → USDT`\n : `USDT → ETH → ${token} → USDT`;\n\n return {\n symbol: token,\n arbPercent: ((gross - TRADE_AMOUNT_USDT) / TRADE_AMOUNT_USDT) * 100,\n netProfit: net - TRADE_AMOUNT_USDT,\n route,\n };\n}\n\n// ---------- Telegram ----------\nasync function sendTelegram(text: string) {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n if (!token || !chatId) {\n console.log(\"[telegram] missing TELEGRAM_BOT_TOKEN / TELEGRAM_CHAT_ID; skipping send\");\n return false;\n }\n await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: \"HTML\" }),\n });\n return true;\n}\n\n// Real-time alert for a single executed trade, including total balance + PnL.\n// Sent for both small and large trades (no filtering).\nasync function sendTradeAlert(a: ArbResult, w: Wallet) {\n const pnl = w.balance - w.initial_balance;\n const pnlPct = (pnl / w.initial_balance) * 100;\n const text = [\n \"⚡ ARB TRADE OPENED ⚡\",\n \"\",\n `🎯 Token: ${a.symbol}`,\n `🔄 Route: ${a.route}`,\n `📈 Gross Arb: ${a.arbPercent.toFixed(4)}%`,\n `💵 Net Profit: ${a.netProfit >= 0 ? \"+\" : \"\"}${a.netProfit.toFixed(4)}`,\n \"\",\n `💰 Total Balance: ${w.balance.toFixed(2)}`,\n `📊 PnL: ${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(4)} (${pnlPct.toFixed(3)}%)`,\n ].join(\"\\n\");\n await sendTelegram(text);\n}\n\n// Shared by cron and the /stats HTTP handler\nexport async function buildReport() {\n const w = await getWallet();\n const since = w.last_report_time;\n const trades = await sqlite.execute(\n \"SELECT * FROM paper_trades WHERE timestamp > ? ORDER BY timestamp\",\n [since],\n );\n const recent = trades.rows as unknown as {\n symbol: string;\n profit_loss: number;\n arb_percent: number;\n route: string;\n timestamp: number;\n }[];\n\n const pnl = w.balance - w.initial_balance;\n const pnlPct = (pnl / w.initial_balance) * 100;\n const winRate = w.total_trades > 0 ? (w.winning_trades / w.total_trades) * 100 : 0;\n const avgArb = recent.length\n ? recent.reduce((s, t) => s + t.arb_percent, 0) / recent.length\n : 0;\n\n const lines = [\n \"📊 Binance Triangular Arb — 10min Report\",\n \"\",\n `💰 Balance: $${w.balance.toFixed(2)}`,\n `📈 PnL: ${pnl >= 0 ? \"+\" : \"\"}$${pnl.toFixed(4)} (${pnlPct.toFixed(3)}%)`,\n `🎯 Win Rate: ${winRate.toFixed(1)}% (${w.winning_trades}/${w.total_trades})`,\n `🔍 Total Scans: ${w.total_scans}`,\n `⚡ Trades (last 10m): ${recent.length}`,\n `📊 Avg Arb (last 10m): ${avgArb.toFixed(4)}%`,\n \"\",\n ];\n if (recent.length === 0) {\n lines.push(\"No trades captured in the last 10 minutes.\");\n } else {\n lines.push(\"Last 10m trades:\");\n for (const t of recent) {\n lines.push(\n `• ${t.symbol} | ${t.arb_percent.toFixed(3)}% | ` +\n `${t.profit_loss >= 0 ? \"+\" : \"\"}$${t.profit_loss.toFixed(4)} | ${t.route}`,\n );\n }\n }\n return lines.join(\"\\n\");\n}\n\nasync function maybeSendReport(w: Wallet): Promise {\n const now = Date.now();\n if (now - w.last_report_time < REPORT_INTERVAL_MS) return w;\n const report = await buildReport();\n const sent = await sendTelegram(report);\n // Only advance the timer if it was actually delivered, so the first\n // configured run sends immediately rather than being skipped.\n if (sent) {\n await sqlite.execute(\n \"UPDATE paper_wallet SET last_report_time = ? WHERE id = 1\",\n [now],\n );\n return { ...w, last_report_time: now };\n }\n return w;\n}\n\n// One full scan cycle. Reads the wallet fresh each round, since we may run\n// several rounds per cron invocation.\nasync function runScan(round: number) {\n let w = await getWallet();\n\n let topGainers: Ticker[] = [];\n try {\n topGainers = await getTopGainersCached(TOP_GAINERS_N);\n } catch (e) {\n console.log(\"[scan] top-gainer fetch failed:\", e instanceof Error ? e.message : e);\n }\n\n // Concurrently analyze every discovered top-gainer triangle.\n const results = await Promise.allSettled(topGainers.map((t) => checkTriangle(t.symbol.slice(0, -4))));\n\n const arbs: ArbResult[] = [];\n for (const r of results) {\n if (r.status === \"fulfilled\") arbs.push(r.value);\n else console.log(\"[scan] triangle failed:\", r.reason?.message ?? r.reason);\n }\n\n // Execute profitable paper trades, sending a real-time Telegram alert for\n // EVERY trade (small or large) with the updated total balance.\n let executed = 0;\n for (const a of arbs) {\n if (\n Number.isFinite(a.netProfit) &&\n a.netProfit >= (TRADE_AMOUNT_USDT * MIN_NET_PROFIT_PCT) / 100 &&\n w.balance >= TRADE_AMOUNT_USDT\n ) {\n await sqlite.execute(\n `INSERT INTO paper_trades (symbol, profit_loss, arb_percent, route, timestamp)\n VALUES (?, ?, ?, ?, ?)`,\n [a.symbol, a.netProfit, a.arbPercent, a.route, Date.now()],\n );\n w = {\n ...w,\n balance: w.balance + a.netProfit,\n total_trades: w.total_trades + 1,\n winning_trades: w.winning_trades + 1,\n };\n executed++;\n await sendTradeAlert(a, w);\n }\n }\n\n w.total_scans += 1;\n await sqlite.execute(\n `UPDATE paper_wallet SET balance = ?, total_scans = ?, total_trades = ?, winning_trades = ?\n WHERE id = 1`,\n [w.balance, w.total_scans, w.total_trades, w.winning_trades],\n );\n\n console.log(\n `[scan ${round}/${SCAN_ROUNDS}] top gainers: ${topGainers.length}, triangles ok: ${arbs.length}, executed: ${executed}, balance: ${w.balance.toFixed(2)}`,\n );\n\n // At most one Telegram summary per 10 minutes\n await maybeSendReport(w);\n}\n\n// ---------- Cron entrypoint ----------\n// One cron run (every minute) performs SCAN_ROUNDS scans spaced COOLDOWN_MS\n// apart, so a new scan happens roughly every 15 seconds (Val Town cron has no\n// sub-minute granularity on this tier).\nexport default async function binanceTriangularBot() {\n await initDb();\n\n for (let round = 1; round <= SCAN_ROUNDS; round++) {\n const started = Date.now();\n await runScan(round);\n const elapsed = Date.now() - started;\n if (round < SCAN_ROUNDS) {\n const wait = Math.max(0, COOLDOWN_MS - elapsed);\n await sleep(wait);\n }\n }\n}\n","deleted",false,"label",[14],"4656a5b0-561d-4ff3-812e-b3949dee3507",["D",1788372422505],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Binance triangular arbitrage paper bot","imageUrl","userId","a79beaf8-5d23-4a58-a785-4a70bab11255","pinnedFileId","01a0634d-9e20-77ee-876e-733794a7e2e2","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0634a-0ca9-7584-9a97-35a1aeb44011","tursoName","4656a5b0561d4ff3812eb3949dee3507","tursoHostname","4656a5b0561d4ff3812eb3949dee3507-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789501263826],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":100},"org",{"_9":10,"_99":100,"_101":100,"_55":56,"_102":103,"_104":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",78,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]