From 9fe681d73bc0c106984b691a07d62836f0a922ee Mon Sep 17 00:00:00 2001
From: shocknet-justin <justin@shock.network>
Date: Thu, 5 Feb 2026 15:46:39 -0500
Subject: [PATCH] swap clear interval

---
 src/services/lnd/swaps/reverseSwaps.ts   | 4 +---
 src/services/lnd/swaps/submarineSwaps.ts | 2 +-
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/services/lnd/swaps/reverseSwaps.ts b/src/services/lnd/swaps/reverseSwaps.ts
index 14dc4d44..83dddc37 100644
--- a/src/services/lnd/swaps/reverseSwaps.ts
+++ b/src/services/lnd/swaps/reverseSwaps.ts
@@ -155,9 +155,7 @@ export class ReverseSwaps {
                 }
             } catch (err: any) {
                 this.log(ERROR, 'Error handling transaction WebSocket message', err.message)
-                isDone = true
-                webSocket.close()
-                swapDone({ ok: false, error: err.message })
+                done(err.message)
                 return
             }
         })
diff --git a/src/services/lnd/swaps/submarineSwaps.ts b/src/services/lnd/swaps/submarineSwaps.ts
index 32ed1fac..462f4751 100644
--- a/src/services/lnd/swaps/submarineSwaps.ts
+++ b/src/services/lnd/swaps/submarineSwaps.ts
@@ -407,7 +407,7 @@ export class SubmarineSwaps {
                 await this.handleSwapInvoiceMessage(rawMsg, data, done, waitingTx)
             } catch (err: any) {
                 this.log(ERROR, 'Error handling invoice WebSocket message', err.message)
-                webSocket.close()
+                done(err.message)
                 return
             }
         });