implemente custom error and endpoint to create a project

bruno/projects/Create Project.bru

@@ -6,6 +6,16 @@ meta {
 
 post {
   url: {{api_base}}/projects
-  body: none
+  body: json
   auth: inherit
 }
+
+body:json {
+  {
+    "name": "{{name}}"
+  }
+}
+
+vars:pre-request {
+  name: FillThisOutButDontCommitIt!
+}

crates/backend/Cargo.toml

@@ -14,11 +14,16 @@ actix-files = "0.6"
 tracing-actix-web = "0.7.16"
 
 argon2 = "0.5.3"
+thiserror = "2"
 
-env_logger  = "0.11"
+env_logger = "0.11"
 
-serde = {version = "1", features = ["derive"]}
-sea-orm ={ version = "1.1", features = ["sqlx-postgres", "runtime-tokio-rustls", "macros"]}
+serde = { version = "1", features = ["derive"] }
+sea-orm = { version = "1.1", features = [
+    "sqlx-postgres",
+    "runtime-tokio-rustls",
+    "macros",
+] }
 
 dotenvy = "0.15"
 

crates/backend/src/controller.rs

@@ -1,7 +1,7 @@
 use actix_web::web::{self, ServiceConfig};
 
-mod projects;
+mod project;
 
 pub fn register_controllers(cfg: &mut ServiceConfig) {
-    cfg.service(web::scope("/projects").configure(projects::setup));
+    cfg.service(web::scope("/projects").configure(project::setup));
 }

crates/backend/src/controller/project.rs

@@ -0,0 +1,24 @@
+use actix_web::{Result, web};
+use serde::Deserialize;
+
+use crate::db::Database;
+use crate::error::ApiError;
+
+#[derive(Deserialize)]
+struct CreateProject {
+    name: String,
+}
+
+pub fn setup(cfg: &mut actix_web::web::ServiceConfig) {
+    cfg.service(create_project);
+}
+
+#[actix_web::post("")]
+async fn create_project(
+    db: web::Data<Database>,
+    create_project_struct: web::Json<CreateProject>,
+) -> Result<web::Json<entity::project::Model>, ApiError> {
+    let result = db.create_project(&create_project_struct.name).await?;
+
+    Ok(web::Json(result))
+}

crates/backend/src/controller/projects.rs

@@ -1,10 +0,0 @@
-use actix_web::Result;
-
-pub fn setup(cfg: &mut actix_web::web::ServiceConfig) {
-    cfg.service(create_project);
-}
-
-#[actix_web::post("")]
-async fn create_project() -> Result<actix_web::HttpResponse> {
-    Ok(actix_web::HttpResponse::Ok().finish())
-}

crates/backend/src/db.rs

@@ -1,15 +1,16 @@
 use sea_orm::{ConnectOptions, DatabaseConnection};
 
+mod project;
 
 #[derive(Clone)]
 pub struct Database {
-    conn: DatabaseConnection
+    conn: DatabaseConnection,
 }
 
 impl Database {
     pub async fn new(options: ConnectOptions) -> Result<Self, sea_orm::DbErr> {
         Ok(Database {
-            conn: sea_orm::Database::connect(options).await?
+            conn: sea_orm::Database::connect(options).await?,
         })
     }
-}
+}

crates/backend/src/db/project.rs

@@ -0,0 +1,18 @@
+use super::Database;
+use crate::error::ApiError;
+
+use entity::project;
+use sea_orm::ActiveModelTrait;
+use sea_orm::ActiveValue::{NotSet, Set};
+
+impl Database {
+    pub async fn create_project(&self, name: &str) -> Result<project::Model, ApiError> {
+        let project = project::ActiveModel {
+            id: NotSet,
+            name: Set(name.to_owned()),
+        };
+
+        let project = project.insert(&self.conn).await?;
+        Ok(project)
+    }
+}

crates/backend/src/error.rs

@@ -0,0 +1,20 @@
+use actix_web::{HttpResponse, ResponseError, http::StatusCode};
+use thiserror::Error;
+
+#[derive(Error, Debug)]
+pub enum ApiError {
+    #[error("Database Error: {0}")]
+    Database(#[from] sea_orm::DbErr),
+}
+
+impl ResponseError for ApiError {
+    fn status_code(&self) -> StatusCode {
+        match self {
+            ApiError::Database(..) => StatusCode::INTERNAL_SERVER_ERROR,
+        }
+    }
+
+    fn error_response(&self) -> HttpResponse {
+        HttpResponse::build(self.status_code()).body(self.to_string())
+    }
+}

crates/backend/src/main.rs

@@ -7,6 +7,7 @@ use std::env;
 
 mod controller;
 mod db;
+mod error;
 
 #[actix_web::main]
 async fn main() -> std::io::Result<()> {