From 004725b3f6b423704ed512bd212ef0959a6bbc5e Mon Sep 17 00:00:00 2001
From: thybux <faivre.thomas88@free.fr>
Date: Fri, 26 Apr 2024 14:49:07 +0200
Subject: [PATCH] ajout des route login et create_user

---
 services/eat/src/main.rs | 79 +++++++++++++++++++++++++++++++++++-----
 1 file changed, 70 insertions(+), 9 deletions(-)

diff --git a/services/eat/src/main.rs b/services/eat/src/main.rs
index fd44387..c3f2b64 100644
--- a/services/eat/src/main.rs
+++ b/services/eat/src/main.rs
@@ -1,6 +1,8 @@
+use common::db::Db;
+use rocket::http::Status;
+use rocket::serde::json::Json;
 use rocket::serde::Deserialize;
 use serde_json::Value;
-use rocket::serde::json::Json;
 
 #[macro_use]
 extern crate rocket;
@@ -15,12 +17,25 @@ struct CityCoord {
     long: f64,
 }
 
+#[derive(Deserialize)]
+#[serde(crate = "rocket::serde")]
+struct AccountCreationData {
+    email: String,
+    password: String,
+    first_name: String,
+    last_name: String,
+}
+
+#[derive(Deserialize)]
+#[serde(crate = "rocket::serde")]
+struct AuthCredentials {
+    email: String,
+    password: String,
+}
+
 impl CityCoord {
     fn new(lat: f64, long: f64) -> Self {
-        Self {
-            lat,
-            long
-        }
+        Self { lat, long }
     }
 }
 
@@ -35,6 +50,43 @@ async fn coord(localisation: String) -> Json<CityCoord> {
     Json(result)
 }
 
+#[post("/login/auth", format = "application/json", data = "<credentials>")]
+async fn auth(
+    credentials: Json<AuthCredentials>,
+    db: &rocket::State<Db>,
+) -> Result<Status, Status> {
+    match db.login(&credentials.email, &credentials.password).await {
+        Ok(true) => Ok(Status::Ok),
+        Ok(false) => Err(Status::Forbidden),
+        Err(_) => Err(Status::InternalServerError),
+    }
+}
+
+#[post(
+    "/create_account",
+    format = "application/json",
+    data = "<account_data>"
+)]
+async fn create_account_route(
+    account_data: Json<AccountCreationData>,
+    db: &rocket::State<Db>,
+) -> Result<Status, Status> {
+    let result = db
+        .create_account(
+            &account_data.email,
+            &account_data.password,
+            &account_data.first_name,
+            &account_data.last_name,
+        )
+        .await;
+
+    match result {
+        Ok(true) => Ok(Status::Created),
+        Ok(false) => Err(Status::Conflict),
+        Err(_) => Err(Status::InternalServerError),
+    }
+}
+
 // URL pour récupérer les restaurant dans un périmétre donné et pour une localisation donnée
 #[get("/service/eat/<localisation>/<radius>")]
 async fn index(localisation: String, radius: i32) -> Json<Vec<Emplacement>> {
@@ -43,9 +95,17 @@ async fn index(localisation: String, radius: i32) -> Json<Vec<Emplacement>> {
     Json(result)
 }
 
-#[launch]
-fn rocket() -> _ {
-    rocket::build().mount("/", routes![index, coord])
+#[rocket::main]
+async fn main() {
+    let db = Db::new().await.expect("Failed to create database pool");
+    let rocket_instance = rocket::build()
+        .manage(db)
+        .mount("/", routes![index, coord, auth, create_account_route]);
+
+    match rocket_instance.launch().await {
+        Ok(_) => println!("Server launched successfully."),
+        Err(e) => println!("Server failed to launch: {:?}", e),
+    }
 }
 
 pub(crate) async fn get_google(localisation: String, radius: i32) -> Value {
@@ -85,7 +145,8 @@ mod tests {
         let expected = exploit_json(get_google(String::from("Le Bardon"), 1000).await).unwrap();
 
         // Convertir `result` et `expected` en JSON String pour la comparaison
-        let result_str = serde_json::to_string(&result.into_inner()).expect("Failed to serialize result");
+        let result_str =
+            serde_json::to_string(&result.into_inner()).expect("Failed to serialize result");
         let expected_str = serde_json::to_string(&expected).expect("Failed to serialize expected");
 
         // Comparer les chaînes JSON