use activitypub_federation::{ axum::json::FederationJson, config::Data, protocol::context::WithContext, traits::Object, }; use axum::{debug_handler, extract::Path, http::StatusCode, response::IntoResponse}; use crate::{error::AppError, state::AppHandle}; #[debug_handler] pub async fn http_get_user( Path(name): Path, data: Data, ) -> Result { if let Some(a) = read_user(&name, &data).await { let json_user = a.into_json(&data).await?; Ok(( StatusCode::OK, FederationJson(WithContext::new_default(json_user)), ) .into_response()) } else { Ok((StatusCode::NOT_FOUND, "").into_response()) } } pub async fn read_user(name: &str, data: &Data) -> Option { let read = data.users.read().await; read.iter() .find(|value| value.username.eq(&name)) .map(ToOwned::to_owned) } #[cfg(test)] mod tests { use axum::{ body::Body, http::{Request, StatusCode}, }; use tower::ServiceExt; use crate::{server, state::AppState}; #[tokio::test] async fn get_user() { let state = AppState::new().await.unwrap(); let app = server::router(state); let response = app .oneshot( Request::builder() .uri("/users/sellershut") .body(Body::empty()) .unwrap(), ) .await .unwrap(); assert_eq!(response.status(), StatusCode::OK); } #[tokio::test] async fn get_user_not_found() { let state = AppState::new().await.unwrap(); let app = server::router(state); let response = app .oneshot( Request::builder() .uri("/users/selut") .body(Body::empty()) .unwrap(), ) .await .unwrap(); assert_eq!(response.status(), StatusCode::NOT_FOUND); } }