特定ユーザ取得APIの実装

backend/Cargo.toml

@@ -15,4 +15,5 @@ sea-orm = { version = "0.12", features = [
   "sqlx-postgres",
   "runtime-tokio-native-tls",
   "macros",
+  "mock",
 ] }

backend/db-schema/migrations/20240908082102_/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "User" ALTER COLUMN "updated_at" DROP NOT NULL;

backend/db-schema/schema.prisma

@@ -23,7 +23,7 @@ model User {
   user_name    String        @unique
   display_name String        @db.VarChar(255)
   created_at   DateTime      @default(now())
-  updated_at   DateTime      @updatedAt
+  updated_at   DateTime?     @updatedAt
   channel      Channel[]
   message      Message[]
   channel_user ChannelUser[]

backend/src/generate/entities/user.rs

@@ -11,7 +11,7 @@ pub struct Model {
     pub user_name: String,
     pub display_name: String,
     pub created_at: DateTime,
-    pub updated_at: DateTime,
+    pub updated_at: Option<DateTime>,
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]

backend/src/handler.rs

@@ -1,3 +1,4 @@
 pub mod mutation;
 pub mod query;
 mod test_handler;
+mod user;

backend/src/handler/query.rs

@@ -1,5 +1,7 @@
 use crate::handler::test_handler::TestQuery;
 use async_graphql::MergedObject;
 
+use crate::handler::user::UserQuery;
+
 #[derive(MergedObject, Default)]
-pub struct Query(TestQuery);
+pub struct Query(TestQuery, UserQuery);

backend/src/handler/user.rs

@@ -0,0 +1,27 @@
+use async_graphql::Error;
+use async_graphql::Object;
+use async_graphql::Result;
+
+use crate::context::Context;
+use crate::models;
+use crate::usecase;
+
+#[derive(Default)]
+pub struct UserQuery;
+
+#[Object]
+impl UserQuery {
+    async fn user<'ctx>(
+        &self,
+        ctx: &async_graphql::Context<'ctx>,
+        id: String,
+    ) -> Result<models::user::User> {
+        let ctx = ctx.data_unchecked::<Context>();
+
+        match usecase::user::get_user_by_id(ctx, id.as_str()).await {
+            Ok(Some(user)) => Ok(user),
+            Ok(None) => Err(Error::new("Not found")),
+            Err(_) => Err(Error::new("Internal server error")),
+        }
+    }
+}

backend/src/models.rs

@@ -1 +1,2 @@
 pub mod test;
+pub mod user;

backend/src/models/user.rs

@@ -0,0 +1,8 @@
+use async_graphql::SimpleObject;
+
+#[derive(SimpleObject, Debug, Eq, PartialEq)]
+pub struct User {
+    pub id: String,
+    pub name: String,
+    pub display_name: String,
+}

backend/src/usecase.rs

@@ -1 +1,2 @@
 pub mod test;
+pub mod user;

backend/src/usecase/user.rs

@@ -0,0 +1,86 @@
+use sea_orm::EntityTrait;
+
+use crate::generate::entities::user;
+use crate::{context::Context, models::user::User};
+
+pub async fn get_user_by_id(ctx: &Context, id: &str) -> Result<Option<User>, ()> {
+    let db = &ctx.db;
+
+    let Ok(user) = user::Entity::find_by_id(id).one(db).await else {
+        return Err(());
+    };
+
+    Ok(user.map(|user| User {
+        id: user.id,
+        name: user.user_name,
+        display_name: user.display_name,
+    }))
+}
+
+#[cfg(test)]
+pub mod test {
+    use sea_orm::prelude::*;
+    use sea_orm::DatabaseConnection;
+    use sea_orm::MockDatabase;
+
+    use crate::context::Context;
+    use crate::generate::entities::user;
+    use crate::models::user::User;
+    use crate::usecase::user::get_user_by_id;
+
+    #[tokio::test]
+    async fn 指定IDのユーザが取得される() {
+        // Arrange
+        let id = "4e36eb58-49a5-43aa-935f-5a5cccb77a90";
+
+        let db: DatabaseConnection = MockDatabase::new(sea_orm::DatabaseBackend::Postgres)
+            .append_query_results([vec![user::Model {
+                id: id.to_string(),
+                user_name: "aiueo".to_string(),
+                display_name: "あいうえお".to_string(),
+                created_at: DateTime::parse_from_str("2024-08-08 00:00:00", "%Y-%m-%d %H:%M:%S")
+                    .unwrap(),
+                updated_at: None,
+            }]])
+            .into_connection();
+
+        let ctx = Context {
+            env: "".to_string(),
+            db,
+        };
+
+        // Action
+        let result = get_user_by_id(&ctx, id).await;
+
+        // Assert
+        assert_eq!(
+            result,
+            Ok(Some(User {
+                id: id.to_string(),
+                name: "aiueo".to_string(),
+                display_name: "あいうえお".to_string(),
+            }))
+        );
+    }
+
+    #[tokio::test]
+    async fn 指定IDのユーザが存在しない場合None() {
+        // Arrange
+        let id = "4e36eb58-49a5-43aa-935f-5a5cccb77a90";
+
+        let db: DatabaseConnection = MockDatabase::new(sea_orm::DatabaseBackend::Postgres)
+            .append_query_results(vec![Vec::<user::Model>::new()])
+            .into_connection();
+
+        let ctx = Context {
+            env: "".to_string(),
+            db,
+        };
+
+        // Action
+        let result = get_user_by_id(&ctx, "存在しないID").await;
+
+        // Assert
+        assert_eq!(result, Ok(None));
+    }
+}