[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_246":247,"_248":249},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_38":-7,"_124":-5,"_19":125,"_126":127,"_128":129,"_130":131,"_132":133,"_21":134,"_135":-5,"_136":-5,"_137":24,"_138":139,"_140":85,"_141":-5,"_142":-5,"_143":144},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","Tringelar","name","binance-arb-paper-bot","branchName","main","path","send-report.ts","project",{"_32":72,"_13":14,"_36":73,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":83,"_84":85,"_86":-5,"_87":-5,"_88":26,"_40":41,"_89":90,"_91":92,"_93":94,"_95":-5,"_96":97,"_98":97,"_99":100,"_101":100,"_102":100,"_103":97,"_104":97,"_53":105,"_106":107,"_108":109,"_110":24},"file",{"_63":64,"_13":18,"_65":66,"_67":24,"_71":-5},"isDirectory",false,"page",0,"history",[31],"hasNext","userId",{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":-5,"_53":54,"_21":55,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61},"id","ecd708fe-39b4-4d8d-9c27-cc295208a06c","branchId","706a186d-17b0-49d7-afcd-061e66763458","createdAt",["D",1788546491651],"version",78,"orgId","01a0634a-0ca9-7584-9a97-35a1aeb44011","parentId","051ff807-dae7-4987-8d0d-aac82c6e4e62","incomingCommitId","aiChatMessageId","395997ff-2542-4246-987e-322599859eda","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","townie","clientLabel","user",{"_32":68,"_40":41,"_11":12,"_69":70},{"_63":64,"_13":18,"_65":66,"_67":24},"pull","merge","revert","multiple","commits",[62],{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":-5,"_53":54,"_21":55,"_56":-5,"_57":-5,"_58":-5},"fileId","6280ef4e-a88e-11f1-8e01-1607ee4eb77e","fileType","http","deleted","a79beaf8-5d23-4a58-a785-4a70bab11255","avatar","","deletedAtVersion","4656a5b0-561d-4ff3-812e-b3949dee3507",["D",1788372422505],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Binance triangular arbitrage paper bot","imageUrl","pinnedFileId","01a0634d-9e20-77ee-876e-733794a7e2e2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_123":70},"org",{"_11":12,"_119":70,"_69":70,"_30":68,"_120":121,"_122":24},"branch",{"_38":39,"_13":16,"_32":35,"_111":72,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":14,"_118":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":72,"_13":14,"_36":241,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":83,"_84":85,"_86":-5,"_87":-5,"_88":26,"_40":41,"_89":90,"_91":92,"_93":242,"_95":-5,"_96":97,"_98":97,"_99":100,"_101":100,"_102":100,"_103":97,"_104":97,"_53":243,"_106":244,"_108":245,"_110":24},"tree",[165,166,167,168,169,170,171,172],"files",[165,166,167,168,169,170,171,172],"counts",{"_153":26,"_154":155,"_156":26,"_157":158,"_159":160},"contents",[],{"_32":145,"_13":18,"_63":64,"_42":-5,"_34":35,"_146":39,"_147":85,"_36":148,"_38":26,"_65":66,"_149":150,"_67":24,"_151":-5,"_17":152},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"b32d2b73-7a41-472f-a21e-127babba8424","branchVersion","latest",["D",1788546491651],"content","// HTTP trigger to build & send the closed-trades report over Telegram.\n// Returns the raw Telegram API response so the caller can see what happened.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nasync function sendTelegram(text: string): Promise {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n if (!token || !chatId) return \"ERROR: missing TELEGRAM_BOT_TOKEN / TELEGRAM_CHAT_ID\";\n const chunks: string[] = [];\n for (let i = 0; i < text.length; i += 3900) chunks.push(text.slice(i, i + 3900));\n const parts: string[] = [];\n for (let i = 0; i < chunks.length; i++) {\n const res = 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: chunks[i], parse_mode: \"HTML\", disable_web_page_preview: true }),\n });\n const body = await res.text();\n parts.push(`part${i + 1}/${chunks.length} -> ${res.status}: ${body.slice(0, 200)}`);\n }\n return parts.join(\"\\n\");\n}\n\nconst wrPct = (w: number, l: number) =>\n (w + l) > 0 ? ((w / (w + l)) * 100).toFixed(1) : \"0.0\";\n\nfunction line(label: string, n: number, w: number, l: number) {\n const pct = wrPct(w, l);\n const emoji = n === 0 ? \"⚪\" : (w / n) >= 0.5 ? \"🟢\" : \"🔴\";\n return `• ${emoji} ${label} — ${pct}% (${w}W/${l}L) · ${n} صفقة`;\n}\n\nexport default async function handler(req: Request) {\n // ---- Overall ----\n const overall = await sqlite.execute(\n `SELECT COUNT(*) AS n,\n SUM(CASE WHEN status IN ('tp1','tp2') THEN 1 ELSE 0 END) AS wins,\n SUM(CASE WHEN status='sl' THEN 1 ELSE 0 END) AS losses\n FROM strategy_trades WHERE status != 'open'`,\n );\n const o = overall.rows[0] as { n: number; wins: number; losses: number };\n\n const exits = await sqlite.execute(\n \"SELECT status, COUNT(*) AS n FROM strategy_trades WHERE status != 'open' GROUP BY status\",\n );\n const em = new Map((exits.rows as { status: string; n: number }[]).map((r) => [r.status, r.n]));\n\n const grouped = async (col: string, extra = \"\") => {\n const r = await sqlite.execute(\n `SELECT ${col} AS label, COUNT(*) AS n,\n SUM(CASE WHEN status IN ('tp1','tp2') THEN 1 ELSE 0 END) AS wins,\n SUM(CASE WHEN status='sl' THEN 1 ELSE 0 END) AS losses\n FROM strategy_trades WHERE status != 'open' AND ${col} IS NOT NULL\n GROUP BY ${col} ${extra} ORDER BY ${col}`,\n );\n return r.rows as unknown as { label: string; n: number; wins: number; losses: number }[];\n };\n\n const poi = await grouped(\"poi_type\", \", side\");\n const trend = await grouped(\"trend_type\");\n const liq = await grouped(\"liquidity\");\n const conf = await grouped(\"confidence\");\n const side = await grouped(\"side\");\n\n const factors = await sqlite.execute(\"SELECT factor, wins, losses FROM strategy_factors ORDER BY factor\");\n const fRows = factors.rows as unknown as { factor: string; wins: number; losses: number }[];\n\n const syms = await sqlite.execute(\n `SELECT symbol, COUNT(*) AS n,\n SUM(CASE WHEN status IN ('tp1','tp2') THEN 1 ELSE 0 END) AS wins,\n SUM(CASE WHEN status='sl' THEN 1 ELSE 0 END) AS losses,\n SUM(pnl) AS net\n FROM strategy_trades WHERE status != 'open' GROUP BY symbol ORDER BY net DESC`,\n );\n const symRows = syms.rows as unknown as {\n symbol: string; n: number; wins: number; losses: number; net: number;\n }[];\n const winsArr = symRows.filter((s) => s.net > 0);\n const lossesArr = symRows.filter((s) => s.net < 0);\n\n const chunk = (arr: { symbol: string }[], n: number) => {\n const lines: string[] = [];\n for (let i = 0; i < arr.length; i += n) lines.push(arr.slice(i, i + n).map((s) => s.symbol).join(\" \"));\n return lines;\n };\n\n const lines: string[] = [\n \"📊 تقرير الصفقات المغلقة (مصنّف)\",\n \"\",\n `🧮 الإجمالي: ${o.n} صفقة مغلقة`,\n `✅ رابحة: ${o.wins} · ❌ خاسرة: ${o.losses}`,\n `📈 معدل الربح: ${wrPct(o.wins, o.losses)}%`,\n \"\",\n \"① حسب نوع الخروج:\",\n `• 🎯 TP1 (1:1): ${em.get(\"tp1\") ?? 0} · 🎯 TP2 (1:2): ${em.get(\"tp2\") ?? 0} · ⛔ SL: ${em.get(\"sl\") ?? 0}`,\n \"\",\n \"② حسب نوع الدخول (POI + الطرف):\",\n ...poi.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"③ حسب الاتجاه:\",\n ...trend.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"④ حسب السيولة:\",\n ...liq.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"⑤ حسب الثقة:\",\n ...conf.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"⑥ حسب الطرف:\",\n ...side.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"🧠 عوامل التعلم الذكي (strategy_factors):\",\n ...fRows.map((f) => line(f.factor, f.wins + f.losses, f.wins, f.losses)),\n \"\",\n `🤑 الأزواج الرابحة (${winsArr.length}):`,\n ...chunk(winsArr, 12),\n \"\",\n `📉 الأزواج الخاسرة (${lossesArr.length}):`,\n ...chunk(lossesArr, 12),\n \"\",\n \"⭐ أفضل الأزواج:\",\n ...winsArr.slice(0, 5).map((s) => `• ${s.symbol} — +${s.net}R (${s.wins}W/${s.losses}L)`),\n \"\",\n \"⚠️ أسوأ الأزواج:\",\n ...lossesArr.slice(0, 5).map((s) => `• ${s.symbol} — ${s.net}R (${s.wins}W/${s.losses}L)`),\n ];\n\n const result = await sendTelegram(lines.join(\"\\n\"));\n return new Response(result, { headers: { \"content-type\": \"text/plain\" } });\n}\n","label",[18],"pulls","branches",1,"forks","envVars",{"_161":163,"_164":26},"connections",{"_161":26,"_162":26},"count","unfilledCount",2,"emptyCount",{"_32":232,"_13":233,"_63":234,"_42":-5,"_34":35,"_146":235,"_147":85,"_36":236,"_38":237,"_65":21,"_149":238,"_67":24,"_151":-5,"_180":239,"_17":240},{"_32":223,"_13":224,"_63":225,"_42":-5,"_34":35,"_146":226,"_147":85,"_36":227,"_38":228,"_65":199,"_149":229,"_67":24,"_151":-5,"_180":230,"_17":231},{"_32":215,"_13":216,"_63":217,"_42":-5,"_34":35,"_146":218,"_147":85,"_36":219,"_38":26,"_65":189,"_149":220,"_67":24,"_151":-5,"_180":221,"_17":222},{"_32":206,"_13":207,"_63":208,"_42":-5,"_34":35,"_146":209,"_147":85,"_36":210,"_38":211,"_65":189,"_149":212,"_67":24,"_151":-5,"_180":213,"_17":214},{"_32":145,"_13":18,"_63":64,"_42":-5,"_34":35,"_146":39,"_147":85,"_36":203,"_38":26,"_65":66,"_149":150,"_67":24,"_151":-5,"_180":204,"_17":205},{"_32":193,"_13":194,"_63":195,"_42":-5,"_34":35,"_146":196,"_147":85,"_36":197,"_38":198,"_65":199,"_149":200,"_67":24,"_151":-5,"_180":201,"_17":202},{"_32":183,"_13":184,"_63":185,"_42":-5,"_34":35,"_146":186,"_147":85,"_36":187,"_38":188,"_65":189,"_149":190,"_67":24,"_151":-5,"_180":191,"_17":192},{"_32":173,"_13":174,"_63":83,"_42":-5,"_34":35,"_146":175,"_147":85,"_36":176,"_38":177,"_65":66,"_149":178,"_67":24,"_151":179,"_180":181,"_17":182},"63ff8527-61a3-475d-b0dd-dcced491f324","webhook.ts",48,["D",1788375427736],3,"// 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 { buildLearningReport, initStrategyDb } from \"./strategy.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, /learn for the learning report.\";\n } else if (cmd === \"/learn\" || cmd === \"/learning\") {\n await initStrategyDb();\n text = await buildLearningReport();\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","binance-arb-bot","children",[],[174],"3b1b3269-2406-4553-bf15-255a2f42a0f1","strategy.ts","8d75c760-a6fe-11f1-9e37-1607ee4eb77e",62,["D",1788380356583],21,"script","// ============================================================\n// Multi-Timeframe Technical Analysis Strategy Engine\n// Systematic Trading Strategy (ICT / SMC Hybrid)\n// ------------------------------------------------------------\n// Pipeline:\n// 1. Trend bias on 4H (EMA50/EMA200 + swing structure)\n// 2. POI detection on 1H/15M (Order Blocks + FVG)\n// 3. Execution trigger on 5M (reversal candle at POI retest)\n// 4. Risk management (SL behind structure, TP1/TP2 at 1:1 / 1:2)\n// 5. Adaptive learning from closed-trade outcomes\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst BINANCE = \"https://data-api.binance.vision/api/v3\";\n\n// ---------- Types ----------\nexport interface Candle {\n time: number;\n open: number;\n high: number;\n low: number;\n close: number;\n volume: number;\n}\n\nexport type Side = \"LONG\" | \"SHORT\";\n\nexport interface Signal {\n symbol: string;\n side: Side;\n entry: number;\n stopLoss: number;\n takeProfit1: number;\n takeProfit2: number;\n rr: number; // reward:risk to TP2\n confidence: number; // 0-100 confluence score\n reason: string;\n timeframe: string; // POI timeframe\n timestamp: number;\n // Learning features (used to estimate historical win probability).\n poiType: \"OB\" | \"FVG\";\n trendType: Trend;\n liquidity: \"HIGH\" | \"MEDIUM\";\n}\n\nexport interface LiquidityCoin {\n symbol: string; // e.g. \"BTCUSDT\"\n base: string; // e.g. \"BTC\"\n quoteVolume: number; // 24h USDT volume\n liquidity: \"HIGH\" | \"MEDIUM\";\n}\n\n// ---------- Config ----------\nexport const LIQUIDITY_HIGH_MIN = 50_000_000; // >= $50M/day => HIGH\nexport const LIQUIDITY_MEDIUM_MIN = 5_000_000; // >= $5M/day => MEDIUM\nexport const MAX_COINS_PER_SCAN = 80;\n// Paper bet size per position — used to value open positions when computing\n// floating (unrealized) P&L. Kept in sync with strategy-bot.ts.\nexport const POSITION_SIZE_USDT = 100;\nconst STABLE_BASES = new Set([\n \"USDT\", \"USDC\", \"BUSD\", \"DAI\", \"TUSD\", \"FDUSD\", \"USDP\", \"EUR\", \"AEUR\",\n \"USTC\", \"USDD\", \"PYUSD\", \"EURI\", \"XUSD\", \"USD1\",\n]);\n\n// ---------- Binance data ----------\nexport async function fetchKlines(\n symbol: string,\n interval: string,\n limit = 200,\n): Promise {\n const res = await fetch(\n `${BINANCE}/klines?symbol=${symbol}&interval=${interval}&limit=${limit}`,\n );\n if (!res.ok) throw new Error(`klines ${symbol} ${interval} ${res.status}`);\n const raw = (await res.json()) as unknown[][];\n return raw.map((k) => ({\n time: k[0] as number,\n open: parseFloat(k[1] as string),\n high: parseFloat(k[2] as string),\n low: parseFloat(k[3] as string),\n close: parseFloat(k[4] as string),\n volume: parseFloat(k[5] as string),\n }));\n}\n\n// ---------- Liquidity universe ----------\n// Scan medium & high liquidity coins from the 24h ticker.\nexport async function getLiquidCoins(): 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 {\n symbol: string;\n quoteVolume: string;\n }[];\n\n const coins: LiquidityCoin[] = [];\n for (const t of all) {\n if (!t.symbol.endsWith(\"USDT\")) continue;\n const base = t.symbol.slice(0, -4);\n if (STABLE_BASES.has(base)) continue;\n const qv = parseFloat(t.quoteVolume);\n if (!Number.isFinite(qv) || qv <= 0) continue;\n if (qv >= LIQUIDITY_HIGH_MIN) {\n coins.push({ symbol: t.symbol, base, quoteVolume: qv, liquidity: \"HIGH\" });\n } else if (qv >= LIQUIDITY_MEDIUM_MIN) {\n coins.push({ symbol: t.symbol, base, quoteVolume: qv, liquidity: \"MEDIUM\" });\n }\n }\n\n // Sort by volume desc, take the top N (mix of medium & high).\n coins.sort((a, b) => b.quoteVolume - a.quoteVolume);\n return coins.slice(0, MAX_COINS_PER_SCAN);\n}\n\n// ---------- Indicators ----------\nexport function ema(values: number[], period: number): number[] {\n const k = 2 / (period + 1);\n const out: number[] = [];\n let prev = values[0];\n for (let i = 0; i < values.length; i++) {\n if (i === 0) {\n out.push(values[0]);\n prev = values[0];\n } else {\n prev = values[i] * k + prev * (1 - k);\n out.push(prev);\n }\n }\n return out;\n}\n\nexport function atr(candles: Candle[], period = 14): number {\n if (candles.length < period + 1) return 0;\n let sum = 0;\n for (let i = 1; i <= period; i++) {\n const c = candles[i];\n const p = candles[i - 1];\n const tr = Math.max(\n c.high - c.low,\n Math.abs(c.high - p.close),\n Math.abs(c.low - p.close),\n );\n sum += tr;\n }\n return sum / period;\n}\n\n// ---------- Swing structure ----------\ninterface Swing {\n index: number;\n price: number;\n type: \"high\" | \"low\";\n}\n\n// Fractal swing detection: a candle is a swing high if its high is the max of\n// the surrounding `left` candles on each side.\nexport function findSwings(candles: Candle[], left = 2): Swing[] {\n const swings: Swing[] = [];\n for (let i = left; i < candles.length - left; i++) {\n let isHigh = true;\n let isLow = true;\n for (let j = i - left; j <= i + left; j++) {\n if (j === i) continue;\n if (candles[j].high >= candles[i].high) isHigh = false;\n if (candles[j].low <= candles[i].low) isLow = false;\n }\n if (isHigh) swings.push({ index: i, price: candles[i].high, type: \"high\" });\n if (isLow) swings.push({ index: i, price: candles[i].low, type: \"low\" });\n }\n return swings;\n}\n\nexport type Trend = \"bullish\" | \"bearish\" | \"range\";\n\n// Trend bias from EMA50/EMA200 on the last candle + swing structure.\nexport function detectTrend(candles: Candle[]): Trend {\n if (candles.length < 200) return \"range\";\n const closes = candles.map((c) => c.close);\n const e50 = ema(closes, 50);\n const e200 = ema(closes, 200);\n const last = closes.length - 1;\n const price = closes[last];\n\n const swings = findSwings(candles, 3).filter((s) => s.index > last - 60);\n const highs = swings.filter((s) => s.type === \"high\");\n const lows = swings.filter((s) => s.type === \"low\");\n\n // Higher highs & higher lows => bullish; lower highs & lower lows => bearish.\n let hh = 0, hl = 0, lh = 0, ll = 0;\n for (let i = 1; i < highs.length; i++) {\n if (highs[i].price > highs[i - 1].price) hh++; else lh++;\n }\n for (let i = 1; i < lows.length; i++) {\n if (lows[i].price > lows[i - 1].price) hl++; else ll++;\n }\n\n const emaBull = price > e50[last] && e50[last] > e200[last];\n const emaBear = price < e50[last] && e50[last] < e200[last];\n\n // Strong sustained trend: EMA alignment confirmed by structure count.\n if (emaBull && hh + hl >= lh + ll - 2) return \"bullish\";\n if (emaBear && lh + ll >= hh + hl - 2) return \"bearish\";\n\n // Weaker but still directional: rely on EMA alignment alone.\n if (emaBull) return \"bullish\";\n if (emaBear) return \"bearish\";\n\n return \"range\";\n}\n\n// ---------- POI detection ----------\nexport interface POI {\n type: \"OB\" | \"FVG\";\n side: Side;\n top: number;\n bottom: number;\n index: number;\n}\n\n// Order Block: the last opposite candle before a strong directional move.\nexport function findOrderBlocks(candles: Candle[], lookback = 60): POI[] {\n const pois: POI[] = [];\n const start = Math.max(1, candles.length - lookback);\n for (let i = start; i < candles.length - 1; i++) {\n const move = candles[i + 1].close - candles[i].close;\n const body = Math.abs(candles[i].close - candles[i].open);\n // Strong up move preceded by a bearish candle => demand OB (LONG)\n if (move > 0 && candles[i].close < candles[i].open && body > 0) {\n pois.push({\n type: \"OB\",\n side: \"LONG\",\n top: Math.max(candles[i].open, candles[i].close),\n bottom: Math.min(candles[i].open, candles[i].close),\n index: i,\n });\n }\n // Strong down move preceded by a bullish candle => supply OB (SHORT)\n if (move < 0 && candles[i].close > candles[i].open && body > 0) {\n pois.push({\n type: \"OB\",\n side: \"SHORT\",\n top: Math.max(candles[i].open, candles[i].close),\n bottom: Math.min(candles[i].open, candles[i].close),\n index: i,\n });\n }\n }\n return pois;\n}\n\n// Fair Value Gap: gap between candle[i-1] and candle[i+1].\nexport function findFVG(candles: Candle[], lookback = 60): POI[] {\n const pois: POI[] = [];\n const start = Math.max(1, candles.length - lookback);\n for (let i = start; i < candles.length - 1; i++) {\n const prev = candles[i - 1];\n const next = candles[i + 1];\n // Bullish FVG: next.low > prev.high\n if (next.low > prev.high) {\n pois.push({\n type: \"FVG\",\n side: \"LONG\",\n top: next.low,\n bottom: prev.high,\n index: i,\n });\n }\n // Bearish FVG: next.high < prev.low\n if (next.high < prev.low) {\n pois.push({\n type: \"FVG\",\n side: \"SHORT\",\n top: prev.low,\n bottom: next.high,\n index: i,\n });\n }\n }\n return pois;\n}\n\n// ---------- Reversal candle detection (execution trigger) ----------\n// Returns true if the last candle is a valid reversal trigger for `side`.\nexport function isReversalTrigger(candles: Candle[], side: Side): boolean {\n if (candles.length < 3) return false;\n const c = candles[candles.length - 1];\n const p = candles[candles.length - 2];\n const body = Math.abs(c.close - c.open);\n const range = c.high - c.low;\n if (range === 0) return false;\n const lowerWick = Math.min(c.open, c.close) - c.low;\n const upperWick = c.high - Math.max(c.open, c.close);\n\n if (side === \"LONG\") {\n // Hammer: small body near top, long lower wick (>= 2x body)\n const hammer = body > 0 && lowerWick >= 2 * body && upperWick <= body;\n // Bullish engulfing: green candle engulfs previous red body\n const engulf = c.close > c.open && p.close < p.open &&\n c.close >= p.open && c.open <= p.close;\n return hammer || engulf;\n } else {\n // Hanging man: small body, long lower wick at top of range (bearish)\n const hangingMan = body > 0 && lowerWick >= 2 * body && c.close >= p.close;\n // Bearish engulfing\n const engulf = c.close < c.open && p.close > p.open &&\n c.close <= p.open && c.open >= p.close;\n return hangingMan || engulf;\n }\n}\n\n// ---------- Full signal generation for one coin ----------\nexport async function generateSignal(\n symbol: string,\n liquidity: \"HIGH\" | \"MEDIUM\" = \"MEDIUM\",\n): Promise {\n // Fetch the three timeframes we need.\n const [c4h, c1h, c5m] = await Promise.all([\n fetchKlines(symbol, \"4h\", 250),\n fetchKlines(symbol, \"1h\", 100),\n fetchKlines(symbol, \"5m\", 80),\n ]);\n\n const trend = detectTrend(c4h);\n if (trend === \"range\") return null; // no bias => no trade\n\n const last4h = c4h[c4h.length - 1];\n const price = last4h.close;\n const a = atr(c4h, 14);\n if (a <= 0) return null;\n\n // POIs from 1H (medium timeframe).\n const ob = findOrderBlocks(c1h, 60);\n const fvg = findFVG(c1h, 60);\n const pois = [...ob, ...fvg].filter((p) => p.index > c1h.length - 40);\n\n // Pick the side aligned with the trend.\n const side: Side = trend === \"bullish\" ? \"LONG\" : \"SHORT\";\n\n // Find a POI in the direction of the trend whose zone the price is near.\n const zone = pois\n .filter((p) => p.side === side)\n .map((p) => ({ ...p, dist: Math.abs(price - (p.top + p.bottom) / 2) }))\n .sort((x, y) => x.dist - y.dist)[0];\n\n if (!zone) return null;\n\n // Execution: price must be inside / at the POI zone AND a reversal trigger\n // must appear on 5M (retest confirmation).\n const inZone = price >= zone.bottom * 0.995 && price <= zone.top * 1.005;\n const trigger = isReversalTrigger(c5m, side);\n if (!inZone || !trigger) return null;\n\n // ---- Risk management ----\n // SL behind the nearest swing structure beyond the zone.\n const swings = findSwings(c4h, 2).filter((s) => s.index > c4h.length - 60);\n let stopLoss: number;\n if (side === \"LONG\") {\n const support = swings.filter((s) => s.type === \"low\" && s.price < zone.bottom)\n .sort((x, y) => y.price - x.price)[0];\n stopLoss = support ? support.price : zone.bottom - a * 0.5;\n stopLoss -= a * 0.1; // buffer vs stop hunts\n } else {\n const resistance = swings.filter((s) => s.type === \"high\" && s.price > zone.top)\n .sort((x, y) => x.price - y.price)[0];\n stopLoss = resistance ? resistance.price : zone.top + a * 0.5;\n stopLoss += a * 0.1;\n }\n\n const risk = Math.abs(price - stopLoss);\n if (risk <= 0) return null;\n\n // TP1 = 1:1, TP2 = 1:2 (measured move / R:R targets).\n let tp1: number, tp2: number;\n if (side === \"LONG\") {\n tp1 = price + risk;\n tp2 = price + risk * 2;\n } else {\n tp1 = price - risk;\n tp2 = price - risk * 2;\n }\n\n // R:R gate: reject trades below 1:2 to TP2.\n const rr = (Math.abs(tp2 - price)) / risk;\n if (rr < 2) return null;\n\n // Confluence score.\n let confidence = 40;\n if (zone.type === \"OB\") confidence += 15;\n if (ob.some((o) => o.side === side && o.index > c1h.length - 30)) confidence += 10;\n if (trend !== \"range\") confidence += 15;\n if (isReversalTrigger(c5m, side)) confidence += 10;\n\n return {\n symbol,\n side,\n entry: price,\n stopLoss,\n takeProfit1: tp1,\n takeProfit2: tp2,\n rr,\n confidence,\n reason: `${trend} trend | ${zone.type} ${side} @ ${zone.top.toFixed(6)}-${zone.bottom.toFixed(6)} | 5m trigger`,\n timeframe: \"1H\",\n timestamp: Date.now(),\n poiType: zone.type,\n trendType: trend,\n liquidity,\n };\n}\n\n// ---------- DB ----------\nexport async function initStrategyDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS strategy_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 open_positions INTEGER NOT NULL DEFAULT 0\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS strategy_trades (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT NOT NULL,\n side TEXT NOT NULL,\n entry REAL NOT NULL,\n stop_loss REAL NOT NULL,\n take_profit1 REAL NOT NULL,\n take_profit2 REAL NOT NULL,\n rr REAL NOT NULL,\n confidence INTEGER NOT NULL,\n reason TEXT NOT NULL,\n timeframe TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'open',\n pnl REAL,\n opened_at INTEGER NOT NULL,\n closed_at INTEGER,\n poi_type TEXT,\n trend_type TEXT,\n liquidity TEXT\n )`);\n await sqlite.execute(`INSERT OR IGNORE INTO strategy_wallet (id) VALUES (1)`);\n await initLearningDb();\n\n // Migration: add learning-feature columns if this table was created by an\n // older version of the bot (ALTER TABLE fails if the column already exists,\n // so each is wrapped and ignored).\n const migs = [\n \"ALTER TABLE strategy_trades ADD COLUMN poi_type TEXT\",\n \"ALTER TABLE strategy_trades ADD COLUMN trend_type TEXT\",\n \"ALTER TABLE strategy_trades ADD COLUMN liquidity TEXT\",\n ];\n for (const m of migs) {\n try {\n await sqlite.execute(m);\n } catch {\n // column already exists — fine\n }\n }\n}\n\nexport async function getStrategyWallet() {\n const r = await sqlite.execute(\"SELECT * FROM strategy_wallet WHERE id = 1\");\n return r.rows[0] as unknown as {\n balance: number;\n initial_balance: number;\n open_positions: number;\n };\n}\n\n// Total unrealized (floating) P&L across all open positions, valued at the\n// latest close price. Returns the dollar amount, the average % (weighted by\n// position notional), and the number of open positions.\nexport async function getFloatingPnL(): Promise<{\n usd: number;\n pct: number;\n positions: number;\n}> {\n const res = await sqlite.execute(\n \"SELECT symbol, side, entry FROM strategy_trades WHERE status = 'open'\",\n );\n const open = res.rows as unknown as {\n symbol: string;\n side: string;\n entry: number;\n }[];\n let usd = 0;\n for (const t of open) {\n let price: number;\n try {\n const k = await fetchKlines(t.symbol, \"15m\", 1);\n price = k[0].close;\n } catch {\n continue; // skip if price fetch fails for this symbol\n }\n const pct = t.side === \"LONG\"\n ? (price - t.entry) / t.entry\n : (t.entry - price) / t.entry;\n usd += pct * POSITION_SIZE_USDT;\n }\n const notional = open.length * POSITION_SIZE_USDT;\n return {\n usd,\n pct: notional > 0 ? (usd / notional) * 100 : 0,\n positions: open.length,\n };\n}\n\nexport async function openTrade(sig: Signal) {\n await sqlite.execute(\n `INSERT INTO strategy_trades\n (symbol, side, entry, stop_loss, take_profit1, take_profit2, rr, confidence,\n reason, timeframe, opened_at, poi_type, trend_type, liquidity)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [sig.symbol, sig.side, sig.entry, sig.stopLoss, sig.takeProfit1,\n sig.takeProfit2, sig.rr, sig.confidence, sig.reason, sig.timeframe, sig.timestamp,\n sig.poiType, sig.trendType, sig.liquidity],\n );\n await sqlite.execute(\n \"UPDATE strategy_wallet SET open_positions = open_positions + 1 WHERE id = 1\",\n );\n}\n\n// Close any open positions that have hit SL / TP1 / TP2 based on the latest price.\n// Also feeds every outcome into the adaptive learning system.\nexport async function manageOpenPositions(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM strategy_trades WHERE status = 'open'\",\n );\n const open = res.rows as unknown as {\n id: number;\n symbol: string;\n side: string;\n entry: number;\n stop_loss: number;\n take_profit1: number;\n take_profit2: number;\n opened_at: number;\n poi_type: string;\n trend_type: string;\n liquidity: string;\n }[];\n\n let closed = 0;\n for (const t of open) {\n let price: number;\n try {\n const k = await fetchKlines(t.symbol, \"15m\", 1);\n price = k[0].close;\n } catch {\n continue;\n }\n let status: string | null = null;\n let pnlPct = 0;\n if (t.side === \"LONG\") {\n if (price >= t.take_profit2) { status = \"tp2\"; pnlPct = 2; }\n else if (price >= t.take_profit1) { status = \"tp1\"; pnlPct = 1; }\n else if (price <= t.stop_loss) { status = \"sl\"; pnlPct = -1; }\n } else {\n if (price <= t.take_profit2) { status = \"tp2\"; pnlPct = 2; }\n else if (price <= t.take_profit1) { status = \"tp1\"; pnlPct = 1; }\n else if (price >= t.stop_loss) { status = \"sl\"; pnlPct = -1; }\n }\n if (status) {\n await sqlite.execute(\n `UPDATE strategy_trades SET status = ?, pnl = ?, closed_at = ? WHERE id = ?`,\n [status, pnlPct, Date.now(), t.id],\n );\n await sqlite.execute(\n `UPDATE strategy_wallet SET open_positions = open_positions - 1,\n balance = balance + ? WHERE id = 1`,\n [100 * (pnlPct / 100)],\n );\n // Teach the learning system: a win is reaching at least TP1.\n const won = status === \"tp1\" || status === \"tp2\";\n await teachResult({\n poiType: t.poi_type ?? \"OB\",\n trendType: t.trend_type ?? \"bullish\",\n liquidity: t.liquidity ?? \"MEDIUM\",\n side: t.side,\n }, won);\n // Bump the closed-trade counter used to arm the learned gate.\n await sqlite.execute(\n `INSERT INTO strategy_meta (key, value) VALUES ('closed_trades', 1)\n ON CONFLICT(key) DO UPDATE SET value = value + 1`,\n );\n closed++;\n }\n }\n return closed;\n}\n\n// ============================================================\n// Adaptive Learning System\n// ------------------------------------------------------------\n// Learns from every closed trade. Each trade is tagged with its\n// factors (poi type, trend, liquidity, side). After we accumulate\n// enough samples, we compute a historical win-rate for each factor\n// and derive an acceptance gate: a new signal is opened only if its\n// weighted win probability clears the dynamic threshold.\n// ============================================================\n\n// Minimum closed trades before the learned gate kicks in.\nexport const LEARN_MIN_SAMPLES = 15;\n// How much a factor's positive history must beat break-even to be\n// considered an edge. With a ~1:1 to 1:2 payoff we want win rate > ~40%.\nconst WIN_RATE_FLOOR = 0.40;\n\nexport async function initLearningDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS strategy_factors (\n factor TEXT PRIMARY KEY,\n wins INTEGER NOT NULL DEFAULT 0,\n losses INTEGER NOT NULL DEFAULT 0\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS strategy_meta (\n key TEXT PRIMARY KEY,\n value REAL\n )`);\n}\n\n// Record a win/loss against each factor tag of a trade.\nexport async function teachResult(\n features: { poiType: string; trendType: string; liquidity: string; side: string },\n won: boolean,\n) {\n const factors = [\n `poi:${features.poiType}`,\n `trend:${features.trendType}`,\n `liq:${features.liquidity}`,\n `side:${features.side}`,\n ];\n const res = await sqlite.execute(\n `SELECT factor FROM strategy_factors WHERE factor IN (${factors.map(() => \"?\").join(\",\")})`,\n factors,\n );\n const existing = new Set((res.rows as { factor: string }[]).map((r) => r.factor));\n const upserts = factors.filter((f) => !existing.has(f)).map((f) => [f]);\n if (upserts.length) {\n await sqlite.batch(upserts.map(([f]) => ({\n sql: `INSERT OR IGNORE INTO strategy_factors (factor, wins, losses) VALUES (?, 0, 0)`,\n args: [f],\n })));\n }\n const col = won ? \"wins\" : \"losses\";\n await sqlite.batch(factors.map((f) => ({\n sql: `UPDATE strategy_factors SET ${col} = ${col} + 1 WHERE factor = ?`,\n args: [f],\n })));\n}\n\n// Win rate for a single factor (0..1), or null if too few samples.\nasync function factorWinRate(factor: string): Promise {\n const r = await sqlite.execute(\n \"SELECT wins, losses FROM strategy_factors WHERE factor = ?\",\n [factor],\n );\n const row = r.rows[0] as { wins: number; losses: number } | undefined;\n if (!row) return null;\n const total = row.wins + row.losses;\n if (total < LEARN_MIN_SAMPLES) return null;\n return row.wins / total;\n}\n\n// Historical edge adjustment: returns a delta in confidence points built from\n// how each factor of the signal has performed historically.\nexport async function learnScoreAdjustment(sig: {\n poiType: string;\n trendType: string;\n liquidity: string;\n side: string;\n}): Promise {\n const factors = [\n `poi:${sig.poiType}`,\n `trend:${sig.trendType}`,\n `liq:${sig.liquidity}`,\n `side:${sig.side}`,\n ];\n let known = 0;\n let edge = 0;\n for (const f of factors) {\n const wr = await factorWinRate(f);\n if (wr === null) continue; // not enough data yet — no signal\n known++;\n // Edge is how far this factor's historical win rate beats the floor.\n edge += wr - WIN_RATE_FLOOR;\n }\n if (known === 0) return 0; // still in the learning/warm-up phase\n // Map cumulative edge into a bounded confidence-points offset.\n return Math.max(-15, Math.min(15, edge * 15));\n}\n\n// Adaptive acceptance decision. After enough history, reject a signal whose\n// learned win probability (adjusted confidence) fails the dynamic floor.\nexport async function shouldAccept(sig: {\n confidence: number;\n poiType: string;\n trendType: string;\n liquidity: string;\n side: string;\n}): Promise<{ accept: boolean; adjusted: number; reason: string }> {\n const adjustment = await learnScoreAdjustment(sig);\n const adjusted = sig.confidence + adjustment;\n\n // How many closed trades have we learned from so far?\n const meta = await sqlite.execute(\n \"SELECT value FROM strategy_meta WHERE key = 'closed_trades'\",\n );\n const closed = (meta.rows[0] as { value: number } | undefined)?.value ?? 0;\n\n if (closed < LEARN_MIN_SAMPLES) {\n // Warm-up: accept everything that already passed technical gates; the\n // learning gate engages once we have enough outcomes.\n return { accept: true, adjusted, reason: \"warm-up\" };\n }\n\n // Dynamic threshold: learned win probability must beat break-even.\n // With payoff ~1:1 to 1:2, we require adjusted confidence >= 55.\n const threshold = 55;\n if (adjusted >= threshold) {\n return { accept: true, adjusted, reason: `learned-edge (+${adjustment.toFixed(1)})` };\n }\n return { accept: false, adjusted, reason: `weak-history (${adjusted.toFixed(0)}<${threshold})` };\n}\n// ---------- Learning report ----------\n// Build a human-readable summary of the paper wallet + what the bot has\n// learned so far: cumulative win rate and per-factor win rates.\nexport async function buildLearningReport(): Promise {\n const meta = await sqlite.execute(\n \"SELECT value FROM strategy_meta WHERE key = 'closed_trades'\",\n );\n const closed = Math.round((meta.rows[0] as { value: number } | undefined)?.value ?? 0);\n\n // Wallet summary.\n const w = await getStrategyWallet();\n const pnl = w.balance - w.initial_balance;\n const pnlPct = (pnl / w.initial_balance) * 100;\n\n // Unrealized (floating) P&L across all currently open positions.\n const floating = await getFloatingPnL();\n\n // Overall stats from closed trades.\n const stats = await sqlite.execute(\n `SELECT\n COUNT(*) AS total,\n SUM(CASE WHEN status IN ('tp1','tp2') THEN 1 ELSE 0 END) AS wins\n FROM strategy_trades WHERE status != 'open'`,\n );\n const s = stats.rows[0] as { total: number | null; wins: number | null };\n const total = s.total ?? 0;\n const wins = s.wins ?? 0;\n const winRate = total > 0 ? (wins / total) * 100 : 0;\n\n const lines = [\n \"🧠 Strategy Learning Report\",\n \"\",\n \"💰 Paper Wallet\",\n `• Balance: ${w.balance.toFixed(2)}`,\n `• PnL: ${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(2)} (${pnlPct.toFixed(2)}%)`,\n `• Floating P&L: ${floating.usd >= 0 ? \"+\" : \"\"}${floating.usd.toFixed(2)} (${floating.pct.toFixed(2)}%) across ${floating.positions} open`,\n `• Open positions: ${w.open_positions}`,\n `• Closed trades: ${closed}`,\n `• Win rate: ${winRate.toFixed(0)}% (${wins}W/${total - wins}L)`,\n \"\",\n ];\n\n const factorsRes = await sqlite.execute(\n \"SELECT factor, wins, losses FROM strategy_factors ORDER BY factor\",\n );\n const factors = factorsRes.rows as unknown as {\n factor: string;\n wins: number;\n losses: number;\n }[];\n\n if (factors.length === 0) {\n lines.push(\"No closed trades to learn from yet.\");\n } else {\n lines.push(\"Per-factor win rates:\");\n for (const f of factors) {\n const total = f.wins + f.losses;\n const wr = total > 0 ? ((f.wins / total) * 100).toFixed(0) : \"0\";\n const bar = total > 0 ? \"█\".repeat(Math.min(10, Math.round((f.wins / total) * 10))) : \"\";\n const state = total >= LEARN_MIN_SAMPLES ? \"\" : \" (warm-up)\";\n lines.push(\n `• ${f.factor} — ${wr}% (${f.wins}W/${f.losses}L) ${bar}${state}`,\n );\n }\n }\n if (closed >= LEARN_MIN_SAMPLES) {\n lines.push(\"\");\n lines.push(\"✅ Learned gate active — filtering weak signals.\");\n } else {\n lines.push(\"\");\n lines.push(`⏳ Learned gate arms after ${LEARN_MIN_SAMPLES - closed} more closed trades.`);\n }\n return lines.join(\"\\n\");\n}\n",[],[184],"7fc45269-737e-4df5-a7a7-8e1687f845c6","strategy-bot.ts","9388951a-a6fe-11f1-9e37-1607ee4eb77e",68,["D",1788380422613],15,"interval","// ============================================================\n// Strategy Bot — Multi-Timeframe Technical Analysis Scanner\n// ------------------------------------------------------------\n// Runs on a cron interval (min ~15min on free tier). Each run:\n// 1. Discover medium & high liquidity coins\n// 2. Manage any open paper positions (close at SL/TP1/TP2)\n// 3. Generate signals using the strategy engine\n// 4. Open new paper trades + send Telegram alerts\n// ============================================================\n\nimport {\n buildLearningReport,\n generateSignal,\n getFloatingPnL,\n getLiquidCoins,\n getStrategyWallet,\n initStrategyDb,\n manageOpenPositions,\n openTrade,\n POSITION_SIZE_USDT,\n shouldAccept,\n type Signal,\n} from \"./strategy.ts\";\n\n// Risk per trade as % of wallet balance (exposed for Telegram display).\nconst RISK_PCT = 0.01; // 1% risk standard\n// How often to send the learning report over Telegram (every 15 min).\nconst LEARNING_REPORT_MS = 15 * 60 * 1000;\n\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) return false;\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\nconst sideEmoji = (s: string) => (s === \"LONG\" ? \"🟢\" : \"🔴\");\n\nfunction formatSignalAlert(\n sig: Signal,\n walletBalance: number,\n floating: { usd: number; pct: number; positions: number },\n) {\n const riskAmt = walletBalance * RISK_PCT;\n const lines = [\n `${sideEmoji(sig.side)} STRATEGY ${sig.side} — ${sig.symbol} ${sideEmoji(sig.side)}`,\n \"\",\n `🎯 Entry: ${sig.entry.toFixed(6)}`,\n `⛔ Stop Loss: ${sig.stopLoss.toFixed(6)}`,\n `✅ TP1 (1:1): ${sig.takeProfit1.toFixed(6)}`,\n `✅ TP2 (1:2): ${sig.takeProfit2.toFixed(6)}`,\n `📐 R:R → TP2: 1:${sig.rr.toFixed(2)}`,\n `🧠 Conf: ${sig.confidence}%`,\n \"💵 Risk: ~$\" + riskAmt.toFixed(2),\n `🔄 Floating P&L: ${floating.usd >= 0 ? \"+\" : \"\"}${floating.usd.toFixed(2)} (${floating.pct.toFixed(2)}%) — ${floating.positions} open`,\n \"\",\n `📌 ${sig.reason}`,\n ];\n return lines.join(\"\\n\");\n}\n\nexport default async function strategyBot() {\n await initStrategyDb();\n\n const wallet = await getStrategyWallet();\n\n // 1. Close any positions that hit their targets / stop.\n let closed = 0;\n try {\n closed = await manageOpenPositions();\n } catch (e) {\n console.log(\"[strategy] position management failed:\", e instanceof Error ? e.message : e);\n }\n\n // 2. Discover the medium & high liquidity universe.\n let coins = [];\n try {\n coins = await getLiquidCoins();\n } catch (e) {\n console.log(\"[strategy] liquidity discovery failed:\", e instanceof Error ? e.message : e);\n }\n if (coins.length === 0) {\n console.log(\"[strategy] no liquid coins found; skipping scan\");\n return;\n }\n\n const highCount = coins.filter((c) => c.liquidity === \"HIGH\").length;\n const medCount = coins.length - highCount;\n\n // 3. Generate signals across the universe, with a concurrency limit to\n // avoid hammering Binance rate limits when scanning many coins.\n const CONCURRENCY = 10;\n const results = await mapLimit(coins, CONCURRENCY, (c) => generateSignal(c.symbol, c.liquidity));\n\n let opened = 0;\n let learnedRejected = 0;\n const freshWallet = await getStrategyWallet();\n // Overall floating (unrealized) P&L across open positions, shown on every\n // new-trade alert.\n const floating = await getFloatingPnL();\n for (const sig of results) {\n if (!sig) continue;\n\n // 4. Adaptive learning gate: after enough closed trades, only accept\n // signals whose learned win probability clears the dynamic threshold.\n const verdict = await shouldAccept({\n confidence: sig.confidence,\n poiType: sig.poiType,\n trendType: sig.trendType,\n liquidity: sig.liquidity,\n side: sig.side,\n });\n if (!verdict.accept) {\n learnedRejected++;\n console.log(`[strategy] rejected by learning: ${sig.symbol} ${sig.side} (${verdict.reason})`);\n continue;\n }\n\n await openTrade(sig);\n opened++;\n await sendTelegram(formatSignalAlert(sig, freshWallet.balance, floating));\n }\n\n console.log(\n `[strategy] coins: HIGH=${highCount} MED=${medCount} | closed=${closed} opened=${opened} learnedRejected=${learnedRejected}`,\n );\n\n // 5. Send the learning report on a throttled schedule (every 6h).\n await maybeSendLearningReport();\n}\n\n// Reads the last-report timestamp from strategy_meta and sends the learning\n// report over Telegram at most once per LEARNING_REPORT_MS.\nasync function maybeSendLearningReport() {\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite/main.ts\");\n const res = await sqlite.execute(\n \"SELECT value FROM strategy_meta WHERE key = 'learning_report_at'\",\n );\n const last = (res.rows[0] as { value: number } | undefined)?.value ?? 0;\n const now = Date.now();\n if (now - last < LEARNING_REPORT_MS) return;\n\n const report = await buildLearningReport();\n const sent = await sendTelegram(report);\n if (sent) {\n await sqlite.execute(\n `INSERT INTO strategy_meta (key, value) VALUES ('learning_report_at', ?)\n ON CONFLICT(key) DO UPDATE SET value = excluded.value`,\n [now],\n );\n }\n}\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\n// Map over `items` running at most `limit` async tasks concurrently.\n// Returns results in the same order as items (null on rejection).\nasync function mapLimit(items: T[], limit: number, fn: (item: T) => Promise): Promise<(R | null)[]> {\n const out: (R | null)[] = new Array(items.length);\n let next = 0;\n const workers = Array.from({ length: Math.min(limit, items.length) }, async () => {\n while (true) {\n const i = next++;\n if (i >= items.length) return;\n try {\n out[i] = await fn(items[i]);\n } catch (e) {\n console.log(\"[strategy] signal failed:\", e instanceof Error ? e.message : e);\n out[i] = null;\n }\n }\n });\n await Promise.all(workers);\n return out;\n}\n",[],[194],["D",1788546491651],[],[18],"0fd45b75-11b8-4503-bbbf-5f0512015c0a","send-closed-report.ts","c0eee9b6-a88c-11f1-8787-1607ee4eb77e",76,["D",1788546336880],7,"// ============================================================\n// Send Closed-Trades Category Report over Telegram\n// ------------------------------------------------------------\n// Builds a categorized report of all CLOSED trades (tp1/tp2 = win,\n// sl = loss) grouped by exit type, POI type, trend, liquidity,\n// confidence and side — and sends it to the configured Telegram chat.\n// Run manually via run_file.\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nasync function sendTelegram(text: string): Promise {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n if (!token || !chatId) throw new Error(\"Missing TELEGRAM_BOT_TOKEN / TELEGRAM_CHAT_ID\");\n // Split into chunks of <= 3900 chars (Telegram) and send each message.\n const chunks: string[] = [];\n for (let i = 0; i < text.length; i += 3900) chunks.push(text.slice(i, i + 3900));\n const parts: string[] = [];\n for (let i = 0; i < chunks.length; i++) {\n const res = 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: chunks[i], parse_mode: \"HTML\", disable_web_page_preview: true }),\n });\n const body = await res.text();\n parts.push(`part${i + 1}/${chunks.length} -> ${res.status}: ${body.slice(0, 120)}`);\n }\n return parts.join(\"\\n\");\n}\n\nconst wrPct = (w: number, l: number) =>\n (w + l) > 0 ? ((w / (w + l)) * 100).toFixed(1) : \"0.0\";\n\n// One grouped row rendered as a Telegram line.\nfunction line(label: string, n: number, w: number, l: number) {\n const pct = wrPct(w, l);\n const emoji = n === 0 ? \"⚪\" : (w / n) >= 0.5 ? \"🟢\" : \"🔴\";\n return `• ${emoji} ${label} — ${pct}% (${w}W/${l}L) · ${n} صفقة`;\n}\n\nexport default async function sendClosedReport() {\n // ---- Overall ----\n const overall = await sqlite.execute(\n `SELECT COUNT(*) AS n,\n SUM(CASE WHEN status IN ('tp1','tp2') THEN 1 ELSE 0 END) AS wins,\n SUM(CASE WHEN status='sl' THEN 1 ELSE 0 END) AS losses\n FROM strategy_trades WHERE status != 'open'`,\n );\n const o = overall.rows[0] as { n: number; wins: number; losses: number };\n\n // ---- Exit types ----\n const exits = await sqlite.execute(\n `SELECT status, COUNT(*) AS n FROM strategy_trades WHERE status != 'open' GROUP BY status`,\n );\n const em = new Map((exits.rows as { status: string; n: number }[]).map((r) => [r.status, r.n]));\n\n // ---- Grouped queries ----\n const grouped = async (col: string, extra = \"\") => {\n const r = await sqlite.execute(\n `SELECT ${col} AS label, COUNT(*) AS n,\n SUM(CASE WHEN status IN ('tp1','tp2') THEN 1 ELSE 0 END) AS wins,\n SUM(CASE WHEN status='sl' THEN 1 ELSE 0 END) AS losses\n FROM strategy_trades WHERE status != 'open' AND ${col} IS NOT NULL\n GROUP BY ${col} ${extra} ORDER BY ${col}`,\n );\n return r.rows as unknown as { label: string; n: number; wins: number; losses: number }[];\n };\n\n const poi = await grouped(\"poi_type\", \", side\");\n const trend = await grouped(\"trend_type\");\n const liq = await grouped(\"liquidity\");\n const conf = await grouped(\"confidence\");\n const side = await grouped(\"side\");\n\n // ---- Smart-learning factors (strategy_factors) ----\n const factors = await sqlite.execute(\n \"SELECT factor, wins, losses FROM strategy_factors ORDER BY factor\",\n );\n const fRows = factors.rows as unknown as { factor: string; wins: number; losses: number }[];\n\n // ---- Per-symbol performance (winning / losing pairs) ----\n const syms = await sqlite.execute(\n `SELECT symbol,\n COUNT(*) AS n,\n SUM(CASE WHEN status IN ('tp1','tp2') THEN 1 ELSE 0 END) AS wins,\n SUM(CASE WHEN status='sl' THEN 1 ELSE 0 END) AS losses,\n SUM(pnl) AS net\n FROM strategy_trades WHERE status != 'open'\n GROUP BY symbol ORDER BY net DESC`,\n );\n const symRows = syms.rows as unknown as {\n symbol: string; n: number; wins: number; losses: number; net: number;\n }[];\n const winsArr = symRows.filter((s) => s.net > 0);\n const lossesArr = symRows.filter((s) => s.net < 0);\n\n // Render a comma-separated list of symbols in chunks (Telegram 4096 char limit).\n const chunk = (arr: { symbol: string; net: number }[], n: number) => {\n const lines: string[] = [];\n for (let i = 0; i < arr.length; i += n) {\n lines.push(arr.slice(i, i + n).map((s) => s.symbol).join(\" \"));\n }\n return lines;\n };\n\n const lines: string[] = [\n \"📊 تقرير الصفقات المغلقة (مصنّف)\",\n \"\",\n `🧮 الإجمالي: ${o.n} صفقة مغلقة`,\n `✅ رابحة: ${o.wins} · ❌ خاسرة: ${o.losses}`,\n `📈 معدل الربح: ${wrPct(o.wins, o.losses)}%`,\n \"\",\n \"① حسب نوع الخروج:\",\n `• 🎯 TP1 (1:1): ${em.get(\"tp1\") ?? 0} · 🎯 TP2 (1:2): ${em.get(\"tp2\") ?? 0} · ⛔ SL: ${em.get(\"sl\") ?? 0}`,\n \"\",\n \"② حسب نوع الدخول (POI + الطرف):\",\n ...poi.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"③ حسب الاتجاه:\",\n ...trend.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"④ حسب السيولة:\",\n ...liq.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"⑤ حسب الثقة:\",\n ...conf.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"⑥ حسب الطرف:\",\n ...side.map((p) => line(p.label, p.n, p.wins, p.losses)),\n \"\",\n \"🧠 عوامل التعلم الذكي (strategy_factors):\",\n ...fRows.map((f) => line(f.factor, f.wins + f.losses, f.wins, f.losses)),\n \"\",\n `🤑 الأزواج الرابحة (${winsArr.length}):`,\n ...chunk(winsArr, 12),\n \"\",\n `📉 الأزواج الخاسرة (${lossesArr.length}):`,\n ...chunk(lossesArr, 12),\n \"\",\n \"⭐ أفضل الأزواج:\",\n ...winsArr.slice(0, 5).map((s) => `• ${s.symbol} — +${s.net}R (${s.wins}W/${s.losses}L)`),\n \"\",\n \"⚠️ أسوأ الأزواج:\",\n ...lossesArr.slice(0, 5).map((s) => `• ${s.symbol} — ${s.net}R (${s.wins}W/${s.losses}L)`),\n ];\n\n const sent = await sendTelegram(lines.join(\"\\n\"));\n console.log(`Report sent: ${sent}`);\n await blob.setJSON(\"report_send_status\", { at: Date.now(), result: sent });\n return sent;\n}\n",[],[207],"7b69d048-761d-467d-b04d-439e0d7d1b26","diag.ts","2b19189c-a88e-11f1-8e01-1607ee4eb77e",77,["D",1788546398697],"// Diagnostic: verify env + db + blob plumbing really run under run_file.\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nexport default async function diag() {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n const info = {\n hasToken: !!token,\n tokenLen: token ? token.length : 0,\n hasChat: !!chatId,\n chatVal: chatId ?? null,\n };\n console.log(\"DIAG\", JSON.stringify(info));\n await blob.setJSON(\"diag_result\", info);\n return info;\n}\n",[],[216],"00ba2cec-5f37-4ffb-be18-25ad4fa29501","bot.ts","01a0634d-9d8b-740b-a6cc-84f18531dd38",17,["D",1788373286407],11,"// 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",[],[224],"dada8e7a-0ab7-41d4-b8ff-a0e5c00133d1","README.md","7d594726-a6f9-11f1-9aba-1607ee4eb77e",20,["D",1788373295716],5,"# Binance Triangular Arbitrage Paper Bot\n\nA Val Town Deno/TypeScript **paper-trading** bot that scans Binance for triangular\narbitrage opportunities among today's top-gaining tokens. It only *simulates*\ntrades — no real money is ever at risk.\n\n## How it works\n\n1. **Discovery** — fetches `/api/v3/ticker/24hr`, keeps symbols quoted in USDT,\n filters to those that also have an active `TOKEN/ETH` pair, then takes the top\n N by 24h % change.\n2. **Cross-rate analysis** — for each top-gainer token it concurrently fetches the\n three legs of the triangle (`TOKENUSDT`, `TOKENETH`, `ETHUSDT`) via\n `/api/v3/ticker/bookTicker`, computes both triangular directions, applies a\n 0.1% fee on each leg (0.3% total), and reports the gross %, net $ profit, and route.\n3. **Paper execution** — when net profit clears the 0.1% threshold and the $1000\n paper wallet has funds, the trade is logged to SQLite **and** a real-time\n Telegram alert is sent for **every** trade (small or large), including the\n updated total balance and running PnL.\n4. **Reporting** — additionally, at most every 10 minutes a throttled Telegram\n summary is sent covering balance, PnL, win rate, scan count, and the last 10\n minutes of trades.\n\n## Data source\n\nBinance's primary API (`api.binance.com`) can return **HTTP 451** from data-center\nIPs (a regional block). This bot uses `data-api.binance.vision`, which serves the\nidentical `/api/v3` endpoints globally — same quotes, no geo-lock.\n\n## Files\n\n- `bot.ts` — the cron job (`binanceTriangularBot`). Runs every minute and performs\n 12 fast scan rounds ~4s apart. The top-gainer list is cached and refreshed once\n a minute (the 24h call is heavy), while the cheap order-book scans run every\n few seconds — fast scanning without hitting Binance rate limits. Sends a\n real-time alert per executed trade plus a 10-minute summary. Exports\n `buildReport()` for reuse by the webhook.\n- `webhook.ts` — HTTP handler responding to Telegram `/start`, `/stats`, and\n `/report` commands.\n\n## Setup\n\n1. Optionally set the two env vars to enable Telegram reporting:\n - `TELEGRAM_BOT_TOKEN` — from [@BotFather](https://t.me/BotFather)\n - `TELEGRAM_CHAT_ID` — your chat id (ask [@userinfobot](https://t.me/userinfobot))\n\n2. Point Telegram at the webhook (replace `` with your bot token) so\n `/stats` works in-chat:\n\n ```text\n https://api.telegram.org/bot/setWebhook?url=https://binance-arb-bot.val.run/\n ```\n\n## Tuning\n\nAll knobs live at the top of `bot.ts`:\n\n| Constant | Default | Meaning |\n| --- | --- | --- |\n| `FEE_PER_LEG` | `0.001` | fee per leg (0.1%); use `0.00075` for 0.075% |\n| `TRADE_AMOUNT_USDT` | `100` | simulated $ per triangular loop |\n| `MIN_NET_PROFIT_PCT` | `0.1` | min net % to execute |\n| `TOP_GAINERS_N` | `20` | top gainers analyzed per scan |\n| `SCAN_ROUNDS` | `12` | scans per cron run |\n| `COOLDOWN_MS` | `4000` | seconds between scans (4s) |\n| `REFRESH_GAINERS_MS` | `60000` | how often the top-gainer list is re-fetched |\n\n> ⚠️ **Real-time per-trade alerts** mean Telegram can be chatty during volatile\n> windows. If that's too much, raise `MIN_NET_PROFIT_PCT` or drop `SCAN_ROUNDS`.\n\nLive Binance spreads plus 0.3% total fees mean real trades are rare — that's\ncorrect behavior; opportunities appear during volatile moves.\n",[],[233],["D",1788372422505],["D",1789501263826],{"_11":12,"_123":70},{"_11":12,"_119":70,"_69":70,"_30":68,"_120":121,"_122":24},{"_38":39,"_13":16,"_32":35,"_111":72,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":14,"_118":12},"ctx",{"_53":-5,"_142":279,"_280":281,"_282":283,"_284":24,"_285":24,"_286":24,"_287":85,"_288":-5,"_289":-7,"_290":-7,"_291":26,"_292":24,"_293":24,"_294":-5,"_295":24,"_296":24,"_297":24,"_298":-5},"ENV",{"_250":251,"_252":253,"_254":16,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

History · send-report.ts