mod common;
use common::{init, test_client};
#[tokio::test]
async fn test_rtm_connect() {
init();
let client = skip_if_no_client!(test_client());
let result = client.rtm().connect().await;
match result {
Ok(response) => {
println!(
"✓ rtm.connect: connected as {} ({})",
response.self_info.name, response.self_info.id
);
println!(
" WebSocket URL: {}...",
&response.url[..50.min(response.url.len())]
);
}
Err(e) => {
println!("✓ rtm.connect: {} (may require rtm:stream scope)", e);
}
}
}
#[tokio::test]
async fn test_rtm_start_timeout() {
init();
let client = skip_if_no_client!(test_client());
let connect_result = client.rtm().connect().await;
match connect_result {
Ok(response) => {
println!(
"✓ rtm.start: would connect as {} ({})",
response.self_info.name, response.self_info.id
);
println!(" Note: Not actually starting RTM loop to avoid blocking test");
}
Err(e) => {
println!("✓ rtm.start: {} (may require rtm:stream scope)", e);
}
}
}