Skip to content

Commit

Permalink
add runtime_icmp
Browse files Browse the repository at this point in the history
  • Loading branch information
yanganto committed Sep 9, 2023
1 parent 4af2eec commit dc066c4
Show file tree
Hide file tree
Showing 2 changed files with 70 additions and 0 deletions.
4 changes: 4 additions & 0 deletions examples/runner/examples/test.rs
Original file line number Diff line number Diff line change
Expand Up @@ -69,4 +69,8 @@ mod net {
fn https_test_works() {
assert!(true);
}
#[test_with::runtime_icmp(193.194.195.196)]
fn test_ignored_with_non_existing_host() {
panic!("should be ignored with non existing host")
}
}
66 changes: 66 additions & 0 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -886,6 +886,72 @@ fn check_icmp_condition(attr_str: String) -> (bool, String) {
(missing_ips.is_empty(), ignore_msg)
}

/// Run test case when the example running and the http service exist.
///```rust
/// // write as example in exmaples/*rs
/// test_with::runner!(icmp);
/// #[test_with::module]
/// mod icmp {
/// // 193.194.195.196 is offline
/// #[test_with::runtime_icmp(193.194.195.196)]
/// fn test_ignored_with_non_existing_host() {
/// panic!("should be ignored with non existing host")
/// }
/// }
#[cfg(not(feature = "runtime"))]
#[proc_macro_attribute]
#[proc_macro_error]
pub fn runtime_icmp(_attr: TokenStream, _stream: TokenStream) -> TokenStream {
panic!("should be used with runtime feature")
}

#[cfg(all(feature = "runtime", feature = "icmp"))]
#[proc_macro_attribute]
#[proc_macro_error]
pub fn runtime_icmp(attr: TokenStream, stream: TokenStream) -> TokenStream {
let attr_str = attr.to_string().replace(' ', "");
let ips: Vec<&str> = attr_str.split(',').collect();
let ItemFn {
attrs,
vis,
sig,
block,
} = parse_macro_input!(stream as ItemFn);
let syn::Signature { ident, .. } = sig.clone();
let check_ident = syn::Ident::new(
&format!("_check_{}", ident.to_string()),
proc_macro2::Span::call_site(),
);
quote::quote! {
fn #check_ident() -> Result<(), libtest_with::Failed> {

let mut missing_ips = vec![];
let client = libtest_with::reqwest::blocking::Client::new();
#(
if client.head(&format!("https://{}", #ips)).send().is_err() {
missing_ips.push(format!("https://{}", #ips));
}
)*
match missing_ips.len() {
0 => #ident(),
1 => return Err(
format!("{}because {} not response",
libtest_with::RUNTIME_IGNORE_PREFIX, missing_ips[0]
).into()),
_ => return Err(
format!("{}because following ips not response: \n{}\n",
libtest_with::RUNTIME_IGNORE_PREFIX, missing_ips.join(", ")
).into()),
}
Ok(())
}

#(#attrs)*
#vis #sig #block
}
.into()
}

/// Run test case when socket connected
///
/// ```
Expand Down

0 comments on commit dc066c4

Please sign in to comment.