elo/src/global_state.rs

// Not a page, global state that is shared between all pages

use perseus::{prelude::*, state::GlobalStateCreator};
use serde::{Deserialize, Serialize};

use crate::{
    models::auth::{Claims, WebAuthInfo},
    state_enums::{LoginState, OpenState},
};

cfg_if::cfg_if! {
    if #[cfg(engine)] {

    }
}

#[derive(Serialize, Deserialize, ReactiveState, Clone)]
#[rx(alias = "AppStateRx")]
pub struct AppState {
    #[rx(nested)]
    pub auth: AuthData,
    #[rx(nested)]
    pub modals_open: ModalOpenData,
}

#[derive(Serialize, Deserialize, ReactiveState, Clone)]
#[rx(alias = "AuthDataRx")]
pub struct AuthData {
    pub state: LoginState,
    pub username: Option<String>,
    pub remember_me: Option<bool>,
    pub auth_info: Option<WebAuthInfo>,
}

impl AuthDataRx {
    pub fn handle_log_in(&self, auth_info: WebAuthInfo) {
        // Save new token to persistent storage
        if auth_info.remember_me {
            let storage: web_sys::Storage =
                web_sys::window().unwrap().local_storage().unwrap().unwrap();
            let value = serde_json::to_string(&auth_info).unwrap();
            storage.set_item("auth", &value).unwrap();
        }
        // Save into session storage always
        let storage: web_sys::Storage = web_sys::window()
            .unwrap()
            .session_storage()
            .unwrap()
            .unwrap();
        let value = serde_json::to_string(&auth_info).unwrap();
        storage.set_item("auth", &value).unwrap();

        // Save token to session storage
        self.username.set(Some(auth_info.username.clone()));
        self.remember_me.set(Some(auth_info.remember_me.clone()));
        self.auth_info.set(Some(auth_info));
        self.state.set(LoginState::Authenticated);
    }

    pub fn handle_log_out(&self) {
        // Delete persistent storage
        // TODO -> handle error if local storage is not readable in browser
        let storage: web_sys::Storage =
            web_sys::window().unwrap().local_storage().unwrap().unwrap();
        storage.remove_item("auth").unwrap();
        let storage: web_sys::Storage = web_sys::window()
            .unwrap()
            .session_storage()
            .unwrap()
            .unwrap();
        storage.remove_item("auth").unwrap();
        // Update state
        self.auth_info.set(None);
        self.username.set(None);
        self.remember_me.set(None);
        self.state.set(LoginState::NotAuthenticated);
    }
}

#[derive(Serialize, Deserialize, ReactiveState, Clone)]
#[rx(alias = "ModalOpenDataRx")]
pub struct ModalOpenData {
    pub login: OpenState,
    pub register: OpenState,
    pub forgot_password: OpenState,
}

pub fn get_global_state_creator() -> GlobalStateCreator {
    GlobalStateCreator::new().build_state_fn(get_build_state)
}

#[engine_only_fn]
pub async fn get_build_state() -> AppState {
    AppState {
        auth: AuthData {
            state: LoginState::Unknown,
            username: None,
            remember_me: None,
            auth_info: None,
        },
        modals_open: ModalOpenData {
            login: OpenState::Closed,
            register: OpenState::Closed,
            forgot_password: OpenState::Closed,
        },
    }
}

// Client only code to check if they're authenticated
#[cfg(client)]
impl AuthDataRx {
    pub fn detect_state(&self) {
        // If the user is in a known state, return
        if let LoginState::Authenticated | LoginState::NotAuthenticated = *self.state.get() {
            return;
        }
        // TODO handle error case better
        // Save new token to persistent storage
        let storage: web_sys::Storage =
            web_sys::window().unwrap().local_storage().unwrap().unwrap();
        let saved_auth = storage.get("auth").unwrap();
        match saved_auth {
            Some(auth_info) => {
                // TODO check if session is expiring
                let auth_info = serde_json::from_str(&auth_info).unwrap();
                self.handle_log_in(auth_info);
            }
            None => {
                // Try session storage
                let storage: web_sys::Storage = web_sys::window()
                    .unwrap()
                    .session_storage()
                    .unwrap()
                    .unwrap();
                let saved_auth = storage.get("auth").unwrap();
                match saved_auth {
                    Some(auth_info) => {
                        let auth_info = serde_json::from_str(&auth_info).unwrap();
                        self.handle_log_in(auth_info);
                    }
                    None => {
                        self.state.set(LoginState::NotAuthenticated);
                    }
                }
            }
        }
    }
}