From fe3c582d09d16d6e4288d285d5d90542d576126c Mon Sep 17 00:00:00 2001
From: bitfl0wer <florian@pro-weber.com>
Date: Sun, 23 Apr 2023 20:11:14 +0200
Subject: [PATCH] Implement Login

---
 src/api/auth/login.rs | 92 +++++++++++++++++++++++++++++++++++++++++--
 src/api/schemas.rs    |  2 +-
 2 files changed, 90 insertions(+), 4 deletions(-)

diff --git a/src/api/auth/login.rs b/src/api/auth/login.rs
index 8813b14..e8254f0 100644
--- a/src/api/auth/login.rs
+++ b/src/api/auth/login.rs
@@ -1,13 +1,99 @@
 pub mod login {
-    use crate::api::schemas::schemas::{LoginResult, LoginSchema};
+    use reqwest::Client;
+    use serde_json::{from_str, json};
+
+    use crate::api::limits::LimitType;
+    use crate::api::schemas::schemas::{ErrorResponse, LoginResult, LoginSchema};
     use crate::errors::InstanceServerError;
     use crate::instance::Instance;
 
-    /* impl Instance {
+    impl Instance {
         pub async fn login_account(
             &mut self,
             login_schema: &LoginSchema,
         ) -> Result<LoginResult, InstanceServerError> {
+            let requester = &mut self.requester;
+            let json_schema = json!(login_schema);
+            let client = Client::new();
+            let endpoint_url = self.urls.get_api().to_string() + "/auth/login";
+            let request_builder = client.post(endpoint_url).body(json_schema.to_string());
+            let response = requester
+                .send_request(request_builder, LimitType::AuthRegister)
+                .await;
+            if !response.is_ok() {
+                return Err(InstanceServerError::NoResponse);
+            }
+
+            let response_unwrap = response.unwrap();
+            let status = response_unwrap.status();
+            let response_text_string = response_unwrap.text().await.unwrap();
+            if status.is_client_error() {
+                let json: ErrorResponse = serde_json::from_str(&response_text_string).unwrap();
+                let error_type = json.errors.errors.iter().next().unwrap().0.to_owned();
+                let mut error = "".to_string();
+                for (_, value) in json.errors.errors.iter() {
+                    for error_item in value._errors.iter() {
+                        error += &(error_item.message.to_string() + " (" + &error_item.code + ")");
+                    }
+                }
+                return Err(InstanceServerError::InvalidFormBodyError { error_type, error });
+            }
+
+            let login_result: LoginResult = from_str(&response_text_string).unwrap();
+
+            return Ok(login_result);
         }
-    } */
+    }
+}
+
+#[cfg(test)]
+mod test {
+    use crate::api::schemas::schemas::{
+        AuthEmail, AuthPassword, AuthUsername, LoginSchema, RegisterSchema,
+    };
+    use crate::instance::Instance;
+    use crate::limit::LimitedRequester;
+    use crate::URLBundle;
+
+    #[tokio::test]
+    async fn test_login() {
+        let urls = URLBundle::new(
+            "http://localhost:3001/api".to_string(),
+            "http://localhost:3001".to_string(),
+            "http://localhost:3001".to_string(),
+        );
+        let limited_requester = LimitedRequester::new(urls.get_api().to_string()).await;
+        let mut test_instance = Instance::new(urls.clone(), limited_requester)
+            .await
+            .unwrap();
+        let reg = RegisterSchema::new(
+            AuthUsername::new("TestAccount".to_string()).unwrap(),
+            Some(AuthPassword::new("transrights".to_string()).unwrap()),
+            true,
+            Some(AuthEmail::new("apiauthlogin1@testlogin.xyz".to_string()).unwrap()),
+            None,
+            None,
+            Some("2000-01-01".to_string()),
+            None,
+            None,
+            None,
+        )
+        .unwrap();
+        test_instance.register_account(&reg).await.unwrap().token;
+
+        let login_schema = LoginSchema::new(
+            AuthUsername::new("apiauthlogin1@testlogin.xyz".to_string()).unwrap(),
+            "transrights".to_string(),
+            Some(false),
+            None,
+            None,
+            None,
+        );
+
+        let login_result = test_instance
+            .login_account(&login_schema.unwrap())
+            .await
+            .unwrap();
+        println!("{:?}", login_result);
+    }
 }
diff --git a/src/api/schemas.rs b/src/api/schemas.rs
index 4a68488..ad7d297 100644
--- a/src/api/schemas.rs
+++ b/src/api/schemas.rs
@@ -273,7 +273,7 @@ pub mod schemas {
         stream_notifications_enabled: bool,
         theme: String,
         timezone_offset: i32,
-        view_nsfw_guilds: Option<bool>,
+        view_nsfw_guilds: bool,
     }
 
     #[derive(Debug, Serialize, Deserialize)]