mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2024-11-20 10:12:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

ForwardingService: static method to create CoinSelector

Browse Source 
This uses partial function application rather than creating a class
to create the parent-transaction only CoinSelector.
This commit is contained in:
Sean Gilligan 2022-07-28 15:34:11 -07:00 committed by Andreas Schildbach
parent c89128c77b
commit 15d0134937
1 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
examples/src/main/java/org/bitcoinj/examples/ForwardingService.java
View File

@ -177,7 +177,7 @@ public class ForwardingService implements AutoCloseable {
System.out.printf("Incoming tx has received %d confirmations.\n", confidence.getDepthInBlocks());
// Now send the coins onwards by sending exactly the outputs that have been sent to us
SendRequest sendRequest = SendRequest.emptyWallet(forwardingAddress);
sendRequest.coinSelector = new ForwardingCoinSelector(incomingTx);
sendRequest.coinSelector = forwardingCoinSelector(incomingTx.getTxId());
System.out.printf("Creating outgoing transaction for %s...\n", forwardingAddress);
return sendTransaction(sendRequest);
})
@ -251,20 +251,20 @@ public class ForwardingService implements AutoCloseable {
return String.format("forwarding-service-%s", network.toString());
}
static class ForwardingCoinSelector implements CoinSelector {
private final Sha256Hash forwardTxId;
public ForwardingCoinSelector(Transaction transactionToForward) {
this.forwardTxId = transactionToForward.getTxId();
}
@Override
public CoinSelection select(Coin target, List<TransactionOutput> candidates) {
var selected =
candidates.stream()
.filter(output -> output.getParentTransactionHash().equals(forwardTxId))
.collect(Collectors.toList());
/**
* Create a CoinSelector that only returns outputs from a given parent transaction.
* <p>
* This is using the idea of partial function application to create a 2-argument function for coin selection
* with a third, fixed argument of the transaction id.
* @param forwardTxId The parent transaction hash
* @return a coin selector
*/
static CoinSelector forwardingCoinSelector(Sha256Hash forwardTxId) {
return (target, candidates) -> {
var selected = candidates.stream()
.filter(output -> output.getParentTransactionHash().equals(forwardTxId))
.collect(Collectors.toList());
return new CoinSelection(selected);
}
};
}
}