upub-web 0.6.0

web frontend for upub
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

use leptos::prelude::*;
use reqwest::Method;
use crate::{components::AuthResponse, URL_BASE};

#[derive(Debug, Clone, Copy)]
pub struct Auth {
	pub token: Signal<Option<String>>,
	pub userid: Signal<Option<String>>,
}

impl Auth {
	pub fn token(&self) -> String {
		self.token.get().unwrap_or_default()
	}

	pub fn user_id(&self) -> String {
		self.userid.get().unwrap_or_default()
	}
	
	pub fn username(&self) -> String {
		// TODO maybe cache this?? how often do i need it?
		self.userid.get()
			.unwrap_or_default()
			.split('/')
			.next_back()
			.unwrap_or_default()
			.to_string()
	}

	pub fn present(&self) -> bool {
		self.token.get().is_some_and(|x| !x.is_empty())
	}

	pub fn anonymous(&self) -> bool {
		self.token.get().is_none_or(|x| x.is_empty())
	}

	pub fn outbox(&self) -> String {
		format!("{}/outbox", self.user_id())
	}

	pub async fn refresh(
		auth: Auth,
		set_token: WriteSignal<Option<String>>,
		set_userid: WriteSignal<Option<String>>,
	) -> bool {
		if let Some(tok) = auth.token.get_untracked() {
			match crate::Http::request::<>(
				Method::PATCH,
				&format!("{URL_BASE}/auth"),
				Some(&serde_json::json!({"token": tok})),
				auth,
			)
				.await
			{
				Err(e) => tracing::error!("could not refresh token: {e}"),
				Ok(res) => match res.error_for_status() {
					Err(e) => tracing::error!("server rejected refresh: {e}"),
					Ok(doc) => match doc.json::<AuthResponse>().await {
						Err(e) => tracing::error!("failed parsing auth response: {e}"),
						Ok(auth) => {
							set_token.set(Some(auth.token));
							set_userid.set(Some(auth.user));
							return true;
						},
					}
				}
			}
		}
		false
	}
}