highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-08-29 23:21:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

itest: fix RPC middleware itest

Browse Source
This commit is contained in:
Oliver Gugger
2022-01-05 12:57:17 +01:00
committed by yyforyongyu
parent 587273174e
commit 10d876ae98
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lntest/harness_node.go
View File

@@ -655,7 +655,7 @@ func (hn *HarnessNode) start(lndBinary string, lndError chan<- error,
} }
// Init all the RPC clients. // Init all the RPC clients.
hn.initRPCClients(conn) hn.InitRPCClients(conn)
if err := hn.WaitUntilStarted(); err != nil { if err := hn.WaitUntilStarted(); err != nil {
return err return err
@@ -717,7 +717,7 @@ func (hn *HarnessNode) WaitUntilLeader(timeout time.Duration) error {
} }
// Init all the RPC clients. // Init all the RPC clients.
hn.initRPCClients(conn) hn.InitRPCClients(conn)
if err := hn.WaitUntilStarted(); err != nil { if err := hn.WaitUntilStarted(); err != nil {
return err return err
@@ -772,7 +772,7 @@ func (hn *HarnessNode) initClientWhenReady(stateless bool,
} }
// Init all the RPC clients. // Init all the RPC clients.
hn.initRPCClients(conn) hn.InitRPCClients(conn)
return hn.initLightningClient() return hn.initLightningClient()
} }
@@ -897,8 +897,8 @@ func (hn *HarnessNode) waitTillServerState(
} }
} }
// initRPCClients initializes a list of RPC clients for the node. // InitRPCClients initializes a list of RPC clients for the node.
func (hn *HarnessNode) initRPCClients(c *grpc.ClientConn) { func (hn *HarnessNode) InitRPCClients(c *grpc.ClientConn) {
hn.rpc = &RPCClients{ hn.rpc = &RPCClients{
conn: c, conn: c,
LN: lnrpc.NewLightningClient(c), LN: lnrpc.NewLightningClient(c),

1
lntest/itest/lnd_rpc_middleware_interceptor_test.go
View File

@@ -403,6 +403,7 @@ func middlewareMandatoryTest(t *testing.T, node *lntest.HarnessNode,
// test case. So we need to do the wait and client setup manually here. // test case. So we need to do the wait and client setup manually here.
conn, err := node.ConnectRPC(true) conn, err := node.ConnectRPC(true)
require.NoError(t, err) require.NoError(t, err)
node.InitRPCClients(conn)
err = node.WaitUntilStateReached(lnrpc.WalletState_RPC_ACTIVE) err = node.WaitUntilStateReached(lnrpc.WalletState_RPC_ACTIVE)
require.NoError(t, err) require.NoError(t, err)
node.LightningClient = lnrpc.NewLightningClient(conn) node.LightningClient = lnrpc.NewLightningClient(conn)