[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","Binance","name","bybit-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/bybit-real-bot/code/main.ts","extension","id","c926f5d7-4c19-438f-bcd5-519cb9512196","fileId","01a08c71-2752-7580-b74f-ecaa964081fc","parentId","branchId","f55e56d9-ba48-4dc9-b0cf-2c04b61ed99b","branchVersion",3,"latest",true,"createdAt",["D",1789062649052],"version",2,"fileType","interval","content","// ============================================================================\n// 🤖 Bybit USDT perpetual 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// Bybit linear perps (/USDT:USDT), the same universe the old Binance bot used.\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 // Bybit linear perpetuals are /USDT:USDT in ccxt; skip spot and\n // inverse-perp (/USD:USD) pairs with this filter.\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 // Bybit bracket: attach the stop-loss and take-profit to the SAME entry\n // order so the position is protected the instant it opens. ccxt turns\n // stopLoss/takeProfit params into Bybit's trigger orders automatically\n // (setting triggerDirection for us). No gap where a position sits naked.\n const order = await exchange.createOrder(symbol, \"market\", sig.side, amount, undefined, {\n stopLoss: { triggerPrice: exchange.priceToPrecision(symbol, sig.stop) },\n takeProfit: { triggerPrice: exchange.priceToPrecision(symbol, sig.target) },\n });\n const execPrice = parseFloat(order?.average) || sig.price;\n\n await registerOpenPosition(symbol, sig.side, amount, execPrice, execPrice, sig.stop, sig.target);\n\n const msg =\n `✅ Real trade opened @ Bybit\\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: ${exchange.priceToPrecision(symbol, sig.stop)} Target: ${exchange.priceToPrecision(symbol, sig.target)}\\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 bybitBot() {\n const apiKey = Deno.env.get(\"BYBIT_API_KEY\");\n const secret = Deno.env.get(\"BYBIT_SECRET\");\n if (!apiKey || !secret) {\n console.error(\"❌ BYBIT_API_KEY / BYBIT_SECRET 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 — using Bybit directly\");\n\n const exchange: any = new ccxt.bybit({\n apiKey,\n secret,\n enableRateLimit: true,\n // 'swap' = linear (USDT / USDC) perpetuals. This is the Bybit equivalent\n // of Binance's USDT-M futures market.\n options: { defaultType: \"swap\" },\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],"a8db929b-14e4-41d7-8824-3d01dc9f26d1",["D",1789062620859],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Bybit perps bot via ccxt: order-flow strategy + safety rails","imageUrl","userId","de9949b3-d286-4696-9538-79ebf129f0e6","pinnedFileId","01a08c71-2751-70cd-9be5-7675cf007f90","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0828d-f9ec-77f1-abc8-5a6cd3581ff4","tursoName","a8db929b14e441d788243d01dc9f26d1","tursoHostname","a8db929b14e441d788243d01dc9f26d1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789497078049],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":103},"org",{"_9":10,"_102":103,"_104":103,"_55":56,"_105":106,"_107":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":93,"_94":95,"_96":50,"_97":98,"_99":65,"_100":12,"_101":10},"isOwned",6,"main","projectId","forkedBranchId","9f798aa1-ba4a-45ed-a7ed-ddaad6de2951","forkedBranchVersion",25,"forkedProjectPrivacy","forkedProjectId","075de61f-1141-4ceb-b83f-96232b211a28","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_142":143,"_144":145,"_146":147,"_148":42,"_149":42,"_150":42,"_151":32,"_152":-5,"_153":-7,"_154":-7,"_155":63,"_156":42,"_157":42,"_158":-5,"_159":42,"_160":42,"_161":42,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":90,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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"]