mirrors/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2024-11-19 01:43:16 +01:00
Code Issues Projects Releases Wiki Activity

itest: remove loop in wsTestCaseBiDirectionalSubscription

Browse Source 
So we know which open channel operation failed.
This commit is contained in:
yyforyongyu 2024-10-31 07:29:28 +08:00
parent b1403bc80d
commit c9d398616e
No known key found for this signature in database
GPG Key ID: 9BCD95C4FF296868
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
itest/lnd_rest_api_test.go
View File

@ -440,7 +440,6 @@ func wsTestCaseBiDirectionalSubscription(ht *lntest.HarnessTest) {
msgChan := make(chan *lnrpc.ChannelAcceptResponse, 1)
errChan := make(chan error)
done := make(chan struct{})
timeout := time.After(defaultTimeout)
// We want to read messages over and over again. We just accept any
// channels that are opened.
@ -506,6 +505,7 @@ func wsTestCaseBiDirectionalSubscription(ht *lntest.HarnessTest) {
}
return
}
ht.Log("Finish writing message")
// Also send the message on our message channel to make
// sure we count it as successful.
@ -525,23 +525,27 @@ func wsTestCaseBiDirectionalSubscription(ht *lntest.HarnessTest) {
bob := ht.NewNodeWithCoins("Bob", nil)
ht.EnsureConnected(alice, bob)
// Open 3 channels to make sure multiple requests and responses can be
// sent over the web socket.
const numChannels = 3
for i := 0; i < numChannels; i++ {
ht.OpenChannel(
bob, alice, lntest.OpenChannelParams{Amt: 500000},
)
assertMsgReceived := func() {
select {
case <-msgChan:
case err := <-errChan:
ht.Fatalf("Received error from WS: %v", err)
case <-timeout:
case <-time.After(defaultTimeout):
ht.Fatalf("Timeout before message was received")
}
}
// Open 3 channels to make sure multiple requests and responses can be
// sent over the web socket.
ht.OpenChannel(bob, alice, lntest.OpenChannelParams{Amt: 500000})
assertMsgReceived()
ht.OpenChannel(bob, alice, lntest.OpenChannelParams{Amt: 500000})
assertMsgReceived()
ht.OpenChannel(bob, alice, lntest.OpenChannelParams{Amt: 500000})
assertMsgReceived()
}
func wsTestPingPongTimeout(ht *lntest.HarnessTest) {