upub/src/routes/activitypub/user/mod.rs

77 lines
2.3 KiB
Rust
Raw Normal View History

2024-03-25 02:00:57 +01:00
pub mod inbox;
2024-03-23 04:31:48 +01:00
2024-03-25 02:00:57 +01:00
pub mod outbox;
2024-03-23 04:31:48 +01:00
2024-03-27 04:23:42 +01:00
pub mod following;
2024-03-23 04:31:48 +01:00
use axum::extract::{Path, State};
use sea_orm::EntityTrait;
2024-03-23 04:31:48 +01:00
use apb::{PublicKeyMut, ActorMut, DocumentMut, DocumentType, ObjectMut, BaseMut, Node};
2024-04-13 06:55:16 +02:00
use crate::{errors::UpubError, model::{self, user}, server::Context, url};
2024-03-23 04:31:48 +01:00
use super::{jsonld::LD, JsonLD};
2024-03-23 04:31:48 +01:00
2024-03-23 20:24:38 +01:00
pub fn ap_user(user: model::user::Model) -> serde_json::Value {
serde_json::Value::new_object()
.set_id(Some(&user.id))
.set_actor_type(Some(user.actor_type))
.set_name(user.name.as_deref())
.set_summary(user.summary.as_deref())
.set_icon(Node::maybe_object(user.icon.map(|i|
serde_json::Value::new_object()
.set_document_type(Some(DocumentType::Image))
.set_url(Node::link(i.clone()))
)))
.set_image(Node::maybe_object(user.image.map(|i|
serde_json::Value::new_object()
.set_document_type(Some(DocumentType::Image))
.set_url(Node::link(i.clone()))
)))
.set_published(Some(user.created))
.set_preferred_username(Some(&user.preferred_username))
.set_inbox(Node::maybe_link(user.inbox))
.set_outbox(Node::maybe_link(user.outbox))
.set_following(Node::maybe_link(user.following))
.set_followers(Node::maybe_link(user.followers))
2024-03-26 00:49:56 +01:00
.set_public_key(Node::object(
serde_json::Value::new_object()
.set_id(Some(&format!("{}#main-key", user.id)))
.set_owner(Some(&user.id))
.set_public_key_pem(&user.public_key)
))
2024-03-23 20:24:38 +01:00
.set_discoverable(Some(true))
.set_endpoints(Node::Empty)
2024-03-23 04:31:48 +01:00
}
pub async fn view(
State(ctx) : State<Context>,
Path(id): Path<String>,
) -> crate::Result<JsonLD<serde_json::Value>> {
let uid = if id.starts_with('+') {
format!("https://{}", id.replacen('+', "", 1).replace('@', "/"))
} else {
ctx.uid(id.clone())
};
match user::Entity::find_by_id(uid)
.find_also_related(model::config::Entity)
2024-04-13 06:55:16 +02:00
.one(ctx.db()).await?
{
// local user
2024-04-13 06:55:16 +02:00
Some((user, Some(_cfg))) => {
2024-03-23 20:24:38 +01:00
Ok(JsonLD(ap_user(user.clone()) // ew ugly clone TODO
.set_inbox(Node::link(url!(ctx, "/users/{id}/inbox")))
.set_outbox(Node::link(url!(ctx, "/users/{id}/outbox")))
.set_following(Node::link(url!(ctx, "/users/{id}/following")))
.set_followers(Node::link(url!(ctx, "/users/{id}/followers")))
// .set_public_key(user.public_key) // TODO
2024-03-23 06:32:15 +01:00
.ld_context()
))
},
// remote user TODDO doesn't work?
2024-04-13 06:55:16 +02:00
Some((user, None)) => Ok(JsonLD(ap_user(user).ld_context())),
None => Err(UpubError::not_found()),
2024-03-23 04:31:48 +01:00
}
}