From d61eabc3d2e53881cda2bcd5dc094c9b974037ce Mon Sep 17 00:00:00 2001
From: woodser <woodser@protonmail.com>
Date: Wed, 2 Oct 2024 08:16:33 -0400
Subject: [PATCH] schedule offer using available and pending funds

---
 .../haveno/core/offer/OpenOfferManager.java   | 55 +++++++++++++++----
 1 file changed, 43 insertions(+), 12 deletions(-)

diff --git a/core/src/main/java/haveno/core/offer/OpenOfferManager.java b/core/src/main/java/haveno/core/offer/OpenOfferManager.java
index 38ee71f6..ffed498b 100644
--- a/core/src/main/java/haveno/core/offer/OpenOfferManager.java
+++ b/core/src/main/java/haveno/core/offer/OpenOfferManager.java
@@ -934,6 +934,23 @@ public class OpenOfferManager implements PeerManager.Listener, DecryptedDirectMe
                     return;
                 }
 
+                // cancel offer if scheduled txs unavailable
+                if (openOffer.getScheduledTxHashes() != null) {
+                    boolean scheduledTxsAvailable = true;
+                    for (MoneroTxWallet tx : xmrWalletService.getTxs(openOffer.getScheduledTxHashes())) {
+                        if (!tx.isLocked() && !isOutputsAvailable(tx)) {
+                            scheduledTxsAvailable = false;
+                            break;
+                        }
+                    }
+                    if (!scheduledTxsAvailable) {
+                        log.warn("Canceling offer {} because scheduled txs are no longer available", openOffer.getId());
+                        doCancelOffer(openOffer);
+                        resultHandler.handleResult(null);
+                        return;
+                    }
+                }
+
                 // get amount needed to reserve offer
                 BigInteger amountNeeded = openOffer.getOffer().getAmountNeeded();
 
@@ -1138,25 +1155,31 @@ public class OpenOfferManager implements PeerManager.Listener, DecryptedDirectMe
             throw new RuntimeException("Not enough money in Haveno wallet");
         }
 
-        // get locked txs
-        List<MoneroTxWallet> lockedTxs = xmrWalletService.getTxs(new MoneroTxQuery().setIsLocked(true));
-
-        // get earliest unscheduled txs with sufficient incoming amount
-        List<String> scheduledTxHashes = new ArrayList<String>();
+        // get earliest available or pending txs with sufficient incoming amount
         BigInteger scheduledAmount = BigInteger.ZERO;
-        for (MoneroTxWallet lockedTx : lockedTxs) {
-            if (isTxScheduledByOtherOffer(openOffers, openOffer, lockedTx.getHash())) continue;
-            if (lockedTx.getIncomingTransfers() == null || lockedTx.getIncomingTransfers().isEmpty()) continue;
-            scheduledTxHashes.add(lockedTx.getHash());
-            for (MoneroIncomingTransfer transfer : lockedTx.getIncomingTransfers()) {
-                if (transfer.getAccountIndex() == 0) scheduledAmount = scheduledAmount.add(transfer.getAmount());
+        Set<MoneroTxWallet> scheduledTxs = new HashSet<MoneroTxWallet>();
+        for (MoneroTxWallet tx : xmrWalletService.getTxs()) {
+
+            // skip if outputs unavailable
+            if (tx.getIncomingTransfers() == null || tx.getIncomingTransfers().isEmpty()) continue;
+            if (!isOutputsAvailable(tx)) continue;
+            if (isTxScheduledByOtherOffer(openOffers, openOffer, tx.getHash())) continue;
+
+            // add scheduled tx
+            for (MoneroIncomingTransfer transfer : tx.getIncomingTransfers()) {
+                if (transfer.getAccountIndex() == 0) {
+                    scheduledAmount = scheduledAmount.add(transfer.getAmount());
+                    scheduledTxs.add(tx);
+                }
             }
+
+            // break if sufficient funds
             if (scheduledAmount.compareTo(offerReserveAmount) >= 0) break;
         }
         if (scheduledAmount.compareTo(offerReserveAmount) < 0) throw new RuntimeException("Not enough funds to schedule offer");
 
         // schedule txs
-        openOffer.setScheduledTxHashes(scheduledTxHashes);
+        openOffer.setScheduledTxHashes(scheduledTxs.stream().map(tx -> tx.getHash()).collect(Collectors.toList()));
         openOffer.setScheduledAmount(scheduledAmount.toString());
         openOffer.setState(OpenOffer.State.PENDING);
     }
@@ -1192,6 +1215,14 @@ public class OpenOfferManager implements PeerManager.Listener, DecryptedDirectMe
         return false;
     }
 
+    private boolean isOutputsAvailable(MoneroTxWallet tx) {
+        if (tx.getOutputsWallet() == null) return false;
+        for (MoneroOutputWallet output : tx.getOutputsWallet()) {
+            if (output.isSpent() || output.isFrozen()) return false;
+        }
+        return true;
+    }
+
     private void signAndPostOffer(OpenOffer openOffer,
                                   boolean useSavingsWallet, // TODO: remove this?
                                   TransactionResultHandler resultHandler, ErrorMessageHandler errorMessageHandler) {