1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92
|
mod mock_error;
use mock_error::setup_error_handler;
use octocrab::Octocrab;
use wiremock::{
matchers::{method, path},
Mock, MockServer, ResponseTemplate,
};
async fn setup_delete_thread_sub_api(template: ResponseTemplate) -> MockServer {
let thread_id = 123u64;
let mock_server = MockServer::start().await;
Mock::given(method("DELETE"))
.and(path(format!(
"/notifications/threads/{thread_id}/subscription"
)))
.respond_with(template.clone())
.mount(&mock_server)
.await;
setup_error_handler(
&mock_server,
&format!("DELETE on /notifications/threads/{thread_id}/subscription was not received"),
)
.await;
mock_server
}
fn setup_octocrab(uri: &str) -> Octocrab {
Octocrab::builder().base_uri(uri).unwrap().build().unwrap()
}
const THREAD_ID: u64 = 123u64;
#[tokio::test]
async fn delete_thread_subscription_204() {
let template = ResponseTemplate::new(204);
let mock_server = setup_delete_thread_sub_api(template).await;
let client = setup_octocrab(&mock_server.uri());
let result = client
.activity()
.notifications()
.delete_thread_subscription(THREAD_ID.into())
.await;
assert!(
result.is_ok(),
"expected successful result, got error: {:#?}",
result
);
}
#[tokio::test]
async fn delete_thread_subscription_404() {
let template = ResponseTemplate::new(404);
let mock_server = setup_delete_thread_sub_api(template).await;
let client = setup_octocrab(&mock_server.uri());
let result = client
.activity()
.notifications()
.delete_thread_subscription(THREAD_ID.into())
.await;
assert!(
result.is_err(),
"expected error result, got success: {:#?}",
result
);
}
#[tokio::test]
async fn delete_thread_subscription_500() {
let template = ResponseTemplate::new(500);
let mock_server = setup_delete_thread_sub_api(template).await;
let client = setup_octocrab(&mock_server.uri());
let result = client
.activity()
.notifications()
.delete_thread_subscription(THREAD_ID.into())
.await;
assert!(
result.is_err(),
"expected error result, got success: {:#?}",
result
);
}
|