2021-10-06 20:20:05 +00:00
|
|
|
use crate::http::{
|
|
|
|
comment::get_apub_comment,
|
|
|
|
community::{
|
2021-12-30 18:37:59 +00:00
|
|
|
community_inbox, get_apub_community_followers, get_apub_community_http,
|
|
|
|
get_apub_community_moderators, get_apub_community_outbox,
|
2020-10-12 14:10:09 +00:00
|
|
|
},
|
2021-10-06 20:20:05 +00:00
|
|
|
get_activity,
|
2021-10-27 16:03:07 +00:00
|
|
|
person::{get_apub_person_http, get_apub_person_outbox, person_inbox},
|
2021-10-06 20:20:05 +00:00
|
|
|
post::get_apub_post,
|
|
|
|
shared_inbox,
|
2020-05-16 14:04:08 +00:00
|
|
|
};
|
2021-12-30 18:37:59 +00:00
|
|
|
use actix_web::{
|
|
|
|
guard::{Guard, GuardContext},
|
|
|
|
http::Method,
|
|
|
|
web,
|
|
|
|
};
|
2021-02-09 18:26:06 +00:00
|
|
|
use http_signature_normalization_actix::digest::middleware::VerifyDigest;
|
2021-03-01 17:24:11 +00:00
|
|
|
use lemmy_utils::settings::structs::Settings;
|
2020-07-13 13:55:55 +00:00
|
|
|
use sha2::{Digest, Sha256};
|
2019-12-31 12:55:33 +00:00
|
|
|
|
2021-09-22 15:57:09 +00:00
|
|
|
pub fn config(cfg: &mut web::ServiceConfig, settings: &Settings) {
|
|
|
|
if settings.federation.enabled {
|
|
|
|
println!("federation enabled, host is {}", settings.hostname);
|
2020-10-21 13:48:43 +00:00
|
|
|
|
2020-01-02 18:22:23 +00:00
|
|
|
cfg
|
2021-11-10 13:17:56 +00:00
|
|
|
.route(
|
|
|
|
"/c/{community_name}",
|
|
|
|
web::get().to(get_apub_community_http),
|
|
|
|
)
|
|
|
|
.route(
|
|
|
|
"/c/{community_name}/followers",
|
|
|
|
web::get().to(get_apub_community_followers),
|
|
|
|
)
|
|
|
|
.route(
|
|
|
|
"/c/{community_name}/outbox",
|
|
|
|
web::get().to(get_apub_community_outbox),
|
|
|
|
)
|
|
|
|
.route(
|
|
|
|
"/c/{community_name}/moderators",
|
|
|
|
web::get().to(get_apub_community_moderators),
|
|
|
|
)
|
|
|
|
.route("/u/{user_name}", web::get().to(get_apub_person_http))
|
|
|
|
.route(
|
|
|
|
"/u/{user_name}/outbox",
|
|
|
|
web::get().to(get_apub_person_outbox),
|
2020-04-14 15:37:23 +00:00
|
|
|
)
|
2021-11-10 13:17:56 +00:00
|
|
|
.route("/post/{post_id}", web::get().to(get_apub_post))
|
|
|
|
.route("/comment/{comment_id}", web::get().to(get_apub_comment))
|
|
|
|
.route("/activities/{type_}/{id}", web::get().to(get_activity));
|
|
|
|
|
|
|
|
cfg.service(
|
|
|
|
web::scope("")
|
|
|
|
.wrap(VerifyDigest::new(Sha256::new()))
|
|
|
|
.guard(InboxRequestGuard)
|
|
|
|
.route("/c/{community_name}/inbox", web::post().to(community_inbox))
|
|
|
|
.route("/u/{user_name}/inbox", web::post().to(person_inbox))
|
|
|
|
.route("/inbox", web::post().to(shared_inbox)),
|
|
|
|
);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Without this, things like webfinger or RSS feeds stop working, as all requests seem to get
|
|
|
|
/// routed into the inbox service (because it covers the root path). So we filter out anything that
|
|
|
|
/// definitely can't be an inbox request (based on Accept header and request method).
|
|
|
|
struct InboxRequestGuard;
|
|
|
|
|
|
|
|
impl Guard for InboxRequestGuard {
|
2021-12-30 18:37:59 +00:00
|
|
|
fn check(&self, request: &GuardContext) -> bool {
|
|
|
|
if request.head().method != Method::POST {
|
2021-11-10 13:17:56 +00:00
|
|
|
return false;
|
|
|
|
}
|
2021-12-30 18:37:59 +00:00
|
|
|
if let Some(val) = request.head().headers.get("Content-Type") {
|
2021-11-11 12:18:08 +00:00
|
|
|
return val
|
|
|
|
.to_str()
|
|
|
|
.expect("Content-Type header contains non-ascii chars.")
|
|
|
|
.starts_with("application/");
|
2021-11-10 13:17:56 +00:00
|
|
|
}
|
|
|
|
false
|
2020-01-02 18:22:23 +00:00
|
|
|
}
|
2019-12-31 12:55:33 +00:00
|
|
|
}
|