mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-03-03 10:46:42 +01:00
Code Issues Projects Releases Packages Wiki Activity

Fetch findByFundingTxId/findByFundingOutPoints in parallel as an optimization (#4560)

Browse source
This commit is contained in:
Chris Stewart 2022-08-02 06:40:28 -05:00 • committed by GitHub
parent 191df09196
commit ba396f2fb3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
dlc-wallet/src/main/scala/org/bitcoins/dlc/wallet/internal/DLCTransactionProcessing.scala
View file

@ -243,6 +243,7 @@ private[bitcoins] trait DLCTransactionProcessing extends TransactionProcessing {
newTags: Vector[AddressTag], newTags: Vector[AddressTag],
relevantReceivedOutputs: Vector[OutputWithIndex]): Future[ relevantReceivedOutputs: Vector[OutputWithIndex]): Future[
Vector[SpendingInfoDb]] = { Vector[SpendingInfoDb]] = {
val dlcDbsF = dlcDAO.findByFundingTxId(tx.txIdBE)
super super
.processReceivedUtxos(tx, .processReceivedUtxos(tx,
blockHashOpt, blockHashOpt,
@ -251,7 +252,7 @@ private[bitcoins] trait DLCTransactionProcessing extends TransactionProcessing {
relevantReceivedOutputs) relevantReceivedOutputs)
.flatMap { res => .flatMap { res =>
for { for {
dlcDbs <- dlcDAO.findByFundingTxId(tx.txIdBE) dlcDbs <- dlcDbsF
_ <- _ <-
if (dlcDbs.nonEmpty) { if (dlcDbs.nonEmpty) {
logger.info( logger.info(
@ -314,13 +315,13 @@ private[bitcoins] trait DLCTransactionProcessing extends TransactionProcessing {
outputsBeingSpent: Vector[SpendingInfoDb], outputsBeingSpent: Vector[SpendingInfoDb],
blockHashOpt: Option[DoubleSha256DigestBE]): Future[ blockHashOpt: Option[DoubleSha256DigestBE]): Future[
Vector[SpendingInfoDb]] = { Vector[SpendingInfoDb]] = {
val outPoints = transaction.inputs.map(_.previousOutput).toVector
val dlcDbsF = dlcDAO.findByFundingOutPoints(outPoints)
super super
.processSpentUtxos(transaction, outputsBeingSpent, blockHashOpt) .processSpentUtxos(transaction, outputsBeingSpent, blockHashOpt)
.flatMap { res => .flatMap { res =>
val outPoints = transaction.inputs.map(_.previousOutput).toVector
for { for {
dlcDbs <- dlcDAO.findByFundingOutPoints(outPoints) dlcDbs <- dlcDbsF
_ <- _ <-
if (dlcDbs.nonEmpty) { if (dlcDbs.nonEmpty) {
logger.info( logger.info(