From ba396f2fb3fbd7fdc921ff996a093d4c6fbfd026 Mon Sep 17 00:00:00 2001
From: Chris Stewart <stewart.chris1234@gmail.com>
Date: Tue, 2 Aug 2022 06:40:28 -0500
Subject: [PATCH] Fetch findByFundingTxId/findByFundingOutPoints in parallel as
 an optimization (#4560)

---
 .../dlc/wallet/internal/DLCTransactionProcessing.scala   | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/dlc-wallet/src/main/scala/org/bitcoins/dlc/wallet/internal/DLCTransactionProcessing.scala b/dlc-wallet/src/main/scala/org/bitcoins/dlc/wallet/internal/DLCTransactionProcessing.scala
index 24d06f83c5..1a9a893500 100644
--- a/dlc-wallet/src/main/scala/org/bitcoins/dlc/wallet/internal/DLCTransactionProcessing.scala
+++ b/dlc-wallet/src/main/scala/org/bitcoins/dlc/wallet/internal/DLCTransactionProcessing.scala
@@ -243,6 +243,7 @@ private[bitcoins] trait DLCTransactionProcessing extends TransactionProcessing {
       newTags: Vector[AddressTag],
       relevantReceivedOutputs: Vector[OutputWithIndex]): Future[
     Vector[SpendingInfoDb]] = {
+    val dlcDbsF = dlcDAO.findByFundingTxId(tx.txIdBE)
     super
       .processReceivedUtxos(tx,
                             blockHashOpt,
@@ -251,7 +252,7 @@ private[bitcoins] trait DLCTransactionProcessing extends TransactionProcessing {
                             relevantReceivedOutputs)
       .flatMap { res =>
         for {
-          dlcDbs <- dlcDAO.findByFundingTxId(tx.txIdBE)
+          dlcDbs <- dlcDbsF
           _ <-
             if (dlcDbs.nonEmpty) {
               logger.info(
@@ -314,13 +315,13 @@ private[bitcoins] trait DLCTransactionProcessing extends TransactionProcessing {
       outputsBeingSpent: Vector[SpendingInfoDb],
       blockHashOpt: Option[DoubleSha256DigestBE]): Future[
     Vector[SpendingInfoDb]] = {
+    val outPoints = transaction.inputs.map(_.previousOutput).toVector
+    val dlcDbsF = dlcDAO.findByFundingOutPoints(outPoints)
     super
       .processSpentUtxos(transaction, outputsBeingSpent, blockHashOpt)
       .flatMap { res =>
-        val outPoints = transaction.inputs.map(_.previousOutput).toVector
-
         for {
-          dlcDbs <- dlcDAO.findByFundingOutPoints(outPoints)
+          dlcDbs <- dlcDbsF
           _ <-
             if (dlcDbs.nonEmpty) {
               logger.info(