Cleanup register and prevent multiple swaps per channel

ACINQ · Oct 26, 2022 · ddef11d · ddef11d
1 parent 4da5074
commit ddef11d
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/plugins/peerswap/src/main/scala/fr/acinq/eclair/plugins/peerswap/StatusAggregator.scala b/plugins/peerswap/src/main/scala/fr/acinq/eclair/plugins/peerswap/StatusAggregator.scala
@@ -22,7 +22,12 @@ import fr.acinq.eclair.plugins.peerswap.SwapResponses.Status
 
 object StatusAggregator {
   def apply(swapsCount: Int, replyTo: ActorRef[Iterable[Status]]): Behavior[Status] = Behaviors.setup { context =>
-    new StatusAggregator(context, swapsCount, replyTo).waiting(Set())
+    if (swapsCount == 0) {
+      replyTo ! Seq()
+      Behaviors.stopped
+    } else {
+      new StatusAggregator(context, swapsCount, replyTo).waiting(Set())
+    }
   }
 }