mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-03-01 01:32:17 +01:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #7319 from alvasw/BitcoinjRegtestSetup_Implement_wallet_funding

Browse source 
BitcoinjRegtestSetup: Implement wallet funding
This commit is contained in:
Alejandro García 2024-12-10 07:54:08 +00:00 • committed by GitHub
commit a05f9c5656
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 53 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

53
core/src/integrationTest/java/bisq/core/BitcoinjRegtestSetup.java Normal file
View file

@ -0,0 +1,53 @@
package bisq.core;
import org.bitcoinj.core.Address;
import org.bitcoinj.core.Coin;
import org.bitcoinj.wallet.Wallet;
import org.bitcoinj.wallet.listeners.WalletCoinsReceivedEventListener;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import bisq.wallets.regtest.bitcoind.BitcoindRegtestSetup;
public class BitcoinjRegtestSetup {
private final BitcoindRegtestSetup bitcoindRegtestSetup;
public BitcoinjRegtestSetup(BitcoindRegtestSetup bitcoindRegtestSetup) {
this.bitcoindRegtestSetup = bitcoindRegtestSetup;
}
public void fundWallet(Wallet wallet, double amount) throws InterruptedException {
var walletReceivedLatch = new CountDownLatch(1);
WalletCoinsReceivedEventListener coinsReceivedEventListener =
(affectedWallet, tx, prevBalance, newBalance) -> {
walletReceivedLatch.countDown();
};
wallet.addCoinsReceivedEventListener(coinsReceivedEventListener);
Coin previousBalance = wallet.getBalance();
Address currentReceiveAddress = wallet.currentReceiveAddress();
String address = currentReceiveAddress.toString();
bitcoindRegtestSetup.fundAddress(address, amount);
bitcoindRegtestSetup.mineOneBlock();
boolean isSuccess = walletReceivedLatch.await(30, TimeUnit.SECONDS);
wallet.removeCoinsReceivedEventListener(coinsReceivedEventListener);
if (!isSuccess) {
throw new IllegalStateException("Wallet not funded after 30 seconds.");
}
Coin balance = wallet.getBalance();
Coin receivedAmount = balance.minus(previousBalance);
long receivedAmountAsLong = receivedAmount.value;
long fundedAmount = (long) amount * 100_000_000;
if (receivedAmount.value != fundedAmount) {
throw new IllegalStateException("Wallet balance is " + receivedAmountAsLong +
" but should be " + fundedAmount + ".");
}
}
}