mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-04-26 11:02:14 +00:00
fix(test): improve flakey random walk discovery test (#574)
* test: improve stability of dht discovery test * test: isolate who is random walking
This commit is contained in:
parent
524e6f8433
commit
f4ec35573e
@ -139,17 +139,21 @@ describe('peer discovery scenarios', () => {
|
|||||||
},
|
},
|
||||||
dht: {
|
dht: {
|
||||||
randomWalk: {
|
randomWalk: {
|
||||||
enabled: true,
|
enabled: false,
|
||||||
delay: 1000, // start the first query quickly
|
delay: 1000, // start the first query quickly
|
||||||
interval: 10000,
|
interval: 10000,
|
||||||
timeout: 1000
|
timeout: 5000
|
||||||
},
|
},
|
||||||
enabled: true
|
enabled: true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
libp2p = new Libp2p(getConfig(peerInfo))
|
const localConfig = getConfig(peerInfo)
|
||||||
|
// Only run random walk on our local node
|
||||||
|
localConfig.config.dht.randomWalk.enabled = true
|
||||||
|
libp2p = new Libp2p(localConfig)
|
||||||
|
|
||||||
const remoteLibp2p1 = new Libp2p(getConfig(remotePeerInfo1))
|
const remoteLibp2p1 = new Libp2p(getConfig(remotePeerInfo1))
|
||||||
const remoteLibp2p2 = new Libp2p(getConfig(remotePeerInfo2))
|
const remoteLibp2p2 = new Libp2p(getConfig(remotePeerInfo2))
|
||||||
|
|
||||||
@ -161,6 +165,7 @@ describe('peer discovery scenarios', () => {
|
|||||||
})
|
})
|
||||||
|
|
||||||
await Promise.all([
|
await Promise.all([
|
||||||
|
libp2p.start(),
|
||||||
remoteLibp2p1.start(),
|
remoteLibp2p1.start(),
|
||||||
remoteLibp2p2.start()
|
remoteLibp2p2.start()
|
||||||
])
|
])
|
||||||
@ -173,8 +178,6 @@ describe('peer discovery scenarios', () => {
|
|||||||
remoteLibp2p2.dial(remotePeerInfo1)
|
remoteLibp2p2.dial(remotePeerInfo1)
|
||||||
])
|
])
|
||||||
|
|
||||||
libp2p.start()
|
|
||||||
|
|
||||||
await deferred.promise
|
await deferred.promise
|
||||||
return Promise.all([
|
return Promise.all([
|
||||||
remoteLibp2p1.stop(),
|
remoteLibp2p1.stop(),
|
||||||
|
Loading…
x
Reference in New Issue
Block a user