59 lines
1.9 KiB
Kotlin
59 lines
1.9 KiB
Kotlin
package cash.z.android.wallet.ui.presenter
|
|
|
|
import android.util.Log
|
|
import cash.z.android.wallet.ui.presenter.Presenter.PresenterView
|
|
import cash.z.wallet.sdk.dao.WalletTransaction
|
|
import cash.z.wallet.sdk.data.ActiveSendTransaction
|
|
import cash.z.wallet.sdk.data.ActiveTransaction
|
|
import cash.z.wallet.sdk.data.Synchronizer
|
|
import cash.z.wallet.sdk.data.TransactionState
|
|
import cash.z.wallet.sdk.data.twig
|
|
import kotlinx.coroutines.*
|
|
import kotlinx.coroutines.Dispatchers.Main
|
|
import kotlinx.coroutines.channels.ReceiveChannel
|
|
import kotlin.coroutines.CoroutineContext
|
|
|
|
class HistoryPresenter(
|
|
private val view: HistoryView,
|
|
private val synchronizer: Synchronizer
|
|
) : Presenter, CoroutineScope {
|
|
|
|
private val job = Job()
|
|
override val coroutineContext: CoroutineContext get() = Dispatchers.Main + job
|
|
|
|
interface HistoryView : PresenterView {
|
|
fun setTransactions(transactions: List<WalletTransaction>)
|
|
}
|
|
|
|
override suspend fun start() {
|
|
Log.e("@TWIG", "historyPresenter starting!")
|
|
launchTransactionBinder(synchronizer.allTransactions())
|
|
}
|
|
|
|
override fun stop() {
|
|
Log.e("@TWIG", "historyPresenter stopping!")
|
|
job.cancel()
|
|
}
|
|
|
|
private fun CoroutineScope.launchTransactionBinder(channel: ReceiveChannel<List<WalletTransaction>>) = launch {
|
|
Log.e("@TWIG", "transaction binder starting!")
|
|
for (walletTransactionList in channel) {
|
|
Log.e("@TWIG", "received ${walletTransactionList.size} transactions for presenting")
|
|
bind(walletTransactionList)
|
|
}
|
|
Log.e("@TWIG", "transaction binder exiting!")
|
|
}
|
|
|
|
|
|
//
|
|
// View Callbacks on Main Thread
|
|
//
|
|
|
|
private fun bind(transactions: List<WalletTransaction>) {
|
|
twig("binding ${transactions.size} walletTransactions")
|
|
view.setTransactions(transactions.sortedByDescending { it.timeInSeconds })
|
|
}
|
|
|
|
}
|
|
|