You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
59 lines
1.5 KiB
Rust
59 lines
1.5 KiB
Rust
use futures_util::StreamExt;
|
|
|
|
mod common;
|
|
|
|
#[tokio::test]
|
|
async fn test_options() {
|
|
let client = common::get_client();
|
|
client.get_options().await.unwrap();
|
|
}
|
|
|
|
#[tokio::test]
|
|
async fn test_metadata() {
|
|
let client = common::get_client();
|
|
let metadata = client.get_metadata(0).await.unwrap();
|
|
assert!(metadata.update_hashes().len() > 0);
|
|
}
|
|
|
|
const DEFINITIONS_UPDATE_HASH: &str =
|
|
"4a4d13c1fcdf0cf734927ec4c9637fdac6144512ad7dc919e0f222e7b0e71586";
|
|
const CONTENT_UPDATE_HASH: &str =
|
|
"cd1418ffeba0b8fe46aefa51a7adf1210356523ead658b182762ff61b73ebae5";
|
|
|
|
#[tokio::test]
|
|
async fn test_update() {
|
|
let client = common::get_client();
|
|
|
|
client.get_update(DEFINITIONS_UPDATE_HASH).await.unwrap();
|
|
client.get_update(CONTENT_UPDATE_HASH).await.unwrap();
|
|
}
|
|
|
|
#[tokio::test]
|
|
async fn test_update_stream() {
|
|
let client = common::get_client(); // 3230
|
|
let mut update_stream = client.stream_updates(0).await.unwrap();
|
|
let mut retry_count = 3;
|
|
let mut test_count = 25;
|
|
|
|
while let Some(update) = update_stream.next().await {
|
|
test_count -= 1;
|
|
if let Err(e) = update {
|
|
if retry_count > 0 {
|
|
retry_count -= 1;
|
|
update_stream.retry_latest();
|
|
} else {
|
|
assert!(
|
|
false,
|
|
"fetching next update failed within retry limit: {}",
|
|
e
|
|
)
|
|
}
|
|
} else {
|
|
retry_count = 3;
|
|
if test_count <= 0 {
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|