feat: cache in progress transfers

Author: jvsena42

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

@@ -7,11 +7,16 @@ import com.synonym.bitkitcore.PaymentType
 import com.synonym.bitkitcore.SortDirection
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.asStateFlow
+import kotlinx.coroutines.flow.combine
 import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.withContext
 import org.lightningdevkit.ldknode.PaymentDetails
 import to.bitkit.data.CacheStore
+import to.bitkit.data.dto.InProgressTransfer
 import to.bitkit.data.dto.PendingBoostActivity
+import to.bitkit.data.dto.TransferType
 import to.bitkit.di.BgDispatcher
 import to.bitkit.ext.matchesPaymentId
 import to.bitkit.ext.rawId
@@ -31,6 +36,9 @@ class ActivityRepo @Inject constructor(
 
     var isSyncingLdkNodePayments = false
 
+    private val _pendingTransfers: MutableStateFlow<List<Activity.Onchain>> = MutableStateFlow(emptyList())
+    val pendingTransfers = _pendingTransfers.asStateFlow()
+
     suspend fun syncActivities(): Result<Unit> = withContext(bgDispatcher) {
         Logger.debug("syncActivities called", context = TAG)
 
@@ -278,20 +286,33 @@ class ActivityRepo @Inject constructor(
 
                 when (activityToUpdate) {
                     is Activity.Onchain -> {
+                        val onChainActivity = activityToUpdate.v1.copy(
+                            feeRate = activityMetaData.feeRate.toULong(),
+                            address = activityMetaData.address,
+                            isTransfer = activityMetaData.isTransfer,
+                            channelId = activityMetaData.channelId,
+                            transferTxId = activityMetaData.transferTxId
+                        )
                         val updatedActivity = Onchain(
-                            v1 = activityToUpdate.v1.copy(
-                                feeRate = activityMetaData.feeRate.toULong(),
-                                address = activityMetaData.address,
-                                isTransfer = activityMetaData.isTransfer,
-                                channelId = activityMetaData.channelId,
-                                transferTxId = activityMetaData.transferTxId
-                            )
+                            v1 = onChainActivity
                         )
 
                         updateActivity(
                             id = updatedActivity.v1.id,
                             activity = updatedActivity
                         ).onSuccess {
+                            if (onChainActivity.isTransfer && onChainActivity.doesExist) {
+                                cacheStore.addInProgressTransfer(
+                                    InProgressTransfer(
+                                        activityId = updatedActivity.v1.id,
+                                        type = if (onChainActivity.txType == PaymentType.SENT) {
+                                            TransferType.TO_SPENDING
+                                        } else {
+                                            TransferType.TO_SAVINGS
+                                        }
+                                    )
+                                )
+                            }
                             cacheStore.removeTransactionMetadata(activityMetaData)
                         }
                     }