All files / src/routes funds.routes.ts

0% Statements 0/40
0% Branches 0/13
0% Functions 0/2
0% Lines 0/40

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118                                                                                                                                                                                                                                           
import { Router, Request, Response } from 'express';
import { exec } from 'child_process';
import { promisify } from 'util';
 
const router = Router();
const execAsync = promisify(exec);
 
/**
 * Route pour transférer automatiquement des fonds du wallet mining vers le relay
 */
router.post('/transfer', async (req: Request, res: Response) => {
  try {
    const { amount = 0.01, source = 'mining_mnemonic', target = 'default' } = req.body;
 
    console.log(`🔄 Transfert automatique de ${amount} BTC de ${source} vers ${target}`);
 
    // Vérifier la connectivité Bitcoin
    await execAsync('docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" getblockchaininfo');
 
    // Charger le wallet cible
    await execAsync(`docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" loadwallet "${target}"`);
 
    // Vérifier le solde du wallet source
    const { stdout: sourceBalance } = await execAsync(`docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" -rpcwallet="${source}" getbalance`);
    const balance = parseFloat(sourceBalance.trim());
 
    if (balance < amount) {
      return res.status(400).json({
        success: false,
        error: `Solde insuffisant dans le wallet ${source}: ${balance} BTC < ${amount} BTC`
      });
    }
 
    // Vérifier le solde du wallet cible
    const { stdout: targetBalance } = await execAsync(`docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" -rpcwallet="${target}" getbalance`);
    const targetBalanceValue = parseFloat(targetBalance.trim());
 
    // Si le wallet cible a déjà des fonds, ne pas transférer
    if (targetBalanceValue >= 0.001) {
      return res.json({
        success: true,
        message: `Wallet ${target} a déjà des fonds suffisants (${targetBalanceValue} BTC)`,
        targetBalance: targetBalanceValue
      });
    }
 
    // Générer une adresse pour le wallet cible
    const { stdout: address } = await execAsync(`docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" -rpcwallet="${target}" getnewaddress "auto_funding"`);
 
    // Effectuer le transfert
    const { stdout: txid } = await execAsync(`docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" -rpcwallet="${source}" sendtoaddress "${address.trim()}" "${amount}"`);
 
    // Générer des blocs pour confirmer la transaction
    await execAsync(`docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" -rpcwallet="${source}" generatetoaddress 6 "${address.trim()}"`);
 
    // Redémarrer le relay
    await execAsync('docker compose restart sdk_relay');
 
    res.json({
      success: true,
      message: `Transfert de ${amount} BTC réussi`,
      transactionId: txid.trim(),
      address: address.trim(),
      sourceBalance: balance,
      targetBalance: targetBalanceValue
    });
    return;
 
  } catch (error) {
    console.error('❌ Erreur lors du transfert automatique:', error);
    res.status(500).json({
      success: false,
      error: `Erreur lors du transfert: ${error instanceof Error ? error.message : String(error)}`
    });
    return;
  }
});
 
/**
 * Route pour vérifier les fonds du relay
 */
router.get('/check', async (req: Request, res: Response) => {
  try {
    // Vérifier les fonds du relay dans la configuration
    const { stdout: outputsCount } = await execAsync('docker exec sdk_relay cat /home/bitcoin/.4nk/default 2>/dev/null | jq -r \'.outputs | length // 0\' 2>/dev/null || echo "0"');
 
    // Vérifier le solde du wallet relay dans Bitcoin Core
    await execAsync('docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" loadwallet "default"');
    const { stdout: relayBalance } = await execAsync('docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" -rpcwallet="default" getbalance');
 
    // Vérifier le solde du wallet mining
    const { stdout: miningBalance } = await execAsync('docker exec bitcoin-signet bitcoin-cli -signet -rpccookiefile="/home/bitcoin/.bitcoin/signet/.cookie" -rpcwallet="mining_mnemonic" getbalance');
 
    res.json({
      success: true,
      relay: {
        outputsCount: parseInt(outputsCount.trim()),
        balance: parseFloat(relayBalance.trim())
      },
      mining: {
        balance: parseFloat(miningBalance.trim())
      },
      needsTransfer: parseInt(outputsCount.trim()) === 0 && parseFloat(relayBalance.trim()) < 0.001
    });
    return;
 
  } catch (error) {
    console.error('❌ Erreur lors de la vĂ©rification des fonds:', error);
    res.status(500).json({
      success: false,
      error: `Erreur lors de la vérification: ${error instanceof Error ? error.message : String(error)}`
    });
    return;
  }
});
 
export default router;