do not revert trade funds on init timeout until error processing

Author: woodser

core/src/main/java/haveno/core/trade/Trade.java

@@ -1812,27 +1812,17 @@ public void onProtocolInitializationError() {
             return;
         }
 
-        // unreserve taker's key images
-        if (this instanceof TakerTrade) {
-            ThreadUtils.submitToPool(() -> {
-                xmrWalletService.thawOutputs(getSelf().getReserveTxKeyImages());
-            });
-        }
-
-        // unreserve maker's open offer
-        Optional<OpenOffer> openOffer = processModel.getOpenOfferManager().getOpenOffer(this.getId());
-        if (this instanceof MakerTrade && openOffer.isPresent()) {
-            processModel.getOpenOfferManager().unreserveOpenOffer(openOffer.get());
-        }
-
         // remove if deposit not requested or is failed
         if (!isDepositRequested() || isDepositRequestFailed()) {
             removeTradeOnError();
             return;
         }
 
         // done if wallet already deleted
-        if (!walletExists()) return;
+        if (!walletExists()) {
+            removeTradeOnError();
+            return;
+        }
 
         // set error height
         if (processModel.getTradeProtocolErrorHeight() == 0) {
@@ -1927,6 +1917,19 @@ private void removeTradeOnError() {
             forceCloseWallet();
             if (isDepositRequested()) getWallet();
 
+            // unreserve taker's key images
+            if (this instanceof TakerTrade) {
+                ThreadUtils.submitToPool(() -> {
+                    xmrWalletService.thawOutputs(getSelf().getReserveTxKeyImages());
+                });
+            }
+
+            // unreserve maker's open offer
+            Optional<OpenOffer> openOffer = processModel.getOpenOfferManager().getOpenOffer(this.getId());
+            if (this instanceof MakerTrade && openOffer.isPresent()) {
+                processModel.getOpenOfferManager().unreserveOpenOffer(openOffer.get());
+            }
+
             // clear and shut down trade
             onShutDownStarted();
             clearAndShutDown();

core/src/main/java/haveno/core/trade/TradeManager.java

@@ -920,6 +920,10 @@ public void onTakeOffer(BigInteger amount,
             // ensure trade is not already open
             Optional<Trade> tradeOptional = getOpenTrade(offer.getId());
             if (tradeOptional.isPresent()) throw new RuntimeException("Cannot create trade protocol because trade with ID " + offer.getId() + " is already open");
+
+            // ensure failed trade is not processing
+            tradeOptional = getFailedTrade(offer.getId());
+            if (tradeOptional.isPresent() && tradeOptional.get().walletExists()) throw new RuntimeException("Cannot create trade protocol because trade with ID " + offer.getId() + " has failed but is not processed");
 
             // create trade
             Trade trade;