[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_449":450,"_451":452},"routes/_app.x.$handle.$name",{"_101":100,"_32":46,"_110":91,"_27":111,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_20":-5,"_122":-5,"_123":-5,"_124":25,"_125":126,"_127":60,"_128":-5,"_129":-5,"_130":131},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":25},"version",168,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","crons/reporter.ts","latestPath","fileId","be5531da-7b0d-11f1-942d-1607ee4eb77e","name","reporter.ts","fileType","interval","content","// Reporting Telegram — toutes les heures, pile à l'heure. Multi-paires.\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 (${p.mode})`);\n if (p.halted) {\n lines.push(`🔴 BOT ARRÊTÉ (kill-switch)`);\n }\n const invested = p.equity - p.eur;\n const investedPct = p.equity > 0 ? (invested / p.equity) * 100 : 0;\n lines.push(`Équité : ${fmt(p.equity)} €`);\n lines.push(\n `🏛️ Cœur (buy & hold) : ${fmt(p.coreValue)} € · 💵 Cash : ${fmt(p.eur)} € · ` +\n `Exposition marché : ${fmt(investedPct, 0)}%`,\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 for (const pair of p.pairs) {\n lines.push(`\\n${pair.label} — ${fmt(pair.ticker.last)} €${pair.halted ? \" · 🔴 désactivée (kill-switch paire)\" : \"\"}`);\n if (pair.coreVolume > 0) {\n lines.push(`🏛️ Cœur : ${fmt(pair.coreValueEur)} €`);\n }\n if (pair.position) {\n const pnl = ((pair.ticker.bid - pair.position.entry) / pair.position.entry) * 100;\n const pnlEur = (pair.ticker.bid - pair.position.entry) * pair.position.volume;\n lines.push(\n `📌 ${pair.position.volume} ${pair.label} @ ${fmt(pair.position.entry)} € ` +\n `(${pnl >= 0 ? \"+\" : \"\"}${fmt(pnl)}% · ${pnlEur >= 0 ? \"+\" : \"\"}${fmt(pnlEur)} €)`,\n );\n const hw = pair.position.highWater ?? pair.position.entry;\n lines.push(\n `🎯 TP ${fmt(pair.position.entry * (1 + (pair.position.tpPct ?? pair.tpPct)), 4)} € · 📉 stop suiveur ~${fmt(hw * (1 - (pair.position.trailPct ?? pair.trailPct)), 4)} €`,\n );\n } else if (pair.pending) {\n lines.push(`⏳ Ordre d'achat en attente @ ${fmt(pair.pending.price)} €`);\n } else if (!p.halted) {\n lines.push(`😴 En attente d'un signal (RSI < ${pair.rsiBuyBelow})`);\n }\n }\n\n const trades = await recentTrades(4);\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\"} ${t.pair} @ ${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","// Reporting Telegram — toutes les heures.\n// Mode accumulation : valeur du stack + prix de revient + plus/moins-value.\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 // --- MODE ACCUMULATION (buy & hold) ---\n if (CONFIG.ACCUMULATE_ONLY) {\n const stackValue = p.coreValue;\n const cost = p.coreCost;\n const pnl = stackValue - cost;\n const pnlPct = cost > 0 ? (pnl / cost) * 100 : 0;\n const lines: string[] = [];\n lines.push(`🏛️ Stack crypto (accumulation)`);\n lines.push(\n `Valeur : ${fmt(stackValue)} € · investi ${fmt(cost)} €`,\n );\n lines.push(\n `${pnl >= 0 ? \"📈\" : \"📉\"} Plus/moins-value : ${pnl >= 0 ? \"+\" : \"\"}${fmt(pnl)} € (${pnlPct >= 0 ? \"+\" : \"\"}${fmt(pnlPct)}%)`,\n );\n lines.push(pctLine(\"Sur 24h\", stackValue, await equityAgo(24, p.mode)));\n lines.push(`💵 Cash restant à investir : ${fmt(p.eur)} €`);\n\n for (const pair of p.pairs) {\n if (pair.coreVolume <= 0) continue;\n const pnlP = pair.coreCost > 0 ? ((pair.coreValueEur - pair.coreCost) / pair.coreCost) * 100 : 0;\n lines.push(\n `\\n${pair.label} — ${fmt(pair.ticker.last, pair.ticker.last > 100 ? 1 : 4)} €` +\n `\\n${fmt(pair.coreValueEur)} € · revient ${fmt(pair.coreCost)} € (${pnlP >= 0 ? \"+\" : \"\"}${fmt(pnlP)}%)`,\n );\n }\n\n const buys = await recentTrades(3);\n if (buys.length) {\n lines.push(`\\nDerniers achats :`);\n for (const t of buys) {\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(`· ${hh} UTC ${t.side === \"buy\" ? \"🟢\" : \"🔻\"} ${t.pair} @ ${fmt(Number(t.price), Number(t.price) > 100 ? 1 : 4)} € (${t.reason})`);\n }\n }\n lines.push(`\\nXRP/DOGE conservés hors bot. Aucun ordre de vente actif.`);\n await sendTelegram(lines.join(\"\\n\"));\n return;\n }\n\n // --- MODE TRADING (historique) ---\n const lines: string[] = [];\n lines.push(`📊 Rapport horaire (${p.mode})`);\n if (p.halted) lines.push(`🔴 BOT ARRÊTÉ (kill-switch)`);\n const invested = p.equity - p.eur;\n const investedPct = p.equity > 0 ? (invested / p.equity) * 100 : 0;\n lines.push(`Équité : ${fmt(p.equity)} €`);\n lines.push(`🏛️ Cœur : ${fmt(p.coreValue)} € · 💵 Cash : ${fmt(p.eur)} € · Expo : ${fmt(investedPct, 0)}%`);\n if (p.initialEquity !== null) {\n const gain = p.equity - p.initialEquity;\n const gainPct = (gain / p.initialEquity) * 100;\n lines.push(`💰 Gain/Perte : ${gain >= 0 ? \"+\" : \"\"}${fmt(gain)} € (${gainPct >= 0 ? \"+\" : \"\"}${fmt(gainPct)}%)`);\n }\n lines.push(pctLine(\"PnL 24h\", p.equity, await equityAgo(24, p.mode)));\n for (const pair of p.pairs) {\n lines.push(`\\n${pair.label} — ${fmt(pair.ticker.last)} €`);\n if (pair.coreVolume > 0) lines.push(`🏛️ Cœur : ${fmt(pair.coreValueEur)} €`);\n if (pair.position) {\n const pnl = ((pair.ticker.bid - pair.position.entry) / pair.position.entry) * 100;\n lines.push(`📌 ${pair.position.volume} @ ${fmt(pair.position.entry)} € (${pnl >= 0 ? \"+\" : \"\"}${fmt(pnl)}%)`);\n }\n }\n await sendTelegram(lines.join(\"\\n\"));\n } catch (e) {\n await notifyError(\"rapport horaire\", e);\n }\n}\n","createdAt",["D",1785878323927],"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",{"_101":100,"_109":105},"org",{"_101":100,"_102":103,"_104":105,"_18":56,"_106":107,"_108":25},"branch",{"_13":90,"_32":91,"_44":43,"_92":45,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":46,"_99":100},"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",{"_44":45,"_32":46,"_39":444,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":445,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":446,"_85":447,"_87":448,"_89":25},"tree",[202,207,211,218,225,231,232],"files",[202,203,204,205,206,207,208,209,210,211,212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231,232],"counts",{"_190":64,"_191":192,"_193":64,"_194":195,"_196":197},"contents",[132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":184,"_32":185,"_30":186,"_142":-5,"_42":43,"_41":187,"_144":60,"_39":188,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_27":189},{"_44":178,"_32":179,"_30":180,"_142":-5,"_42":43,"_41":181,"_144":60,"_39":182,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_27":183},{"_44":172,"_32":173,"_30":174,"_142":-5,"_42":43,"_41":175,"_144":60,"_39":176,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_27":177},{"_44":166,"_32":167,"_30":168,"_142":-5,"_42":43,"_41":169,"_144":60,"_39":170,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_27":171},{"_44":159,"_32":160,"_30":161,"_142":-5,"_42":43,"_41":162,"_144":60,"_39":163,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_27":165},{"_44":151,"_32":152,"_30":153,"_142":-5,"_42":43,"_41":154,"_144":60,"_39":155,"_13":156,"_34":20,"_36":157,"_24":25,"_149":-5,"_27":158},{"_44":139,"_32":140,"_30":141,"_142":-5,"_42":43,"_41":143,"_144":60,"_39":145,"_13":146,"_34":147,"_36":148,"_24":25,"_149":-5,"_27":150},"b2c17db3-ed23-4799-8db5-29605a38d845","config.ts","49432064-7b0d-11f1-bdc0-1607ee4eb77e","parentId",162,"latest",["D",1785878219405],24,"script","// Configuration du bot — tout est en un seul endroit.\n\n// Profil de risque par paire. allocPct = part max de l'équité totale\n// que cette paire peut engager (le cash est un pot commun).\nexport interface PairConfig {\n pair: string; // code Kraken (ex: XBTEUR)\n baseAsset: string; // clé de balance Kraken (ex: XXBT)\n label: string; // libellé d'affichage\n volDecimals: number;\n rsiBuyBelow: number;\n // Stop suiveur (trailing stop) : vend quand le prix retombe de trailPct depuis\n // son plus haut. Protection résidente côté Kraken (instantanée).\n trailPct: number;\n // Prise de gains fixe : vente dès que le prix dépasse entry*(1+tpPct)\n // (vérifiée à chaque cycle). Petits gains fréquents plutôt que gros coups.\n tpPct: number;\n entryTtlMin: number;\n allocPct: number;\n}\n\nexport const PAIRS: PairConfig[] = [\n // BTC : profil prudent (peu volatil, trail serré)\n {\n pair: \"XBTEUR\",\n baseAsset: \"XXBT\",\n label: \"BTC\",\n volDecimals: 6,\n rsiBuyBelow: 30,\n trailPct: 0.02,\n tpPct: 0.015,\n entryTtlMin: 45,\n allocPct: 0.34,\n },\n // ETH : volatilité intermédiaire — profil médian\n {\n pair: \"ETHEUR\",\n baseAsset: \"XETH\",\n label: \"ETH\",\n volDecimals: 5,\n rsiBuyBelow: 32,\n trailPct: 0.025,\n tpPct: 0.018,\n entryTtlMin: 45,\n allocPct: 0.33,\n },\n // SOL : volatil — trail large, entrées un peu plus fréquentes\n {\n pair: \"SOLEUR\",\n baseAsset: \"SOL\",\n label: \"SOL\",\n volDecimals: 4,\n rsiBuyBelow: 33,\n trailPct: 0.03,\n tpPct: 0.02,\n entryTtlMin: 60,\n allocPct: 0.33,\n },\n];\n// XRP et DOGE retirés le 2026-08-04 : mode accumulation BTC/ETH/SOL uniquement.\n// Les XRP/DOGE déjà détenus restent dans le compte Kraken, non gérés par le bot.\n\nexport const CONFIG = {\n QUOTE_ASSET: \"ZEUR\", // clé de balance Kraken pour EUR\n CANDLE_MINUTES: 15, // bougies 15 min\n RSI_PERIOD: 14,\n INITIAL_CAPITAL_EUR: 10, // capital de départ paper\n\n // Sorties adaptatives : TP et trail dimensionnés sur la volatilité réalisée\n // (ATR 15 min), bornés pour rester rentables après frais. Les tpPct/trailPct\n // des paires servent de valeurs de secours si l'ATR est indisponible.\n ATR_PERIOD: 14,\n ATR_TP_MULT: 1.5, // TP ≈ 1,5 × ATR%\n ATR_TRAIL_MULT: 2.0, // trail ≈ 2 × ATR% (protection : doit respirer)\n TP_MIN: 0.02, // jamais sous +2% (frais 1,2% aller-retour depuis le barème Kraken du 09/07/2026)\n TP_MAX: 0.035,\n TRAIL_MIN: 0.02,\n TRAIL_MAX: 0.045,\n\n // Anti-churn : après une sortie perdante sur une paire, pas de rachat\n // pendant ce délai (évite d'acheter en série dans la même chute)\n REENTRY_COOLDOWN_MIN: 120,\n\n // Filtre de régime : pas d'achat si le prix est enfoncé sous sa moyenne 24 h\n // (survente en chute installée = couteau qui tombe, pas une solde)\n TREND_SMA_CANDLES: 96, // 96 bougies 15 min = 24 h\n TREND_MAX_DISCOUNT: 0.975, // prix requis ≥ 97,5% de la SMA 24h\n\n // Porte de marché GLOBALE : BTC est le baromètre du marché crypto entier.\n // Si BTC est sous sa moyenne 24h, AUCUNE nouvelle entrée sur AUCUNE paire\n // (leçon du 13/07 : toutes les pertes sont venues d'achats pendant une\n // baisse de marché généralisée que le filtre par paire laissait passer).\n MARKET_GATE_TOLERANCE: 0.998,\n\n // Anti-corrélation : max 2 nouvelles entrées par cycle (le 13/07, 3 achats\n // simultanés SOL+XRP+ETH sont morts ensemble — les cryptos chutent de concert)\n MAX_NEW_ENTRIES_PER_CYCLE: 2,\n\n // Réserve de cash : ne jamais investir les derniers 15% d'équité\n // (garder des munitions pour les creux plus profonds)\n CASH_RESERVE_PCT: 0.15,\n\n // === CŒUR-SATELLITE ===\n // Le \"cœur\" est un panier buy-and-hold diversifié qui SUIT le marché (monte\n // avec les hausses, baisse avec les baisses). Sans lui, le bot reste en cash\n // et rate les tendances haussières. Le \"satellite\" = trading tactique sur le\n // reste du cash. Le cœur n'est JAMAIS vendu par TP/trailing — seul le\n // kill-switch global le protège. Acheté au marché (fill garanti), lissé (DCA).\n CORE_TARGET_PCT: 0.96, // ~tout investi en buy-and-hold (mode accumulation)\n CORE_DCA_PER_CYCLE: 0.10, // déployer au plus 10% de l'équité par cycle (anti-top)\n CORE_REBALANCE_BAND: 0.02, // maintenir quasi pleinement investi\n\n // MODE ACCUMULATION (2026-08-04, demande utilisateur) : buy-and-hold pur.\n // Le bot n'ACHÈTE que (DCA vers le cœur), ne vend JAMAIS de lui-même :\n // aucune entrée RSI, aucun take-profit, aucun stop, aucun kill-switch.\n // \"Ma crypto suit le cours, sans ordre de vente.\"\n ACCUMULATE_ONLY: true,\n\n // Garde-fous\n PAIR_KILL_DRAWDOWN: 0.20, // -20% du capital engagé sur UNE paire => liquider + désactiver cette paire\n KILL_SWITCH_DRAWDOWN: 0.20, // -20% de l'équité initiale => tout liquider + arrêt définitif (filet ultime)\n CASH_BUFFER_PCT: 0.005, // marge pour les frais lors du sizing\n\n // Frais Kraken Tier 1 — nouveau barème du 9 juillet 2026 (vérifié sur les\n // exécutions réelles du compte). Tier 2 (0,30/0,60) à partir de 2 500 $ de\n // volume sur 30 jours.\n MAKER_FEE: 0.004,\n TAKER_FEE: 0.008,\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",[140],"708294f1-fd65-46dc-8e77-f85cdc752131","README.md","3d85097c-7b0d-11f1-a442-1607ee4eb77e",59,["D",1783581307297],2,"# 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` + `trader-b.ts` + `trader-c.ts` — cycle de trading (3 crons décalés = un passage toutes les 5 min, verrou anti-chevauchement dans le moteur)\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",[152],"4ccd62ee-0b28-4867-86fa-d2b0ff15a7f3","tests","0384723a-a63e-46c0-8aa5-125975c5b0a8",16,["D",1783544253770],"directory",[160],"abe96940-4160-48e0-b2ba-81119a7404aa","setup","67aba91e-b7a2-4f5f-8392-de13ade9637a",10,["D",1783543473813],[167],"77ee57fe-496b-410f-b837-7ef72b832315","lib","9ba94c81-ca7a-4c04-b9af-f3824df06960",3,["D",1783543271782],[173],"7a62f18a-baad-457b-87a9-fe0a7f8bb958","dashboard","0c0953d3-0a92-465a-a4a7-b2b49e4fbb61",41,["D",1783546834930],[179],"94378d7f-2aed-4b51-8e58-2dd6014867c1","crons","e6925dad-2c65-4a6b-a1f3-bc5939f3e670",8,["D",1783543425494],[185],"pulls","branches",1,"forks","envVars",{"_198":200,"_201":64},"connections",{"_198":64,"_199":64},"count","unfilledCount",5,"emptyCount",{"_44":184,"_32":185,"_30":186,"_142":-5,"_42":43,"_41":187,"_144":60,"_39":441,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_234":442,"_27":443},{"_44":437,"_32":33,"_30":31,"_142":186,"_42":43,"_41":14,"_144":25,"_39":438,"_13":253,"_34":35,"_36":38,"_24":25,"_149":-5,"_234":439,"_27":440},{"_44":429,"_32":430,"_30":431,"_142":186,"_42":43,"_41":432,"_144":60,"_39":433,"_13":64,"_34":35,"_36":434,"_24":25,"_149":-5,"_234":435,"_27":436},{"_44":421,"_32":422,"_30":423,"_142":186,"_42":43,"_41":424,"_144":60,"_39":425,"_13":64,"_34":35,"_36":426,"_24":25,"_149":-5,"_234":427,"_27":428},{"_44":414,"_32":415,"_30":416,"_142":186,"_42":43,"_41":187,"_144":60,"_39":417,"_13":64,"_34":35,"_36":418,"_24":25,"_149":-5,"_234":419,"_27":420},{"_44":178,"_32":179,"_30":180,"_142":-5,"_42":43,"_41":181,"_144":60,"_39":411,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_234":412,"_27":413},{"_44":403,"_32":404,"_30":405,"_142":180,"_42":43,"_41":406,"_144":60,"_39":407,"_13":187,"_34":147,"_36":408,"_24":25,"_149":-5,"_234":409,"_27":410},{"_44":395,"_32":396,"_30":397,"_142":180,"_42":43,"_41":398,"_144":60,"_39":399,"_13":64,"_34":20,"_36":400,"_24":25,"_149":-5,"_234":401,"_27":402},{"_44":387,"_32":388,"_30":58,"_142":180,"_42":43,"_41":389,"_144":60,"_39":390,"_13":187,"_34":391,"_36":392,"_24":25,"_149":-5,"_234":393,"_27":394},{"_44":172,"_32":173,"_30":174,"_142":-5,"_42":43,"_41":175,"_144":60,"_39":384,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_234":385,"_27":386},{"_44":376,"_32":377,"_30":378,"_142":174,"_42":43,"_41":379,"_144":25,"_39":380,"_13":64,"_34":147,"_36":381,"_24":25,"_149":-5,"_234":382,"_27":383},{"_44":368,"_32":369,"_30":370,"_142":174,"_42":43,"_41":371,"_144":60,"_39":372,"_13":175,"_34":147,"_36":373,"_24":25,"_149":-5,"_234":374,"_27":375},{"_44":359,"_32":360,"_30":361,"_142":174,"_42":43,"_41":362,"_144":60,"_39":363,"_13":364,"_34":147,"_36":365,"_24":25,"_149":-5,"_234":366,"_27":367},{"_44":351,"_32":352,"_30":353,"_142":174,"_42":43,"_41":354,"_144":60,"_39":355,"_13":192,"_34":147,"_36":356,"_24":25,"_149":-5,"_234":357,"_27":358},{"_44":342,"_32":343,"_30":344,"_142":174,"_42":43,"_41":345,"_144":60,"_39":346,"_13":347,"_34":147,"_36":348,"_24":25,"_149":-5,"_234":349,"_27":350},{"_44":335,"_32":336,"_30":337,"_142":174,"_42":43,"_41":200,"_144":60,"_39":338,"_13":64,"_34":147,"_36":339,"_24":25,"_149":-5,"_234":340,"_27":341},{"_44":166,"_32":167,"_30":168,"_142":-5,"_42":43,"_41":169,"_144":60,"_39":332,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_234":333,"_27":334},{"_44":324,"_32":325,"_30":326,"_142":168,"_42":43,"_41":327,"_144":60,"_39":328,"_13":64,"_34":147,"_36":329,"_24":25,"_149":-5,"_234":330,"_27":331},{"_44":316,"_32":317,"_30":318,"_142":168,"_42":43,"_41":319,"_144":60,"_39":320,"_13":64,"_34":147,"_36":321,"_24":25,"_149":-5,"_234":322,"_27":323},{"_44":308,"_32":309,"_30":310,"_142":168,"_42":43,"_41":311,"_144":60,"_39":312,"_13":200,"_34":147,"_36":313,"_24":25,"_149":-5,"_234":314,"_27":315},{"_44":300,"_32":301,"_30":302,"_142":168,"_42":43,"_41":303,"_144":60,"_39":304,"_13":64,"_34":147,"_36":305,"_24":25,"_149":-5,"_234":306,"_27":307},{"_44":292,"_32":293,"_30":294,"_142":168,"_42":43,"_41":295,"_144":60,"_39":296,"_13":192,"_34":147,"_36":297,"_24":25,"_149":-5,"_234":298,"_27":299},{"_44":284,"_32":285,"_30":286,"_142":168,"_42":43,"_41":287,"_144":60,"_39":288,"_13":192,"_34":147,"_36":289,"_24":25,"_149":-5,"_234":290,"_27":291},{"_44":159,"_32":160,"_30":161,"_142":-5,"_42":43,"_41":162,"_144":60,"_39":281,"_13":64,"_34":164,"_36":-5,"_24":25,"_149":-5,"_234":282,"_27":283},{"_44":273,"_32":274,"_30":275,"_142":161,"_42":43,"_41":276,"_144":60,"_39":277,"_13":64,"_34":147,"_36":278,"_24":25,"_149":-5,"_234":279,"_27":280},{"_44":265,"_32":266,"_30":267,"_142":161,"_42":43,"_41":268,"_144":60,"_39":269,"_13":64,"_34":147,"_36":270,"_24":25,"_149":-5,"_234":271,"_27":272},{"_44":257,"_32":258,"_30":259,"_142":161,"_42":43,"_41":260,"_144":60,"_39":261,"_13":64,"_34":147,"_36":262,"_24":25,"_149":-5,"_234":263,"_27":264},{"_44":248,"_32":249,"_30":250,"_142":161,"_42":43,"_41":251,"_144":60,"_39":252,"_13":253,"_34":147,"_36":254,"_24":25,"_149":-5,"_234":255,"_27":256},{"_44":240,"_32":241,"_30":242,"_142":161,"_42":43,"_41":243,"_144":60,"_39":244,"_13":64,"_34":147,"_36":245,"_24":25,"_149":-5,"_234":246,"_27":247},{"_44":151,"_32":152,"_30":153,"_142":-5,"_42":43,"_41":154,"_144":60,"_39":237,"_13":156,"_34":20,"_36":157,"_24":25,"_149":-5,"_234":238,"_27":239},{"_44":139,"_32":140,"_30":141,"_142":-5,"_42":43,"_41":143,"_144":60,"_39":233,"_13":146,"_34":147,"_36":148,"_24":25,"_149":-5,"_234":235,"_27":236},["D",1785878219405],"children",[],[140],["D",1783581307297],[],[152],"58912005-30c7-481e-9504-ac69fbb1842a","event-trump.ts","1fd9b722-7be6-11f1-9479-1607ee4eb77e",92,["D",1783636373202],"// Analyse d'événement : réaction des cryptos à la déclaration crypto de Trump\n// (Bureau ovale, lundi 6 juillet 2026 ~13h30 UTC : \"I've become a big crypto guy\").\nimport { PAIRS } from \"../config.ts\";\nimport { getOHLC } from \"../lib/kraken.ts\";\n\nconst EVENT = Date.parse(\"2026-07-06T13:30:00Z\") / 1000;\nconst BEFORE_H = 6; // fenêtre avant : plus bas des 6 h précédentes\nconst AFTER_H = 24; // fenêtre après : plus haut des 24 h suivantes\n\nfor (const pc of PAIRS) {\n const candles = await getOHLC(pc.pair, 15);\n const at = candles.filter((c) => c.time <= EVENT).at(-1);\n const before = candles.filter((c) => c.time >= EVENT - BEFORE_H * 3600 && c.time <= EVENT);\n const after = candles.filter((c) => c.time > EVENT && c.time <= EVENT + AFTER_H * 3600);\n if (!at || !before.length || !after.length) {\n console.log(`${pc.label}: données insuffisantes`);\n continue;\n }\n const priceAt = at.close;\n const lowBefore = Math.min(...before.map((c) => c.low));\n const highAfter = Math.max(...after.map((c) => c.high));\n const h6 = after.filter((c) => c.time <= EVENT + 6 * 3600);\n const closeH6 = h6.at(-1)?.close ?? priceAt;\n const pct = (a: number, b: number) => (((a - b) / b) * 100).toFixed(2);\n\n console.log(\n `${pc.label}: ${priceAt.toFixed(4)} € au moment de la déclaration · ` +\n `plus bas 6h avant ${lowBefore.toFixed(4)} € · ` +\n `+6h: ${closeH6.toFixed(4)} € (${pct(closeH6, priceAt)}%) · ` +\n `pic 24h: ${highAfter.toFixed(4)} € (${pct(highAfter, priceAt)}% vs déclaration, ${pct(highAfter, lowBefore)}% vs creux)`,\n );\n}\n",[],[160,241],"965fc5c2-d370-454a-ac7e-c58e27f2b667","backtest.ts","a4629478-7b0f-11f1-8991-1607ee4eb77e",120,["D",1783883863498],15,"// Backtest de la stratégie sur les dernières 72h (bougies 15 min Kraken), par paire.\n// Reflète la logique LIVE : entrée limite post-only si RSI < seuil ET prix pas trop\n// enfoncé sous la SMA 24h (filtre régime) ; sorties adaptatives ATR (TP + stop suiveur).\n// Hypothèse pessimiste : si stop et TP touchés dans la même bougie, le stop gagne.\nimport { CONFIG, PAIRS, type PairConfig } from \"../config.ts\";\nimport { getOHLC, getPairInfo, type PairInfo } from \"../lib/kraken.ts\";\nimport { atrPct, rsi, sma } from \"../lib/indicators.ts\";\n\nconst HOURS = 72;\nconst CAPITAL = 10;\n\nconst clamp = (x: number, lo: number, hi: number) => Math.min(Math.max(x, lo), hi);\n\nfunction simulate(\n pc: PairConfig,\n info: PairInfo,\n startCapital: number,\n candles: { time: number; open: number; high: number; low: number; close: number }[],\n startIdx: number,\n) {\n let cash = startCapital;\n let position: { entry: number; volume: number; high: number; tp: number; trail: number } | null = null;\n let pending: { price: number; volume: number; idx: number; tp: number; trail: number } | null = null;\n const trades: string[] = [];\n let fees = 0;\n let halted = false;\n let filtered = 0;\n let cooldownUntil = -1;\n const cooldownCandles = Math.ceil(CONFIG.REENTRY_COOLDOWN_MIN / CONFIG.CANDLE_MINUTES);\n\n const closes = candles.map((c) => c.close);\n const ttlCandles = Math.ceil(pc.entryTtlMin / 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 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 high: pending.price,\n tp: pending.tp,\n trail: pending.trail,\n };\n trades.push(`${when} 🟢 achat @ ${pending.price.toFixed(4)} € (TP +${(pending.tp * 100).toFixed(1)}%, trail ${(pending.trail * 100).toFixed(1)}%)`);\n pending = null;\n } else if (i - pending.idx >= ttlCandles) {\n trades.push(`${when} ⌛ ordre expiré (@ ${pending.price.toFixed(4)} €)`);\n pending = null;\n }\n }\n\n if (position) {\n const stop = position.high * (1 - position.trail);\n const tpPrice = position.entry * (1 + position.tp);\n if (c.low <= stop) {\n const sellPrice = Math.min(stop, c.open);\n const proceeds = sellPrice * position.volume;\n const fee = proceeds * CONFIG.TAKER_FEE;\n cash += proceeds - fee;\n fees += fee;\n const pnl = ((sellPrice - position.entry) / position.entry) * 100;\n trades.push(`${when} ${pnl >= 0 ? \"🎯\" : \"🛑\"} stop suiveur @ ${sellPrice.toFixed(4)} € (${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(2)}%)`);\n if (pnl < 0) cooldownUntil = i + cooldownCandles;\n position = null;\n } else if (c.high >= tpPrice) {\n const proceeds = tpPrice * position.volume;\n const fee = proceeds * CONFIG.TAKER_FEE;\n cash += proceeds - fee;\n fees += fee;\n trades.push(`${when} 🎯 take-profit @ ${tpPrice.toFixed(4)} € (+${(position.tp * 100).toFixed(1)}%)`);\n position = null;\n } else if (c.high > position.high) {\n position.high = c.high;\n }\n }\n\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 if (!position && !pending && i >= cooldownUntil) {\n const hist = candles.slice(0, i + 1);\n const r = rsi(closes.slice(0, i + 1), CONFIG.RSI_PERIOD);\n if (r !== null && r < pc.rsiBuyBelow) {\n // Filtre de régime : pas d'achat en chute installée\n const trend = sma(closes.slice(0, i + 1), CONFIG.TREND_SMA_CANDLES);\n if (trend !== null && c.close < trend * CONFIG.TREND_MAX_DISCOUNT) {\n filtered++;\n continue;\n }\n const atr = atrPct(hist, CONFIG.ATR_PERIOD);\n const tp = atr !== null ? clamp(atr * CONFIG.ATR_TP_MULT, CONFIG.TP_MIN, CONFIG.TP_MAX) : pc.tpPct;\n const trail = atr !== null ? clamp(atr * CONFIG.ATR_TRAIL_MULT, CONFIG.TRAIL_MIN, CONFIG.TRAIL_MAX) : pc.trailPct;\n const price = c.close;\n const volume = (cash * (1 - CONFIG.CASH_BUFFER_PCT)) / price;\n if (volume >= info.ordermin && volume * price >= info.costmin) {\n pending = { price, volume, idx: i, tp, trail };\n trades.push(`${when} 📥 ordre limite posé @ ${price.toFixed(4)} € (RSI ${r.toFixed(1)})`);\n }\n }\n }\n }\n\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, filtered };\n}\n\n// ---- Exécution ----\nfor (const pc of PAIRS) {\n const info = await getPairInfo(pc.pair);\n const candles = await getOHLC(pc.pair, CONFIG.CANDLE_MINUTES);\n const cutoff = Date.now() / 1000 - HOURS * 3600;\n const startIdx = candles.findIndex((c) => c.time >= cutoff);\n\n const first = candles[startIdx];\n const last = candles[candles.length - 1];\n const buyHold = ((last.close - first.close) / first.close) * 100;\n\n const r = simulate(pc, info, CAPITAL, candles, startIdx);\n const pnl = r.finalEquity - CAPITAL;\n const pnlPct = (pnl / CAPITAL) * 100;\n\n console.log(`=== ${pc.label}/EUR (RSI<${pc.rsiBuyBelow}, sorties ATR adaptatives) ===`);\n console.log(`Prix : ${first.close.toFixed(4)} € → ${last.close.toFixed(4)} € (buy & hold : ${buyHold >= 0 ? \"+\" : \"\"}${buyHold.toFixed(2)}%)`);\n console.log(`Équité finale (${CAPITAL} €) : ${r.finalEquity.toFixed(2)} € (${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(2)} €, ${pnlPct >= 0 ? \"+\" : \"\"}${pnlPct.toFixed(2)}%)${r.halted ? \" · 🔴 KILL SWITCH\" : \"\"}`);\n console.log(`Frais : ${r.fees.toFixed(3)} € · Signaux filtrés (régime baissier) : ${r.filtered} · Position ouverte en fin : ${r.openPosition ? \"oui\" : \"non\"}`);\n for (const t of r.trades) console.log(\" \" + t);\n console.log(\"\");\n}\n",[],[160,249],"156d3730-b004-44d4-9d21-9f9264d8758e","backtest-trump.ts","7cdfc7d0-7be7-11f1-be0e-1607ee4eb77e",93,["D",1783636958775],"// Simulation : entrer sur chaque déclaration crypto/marché de Trump depuis le\n// 01/01/2026, sortir selon la stratégie actuelle (TP fixe + stop suiveur).\n// Bougies JOURNALIÈRES (limite API Kraken : le 15 min ne remonte que sur ~7 jours).\n// Entrée = clôture du jour de la déclaration (on ne peut pas acheter avant le tweet !).\n// Pessimiste : si stop et TP touchés le même jour, le stop gagne.\nimport { CONFIG, PAIRS, type PairConfig } from \"../config.ts\";\nimport { getOHLC } from \"../lib/kraken.ts\";\n\nconst EVENTS = [\n { date: \"2026-03-03\", label: \"Post anti-banques GENIUS/Clarity Act\" },\n { date: \"2026-04-14\", label: \"Pourparlers de paix Iran (macro)\" },\n { date: \"2026-04-17\", label: \"Annonce fin de blocus (macro)\" },\n { date: \"2026-07-06\", label: \"« Big crypto guy » / Trump Accounts\" },\n];\n\nfunction dayIndex(candles: { time: number }[], dateStr: string): number {\n const target = Date.parse(dateStr + \"T00:00:00Z\") / 1000;\n return candles.findIndex((c) => c.time >= target && c.time < target + 86400);\n}\n\nfor (const pc of PAIRS) {\n const candles = await getOHLC(pc.pair, 1440); // journalier\n let capital = 10;\n const lines: string[] = [`=== ${pc.label}/EUR (TP +${(pc.tpPct * 100).toFixed(1)}%, trail ${(pc.trailPct * 100).toFixed(1)}%) ===`];\n let busyUntil = -1;\n\n for (const ev of EVENTS) {\n const idx = dayIndex(candles, ev.date);\n if (idx < 0 || idx + 1 >= candles.length) {\n lines.push(` ${ev.date} ${ev.label}: données manquantes`);\n continue;\n }\n if (idx <= busyUntil) {\n lines.push(` ${ev.date} ${ev.label}: sauté (position déjà ouverte)`);\n continue;\n }\n const entry = candles[idx].close;\n const volume = (capital * (1 - CONFIG.CASH_BUFFER_PCT)) / entry;\n const feeIn = entry * volume * CONFIG.TAKER_FEE;\n let high = entry;\n let exitPrice: number | null = null;\n let exitDay = idx;\n let reason = \"\";\n\n for (let i = idx + 1; i < candles.length; i++) {\n const c = candles[i];\n const stop = high * (1 - pc.trailPct);\n const tp = entry * (1 + pc.tpPct);\n if (c.low <= stop) {\n exitPrice = Math.min(stop, c.open);\n reason = exitPrice >= entry ? \"stop suiveur (gain)\" : \"stop suiveur (perte)\";\n exitDay = i;\n break;\n }\n if (c.high >= tp) {\n exitPrice = tp;\n reason = \"take-profit\";\n exitDay = i;\n break;\n }\n if (c.high > high) high = c.high;\n }\n if (exitPrice === null) {\n exitPrice = candles[candles.length - 1].close;\n reason = \"encore ouverte\";\n exitDay = candles.length - 1;\n }\n const feeOut = exitPrice * volume * CONFIG.TAKER_FEE;\n const pnl = (exitPrice - entry) * volume - feeIn - feeOut;\n capital += pnl;\n busyUntil = exitDay;\n const pct = ((exitPrice - entry) / entry) * 100;\n lines.push(\n ` ${ev.date} ${ev.label}: entrée ${entry.toFixed(4)} € → sortie ${exitPrice.toFixed(4)} € ` +\n `(${pct >= 0 ? \"+\" : \"\"}${pct.toFixed(2)}%, ${reason}, ${exitDay - idx} j) · PnL ${pnl >= 0 ? \"+\" : \"\"}${pnl.toFixed(3)} €`,\n );\n }\n const totalPct = ((capital - 10) / 10) * 100;\n lines.push(` ➜ Capital final : ${capital.toFixed(2)} € (${totalPct >= 0 ? \"+\" : \"\"}${totalPct.toFixed(2)}%)`);\n console.log(lines.join(\"\\n\"));\n}\n",[],[160,258],"7b0115e3-ee31-49dc-ac29-06b327f249c3","backtest-risk.ts","30aa8bde-836c-11f1-8d41-1607ee4eb77e",135,["D",1784463612122],"// Comparaison de profils de risque sur les 7 derniers jours (bougies 15 min).\n// \"actuel\" : paramètres du bot en production (filtres + sorties ATR bornées serrées)\n// \"risque+\" : entrées plus fréquentes (RSI +5), aucun filtre ni cooldown, cibles larges\n// \"maximal\" : idem risque+, mais AUCUN take-profit — trailing large seul (laisser courir)\nimport { CONFIG, PAIRS, type PairConfig } from \"../config.ts\";\nimport { getOHLC, getPairInfo, type PairInfo } from \"../lib/kraken.ts\";\nimport { atrPct, rsi, sma } from \"../lib/indicators.ts\";\n\nconst HOURS = 168;\nconst CAPITAL = 10;\n\ninterface Profile {\n name: string;\n rsiOffset: number;\n trendFilter: boolean;\n cooldown: boolean;\n tpEnabled: boolean;\n tpMult: number; tpMin: number; tpMax: number;\n trailMult: number; trailMin: number; trailMax: number;\n}\n\nconst PROFILES: Profile[] = [\n { name: \"actuel\", rsiOffset: 0, trendFilter: true, cooldown: true, tpEnabled: true,\n tpMult: 1.5, tpMin: 0.02, tpMax: 0.035, trailMult: 2.0, trailMin: 0.02, trailMax: 0.045 },\n { name: \"risque+\", rsiOffset: 5, trendFilter: false, cooldown: false, tpEnabled: true,\n tpMult: 2.5, tpMin: 0.025, tpMax: 0.06, trailMult: 3.0, trailMin: 0.03, trailMax: 0.08 },\n { name: \"maximal\", rsiOffset: 5, trendFilter: false, cooldown: false, tpEnabled: false,\n tpMult: 0, tpMin: 0, tpMax: 0, trailMult: 3.0, trailMin: 0.03, trailMax: 0.08 },\n];\n\nconst clamp = (x: number, lo: number, hi: number) => Math.min(Math.max(x, lo), hi);\n\nfunction simulate(\n pc: PairConfig,\n info: PairInfo,\n pr: Profile,\n candles: { time: number; open: number; high: number; low: number; close: number }[],\n startIdx: number,\n) {\n let cash = CAPITAL;\n let position: { entry: number; volume: number; high: number; tp: number; trail: number } | null = null;\n let pending: { price: number; volume: number; idx: number; tp: number; trail: number } | null = null;\n let wins = 0, losses = 0, fees = 0;\n let cooldownUntil = -1;\n let maxDrawdown = 0, peak = CAPITAL;\n const cooldownCandles = Math.ceil(CONFIG.REENTRY_COOLDOWN_MIN / CONFIG.CANDLE_MINUTES);\n const ttlCandles = Math.ceil(pc.entryTtlMin / CONFIG.CANDLE_MINUTES);\n const closes = candles.map((c) => c.close);\n\n for (let i = startIdx; i < candles.length; i++) {\n const c = candles[i];\n\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 = { entry: pending.price, volume: pending.volume, high: pending.price, tp: pending.tp, trail: pending.trail };\n pending = null;\n } else if (i - pending.idx >= ttlCandles) {\n pending = null;\n }\n }\n\n if (position) {\n const stop = position.high * (1 - position.trail);\n const tpPrice = position.entry * (1 + position.tp);\n if (c.low <= stop) {\n const sellPrice = Math.min(stop, c.open);\n const fee = sellPrice * position.volume * CONFIG.TAKER_FEE;\n cash += sellPrice * position.volume - fee;\n fees += fee;\n if (sellPrice >= position.entry) wins++; else { losses++; if (pr.cooldown) cooldownUntil = i + cooldownCandles; }\n position = null;\n } else if (pr.tpEnabled && c.high >= tpPrice) {\n const fee = tpPrice * position.volume * CONFIG.TAKER_FEE;\n cash += tpPrice * position.volume - fee;\n fees += fee;\n wins++;\n position = null;\n } else if (c.high > position.high) {\n position.high = c.high;\n }\n }\n\n const equity = cash + (position ? position.volume * c.close : 0);\n if (equity > peak) peak = equity;\n const dd = (peak - equity) / peak;\n if (dd > maxDrawdown) maxDrawdown = dd;\n\n if (!position && !pending && i >= cooldownUntil) {\n const r = rsi(closes.slice(0, i + 1), CONFIG.RSI_PERIOD);\n if (r !== null && r < pc.rsiBuyBelow + pr.rsiOffset) {\n if (pr.trendFilter) {\n const trend = sma(closes.slice(0, i + 1), CONFIG.TREND_SMA_CANDLES);\n if (trend !== null && c.close < trend * CONFIG.TREND_MAX_DISCOUNT) continue;\n }\n const atr = atrPct(candles.slice(0, i + 1), CONFIG.ATR_PERIOD);\n const tp = pr.tpEnabled ? (atr !== null ? clamp(atr * pr.tpMult, pr.tpMin, pr.tpMax) : pr.tpMin) : Infinity;\n const trail = atr !== null ? clamp(atr * pr.trailMult, pr.trailMin, pr.trailMax) : pr.trailMin;\n const price = c.close;\n const volume = (cash * (1 - CONFIG.CASH_BUFFER_PCT)) / price;\n if (volume >= info.ordermin && volume * price >= info.costmin) {\n pending = { price, volume, idx: i, tp, trail };\n }\n }\n }\n }\n\n const finalEquity = cash + (position ? position.volume * candles[candles.length - 1].close : 0);\n return { finalEquity, wins, losses, fees, maxDrawdown };\n}\n\nconst totals = new Map();\nfor (const pr of PROFILES) totals.set(pr.name, { eq: 0, wins: 0, losses: 0, fees: 0, worstDd: 0 });\n\nfor (const pc of PAIRS) {\n const info = await getPairInfo(pc.pair);\n const candles = await getOHLC(pc.pair, CONFIG.CANDLE_MINUTES);\n const cutoff = Date.now() / 1000 - HOURS * 3600;\n const startIdx = Math.max(candles.findIndex((c) => c.time >= cutoff), CONFIG.TREND_SMA_CANDLES);\n\n const lines = [`=== ${pc.label}/EUR ===`];\n for (const pr of PROFILES) {\n const r = simulate(pc, info, pr, candles, startIdx);\n const pct = ((r.finalEquity - CAPITAL) / CAPITAL) * 100;\n const t = totals.get(pr.name)!;\n t.eq += r.finalEquity; t.wins += r.wins; t.losses += r.losses; t.fees += r.fees;\n if (r.maxDrawdown > t.worstDd) t.worstDd = r.maxDrawdown;\n lines.push(\n ` ${pr.name.padEnd(8)}: ${r.finalEquity.toFixed(2)} € (${pct >= 0 ? \"+\" : \"\"}${pct.toFixed(2)}%) · ` +\n `${r.wins}W/${r.losses}L · frais ${r.fees.toFixed(2)} € · drawdown max ${(r.maxDrawdown * 100).toFixed(1)}%`,\n );\n }\n console.log(lines.join(\"\\n\"));\n}\n\nconsole.log(\"\\n=== TOTAL (5 × 10 €) ===\");\nfor (const pr of PROFILES) {\n const t = totals.get(pr.name)!;\n const pct = ((t.eq - 50) / 50) * 100;\n console.log(\n `${pr.name.padEnd(8)}: ${t.eq.toFixed(2)} € (${pct >= 0 ? \"+\" : \"\"}${pct.toFixed(2)}%) · ` +\n `${t.wins}W/${t.losses}L · frais ${t.fees.toFixed(2)} € · pire drawdown ${(t.worstDd * 100).toFixed(1)}%`,\n );\n}\n",[],[160,266],"163ab849-2ce0-4f82-85e0-6156d64010bf","backtest-momentum.ts","7490e354-7be5-11f1-bbb1-1607ee4eb77e",91,["D",1783636085837],"// Backtest d'une entrée MOMENTUM : \"si le prix prend +M% en W bougies, on achète\n// même plus cher\" (au market, frais taker). Sorties identiques au bot actuel :\n// TP fixe + stop suiveur. À comparer avec la stratégie RSI sur la même fenêtre.\nimport { CONFIG, PAIRS, type PairConfig } from \"../config.ts\";\nimport { getOHLC } from \"../lib/kraken.ts\";\n\nconst HOURS = 72;\nconst CAPITAL = 10;\n\n// Variantes testées : gain minimal sur la fenêtre (en bougies 15 min)\nconst VARIANTS = [\n { label: \"+1.5% en 1h\", pct: 0.015, window: 4 },\n { label: \"+2% en 2h\", pct: 0.02, window: 8 },\n];\n\nfunction simulate(\n pc: PairConfig,\n momPct: number,\n momWindow: number,\n candles: { time: number; open: number; high: number; low: number; close: number }[],\n startIdx: number,\n) {\n let cash = CAPITAL;\n let position: { entry: number; volume: number; high: number } | null = null;\n let wins = 0, losses = 0;\n let fees = 0;\n\n for (let i = Math.max(startIdx, momWindow); i < candles.length; i++) {\n const c = candles[i];\n\n if (position) {\n const tpPrice = position.entry * (1 + pc.tpPct);\n const stop = position.high * (1 - pc.trailPct);\n if (c.low <= stop) {\n const sellPrice = Math.min(stop, c.open);\n const fee = sellPrice * position.volume * CONFIG.TAKER_FEE;\n cash += sellPrice * position.volume - fee;\n fees += fee;\n sellPrice >= position.entry ? wins++ : losses++;\n position = null;\n } else if (c.high >= tpPrice) {\n const fee = tpPrice * position.volume * CONFIG.TAKER_FEE;\n cash += tpPrice * position.volume - fee;\n fees += fee;\n wins++;\n position = null;\n } else if (c.high > position.high) {\n position.high = c.high;\n }\n }\n\n // Entrée momentum : le prix a pris momPct sur les momWindow dernières bougies\n if (!position) {\n const ref = candles[i - momWindow].close;\n if (c.close >= ref * (1 + momPct)) {\n const entry = c.close; // achat market (taker) au prix courant, \"plus cher\"\n const volume = (cash * (1 - CONFIG.CASH_BUFFER_PCT)) / entry;\n const fee = entry * volume * CONFIG.TAKER_FEE;\n cash -= entry * volume + fee;\n fees += fee;\n position = { entry, volume, high: entry };\n }\n }\n }\n\n const last = candles[candles.length - 1].close;\n const finalEquity = cash + (position ? position.volume * last : 0);\n return { finalEquity, wins, losses, fees, open: !!position };\n}\n\nfor (const pc of PAIRS) {\n const candles = await getOHLC(pc.pair, CONFIG.CANDLE_MINUTES);\n const cutoff = Date.now() / 1000 - HOURS * 3600;\n const startIdx = candles.findIndex((c) => c.time >= cutoff);\n const buyHold = ((candles[candles.length - 1].close - candles[startIdx].close) / candles[startIdx].close) * 100;\n\n const lines = [`=== ${pc.label}/EUR (buy & hold ${buyHold >= 0 ? \"+\" : \"\"}${buyHold.toFixed(2)}%) ===`];\n for (const v of VARIANTS) {\n const r = simulate(pc, v.pct, v.window, candles, startIdx);\n const pnlPct = ((r.finalEquity - CAPITAL) / CAPITAL) * 100;\n lines.push(\n ` ${v.label}: ${r.finalEquity.toFixed(2)} € (${pnlPct >= 0 ? \"+\" : \"\"}${pnlPct.toFixed(2)}%) · ` +\n `${r.wins}W/${r.losses}L · frais ${r.fees.toFixed(3)} €${r.open ? \" · position ouverte\" : \"\"}`,\n );\n }\n console.log(lines.join(\"\\n\"));\n}\n",[],[160,274],["D",1783544253770],[226,227,228,229,230],[160],"b001ee5f-e74f-4304-a6ee-436a2abe8011","switch-to-hold.ts","8697c19e-9049-11f1-8536-1607ee4eb77e",157,["D",1785878109034],"// One-shot : bascule du mode trading vers le mode ACCUMULATION (buy & hold).\n// - Annule tous les ordres de vente résidents (stops suiveurs) sur Kraken.\n// - Convertit les positions tactiques en détention (fold dans le cœur).\n// - Nettoie l'état tactique (positions, pendings, cooldowns, halts).\n// XRP/DOGE : leurs stops sont annulés, le reste est laissé intact (non géré).\nimport { cancelOrder } from \"../lib/kraken.ts\";\nimport { addToCore } from \"../lib/core.ts\";\nimport { initDb } from \"../lib/db.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nawait initDb();\n\n// 1. Annuler tous les stops suiveurs résidents + basculer les positions en détention.\nconst posRows = await sqlite.execute(\"SELECT key, value FROM state WHERE key LIKE 'position_live_%'\");\nfor (const row of posRows.rows) {\n const key = String(row.key);\n const pos = JSON.parse(String(row.value));\n const pairCode = key.replace(\"position_live_\", \"\");\n if (pos.exitOrderId) {\n try {\n await cancelOrder(pos.exitOrderId);\n console.log(`${pairCode}: stop ${pos.exitOrderId} annulé.`);\n } catch (e) {\n console.log(`${pairCode}: annulation stop impossible (déjà clos ?): ${e}`);\n }\n }\n // Fold la position tactique dans le cœur (détention pure) puis efface-la.\n await addToCore(\"live\", { pair: pairCode } as any, pos.volume, pos.entry * pos.volume);\n await sqlite.execute({ sql: \"DELETE FROM state WHERE key = ?\", args: [key] });\n console.log(`${pairCode}: position ${pos.volume} @ ${pos.entry} € basculée en détention (cœur).`);\n}\n\n// 2. Nettoyer pendings, cooldowns, halts de paire.\nawait sqlite.execute(\n \"DELETE FROM state WHERE key LIKE 'pending_live_%' OR key LIKE 'cooldown_live_%' OR key LIKE 'halted_live_%'\",\n);\nconsole.log(\"Pendings / cooldowns / halts nettoyés.\");\nconsole.log(\"Bascule terminée. Plus aucun ordre de vente actif.\");\n",[],[167,285],"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",[],[167,293],"a05bc219-0c48-430b-b38e-26bea90a62d5","migrate-trailing.ts","d97f612a-7b6b-11f1-aa18-1607ee4eb77e",63,["D",1783583856582],"// One-shot : remplace les anciens take-profits fixes par des stops suiveurs Kraken.\nimport { PAIRS } from \"../config.ts\";\nimport { addTrailingStop, cancelOrder, getTicker } from \"../lib/kraken.ts\";\nimport { getState, initDb, setState } from \"../lib/db.ts\";\n\nawait initDb();\nfor (const pc of PAIRS) {\n const key = `position_live_${pc.pair}`;\n const raw = await getState(key);\n if (!raw) {\n console.log(`${pc.label}: pas de position live.`);\n continue;\n }\n const pos = JSON.parse(raw);\n // 1. Annuler l'ancien TP fixe s'il existe\n if (pos.tpOrderId) {\n try {\n await cancelOrder(pos.tpOrderId);\n console.log(`${pc.label}: ancien TP ${pos.tpOrderId} annulé.`);\n } catch (e) {\n console.log(`${pc.label}: annulation TP impossible (${e}) — peut-être déjà exécuté, vérifier !`);\n }\n }\n // 2. Poser le stop suiveur\n const ticker = await getTicker(pc.pair);\n const newPos = {\n entry: pos.entry,\n volume: pos.volume,\n trailPct: pc.trailPct,\n highWater: Math.max(pos.entry, ticker.last),\n openedAt: pos.openedAt ?? Date.now(),\n } as any;\n try {\n newPos.exitOrderId = await addTrailingStop(pc.pair, String(pos.volume), pc.trailPct);\n console.log(`${pc.label}: stop suiveur posé (${newPos.exitOrderId}, trail ${pc.trailPct * 100}%).`);\n } catch (e) {\n console.log(`${pc.label}: échec stop suiveur (${e}) — surveillance par cycle en secours.`);\n }\n await setState(key, JSON.stringify(newPos));\n}\nconsole.log(\"Migration terminée.\");\n",[],[167,301],"5033da1e-f798-4e49-aa66-61df86c3b3ed","check.ts","d3803136-7b0d-11f1-9c3b-1607ee4eb77e",54,["D",1783580793995],"// Script de vérification de la configuration. À exécuter manuellement.\n// Vérifie : accès Kraken public (toutes paires), clés API privées, Telegram.\nimport { CONFIG, isLive, PAIRS } 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, par paire\n for (const pc of PAIRS) {\n try {\n const t = await getTicker(pc.pair);\n const info = await getPairInfo(pc.pair);\n report.push(`✅ ${pc.label}/EUR OK — ${t.last} € (min: ${info.ordermin} ${pc.label} / ${info.costmin} €)`);\n } catch (e) {\n report.push(`❌ ${pc.label}/EUR KO: ${e}`);\n }\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 held = PAIRS.map((pc) => `${b[pc.baseAsset] ?? 0} ${pc.label}`).join(\" · \");\n report.push(`✅ Clés Kraken OK — Solde: ${eur.toFixed(2)} € · ${held}`);\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 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(`⚠️ TELEGRAM_CHAT_ID non configuré — envoie /start à @${me.result.username} puis relance.`);\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 bot 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",[],[167,309],"00895f75-e460-478b-8bd0-16958858c2b9","balances.ts","e5a0ec02-7b71-11f1-9425-1607ee4eb77e",72,["D",1783586453911],"// Debug : affiche le solde Kraken brut, tous codes d'actifs confondus.\nimport { krakenPrivate } from \"../lib/kraken.ts\";\n\nconst result = await krakenPrivate(\"Balance\");\nfor (const [asset, amount] of Object.entries(result)) {\n if (parseFloat(amount as string) > 0) {\n console.log(`${asset}: ${amount}`);\n }\n}\n",[],[167,317],"455fb1f1-3eed-47b0-9376-bc5561e4847d","audit.ts","3e2391b0-7ebd-11f1-80ed-1607ee4eb77e",121,["D",1783948668150],"// Audit : frais réels Kraken (TradesHistory) + équité actuelle vs référence.\nimport { CONFIG, PAIRS } from \"../config.ts\";\nimport { getBalances, getTicker, krakenPrivate } from \"../lib/kraken.ts\";\nimport { getState, initDb } from \"../lib/db.ts\";\n\nawait initDb();\n\n// 1. Frais réels des dernières exécutions (source: Kraken)\nconst th = await krakenPrivate(\"TradesHistory\");\nconst trades = Object.values(th.trades ?? {}) as any[];\ntrades.sort((a, b) => Number(b.time) - Number(a.time));\nconsole.log(\"--- 12 dernières exécutions Kraken (réelles) ---\");\nfor (const t of trades.slice(0, 12)) {\n const d = new Date(Number(t.time) * 1000).toISOString().slice(5, 16);\n console.log(`${d} ${t.pair} ${t.type} vol=${t.vol} prix=${t.price} coût=${t.cost} frais=${t.fee}`);\n}\n\n// 2. Équité actuelle vs référence => gain réel de trading\nconst balances = await getBalances();\nlet equity = balances[CONFIG.QUOTE_ASSET] ?? 0;\nconst lines: string[] = [`cash EUR: ${(balances[CONFIG.QUOTE_ASSET] ?? 0).toFixed(2)} €`];\nfor (const pc of PAIRS) {\n const bal = balances[pc.baseAsset] ?? 0;\n if (bal > 0) {\n const t = await getTicker(pc.pair);\n equity += bal * t.last;\n lines.push(`${pc.label}: ${bal} × ${t.last} = ${(bal * t.last).toFixed(2)} €`);\n }\n}\nconst ref = Number((await getState(\"initial_equity_live\")) ?? 0);\nconsole.log(\"--- Équité ---\");\nconsole.log(lines.join(\"\\n\"));\nconsole.log(`Équité totale: ${equity.toFixed(2)} € · Référence (dépôts): ${ref.toFixed(2)} €`);\nconsole.log(`GAIN RÉEL TRADING: ${(equity - ref).toFixed(2)} €`);\n",[],[167,325],["D",1783543473813],[219,220,221,222,223,224],[167],"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",[],[173,336],"274a8903-b4d9-45b8-9c23-3d27b97591f8","kraken.ts","5b135c5a-7b0d-11f1-8e61-1607ee4eb77e",125,["D",1783948788472],4,"// 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\n// Nonce strictement croissant, à l'échelle de la microseconde + aléa : évite\n// les collisions \"EAPI:Invalid nonce\" quand deux crons appellent Kraken en\n// parallèle dans la même milliseconde.\nlet lastNonce = 0;\nfunction nextNonce(): string {\n let n = Date.now() * 1000 + Math.floor(Math.random() * 1000);\n if (n <= lastNonce) n = lastNonce + 1;\n lastNonce = n;\n return String(n);\n}\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 = nextNonce();\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\n// Stop suiveur natif Kraken : suit le plus haut en continu et vend au market\n// quand le prix retombe de offsetPct depuis ce plus haut (frais taker).\nexport async function addTrailingStop(\n pair: string,\n volume: string,\n offsetPct: number,\n): Promise {\n const result = await krakenPrivate(\"AddOrder\", {\n pair,\n type: \"sell\",\n ordertype: \"trailing-stop\",\n price: `+${(offsetPct * 100).toFixed(1)}%`,\n volume,\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",[],[173,343],"696a7ce2-8041-4164-9d57-4f587b5a9127","indicators.ts","635404be-7b0d-11f1-bd58-1607ee4eb77e",100,["D",1783883560851],"// 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\n// ATR (Average True Range) en fraction du dernier prix — mesure l'amplitude\n// réelle des oscillations. Lissage de Wilder, comme le RSI.\nexport function atrPct(\n candles: { high: number; low: number; close: number }[],\n period: number,\n): number | null {\n if (candles.length < period + 1) return null;\n const trs: number[] = [];\n for (let i = 1; i < candles.length; i++) {\n const c = candles[i];\n const prevClose = candles[i - 1].close;\n trs.push(\n Math.max(c.high - c.low, Math.abs(c.high - prevClose), Math.abs(c.low - prevClose)),\n );\n }\n let atr = trs.slice(0, period).reduce((a, b) => a + b, 0) / period;\n for (let i = period; i < trs.length; i++) {\n atr = (atr * (period - 1) + trs[i]) / period;\n }\n return atr / candles[candles.length - 1].close;\n}\n",[],[173,352],"f1902363-d7d7-493a-b1c9-8b63b2f21ccc","engine.ts","a9f3cda0-7b0d-11f1-9c27-1607ee4eb77e",167,["D",1785878295336],51,"// Moteur de trading multi-paires. 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.\n// Sorties par STOP SUIVEUR natif Kraken : le stop suit le plus haut en continu\n// (exécution instantanée côté Kraken). Il sert de stop-loss ET de prise de gains.\n// Kill-switch GLOBAL : équité < -20% du capital initial => tout liquider, arrêt définitif.\nimport { CONFIG, isLive, PAIRS, type PairConfig } from \"../config.ts\";\nimport {\n addLimitPostOnly,\n addMarketOrder,\n addTrailingStop,\n cancelOrder,\n getBalances,\n getOHLC,\n getPairInfo,\n getTicker,\n queryOrder,\n type Candle,\n type PairInfo,\n type Ticker,\n} from \"./kraken.ts\";\nimport { atrPct, rsi, sma } from \"./indicators.ts\";\nimport { addToCore, liquidateCore, maintainCore, readCore } from \"./core.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 trailPct: number;\n tpPct?: number; // TP adaptatif figé à l'ouverture (secours: config paire)\n highWater: number; // plus haut observé depuis l'ouverture (suivi local)\n exitOrderId?: string; // stop suiveur résident Kraken (live uniquement)\n openedAt: number;\n}\n\n// Sorties adaptatives : dimensionnées sur la volatilité mesurée (ATR),\n// bornées, avec les valeurs de la paire en secours.\nfunction adaptiveExits(pc: PairConfig, atr: number | null): { tpPct: number; trailPct: number } {\n if (atr === null) return { tpPct: pc.tpPct, trailPct: pc.trailPct };\n const clamp = (x: number, lo: number, hi: number) => Math.min(Math.max(x, lo), hi);\n return {\n tpPct: clamp(atr * CONFIG.ATR_TP_MULT, CONFIG.TP_MIN, CONFIG.TP_MAX),\n trailPct: clamp(atr * CONFIG.ATR_TRAIL_MULT, CONFIG.TRAIL_MIN, CONFIG.TRAIL_MAX),\n };\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}\nconst fmt = (x: number, d = 2) => x.toFixed(d);\n\nconst posKey = (mode: string, pc: PairConfig) => `position_${mode}_${pc.pair}`;\nconst pendKey = (mode: string, pc: PairConfig) => `pending_${mode}_${pc.pair}`;\nconst refKey = (mode: string, pc: PairConfig) => `ref_${mode}_${pc.pair}`; // capital engagé max sur la paire\nconst cumKey = (mode: string, pc: PairConfig) => `pnl_cum_${mode}_${pc.pair}`; // PnL réalisé cumulé (EUR)\nconst haltKey = (mode: string, pc: PairConfig) => `halted_${mode}_${pc.pair}`; // kill-switch de la paire\n\nasync function isPairHalted(mode: string, pc: PairConfig): Promise {\n return (await getState(haltKey(mode, pc))) === \"1\";\n}\n\nasync function addRealized(\n mode: string,\n pc: PairConfig,\n deltaEur: number,\n opts?: { isExit?: boolean },\n): Promise {\n const cur = Number((await getState(cumKey(mode, pc))) ?? 0);\n await setState(cumKey(mode, pc), String(cur + deltaEur));\n // Sortie perdante => délai anti-churn avant tout rachat de cette paire\n // (les frais d'achat, négatifs par nature, ne déclenchent pas le délai)\n if ((opts?.isExit ?? true) && deltaEur < 0) {\n await setState(`cooldown_${mode}_${pc.pair}`, String(Date.now()));\n }\n}\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 PairStatus {\n pair: string;\n label: string;\n rsiBuyBelow: number;\n trailPct: number;\n tpPct: number;\n halted: boolean;\n ticker: Ticker;\n position: Position | null;\n pending: PendingBuy | null;\n baseBalance: number; // part TACTIQUE uniquement (hors cœur)\n valueEur: number; // valeur de la part tactique\n coreVolume: number; // volume détenu en cœur (buy & hold)\n coreValueEur: number; // valeur du cœur pour cette paire\n coreCost: number; // prix de revient cumulé du cœur (EUR)\n}\n\nexport interface Portfolio {\n mode: \"live\" | \"paper\";\n eur: number;\n equity: number;\n coreValue: number; // valeur totale du cœur buy & hold\n coreCost: number; // prix de revient total du cœur (EUR)\n initialEquity: number | null;\n halted: boolean;\n pairs: PairStatus[];\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 halted = (await getState(\"halted\")) === \"1\";\n const initRaw = await getState(`initial_equity_${mode}`);\n\n let balances: Record = {};\n let eur: number;\n if (mode === \"live\") {\n balances = await getBalances();\n eur = balances[CONFIG.QUOTE_ASSET] ?? balances[\"EUR\"] ?? 0;\n } else {\n const cashRaw = await getState(\"paper_eur\");\n eur = cashRaw !== null ? Number(cashRaw) : CONFIG.INITIAL_CAPITAL_EUR;\n }\n\n const pairs: PairStatus[] = [];\n let equity = eur;\n let coreValueTotal = 0;\n let coreCostTotal = 0;\n for (const pc of PAIRS) {\n const ticker = await getTicker(pc.pair);\n const position = await getJson(posKey(mode, pc));\n const pending = await getJson(pendKey(mode, pc));\n const core = await readCore(mode, pc);\n const coreValueEur = core.volume * ticker.last;\n coreValueTotal += coreValueEur;\n coreCostTotal += core.cost;\n\n // Balance totale détenue sur la paire (cœur + tactique)\n const fullBalance = mode === \"live\"\n ? balances[pc.baseAsset] ?? 0\n : (position?.volume ?? 0) + core.volume;\n // La part TACTIQUE = tout ce qui n'est pas le cœur (jamais négatif)\n const baseBalance = Math.max(fullBalance - core.volume, 0);\n equity += fullBalance * ticker.last; // équité sur la balance COMPLÈTE\n pairs.push({\n pair: pc.pair,\n label: pc.label,\n rsiBuyBelow: pc.rsiBuyBelow,\n trailPct: pc.trailPct,\n tpPct: pc.tpPct,\n halted: await isPairHalted(mode, pc),\n ticker,\n position,\n pending,\n baseBalance,\n valueEur: baseBalance * ticker.last,\n coreVolume: core.volume,\n coreValueEur,\n coreCost: core.cost,\n });\n }\n\n return {\n mode,\n eur,\n equity,\n coreValue: coreValueTotal,\n coreCost: coreCostTotal,\n initialEquity: initRaw !== null ? Number(initRaw) : null,\n halted,\n pairs,\n };\n}\n\n// Ouvre une position : état + stop suiveur résident (live).\n// tpPct/trailPct : sorties adaptatives calculées à l'entrée (ATR).\nasync function openPosition(\n pc: PairConfig,\n mode: \"live\" | \"paper\",\n entry: number,\n volume: number,\n fee: number,\n reason: string,\n exits?: { tpPct: number; trailPct: number },\n): Promise {\n const tpPct = exits?.tpPct ?? pc.tpPct;\n const trailPct = exits?.trailPct ?? pc.trailPct;\n const newPos: Position = {\n entry,\n volume,\n trailPct,\n tpPct,\n highWater: entry,\n openedAt: Date.now(),\n };\n if (mode === \"live\") {\n try {\n newPos.exitOrderId = await addTrailingStop(pc.pair, String(volume), trailPct);\n } catch (e) {\n await logEvent(\"warn\", `${pc.label}: stop suiveur rejeté (${e}) — surveillance par cycle en secours`);\n }\n }\n await setState(posKey(mode, pc), JSON.stringify(newPos));\n await logTrade(mode, pc.label, \"buy\", entry, volume, fee, reason);\n // Référence de capital engagé pour le kill-switch de la paire\n const ref = Number((await getState(refKey(mode, pc))) ?? 0);\n if (entry * volume > ref) {\n await setState(refKey(mode, pc), String(entry * volume));\n }\n return newPos;\n}\n\n// ---- Cycle de trading (appelé toutes les 5 min via 3 crons décalés) ----\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 // Verrou anti-chevauchement : 3 crons décalés de 5 min appellent ce cycle ;\n // si un cycle a démarré il y a moins de 60 s (retry, chevauchement), on saute.\n const lastStart = await getState(\"last_cycle_start\");\n if (lastStart && Date.now() - Number(lastStart) < 60_000) {\n console.log(\"Cycle sauté — un autre vient de démarrer.\");\n return;\n }\n await setState(\"last_cycle_start\", String(Date.now()));\n\n // Données de marché par paire (bougies clôturées pour tous les indicateurs)\n const market = new Map<\n string,\n { candles: Candle[]; rsi: number | null; atr: number | null; smaTrend: number | null; ticker: Ticker; info: PairInfo }\n >();\n for (const pc of PAIRS) {\n const candles = await getOHLC(pc.pair, CONFIG.CANDLE_MINUTES);\n const closed = candles.slice(0, -1); // dernière bougie en cours exclue\n const closes = closed.map((c) => c.close);\n market.set(pc.pair, {\n candles,\n rsi: rsi(closes, CONFIG.RSI_PERIOD),\n atr: atrPct(closed, CONFIG.ATR_PERIOD),\n smaTrend: sma(closes, CONFIG.TREND_SMA_CANDLES),\n ticker: await getTicker(pc.pair),\n info: await getPairInfo(pc.pair),\n });\n }\n\n // MODE ACCUMULATION : buy-and-hold pur. On n'achète que (DCA vers le cœur),\n // on ne vend jamais. Court-circuite reconcile-ventes / kill-switch / trading.\n if (CONFIG.ACCUMULATE_ONLY) {\n for (const pc of PAIRS) {\n const m = market.get(pc.pair)!;\n if (mode === \"live\") await adoptExisting(pc, mode, m.ticker, m.info); // dépôts → cœur\n }\n const pAcc = await readPortfolio();\n await logSnapshot(mode, pAcc.equity, market.get(PAIRS[0].pair)!.ticker.last, market.get(PAIRS[0].pair)!.rsi);\n const cashAcc = Math.max(pAcc.eur - pAcc.equity * CONFIG.CASH_BUFFER_PCT, 0);\n await maintainCore(mode, pAcc.equity, cashAcc, market);\n return;\n }\n\n // 1. Réconciliation + adoption, par paire\n for (const pc of PAIRS) {\n const m = market.get(pc.pair)!;\n await reconcile(pc, mode, m.candles, m.ticker);\n if (mode === \"live\") await adoptExisting(pc, mode, m.ticker, m.info);\n }\n\n // 2. État global + snapshot\n const p = await readPortfolio();\n await logSnapshot(mode, p.equity, market.get(PAIRS[0].pair)!.ticker.last, market.get(PAIRS[0].pair)!.rsi);\n\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 GLOBAL — priorité absolue\n if (initial !== null && p.equity < initial * (1 - CONFIG.KILL_SWITCH_DRAWDOWN)) {\n await triggerKillSwitch(mode, p, market);\n return;\n }\n\n // 3.5. CŒUR buy-and-hold : maintient CORE_TARGET_PCT de l'équité investie en\n // permanence (suit le marché). Déployé progressivement (DCA). S'exécute quel\n // que soit l'état du marché (accumuler dans les creux est le principe du DCA).\n const coreCash = Math.max(p.eur - p.equity * CONFIG.CASH_BUFFER_PCT, 0);\n const coreSpent = await maintainCore(mode, p.equity, coreCash, market);\n\n // 4. Sorties par paire : kill-switch de paire, prise de gains fixe, secours trailing\n for (const pc of PAIRS) {\n const m = market.get(pc.pair)!;\n const position = await getJson(posKey(mode, pc));\n if (!position) continue;\n\n // 4a. KILL-SWITCH DE LA PAIRE : PnL cumulé (réalisé + latent) sous -20% du\n // capital engagé => liquidation de CETTE paire et désactivation, les autres continuent.\n const pairRef = Number((await getState(refKey(mode, pc))) ?? 0);\n const realized = Number((await getState(cumKey(mode, pc))) ?? 0);\n const unrealized = (m.ticker.bid - position.entry) * position.volume;\n if (pairRef > 0 && realized + unrealized <= -CONFIG.PAIR_KILL_DRAWDOWN * pairRef) {\n await exitPosition(pc, mode, position, m.ticker, \"kill-switch paire\");\n await setState(haltKey(mode, pc), \"1\");\n await logEvent(\"error\", `${pc.label}: KILL-SWITCH PAIRE (PnL ${fmt(realized + unrealized)} € / réf ${fmt(pairRef)} €) — paire désactivée.`);\n await sendTelegram(\n `🔴 Kill-switch ${pc.label} (${mode})\\n` +\n `PnL cumulé ${fmt(realized + unrealized)} € (seuil -${CONFIG.PAIR_KILL_DRAWDOWN * 100}% de ${fmt(pairRef)} €).\\n` +\n `${pc.label} liquidé et désactivé — les autres paires continuent.\\n` +\n `Réactivation : setup/reset.ts`,\n );\n continue;\n }\n\n // 4b. PRISE DE GAINS : seuil adaptatif figé à l'ouverture (secours: config paire)\n const tpPct = position.tpPct ?? pc.tpPct;\n const pnlPct = (m.ticker.bid - position.entry) / position.entry;\n if (pnlPct >= tpPct) {\n await exitPosition(pc, mode, position, m.ticker, \"take-profit\");\n await notifyExit(pc, mode, position, m.ticker.bid, `take-profit +${(tpPct * 100).toFixed(1)}%`);\n continue;\n }\n\n // 4c. Mise à jour du plus haut local (les bougies depuis l'ouverture + prix courant)\n const since = position.openedAt / 1000 - CONFIG.CANDLE_MINUTES * 60;\n let high = Math.max(position.highWater ?? position.entry, m.ticker.last);\n for (const c of m.candles) {\n if (c.time >= since && c.high > high) high = c.high;\n }\n if (high > (position.highWater ?? 0)) {\n position.highWater = high;\n await setState(posKey(mode, pc), JSON.stringify(position));\n }\n const stopLevel = high * (1 - position.trailPct);\n\n if (mode === \"live\" && !position.exitOrderId) {\n // Secours : re-tente de poser le stop suiveur, sinon surveille par cycle\n try {\n position.exitOrderId = await addTrailingStop(pc.pair, String(position.volume), position.trailPct);\n await setState(posKey(mode, pc), JSON.stringify(position));\n await logEvent(\"info\", `${pc.label}: stop suiveur posé (rattrapage)`);\n } catch (_) {\n if (m.ticker.bid <= stopLevel) {\n await exitPosition(pc, mode, position, m.ticker, \"stop suiveur (secours)\");\n await notifyExit(pc, mode, position, m.ticker.bid, \"stop suiveur (secours)\");\n }\n }\n } else if (mode === \"paper\") {\n if (m.ticker.bid <= stopLevel) {\n await exitPosition(pc, mode, position, { ...m.ticker, bid: stopLevel }, \"stop suiveur\");\n await notifyExit(pc, mode, position, stopLevel, \"stop suiveur\");\n }\n }\n }\n\n // 5. Entrées par paire (pot commun de cash, plafond allocPct de l'équité)\n let reserved = 0;\n for (const pc of PAIRS) {\n const pend = await getJson(pendKey(mode, pc));\n if (pend) reserved += pend.price * pend.volume;\n }\n\n // PORTE DE MARCHÉ GLOBALE : BTC sous sa moyenne 24h = marché baissier\n // généralisé, aucune nouvelle entrée nulle part (les cryptos chutent ensemble).\n const btcM = market.get(PAIRS[0].pair)!;\n if (btcM.smaTrend !== null && btcM.ticker.last < btcM.smaTrend * CONFIG.MARKET_GATE_TOLERANCE) {\n await logEvent(\n \"info\",\n `Porte de marché fermée : BTC ${fmt(btcM.ticker.last, 1)} € < SMA24h ${fmt(btcM.smaTrend, 1)} € — aucune nouvelle entrée.`,\n );\n return;\n }\n\n // Candidats : survente confirmée + filtre de régime, triés par profondeur\n // de survente (le RSI le plus bas est servi en premier).\n const candidates: { pc: PairConfig; r: number }[] = [];\n for (const pc of PAIRS) {\n const m = market.get(pc.pair)!;\n const r = m.rsi;\n if (r === null || r >= pc.rsiBuyBelow) continue;\n if (await isPairHalted(mode, pc)) continue; // paire désactivée : pas d'entrée\n // Anti-churn : la paire vient de sortir en perte, on laisse la chute se calmer\n const cd = await getState(`cooldown_${mode}_${pc.pair}`);\n if (cd && Date.now() - Number(cd) < CONFIG.REENTRY_COOLDOWN_MIN * 60_000) continue;\n // Filtre de régime : survente en chute installée = couteau qui tombe, on passe\n if (m.smaTrend !== null && m.ticker.last < m.smaTrend * CONFIG.TREND_MAX_DISCOUNT) {\n await logEvent(\n \"info\",\n `${pc.label}: survente (RSI ${fmt(r, 1)}) ignorée — prix ${fmt(m.ticker.last, 4)} € trop enfoncé sous la moyenne 24h (${fmt(m.smaTrend, 4)} €)`,\n );\n continue;\n }\n candidates.push({ pc, r });\n }\n candidates.sort((a, b) => a.r - b.r);\n\n let newEntries = 0;\n for (const { pc, r } of candidates) {\n if (newEntries >= CONFIG.MAX_NEW_ENTRIES_PER_CYCLE) break; // anti-corrélation\n const m = market.get(pc.pair)!;\n const position = await getJson(posKey(mode, pc));\n const pending = await getJson(pendKey(mode, pc));\n if (position || pending) continue;\n\n // Cash tactique = cash − ce que le cœur vient de dépenser − ordres réservés\n // − réserve de 15% (jamais investie).\n const availCash = Math.max(p.eur - coreSpent - reserved - p.equity * CONFIG.CASH_RESERVE_PCT, 0) *\n (1 - CONFIG.CASH_BUFFER_PCT);\n const spend = Math.min(availCash, p.equity * pc.allocPct);\n const price = floorTo(m.ticker.bid, m.info.priceDecimals);\n const volume = floorTo(spend / price, m.info.lotDecimals);\n if (volume < m.info.ordermin || volume * price < m.info.costmin) {\n await logEvent(\n \"warn\",\n `${pc.label}: signal d'achat (RSI ${fmt(r, 1)}) mais cash dispo insuffisant (${fmt(availCash)} €)`,\n );\n continue;\n }\n const newPending: PendingBuy = { price, volume, placedAt: Date.now() };\n if (mode === \"live\") {\n try {\n newPending.txid = await addLimitPostOnly(pc.pair, \"buy\", String(volume), String(price));\n } catch (e) {\n await logEvent(\"error\", `${pc.label}: échec ordre d'achat: ${e}`);\n continue;\n }\n }\n await setState(pendKey(mode, pc), JSON.stringify(newPending));\n reserved += price * volume;\n newEntries++;\n await logEvent(\"info\", `${pc.label}: ordre d'achat posé ${volume} @ ${price} € (RSI ${fmt(r, 1)})`);\n await sendTelegram(\n `📥 Ordre d'achat posé — ${pc.label} (${mode})\\n${volume} ${pc.label} @ ${price} € — RSI ${fmt(r, 1)}\\n(limite post-only, frais maker)`,\n );\n }\n}\n\nasync function notifyExit(\n pc: PairConfig,\n mode: string,\n position: Position,\n sellPrice: number,\n reason: string,\n): Promise {\n const pnlPct = ((sellPrice - position.entry) / position.entry) * 100;\n const pnlEur = (sellPrice - position.entry) * position.volume;\n const emoji = pnlEur >= 0 ? \"🎯\" : \"🛑\";\n await sendTelegram(\n `${emoji} Vente ${pc.label} (${mode}) — ${reason}\\n` +\n `${fmt(position.volume, pc.volDecimals)} ${pc.label} @ ~${fmt(sellPrice, 4)} €\\n` +\n `Résultat : ${pnlEur >= 0 ? \"+\" : \"\"}${fmt(pnlEur)} € (${pnlPct >= 0 ? \"+\" : \"\"}${fmt(pnlPct)}%)`,\n );\n}\n\n// Adopte un solde crypto déposé manuellement DANS LE CŒUR (buy-and-hold).\n// Un dépôt est traité comme une épargne qui suit le marché — jamais un trade\n// tactique à stop serré (leçon du SOL adopté puis stoppé -6,19 € le 13/07).\n// Le \"vrai\" dépôt est isolé en soustrayant le cœur et le tactique déjà connus,\n// pour ne jamais recompter les achats du bot (leçon du dépôt fantôme du 15/07).\nasync function adoptExisting(\n pc: PairConfig,\n mode: \"live\" | \"paper\",\n ticker: Ticker,\n info: PairInfo,\n): Promise {\n if (mode !== \"live\") return; // le paper n'a pas de balance externe\n const balances = await getBalances();\n const fullBal = balances[pc.baseAsset] ?? 0;\n const core = await readCore(mode, pc);\n const tactical = await getJson(posKey(mode, pc));\n const untracked = fullBal - core.volume - (tactical?.volume ?? 0);\n if (untracked < info.ordermin) return;\n\n const entry = ticker.last;\n await addToCore(mode, pc, untracked, untracked * entry);\n await logEvent(\"info\", `${pc.label}: dépôt ${untracked} adopté dans le cœur @ ${entry} €`);\n\n // Recalage du capital de référence : un dépôt n'est pas un gain de trading.\n let refLine = \"\";\n const initRaw = await getState(`initial_equity_${mode}`);\n if (initRaw !== null) {\n const newRef = Number(initRaw) + entry * untracked;\n await setState(`initial_equity_${mode}`, String(newRef));\n await logEvent(\"info\", `Référence recalée après dépôt ${pc.label}: ${fmt(Number(initRaw))} € → ${fmt(newRef)} €`);\n refLine = `\\n💰 Référence recalée : ${fmt(newRef)} € · kill-switch ${fmt(newRef * (1 - CONFIG.KILL_SWITCH_DRAWDOWN))} €`;\n }\n\n await sendTelegram(\n `🏛️ Dépôt ajouté au cœur — ${pc.label} (${mode})\\n` +\n `${untracked} ${pc.label} (≈ ${fmt(untracked * entry)} €) rejoignent le panier buy-and-hold.\\n` +\n `Il suit le marché à la hausse comme à la baisse ; protégé par le kill-switch global.` +\n refLine,\n );\n}\n\n// Réconcilie ordres en attente / stop suiveur avec la réalité (Kraken ou simulation).\nasync function reconcile(\n pc: PairConfig,\n mode: \"live\" | \"paper\",\n candles: Candle[],\n ticker: Ticker,\n): Promise {\n const pending = await getJson(pendKey(mode, pc));\n const position = await getJson(posKey(mode, pc));\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(pendKey(mode, pc));\n // Exécution PARTIELLE avant annulation : la partie achetée devient une\n // position (bug du 15/07 : fills partiels perdus puis re-comptés en \"dépôt\")\n if (o.volExec > 0) {\n filled = true;\n fillPrice = o.avgPrice || pending.price;\n fillVolume = o.volExec;\n fee = o.feeEur;\n await logEvent(\"warn\", `${pc.label}: ordre ${o.status} avec exécution partielle ${o.volExec} — position ouverte`);\n } else {\n await logEvent(\"info\", `${pc.label}: ordre d'achat ${o.status}`);\n }\n } else if (ageMin > pc.entryTtlMin) {\n try {\n await cancelOrder(pending.txid);\n } catch (e) {\n await logEvent(\"warn\", `${pc.label}: annulation TTL impossible (${e}) — re-vérification au prochain cycle`);\n return; // l'ordre a peut-être été exécuté entre-temps : on re-vérifiera\n }\n // Après annulation, vérifier s'il y a eu exécution partielle entre-temps\n const o2 = await queryOrder(pending.txid);\n await delState(pendKey(mode, pc));\n if (o2.volExec > 0) {\n filled = true;\n fillPrice = o2.avgPrice || pending.price;\n fillVolume = o2.volExec;\n fee = o2.feeEur;\n await logEvent(\"warn\", `${pc.label}: annulé après TTL mais partiellement exécuté ${o2.volExec} — position ouverte`);\n } else {\n await logEvent(\"info\", `${pc.label}: ordre d'achat annulé après ${fmt(ageMin, 0)} min`);\n }\n }\n } else if (mode === \"paper\") {\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 > pc.entryTtlMin) {\n await delState(pendKey(mode, pc));\n await logEvent(\"info\", `${pc.label}: ordre d'achat simulé expiré`);\n }\n }\n\n if (filled) {\n await delState(pendKey(mode, pc));\n const exits = adaptiveExits(pc, atrPct(candles.slice(0, -1), CONFIG.ATR_PERIOD));\n const pos = await openPosition(pc, mode, fillPrice, fillVolume, fee, \"entrée RSI\", exits);\n if (fee > 0) await addRealized(mode, pc, -fee, { isExit: false }); // frais d'achat comptés dans le PnL\n await logEvent(\"info\", `${pc.label}: achat exécuté ${fillVolume} @ ${fillPrice} €`);\n await sendTelegram(\n `✅ Achat exécuté — ${pc.label} (${mode})\\n${fillVolume} ${pc.label} @ ${fillPrice} €\\n` +\n `📉 Stop suiveur ${(pc.trailPct * 100).toFixed(1)}% posé${pos.exitOrderId ? \" (résident Kraken)\" : \"\"}`,\n );\n }\n return;\n }\n\n // --- Stop suiveur résident : vérifier s'il s'est exécuté (live) ---\n if (position && mode === \"live\" && position.exitOrderId) {\n const o = await queryOrder(position.exitOrderId);\n if (o.status === \"closed\") {\n const sellPrice = o.avgPrice || ticker.bid;\n await delState(posKey(mode, pc));\n await logTrade(mode, pc.label, \"sell\", sellPrice, position.volume, o.feeEur, \"stop suiveur\");\n await addRealized(mode, pc, (sellPrice - position.entry) * position.volume - o.feeEur);\n await logEvent(\"info\", `${pc.label}: stop suiveur exécuté @ ${sellPrice} €`);\n await notifyExit(pc, mode, position, sellPrice, \"stop suiveur\");\n } else if (o.status === \"canceled\" || o.status === \"expired\") {\n // L'ordre a disparu (annulation manuelle ?) : on retente au prochain cycle\n position.exitOrderId = undefined;\n await setState(posKey(mode, pc), JSON.stringify(position));\n await logEvent(\"warn\", `${pc.label}: stop suiveur ${o.status} — repose au prochain cycle`);\n }\n }\n}\n\n// Sortie de position au marché (secours ou kill-switch).\nasync function exitPosition(\n pc: PairConfig,\n mode: \"live\" | \"paper\",\n position: Position,\n ticker: Ticker,\n reason: string,\n): Promise {\n const fee = ticker.bid * position.volume * CONFIG.TAKER_FEE;\n if (mode === \"live\") {\n if (position.exitOrderId) {\n try {\n await cancelOrder(position.exitOrderId);\n } catch (e) {\n await logEvent(\"warn\", `${pc.label}: annulation stop impossible (déjà clos ?): ${e}`);\n }\n }\n await addMarketOrder(pc.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(posKey(mode, pc));\n await logTrade(mode, pc.label, \"sell\", ticker.bid, position.volume, fee, reason);\n await addRealized(mode, pc, (ticker.bid - position.entry) * position.volume - fee);\n await logEvent(\"warn\", `${pc.label}: sortie market (${reason}) @ ~${ticker.bid} €`);\n}\n\nasync function triggerKillSwitch(\n mode: \"live\" | \"paper\",\n p: Portfolio,\n market: Map,\n): Promise {\n // Annuler tous les ordres en attente, tout liquider, arrêter définitivement.\n for (const pc of PAIRS) {\n const pending = await getJson(pendKey(mode, pc));\n if (pending?.txid && mode === \"live\") {\n try {\n await cancelOrder(pending.txid);\n } catch (_) { /* déjà clos */ }\n }\n await delState(pendKey(mode, pc));\n\n const position = await getJson(posKey(mode, pc));\n if (position) {\n await exitPosition(pc, mode, position, market.get(pc.pair)!.ticker, \"kill-switch\");\n }\n }\n // Le cœur buy-and-hold est liquidé lui aussi (filet ultime).\n await liquidateCore(mode, market);\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",[],[173,360],"9bb52111-7df8-4fc9-a72b-362c2db8bfac","db.ts","71ff2ac0-7b0d-11f1-8026-1607ee4eb77e",47,["D",1783580576150],"// 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 // Migration multi-paires : colonne pair sur les trades\n try {\n await sqlite.execute(\"ALTER TABLE trades ADD COLUMN pair TEXT NOT NULL DEFAULT 'BTC'\");\n } catch (_) { /* déjà migrée */ }\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 pairLabel: 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, pair, side, price, volume, fee_eur, reason) VALUES (?, ?, ?, ?, ?, ?, ?, ?)\",\n args: [new Date().toISOString(), mode, pairLabel, 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",[],[173,369],"c90eb9ed-85d6-46f7-8417-ebc203efb086","core.ts","db79be80-8543-11f1-99a3-1607ee4eb77e",139,["D",1784666191655],"// Cœur buy-and-hold (modèle cœur-satellite).\n// Le cœur est un panier diversifié maintenu à CORE_TARGET_PCT de l'équité : il\n// SUIT le marché (monte avec les hausses, baisse avec les baisses). Il n'est\n// JAMAIS vendu par take-profit ni stop suiveur — seul le kill-switch global le\n// liquide. Acheté au marché (fill garanti), déployé progressivement (DCA) pour\n// ne pas tout acheter au même instant sur un pic.\n//\n// Traçabilité stricte : le volume \"cœur\" est stocké séparément (clé core_*).\n// Le système tactique lit balance_Kraken - volume_cœur, donc les deux ne se\n// confondent jamais (c'est ce mélange qui avait causé le bug du dépôt fantôme).\nimport { CONFIG, PAIRS, type PairConfig } from \"../config.ts\";\nimport { addMarketOrder, type Ticker } from \"./kraken.ts\";\nimport { delState, getState, logEvent, logTrade, setState } from \"./db.ts\";\nimport { sendTelegram } from \"./telegram.ts\";\n\nexport interface CoreHolding {\n volume: number;\n cost: number; // coût d'acquisition cumulé (EUR, frais inclus)\n}\n\nconst coreKey = (mode: string, pc: PairConfig) => `core_${mode}_${pc.pair}`;\n\nexport async function readCore(mode: string, pc: PairConfig): Promise {\n const raw = await getState(coreKey(mode, pc));\n return raw ? (JSON.parse(raw) as CoreHolding) : { volume: 0, cost: 0 };\n}\n\nasync function writeCore(mode: string, pc: PairConfig, h: CoreHolding): Promise {\n await setState(coreKey(mode, pc), JSON.stringify(h));\n}\n\n// Ajoute du volume au cœur (dépôt adopté en buy-and-hold, ou renfort).\nexport async function addToCore(mode: string, pc: PairConfig, volume: number, cost: number): Promise {\n const h = await readCore(mode, pc);\n await writeCore(mode, pc, { volume: h.volume + volume, cost: h.cost + cost });\n}\n\nconst fmt = (x: number, d = 2) => x.toFixed(d);\n\ntype MarketInfo = Map;\n\n// Valeur totale du cœur (EUR) au prix courant, et détail par paire.\nexport async function coreSummary(\n mode: string,\n market: MarketInfo,\n): Promise<{ total: number; cost: number; byPair: Map }> {\n const byPair = new Map();\n let total = 0, cost = 0;\n for (const pc of PAIRS) {\n const h = await readCore(mode, pc);\n const value = h.volume * (market.get(pc.pair)?.ticker.last ?? 0);\n total += value;\n cost += h.cost;\n byPair.set(pc.pair, { vol: h.volume, value, cost: h.cost });\n }\n return { total, cost, byPair };\n}\n\n// Maintient le cœur à CORE_TARGET_PCT de l'équité (achats marché, DCA).\n// Retourne le cash EUR dépensé ce cycle (pour l'accounting du satellite).\nexport async function maintainCore(\n mode: \"live\" | \"paper\",\n equity: number,\n cashAvailable: number,\n market: MarketInfo,\n): Promise {\n const { total: coreVal } = await coreSummary(mode, market);\n const target = equity * CONFIG.CORE_TARGET_PCT;\n\n // Déjà dans la bande de tolérance : rien à faire (évite le sur-trading).\n if (coreVal >= target * (1 - CONFIG.CORE_REBALANCE_BAND)) return 0;\n\n const gap = target - coreVal;\n const budget = Math.min(gap, equity * CONFIG.CORE_DCA_PER_CYCLE, cashAvailable);\n if (budget < 1) return 0;\n\n // Cibler les paires les plus sous-pondérées (cible par paire = target × allocPct).\n const perPair: { pc: PairConfig; gap: number }[] = [];\n for (const pc of PAIRS) {\n const h = await readCore(mode, pc);\n const value = h.volume * (market.get(pc.pair)?.ticker.last ?? 0);\n perPair.push({ pc, gap: Math.max(0, target * pc.allocPct - value) });\n }\n perPair.sort((a, b) => b.gap - a.gap);\n const picks = perPair.filter((x) => x.gap > 0).slice(0, 2); // 2 paires/cycle max\n if (picks.length === 0) return 0;\n\n let spent = 0;\n const per = budget / picks.length;\n for (const { pc } of picks) {\n const m = market.get(pc.pair)!;\n const price = m.ticker.ask; // achat marché ≈ ask\n const spend = Math.min(per, budget - spent);\n const f = 10 ** m.info.lotDecimals;\n const volume = Math.floor((spend / price) * f) / f;\n if (volume < m.info.ordermin || volume * price < m.info.costmin) continue;\n const fee = volume * price * CONFIG.TAKER_FEE;\n if (mode === \"live\") {\n try {\n await addMarketOrder(pc.pair, \"buy\", String(volume));\n } catch (e) {\n await logEvent(\"error\", `${pc.label}: achat cœur échoué: ${e}`);\n continue;\n }\n } else {\n const cash = Number((await getState(\"paper_eur\")) ?? 0);\n await setState(\"paper_eur\", String(cash - volume * price - fee));\n }\n await addToCore(mode, pc, volume, volume * price + fee);\n await logTrade(mode, pc.label, \"buy\", price, volume, fee, \"cœur (buy & hold)\");\n await logEvent(\"info\", `${pc.label}: cœur +${volume} @ ~${price} € (${fmt(spend, 0)} €)`);\n spent += volume * price + fee;\n }\n\n if (spent > 0) {\n const { total: newCore } = await coreSummary(mode, market);\n await sendTelegram(\n `🏛️ Cœur renforcé (${mode})\\n` +\n `+${fmt(spent)} € investis en buy-and-hold (suit le marché).\\n` +\n `Cœur : ${fmt(newCore)} € / cible ${fmt(target)} € (${CONFIG.CORE_TARGET_PCT * 100}% de l'équité).`,\n );\n }\n return spent;\n}\n\n// Liquide tout le cœur au marché (kill-switch global uniquement).\nexport async function liquidateCore(mode: \"live\" | \"paper\", market: Map): Promise {\n for (const pc of PAIRS) {\n const h = await readCore(mode, pc);\n if (h.volume > 0) {\n const bid = market.get(pc.pair)?.ticker.bid ?? 0;\n if (mode === \"live\") {\n try {\n await addMarketOrder(pc.pair, \"sell\", String(h.volume));\n } catch (_) { /* déjà vide */ }\n } else {\n const cash = Number((await getState(\"paper_eur\")) ?? 0);\n await setState(\"paper_eur\", String(cash + h.volume * bid));\n }\n await logTrade(mode, pc.label, \"sell\", bid, h.volume, 0, \"cœur liquidé (kill-switch)\");\n }\n await delState(coreKey(mode, pc));\n }\n}\n",[],[173,377],["D",1783543271782],[212,213,214,215,216,217],[173],"ce8c4302-6115-48b6-b7fa-3395da55f251","index.http.ts",153,["D",1784666454348],"http","// Dashboard web du bot — page live + API JSON (rafraîchie toutes les 30 s côté client). Multi-paires.\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(); // cœur-satellite\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 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 pairs = p.pairs.map((pair) => ({\n label: pair.label,\n price: pair.ticker.last,\n bid: pair.ticker.bid,\n ask: pair.ticker.ask,\n rsiBuyBelow: pair.rsiBuyBelow,\n halted: pair.halted,\n valueEur: pair.valueEur,\n baseBalance: pair.baseBalance,\n coreValueEur: pair.coreValueEur,\n position: pair.position\n ? {\n volume: pair.position.volume,\n entry: pair.position.entry,\n highWater: pair.position.highWater ?? pair.position.entry,\n stopPrice: (pair.position.highWater ?? pair.position.entry) * (1 - (pair.position.trailPct ?? pair.trailPct)),\n tpPrice: pair.position.entry * (1 + (pair.position.tpPct ?? pair.tpPct)),\n trailPct: pair.position.trailPct ?? pair.trailPct,\n pnlEur: (pair.ticker.bid - pair.position.entry) * pair.position.volume,\n pnlPct: ((pair.ticker.bid - pair.position.entry) / pair.position.entry) * 100,\n }\n : null,\n pending: pair.pending ? { price: pair.pending.price, volume: pair.pending.volume } : null,\n }));\n\n return c.json({\n updatedAt: new Date().toISOString(),\n mode: p.mode,\n halted: p.halted,\n equity: p.equity,\n cashEur: p.eur,\n coreValue: p.coreValue,\n coreTargetPct: CONFIG.CORE_TARGET_PCT,\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 pairs,\n snapshots: snaps.rows,\n trades,\n });\n});\n\nexport default app.fetch;\n",[],[179,388],"45a7a64b-534b-469e-b6af-7caf16fea97b","index.html","b11ed694-7b15-11f1-82d2-1607ee4eb77e",42,["D",1783546852120],"\n\n\n \n \n Bot BTC — Live\n \n \n \n\n\n

\n \n\n\n",[],[179,396],"d58a4e25-7564-45d5-b9df-f8eea164f1f3","App.tsx","d02c60ce-7b15-11f1-8e10-1607ee4eb77e",155,["D",1784666551171],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0\";\n\nconst eur = (x: number, d = 2) =>\n new Intl.NumberFormat(\"fr-FR\", { minimumFractionDigits: d, maximumFractionDigits: d }).format(x) + \" €\";\nconst signed = (x: number, d = 2) => (x >= 0 ? \"+\" : \"\") + eur(x, d);\nconst pct = (x: number) => (x >= 0 ? \"+\" : \"\") + x.toFixed(2) + \" %\";\nconst timeFr = (iso: string) =>\n new Date(iso).toLocaleTimeString(\"fr-FR\", { hour: \"2-digit\", minute: \"2-digit\" });\n\nfunction Badge({ children, tone }: { children: any; tone: \"good\" | \"warn\" | \"crit\" | \"muted\" }) {\n const color = tone === \"good\"\n ? \"var(--good-text)\"\n : tone === \"crit\"\n ? \"var(--critical)\"\n : tone === \"warn\"\n ? \"var(--warning)\"\n : \"var(--ink-muted)\";\n return (\n \n {children}\n \n );\n}\n\nfunction Tile({ label, value, sub }: { label: string; value: any; sub?: any }) {\n return (\n

{label}

{value}

\n {sub &&

{sub}

}\n

\n );\n}\n\n// Courbe d'équité (série unique) avec crosshair + tooltip au survol.\nfunction EquityChart({ snapshots, killLevel }: { snapshots: any[]; killLevel: number | null }) {\n const [hover, setHover] = useState(null);\n const svgRef = useRef(null);\n const W = 640, H = 180, PAD = { l: 48, r: 12, t: 12, b: 22 };\n\n if (!snapshots || snapshots.length < 2) {\n return (\n

\n Pas encore assez d'historique — la courbe apparaîtra après quelques cycles.\n

\n );\n }\n\n const pts = snapshots.map((s) => ({ t: new Date(String(s.ts)).getTime(), v: Number(s.equity) }));\n const tMin = pts[0].t, tMax = pts[pts.length - 1].t;\n const vals = pts.map((p) => p.v).concat(killLevel !== null ? [killLevel] : []);\n const vMin = Math.min(...vals), vMax = Math.max(...vals);\n const span = Math.max(vMax - vMin, 0.01);\n const x = (t: number) => PAD.l + ((t - tMin) / Math.max(tMax - tMin, 1)) * (W - PAD.l - PAD.r);\n const y = (v: number) => PAD.t + (1 - (v - (vMin - span * 0.1)) / (span * 1.2)) * (H - PAD.t - PAD.b);\n const path = pts.map((p, i) => `${i ? \"L\" : \"M\"}${x(p.t).toFixed(1)},${y(p.v).toFixed(1)}`).join(\" \");\n\n const onMove = (e: any) => {\n const rect = svgRef.current!.getBoundingClientRect();\n const mx = ((e.clientX - rect.left) / rect.width) * W;\n let best = 0, bestD = Infinity;\n pts.forEach((p, i) => {\n const d = Math.abs(x(p.t) - mx);\n if (d < bestD) { bestD = d; best = i; }\n });\n setHover(best);\n };\n\n const gridVals = [vMin, (vMin + vMax) / 2, vMax];\n const h = hover !== null ? pts[hover] : null;\n\n return (\n

\n setHover(null)}\n >\n {gridVals.map((v, i) => (\n \n \n \n {v.toFixed(2)}\n \n \n ))}\n {killLevel !== null && (\n \n \n \n kill-switch {killLevel.toFixed(2)} €\n \n \n )}\n \n {[0, pts.length - 1].map((i) => (\n \n {timeFr(new Date(pts[i].t).toISOString())}\n \n ))}\n {h && (\n \n \n \n \n )}\n \n {h && (\n W / 2 ? \"translateX(-105%)\" : \"translateX(8px)\",\n background: \"var(--surface-1)\",\n border: \"1px solid var(--border)\",\n color: \"var(--ink-1)\",\n }}\n >\n {timeFr(new Date(h.t).toISOString())} · {eur(h.v)}\n

\n )}\n \n );\n}\n\nfunction App() {\n const [data, setData] = useState(null);\n const [error, setError] = useState(null);\n\n const load = async () => {\n try {\n const res = await fetch(\"/api/status\");\n if (!res.ok) throw new Error(`HTTP ${res.status}`);\n setData(await res.json());\n setError(null);\n } catch (e) {\n setError(String(e));\n }\n };\n\n useEffect(() => {\n load();\n const id = setInterval(load, 30_000);\n return () => clearInterval(id);\n }, []);\n\n if (error && !data) {\n return

Erreur : {error}

;\n }\n if (!data) {\n return

Chargement…

;\n }\n\n const gainTone = data.gain === null ? \"muted\" : data.gain >= 0 ? \"good\" : \"crit\";\n const gainColor = data.gain === null ? \"var(--ink-muted)\" : data.gain >= 0 ? \"var(--good-text)\" : \"var(--critical)\";\n\n return (\n

₿ Bot Kraken — {data.pairs.map((x: any) => x.label).join(\" · \")}

\n {data.mode}\n {data.halted && arrêté}\n

\n maj {timeFr(data.updatedAt)} · auto 30s\n

\n\n {/* Héro : gain/perte à l'instant T */}\n

\n Gain / Perte à l'instant T\n

\n {data.gain !== null ? `${data.gain >= 0 ? \"▲\" : \"▼\"} ${signed(data.gain)}` : \"—\"}\n

\n {data.gainPct !== null ? `${pct(data.gainPct)} depuis le départ (${eur(data.initialEquity)})` : \"en attente du premier cycle\"}\n

\n\n {/* Tuiles globales */}\n

\n \n 0 ? (((data.equity - data.cashEur) / data.equity) * 100).toFixed(0) : 0}%`}\n />\n \n

\n\n {/* Une carte par paire */}\n

\n {data.pairs.map((pr: any) => (\n

\n {pr.label}/EUR {pr.halted && · désactivée}\n {eur(pr.price, pr.price > 100 ? 1 : 4)}\n

\n {pr.coreValueEur > 0 && (\n

\n 🏛️ Cœur : {eur(pr.coreValueEur)}\n

\n )}\n {pr.position ? (\n

= 0 ? \"var(--good-text)\" : \"var(--critical)\" }}>\n {pr.position.pnlEur >= 0 ? \"▲\" : \"▼\"} {signed(pr.position.pnlEur)} ({pct(pr.position.pnlPct)})\n

\n {pr.position.volume} {pr.label} @ {eur(pr.position.entry, pr.position.entry > 100 ? 1 : 4)}\n

\n 🎯 TP {eur(pr.position.tpPrice, pr.position.tpPrice > 100 ? 1 : 4)} · 📉 stop {eur(pr.position.stopPrice, pr.position.stopPrice > 100 ? 1 : 4)}\n

\n ) : pr.pending ? (\n

\n ⏳ Ordre d'achat en attente @ {eur(pr.pending.price, pr.pending.price > 100 ? 1 : 4)}\n

\n ) : (\n

\n 😴 En attente d'un signal (RSI < {pr.rsiBuyBelow})\n

\n )}\n

\n ))}\n

\n\n {/* Courbe d'équité */}\n

Équité — dernières 48 h

\n \n

\n\n {/* Derniers trades */}\n

Derniers trades

\n {data.trades.length === 0 ? (\n

Aucun trade pour l'instant.

\n ) : (\n \n \n {data.trades.map((t: any) => (\n \n \n \n \n \n \n \n ))}\n \n

\n {new Date(String(t.ts)).toLocaleString(\"fr-FR\", { day: \"2-digit\", month: \"2-digit\", hour: \"2-digit\", minute: \"2-digit\" })}\n

{t.side === \"buy\" ? \"🟢 achat\" : \"🔻 vente\"}

{t.pair}

{eur(Number(t.price), Number(t.price) > 100 ? 1 : 4)}

{t.reason}

\n )}\n

\n\n \n

\n );\n}\n\ncreateRoot(document.getElementById(\"root\")!).render();\n",[],[179,404],["D",1783546834930],[208,209,210],[179],"e95b980d-bc65-48da-b09f-564e8187b408","trader.ts","b6b24d1e-7b0d-11f1-aad7-1607ee4eb77e",["D",1783543425494],"// 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",[],[185,415],"4fdc8a3e-3b3c-4d30-badf-80ca4f3ffc6b","trader-c.ts","bdeeb25e-7b65-11f1-a207-1607ee4eb77e",58,["D",1783581233352],"// Cron de trading décalé (+10 min) — même cycle, voir crons/trader.ts.\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 (c)\", e);\n }\n}\n",[],[185,422],"6cf38b77-7db4-497c-a37f-0fb6caada105","trader-b.ts","ba658694-7b65-11f1-918f-1607ee4eb77e",57,["D",1783581227420],"// Cron de trading décalé (+5 min) — même cycle, voir crons/trader.ts.\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 (b)\", e);\n }\n}\n",[],[185,430],"cdc9daa6-15d5-4cc9-b3af-cafe5e52f88f",["D",1785878323927],[],[185,33],["D",1783543425494],[203,204,205,206],[185],["D",1783543222179],["D",1789525245864],{"_101":100,"_109":105},{"_101":100,"_102":103,"_104":105,"_18":56,"_106":107,"_108":25},{"_13":90,"_32":91,"_44":43,"_92":45,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":46,"_99":100},"ctx",{"_83":-5,"_129":482,"_483":484,"_485":486,"_487":25,"_488":25,"_489":25,"_490":60,"_491":-5,"_492":-7,"_493":-7,"_494":64,"_495":25,"_496":25,"_497":-5,"_498":25,"_499":25,"_500":25,"_501":-5},"ENV",{"_453":454,"_455":456,"_457":91,"_458":459,"_460":461,"_462":463,"_464":465,"_466":467,"_468":469,"_470":471,"_472":473,"_474":475,"_476":477,"_478":479,"_480":481},"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 · v168