added fts and ots handling on extension

src/ots_api.rs

@@ -0,0 +1,84 @@
+use once_cell::sync::Lazy;
+use tokio::runtime::Runtime;
+
+use crate::{
+    structs::LoginPayload,
+    util::{blocking_fetch_auth_token, parse_login_to_payload},
+};
+
+pub static RUNTIME: Lazy<Runtime> = Lazy::new(|| {
+    Runtime::new().expect("Failed to build the Tokio Runtime")
+});
+
+pub fn get_auth_token(login_payload: LoginPayload) -> String {
+    let api_address = login_payload.address.clone();
+    let login_info = parse_login_to_payload(login_payload);
+
+    return blocking_fetch_auth_token(login_info, api_address);
+}
+
+pub mod markers {
+    use crate::{structs::Marker, util::{async_post_markers, parse_marker_to_payload}};
+    use log::{error, info};
+    use std::thread;
+
+    use super::RUNTIME;
+
+    pub fn get(placeholder: String) -> &'static str {
+        info!("{}", placeholder);
+
+        return "not implemented yet";
+    }
+
+    pub fn post(data: Vec<Marker>) -> &'static str {
+        thread::spawn(move || {
+            RUNTIME.block_on(async_post_markers(data));
+        });
+
+        "loading"
+    }
+
+    pub fn post_debug(data: Vec<Marker>) -> String {
+        let client = reqwest::blocking::Client::new();
+
+        let authentication_token = data[0].api_auth_token.clone();
+        let parsed_address: String =
+            data[0].api_address.clone() + "/api/markers?auth_token=" + &authentication_token;
+
+        let mut status: String = "fetching".to_string();
+
+        for marker in data {
+            let payload = parse_marker_to_payload(marker);
+            let request_body = serde_json::to_string(&payload).unwrap();
+
+            info!(
+                "Parsing: {} with {}",
+                request_body, authentication_token
+            );
+
+            let response = client
+                .post(parsed_address.clone())
+                .body(request_body)
+                .header("Content-Type", "application/json")
+                .send();
+
+            match response {
+                Ok(result) => {
+                    info!("Received: {}", result.text().unwrap());
+                }
+                Err(error) => {
+                    status = "fetch failed".to_string();
+                    error!("Error: {}", error)
+                }
+            }
+        };
+
+        return status.to_string();
+    }
+
+    pub fn delete(placeholder: String) -> &'static str {
+        info!("{}", placeholder);
+
+        return "not implemented yet";
+    }
+}