fix: bouncer btc client mutex for vault swaps

bouncer/commands/create_raw_btc_tx.ts

@@ -2,26 +2,23 @@
 // Constructs a very simple Raw BTC transaction. Can be used for manual testing a raw broadcast for example.
 // Usage: ./commands/create_raw_btc_tx.ts <bitcoin_address> <btc_amount>
 
-import { BTC_ENDPOINT, btcClient, selectInputs } from '../shared/send_btc';
+import { BTC_ENDPOINT, btcClient } from '../shared/send_btc';
 
 console.log(`Btc endpoint is set to '${BTC_ENDPOINT}'`);
 
 const createRawTransaction = async (toAddress: string, amountInBtc: number | string) => {
   try {
-    // Inputs and outputs
-    const feeInBtc = 0.00001;
-    const { inputs, change } = await selectInputs(Number(amountInBtc) + feeInBtc);
-    const changeAddress = await btcClient.getNewAddress();
-    const outputs = {
-      [toAddress]: amountInBtc,
-      [changeAddress]: change,
-    };
-
     // Create the raw transaction
-    const rawTx = await btcClient.createRawTransaction(inputs, outputs);
+    const rawTx = await btcClient.createRawTransaction([], {
+      [toAddress]: amountInBtc,
+    });
+    const fundedTx = (await btcClient.fundRawTransaction(rawTx, {
+      changeAddress: await btcClient.getNewAddress(),
+      feeRate: 0.00001,
+    })) as { hex: string };
 
     // Sign the raw transaction
-    const signedTx = await btcClient.signRawTransactionWithWallet(rawTx);
+    const signedTx = await btcClient.signRawTransactionWithWallet(fundedTx);
 
     // Here's your raw signed transaction
     console.log('Raw signed transaction:', signedTx.hex);

bouncer/shared/send_btc.ts

@@ -11,26 +11,46 @@ export const btcClient = new Client({
   wallet: 'whale',
 });
 
-export async function selectInputs(amount: number) {
-  // List unspent UTXOs
-  const utxos = await btcClient.listUnspent();
-
-  // Find a UTXO with enough funds
-  const utxo = utxos.find((u) => u.amount >= amount);
-  if (!utxo) throw new Error('Insufficient funds');
-  // TODO: be able to select more than one UTXO
+export async function fundAndSendTransaction(
+  outputs: object[],
+  changeAddress: string,
+  feeRate?: number,
+): Promise<string> {
+  return btcClientMutex.runExclusive(async () => {
+    const rawTx = await btcClient.createRawTransaction([], outputs);
+    const fundedTx = (await btcClient.fundRawTransaction(rawTx, {
+      changeAddress,
+      feeRate: feeRate ?? 0.00001,
+    })) as { hex: string };
+    const signedTx = await btcClient.signRawTransactionWithWallet(fundedTx.hex);
+    const txId = (await btcClient.sendRawTransaction(signedTx.hex)) as string | undefined;
 
-  const change = utxo.amount - amount;
+    if (!txId) {
+      throw new Error('Broadcast failed');
+    }
 
-  // Prepare the transaction inputs and outputs
-  const inputs = [
-    {
-      txid: utxo.txid,
-      vout: utxo.vout,
-    },
-  ];
+    return txId;
+  });
+}
 
-  return { inputs, change };
+export async function sendVaultTransaction(
+  nulldataUtxo: string,
+  amountBtc: number,
+  depositAddress: string,
+  refundAddress: string,
+): Promise<string> {
+  return fundAndSendTransaction(
+    [
+      {
+        [depositAddress]: amountBtc,
+      },
+      {
+        // The `createRawTransaction` function will add the op codes, so we have to remove them here.
+        data: nulldataUtxo.replace('0x', '').substring(4),
+      },
+    ],
+    refundAddress,
+  );
 }
 
 export async function waitForBtcTransaction(txid: string, confirmations = 1) {

bouncer/tests/btc_vault_swap.ts

@@ -1,11 +1,10 @@
 import assert from 'assert';
 import { ExecutableTest } from '../shared/executable_test';
-import { BTC_ENDPOINT, selectInputs, waitForBtcTransaction, btcClient } from '../shared/send_btc';
+import { BTC_ENDPOINT, waitForBtcTransaction, sendVaultTransaction } from '../shared/send_btc';
 import {
   amountToFineAmount,
   Asset,
   assetDecimals,
-  btcClientMutex,
   createStateChainKeypair,
   newAddress,
   observeBalanceIncrease,
@@ -51,9 +50,6 @@ async function buildAndSendBtcVaultSwap(
     affiliates.push({ account: affiliateAddress, bps: commissionBps });
   }
 
-  const feeBtc = 0.00001;
-  const { inputs, change } = await selectInputs(Number(depositAmountBtc) + feeBtc);
-
   const vaultSwapDetails = (await chainflip.rpc(
     `cf_get_vault_swap_details`,
     broker.address,
@@ -71,32 +67,15 @@ async function buildAndSendBtcVaultSwap(
   testBtcVaultSwap.debugLog('nulldata_utxo:', vaultSwapDetails.nulldata_utxo);
   testBtcVaultSwap.debugLog('deposit_address:', vaultSwapDetails.deposit_address);
 
-  // The `createRawTransaction` function will add the op codes, so we have to remove them here.
-  const nullDataWithoutOpCodes = vaultSwapDetails.nulldata_utxo.replace('0x', '').substring(4);
-
-  const outputs = [
-    {
-      [vaultSwapDetails.deposit_address]: depositAmountBtc,
-    },
-    {
-      data: nullDataWithoutOpCodes,
-    },
-    {
-      [refundAddress]: change,
-    },
-  ];
-
-  const rawTx = await btcClient.createRawTransaction(inputs, outputs, 0, false);
-  const signedTx = await btcClient.signRawTransactionWithWallet(rawTx);
-  const txid = await btcClientMutex.runExclusive(async () =>
-    btcClient.sendRawTransaction(signedTx.hex),
+  const txid = await sendVaultTransaction(
+    vaultSwapDetails.nulldata_utxo,
+    depositAmountBtc,
+    vaultSwapDetails.deposit_address,
+    refundAddress,
   );
-  if (!txid) {
-    throw new Error('Broadcast failed');
-  }
   testBtcVaultSwap.log('Broadcast successful, txid:', txid);
 
-  await waitForBtcTransaction(txid as string);
+  await waitForBtcTransaction(txid);
   testBtcVaultSwap.debugLog('Transaction confirmed');
 }
 

bouncer/tests/lp_api_test.ts

@@ -21,7 +21,7 @@ import { getChainflipApi, observeEvent } from '../shared/utils/substrate';
 import { ExecutableTest } from '../shared/executable_test';
 
 /* eslint-disable @typescript-eslint/no-use-before-define */
-export const testLpApi = new ExecutableTest('LP-API', main, 200);
+export const testLpApi = new ExecutableTest('LP-API', main, 1000);
 
 type RpcAsset = {
   asset: string;