1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
/*
* This file is part of GNU Taler
* (C) 2024 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 <http://www.gnu.org/licenses/>
*/
package net.taler.wallet.balances
import android.util.Log
import androidx.annotation.UiThread
import androidx.lifecycle.LiveData
import androidx.lifecycle.MutableLiveData
import androidx.lifecycle.distinctUntilChanged
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.launch
import kotlinx.serialization.Serializable
import kotlinx.serialization.encodeToString
import kotlinx.serialization.json.Json
import net.taler.common.CurrencySpecification
import net.taler.wallet.TAG
import net.taler.wallet.backend.TalerErrorInfo
import net.taler.wallet.backend.WalletBackendApi
import org.json.JSONObject
@Serializable
data class BalanceResponse(
val balances: List<BalanceItem>
)
@Serializable
data class GetCurrencySpecificationResponse(
val currencySpecification: CurrencySpecification,
)
sealed class BalanceState {
data object None: BalanceState()
data object Loading: BalanceState()
data class Success(
val balances: List<BalanceItem>,
): BalanceState()
data class Error(
val error: TalerErrorInfo,
): BalanceState()
}
class BalanceManager(
private val api: WalletBackendApi,
private val scope: CoroutineScope,
) {
private val mBalances = MutableLiveData<List<BalanceItem>>(emptyList())
val balances: LiveData<List<BalanceItem>> = mBalances
private val mState = MutableLiveData<BalanceState>(BalanceState.None)
val state: LiveData<BalanceState> = mState.distinctUntilChanged()
private val currencySpecs: MutableMap<ScopeInfo, CurrencySpecification?> = mutableMapOf()
@UiThread
fun loadBalances() {
mState.value = BalanceState.Loading
scope.launch {
val response = api.request("getBalances", BalanceResponse.serializer())
response.onError {
Log.e(TAG, "Error retrieving balances: $it")
mState.postValue(BalanceState.Error(it))
}
response.onSuccess {
mBalances.postValue(it.balances)
scope.launch {
// Fetch missing currency specs for all balances
it.balances.forEach { balance ->
if (!currencySpecs.containsKey(balance.scopeInfo)) {
currencySpecs[balance.scopeInfo] = getCurrencySpecification(balance.scopeInfo)
}
}
mState.postValue(
BalanceState.Success(it.balances.map { balance ->
val spec = currencySpecs[balance.scopeInfo]
balance.copy(
available = balance.available.withSpec(spec),
pendingIncoming = balance.pendingIncoming.withSpec(spec),
pendingOutgoing = balance.pendingOutgoing.withSpec(spec),
)
}),
)
}
}
}
}
private suspend fun getCurrencySpecification(scopeInfo: ScopeInfo): CurrencySpecification? {
var spec: CurrencySpecification? = null
api.request("getCurrencySpecification", GetCurrencySpecificationResponse.serializer()) {
val json = Json.encodeToString(scopeInfo)
Log.d(TAG, "BalanceManager: $json")
put("scope", JSONObject(json))
}.onSuccess {
spec = it.currencySpecification
}.onError {
Log.e(TAG, "Error getting currency spec for scope $scopeInfo: $it")
}
return spec
}
@Deprecated("Please find spec via scopeInfo instead", ReplaceWith("getSpecForScopeInfo"))
fun getSpecForCurrency(currency: String): CurrencySpecification? {
val state = mState.value
if (state !is BalanceState.Success) return null
return state.balances.find { it.currency == currency }?.available?.spec
}
fun getSpecForScopeInfo(scopeInfo: ScopeInfo): CurrencySpecification? {
val state = mState.value
if (state !is BalanceState.Success) return null
return state.balances.find { it.scopeInfo == scopeInfo }?.available?.spec
}
fun resetBalances() {
mState.value = BalanceState.None
}
}
|
