Fetch all transactions for given address

horizontalsystems · Mar 31, 2023 · bd4633b · bd4633b
1 parent aa88f67
commit bd4633b
Showing 1 changed file with 26 additions and 17 deletions.
diff --git a/ecashkit/src/main/kotlin/io/horizontalsystems/ecash/ChronikApi.kt b/ecashkit/src/main/kotlin/io/horizontalsystems/ecash/ChronikApi.kt
@@ -15,26 +15,35 @@ class ChronikApi : IInitialSyncApi {
 
         for (address in addresses) {
             try {
-                val get = apiManager.get("script/p2pkh/$address/history")
-                val txHistoryPage = Chronik.TxHistoryPage.parseFrom(get)
-                transactionItems.addAll(
-                    txHistoryPage.txsList.map {
-                        TransactionItem(
-                            blockHash = it.block.hash.toByteArray().toReversedHex(),
-                            blockHeight = it.block.height,
-                            txOutputs = it.outputsList.map { txOutput ->
-                                TransactionOutputItem(
-                                    script = txOutput.outputScript.toByteArray().toReversedHex(),
-                                    address = ""
-                                )
-                            }
-                        )
-                    }
-                )
+                var page = 0
+
+                while (true) {
+                    Thread.sleep(10)
+                    val get = apiManager.get("script/p2pkh/$address/history?page=$page")
+                    val txHistoryPage = Chronik.TxHistoryPage.parseFrom(get)
+                    transactionItems.addAll(
+                        txHistoryPage.txsList.map {
+                            TransactionItem(
+                                blockHash = it.block.hash.toByteArray().toReversedHex(),
+                                blockHeight = it.block.height,
+                                txOutputs = it.outputsList.map { txOutput ->
+                                    TransactionOutputItem(
+                                        script = txOutput.outputScript.toByteArray().toReversedHex(),
+                                        address = ""
+                                    )
+                                }
+                            )
+                        }
+                    )
+
+                    page++
+
+                    if (txHistoryPage.numPages < page + 1)
+                        break
+                }
             } catch (e: Throwable) {
                 continue
             }
-            Thread.sleep(10)
         }
 
         return transactionItems