upub/src/routes/activitypub/activity.rs

use axum::{extract::{Path, State}, http::StatusCode};
use sea_orm::{ColumnTrait, QueryFilter};
use crate::{model::{self, addressing::EmbeddedActivity}, server::{auth::AuthIdentity, Context}};
use apb::{ActivityMut, ObjectMut, BaseMut, Node};

use super::{jsonld::LD, JsonLD};

// TODO this is used outside /routes, maybe move in model?
pub fn ap_activity(activity: model::activity::Model) -> serde_json::Value {
	serde_json::Value::new_object()
		.set_id(Some(&activity.id))
		.set_activity_type(Some(activity.activity_type))
		.set_actor(Node::link(activity.actor))
		.set_object(Node::maybe_link(activity.object))
		.set_target(Node::maybe_link(activity.target))
		.set_published(Some(activity.published))
		.set_to(Node::links(activity.to.0.clone()))
		.set_bto(Node::Empty)
		.set_cc(Node::links(activity.cc.0.clone()))
		.set_bcc(Node::Empty)
}

pub async fn view(
	State(ctx): State<Context>,
	Path(id): Path<String>,
	AuthIdentity(auth): AuthIdentity,
) -> Result<JsonLD<serde_json::Value>, StatusCode> {
	let aid = if id.starts_with('+') {
		format!("https://{}", id.replacen('+', "", 1).replace('@', "/"))
	} else {
		ctx.aid(id.clone())
	};
	match model::addressing::Entity::find_activities()
		.filter(model::activity::Column::Id.eq(aid))
		.filter(auth.filter_condition())
		.into_model::<EmbeddedActivity>()
		.one(ctx.db())
		.await
	{
		Ok(Some(activity)) => Ok(JsonLD(serde_json::Value::from(activity).ld_context())),
		Ok(None) => Err(StatusCode::NOT_FOUND),
		Err(e) => {
			tracing::error!("error querying for activity: {e}");
			Err(StatusCode::INTERNAL_SERVER_ERROR)
		},
	}
}