Added test

This commit is contained in:
2026-06-11 17:17:17 -04:00
parent cbd9392f5a
commit a6d70e3155
+108
View File
@@ -133,6 +133,22 @@ pub mod requests {
app.clone().oneshot(req).await app.clone().oneshot(req).await
} }
pub async fn login_service_user(app: &axum::Router, username: &String, passphrase: &String) -> Result<axum::response::Response, std::convert::Infallible> {
let payload = serde_json::json!({
"username": username,
"passphrase": passphrase,
});
let req = axum::http::Request::builder()
.method(axum::http::Method::POST)
.uri(super::callers::endpoints::LOGIN_SERVICE_USER)
.header(axum::http::header::CONTENT_TYPE, "application/json")
.body(axum::body::Body::from(payload.to_string()))
.unwrap();
app.clone().oneshot(req).await
}
} }
/// Test user firstname /// Test user firstname
@@ -216,6 +232,52 @@ async fn login_user(
} }
} }
async fn register_service_user(app: &axum::Router,) -> Result<textsender_models::user::ServiceUser, std::io::Error> {
match requests::register_service_user(&app).await {
Ok(response) => {
if axum::http::StatusCode::CREATED != response.status() {
Err(std::io::Error::other(format!(
"Status code is off {:?}",
response.status()
)))
} else {
match convert_response::<textsender_models::user::ServiceUser>(response).await {
Ok(service_user) => {
Ok(service_user)
}
Err(err) => {
Err(err)
}
}
}
}
Err(err) => Err(std::io::Error::other(err.to_string())),
}
}
async fn login_service_user(app: &axum::Router, username: &String, passphrase: &String) -> Result<textsender_models::token::LoginResult, std::io::Error> {
match requests::login_service_user(&app, username, passphrase).await {
Ok(response) => {
if axum::http::StatusCode::OK != response.status() {
Err(std::io::Error::other(format!(
"Status code is off {:?}",
response.status()
)))
} else {
match convert_response::<textsender_models::token::LoginResult>(response).await {
Ok(service_user) => {
Ok(service_user)
}
Err(err) => {
Err(err)
}
}
}
}
Err(err) => Err(std::io::Error::other(err.to_string())),
}
}
#[tokio::test] #[tokio::test]
async fn test_register_user() { async fn test_register_user() {
let tm_pool = db_mgr::get_pool().await.unwrap(); let tm_pool = db_mgr::get_pool().await.unwrap();
@@ -354,3 +416,49 @@ async fn test_register_service_user() {
} }
} }
} }
#[tokio::test]
async fn test_login_service_user() {
let tm_pool = db_mgr::get_pool().await.unwrap();
let db_name = db_mgr::generate_db_name().await;
match db_mgr::create_database(&tm_pool, &db_name).await {
Ok(_) => {
println!("Success");
}
Err(e) => {
assert!(false, "Error: {:?}", e.to_string());
}
}
let pool = db_mgr::connect_to_db(&db_name).await.unwrap();
db::init::migrations(&pool).await;
let app = init::routes().await.layer(axum::Extension(pool));
match register_service_user(&app).await {
Ok(user) => match login_service_user(&app, &user.username, TEST_SERVICE_PASSPHRASE).await {
Ok(login_result) => {
assert_eq!(
false,
login_result.access_token.is_empty(),
"Access token is empty when it should not be"
);
}
Err(err) => {
assert!(false, "Error: {err:?}");
}
},
Err(err) => {
assert!(false, "Error: {err:?}");
}
}
match db_mgr::drop_database(&tm_pool, &db_name).await {
Ok(()) => {}
Err(err) => {
assert!(false, "Error: {err:?}");
}
}
}