@@ -59,7 +59,6 @@ import javax.inject.Singleton
5959import kotlin.io.path.Path
6060import kotlin.time.Duration
6161import kotlin.time.Duration.Companion.seconds
62- import kotlin.toString
6362
6463typealias NodeEventHandler = suspend (Event ) -> Unit
6564
@@ -74,7 +73,7 @@ class LightningService @Inject constructor(
7473 @Volatile
7574 var node: Node ? = null
7675
77- private lateinit var trustedLnPeers : List <PeerDetails >
76+ private lateinit var trustedPeers : List <PeerDetails >
7877
7978 suspend fun setup (
8079 walletIndex : Int ,
@@ -85,16 +84,17 @@ class LightningService @Inject constructor(
8584 val passphrase = keychain.loadString(Keychain .Key .BIP39_PASSPHRASE .name)
8685
8786 // TODO get trustedLnPeers from blocktank info
88- this .trustedLnPeers = Env .trustedLnPeers
87+ this .trustedPeers = Env .trustedLnPeers
8988 val dirPath = Env .ldkStoragePath(walletIndex)
9089
91- val trustedPeers0conf = trustedLnPeers.map { it.nodeId }
90+ val trustedPeerNodeIds = trustedPeers.map { it.nodeId }
91+
9292 val config = defaultConfig().copy(
9393 storageDirPath = dirPath,
9494 network = Env .network,
95- trustedPeers0conf = trustedPeers0conf ,
95+ trustedPeers0conf = trustedPeerNodeIds ,
9696 anchorChannelsConfig = AnchorChannelsConfig (
97- trustedPeersNoReserve = trustedPeers0conf ,
97+ trustedPeersNoReserve = trustedPeerNodeIds ,
9898 perChannelReserveSats = 1u ,
9999 )
100100 )
@@ -274,7 +274,7 @@ class LightningService @Inject constructor(
274274 val node = this .node ? : throw ServiceError .NodeNotSetup
275275
276276 ServiceQueue .LDK .background {
277- for (peer in trustedLnPeers ) {
277+ for (peer in trustedPeers ) {
278278 try {
279279 node.connect(peer.nodeId, peer.address, persist = true )
280280 Logger .info(" Connected to trusted peer: $peer " )
0 commit comments