codex-storage
/
nim-libp2p
mirror of https://github.com/codex-storage/nim-libp2p.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix testrelay (#860)

This commit is contained in:
Ludovic Chenut 2023-02-15 11:18:42 +01:00 committed by GitHub
parent f7f1e89669
commit 0012b639c8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/testrelayv2.nim
View File

@ -40,7 +40,7 @@ suite "Circuit Relay V2":
range {.threadvar.}: HSlice[times.DateTime, times.DateTime] range {.threadvar.}: HSlice[times.DateTime, times.DateTime]
asyncSetup: asyncSetup:
ttl = 1 ttl = 3
ldur = 60 ldur = 60
ldata = 2048 ldata = 2048
cl1 = RelayClient.new() cl1 = RelayClient.new()
@ -179,12 +179,12 @@ suite "Circuit Relay V2":
await allFutures(src.stop(), dst.stop(), rel.stop()) await allFutures(src.stop(), dst.stop(), rel.stop())
asyncTest "Connection duration exceeded": asyncTest "Connection duration exceeded":
ldur = 2 ldur = 3
proto.handler = proc(conn: Connection, proto: string) {.async.} = proto.handler = proc(conn: Connection, proto: string) {.async.} =
check "wanna sleep?" == string.fromBytes(await conn.readLp(1024)) check "wanna sleep?" == string.fromBytes(await conn.readLp(1024))
await conn.writeLp("yeah!") await conn.writeLp("yeah!")
check "go!" == string.fromBytes(await conn.readLp(1024)) check "go!" == string.fromBytes(await conn.readLp(1024))
await sleepAsync(3000) await sleepAsync(chronos.timer.seconds(ldur + 1))
await conn.writeLp("that was a cool power nap") await conn.writeLp("that was a cool power nap")
await conn.close() await conn.close()
rv2 = Relay.new(reservationTTL=initDuration(seconds=ttl), rv2 = Relay.new(reservationTTL=initDuration(seconds=ttl),
@ -263,7 +263,7 @@ take to the ship.""")
await allFutures(src.stop(), dst.stop(), rel.stop()) await allFutures(src.stop(), dst.stop(), rel.stop())
asyncTest "Reservation ttl expire during connection": asyncTest "Reservation ttl expire during connection":
ttl = 1 ttl = 3
proto.handler = proc(conn: Connection, proto: string) {.async.} = proto.handler = proc(conn: Connection, proto: string) {.async.} =
check: "test1" == string.fromBytes(await conn.readLp(1024)) check: "test1" == string.fromBytes(await conn.readLp(1024))
await conn.writeLp("test2") await conn.writeLp("test2")
@ -294,7 +294,7 @@ take to the ship.""")
await conn.writeLp("test3") await conn.writeLp("test3")
check: "test4" == string.fromBytes(await conn.readLp(1024)) check: "test4" == string.fromBytes(await conn.readLp(1024))
await src.disconnect(rel.peerInfo.peerId) await src.disconnect(rel.peerInfo.peerId)
await sleepAsync(2000) await sleepAsync(chronos.timer.seconds(ttl + 1))
expect(DialFailedError): expect(DialFailedError):
check: conn.atEof() check: conn.atEof()