feat: persist with sqlx

1 files changed, 15 insertions, 8 deletions

diff --git a/src/server/routes/users/webfinger.rs b/src/server/routes/users/webfinger.rs
index 22975c2..8efeda6 100644
--- a/src/server/routes/users/webfinger.rs
+++ b/src/server/routes/users/webfinger.rs
@@ -17,7 +17,7 @@ pub async fn webfinger(
     data: Data<AppHandle>,
 ) -> Result<impl IntoResponse, AppError> {
     let name = extract_webfinger_name(&query.resource, &data)?;
-    if let Some(db_user) = read_user(name, &data).await {
+    if let Some(db_user) = read_user(name, &data).await? {
         Ok((
             StatusCode::OK,
             Json(build_webfinger_response(
@@ -37,13 +37,19 @@ mod tests {
         body::Body,
         http::{Request, StatusCode},
     };
+    use sqlx::PgPool;
+    use stack_up::Services;
     use tower::ServiceExt;
 
-    use crate::{server, state::AppState};
+    use crate::{
+        server::{self, test_config},
+        state::AppState,
+    };
 
-    #[tokio::test]
-    async fn webfinger_ok() {
-        let state = AppState::new().await.unwrap();
+    #[sqlx::test]
+    async fn webfinger_ok(pool: PgPool) {
+        let services = Services { postgres: pool };
+        let state = AppState::new(services, &test_config()).await.unwrap();
         let app = server::router(state);
 
         let response = app
@@ -59,9 +65,10 @@ mod tests {
         assert_eq!(response.status(), StatusCode::OK);
     }
 
-    #[tokio::test]
-    async fn webfinger_err() {
-        let state = AppState::new().await.unwrap();
+    #[sqlx::test]
+    async fn webfinger_err(pool: PgPool) {
+        let services = Services { postgres: pool };
+        let state = AppState::new(services, &test_config()).await.unwrap();
         let app = server::router(state);
 
         let response = app