[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_108":109,"_110":111},"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","safety.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":36,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":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/safety.ts","extension","id","08a99dd7-c3cd-48cf-a338-fb94b4e5f679","fileId","01a08c71-2752-7580-b74f-f1ae245c8a62","parentId","branchId","f55e56d9-ba48-4dc9-b0cf-2c04b61ed99b","branchVersion",1,"latest",true,"createdAt",["D",1789062620859],"version",0,"fileType","script","content","// 🛡️ Safety rails (Option C) — kill switch, daily loss/trade caps, drawdown\n// guard, position dedup, per-symbol cooldown, and position reconciliation.\n//\n// All state lives in this val's SQLite DB, so the rails survive restarts and\n// are shared between the cron bot and the HTTP control webhook.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport * as cfg from \"./config.ts\";\n\nexport async function initDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS state (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n kill_switch INTEGER NOT NULL DEFAULT 0,\n updated_at INTEGER NOT NULL DEFAULT 0,\n mode TEXT NOT NULL DEFAULT 'paper'\n )`);\n // Migration for databases created before the `mode` column existed.\n await sqlite.execute(`ALTER TABLE state ADD COLUMN mode TEXT NOT NULL DEFAULT 'paper'`).catch(() => {});\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS daily (\n day TEXT PRIMARY KEY,\n realized_pnl REAL NOT NULL DEFAULT 0,\n trades INTEGER NOT NULL DEFAULT 0\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS open_positions (\n symbol TEXT PRIMARY KEY,\n side TEXT NOT NULL,\n amount REAL NOT NULL,\n entry REAL NOT NULL,\n last_mark REAL NOT NULL,\n opened_at INTEGER NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS trade_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT NOT NULL,\n side TEXT NOT NULL,\n amount REAL NOT NULL,\n entry REAL NOT NULL,\n stop REAL NOT NULL,\n target REAL NOT NULL,\n pnl REAL,\n status TEXT NOT NULL DEFAULT 'open',\n ts INTEGER NOT NULL\n )`);\n await sqlite.execute(\n `INSERT OR IGNORE INTO state (id, kill_switch, updated_at) VALUES (1, 0, 0)`,\n );\n}\n\n// ---------- Kill switch ----------\nexport async function isKillSwitched(): Promise {\n const r = await sqlite.execute(\"SELECT kill_switch FROM state WHERE id = 1\");\n const row = r.rows[0] as unknown as { kill_switch: number } | undefined;\n return row ? !!row.kill_switch : false;\n}\n\nexport async function setKillSwitch(on: boolean): Promise {\n await sqlite.execute(\"UPDATE state SET kill_switch = ?, updated_at = ? WHERE id = 1\", [on ? 1 : 0, Date.now()]);\n}\n\n// ---------- Daily ledger ----------\nfunction today(): string {\n return new Date().toISOString().slice(0, 10); // UTC YYYY-MM-DD\n}\n\nasync function getDaily(): Promise<{ realized_pnl: number; trades: number }> {\n const r = await sqlite.execute(\"SELECT realized_pnl, trades FROM daily WHERE day = ?\", [today()]);\n const row = r.rows[0] as unknown as { realized_pnl: number; trades: number } | undefined;\n if (!row) return { realized_pnl: 0, trades: 0 };\n return { realized_pnl: row.realized_pnl ?? 0, trades: row.trades ?? 0 };\n}\n\nexport async function getDailyStats() {\n return getDaily();\n}\n\nexport async function openPositionCount(): Promise {\n const r = await sqlite.execute(\"SELECT COUNT(*) AS n FROM open_positions\");\n const row = r.rows[0] as unknown as { n: number };\n return row?.n ?? 0;\n}\n\n// ---------- Entry-time protection ----------\nexport interface SafetyResult { ok: boolean; reason?: string; }\n\nexport async function checkEntrySafety(symbol: string): Promise {\n if (await isKillSwitched()) return { ok: false, reason: \"kill switch is ON\" };\n\n if ((await openPositionCount()) >= cfg.MAX_OPEN_TRADES) {\n return { ok: false, reason: `max open trades (${cfg.MAX_OPEN_TRADES}) reached` };\n }\n\n const d = await getDaily();\n if (d.realized_pnl <= -cfg.MAX_DAILY_LOSS_USD) {\n return { ok: false, reason: `daily loss cap hit (${d.realized_pnl.toFixed(2)} USD)` };\n }\n if (d.trades >= cfg.MAX_DAILY_TRADES) {\n return { ok: false, reason: `daily trade cap hit (${d.trades})` };\n }\n\n const pos = await sqlite.execute(\"SELECT 1 FROM open_positions WHERE symbol = ?\", [symbol]);\n if (pos.rows.length > 0) return { ok: false, reason: \"symbol already has an open position\" };\n\n const last = await sqlite.execute(\n \"SELECT ts FROM trade_log WHERE symbol = ? ORDER BY ts DESC LIMIT 1\",\n [symbol],\n );\n const lastTs = (last.rows[0] as unknown as { ts: number } | undefined)?.ts;\n if (lastTs && Date.now() - lastTs < cfg.SYMBOL_COOLDOWN_MS) {\n return { ok: false, reason: \"symbol in cooldown\" };\n }\n\n return { ok: true };\n}\n\nexport async function unrealizedDrawdownUsd(): Promise {\n const r = await sqlite.execute(\"SELECT side, amount, entry, last_mark FROM open_positions\");\n const rows = r.rows as unknown as { side: string; amount: number; entry: number; last_mark: number }[];\n let loss = 0;\n for (const p of rows) {\n const move = p.side === \"buy\" ? p.last_mark - p.entry : p.entry - p.last_mark;\n const pnl = move * p.amount;\n if (pnl < 0) loss += Math.abs(pnl);\n }\n return loss;\n}\n\n// ---------- Recording trades ----------\nexport async function registerOpenPosition(\n symbol: string,\n side: \"buy\" | \"sell\",\n amount: number,\n entry: number,\n lastMark: number,\n stop: number,\n target: number,\n) {\n await sqlite.batch([\n {\n sql: \"INSERT INTO open_positions (symbol, side, amount, entry, last_mark, opened_at) VALUES (?, ?, ?, ?, ?, ?)\",\n args: [symbol, side, amount, entry, lastMark, Date.now()],\n },\n {\n sql: \"INSERT INTO trade_log (symbol, side, amount, entry, stop, target, status, ts) VALUES (?, ?, ?, ?, ?, ?, 'open', ?)\",\n args: [symbol, side, amount, entry, stop, target, Date.now()],\n },\n {\n sql: \"INSERT INTO daily (day, realized_pnl, trades) VALUES (?, 0, 1) ON CONFLICT(day) DO UPDATE SET trades = trades + 1\",\n args: [today()],\n },\n ]);\n}\n\n// ---------- Reconciliation with the exchange ----------\n// Syncs our DB ledger with what Binance actually reports, marking positions\n// that have disappeared as closed and booking their (approximate) realized PnL.\nexport async function reconcile(exchange: any): Promise<{ liveCount: number; realizedClosed: number }> {\n let live: any[] = [];\n try {\n live = await exchange.fetchPositions();\n } catch (err) {\n console.error(\"[reconcile] fetchPositions failed:\", err?.message ?? err);\n return { liveCount: 0, realizedClosed: 0 };\n }\n\n // Correct short handling: use |contracts|, not positive-only (Option C fix).\n const liveMap = new Map();\n for (const p of live) {\n if (Math.abs(parseFloat(p.contracts)) > 0) {\n const mark = parseFloat(p.markPrice ?? p.entryPrice) || 0;\n liveMap.set(p.symbol, mark);\n }\n }\n\n // Update last_mark for live positions.\n for (const [symbol, mark] of liveMap) {\n await sqlite.execute(\"UPDATE open_positions SET last_mark = ? WHERE symbol = ?\", [mark, symbol]);\n }\n\n // Book closures: positions in our DB no longer on the exchange.\n const r = await sqlite.execute(\"SELECT * FROM open_positions\");\n const rows = r.rows as unknown as {\n symbol: string; side: string; amount: number; entry: number; last_mark: number;\n }[];\n let realized = 0;\n for (const p of rows) {\n if (!liveMap.has(p.symbol)) {\n const move = p.side === \"buy\" ? p.last_mark - p.entry : p.entry - p.last_mark;\n const pnl = move * p.amount;\n realized += pnl;\n await sqlite.batch([\n {\n sql: \"UPDATE trade_log SET pnl = ?, status = 'closed' WHERE symbol = ? AND status = 'open'\",\n args: [pnl, p.symbol],\n },\n { sql: \"DELETE FROM open_positions WHERE symbol = ?\", args: [p.symbol] },\n ]);\n }\n }\n if (realized !== 0) {\n await sqlite.execute(\n `INSERT INTO daily (day, realized_pnl, trades) VALUES (?, ?, 0)\n ON CONFLICT(day) DO UPDATE SET realized_pnl = realized_pnl + ?`,\n [today(), realized, realized],\n );\n }\n return { liveCount: liveMap.size, realizedClosed: realized };\n}\n// ---------- Trade mode (paper vs real) ----------\n// The switch lives in the DB so it can be flipped instantly (no redeploy) via\n// the control webhook. Default is 'paper' — safe to test without live money.\nexport type TradeMode = \"paper\" | \"real\";\n\nexport async function getMode(): Promise {\n const r = await sqlite.execute(\"SELECT mode FROM state WHERE id = 1\");\n const row = r.rows[0] as unknown as { mode?: string } | undefined;\n return row?.mode === \"real\" ? \"real\" : \"paper\";\n}\n\nexport async function setMode(mode: TradeMode): Promise {\n await sqlite.execute(\"UPDATE state SET mode = ?, updated_at = ? WHERE id = 1\", [mode, Date.now()]);\n}\n\n// ---------- Paper simulation helpers ----------\nexport interface OpenPositionRow {\n symbol: string;\n side: \"buy\" | \"sell\";\n amount: number;\n entry: number;\n last_mark: number;\n stop: number;\n target: number;\n}\n\nexport async function listOpenPositions(): Promise {\n const r = await sqlite.execute(\n `SELECT o.symbol, o.side, o.amount, o.entry, o.last_mark, t.stop, t.target\n FROM open_positions o\n LEFT JOIN trade_log t ON t.symbol = o.symbol AND t.status = 'open'`,\n );\n return (r.rows as unknown as OpenPositionRow[]).filter((x) => x.stop != null && x.target != null);\n}\n\nexport async function updateMark(symbol: string, mark: number): Promise {\n await sqlite.execute(\"UPDATE open_positions SET last_mark = ? WHERE symbol = ?\", [mark, symbol]);\n}\n\n// Books a paper close at exitPrice. Returns the realized PnL.\nexport async function bookClose(symbol: string, exitPrice: number): Promise {\n const r = await sqlite.execute(\n \"SELECT side, amount, entry FROM open_positions WHERE symbol = ?\",\n [symbol],\n );\n const p = r.rows[0] as unknown as { side: string; amount: number; entry: number } | undefined;\n if (!p) return 0;\n const pnl = p.side === \"buy\" ? (exitPrice - p.entry) * p.amount : (p.entry - exitPrice) * p.amount;\n await sqlite.batch([\n {\n sql: \"UPDATE trade_log SET pnl = ?, status = 'closed' WHERE symbol = ? AND status = 'open'\",\n args: [pnl, symbol],\n },\n { sql: \"DELETE FROM open_positions WHERE symbol = ?\", args: [symbol] },\n ]);\n await sqlite.execute(\n `INSERT INTO daily (day, realized_pnl, trades) VALUES (?, ?, 0)\n ON CONFLICT(day) DO UPDATE SET realized_pnl = realized_pnl + ?`,\n [today(), pnl, pnl],\n );\n return pnl;\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","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,"_107":102},"org",{"_9":10,"_101":102,"_103":102,"_55":56,"_104":105,"_106":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":92,"_93":94,"_95":50,"_96":97,"_98":64,"_99":12,"_100":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",{"_81":-5,"_141":142,"_143":144,"_145":146,"_147":42,"_148":42,"_149":42,"_150":32,"_151":-5,"_152":-7,"_153":-7,"_154":36,"_155":42,"_156":42,"_157":-5,"_158":42,"_159":42,"_160":42,"_161":-5},"ENV",{"_112":113,"_114":115,"_116":89,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140},"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"]