use leptos::{either::Either, prelude::*, reactive::signal::signal};
use leptos_router::{components::Outlet, hooks::use_params};
use crate::{app::FeedRoute, prelude::*, IconGradient, FALLBACK_IMAGE_URL};
use apb::{ActivityMut, Actor, Base, Object, ObjectMut, Shortcuts};
#[component]
pub fn ActorHeader() -> impl IntoView {
let params = use_params::<IdParam>();
let auth = use_context::<Auth>().expect("missing auth context");
let refresh = use_context::<WriteSignal<()>>().expect("missing refresh context");
let list_controls = use_context::<ListControls>().expect("missing list control context");
let matched_route = use_context::<ReadSignal<crate::app::FeedRoute>>().expect("missing route context");
let (loading, set_loading) = signal(false);
let actor = LocalResource::new(
move || {
let id = params.get().ok().and_then(|x| x.id).unwrap_or_default();
async move {
match cache::OBJECTS.get(&Uri::full(U::Actor, &id)) {
Some(x) => Some(x.clone()),
None => {
let user = cache::OBJECTS.fetch(&id, U::Actor, auth).await?;
Some(user)
},
}
}
}
);
move || match actor.get() {
None => view! { <Loader /> }.into_any(),
Some(None) => view! { <code class="center cw color">"could not resolve user"</code> }.into_any(),
Some(Some(actor)) => {
let username = actor.preferred_username().unwrap_or_default().to_string();
let name = actor.name().unwrap_or(username.clone());
let created = actor.published().ok();
let following_me = actor.following_me().unwrap_or(false);
let followed_by_me = actor.followed_by_me().unwrap_or(false);
let domain = actor.id().unwrap_or_default().replace("https://", "").split('/').next().unwrap_or_default().to_string();
let actor_type = actor.actor_type().unwrap_or(apb::ActorType::Person);
let actor_type_tag = if actor_type == apb::ActorType::Person { None } else {
Some(view! { <sup class="ml-s"><small>"["{actor_type.as_ref().to_lowercase()}"]"</small></sup> } )
};
let background_url = actor.image_url().unwrap_or(FALLBACK_IMAGE_URL.into());
let (avatar_url, avatar_style) = actor.icon_url_and_style();
let fields = actor.attachment()
.flat()
.into_iter()
.filter_map(|x| x.into_inner().ok())
.map(|x| view! {
<tr>
<td class="w-25"><b class="color">{x.name().unwrap_or_default()}</b></td>
<td class="w-75" inner_html={mdhtml::safe_html(&x.value().unwrap_or_default())}></td>
</tr>
})
.collect_view();
let uid = actor.id().unwrap_or_default().to_string();
let web_path = Uri::web(U::Actor, &uid);
let _uid = uid.clone();
let __uid = uid.clone();
let ___uid = uid.clone();
let ____uid = uid.clone();
view! {
<div class="ml-3 mr-3">
<div
class="banner"
style={format!("background: center / cover url({background_url});")}
>
<div style="height: 10em"></div> </div>
<div class="overlap">
<div class="pl-1 pr-1" style="display: flex">
<img class="avatar avatar-large avatar-border mr-s" src={avatar_url} style={avatar_style} />
<div class="ma-s">
<p class="line shadow">
<span class="emoji mr-s">"\u{1f582}"</span><small>{actor.statuses_count().unwrap_or_default()}</small>
<span class="emoji ml-1 mr-s">"👥"</span><small>{actor.following_count().unwrap_or_default()}</small>
<span class="emoji ml-1 mr-s">"📢"</span><small>{actor.followers_count().unwrap_or_default()}</small>
</p>
<p class="line pt-1"><b class="big mt-1">{name}</b>{actor_type_tag}</p>
<p class="line"><small><a class="clean hover" href={uid.clone()} target="_blank">{username.clone()}@{domain}</a></small></p>
<p class="line"><DateTime t=created /></p>
</div>
<div class="ma-s pt-3 rev" style="flex-grow: 1; white-space: nowrap;">
</div>
</div>
<div class="mr-1 ml-1" class:hidden=move || !auth.present() || auth.user_id() == uid>
{if following_me {
Some(view! {
<span class="border-button ml-s cursor" title="remove follower" on:click=move |_| remove_follower(___uid.clone(), auth)>
<code class="color mr-s">"!"</code>
<small class="mr-s">follows you</small>
</span>
})
} else {
None
}}
{if followed_by_me {
Either::Left(view! {
<span class="border-button ml-s cursor" title="undo follow" on:click=move |_| unfollow(_uid.clone(), auth)>
<code class="color mr-s">x</code>
<small class="mr-s">following</small>
</span>
})
} else {
Either::Right(view! {
<span class="border-button ml-s cursor" title="send follow request" on:click=move |_| send_follow_request(_uid.clone(), auth)>
<code class="color mr-s">+</code>
<small class="mr-s">follow</small>
</span>
})
}}
{list_controls.active.get().map(|active| {
view! {
<span class="border-button ml-s cursor" title="add to list"
on:click=move |_| list_controls.add_to_list(active.clone(), ____uid.clone(), auth)
>
<code class="color mr-s">#</code>
<small class="mr-s">add</small>
</span>
}
})}
</div>
</div>
<p class="mb-2 mt-0 center bio" inner_html={mdhtml::safe_html(&actor.summary().unwrap_or_default())}></p>
<p class="center">
<table class="fields center w-100 pa-s" style="margin: auto; table-layout: fixed;">{fields}</table>
</p>
</div>
<p class="mt-2">
<span class:tab-active=move || matches!(matched_route.get(), FeedRoute::User)>
<a class="clean" href=web_path.clone()><span class="emoji">"📫 "</span>"outbox"</a>
</span>
<span class="ml-1" class:tab-active=move || matches!(matched_route.get(), FeedRoute::ActorLikes)>
<a class="clean" href=format!("{web_path}/likes")><span class="emoji">"⭐ "</span>"likes"</a>
</span>
<span class="ml-1" style="float: right" class:tab-active=move || matches!(matched_route.get(), FeedRoute::Followers)>
<a class="clean" href=format!("{web_path}/followers")><span class="emoji">"📢"</span><span class:hidden-on-mobile=move || !matches!(matched_route.get(), FeedRoute::Followers)>" followers"</span></a>
</span>
<span class="ml-1" style="float: right" class:tab-active=move || matches!(matched_route.get(), FeedRoute::Following)>
<a class="clean" href=format!("{web_path}/following")><span class="emoji">"👥"</span><span class:hidden-on-mobile=move || !matches!(matched_route.get(), FeedRoute::Following)>" following"</span></a>
</span>
{move || if auth.present() {
if loading.get() {
Some(Either::Left(view! {
<span style="float: right">
<span class="hidden-on-mobile">"fetching "</span><span class="dots"></span>
</span>
}))
} else {
let uid = __uid.clone();
Some(Either::Right(view! {
<span style="float: right">
<a
class="clean"
on:click=move |ev| fetch_cb(ev, set_loading, uid.clone(), auth, refresh)
href="#"
>
<span class="emoji ml-2">"↺ "</span><span class="hidden-on-mobile">"fetch"</span>
</a>
</span>
}))
}
} else {
None
}}
</p>
<hr class="color" />
<Outlet />
}.into_any()
},
}
}
#[allow(unused)]
async fn send_follow_response(kind: apb::ActivityType, target: String, to: String, auth: Auth) {
let payload = apb::new()
.set_activity_type(Some(kind))
.set_object(apb::Node::link(target))
.set_to(apb::Node::links(vec![to]));
if let Err(e) = Http::post(&auth.outbox(), &payload, auth).await {
tracing::error!("failed posting follow response: {e}");
}
}
fn send_follow_request(target: String, auth: Auth) {
leptos::task::spawn_local(async move {
let payload = apb::new()
.set_activity_type(Some(apb::ActivityType::Follow))
.set_object(apb::Node::link(target.clone()))
.set_to(apb::Node::links(vec![target]));
if let Err(e) = Http::post(&auth.outbox(), &payload, auth).await {
tracing::error!("failed sending follow request: {e}");
}
})
}
fn unfollow(target: String, auth: Auth) {
leptos::task::spawn_local(async move {
let payload = apb::new()
.set_activity_type(Some(apb::ActivityType::Undo))
.set_to(apb::Node::links(vec![target.clone()]))
.set_object(apb::Node::object(
apb::new()
.set_activity_type(Some(apb::ActivityType::Follow))
.set_object(apb::Node::link(target))
));
if let Err(e) = Http::post(&auth.outbox(), &payload, auth).await {
tracing::error!("failed sending unfollow: {e}");
}
})
}
fn remove_follower(target: String, auth: Auth) {
leptos::task::spawn_local(async move {
let payload = apb::new()
.set_activity_type(Some(apb::ActivityType::Undo))
.set_to(apb::Node::links(vec![target.clone()]))
.set_object(apb::Node::object(
apb::new()
.set_activity_type(Some(apb::ActivityType::Follow))
.set_actor(apb::Node::link(target))
.set_object(apb::Node::link(auth.user_id()))
));
if let Err(e) = Http::post(&auth.outbox(), &payload, auth).await {
tracing::error!("failed sending follow removal request: {e}");
}
})
}
fn fetch_cb(ev: leptos::ev::MouseEvent, set_loading: WriteSignal<bool>, uid: String, auth: Auth, refresh: WriteSignal<()>) {
let api = Uri::api(U::Actor, &uid, 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}/outbox?fetch=true"), auth).await {
tracing::error!("failed fetching outbox for {uid}: {e}");
}
set_loading.set(false);
refresh.set(());
});
}