List Rooms in a Home (#18)

src/app/actions/room.rs

@@ -6,6 +6,14 @@ use crate::app::models::room;
 
 type DbError = Box<dyn std::error::Error + Send + Sync>;
 
+pub fn list_rooms(conn: &mut PgConnection, uid: Uuid) -> Result<Vec<room::Room>, DbError> {
+    use crate::schema::rooms::dsl::*;
+
+    let room_list = rooms.filter(home_id.eq(uid.to_string())).load(conn)?;
+
+    Ok(room_list)
+}
+
 pub fn insert_new_room(
     conn: &mut PgConnection,
     form: &Json<room::NewRoom>,

src/app/api/room.rs

@@ -1,4 +1,4 @@
-use actix_web::{error, post, web, HttpResponse, Responder, Result};
+use actix_web::{error, get, post, web, HttpResponse, Responder, Result};
 use diesel::{r2d2, PgConnection};
 
 use crate::app::actions;
@@ -20,3 +20,20 @@ async fn add_room(
 
     Ok(HttpResponse::Created().json(response))
 }
+
+#[get("/room")]
+async fn get_room(
+  pool: web::Data<DbPool>,
+  query: web::Query<models::room::RoomQuery>,
+) -> Result<impl Responder> {
+  let home_uid = query.home_id;
+
+  let response = web::block(move || {
+    let mut conn = pool.get()?;
+    actions::room::list_rooms(&mut conn, home_uid)
+  })
+  .await?
+  .map_err(error::ErrorBadRequest)?;
+
+  Ok(HttpResponse::Ok().json(response))
+}

src/app/models/room.rs

@@ -1,6 +1,7 @@
 use diesel::prelude::*;
 use diesel::{prelude::Insertable, Queryable};
 use serde::{Deserialize, Serialize};
+use uuid::Uuid;
 
 use crate::schema::rooms;
 use crate::app::models::home::Home;
@@ -15,6 +16,11 @@ pub struct Room {
     pub home_id: String,
 }
 
+#[derive(Deserialize)]
+pub struct RoomQuery {
+    pub home_id: Uuid,
+}
+
 /// New room details.
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct NewRoom {

src/main.rs

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