more api handling stuff

this should also trigger the checking workflow

api/src/event_handler.rs

@@ -7,10 +7,16 @@ use rocket::serde::json::Json;
 
 #[get("/")]
 pub fn list_events_handler() -> String {
-    todo!()
+    let posts: Vec<Event> = read::list_events();
+    let response = Response { body: ResponseBody::Events(events) };
+
+    serde_json::to_string(&response).unwrap()
 }
 
 #[get("/event/<event_id>")]
 pub fn list_event_handler(event_id: i32) -> Result<String, NotFound<String>> {
-    todo!()
+    let event = read::list_post(event_id)?;
+    let response = Response { body: ResponseBody::Event(event) };
+
+    Ok(serde_json::to_string(&response).unwrap())
 }

application/Cargo.toml

@@ -4,3 +4,10 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
+domain = { path = "../domain" }
+infrastructure = { path = "../infrastructure" }
+shared = { path = "../shared" }
+
+diesel = { version = "2.0", features = ["sqlite, "returning_clauses_for_sqlite_3_35"] }
+serde_json = "1.0"
+rocket = { version = "0.5.0", features = ["json"] }

application/src/event/mod.rs

@@ -0,0 +1 @@
+pub mod read;

application/src/event/read.rs

@@ -0,0 +1,38 @@
+use domain::models::Event;
+use shared::response_models::{Response, ResponseBody};
+use infrastructure::establish_connection;
+use diesel::prelude::*;
+use rocket::response::status::NotFound;
+
+pub fn list_event(event_id: i32) -> Result<Event, NotFound<String>> {
+    use domain::schema::events;
+
+    match events::table.find(event_id).first::<Event>(&mut establish_connection()) {
+        Ok(event) => Ok(event),
+        Err(err) => match err {
+            diesel::result::Error::NotFound => {
+                let response = Response { body: ResponseBody::Message(format!("Error selecting event with id {} - {}", event_id, err))};
+                return Err(NotFound(serde_json::to_string(&response).unwrap()));
+            },
+            _ => {
+                panic!("Database error - {}", err);
+            }        
+        }
+    }
+}
+
+pub fn list_events() -> Vec<Event> {
+    use domain::schema::events;
+
+    match events::table.select(events::all_columns).load::<Event>(&mut establish_connection()) {
+        Ok(mut events) => {
+            events.sort();
+            events
+        },
+        Err(err) => match err {
+            _ => {
+                panic!("Database error - {}", err);
+            }
+        }
+    }
+}

application/src/lib.rs

@@ -1,14 +1 @@
-pub fn add(left: u64, right: u64) -> u64 {
-    left + right
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-
-    #[test]
-    fn it_works() {
-        let result = add(2, 2);
-        assert_eq!(result, 4);
-    }
-}
+pub mod event;