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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

use leptos::{either::Either, ev::MouseEvent};
use leptos::prelude::*;
use leptos_router::components::Outlet;
use leptos_router::hooks::use_params_map;
use crate::{app::FeedRoute, prelude::*};

use apb::Object;

#[component]
pub fn ObjectView() -> impl IntoView {
	let params = use_params_map();
	let matched_route = use_context::<ReadSignal<crate::app::FeedRoute>>().expect("missing route context");
	let auth = use_context::<Auth>().expect("missing auth context");
	let refresh = use_context::<WriteSignal<()>>().expect("missing refresh context");
	let (loading, set_loading) = signal(false);
	let id = Signal::derive(move || params.get().get("id").unwrap_or_default());
	let object = LocalResource::new(
		move || {
			let (oid, _loading) = (id.get(), loading.get());
			async move {
				tracing::info!("rerunning fetcher");
				let obj = cache::OBJECTS.fetch(&oid, U::Object, auth).await?;

				// TODO these two can be parallelized
				if let Ok(author) = obj.attributed_to().id() {
					cache::OBJECTS.fetch(&author, U::Actor, auth).await;
				}
				if let Ok(quote) = obj.quote_url().id() {
					cache::OBJECTS.fetch(&quote, U::Object, auth).await;
				}

				Some(obj)

				// if let Ok(ctx) = obj.context().id() {
				// 	let tl_url = format!("{}/context/page", Uri::api(U::Object, ctx, false));
				// 	if !feeds.context.next.get_untracked().starts_with(&tl_url) {
				// 		feeds.context.reset(Some(tl_url));
				// 	}
				// }
			}
		}
	);

	// TODO since updating dependencies, this tries to get redrawn while it gets disposed, causing
	//      panics. honestly this makes no sense: it's probably a race condition because i've done
	//      something funky, but nonetheless i can't figure out what exactly right away. so we use
	//      .try_get() instead, which makes this nested option hell, but allows us to catch the
	//      "already disposed" case
	//    + i think it may be due to the <Loadable> wrapper
	view! {
		{move || match object.try_get() {
			None => ().into_any(), // already disposed
			Some(None) => view! { <Loader /> }.into_any(), // still loading
			Some(Some(None)) => { // error loading
				let raw_id = params.get().get("id").unwrap_or_default();
				let uid =  uriproxy::uri(URL_BASE, uriproxy::UriClass::Object, &raw_id);
				view! { <p class="center"><code>loading failed</code><sup><small><a class="clean" href={uid} target="_blank">"↗"</a></small></sup></p> }.into_any()
			},
			Some(Some(Some(o))) => { // loaded ok
				tracing::info!("redrawing object");
				view! { <Object object=o.clone() /> }.into_any()
			},
		}}

		<p>
			<span class:tab-active=move || matches!(matched_route.get(), FeedRoute::Context)><a class="clean" href=move || format!("/web/objects/{}", id.get())><span class="emoji ml-2">"🕸️"</span><span class:hidden-on-mobile=move || !matches!(matched_route.get(), FeedRoute::Context)>" context"</span></a></span>
			<span class:tab-active=move || matches!(matched_route.get(), FeedRoute::Replies)><a class="clean" href=move || format!("/web/objects/{}/replies", id.get())><span class="emoji ml-2">"📫"</span><span class:hidden-on-mobile=move || !matches!(matched_route.get(), FeedRoute::Replies)>" replies"</span></a></span>
			<span class:tab-active=move || matches!(matched_route.get(), FeedRoute::ObjectLikes)><a class="clean" href=move || format!("/web/objects/{}/likes", id.get())><span class="emoji ml-2">"⭐"</span><span class:hidden-on-mobile=move || !matches!(matched_route.get(), FeedRoute::ObjectLikes)>" likes"</span></a></span>
			{move || if auth.present() {
				if loading.get() {
					Some(Either::Left(view! {
						<span style="float: right">
							"fetching "<span class="dots"></span>
						</span>
					}))
				} else {
					Some(Either::Right(view! {
						<span style="float: right">
							<a
								class="clean"
								on:click=move |ev| fetch_cb(ev, set_loading, id.get(), auth, refresh)
								href="#"
							>
								<span class="emoji ml-2">"↺ "</span>"fetch"
							</a>
						</span>
					}))
				}
			} else {
				None
			}}
		</p>
		<hr class="color" />

		{move || if object.try_get().is_some_and(|x| x.is_some()) {
			tracing::info!("redrawing outlet");
			Some(view! { <Outlet /> })
		} else {
			None
		}}
	}
}

fn fetch_cb(ev: MouseEvent, set_loading: WriteSignal<bool>, oid: String, auth: Auth, refresh: WriteSignal<()>) {
	let api = Uri::api(U::Object, &oid, false);
	ev.prevent_default();
	set_loading.set(true);
	leptos::task::spawn_local(async move {
		if let Err(e) = Http::fetch::<serde_json::Value>(&format!("{api}/replies?fetch=true"), auth).await {
			tracing::error!("failed crawling replies for {oid}: {e}");
		}
		cache::OBJECTS.invalidate(&Uri::full(U::Object, &oid));
		tracing::info!("invalidated {}", Uri::full(U::Object, &oid));
		set_loading.set(false);
		refresh.set(());
	});
}