Merge pull request #283 from synonymdev/fix/transfer-watch-pooling

Fix/transfer watch pooling

Author: jvsena42

app/src/main/java/to/bitkit/repositories/BlocktankRepo.kt

@@ -1,5 +1,6 @@
 package to.bitkit.repositories
 
+import com.synonym.bitkitcore.BtOrderState2
 import com.synonym.bitkitcore.CreateCjitOptions
 import com.synonym.bitkitcore.CreateOrderOptions
 import com.synonym.bitkitcore.IBtEstimateFeeResponse2
@@ -142,7 +143,13 @@ class BlocktankRepo @Inject constructor(
                 )
             }
 
-            Logger.debug("Orders refreshed: ${orders.size} orders, ${cjitEntries.size} cjit entries", context = TAG)
+            Logger.debug(
+                "Orders refreshed: ${orders.size} orders, " +
+                    "${cjitEntries.size} cjit entries, " +
+                    "${_blocktankState.value.paidOrders.size} paid orders",
+                context = TAG
+            )
+            openChannelWithPaidOrders()
         } catch (e: Throwable) {
             Logger.error("Failed to refresh orders", e, context = TAG)
         } finally {
@@ -284,6 +291,12 @@ class BlocktankRepo @Inject constructor(
         }
     }
 
+    private suspend fun openChannelWithPaidOrders() = withContext(bgDispatcher) {
+        _blocktankState.value.paidOrders.filter { it.state2 == BtOrderState2.PAID }.forEach { order ->
+            openChannel(order.id)
+        }
+    }
+
     private suspend fun defaultCreateOrderOptions(clientBalanceSat: ULong): CreateOrderOptions {
         val nodeId = lightningService.nodeId ?: throw ServiceError.NodeNotStarted
         val timestamp = nowTimestamp().toString()