mirrors/eclair
1
0
Fork 0
mirror of https://github.com/ACINQ/eclair.git synced 2025-01-19 13:43:43 +01:00
Code Issues Projects Releases Wiki Activity

Increase timeout onion message integration tests (#2106)

Browse Source 
In channel tests, we set a 60 seconds timeout on the receiver end,
otherwise we sometimes run into timeout on slow CI machines that run a
lot of tests in parallel.

It makes sense to do the same for onion messages, to help us figure out
whether there is a race condition or it's just the machines that are slow.
This commit is contained in:
Bastien Teinturier 2021-12-14 19:20:48 +01:00 committed by GitHub
parent 4ebc8b5d6b
commit 576c0f6e39
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
eclair-core/src/test/scala/fr/acinq/eclair/integration/MessageIntegrationSpec.scala
View File

@ -68,7 +68,7 @@ class MessageIntegrationSpec extends IntegrationSpec {
alice.sendOnionMessage(nodes("B").nodeParams.nodeId :: Nil, ByteVector.empty, Some(hex"111111")).pipeTo(probe.ref)
assert(probe.expectMsgType[SendOnionMessageResponse].sent)
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage]
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage](max = 60 seconds)
assert(r.pathId === Some(hex"111111"))
}
@ -82,7 +82,7 @@ class MessageIntegrationSpec extends IntegrationSpec {
eve.sendOnionMessage(nodes("A").nodeParams.nodeId :: Nil, ByteVector.empty, Some(hex"111111")).pipeTo(probe.ref)
assert(probe.expectMsgType[SendOnionMessageResponse].sent)
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage]
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage](max = 60 seconds)
assert(r.pathId === Some(hex"111111"))
}
@ -96,7 +96,7 @@ class MessageIntegrationSpec extends IntegrationSpec {
fabrice.sendOnionMessage(nodes("A").nodeParams.nodeId :: Nil, ByteVector.empty, Some(hex"111111")).pipeTo(probe.ref)
assert(probe.expectMsgType[SendOnionMessageResponse].sent)
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage]
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage](max = 60 seconds)
assert(r.pathId === Some(hex"111111"))
}
@ -110,7 +110,7 @@ class MessageIntegrationSpec extends IntegrationSpec {
alice.sendOnionMessage(nodes("B").nodeParams.nodeId :: nodes("C").nodeParams.nodeId :: Nil, hex"710301020375020102", Some(hex"2222")).pipeTo(probe.ref)
assert(probe.expectMsgType[SendOnionMessageResponse].sent)
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage]
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage](max = 60 seconds)
assert(r.pathId === Some(hex"2222"))
assert(r.finalPayload.records.unknown.toSet === Set(GenericTlv(UInt64(113), hex"010203"), GenericTlv(UInt64(117), hex"0102")))
}
@ -204,7 +204,7 @@ class MessageIntegrationSpec extends IntegrationSpec {
alice.sendOnionMessage(nodes("E").nodeParams.nodeId :: nodes("C").nodeParams.nodeId :: Nil, hex"710301020375020102", Some(hex"2222")).pipeTo(probe.ref)
assert(probe.expectMsgType[SendOnionMessageResponse].sent)
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage]
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage](max = 60 seconds)
assert(r.pathId === Some(hex"2222"))
assert(r.finalPayload.records.unknown.toSet === Set(GenericTlv(UInt64(113), hex"010203"), GenericTlv(UInt64(117), hex"0102")))
}
@ -230,7 +230,7 @@ class MessageIntegrationSpec extends IntegrationSpec {
alice.sendOnionMessage(nodes("C").nodeParams.nodeId :: Nil, ByteVector.empty, Some(hex"33333333")).pipeTo(probe.ref)
assert(probe.expectMsgType[SendOnionMessageResponse].sent)
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage]
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage](max = 60 seconds)
assert(r.pathId === Some(hex"33333333"))
// We disconnect A from C for future tests.
@ -283,7 +283,7 @@ class MessageIntegrationSpec extends IntegrationSpec {
alice.sendOnionMessage(nodes("B").nodeParams.nodeId :: nodes("C").nodeParams.nodeId :: Nil, hex"7300", None).pipeTo(probe.ref)
assert(probe.expectMsgType[SendOnionMessageResponse].sent)
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage]
val r = eventListener.expectMsgType[OnionMessages.ReceiveMessage](max = 60 seconds)
assert(r.pathId === None)
assert(r.finalPayload.records.unknown.toSet === Set(GenericTlv(UInt64(115), hex"")))
}