/* This file is part of jellything (https://codeberg.org/metamuffin/jellything) which is licensed under the GNU Affero General Public License (version 3); see /COPYING. Copyright (C) 2025 metamuffin */ use super::{account::session::Session, layout::LayoutPage, node::NodeCard}; use crate::{ database::Database, routes::ui::{error::MyResult, layout::DynLayoutPage}, }; use chrono::{Datelike, Utc}; use jellybase::CONF; use jellycommon::{user::WatchedState, Rating}; use rocket::{get, State}; use tokio::fs::read_to_string; #[get("/")] pub fn r_home(sess: Session, db: &State) -> MyResult { let mut items = db.list_nodes_with_udata(&sess.user.name)?; let random = (0..16) .flat_map(|i| Some(items[cheap_daily_random(i).checked_rem(items.len())?].clone())) .collect::>(); // let toplevel = T_NODE // .get(db, "library")? // .context("root node missing")? // .into_iter() // .map(|n| db.get_node_with_userdata(&n, &sess)) // .collect::>>()? // .into_iter() // .collect::>(); items.sort_by_key(|(n, _)| { n.ratings .get(&Rating::Tmdb) .map(|x| (*x * -1000.) as i32) .unwrap_or(0) }); let top_rated = items .iter() .take(16) .filter(|(n, _)| n.ratings.contains_key(&Rating::Tmdb)) .map(|k| k.to_owned()) .collect::>(); items.sort_by_key(|(n, _)| n.release_date.map(|d| -d).unwrap_or(i64::MAX)); let latest = items .iter() .take(16) .map(|k| k.to_owned()) .collect::>(); let continue_watching = items .iter() .filter(|(_, u)| matches!(u.watched, WatchedState::Progress(_))) .map(|k| k.to_owned()) .collect::>(); let watchlist = items .iter() .filter(|(_, u)| matches!(u.watched, WatchedState::Pending)) .map(|k| k.to_owned()) .collect::>(); Ok(LayoutPage { title: "Home".to_string(), content: markup::new! { h2 { "Explore " @CONF.brand } // ul.children.hlist {@for (id, node, udata) in &toplevel { // li { @NodeCard { id, node, udata } } // }} @if !continue_watching.is_empty() { h2 { "Continue Watching" } ul.children.hlist {@for (node, udata) in &continue_watching { li { @NodeCard { node, udata } } }} } @if !watchlist.is_empty() { h2 { "Watchlist" } ul.children.hlist {@for (node, udata) in &watchlist { li { @NodeCard { node, udata } } }} } h2 { "Today's Picks" } ul.children.hlist {@for (node, udata) in &random { li { @NodeCard { node, udata } } }} h2 { "Latest Releases" } ul.children.hlist {@for (node, udata) in &latest { li { @NodeCard { node, udata } } }} @if !top_rated.is_empty() { h2 { "Top Rated" } ul.children.hlist {@for (node, udata) in &top_rated { li { @NodeCard { node, udata } } }} } }, ..Default::default() }) } #[get("/", rank = 2)] pub async fn r_home_unpriv() -> MyResult> { let front = read_to_string(CONF.asset_path.join("front.htm")).await?; Ok(LayoutPage { title: "Home".to_string(), content: markup::new! { @markup::raw(&front) }, ..Default::default() }) } fn cheap_daily_random(i: usize) -> usize { xorshift(xorshift(Utc::now().num_days_from_ce() as u64) + i as u64) as usize } fn xorshift(mut x: u64) -> u64 { x ^= x << 13; x ^= x >> 7; x ^= x << 17; x }