Skip to content

Commit

Permalink
Rename app to service
Browse files Browse the repository at this point in the history
  • Loading branch information
@canac
canac committed Jan 4, 2024
1 parent 322e645 commit 554d2b5
Showing 1 changed file with 32 additions and 32 deletions.
64 changes: 32 additions & 32 deletions http_server/src/main.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -170,163 +170,163 @@ mod tests {
#[actix_web::test]
async fn test_missing_authorization_header() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get().uri("/api/messages").to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_client_error());
}

#[actix_web::test]
async fn test_invalid_authorization_header() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get()
.uri("/api/messages")
.append_header((header::AUTHORIZATION, "Bearer invalid"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_client_error());
}

#[actix_web::test]
async fn test_cors_header() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get()
.uri("/api/messages")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
assert_eq!(res.headers().get(ACCESS_CONTROL_ALLOW_ORIGIN).unwrap(), "*");
}

#[actix_web::test]
async fn test_filter_ids() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get()
.uri("/api/messages?ids=1")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());

let req = TestRequest::get()
.uri("/api/messages?ids=1,2,3")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());

let req = TestRequest::get()
.uri("/api/messages?ids=foo")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_client_error());
}

#[actix_web::test]
async fn test_filter_mailbox() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get()
.uri("/api/messages?mailbox=foo")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
}

#[actix_web::test]
async fn test_filter_states() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get()
.uri("/api/messages?states=unread")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());

let req = TestRequest::get()
.uri("/api/messages?states=read,archived")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());

let req = TestRequest::get()
.uri("/api/messages?states=unread,foo")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_client_error());
}

#[actix_web::test]
async fn test_filter_multiple() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get()
.uri("/api/messages?ids=1,2,3&mailbox=foo&states=unread,read")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
}

#[actix_web::test]
async fn test_delete_no_filter() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::delete()
.uri("/api/messages")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_client_error());
}

#[actix_web::test]
async fn test_messages() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get()
.uri("/api/messages")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
}

#[actix_web::test]
async fn test_mailboxes() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::get()
.uri("/api/mailboxes")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
}

#[actix_web::test]
async fn test_create_single_message() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::post()
.uri("/api/messages")
Expand All @@ -340,14 +340,14 @@ mod tests {
}"#,
)
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
}

#[actix_web::test]
async fn test_create_multiple_messages() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::post()
.uri("/api/messages")
Expand All @@ -364,35 +364,35 @@ mod tests {
}]"#,
)
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
}

#[actix_web::test]
async fn test_update_messages() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::put()
.uri("/api/messages?states=unread")
.append_header((header::AUTHORIZATION, "Bearer token"))
.append_header(header::ContentType::json())
.set_payload(r#"{"new_state": "read"}"#)
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
}

#[actix_web::test]
async fn test_delete_messages() {
let app = App::new().configure(make_config().await.unwrap());
let app = test::init_service(app).await;
let service = test::init_service(app).await;

let req = TestRequest::delete()
.uri("/api/messages?states=unread")
.append_header((header::AUTHORIZATION, "Bearer token"))
.to_request();
let res = call_service(&app, req).await;
let res = call_service(&service, req).await;
assert!(res.status().is_success());
}
}

0 comments on commit 554d2b5

Please sign in to comment.