Bot BTC — Live

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_344":345,"_346":347},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",42,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":20,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","dashboard/index.html","latestPath","fileId","b11ed694-7b15-11f1-82d2-1607ee4eb77e","name","index.html","fileType","content","\n\n\n \n \n Bot BTC — Live\n \n \n \n\n\n

\n \n\n\n","createdAt",["D",1783546852120],"branchVersion","branchId","7c855042-1822-43ed-88ed-5fba3b2e4b2c","id","0b605b64-5bfb-43d1-ab16-9786bd2f3d83","sol-trader",["D",1783543222179],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Bot de trading SOL/EUR sur Kraken — low-risk, reporting Telegram","imageUrl","8d89a132-e934-4337-9c2d-b24da53fae41","pinnedFileId","a701d49a-7b15-11f1-a875-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f3464-6121-776b-8272-f6b8e0a171e0","tursoName","0b605b645bfb43d1ab169786bd2f3d83","tursoHostname","0b605b645bfb43d1ab169786bd2f3d83-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",172,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Guakamelo","handle","displayName","Alexandre CHASSIN","avatar","https://lh3.googleusercontent.com/a/ACg8ocLwmmkCrNoCajvGIN8g-i5QG-YGLK02kshzyOj-JvD33dyNLI7k=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":339,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":340,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":341,"_82":342,"_84":343,"_86":24},"tree",[197,200,203,209,213,215,216],"files",[197,198,199,200,201,202,203,204,205,206,207,208,209,210,211,212,213,214,215,216],"counts",{"_186":61,"_187":143,"_188":61,"_189":190,"_191":192},"contents",[129,130,131,132,133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":180,"_31":181,"_29":182,"_139":-5,"_39":40,"_38":183,"_141":57,"_36":184,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_26":185},{"_41":174,"_31":175,"_29":176,"_139":-5,"_39":40,"_38":177,"_141":57,"_36":178,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_26":179},{"_41":168,"_31":169,"_29":170,"_139":-5,"_39":40,"_38":171,"_141":57,"_36":172,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_26":173},{"_41":162,"_31":163,"_29":164,"_139":-5,"_39":40,"_38":165,"_141":57,"_36":166,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_26":167},{"_41":155,"_31":156,"_29":157,"_139":-5,"_39":40,"_38":158,"_141":57,"_36":159,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_26":161},{"_41":148,"_31":149,"_29":150,"_139":-5,"_39":40,"_38":151,"_141":24,"_36":152,"_13":143,"_33":20,"_34":153,"_23":24,"_146":-5,"_26":154},{"_41":136,"_31":137,"_29":138,"_139":-5,"_39":40,"_38":140,"_141":24,"_36":142,"_13":143,"_33":144,"_34":145,"_23":24,"_146":-5,"_26":147},"8faa67a8-f4eb-475c-b750-d6d9aff77406","config.ts","49432064-7b0d-11f1-bdc0-1607ee4eb77e","parentId",19,"latest",["D",1783545485322],1,"script","// Configuration du bot — tout est en un seul endroit.\nexport const CONFIG = {\n PAIR: \"XBTEUR\", // paire Kraken (Bitcoin/EUR)\n BASE_ASSET: \"XXBT\", // clé de balance Kraken pour BTC\n BASE_LABEL: \"BTC\", // libellé pour les messages\n QUOTE_ASSET: \"ZEUR\", // clé de balance Kraken pour EUR\n VOL_DECIMALS: 6, // décimales d'affichage du volume\n CANDLE_MINUTES: 15, // bougies 15 min\n\n INITIAL_CAPITAL_EUR: 10, // capital de départ déclaré\n\n // Stratégie : mean-reversion RSI, très peu de trades\n RSI_PERIOD: 14,\n RSI_BUY_BELOW: 30, // achat uniquement en zone de survente\n TAKE_PROFIT_PCT: 0.02, // +2.0% (ordre limite maker posé dès l'entrée)\n STOP_LOSS_PCT: 0.025, // -2.5% (sortie market)\n\n // Garde-fous\n KILL_SWITCH_DRAWDOWN: 0.20, // -20% du capital initial => tout liquider + arrêt définitif\n ENTRY_ORDER_TTL_MIN: 45, // ordre d'achat non exécuté après 45 min => annulé\n CASH_BUFFER_PCT: 0.005, // marge pour les frais lors du sizing\n\n // Frais Kraken (palier < 10k€/mois)\n MAKER_FEE: 0.0025,\n TAKER_FEE: 0.004,\n};\n\n// Mode réel uniquement si LIVE_TRADING=true. Sinon : paper trading (simulation\n// avec les prix réels, aucun ordre envoyé à Kraken).\nexport function isLive(): boolean {\n return Deno.env.get(\"LIVE_TRADING\") === \"true\";\n}\n","label",[137],"198c7ec7-4b7b-4057-9a09-f192e7681129","README.md","3d85097c-7b0d-11f1-a442-1607ee4eb77e",15,["D",1783544063654],"# sol-trader — Bot SOL/EUR sur Kraken\n\nBot de trading conservateur sur la paire SOL/EUR de Kraken, avec reporting Telegram horaire.\n**Priorité n°1 : préservation du capital.**\n\n## Stratégie\n\n- **Mean-reversion RSI** sur bougies 15 min : achat uniquement quand RSI(14) < 30 (survente).\n- **Entrées en ordre limite post-only** → frais maker (0,25 %) au lieu de taker (0,40 %).\n- **Take-profit +2 %** posé immédiatement en ordre limite résident (maker aussi).\n- **Stop-loss -2,5 %** (sortie market).\n- **Une seule position à la fois**, jamais de levier, jamais de short.\n- **Kill-switch : à -20 % du capital initial, tout est liquidé en EUR et le bot s'arrête définitivement.**\n\n## Fichiers\n\n- `crons/trader.ts` — cycle de trading (toutes les 15 min)\n- `crons/reporter.ts` — rapport Telegram (toutes les heures)\n- `lib/engine.ts` — moteur (signaux, ordres, kill-switch)\n- `lib/kraken.ts` — client API Kraken signé\n- `setup/check.ts` — vérifie la config (à lancer après avoir mis les clés)\n- `setup/reset.ts` — réinitialise l'état (lève le kill-switch)\n\n## Configuration (env vars)\n\n| Variable | Rôle |\n|---|---|\n| `KRAKEN_API_KEY` / `KRAKEN_API_SECRET` | Clé API Kraken — permissions **Query Funds + Create & Modify Orders uniquement. JAMAIS Withdraw.** |\n| `TELEGRAM_TOKEN` | Token du bot créé via @BotFather |\n| `TELEGRAM_CHAT_ID` | Ton chat ID (envoie /start au bot puis lance `setup/check.ts`) |\n| `LIVE_TRADING` | `true` = ordres réels. Absent/autre = **paper trading** (simulation, défaut) |\n\n## Démarrage\n\n1. Renseigner les env vars ci-dessus.\n2. Lancer `setup/check.ts` → tout doit être ✅.\n3. Laisser tourner en paper quelques jours pour valider.\n4. Passer `LIVE_TRADING=true`, puis lancer `setup/reset.ts` pour un état propre.\n\n## Avertissement\n\nAucune stratégie n'élimine le risque. Le capital peut baisser, y compris jusqu'au\nkill-switch (-20 %). Ne jamais déposer plus que ce qu'on accepte de perdre.\n",[149],"4ccd62ee-0b28-4867-86fa-d2b0ff15a7f3","tests","0384723a-a63e-46c0-8aa5-125975c5b0a8",16,["D",1783544253770],"directory",[156],"abe96940-4160-48e0-b2ba-81119a7404aa","setup","67aba91e-b7a2-4f5f-8392-de13ade9637a",10,["D",1783543473813],[163],"77ee57fe-496b-410f-b837-7ef72b832315","lib","9ba94c81-ca7a-4c04-b9af-f3824df06960",3,["D",1783543271782],[169],"7a62f18a-baad-457b-87a9-fe0a7f8bb958","dashboard","0c0953d3-0a92-465a-a4a7-b2b49e4fbb61",41,["D",1783546834930],[175],"94378d7f-2aed-4b51-8e58-2dd6014867c1","crons","e6925dad-2c65-4a6b-a1f3-bc5939f3e670",8,["D",1783543425494],[181],"pulls","branches","forks","envVars",{"_193":195,"_196":61},"connections",{"_193":61,"_194":61},"count","unfilledCount",5,"emptyCount",{"_41":180,"_31":181,"_29":182,"_139":-5,"_39":40,"_38":183,"_141":57,"_36":336,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_218":337,"_26":338},{"_41":327,"_31":328,"_29":329,"_139":182,"_39":40,"_38":330,"_141":24,"_36":331,"_13":332,"_33":323,"_34":333,"_23":24,"_146":-5,"_218":334,"_26":335},{"_41":319,"_31":320,"_29":321,"_139":182,"_39":40,"_38":183,"_141":57,"_36":322,"_13":61,"_33":323,"_34":324,"_23":24,"_146":-5,"_218":325,"_26":326},{"_41":174,"_31":175,"_29":176,"_139":-5,"_39":40,"_38":177,"_141":57,"_36":316,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_218":317,"_26":318},{"_41":312,"_31":32,"_29":30,"_139":176,"_39":40,"_38":14,"_141":57,"_36":313,"_13":61,"_33":20,"_34":35,"_23":24,"_146":-5,"_218":314,"_26":315},{"_41":305,"_31":306,"_29":55,"_139":176,"_39":40,"_38":177,"_141":24,"_36":307,"_13":61,"_33":308,"_34":309,"_23":24,"_146":-5,"_218":310,"_26":311},{"_41":168,"_31":169,"_29":170,"_139":-5,"_39":40,"_38":171,"_141":57,"_36":302,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_218":303,"_26":304},{"_41":294,"_31":295,"_29":296,"_139":170,"_39":40,"_38":297,"_141":24,"_36":298,"_13":143,"_33":144,"_34":299,"_23":24,"_146":-5,"_218":300,"_26":301},{"_41":286,"_31":287,"_29":288,"_139":170,"_39":40,"_38":289,"_141":24,"_36":290,"_13":195,"_33":144,"_34":291,"_23":24,"_146":-5,"_218":292,"_26":293},{"_41":279,"_31":280,"_29":281,"_139":170,"_39":40,"_38":257,"_141":24,"_36":282,"_13":61,"_33":144,"_34":283,"_23":24,"_146":-5,"_218":284,"_26":285},{"_41":271,"_31":272,"_29":273,"_139":170,"_39":40,"_38":274,"_141":24,"_36":275,"_13":143,"_33":144,"_34":276,"_23":24,"_146":-5,"_218":277,"_26":278},{"_41":264,"_31":265,"_29":266,"_139":170,"_39":40,"_38":195,"_141":57,"_36":267,"_13":61,"_33":144,"_34":268,"_23":24,"_146":-5,"_218":269,"_26":270},{"_41":162,"_31":163,"_29":164,"_139":-5,"_39":40,"_38":165,"_141":57,"_36":261,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_218":262,"_26":263},{"_41":252,"_31":253,"_29":254,"_139":164,"_39":40,"_38":255,"_141":24,"_36":256,"_13":257,"_33":144,"_34":258,"_23":24,"_146":-5,"_218":259,"_26":260},{"_41":244,"_31":245,"_29":246,"_139":164,"_39":40,"_38":247,"_141":24,"_36":248,"_13":61,"_33":144,"_34":249,"_23":24,"_146":-5,"_218":250,"_26":251},{"_41":236,"_31":237,"_29":238,"_139":164,"_39":40,"_38":239,"_141":57,"_36":240,"_13":143,"_33":144,"_34":241,"_23":24,"_146":-5,"_218":242,"_26":243},{"_41":155,"_31":156,"_29":157,"_139":-5,"_39":40,"_38":158,"_141":57,"_36":233,"_13":61,"_33":160,"_34":-5,"_23":24,"_146":-5,"_218":234,"_26":235},{"_41":224,"_31":225,"_29":226,"_139":157,"_39":40,"_38":227,"_141":24,"_36":228,"_13":229,"_33":144,"_34":230,"_23":24,"_146":-5,"_218":231,"_26":232},{"_41":148,"_31":149,"_29":150,"_139":-5,"_39":40,"_38":151,"_141":24,"_36":221,"_13":143,"_33":20,"_34":153,"_23":24,"_146":-5,"_218":222,"_26":223},{"_41":136,"_31":137,"_29":138,"_139":-5,"_39":40,"_38":140,"_141":24,"_36":217,"_13":143,"_33":144,"_34":145,"_23":24,"_146":-5,"_218":219,"_26":220},["D",1783545485322],"children",[],[137],["D",1783544063654],[],[149],"18c1dcb7-9105-4833-899d-bdd5e533a6a9","backtest.ts","a4629478-7b0f-11f1-8991-1607ee4eb77e",32,["D",1783545596601],6,"// Backtest de la stratégie sur les dernières 72h (bougies 15 min Kraken).\n// Reproduit les règles du bot : entrée limite post-only si RSI<30, TP +2% (maker),\n// SL -2.5% (taker), TTL d'entrée 45 min, une position à la fois, kill-switch -20%.\n// Hypothèse pessimiste : si TP et SL sont touchés dans la même bougie, le SL gagne.\nimport { CONFIG } from \"../config.ts\";\nimport { getOHLC, getPairInfo } from \"../lib/kraken.ts\";\nimport { rsi } from \"../lib/indicators.ts\";\n\nconst HOURS = 72;\n\nfunction simulate(startCapital: number, candles: { time: number; open: number; high: number; low: number; close: number }[], startIdx: number) {\n let cash = startCapital;\n let position: { entry: number; volume: number; tp: number; sl: number } | null = null;\n let pending: { price: number; volume: number; idx: number } | null = null;\n const trades: string[] = [];\n let fees = 0;\n let halted = false;\n\n const closes = candles.map((c) => c.close);\n const ttlCandles = Math.ceil(CONFIG.ENTRY_ORDER_TTL_MIN / CONFIG.CANDLE_MINUTES);\n\n for (let i = startIdx; i < candles.length; i++) {\n const c = candles[i];\n const when = new Date(c.time * 1000).toISOString().slice(5, 16).replace(\"T\", \" \");\n\n if (halted) break;\n\n // 1. Exécution de l'ordre d'achat en attente (posé à la clôture d'une bougie précédente)\n if (pending) {\n if (c.low <= pending.price) {\n const cost = pending.price * pending.volume;\n const fee = cost * CONFIG.MAKER_FEE;\n cash -= cost + fee;\n fees += fee;\n position = {\n entry: pending.price,\n volume: pending.volume,\n tp: pending.price * (1 + CONFIG.TAKE_PROFIT_PCT),\n sl: pending.price * (1 - CONFIG.STOP_LOSS_PCT),\n };\n trades.push(`${when} 🟢 achat ${pending.volume.toFixed(CONFIG.VOL_DECIMALS)} ${CONFIG.BASE_LABEL} @ ${pending.price.toFixed(2)} €`);\n pending = null;\n } else if (i - pending.idx >= ttlCandles) {\n trades.push(`${when} ⌛ ordre d'achat expiré (@ ${pending.price.toFixed(2)} €)`);\n pending = null;\n }\n }\n\n // 2. Sorties (pessimiste : SL avant TP si les deux sont touchés)\n if (position) {\n if (c.low <= position.sl) {\n const proceeds = position.sl * position.volume;\n const fee = proceeds * CONFIG.TAKER_FEE;\n cash += proceeds - fee;\n fees += fee;\n trades.push(`${when} 🛑 stop-loss @ ${position.sl.toFixed(2)} € (-${(CONFIG.STOP_LOSS_PCT * 100).toFixed(1)}%)`);\n position = null;\n } else if (c.high >= position.tp) {\n const proceeds = position.tp * position.volume;\n const fee = proceeds * CONFIG.MAKER_FEE;\n cash += proceeds - fee;\n fees += fee;\n trades.push(`${when} 🎯 take-profit @ ${position.tp.toFixed(2)} € (+${(CONFIG.TAKE_PROFIT_PCT * 100).toFixed(1)}%)`);\n position = null;\n }\n }\n\n // Kill-switch\n const equity = cash + (position ? position.volume * c.close : 0);\n if (equity < startCapital * (1 - CONFIG.KILL_SWITCH_DRAWDOWN)) {\n if (position) {\n const proceeds = position.volume * c.close;\n const fee = proceeds * CONFIG.TAKER_FEE;\n cash += proceeds - fee;\n fees += fee;\n position = null;\n }\n trades.push(`${when} 🔴 KILL SWITCH @ équité ${equity.toFixed(2)} €`);\n halted = true;\n break;\n }\n\n // 3. Signal d'entrée à la clôture de la bougie i\n if (!position && !pending) {\n const r = rsi(closes.slice(0, i + 1), CONFIG.RSI_PERIOD);\n if (r !== null && r < CONFIG.RSI_BUY_BELOW) {\n const price = c.close;\n const volume = (cash * (1 - CONFIG.CASH_BUFFER_PCT)) / price;\n if (volume >= PAIR_INFO.ordermin && volume * price >= PAIR_INFO.costmin) {\n pending = { price, volume, idx: i };\n trades.push(`${when} 📥 ordre limite posé @ ${price.toFixed(2)} € (RSI ${r.toFixed(1)})`);\n }\n }\n }\n }\n\n // Valorisation finale\n const lastClose = candles[candles.length - 1].close;\n const finalEquity = cash + (position ? position.volume * lastClose : 0);\n return { finalEquity, trades, fees, openPosition: position, halted };\n}\n\n// ---- Exécution ----\nconst PAIR_INFO = await getPairInfo(CONFIG.PAIR);\nconst candles = await getOHLC(CONFIG.PAIR, CONFIG.CANDLE_MINUTES);\nconst cutoff = Date.now() / 1000 - HOURS * 3600;\nconst startIdx = candles.findIndex((c) => c.time >= cutoff);\nif (startIdx < CONFIG.RSI_PERIOD + 1) {\n console.log(\"⚠️ Pas assez d'historique avant la fenêtre pour un RSI fiable.\");\n}\n\nconst first = candles[startIdx];\nconst last = candles[candles.length - 1];\nconst buyHold = ((last.close - first.close) / first.close) * 100;\n\nconsole.log(`Backtest ${HOURS}h — ${candles.length - startIdx} bougies 15 min`);\nconsole.log(`${CONFIG.BASE_LABEL}/EUR : ${first.close.toFixed(2)} € → ${last.close.toFixed(2)} € (buy & hold : ${buyHold >= 0 ? \"+\" : \"\"}${buyHold.toFixed(2)}%)`);\nconsole.log(\"\");\n\nfor (const capital of [10, 20]) {\n const r = simulate(capital, candles, startIdx);\n const pnl = r.finalEquity - capital;\n const pnlPct = (pnl / capital) * 100;\n console.log(`=== Capital ${capital} € ===`);\n console.log(`Équité finale : ${r.finalEquity.toFixed(2)} € (${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(2)} €, ${pnlPct >= 0 ? \"+\" : \"\"}${pnlPct.toFixed(2)}%)`);\n console.log(`Frais payés : ${r.fees.toFixed(3)} € · Position ouverte en fin : ${r.openPosition ? \"oui @ \" + r.openPosition.entry.toFixed(2) + \" €\" : \"non\"}${r.halted ? \" · 🔴 KILL SWITCH\" : \"\"}`);\n for (const t of r.trades) console.log(\" \" + t);\n console.log(\"\");\n}\n",[],[156,225],["D",1783544253770],[214],[156],"10e0207f-7f7d-492e-9a0f-b96bc779d376","reset.ts","d50a2bec-7b0d-11f1-a8a2-1607ee4eb77e",14,["D",1783543985911],"// Réinitialise l'état du bot (positions simulées, capital initial, kill-switch).\n// N'annule PAS les ordres réels sur Kraken — à faire manuellement si besoin.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initDb } from \"../lib/db.ts\";\n\nawait initDb();\nawait sqlite.execute(\"DELETE FROM state\");\nconsole.log(\"État réinitialisé : kill-switch levé, positions/paper effacés.\");\nconsole.log(\"Les tables trades/snapshots/events sont conservées (historique).\");\n",[],[163,237],"6c549a61-0284-4be9-a35b-0b20a4e3b4d4","fix-basis.ts","12dd1fae-7b15-11f1-84b8-1607ee4eb77e",40,["D",1783546586611],"// One-shot : recale le capital initial (live) sur le coût d'achat réel du BTC détenu.\nimport { CONFIG } from \"../config.ts\";\nimport { getBalances, getRecentBuyCost } from \"../lib/kraken.ts\";\nimport { getState, initDb, logEvent, setState } from \"../lib/db.ts\";\n\nawait initDb();\nconst balances = await getBalances();\nconst baseBal = balances[CONFIG.BASE_ASSET] ?? 0;\nconst basis = await getRecentBuyCost(CONFIG.PAIR.replace(\"EUR\", \"\"), baseBal);\nconst current = await getState(\"initial_equity_live\");\nif (basis !== null && basis > 0) {\n await setState(\"initial_equity_live\", String(basis));\n await logEvent(\"info\", `Capital initial recalé: ${current} € → coût d'achat réel ${basis.toFixed(2)} €`);\n console.log(`OK — coût d'achat réel: ${basis.toFixed(2)} € (avant: ${current} €)`);\n} else {\n console.log(`Aucun achat trouvé dans l'historique — capital initial inchangé (${current} €)`);\n}\n",[],[163,245],"912da6f2-cf98-4b36-b384-7e95481a5525","check.ts","d3803136-7b0d-11f1-9c3b-1607ee4eb77e",27,["D",1783545552438],4,"// Script de vérification de la configuration. À exécuter manuellement.\n// Vérifie : accès Kraken public, clés API privées, Telegram (et aide à trouver le chat_id).\nimport { CONFIG, isLive } from \"../config.ts\";\nimport { getBalances, getPairInfo, getTicker } from \"../lib/kraken.ts\";\n\nexport async function check(): Promise {\n const report: string[] = [];\n\n // 1. Kraken public\n try {\n const t = await getTicker(CONFIG.PAIR);\n const info = await getPairInfo(CONFIG.PAIR);\n report.push(`✅ Kraken public OK — ${CONFIG.BASE_LABEL}/EUR: ${t.last} € (bid ${t.bid} / ask ${t.ask})`);\n report.push(` Volume min: ${info.ordermin} ${CONFIG.BASE_LABEL} · coût min: ${info.costmin} € · décimales prix: ${info.priceDecimals}`);\n } catch (e) {\n report.push(`❌ Kraken public KO: ${e}`);\n }\n\n // 2. Clés privées Kraken\n if (Deno.env.get(\"KRAKEN_API_KEY\") && Deno.env.get(\"KRAKEN_API_SECRET\")) {\n try {\n const b = await getBalances();\n const eur = b[CONFIG.QUOTE_ASSET] ?? b[\"EUR\"] ?? 0;\n const sol = b[CONFIG.BASE_ASSET] ?? 0;\n report.push(`✅ Clés Kraken OK — Solde: ${eur.toFixed(2)} € · ${sol} ${CONFIG.BASE_LABEL}`);\n if (eur < 5 && sol === 0) {\n report.push(`⚠️ Solde EUR faible (${eur.toFixed(2)} €) — dépose ~10 € pour démarrer.`);\n }\n } catch (e) {\n report.push(`❌ Clés Kraken KO: ${e}`);\n }\n } else {\n report.push(`⚠️ KRAKEN_API_KEY / KRAKEN_API_SECRET non configurées.`);\n }\n\n // 3. Telegram\n const token = Deno.env.get(\"TELEGRAM_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n if (!token) {\n report.push(`⚠️ TELEGRAM_TOKEN non configuré. Crée un bot via https://t.me/botfather`);\n } else {\n const me = await (await fetch(`https://api.telegram.org/bot${token}/getMe`)).json();\n if (!me.ok) {\n report.push(`❌ TELEGRAM_TOKEN invalide: ${JSON.stringify(me)}`);\n } else {\n report.push(`✅ Bot Telegram OK: @${me.result.username}`);\n if (!chatId) {\n // Aider à trouver le chat_id : envoie d'abord un message au bot dans Telegram !\n const updates = await (\n await fetch(`https://api.telegram.org/bot${token}/getUpdates`)\n ).json();\n const chats = new Map();\n for (const u of updates.result ?? []) {\n const c = u.message?.chat;\n if (c) chats.set(c.id, c.first_name ?? c.title ?? \"?\");\n }\n if (chats.size) {\n report.push(`⚠️ TELEGRAM_CHAT_ID non configuré. Chats détectés :`);\n for (const [id, name] of chats) report.push(` → ${name}: TELEGRAM_CHAT_ID=${id}`);\n } else {\n report.push(\n `⚠️ TELEGRAM_CHAT_ID non configuré et aucun message reçu. Envoie /start à @${me.result.username} puis relance ce script.`,\n );\n }\n } else {\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: \"✅ Test de connexion sol-trader OK\" }),\n });\n report.push(res.ok ? `✅ Message de test Telegram envoyé` : `❌ Envoi Telegram KO: ${await res.text()}`);\n }\n }\n }\n\n report.push(`Mode actuel : ${isLive() ? \"🔴 LIVE (ordres réels)\" : \"🟡 PAPER (simulation)\"}`);\n return report.join(\"\\n\");\n}\n\n// Exécution directe (top-level) pour run_file\nconst result = await check();\nconsole.log(result);\n",[],[163,253],["D",1783543473813],[210,211,212],[163],"0d09a2d3-fd7c-4bed-b513-86593f2f331f","telegram.ts","651eee6c-7b0d-11f1-9312-1607ee4eb77e",["D",1783543288622],"// Envoi de messages Telegram (Bot API).\nexport async function sendTelegram(text: string): Promise {\n const token = Deno.env.get(\"TELEGRAM_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n if (!token || !chatId) {\n console.warn(\"Telegram non configuré (TELEGRAM_TOKEN / TELEGRAM_CHAT_ID)\");\n return false;\n }\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({\n chat_id: chatId,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n if (!res.ok) {\n console.error(\"Erreur Telegram:\", await res.text());\n return false;\n }\n return true;\n}\n",[],[169,265],"bbc4d94e-2bdc-411a-97e5-e32d31819e6a","kraken.ts","5b135c5a-7b0d-11f1-8e61-1607ee4eb77e",33,["D",1783546073324],"// Client Kraken REST minimal (public + privé signé HMAC-SHA512).\nimport { createHash, createHmac } from \"node:crypto\";\nimport { Buffer } from \"node:buffer\";\n\nconst BASE = \"https://api.kraken.com\";\n\nexport async function krakenPublic(\n method: string,\n params: Record = {},\n): Promise {\n const qs = new URLSearchParams(params).toString();\n const res = await fetch(`${BASE}/0/public/${method}${qs ? \"?\" + qs : \"\"}`);\n const json = await res.json();\n if (json.error?.length) {\n throw new Error(`Kraken public ${method}: ${json.error.join(\", \")}`);\n }\n return json.result;\n}\n\nexport async function krakenPrivate(\n method: string,\n params: Record = {},\n): Promise {\n const key = Deno.env.get(\"KRAKEN_API_KEY\");\n const secret = Deno.env.get(\"KRAKEN_API_SECRET\");\n if (!key || !secret) {\n throw new Error(\"KRAKEN_API_KEY / KRAKEN_API_SECRET non configurés\");\n }\n const path = `/0/private/${method}`;\n const nonce = Date.now().toString();\n const postData = new URLSearchParams({ nonce, ...params }).toString();\n const sha = createHash(\"sha256\").update(nonce + postData).digest();\n const sign = createHmac(\"sha512\", Buffer.from(secret, \"base64\"))\n .update(path)\n .update(sha)\n .digest(\"base64\");\n const res = await fetch(BASE + path, {\n method: \"POST\",\n headers: {\n \"API-Key\": key,\n \"API-Sign\": sign,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: postData,\n });\n const json = await res.json();\n if (json.error?.length) {\n throw new Error(`Kraken ${method}: ${json.error.join(\", \")}`);\n }\n return json.result;\n}\n\n// ---- Helpers typés ----\n\nexport interface Ticker {\n bid: number;\n ask: number;\n last: number;\n}\n\nexport async function getTicker(pair: string): Promise {\n const result = await krakenPublic(\"Ticker\", { pair });\n const data = result[Object.keys(result)[0]];\n return {\n bid: parseFloat(data.b[0]),\n ask: parseFloat(data.a[0]),\n last: parseFloat(data.c[0]),\n };\n}\n\nexport interface Candle {\n time: number; // epoch secondes (début de bougie)\n open: number;\n high: number;\n low: number;\n close: number;\n}\n\nexport async function getOHLC(pair: string, intervalMin: number): Promise {\n const result = await krakenPublic(\"OHLC\", {\n pair,\n interval: String(intervalMin),\n });\n const key = Object.keys(result).find((k) => k !== \"last\")!;\n return (result[key] as any[]).map((row) => ({\n time: Number(row[0]),\n open: parseFloat(row[1]),\n high: parseFloat(row[2]),\n low: parseFloat(row[3]),\n close: parseFloat(row[4]),\n }));\n}\n\nexport interface PairInfo {\n ordermin: number; // volume minimum (en SOL)\n costmin: number; // coût minimum (en EUR)\n priceDecimals: number;\n lotDecimals: number;\n}\n\nexport async function getPairInfo(pair: string): Promise {\n const result = await krakenPublic(\"AssetPairs\", { pair });\n const info = result[Object.keys(result)[0]];\n return {\n ordermin: parseFloat(info.ordermin),\n costmin: parseFloat(info.costmin ?? \"0\"),\n priceDecimals: info.pair_decimals,\n lotDecimals: info.lot_decimals,\n };\n}\n\nexport async function getBalances(): Promise> {\n const result = await krakenPrivate(\"Balance\");\n const out: Record = {};\n for (const [asset, amount] of Object.entries(result)) {\n out[asset] = parseFloat(amount as string);\n }\n return out;\n}\n\n// Statut d'un ordre : \"open\" | \"closed\" | \"canceled\" | \"expired\" | ...\nexport async function queryOrder(txid: string): Promise<{\n status: string;\n avgPrice: number;\n volExec: number;\n feeEur: number;\n}> {\n const result = await krakenPrivate(\"QueryOrders\", { txid });\n const o = result[txid];\n if (!o) throw new Error(`Ordre introuvable: ${txid}`);\n return {\n status: o.status,\n avgPrice: parseFloat(o.price ?? \"0\"),\n volExec: parseFloat(o.vol_exec ?? \"0\"),\n feeEur: parseFloat(o.fee ?? \"0\"),\n };\n}\n\n// Coût d'acquisition réel (EUR, frais inclus) des derniers achats couvrant `volume`.\n// Utilisé pour retrouver le prix de revient d'un solde acheté manuellement.\nexport async function getRecentBuyCost(\n pairSubstr: string,\n volume: number,\n): Promise {\n const result = await krakenPrivate(\"TradesHistory\");\n const trades = Object.values(result.trades ?? {}) as any[];\n const buys = trades\n .filter((t) => t.type === \"buy\" && String(t.pair).includes(pairSubstr))\n .sort((a, b) => Number(b.time) - Number(a.time));\n let vol = 0;\n let cost = 0;\n for (const t of buys) {\n if (vol >= volume * 0.98) break;\n vol += parseFloat(t.vol);\n cost += parseFloat(t.cost) + parseFloat(t.fee);\n }\n return vol > 0 ? cost : null;\n}\n\nexport async function cancelOrder(txid: string): Promise {\n await krakenPrivate(\"CancelOrder\", { txid });\n}\n\n// Ordre limite post-only (garantit les frais maker ; rejeté s'il croiserait le marché)\nexport async function addLimitPostOnly(\n pair: string,\n side: \"buy\" | \"sell\",\n volume: string,\n price: string,\n): Promise {\n const result = await krakenPrivate(\"AddOrder\", {\n pair,\n type: side,\n ordertype: \"limit\",\n volume,\n price,\n oflags: \"post\",\n });\n return result.txid[0];\n}\n\nexport async function addMarketOrder(\n pair: string,\n side: \"buy\" | \"sell\",\n volume: string,\n): Promise {\n const result = await krakenPrivate(\"AddOrder\", {\n pair,\n type: side,\n ordertype: \"market\",\n volume,\n });\n return result.txid[0];\n}\n",[],[169,272],"70518d86-d71b-4b08-a08a-f147792724fc","indicators.ts","635404be-7b0d-11f1-bd58-1607ee4eb77e",["D",1783543285630],"// Indicateurs techniques — RSI avec lissage de Wilder.\nexport function rsi(closes: number[], period: number): number | null {\n if (closes.length < period + 1) return null;\n let gain = 0;\n let loss = 0;\n for (let i = 1; i <= period; i++) {\n const diff = closes[i] - closes[i - 1];\n if (diff >= 0) gain += diff;\n else loss -= diff;\n }\n let avgGain = gain / period;\n let avgLoss = loss / period;\n for (let i = period + 1; i < closes.length; i++) {\n const diff = closes[i] - closes[i - 1];\n avgGain = (avgGain * (period - 1) + Math.max(diff, 0)) / period;\n avgLoss = (avgLoss * (period - 1) + Math.max(-diff, 0)) / period;\n }\n if (avgLoss === 0) return 100;\n const rs = avgGain / avgLoss;\n return 100 - 100 / (1 + rs);\n}\n\nexport function sma(values: number[], period: number): number | null {\n if (values.length < period) return null;\n const slice = values.slice(-period);\n return slice.reduce((a, b) => a + b, 0) / period;\n}\n",[],[169,280],"0a3ff66f-de70-4535-9f7f-ba7de7f663d3","engine.ts","a9f3cda0-7b0d-11f1-9c27-1607ee4eb77e",39,["D",1783546410573],"// Moteur de trading. Un seul principe : préserver le capital d'abord.\n// - Mode \"paper\" (défaut) : simulation avec prix réels, aucun ordre envoyé.\n// - Mode \"live\" (LIVE_TRADING=true) : ordres réels sur Kraken.\nimport { CONFIG, isLive } from \"../config.ts\";\nimport {\n addLimitPostOnly,\n addMarketOrder,\n cancelOrder,\n getBalances,\n getOHLC,\n getPairInfo,\n getRecentBuyCost,\n getTicker,\n queryOrder,\n type Candle,\n type Ticker,\n} from \"./kraken.ts\";\nimport { rsi } from \"./indicators.ts\";\nimport {\n delState,\n getState,\n initDb,\n logEvent,\n logSnapshot,\n logTrade,\n setState,\n} from \"./db.ts\";\nimport { sendTelegram } from \"./telegram.ts\";\n\ninterface Position {\n entry: number;\n volume: number;\n tpPrice: number;\n tpOrderId?: string; // live uniquement\n openedAt: number;\n}\n\ninterface PendingBuy {\n txid?: string; // live uniquement\n price: number;\n volume: number;\n placedAt: number;\n}\n\nfunction floorTo(x: number, decimals: number): number {\n const f = 10 ** decimals;\n return Math.floor(x * f) / f;\n}\nfunction ceilTo(x: number, decimals: number): number {\n const f = 10 ** decimals;\n return Math.ceil(x * f) / f;\n}\nconst fmt = (x: number, d = 2) => x.toFixed(d);\n\nasync function getJson(key: string): Promise {\n const raw = await getState(key);\n return raw ? (JSON.parse(raw) as T) : null;\n}\n\nexport interface Portfolio {\n mode: \"live\" | \"paper\";\n eur: number;\n sol: number;\n equity: number;\n position: Position | null;\n pending: PendingBuy | null;\n initialEquity: number | null;\n halted: boolean;\n ticker: Ticker;\n}\n\n// Lit l'état complet du portefeuille (sans rien modifier).\nexport async function readPortfolio(): Promise {\n const mode = isLive() ? \"live\" : \"paper\";\n const ticker = await getTicker(CONFIG.PAIR);\n const position = await getJson(`position_${mode}`);\n const pending = await getJson(`pending_${mode}`);\n const initRaw = await getState(`initial_equity_${mode}`);\n const halted = (await getState(\"halted\")) === \"1\";\n\n let eur: number, sol: number;\n if (mode === \"live\") {\n const balances = await getBalances();\n eur = balances[CONFIG.QUOTE_ASSET] ?? balances[\"EUR\"] ?? 0;\n sol = balances[CONFIG.BASE_ASSET] ?? 0;\n } else {\n const cashRaw = await getState(\"paper_eur\");\n eur = cashRaw !== null ? Number(cashRaw) : CONFIG.INITIAL_CAPITAL_EUR;\n sol = position ? position.volume : 0;\n }\n const equity = eur + sol * ticker.last;\n return {\n mode,\n eur,\n sol,\n equity,\n position,\n pending,\n initialEquity: initRaw !== null ? Number(initRaw) : null,\n halted,\n ticker,\n };\n}\n\n// ---- Cycle de trading (appelé toutes les 15 min) ----\nexport async function runTraderCycle(): Promise {\n await initDb();\n const mode = isLive() ? \"live\" : \"paper\";\n\n if ((await getState(\"halted\")) === \"1\") {\n await logEvent(\"info\", \"Bot arrêté (kill-switch) — aucun trade.\");\n return;\n }\n\n const candles = await getOHLC(CONFIG.PAIR, CONFIG.CANDLE_MINUTES);\n // La dernière bougie est en cours : RSI calculé sur les bougies clôturées.\n const closes = candles.slice(0, -1).map((c) => c.close);\n const r = rsi(closes, CONFIG.RSI_PERIOD);\n const ticker = await getTicker(CONFIG.PAIR);\n const pairInfo = await getPairInfo(CONFIG.PAIR);\n\n // 1. Réconciliation des ordres en attente\n await reconcile(mode, candles, ticker, pairInfo.priceDecimals);\n\n // 1bis. Adoption d'un solde BTC préexistant (acheté manuellement hors bot) :\n // il devient une position gérée (TP/SL), entrée = prix actuel, capital initial\n // = coût d'achat réel retrouvé dans l'historique Kraken si possible.\n if (mode === \"live\") {\n const posNow = await getJson(`position_${mode}`);\n const pendNow = await getJson(`pending_${mode}`);\n if (!posNow && !pendNow) {\n const balances = await getBalances();\n const baseBal = balances[CONFIG.BASE_ASSET] ?? 0;\n if (baseBal >= pairInfo.ordermin) {\n const entry = ticker.last;\n const tpPrice = ceilTo(entry * (1 + CONFIG.TAKE_PROFIT_PCT), pairInfo.priceDecimals);\n const newPos: Position = { entry, volume: baseBal, tpPrice, openedAt: Date.now() };\n try {\n newPos.tpOrderId = await addLimitPostOnly(\n CONFIG.PAIR,\n \"sell\",\n String(baseBal),\n String(tpPrice),\n );\n } catch (e) {\n await logEvent(\"warn\", `TP post-only rejeté à l'adoption: ${e}`);\n }\n await setState(`position_${mode}`, JSON.stringify(newPos));\n if ((await getState(`initial_equity_${mode}`)) === null) {\n try {\n const basis = await getRecentBuyCost(CONFIG.PAIR.replace(\"EUR\", \"\"), baseBal);\n if (basis !== null) {\n await setState(`initial_equity_${mode}`, String(basis));\n await logEvent(\"info\", `Coût d'achat retrouvé: ${fmt(basis)} €`);\n }\n } catch (e) {\n // Permission API manquante : le capital initial sera fixé à l'équité actuelle\n await logEvent(\"warn\", `Historique d'achats inaccessible (${e}) — référence = équité actuelle`);\n }\n }\n await logTrade(mode, \"buy\", entry, baseBal, 0, \"adoption solde existant\");\n await sendTelegram(\n `🤝 Position adoptée (${mode})\\n` +\n `${baseBal} ${CONFIG.BASE_LABEL} détenus (≈ ${fmt(baseBal * entry)} €) sont maintenant gérés par le bot.\\n` +\n `🎯 TP @ ${tpPrice} € · 🛑 SL @ ${fmt(entry * (1 - CONFIG.STOP_LOSS_PCT))} €`,\n );\n }\n }\n }\n\n // 2. État du portefeuille + snapshot\n const p = await readPortfolio();\n await logSnapshot(mode, p.equity, ticker.last, r);\n\n // Capital initial : fixé au premier cycle\n let initial = p.initialEquity;\n if (initial === null && p.equity > 0) {\n initial = p.equity;\n await setState(`initial_equity_${mode}`, String(initial));\n await logEvent(\"info\", `Capital initial ${mode}: ${fmt(initial)} €`);\n await sendTelegram(\n `🚀 Bot démarré (${mode})\\nCapital initial : ${fmt(initial)} €\\n` +\n `Kill-switch : ${fmt(initial * (1 - CONFIG.KILL_SWITCH_DRAWDOWN))} €`,\n );\n }\n\n // 3. KILL SWITCH — priorité absolue\n if (initial !== null && p.equity < initial * (1 - CONFIG.KILL_SWITCH_DRAWDOWN)) {\n await triggerKillSwitch(mode, p, ticker);\n return;\n }\n\n // 4. Gestion de la position ouverte (stop-loss)\n const position = await getJson(`position_${mode}`);\n if (position) {\n const pnlPct = (ticker.bid - position.entry) / position.entry;\n if (pnlPct <= -CONFIG.STOP_LOSS_PCT) {\n await exitPosition(mode, position, ticker, \"stop-loss\");\n await sendTelegram(\n `🛑 Stop-loss (${mode})\\nVente ${fmt(position.volume, CONFIG.VOL_DECIMALS)} ${CONFIG.BASE_LABEL} @ ~${fmt(ticker.bid)} € (${fmt(pnlPct * 100)}%)`,\n );\n }\n return; // en position : on ne cherche pas d'entrée\n }\n\n // 5. Entrée : RSI en survente, pas d'ordre déjà en attente\n const pending = await getJson(`pending_${mode}`);\n if (pending || r === null) return;\n\n if (r < CONFIG.RSI_BUY_BELOW) {\n const cash = p.eur;\n const spend = cash * (1 - CONFIG.CASH_BUFFER_PCT);\n const price = floorTo(ticker.bid, pairInfo.priceDecimals);\n const volume = floorTo(spend / price, pairInfo.lotDecimals);\n if (volume < pairInfo.ordermin || volume * price < pairInfo.costmin) {\n await logEvent(\n \"warn\",\n `Signal d'achat (RSI ${fmt(r, 1)}) mais capital insuffisant: ${fmt(cash)} €`,\n );\n return;\n }\n const newPending: PendingBuy = { price, volume, placedAt: Date.now() };\n if (mode === \"live\") {\n try {\n newPending.txid = await addLimitPostOnly(\n CONFIG.PAIR,\n \"buy\",\n String(volume),\n String(price),\n );\n } catch (e) {\n await logEvent(\"error\", `Échec ordre d'achat: ${e}`);\n return;\n }\n }\n await setState(`pending_${mode}`, JSON.stringify(newPending));\n await logEvent(\n \"info\",\n `Ordre d'achat limite posé: ${volume} ${CONFIG.BASE_LABEL} @ ${price} € (RSI ${fmt(r, 1)})`,\n );\n await sendTelegram(\n `📥 Ordre d'achat posé (${mode})\\n${volume} ${CONFIG.BASE_LABEL} @ ${price} € — RSI ${fmt(r, 1)}\\n(limite post-only, frais maker)`,\n );\n }\n}\n\n// Réconcilie ordres en attente / TP avec la réalité (Kraken ou simulation).\nasync function reconcile(\n mode: \"live\" | \"paper\",\n candles: Candle[],\n ticker: Ticker,\n priceDecimals: number,\n): Promise {\n const pending = await getJson(`pending_${mode}`);\n const position = await getJson(`position_${mode}`);\n\n // --- Ordre d'achat en attente ---\n if (pending) {\n const ageMin = (Date.now() - pending.placedAt) / 60000;\n let filled = false;\n let fillPrice = pending.price;\n let fillVolume = pending.volume;\n let fee = 0;\n\n if (mode === \"live\" && pending.txid) {\n const o = await queryOrder(pending.txid);\n if (o.status === \"closed\") {\n filled = true;\n fillPrice = o.avgPrice || pending.price;\n fillVolume = o.volExec || pending.volume;\n fee = o.feeEur;\n } else if (o.status === \"canceled\" || o.status === \"expired\") {\n await delState(`pending_${mode}`);\n await logEvent(\"info\", `Ordre d'achat ${o.status}: ${pending.txid}`);\n } else if (ageMin > CONFIG.ENTRY_ORDER_TTL_MIN) {\n await cancelOrder(pending.txid);\n await delState(`pending_${mode}`);\n await logEvent(\"info\", `Ordre d'achat annulé après ${fmt(ageMin, 0)} min sans exécution`);\n }\n } else if (mode === \"paper\") {\n // Simulé : l'ordre limite est exécuté si une bougie est passée sous le prix.\n const since = pending.placedAt / 1000 - CONFIG.CANDLE_MINUTES * 60;\n const touched = candles.some((c) => c.time >= since && c.low <= pending.price);\n if (touched) {\n filled = true;\n fee = pending.price * pending.volume * CONFIG.MAKER_FEE;\n const cash = Number((await getState(\"paper_eur\")) ?? CONFIG.INITIAL_CAPITAL_EUR);\n await setState(\"paper_eur\", String(cash - pending.price * pending.volume - fee));\n } else if (ageMin > CONFIG.ENTRY_ORDER_TTL_MIN) {\n await delState(`pending_${mode}`);\n await logEvent(\"info\", \"Ordre d'achat simulé expiré sans exécution\");\n }\n }\n\n if (filled) {\n await delState(`pending_${mode}`);\n const tpPrice = ceilTo(fillPrice * (1 + CONFIG.TAKE_PROFIT_PCT), priceDecimals);\n const newPos: Position = {\n entry: fillPrice,\n volume: fillVolume,\n tpPrice,\n openedAt: Date.now(),\n };\n if (mode === \"live\") {\n try {\n newPos.tpOrderId = await addLimitPostOnly(\n CONFIG.PAIR,\n \"sell\",\n String(fillVolume),\n String(tpPrice),\n );\n } catch (e) {\n // Post-only rejeté (prix déjà au-dessus) : le TP sera géré au prochain cycle par le stop/kill logic\n await logEvent(\"warn\", `TP post-only rejeté, position sans TP résident: ${e}`);\n }\n }\n await setState(`position_${mode}`, JSON.stringify(newPos));\n await logTrade(mode, \"buy\", fillPrice, fillVolume, fee, \"entrée RSI\");\n await logEvent(\"info\", `Achat exécuté: ${fillVolume} ${CONFIG.BASE_LABEL} @ ${fillPrice} €`);\n await sendTelegram(\n `✅ Achat exécuté (${mode})\\n${fillVolume} ${CONFIG.BASE_LABEL} @ ${fillPrice} €\\n🎯 TP posé @ ${tpPrice} € (+${fmt(CONFIG.TAKE_PROFIT_PCT * 100, 1)}%)`,\n );\n }\n return;\n }\n\n // --- Take-profit résident sur position ouverte ---\n if (position) {\n let tpFilled = false;\n let sellPrice = position.tpPrice;\n let fee = 0;\n\n if (mode === \"live\" && position.tpOrderId) {\n const o = await queryOrder(position.tpOrderId);\n if (o.status === \"closed\") {\n tpFilled = true;\n sellPrice = o.avgPrice || position.tpPrice;\n fee = o.feeEur;\n }\n } else if (mode === \"paper\") {\n const since = position.openedAt / 1000 - CONFIG.CANDLE_MINUTES * 60;\n const touched = candles.some((c) => c.time >= since && c.high >= position.tpPrice);\n if (touched) {\n tpFilled = true;\n fee = position.tpPrice * position.volume * CONFIG.MAKER_FEE;\n const cash = Number((await getState(\"paper_eur\")) ?? 0);\n await setState(\n \"paper_eur\",\n String(cash + position.tpPrice * position.volume - fee),\n );\n }\n }\n\n if (tpFilled) {\n await delState(`position_${mode}`);\n const pnlPct = (sellPrice - position.entry) / position.entry * 100;\n await logTrade(mode, \"sell\", sellPrice, position.volume, fee, \"take-profit\");\n await logEvent(\"info\", `Take-profit: vente @ ${sellPrice} € (+${fmt(pnlPct)}%)`);\n await sendTelegram(\n `🎯 Take-profit atteint (${mode})\\nVente ${fmt(position.volume, CONFIG.VOL_DECIMALS)} ${CONFIG.BASE_LABEL} @ ${sellPrice} € (+${fmt(pnlPct)}%)`,\n );\n }\n }\n}\n\n// Sortie de position au marché (stop-loss ou kill-switch).\nasync function exitPosition(\n mode: \"live\" | \"paper\",\n position: Position,\n ticker: Ticker,\n reason: string,\n): Promise {\n let fee = ticker.bid * position.volume * CONFIG.TAKER_FEE;\n if (mode === \"live\") {\n if (position.tpOrderId) {\n try {\n await cancelOrder(position.tpOrderId);\n } catch (e) {\n await logEvent(\"warn\", `Annulation TP impossible (déjà clos ?): ${e}`);\n }\n }\n await addMarketOrder(CONFIG.PAIR, \"sell\", String(position.volume));\n } else {\n const cash = Number((await getState(\"paper_eur\")) ?? 0);\n await setState(\"paper_eur\", String(cash + ticker.bid * position.volume - fee));\n }\n await delState(`position_${mode}`);\n await logTrade(mode, \"sell\", ticker.bid, position.volume, fee, reason);\n await logEvent(\"warn\", `Sortie market (${reason}) @ ~${ticker.bid} €`);\n}\n\nasync function triggerKillSwitch(\n mode: \"live\" | \"paper\",\n p: Portfolio,\n ticker: Ticker,\n): Promise {\n // Annuler tout ordre en attente, liquider, arrêter définitivement.\n const pending = await getJson(`pending_${mode}`);\n if (pending?.txid && mode === \"live\") {\n try {\n await cancelOrder(pending.txid);\n } catch (_) { /* déjà clos */ }\n }\n await delState(`pending_${mode}`);\n\n const position = await getJson(`position_${mode}`);\n if (position) {\n await exitPosition(mode, position, ticker, \"kill-switch\");\n }\n await setState(\"halted\", \"1\");\n await logEvent(\"error\", `KILL SWITCH: équité ${fmt(p.equity)} € — bot arrêté définitivement.`);\n await sendTelegram(\n `🔴 KILL SWITCH DÉCLENCHÉ (${mode})\\n` +\n `Équité : ${fmt(p.equity)} € (seuil : -${CONFIG.KILL_SWITCH_DRAWDOWN * 100}%)\\n` +\n `Tout est liquidé en EUR. Le bot est arrêté et ne tradera plus.\\n` +\n `Pour le relancer : exécuter setup/reset.ts`,\n );\n}\n\n// Notification d'erreur avec limitation (max 1/heure) pour éviter le spam.\nexport async function notifyError(context: string, error: unknown): Promise {\n await initDb();\n await logEvent(\"error\", `${context}: ${error}`);\n const last = await getState(\"last_error_notify\");\n if (last && Date.now() - Number(last) < 3600 * 1000) return;\n await setState(\"last_error_notify\", String(Date.now()));\n await sendTelegram(`⚠️ Erreur bot (${context})\\n${String(error).slice(0, 500)}`);\n}\n",[],[169,287],"68fb5fc6-9962-41a8-b976-899c666c1513","db.ts","71ff2ac0-7b0d-11f1-8026-1607ee4eb77e",36,["D",1783546109365],"// Persistance SQLite : état clé/valeur, trades, snapshots d'équité, événements.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function initDb(): Promise {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS state (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS trades (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT NOT NULL,\n mode TEXT NOT NULL,\n side TEXT NOT NULL,\n price REAL NOT NULL,\n volume REAL NOT NULL,\n fee_eur REAL NOT NULL,\n reason TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS snapshots (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT NOT NULL,\n mode TEXT NOT NULL,\n equity REAL NOT NULL,\n price REAL NOT NULL,\n rsi REAL\n )`,\n `CREATE TABLE IF NOT EXISTS events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT NOT NULL,\n level TEXT NOT NULL,\n message TEXT NOT NULL\n )`,\n ]);\n}\n\nexport async function getState(key: string): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT value FROM state WHERE key = ?\",\n args: [key],\n });\n return r.rows.length ? String(r.rows[0].value) : null;\n}\n\nexport async function setState(key: string, value: string): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO state (key, value) VALUES (?, ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value\",\n args: [key, value],\n });\n}\n\nexport async function delState(key: string): Promise {\n await sqlite.execute({ sql: \"DELETE FROM state WHERE key = ?\", args: [key] });\n}\n\nexport async function logTrade(\n mode: string,\n side: string,\n price: number,\n volume: number,\n feeEur: number,\n reason: string,\n): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO trades (ts, mode, side, price, volume, fee_eur, reason) VALUES (?, ?, ?, ?, ?, ?, ?)\",\n args: [new Date().toISOString(), mode, side, price, volume, feeEur, reason],\n });\n}\n\nexport async function logSnapshot(\n mode: string,\n equity: number,\n price: number,\n rsiVal: number | null,\n): Promise {\n await sqlite.execute({\n sql: \"INSERT INTO snapshots (ts, mode, equity, price, rsi) VALUES (?, ?, ?, ?, ?)\",\n args: [new Date().toISOString(), mode, equity, price, rsiVal],\n });\n}\n\nexport async function logEvent(level: string, message: string): Promise {\n console.log(`[${level}] ${message}`);\n await sqlite.execute({\n sql: \"INSERT INTO events (ts, level, message) VALUES (?, ?, ?)\",\n args: [new Date().toISOString(), level, message],\n });\n}\n\nexport async function recentTrades(limit: number): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM trades ORDER BY id DESC LIMIT ?\",\n args: [limit],\n });\n return r.rows as any[];\n}\n\nexport async function equityAgo(hours: number, mode: string): Promise {\n const cutoff = new Date(Date.now() - hours * 3600 * 1000).toISOString();\n const r = await sqlite.execute({\n sql: \"SELECT equity FROM snapshots WHERE ts <= ? AND mode = ? ORDER BY id DESC LIMIT 1\",\n args: [cutoff, mode],\n });\n return r.rows.length ? Number(r.rows[0].equity) : null;\n}\n",[],[169,295],["D",1783543271782],[204,205,206,207,208],[169],"aedd00dc-4ad3-412f-808b-e016e5810f65","index.http.ts",["D",1783546834930],"http","// Dashboard web du bot — page live + API JSON.\nimport { Hono } from \"npm:hono\";\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { CONFIG } from \"../config.ts\";\nimport { equityAgo, initDb, recentTrades } from \"../lib/db.ts\";\nimport { readPortfolio } from \"../lib/engine.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => serveFile(\"/dashboard/index.html\", import.meta.url));\napp.get(\"/App.tsx\", (c) => serveFile(\"/dashboard/App.tsx\", import.meta.url));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\napp.get(\"/api/status\", async (c) => {\n await initDb();\n const p = await readPortfolio();\n\n const since = new Date(Date.now() - 48 * 3600 * 1000).toISOString();\n const snaps = await sqlite.execute({\n sql: \"SELECT ts, equity, price FROM snapshots WHERE mode = ? AND ts >= ? ORDER BY id\",\n args: [p.mode, since],\n });\n const trades = await recentTrades(8);\n\n const gain = p.initialEquity !== null ? p.equity - p.initialEquity : null;\n const position = p.position\n ? {\n volume: p.position.volume,\n entry: p.position.entry,\n tpPrice: p.position.tpPrice,\n slPrice: p.position.entry * (1 - CONFIG.STOP_LOSS_PCT),\n pnlEur: (p.ticker.bid - p.position.entry) * p.position.volume,\n pnlPct: ((p.ticker.bid - p.position.entry) / p.position.entry) * 100,\n }\n : null;\n\n return c.json({\n updatedAt: new Date().toISOString(),\n mode: p.mode,\n halted: p.halted,\n baseLabel: CONFIG.BASE_LABEL,\n price: p.ticker.last,\n bid: p.ticker.bid,\n ask: p.ticker.ask,\n equity: p.equity,\n cashEur: p.eur,\n baseVolume: p.sol,\n initialEquity: p.initialEquity,\n gain,\n gainPct: p.initialEquity ? (gain! / p.initialEquity) * 100 : null,\n equity1hAgo: await equityAgo(1, p.mode),\n equity24hAgo: await equityAgo(24, p.mode),\n killLevel: p.initialEquity !== null ? p.initialEquity * (1 - CONFIG.KILL_SWITCH_DRAWDOWN) : null,\n position,\n pending: p.pending ? { price: p.pending.price, volume: p.pending.volume } : null,\n rsiBuyBelow: CONFIG.RSI_BUY_BELOW,\n snapshots: snaps.rows,\n trades,\n });\n});\n\nexport default app.fetch;\n",[],[175,306],"45a7a64b-534b-469e-b6af-7caf16fea97b",["D",1783546852120],[],[175,32],["D",1783546834930],[201,202],[175],"e95b980d-bc65-48da-b09f-564e8187b408","trader.ts","b6b24d1e-7b0d-11f1-aad7-1607ee4eb77e",["D",1783543425494],"interval","// Cron de trading — toutes les 15 minutes.\nimport { notifyError, runTraderCycle } from \"../lib/engine.ts\";\n\nexport default async function (interval: Interval) {\n try {\n await runTraderCycle();\n } catch (e) {\n await notifyError(\"cycle de trading\", e);\n }\n}\n",[],[181,320],"4d793be9-10e4-4b80-9d66-3c63f490b9af","reporter.ts","be5531da-7b0d-11f1-942d-1607ee4eb77e",38,["D",1783546126803],7,"// Reporting Telegram — toutes les heures, pile à l'heure.\nimport { CONFIG } from \"../config.ts\";\nimport { equityAgo, initDb, recentTrades } from \"../lib/db.ts\";\nimport { notifyError, readPortfolio } from \"../lib/engine.ts\";\nimport { sendTelegram } from \"../lib/telegram.ts\";\n\nconst fmt = (x: number, d = 2) => x.toFixed(d);\n\nfunction pctLine(label: string, now: number, ref: number | null): string {\n if (ref === null || ref === 0) return `${label} : n/a`;\n const pct = ((now - ref) / ref) * 100;\n const arrow = pct >= 0 ? \"📈\" : \"📉\";\n return `${label} : ${arrow} ${pct >= 0 ? \"+\" : \"\"}${fmt(pct)}%`;\n}\n\nexport default async function (interval: Interval) {\n try {\n await initDb();\n const p = await readPortfolio();\n\n const lines: string[] = [];\n lines.push(`📊 Rapport horaire — ${CONFIG.BASE_LABEL}/EUR (${p.mode})`);\n if (p.halted) {\n lines.push(`🔴 BOT ARRÊTÉ (kill-switch)`);\n }\n lines.push(`${CONFIG.BASE_LABEL} : ${fmt(p.ticker.last)} €`);\n lines.push(\n `Équité : ${fmt(p.equity)} € (${fmt(p.eur)} € cash + ${fmt(p.sol, CONFIG.VOL_DECIMALS)} ${CONFIG.BASE_LABEL})`,\n );\n if (p.initialEquity !== null) {\n const gain = p.equity - p.initialEquity;\n const gainPct = (gain / p.initialEquity) * 100;\n lines.push(\n `💰 Gain/Perte à l'instant T : ${gain >= 0 ? \"+\" : \"\"}${fmt(gain)} € ` +\n `(${gainPct >= 0 ? \"+\" : \"\"}${fmt(gainPct)}% depuis le départ à ${fmt(p.initialEquity)} €)`,\n );\n }\n lines.push(pctLine(\"PnL 1h\", p.equity, await equityAgo(1, p.mode)));\n lines.push(pctLine(\"PnL 24h\", p.equity, await equityAgo(24, p.mode)));\n\n if (p.position) {\n const pnl = ((p.ticker.bid - p.position.entry) / p.position.entry) * 100;\n const pnlEur = (p.ticker.bid - p.position.entry) * p.position.volume;\n lines.push(\n `\\n📌 Position : ${fmt(p.position.volume, CONFIG.VOL_DECIMALS)} ${CONFIG.BASE_LABEL} @ ${fmt(p.position.entry)} € ` +\n `(${pnl >= 0 ? \"+\" : \"\"}${fmt(pnl)}% · ${pnlEur >= 0 ? \"+\" : \"\"}${fmt(pnlEur)} €)\\n` +\n `🎯 TP ${fmt(p.position.tpPrice)} € · 🛑 SL ${fmt(p.position.entry * (1 - CONFIG.STOP_LOSS_PCT))} €`,\n );\n } else if (p.pending) {\n lines.push(`\\n⏳ Ordre d'achat en attente @ ${fmt(p.pending.price)} €`);\n } else if (!p.halted) {\n lines.push(`\\n😴 Pas de position — en attente d'un signal (RSI < ${CONFIG.RSI_BUY_BELOW})`);\n }\n\n const trades = await recentTrades(3);\n if (trades.length) {\n lines.push(`\\nDerniers trades :`);\n for (const t of trades) {\n const d = new Date(String(t.ts));\n const hh = `${String(d.getUTCHours()).padStart(2, \"0\")}:${String(d.getUTCMinutes()).padStart(2, \"0\")}`;\n lines.push(\n `· ${hh} UTC ${t.side === \"buy\" ? \"🟢 achat\" : \"🔻 vente\"} ${fmt(Number(t.volume), CONFIG.VOL_DECIMALS)} ${CONFIG.BASE_LABEL} @ ${fmt(Number(t.price))} € (${t.reason})`,\n );\n }\n }\n\n await sendTelegram(lines.join(\"\\n\"));\n } catch (e) {\n await notifyError(\"rapport horaire\", e);\n }\n}\n",[],[181,328],["D",1783543425494],[198,199],[181],["D",1783543222179],["D",1789525245864],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":377,"_378":379,"_380":381,"_382":24,"_383":24,"_384":24,"_385":57,"_386":-5,"_387":-7,"_388":-7,"_389":61,"_390":24,"_391":24,"_392":-5,"_393":24,"_394":24,"_395":24,"_396":-5},"ENV",{"_348":349,"_350":351,"_352":88,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370,"_371":372,"_373":374,"_375":376},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v42