blob: ae338e8b1f9fad8fc3bae9c1df84bb5d6b1c7f11 (
plain)
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
|
/*
* This file is part of GNU Taler
* (C) 2022 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.backend
import android.util.Log
import kotlinx.serialization.decodeFromString
import kotlinx.serialization.json.Json
import net.taler.qtart.TalerWalletCore
import net.taler.wallet.BuildConfig
import org.json.JSONObject
import kotlin.coroutines.resume
import kotlin.coroutines.suspendCoroutine
fun interface NotificationReceiver {
fun onNotificationReceived(payload: NotificationPayload)
}
class BackendManager(
private val notificationReceiver: NotificationReceiver,
) {
companion object {
private const val TAG = "BackendManager"
private const val TAG_CORE = "taler-wallet-embedded"
val json = Json {
ignoreUnknownKeys = true
}
}
private val walletCore = TalerWalletCore()
private val requestManager = RequestManager()
init {
walletCore.setMessageHandler { onMessageReceived(it) }
if (BuildConfig.DEBUG) walletCore.setStdoutHandler {
Log.d(TAG_CORE, it)
}
}
fun run() {
walletCore.run()
}
suspend fun send(operation: String, args: JSONObject? = null): ApiResponse =
suspendCoroutine { cont ->
requestManager.addRequest(cont) { id ->
val request = JSONObject().apply {
put("id", id)
put("operation", operation)
if (args != null) put("args", args)
}
Log.d(TAG, "sending message:\n${request.toString(2)}")
walletCore.sendRequest(request.toString())
}
}
private fun onMessageReceived(msg: String) {
Log.d(TAG, "message received: $msg")
when (val message = json.decodeFromString<ApiMessage>(msg)) {
is ApiMessage.Notification -> {
notificationReceiver.onNotificationReceived(message.payload)
}
is ApiResponse -> {
val id = message.id
val cont = requestManager.getAndRemoveContinuation(id)
if (cont == null) {
Log.e(TAG, "wallet returned unknown request ID ($id)")
} else {
cont.resume(message)
}
}
}
}
}
|
