/* * This file is part of GNU Taler * (C) 2020 Taler Systems S.A. * * GNU Taler is free software; you can redistribute it and/or modify it under the * terms of the GNU General Public License as published by the Free Software * Foundation; either version 3, or (at your option) any later version. * * GNU Taler is distributed in the hope that it will be useful, but WITHOUT ANY * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR * A PARTICULAR PURPOSE. See the GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along with * GNU Taler; see the file COPYING. If not, see */ package net.taler.wallet import android.app.Application import android.util.Log import androidx.annotation.UiThread import androidx.lifecycle.AndroidViewModel import androidx.lifecycle.LiveData import androidx.lifecycle.MutableLiveData import androidx.lifecycle.distinctUntilChanged import androidx.lifecycle.viewModelScope import kotlinx.coroutines.Job import kotlinx.coroutines.launch import net.taler.common.Event import net.taler.common.assertUiThread import net.taler.common.toEvent import net.taler.wallet.backend.WalletBackendApi import net.taler.wallet.balances.BalanceItem import net.taler.wallet.balances.BalanceResponse import net.taler.wallet.exchanges.ExchangeManager import net.taler.wallet.payment.PaymentManager import net.taler.wallet.pending.PendingOperationsManager import net.taler.wallet.refund.RefundManager import net.taler.wallet.transactions.TransactionManager import net.taler.wallet.withdraw.WithdrawManager import org.json.JSONObject import java.util.concurrent.TimeUnit.DAYS import java.util.concurrent.TimeUnit.MINUTES import kotlin.random.Random const val TAG = "taler-wallet" private val transactionNotifications = listOf( "proposal-accepted", "refresh-revealed", "withdraw-group-finished" ) class MainViewModel(val app: Application) : AndroidViewModel(app) { private val mBalances = MutableLiveData>() val balances: LiveData> = mBalances.distinctUntilChanged() val devMode = MutableLiveData(BuildConfig.DEBUG) val showProgressBar = MutableLiveData() var exchangeVersion: String? = null private set var merchantVersion: String? = null private set private val api = WalletBackendApi(app) { payload -> if (payload.optString("operation") == "init") { val result = payload.getJSONObject("result") val versions = result.getJSONObject("supported_protocol_versions") exchangeVersion = versions.getString("exchange") merchantVersion = versions.getString("merchant") } else if (payload.getString("type") != "waiting-for-retry") { // ignore ping Log.i(TAG, "Received notification from wallet-core: ${payload.toString(2)}") loadBalances() if (payload.optString("type") in transactionNotifications) { assertUiThread() // TODO notification API should give us a currency to update // update currently selected transaction list transactionManager.loadTransactions() } // refresh pending ops and history with each notification if (devMode.value == true) { pendingOperationsManager.getPending() } } } val withdrawManager = WithdrawManager(api, viewModelScope) val paymentManager = PaymentManager(api, viewModelScope) val pendingOperationsManager: PendingOperationsManager = PendingOperationsManager(api) val transactionManager: TransactionManager = TransactionManager(api, viewModelScope) val refundManager = RefundManager(api, viewModelScope) val exchangeManager: ExchangeManager = ExchangeManager(api, viewModelScope) private val mTransactionsEvent = MutableLiveData>() val transactionsEvent: LiveData> = mTransactionsEvent private val mLastBackup = MutableLiveData( // fake backup time until we actually do backup System.currentTimeMillis() - Random.nextLong(MINUTES.toMillis(5), DAYS.toMillis(2)) ) val lastBackup: LiveData = mLastBackup override fun onCleared() { api.destroy() super.onCleared() } @UiThread fun loadBalances(): Job = viewModelScope.launch { showProgressBar.value = true val response = api.request("getBalances", BalanceResponse.serializer()) showProgressBar.value = false response.onError { // TODO expose in UI Log.e(TAG, "Error retrieving balances: $it") } response.onSuccess { mBalances.value = it.balances } } /** * Navigates to the given currency's transaction list, when [MainFragment] is shown. */ @UiThread fun showTransactions(currency: String) { mTransactionsEvent.value = currency.toEvent() } @UiThread fun dangerouslyReset() { api.sendRequest("reset") withdrawManager.testWithdrawalInProgress.value = false mBalances.value = emptyList() } fun startTunnel() { api.sendRequest("startTunnel") } fun stopTunnel() { api.sendRequest("stopTunnel") } fun tunnelResponse(resp: String) { val respJson = JSONObject(resp) api.sendRequest("tunnelResponse", respJson) } }