GlcoinCore/lndmanage
1
0
Fork 0
mirror of https://github.com/bitromortac/lndmanage.git synced 2026-08-13 12:33:37 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

lndmanage: communicate with lndmanaged

Browse source
This commit is contained in:
bitromortac 2022-04-29 20:24:54 +02:00
parent 4b51a5070b
commit 5f568bf20f
No known key found for this signature in database
GPG key ID: 1965063FC13BEBE2
1 changed files with 13 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

13
lndmanage/lib/node.py
View file

@ -18,6 +18,8 @@ import lndmanage.grpc_compiled.router_pb2 as lndrouter
import lndmanage.grpc_compiled.router_pb2_grpc as lndrouterrpc
import lndmanage.grpc_compiled.walletkit_pb2 as lndwalletkit
import lndmanage.grpc_compiled.walletkit_pb2_grpc as lndwalletkitrpc
import lndmanage.grpc_compiled.manager_pb2 as managermsg
import lndmanage.grpc_compiled.manager_pb2_grpc as managerrpc
from lndmanage.lib.network import Network
from lndmanage.lib.exceptions import PaymentTimeOut, NoRoute, OurNodeFailure
@ -53,8 +55,10 @@ class LndNode:
_walletrpc: lndwalletkitrpc.WalletKitStub
_async_rpc: lndrpc.LightningStub
_async_routerrpc: lndrouterrpc.RouterStub
_async_managerrpc: managerrpc.MangagerStub
_async_channel: grpc.aio.Channel
_sync_channel: grpc.Channel
_async_manager_channel: grpc.aio.Channel
# attributes (TODO: clean up)
alias: str
@ -152,6 +156,11 @@ class LndNode:
self._async_rpc = lndrpc.LightningStub(self._async_channel)
self._async_routerrpc = lndrouterrpc.RouterStub(self._async_channel)
# optionally connect to lndmanged
self._async_manager_channel = grpc.aio.insecure_channel(
'localhost:50051')
self._async_managerrpc = managerrpc.MangagerStub(self._async_manager_channel)
def connect_sync_rpcs(self):
self._sync_channel = grpc.secure_channel(
self.lnd_host, self.get_rpc_credentials(),
@ -1039,3 +1048,7 @@ class LndNode:
node_to_channel_map[cv['remote_pubkey']].append(c)
return node_to_channel_map
async def running_services(self):
resp = await self._async_managerrpc.RunningServices(managermsg.RunningServicesRequest())
print(resp)