Got log in and out working, moved global state
All checks were successful
Build Crate / build (push) Successful in 1m45s

close to done!
This commit is contained in:
2024-08-26 17:43:08 -04:00
parent 0f20ba3b86
commit 65d47615da
11 changed files with 172 additions and 95 deletions

View File

@@ -16,12 +16,12 @@ serde_json = "1"
env_logger = "0.10.0" env_logger = "0.10.0"
log = "0.4.20" log = "0.4.20"
once_cell = "1.18.0" once_cell = "1.18.0"
web-sys = "0.3.64" web-sys = { version = "0.3.64", features = ["Window", "Storage"] }
cfg-if = "1.0.0" cfg-if = "1.0.0"
chrono = { version = "0.4.38", features = ["serde", "wasm-bindgen"] } chrono = { version = "0.4.38", features = ["serde", "wasm-bindgen"] }
password-auth = "1.0.0" password-auth = "1.0.0"
lazy_static = "1.5" lazy_static = "1.5"
jsonwebtoken = "9"
[target.'cfg(engine)'.dev-dependencies] [target.'cfg(engine)'.dev-dependencies]
fantoccini = "0.19" fantoccini = "0.19"
@@ -37,6 +37,7 @@ sea-orm = { version = "1.0", features = [
"macros", "macros",
"with-chrono", "with-chrono",
] } ] }
jsonwebtoken = "9.3.0"
[target.'cfg(client)'.dependencies] [target.'cfg(client)'.dependencies]
wasm-bindgen = "0.2.93" wasm-bindgen = "0.2.93"

View File

@@ -1,4 +1,4 @@
use std::num::NonZeroU16; use std::arch::global_asm;
use lazy_static::lazy_static; use lazy_static::lazy_static;
use perseus::prelude::*; use perseus::prelude::*;
@@ -6,16 +6,15 @@ use serde::{Deserialize, Serialize};
use sycamore::prelude::*; use sycamore::prelude::*;
use web_sys::Event; use web_sys::Event;
use crate::{
endpoints::LOGIN,
state_enums::OpenState,
templates::{get_api_path, global_state::AppStateRx},
};
cfg_if::cfg_if! { cfg_if::cfg_if! {
if #[cfg(client)] { if #[cfg(client)] {
use crate::{ use crate::{
models::auth::{LoginInfo, LoginResponse}, models::auth::{LoginInfo, LoginResponse},
endpoints::LOGIN,
state_enums::{LoginState, OpenState},
templates::{get_api_path},
global_state::{self, AppStateRx},
models::auth::WebAuthInfo,
}; };
use reqwest::StatusCode; use reqwest::StatusCode;
} }
@@ -61,10 +60,12 @@ fn login_form_capsule<G: Html>(
#[cfg(client)] #[cfg(client)]
{ {
spawn_local_scoped(cx, async move { spawn_local_scoped(cx, async move {
let remember_me = state.remember_me.get().as_ref().clone();
let username = state.username.get().as_ref().clone();
let login_info = LoginInfo { let login_info = LoginInfo {
username: state.username.get().as_ref().clone(), username: username.clone(),
password: state.password.get().as_ref().clone(), password: state.password.get().as_ref().clone(),
remember_me: state.remember_me.get().as_ref().clone(), remember_me,
}; };
// // @todo clean up error handling // // @todo clean up error handling
@@ -79,12 +80,23 @@ fn login_form_capsule<G: Html>(
let global_state = Reactor::<G>::from_cx(cx).get_global_state::<AppStateRx>(cx); let global_state = Reactor::<G>::from_cx(cx).get_global_state::<AppStateRx>(cx);
if response.status() != StatusCode::OK { if response.status() != StatusCode::OK {
// todo update to some type of alert
state.username.set(response.status().to_string()); state.username.set(response.status().to_string());
return; return;
} }
let response = response.json::<LoginResponse>().await.unwrap(); let response = response.json::<LoginResponse>().await.unwrap();
state.username.set(response.token.clone());
// Save token to session/local storage and update state
global_state.auth.handle_log_in(WebAuthInfo {
token: response.token,
expires: response.expires,
username,
remember_me,
});
// Close modal
global_state.modals_open.login.set(OpenState::Closed);
}); });
} }
}; };

View File

@@ -7,9 +7,9 @@ use web_sys::Event;
use crate::{ use crate::{
capsules::login_form::{LoginFormProps, LOGIN_FORM}, capsules::login_form::{LoginFormProps, LOGIN_FORM},
endpoints::LOGIN, endpoints::LOGIN,
global_state::AppStateRx,
models::auth::LoginInfo, models::auth::LoginInfo,
state_enums::{GameState, LoginState, OpenState}, state_enums::{GameState, LoginState, OpenState},
templates::global_state::AppStateRx,
}; };
#[derive(Prop)] #[derive(Prop)]
@@ -33,6 +33,16 @@ pub fn Header<'a, G: Html>(cx: Scope<'a>, HeaderProps { game, title }: HeaderPro
} }
}; };
let handle_log_out = move |_event: Event| {
#[cfg(client)]
{
spawn_local_scoped(cx, async move {
let global_state = Reactor::<G>::from_cx(cx).get_global_state::<AppStateRx>(cx);
global_state.auth.handle_log_out();
});
}
};
view! { cx, view! { cx,
header { header {
div (class = "flex items-center justify-between w-full md:text-center h-20") { div (class = "flex items-center justify-between w-full md:text-center h-20") {
@@ -52,14 +62,18 @@ pub fn Header<'a, G: Html>(cx: Scope<'a>, HeaderProps { game, title }: HeaderPro
"Register" "Register"
} }
button(on:click = handle_log_in,class = "text-white bg-blue-700 hover:bg-blue-800 focus:ring-4 focus:ring-blue-300 font-medium rounded-lg text-sm px-5 py-2.5 me-2 mb-2 dark:bg-blue-600 dark:hover:bg-blue-700 focus:outline-none dark:focus:ring-blue-800") { button(on:click = handle_log_in,class = "text-white bg-blue-700 hover:bg-blue-800 focus:ring-4 focus:ring-blue-300 font-medium rounded-lg text-sm px-5 py-2.5 me-2 mb-2 dark:bg-blue-600 dark:hover:bg-blue-700 focus:outline-none dark:focus:ring-blue-800") {
"Login" "Log in"
} }
} }
} }
LoginState::Authenticated => { LoginState::Authenticated => {
view! { cx, view! { cx,
div { div {
"Hello {username}!" "Hello "
(global_state.auth.username.get().as_ref().clone().unwrap_or("".to_owned()))
}
button(on:click = handle_log_out, class = "text-white bg-blue-700 hover:bg-blue-800 focus:ring-4 focus:ring-blue-300 font-medium rounded-lg text-sm px-5 py-2.5 me-2 mb-2 dark:bg-blue-600 dark:hover:bg-blue-700 focus:outline-none dark:focus:ring-blue-800") {
"Log out"
} }
} }
} }

View File

@@ -1,8 +1,8 @@
use crate::{ use crate::{
capsules::login_form::{LoginFormProps, LOGIN_FORM}, capsules::login_form::{LoginFormProps, LOGIN_FORM},
components::header::{Header, HeaderProps}, components::header::{Header, HeaderProps},
global_state::AppStateRx,
state_enums::{GameState, LoginState}, state_enums::{GameState, LoginState},
templates::global_state::AppStateRx,
}; };
use perseus::prelude::*; use perseus::prelude::*;
use sycamore::prelude::*; use sycamore::prelude::*;

115
src/global_state.rs Normal file
View File

@@ -0,0 +1,115 @@
// 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 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();
// 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 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,
},
}
}
// 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 => {
self.state.set(LoginState::NotAuthenticated);
}
}
}
}

View File

@@ -4,6 +4,7 @@ mod endpoints;
#[allow(unused_imports)] #[allow(unused_imports)]
mod entity; mod entity;
mod error_views; mod error_views;
mod global_state;
mod models; mod models;
#[cfg(engine)] #[cfg(engine)]
mod server; mod server;
@@ -59,7 +60,7 @@ pub fn main<G: Html>() -> PerseusApp<G> {
env_logger::init(); env_logger::init();
PerseusApp::new() PerseusApp::new()
.global_state_creator(crate::templates::global_state::get_global_state_creator()) .global_state_creator(crate::global_state::get_global_state_creator())
.template(crate::templates::index::get_template()) .template(crate::templates::index::get_template())
.template(crate::templates::add_game_form::get_template()) .template(crate::templates::add_game_form::get_template())
.template(crate::templates::one_v_one_board::get_template()) .template(crate::templates::one_v_one_board::get_template())

View File

@@ -21,3 +21,13 @@ pub struct Claims {
pub sub: String, pub sub: String,
pub exp: usize, pub exp: usize,
} }
// For client local storage and session storage
#[derive(Serialize, Deserialize, Clone)]
pub struct WebAuthInfo {
pub token: String,
#[serde(with = "ts_seconds")]
pub expires: DateTime<Utc>,
pub username: String,
pub remember_me: bool,
}

View File

@@ -6,7 +6,7 @@ use web_sys::Event;
cfg_if::cfg_if! { cfg_if::cfg_if! {
if #[cfg(client)] { if #[cfg(client)] {
use crate::templates::global_state::AppStateRx; use crate::global_state::AppStateRx;
use crate::templates::get_api_path; use crate::templates::get_api_path;
use chrono::Utc; use chrono::Utc;
} }

View File

@@ -1,72 +0,0 @@
// 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,
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 claims: Claims,
}
#[derive(Serialize, Deserialize, ReactiveState, Clone)]
#[rx(alias = "ModalOpenDataRx")]
pub struct ModalOpenData {
pub login: 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,
claims: Claims {
sub: "".to_owned(),
exp: 0,
},
},
modals_open: ModalOpenData {
login: 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 -> Get state from storage
self.state.set(LoginState::NotAuthenticated);
}
}

View File

@@ -1,5 +1,4 @@
pub mod add_game_form; pub mod add_game_form;
pub mod global_state;
pub mod index; pub mod index;
pub mod one_v_one_board; pub mod one_v_one_board;
pub mod overall_board; pub mod overall_board;
@@ -7,7 +6,6 @@ pub mod overall_board;
#[cfg(client)] #[cfg(client)]
use perseus::utils::get_path_prefix_client; use perseus::utils::get_path_prefix_client;
#[allow(dead_code)]
pub fn get_api_path(path: &str) -> String { pub fn get_api_path(path: &str) -> String {
#[cfg(engine)] #[cfg(engine)]
{ {

View File

@@ -1,6 +1,4 @@
use crate::{ use crate::{components::layout::Layout, global_state::AppStateRx, state_enums::GameState};
components::layout::Layout, state_enums::GameState, templates::global_state::AppStateRx,
};
use perseus::prelude::*; use perseus::prelude::*;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};