aboutsummaryrefslogtreecommitdiff
path: root/app/src/main/java/org/pacien/tincapp/activities/status/nodes/NodeListLiveData.kt
diff options
context:
space:
mode:
Diffstat (limited to 'app/src/main/java/org/pacien/tincapp/activities/status/nodes/NodeListLiveData.kt')
-rw-r--r--app/src/main/java/org/pacien/tincapp/activities/status/nodes/NodeListLiveData.kt13
1 files changed, 7 insertions, 6 deletions
diff --git a/app/src/main/java/org/pacien/tincapp/activities/status/nodes/NodeListLiveData.kt b/app/src/main/java/org/pacien/tincapp/activities/status/nodes/NodeListLiveData.kt
index cada4bc..1036cc9 100644
--- a/app/src/main/java/org/pacien/tincapp/activities/status/nodes/NodeListLiveData.kt
+++ b/app/src/main/java/org/pacien/tincapp/activities/status/nodes/NodeListLiveData.kt
@@ -20,19 +20,20 @@ package org.pacien.tincapp.activities.status.nodes
20 20
21import org.pacien.tincapp.activities.common.SelfRefreshingLiveData 21import org.pacien.tincapp.activities.common.SelfRefreshingLiveData
22import org.pacien.tincapp.commands.Tinc 22import org.pacien.tincapp.commands.Tinc
23import org.pacien.tincapp.service.TincVpnService
23import java.util.concurrent.TimeUnit 24import java.util.concurrent.TimeUnit
24 25
25/** 26/**
26 * @author pacien 27 * @author pacien
27 */ 28 */
28class NodeListLiveData(private val netName: String) : SelfRefreshingLiveData<List<NodeInfo>>(1, TimeUnit.SECONDS) { 29class NodeListLiveData : SelfRefreshingLiveData<List<NodeInfo>>(1, TimeUnit.SECONDS) {
30 private val vpnService = TincVpnService
29 private val tincCtl = Tinc 31 private val tincCtl = Tinc
30 32
31 override fun onRefresh() { 33 override fun onRefresh() {
32 val nodeList = tincCtl.dumpNodes(netName) 34 vpnService.getCurrentNetName()
33 .thenApply { list -> list.map { NodeInfo.ofNodeDump(it) } } 35 ?.let { netName -> tincCtl.dumpNodes(netName) }
34 .get() 36 ?.thenApply { list -> list.map { NodeInfo.ofNodeDump(it) } }
35 37 ?.thenAccept(this::postValue)
36 postValue(nodeList)
37 } 38 }
38} 39}