pub mod api; mod i18n; mod model; mod pages; pub mod shared; use seed::empty; use seed::prelude::*; use crate::model::Model; use crate::pages::{Msg, Page, PublicPage}; macro_rules! fetch_page { (public $model: expr, $page: ident, $ret: expr) => {{ let p = match &mut $model.page { crate::pages::Page::Public(p) => p, _ => return $ret, }; match p { crate::pages::PublicPage::$page(p) => p, _ => return $ret, } }}; } fn init(url: Url, orders: &mut impl Orders) -> Model { orders.stream(streams::interval(500, || Msg::CheckAccessToken)); Model { token: LocalStorage::get("auth-token").ok(), page: Page::Public(PublicPage::Listing(pages::public::listing::init( url, &mut orders.proxy(proxy_public_listing), ))), logo: seed::document() .query_selector("link[rel=icon]") .ok() .flatten() .and_then(|el: web_sys::Element| el.get_attribute("href")), shared: shared::Model::default(), } } fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders) { match msg { Msg::Shared(msg) => { shared::update(msg, &mut model.shared, orders); } Msg::CheckAccessToken => { orders.skip(); if model.shared.refresh_token.is_none() { return; } if let Some(exp) = model.shared.exp { if exp > chrono::Utc::now().naive_utc() - chrono::Duration::seconds(1) { return; } if let Some(token) = model.shared.refresh_token.take() { orders.send_msg(Msg::Shared(shared::Msg::RefreshToken(token))); } } } Msg::UrlChanged(subs::UrlChanged(url)) => model.page = Page::init(url, orders), Msg::Public(pages::public::Msg::Listing(pages::public::listing::Msg::Shared(msg))) => { shared::update(msg, &mut model.shared, orders); } Msg::Public(pages::public::Msg::Listing(msg)) => { let page = fetch_page!(public model, Listing, ()); pages::public::listing::update(msg, page, &mut orders.proxy(proxy_public_listing)); } } } fn view(model: &Model) -> Node { match &model.page { Page::Public(PublicPage::Listing(page)) => pages::public::listing::view(model, page) .map_msg(|msg| Msg::Public(pages::public::Msg::Listing(msg))), _ => empty![], } } #[wasm_bindgen(start)] pub fn start() { App::start("main", init, update, view); } fn proxy_public_listing(msg: pages::public::listing::Msg) -> Msg { Msg::Public(pages::public::Msg::Listing(msg)) }