[#1170] Regular transaction flow emitting

Although zcash/librustzcash#918 will provide information on when to trigger transaction polling, this partly solve the issue as well
Electric-Coin-Company · Sep 4, 2023 · 0a7620b · 0a7620b
1 parent 4a0b63d
commit 0a7620b
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 4 deletions.
diff --git a/.../screen/transactions/view/Transactions.kt → ...een/transactions/view/TransactionsView.kt b/.../screen/transactions/view/Transactions.kt → ...een/transactions/view/TransactionsView.kt
@@ -41,7 +41,7 @@ private fun ComposablePreview() {
     MaterialTheme {
         // TODO [#1090]: Demo: Add Addresses and Transactions Compose Previews
         // TODO [#1090]: https://github.com/zcash/zcash-android-wallet-sdk/issues/1090
-        // Transactions()
+        // TransactionsView()
     }
 }
 
@@ -127,7 +127,7 @@ private fun TransactionsMainContent(
                     val memos = synchronizer.getMemos(it)
                     queryScope.launch {
                         memos.toList().run {
-                            Twig.debug {
+                            Twig.info {
                                 "Transaction memos: count: $size, contains: ${joinToString().ifEmpty { "-" }}"
                             }
                         }

diff --git a/sdk-lib/src/main/java/cash/z/ecc/android/sdk/block/processor/CompactBlockProcessor.kt b/sdk-lib/src/main/java/cash/z/ecc/android/sdk/block/processor/CompactBlockProcessor.kt
@@ -475,6 +475,11 @@ class CompactBlockProcessor internal constructor(
                     SyncingResult.UpdateBirthday -> {
                         updateBirthdayHeight()
                     }
+                    SyncingResult.EnhanceSuccess -> {
+                        Twig.info { "Triggering transaction refresh now" }
+                        // Invalidate transaction data
+                        refreshTransactions(transactionStorage = repository)
+                    }
                     is SyncingResult.Failure -> {
                         syncingResult = rangeSyncProgress.resultState
                         return@collect
@@ -553,6 +558,12 @@ class CompactBlockProcessor internal constructor(
                         updateBirthdayHeight()
                         SyncingResult.AllSuccess
                     }
+                    SyncingResult.EnhanceSuccess -> {
+                        Twig.info { "Triggering transaction refresh now" }
+                        // Invalidate transaction data and return the common batch syncing success result to the caller
+                        refreshTransactions(transactionStorage = repository)
+                        SyncingResult.AllSuccess
+                    }
                     is SyncingResult.Failure -> {
                         rangeSyncProgress.resultState
                     } else -> {
@@ -598,6 +609,13 @@ class CompactBlockProcessor internal constructor(
         return BlockProcessingResult.Success
     }
 
+    /**
+     * This invalidates transaction storage to trigger data refreshing for its subscribers.
+     */
+    private fun refreshTransactions(transactionStorage: DerivedDataRepository) {
+        transactionStorage.invalidate()
+    }
+
     @Suppress("ReturnCount")
     internal suspend fun runSbSSyncingPreparation(
         backend: TypesafeBackend,
@@ -701,6 +719,11 @@ class CompactBlockProcessor internal constructor(
                 SyncingResult.UpdateBirthday -> {
                     updateBirthdayHeight()
                 }
+                SyncingResult.EnhanceSuccess -> {
+                    Twig.info { "Triggering transaction refresh now" }
+                    // Invalidate transaction data
+                    refreshTransactions(transactionStorage = repository)
+                }
                 is SyncingResult.Failure -> {
                     syncingResult = rangeSyncProgress.resultState
                     return@collect
@@ -1418,8 +1441,8 @@ class CompactBlockProcessor internal constructor(
                                     enhancingResult
                                 }
                                 else -> {
-                                    // Transactions enhanced correctly. Now we return common sync success state.
-                                    SyncingResult.AllSuccess
+                                    // Transactions enhanced correctly. Let's continue with block processing.
+                                    enhancingResult
                                 }
                             }
                             emit(