Room API (#16)

migrations/2023-12-28-134303_create_rooms/down.sql

@@ -0,0 +1,2 @@
+-- This file should undo anything in `up.sql`
+DROP TABLE rooms

migrations/2023-12-28-134303_create_rooms/up.sql

@@ -0,0 +1,6 @@
+-- Your SQL goes here
+CREATE TABLE rooms (
+  id VARCHAR NOT NULL PRIMARY KEY,
+  name VARCHAR NOT NULL,
+  home_id VARCHAR NOT NULL REFERENCES homes(id) on DELETE CASCADE
+)

src/app/actions/mod.rs

@@ -1 +1,2 @@
 pub mod home;
+pub mod room;

src/app/actions/room.rs

@@ -0,0 +1,40 @@
+use actix_web::web::Json;
+use diesel::prelude::*;
+use uuid::Uuid;
+
+use crate::app::models::room;
+
+type DbError = Box<dyn std::error::Error + Send + Sync>;
+
+pub fn insert_new_room(
+    conn: &mut PgConnection,
+    form: &Json<room::NewRoom>,
+) -> Result<room::Room, DbError> {
+    use crate::schema::rooms::dsl::*;
+
+    match form.validate() {
+        Ok(_) => {
+            let new_room = room::Room {
+                id: Uuid::new_v4().to_string(),
+                name: form.name.to_owned(),
+                home_id: form.home_id.to_owned(),
+            };
+
+            diesel::insert_into(rooms).values(&new_room).execute(conn)?;
+
+            Ok(new_room)
+        }
+        Err(error) => Err(DbError::from(error)),
+    }
+}
+
+pub fn delete_room(conn: &mut PgConnection, uid: Uuid) -> Result<String, DbError> {
+    use crate::schema::rooms::dsl::*;
+
+    let result = diesel::delete(rooms.filter(id.eq(uid.to_string()))).execute(conn);
+
+    match result {
+        Ok(_) => Ok("Success".to_string()),
+        Err(e) => Err(DbError::from(e)),
+    }
+}

src/app/api/mod.rs

@@ -1 +1,2 @@
 pub mod home;
+pub mod room;

src/app/api/room.rs

@@ -0,0 +1,22 @@
+use actix_web::{error, post, web, HttpResponse, Responder, Result};
+use diesel::{r2d2, PgConnection};
+
+use crate::app::actions;
+use crate::app::models;
+
+type DbPool = r2d2::Pool<r2d2::ConnectionManager<PgConnection>>;
+
+#[post("/room")]
+async fn add_room(
+    pool: web::Data<DbPool>,
+    form: web::Json<models::room::NewRoom>,
+) -> Result<impl Responder> {
+    let response = web::block(move || {
+        let mut conn = pool.get()?;
+        actions::room::insert_new_room(&mut conn, &form)
+    })
+    .await?
+    .map_err(error::ErrorBadRequest)?;
+
+    Ok(HttpResponse::Created().json(response))
+}

src/app/mod.rs

@@ -4,4 +4,5 @@ pub mod db;
 
 pub mod models {
   pub mod home;
+  pub mod room;
 }

src/app/models/home.rs

@@ -1,10 +1,10 @@
-use diesel::{prelude::Insertable, Queryable};
+use diesel::{prelude::Insertable, Queryable, associations::Identifiable};
 use serde::{Deserialize, Serialize};
 
 use crate::schema::homes;
 
 /// User details.
-#[derive(Debug, Clone, Serialize, Deserialize, Queryable, Insertable)]
+#[derive(Debug, Clone, PartialEq, Identifiable, Serialize, Deserialize, Queryable, Insertable)]
 #[diesel(table_name = homes)]
 pub struct Home {
     pub id: String,

src/app/models/room.rs

@@ -0,0 +1,33 @@
+use diesel::prelude::*;
+use diesel::{prelude::Insertable, Queryable};
+use serde::{Deserialize, Serialize};
+
+use crate::schema::rooms;
+use crate::app::models::home::Home;
+
+/// Room details.
+#[derive(Queryable, Serialize, Selectable, Identifiable, Associations, Debug, PartialEq, Insertable)]
+#[diesel(belongs_to(Home))]
+#[diesel(table_name = rooms)]
+pub struct Room {
+    pub id: String,
+    pub name: String,
+    pub home_id: String,
+}
+
+/// New room details.
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct NewRoom {
+    pub name: String,
+    pub home_id: String,
+}
+
+// validations
+impl NewRoom {
+  pub fn validate(&self) -> Result<(), String> {
+      if self.name.trim().is_empty() {
+          return Err("Name is empty".to_string());
+      }
+      Ok(())
+  }
+}

src/main.rs

@@ -10,6 +10,8 @@ use app::api::home::{
   delete_home
 };
 
+use app::api::room::add_room;
+
 use app::db::{
   initialize_db_pool,
   initial_migration
@@ -37,6 +39,7 @@ async fn main() -> std::io::Result<()> {
         .service(add_home)
         .service(find_home)
         .service(delete_home)
+        .service(add_room)
     })
     .bind(("127.0.0.1", 8080))?
     .run()

src/schema.rs

@@ -2,8 +2,23 @@
 
 diesel::table! {
     homes (id) {
-        id -> Text,
-        title -> Text,
+        id -> Varchar,
+        title -> Varchar,
         body -> Text,
     }
 }
+
+diesel::table! {
+    rooms (id) {
+        id -> Varchar,
+        name -> Varchar,
+        home_id -> Varchar,
+    }
+}
+
+diesel::joinable!(rooms -> homes (home_id));
+
+diesel::allow_tables_to_appear_in_same_query!(
+    homes,
+    rooms,
+);