diff --git a/src/errors.rs b/src/errors.rs index a96e43d..8ec6e1a 100644 --- a/src/errors.rs +++ b/src/errors.rs @@ -1,4 +1,4 @@ -use axum::http::StatusCode; +use axum::{http::StatusCode, response::Redirect}; #[derive(Debug, thiserror::Error)] pub enum UpubError { @@ -22,6 +22,11 @@ pub enum UpubError { #[error("invalid base64 string: {0}")] Base64(#[from] base64::DecodeError), + + // TODO this isn't really an error but i need to redirect from some routes so this allows me to + // keep the type hints on the return type, still what the hell!!!! + #[error("redirecting to {0}")] + Redirect(String), } impl UpubError { @@ -66,6 +71,7 @@ impl axum::response::IntoResponse for UpubError { fn into_response(self) -> axum::response::Response { let descr = self.to_string(); match self { + UpubError::Redirect(to) => Redirect::to(&to).into_response(), UpubError::Status(status) => (status, descr).into_response(), UpubError::Database(_) => (StatusCode::SERVICE_UNAVAILABLE, descr).into_response(), UpubError::Reqwest(x) => diff --git a/src/routes/activitypub/object/mod.rs b/src/routes/activitypub/object/mod.rs index db57254..bf2d939 100644 --- a/src/routes/activitypub/object/mod.rs +++ b/src/routes/activitypub/object/mod.rs @@ -20,7 +20,11 @@ pub async fn view( ctx.oid(id.clone()) }; if auth.is_local() && query.fetch && !ctx.is_local(&oid) { - ctx.fetch_object(&oid).await?; + let obj = ctx.fetch_object(&oid).await?; + // some implementations serve statuses on different urls than their AP id + if obj.id != oid { + return Err(UpubError::Redirect(crate::url!(ctx, "/objects/{}", ctx.id(&obj.id)))); + } } let item = model::addressing::Entity::find_addressed()