fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-05-28 10:11:19 +00:00
Code Issues Projects Releases Wiki Activity

feat(ci): Add support for test_timeout option (#3379)

Browse Source 
Node and browser tests take a little bit longer to spin up in the interop tests. The multidim-interop can tell the tests to increase the timeout when testing against these targets, but the test itself needs to use the passed in value.

This updates the test code to handle the new test_timeout option. See https://github.com/libp2p/test-plans/issues/107
This commit is contained in:
Marco Munizaga 2023-01-25 14:05:03 -08:00 committed by GitHub
parent 43909fa9b0
commit 1b45d5e4dd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
interop-tests/src/bin/ping.rs
View File

@ -16,8 +16,6 @@ use libp2p::{
use redis::AsyncCommands;
use strum::EnumString;
const REDIS_TIMEOUT: usize = 10;
/// Supported transports by rust-libp2p.
#[derive(Clone, Debug, EnumString)]
#[strum(serialize_all = "kebab-case")]
@ -110,6 +108,10 @@ async fn main() -> Result<()> {
.unwrap_or_else(|_| "true".into())
.parse::<bool>()?;
let test_timeout = env::var("test_timeout")
.unwrap_or_else(|_| "10".into())
.parse::<usize>()?;
let redis_addr = env::var("REDIS_ADDR")
.map(|addr| format!("redis://{addr}"))
.unwrap_or_else(|_| "redis://redis:6379".into());
@ -191,7 +193,7 @@ async fn main() -> Result<()> {
// retrieved via `listenAddr` key over the redis connection. Or wait to be pinged and have
// `dialerDone` key ready on the redis connection.
if is_dialer {
let result: Vec<String> = conn.blpop("listenerAddr", REDIS_TIMEOUT).await?;
let result: Vec<String> = conn.blpop("listenerAddr", test_timeout).await?;
let other = result
.get(1)
.context("Failed to wait for listener to be ready")?;
@ -236,7 +238,7 @@ async fn main() -> Result<()> {
}
});
let done: Vec<String> = conn.blpop("dialerDone", REDIS_TIMEOUT).await?;
let done: Vec<String> = conn.blpop("dialerDone", test_timeout).await?;
done.get(1)
.context("Failed to wait for dialer conclusion")?;
log::info!("Ping successful");