[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_178":179,"_180":181},"routes/_app.x.$handle.$name",{"_106":105,"_38":51,"_114":96,"_33":108,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":31,"_128":129,"_130":65,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",8,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","6a51119d-cd51-4356-87de-f5f02d9ecee7","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","bot.ts","latestPath","fileId","01a0634d-9d8b-740b-a6cc-84f18531dd38","name","fileType","interval","content","// Binance Triangular Arbitrage Paper Trading Bot\n// Runs every 1 minute. Dynamically discovers top-gainer tokens that have\n// active pairs with BOTH USDT and ETH, computes triangular cross-rates,\n// logs paper trades to SQLite, and sends a Telegram summary at most every\n// 10 minutes. No per-trade notifications (avoids Telegram spam).\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\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\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// 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 await sendTelegram(report);\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\n// ---------- Cron entrypoint ----------\nexport default async function binanceTriangularBot() {\n await initDb();\n\n let w = await getWallet();\n\n let topGainers: Ticker[] = [];\n try {\n topGainers = await getTopGainers(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 (quiet — no per-trade notifications)\n let executed = 0;\n for (const a of arbs) {\n if (a.netProfit >= (TRADE_AMOUNT_USDT * MIN_NET_PROFIT_PCT) / 100 && w.balance >= TRADE_AMOUNT_USDT) {\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 }\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] 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","// Binance Triangular Arbitrage Paper Trading Bot\n// Runs every 1 minute. Dynamically discovers top-gainer tokens that have\n// active pairs with BOTH USDT and ETH, computes triangular cross-rates,\n// logs paper trades to SQLite, and sends a Telegram summary at most every\n// 10 minutes. No per-trade notifications (avoids Telegram spam).\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\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\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// 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// ---------- Cron entrypoint ----------\nexport default async function binanceTriangularBot() {\n await initDb();\n\n let w = await getWallet();\n\n let topGainers: Ticker[] = [];\n try {\n topGainers = await getTopGainers(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 (quiet — no per-trade notifications)\n let executed = 0;\n for (const a of arbs) {\n if (a.netProfit >= (TRADE_AMOUNT_USDT * MIN_NET_PROFIT_PCT) / 100 && w.balance >= TRADE_AMOUNT_USDT) {\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 }\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] 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","createdAt",["D",1788372547285],"branchVersion","branchId","706a186d-17b0-49d7-afcd-061e66763458","id","4656a5b0-561d-4ff3-812e-b3949dee3507","binance-arb-paper-bot",["D",1788372422505],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Binance triangular arbitrage paper bot","imageUrl","a79beaf8-5d23-4a58-a785-4a70bab11255","pinnedFileId","01a0634d-9e20-77ee-876e-733794a7e2e2","pinPreview",true,"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",{"_106":105,"_113":108},"org",{"_106":105,"_107":108,"_109":108,"_19":61,"_110":111,"_112":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"isOwned",78,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Tringelar","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":173,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":174,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":175,"_90":176,"_92":177,"_94":31},"tree",[164,165],"files",[164,165],"counts",{"_153":69,"_154":143,"_155":69,"_156":157,"_158":159},"contents",[135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":149,"_38":34,"_36":37,"_139":-5,"_47":48,"_46":14,"_141":31,"_44":150,"_13":151,"_39":40,"_41":43,"_30":31,"_146":-5,"_33":152},{"_49":137,"_38":138,"_36":63,"_139":-5,"_47":48,"_46":140,"_141":31,"_44":142,"_13":143,"_39":144,"_41":145,"_30":31,"_146":147,"_33":148},"c95c6196-6487-421b-bb46-5ffa1864d4a9","webhook.ts","parentId",4,"latest",["D",1788372464721],1,"http","// Telegram webhook handler — responds to /stats (and other commands).\n// Set the webhook to this endpoint's URL in Telegram:\n// https://api.telegram.org/bot/setWebhook?url=\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { buildReport } from \"./bot.ts\";\n\nexport async function http(req: Request) {\n let text = \"Unknown command. Try /stats.\";\n try {\n const update = await req.json();\n const msg = update?.message;\n const cmd: string = (msg?.text ?? \"\").split(/[ @]/)[0];\n\n if (cmd === \"/start\") {\n text = \"Binance Triangular Arb Paper Bot ready. Use /stats for the current report.\";\n } else if (cmd === \"/stats\" || cmd === \"/report\") {\n await sqlite.execute(\n `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 );\n await sqlite.execute(`INSERT OR IGNORE INTO paper_wallet (id) VALUES (1)`);\n text = await buildReport();\n }\n } catch (e) {\n text = \"Error: \" + (e instanceof Error ? e.message : String(e));\n }\n\n // If this came from a Telegram webhook, reply directly to the chat\n try {\n const update = await req.clone().json();\n const chatId = update?.message?.chat?.id;\n if (chatId) {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n if (token) {\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 new Response(\"ok\");\n }\n }\n } catch { /* not a webhook call */ }\n\n return new Response(text, {\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n}\n","label","binance-arb-bot",[138],"9bf730e0-e4fa-4352-9497-5b417491893a",["D",1788372547285],5,[34],"pulls","branches","forks","envVars",{"_160":162,"_163":69},"connections",{"_160":69,"_161":69},"count","unfilledCount",2,"emptyCount",{"_49":149,"_38":34,"_36":37,"_139":-5,"_47":48,"_46":14,"_141":31,"_44":170,"_13":151,"_39":40,"_41":43,"_30":31,"_146":-5,"_167":171,"_33":172},{"_49":137,"_38":138,"_36":63,"_139":-5,"_47":48,"_46":140,"_141":31,"_44":166,"_13":143,"_39":144,"_41":145,"_30":31,"_146":147,"_167":168,"_33":169},["D",1788372464721],"children",[],[138],["D",1788372547285],[],[34],["D",1788372422505],["D",1789501263826],{"_106":105,"_113":108},{"_106":105,"_107":108,"_109":108,"_19":61,"_110":111,"_112":31},{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"ctx",{"_88":-5,"_132":211,"_212":213,"_214":215,"_216":31,"_217":31,"_218":31,"_219":65,"_220":-5,"_221":-7,"_222":-7,"_223":69,"_224":31,"_225":31,"_226":-5,"_227":31,"_228":31,"_229":31,"_230":-5},"ENV",{"_182":183,"_184":185,"_186":96,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210},"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 · v8