lemmy/server/src/apub/community_inbox.rs

69 lines
1.7 KiB
Rust
Raw Normal View History

2020-04-24 14:04:36 +00:00
use super::*;
#[serde(untagged)]
2020-04-17 14:55:28 +00:00
#[derive(Deserialize, Debug)]
pub enum CommunityAcceptedObjects {
Follow(Follow),
}
2020-04-24 19:55:54 +00:00
// TODO Consolidate community and user inboxes into a single shared one
2020-04-17 15:33:55 +00:00
/// Handler for all incoming activities to community inboxes.
pub async fn community_inbox(
2020-04-19 17:35:40 +00:00
request: HttpRequest,
input: web::Json<CommunityAcceptedObjects>,
2020-04-17 17:34:18 +00:00
path: web::Path<String>,
2020-04-24 14:04:36 +00:00
db: DbPoolParam,
chat_server: ChatServerParam,
) -> Result<HttpResponse, Error> {
let input = input.into_inner();
2020-04-24 14:04:36 +00:00
let community_name = path.into_inner();
2020-04-17 14:55:28 +00:00
debug!(
"Community {} received activity {:?}",
2020-04-24 19:55:54 +00:00
&community_name, &input
2020-04-17 14:55:28 +00:00
);
match input {
2020-04-24 19:55:54 +00:00
CommunityAcceptedObjects::Follow(f) => {
handle_follow(&f, &request, &community_name, db, chat_server)
}
}
}
2020-04-17 15:33:55 +00:00
/// Handle a follow request from a remote user, adding it to the local database and returning an
/// Accept activity.
2020-04-19 17:35:40 +00:00
fn handle_follow(
follow: &Follow,
request: &HttpRequest,
2020-04-24 14:04:36 +00:00
community_name: &str,
db: DbPoolParam,
2020-04-24 19:55:54 +00:00
_chat_server: ChatServerParam,
2020-04-19 17:35:40 +00:00
) -> Result<HttpResponse, Error> {
let user_uri = follow
.follow_props
.get_actor_xsd_any_uri()
.unwrap()
.to_string();
2020-04-24 19:55:54 +00:00
let _community_uri = follow
.follow_props
.get_object_xsd_any_uri()
.unwrap()
.to_string();
2020-04-24 14:04:36 +00:00
let conn = db.get()?;
let user = get_or_fetch_and_upsert_remote_user(&user_uri, &conn)?;
let community = Community::read_from_name(&conn, &community_name)?;
verify(&request, &user.public_key.unwrap())?;
let community_follower_form = CommunityFollowerForm {
community_id: community.id,
user_id: user.id,
};
2020-04-24 14:04:36 +00:00
// This will fail if they're already a follower
CommunityFollower::follow(&conn, &community_follower_form)?;
2020-04-24 14:04:36 +00:00
accept_follow(&follow, &conn)?;
Ok(HttpResponse::Ok().finish())
}