armatak/src/ots_api.rs

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";
    }
}