[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_105":106,"_107":108},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","Binance","name","binance-real-bot","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/Binance/binance-real-bot/code/main.ts","extension","id","fc1781d6-752a-4bf5-81bc-0286e53e4a7d","fileId","c0d3804c-abbe-11f1-9d5a-1607ee4eb77e","parentId","branchId","9f798aa1-ba4a-45ed-a7ed-ddaad6de2951","branchVersion",25,"latest",true,"createdAt",["D",1788907364690],"version",6,"fileType","interval","content","// ============================================================================\n// 🤖 Binance USDT-M futures bot — cron entrypoint.\n// Real money. Every entry is gated by the scored strategy (Option B) AND all\n// safety rails (Option C). Run via the val's interval schedule.\n// ============================================================================\nimport ccxt from \"npm:ccxt@^4.0.0\";\nimport * as cfg from \"./config.ts\";\nimport { sendTelegram } from \"./telegram.ts\";\nimport { analyze } from \"./strategy.ts\";\nimport { fetchFlow } from \"./flow.ts\";\nimport {\n initDb,\n isKillSwitched,\n checkEntrySafety,\n registerOpenPosition,\n reconcile,\n unrealizedDrawdownUsd,\n} from \"./safety.ts\";\n\nlet cachedSymbols: string[] = [];\nlet lastListUpdate = 0;\n\nfunction splitIntoBatches(arr: T[], n: number): T[][] {\n const out: T[][] = [];\n const size = Math.ceil(arr.length / n);\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\n return out;\n}\n\nasync function getHighVolumeSymbols(exchange: any): Promise {\n const now = Date.now();\n if (cachedSymbols.length > 0 && now - lastListUpdate < cfg.REFRESH_INTERVAL_MS) {\n return cachedSymbols;\n }\n try {\n const tickers = await exchange.fetchTickers();\n const symbols: string[] = [];\n for (const [symbol, t] of Object.entries(tickers) as any) {\n // Futures perps are /USDT:USDT; skip spot-only and non-USDT pairs.\n if (!symbol.includes(\":USDT\")) continue;\n const base = symbol.split(\"/\")[0].toUpperCase();\n // Exclude BTC/ETH and any coin trading above $1,000.\n if (cfg.EXCLUDED_BASES.includes(base)) continue;\n const last = parseFloat(t?.last) || 0;\n if (last > 0 && last > cfg.MAX_BASE_PRICE_USD) continue;\n // Liquidity filter: ≥ $20M 24h quote volume.\n const quoteVolume = t?.quoteVolume ?? 0;\n if (quoteVolume >= cfg.MIN_VOLUME_USD) symbols.push(symbol);\n }\n cachedSymbols = symbols;\n lastListUpdate = now;\n console.log(\n `[universe] ${symbols.length} symbols (vol ≥ ${cfg.MIN_VOLUME_USD / 1e6}M, no BTC/ETH, price ≤ ${cfg.MAX_BASE_PRICE_USD})`,\n );\n } catch (err) {\n console.error(\"[universe] fetch failed:\", err?.message ?? err);\n }\n return cachedSymbols;\n}\n\n// Analyze one symbol and open a real trade if every gate passes.\nasync function analyzeAndTrade(exchange: any, symbol: string, equity: number): Promise {\n try {\n const flow = await fetchFlow(exchange, symbol);\n if (!flow) return false;\n\n const sig = analyze(flow);\n if (!sig) return false;\n\n const safety = await checkEntrySafety(symbol);\n if (!safety.ok) {\n console.log(`[skip] ${symbol} — ${safety.reason}`);\n return false;\n }\n\n // Fixed-fractional risk sizing: risk RISK_PER_TRADE% of equity to the stop.\n const priceRisk = Math.abs(sig.price - sig.stop);\n if (priceRisk <= 0) return false;\n let amount = (equity * cfg.RISK_PER_TRADE) / priceRisk;\n amount = parseFloat(exchange.amountToPrecision(symbol, amount));\n if (!(amount > 0)) return false;\n\n await exchange.setMarginMode(\"ISOLATED\", symbol).catch(() => {});\n await exchange.setLeverage(cfg.LEVERAGE, symbol).catch(() => {});\n\n const order = await exchange.createOrder(symbol, \"market\", sig.side, amount);\n const execPrice = parseFloat(order?.average) || sig.price;\n\n // Bracket: stop-loss and take-profit, both reduce-only so they CLOSE this\n // position rather than building a fresh one.\n const stopSide = sig.side === \"buy\" ? \"sell\" : \"buy\";\n const stopPrice = exchange.priceToPrecision(symbol, sig.stop);\n const tpPrice = exchange.priceToPrecision(symbol, sig.target);\n await exchange.createOrder(symbol, \"STOP_MARKET\", stopSide, amount, undefined, {\n stopPrice,\n reduceOnly: true,\n });\n await exchange.createOrder(symbol, \"TAKE_PROFIT_MARKET\", stopSide, amount, undefined, {\n stopPrice: tpPrice,\n reduceOnly: true,\n });\n\n await registerOpenPosition(symbol, sig.side, amount, execPrice, execPrice, sig.stop, sig.target);\n\n const msg =\n `✅ Real trade opened @ Binance\\n` +\n `Pair: ${symbol} Side: ${sig.side.toUpperCase()}\\n` +\n `Amount: ${amount} Leverage: ${cfg.LEVERAGE}x\\n` +\n `Entry: ${execPrice} Score: ${sig.score}/100\\n` +\n `Stop: ${stopPrice} Target: ${tpPrice}\\n` +\n `(risk ${cfg.RISK_PER_TRADE * 100}% ≈ $${(amount * priceRisk).toFixed(2)})`;\n await sendTelegram(msg);\n console.log(`[trade] OPEN ${symbol} ${sig.side} ${amount} @ ${execPrice} (score ${sig.score})`);\n return true;\n } catch (err) {\n console.error(`[trade] error ${symbol}:`, err?.message ?? err);\n return false;\n }\n}\n\nexport default async function binanceBot() {\n const apiKey = Deno.env.get(\"BINANCE_API_KEY\");\n const secret = Deno.env.get(\"BINANCE_SECRET_KEY\");\n if (!apiKey || !secret) {\n console.error(\"❌ BINANCE_API_KEY / BINANCE_SECRET_KEY missing; aborting.\");\n return;\n }\n await initDb();\n\n if (await isKillSwitched()) {\n console.log(\"⛔ kill switch is ON; skipping this run.\");\n return;\n }\n\n // Proxy support: Deno's fetch routes ALL outbound HTTP through the standard\n // proxy env vars when they are set on the val. Set HTTPS_PROXY (and NO_PROXY\n // to keep e.g. api.telegram.org direct). ccxt uses the global fetch in Deno,\n // so it flows through the same proxy automatically.\n const proxy = Deno.env.get(\"HTTPS_PROXY\") || Deno.env.get(\"ALL_PROXY\");\n if (proxy) console.log(`[proxy] outbound requests via ${proxy}`);\n else console.log(\"[proxy] none set — Binance may 451 from restricted regions\");\n\n const exchange: any = new ccxt.binanceusdm({\n apiKey,\n secret,\n enableRateLimit: true,\n options: { defaultType: \"future\" },\n });\n\n try {\n // 1. Reconcile DB ledger with the exchange (books closed positions, marks).\n const reco = await reconcile(exchange);\n if (reco.realizedClosed !== 0) {\n await sendTelegram(`🔁 Closed positions booked: ${reco.realizedClosed >= 0 ? \"+\" : \"\"}$${reco.realizedClosed.toFixed(2)}`);\n }\n\n // 2. Drawdown guard: keep existing positions, but stop opening new ones.\n const dd = await unrealizedDrawdownUsd();\n if (dd >= cfg.MAX_DRAWDOWN_USD) {\n const warn = `🛑 Drawdown guard: unrealized loss $${dd.toFixed(2)} ≥ $${cfg.MAX_DRAWDOWN_USD}. No new trades this run.`;\n console.log(warn);\n await sendTelegram(warn);\n return;\n }\n\n // 3. Equity check.\n const balance = await exchange.fetchBalance();\n const equity = parseFloat(balance?.total?.USDT) || 0;\n if (equity < cfg.MIN_EQUITY_USD) {\n console.log(`❌ Equity ${equity.toFixed(2)} below minimum ${cfg.MIN_EQUITY_USD}; skipping.`);\n return;\n }\n\n // 4. Scan the high-liquidity universe in batches.\n const symbols = await getHighVolumeSymbols(exchange);\n if (symbols.length === 0) return;\n const batches = splitIntoBatches(symbols, cfg.NUM_BATCHES);\n\n let opened = 0;\n for (let i = 0; i < batches.length; i++) {\n console.log(`⚡ batch ${i + 1}/${batches.length} — ${batches[i].length} symbols`);\n for (const symbol of batches[i]) {\n if (opened >= cfg.MAX_OPEN_TRADES) break;\n if (await analyzeAndTrade(exchange, symbol, equity)) opened++;\n }\n if (i < batches.length - 1) await new Promise((r) => setTimeout(r, 1500));\n }\n console.log(`[done] opened ${opened} trades this run.`);\n } catch (err) {\n console.error(\"[bot] fatal:\", err?.message ?? err);\n await sendTelegram(`💥 Bot error: ${String(err?.message ?? err).slice(0, 400)}`);\n } finally {\n await exchange.close().catch(() => {});\n }\n}\n","deleted",false,"label",[14],"075de61f-1141-4ceb-b83f-96232b211a28",["D",1788897119110],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Binance USDT-M futures bot: scored strategy + safety rails","imageUrl","userId","de9949b3-d286-4696-9538-79ebf129f0e6","pinnedFileId","02647584-abbf-11f1-9109-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0828d-f9ec-77f1-abc8-5a6cd3581ff4","tursoName","075de61f11414cebb83f96232b211a28","tursoHostname","075de61f11414cebb83f96232b211a28-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789511441255],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_104":99},"org",{"_9":10,"_98":99,"_100":99,"_55":56,"_101":102,"_103":42},"branch",{"_35":30,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_138":139,"_140":141,"_142":143,"_144":42,"_145":42,"_146":42,"_147":32,"_148":-5,"_149":-7,"_150":-7,"_151":63,"_152":42,"_153":42,"_154":-5,"_155":42,"_156":42,"_157":42,"_158":-5},"ENV",{"_109":110,"_111":112,"_113":89,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]