From c1db86925f286d9123ae9169f4467100611e3182 Mon Sep 17 00:00:00 2001 From: Felix Ableitner Date: Sat, 17 Jul 2021 18:20:44 +0200 Subject: [PATCH] Merge apub, apub_receive crates (fixes #1621) --- Cargo.lock | 47 +------ Cargo.toml | 2 - ansible/templates/docker-compose.yml | 2 +- api_tests/prepare-drone-federation-test.sh | 2 +- crates/apub/Cargo.toml | 4 +- .../src/activities/comment/create.rs | 13 +- .../src/activities/comment/mod.rs | 2 +- .../src/activities/comment/remove.rs | 2 +- .../src/activities/comment/undo_remove.rs | 2 +- .../src/activities/comment/update.rs | 13 +- .../src/activities/community/add_mod.rs | 18 +-- .../src/activities/community/announce.rs | 2 +- .../src/activities/community/block_user.rs | 9 +- .../src/activities/community/mod.rs | 0 .../activities/community/undo_block_user.rs | 17 ++- .../src/activities/community/update.rs | 15 ++- .../src/activities/deletion/delete.rs | 22 ++-- .../src/activities/deletion/mod.rs | 0 .../src/activities/deletion/undo_delete.rs | 24 ++-- .../src/activities/following/accept.rs | 9 +- .../src/activities/following/follow.rs | 10 +- .../src/activities/following/mod.rs | 0 .../src/activities/following/undo.rs | 9 +- crates/apub/src/activities/mod.rs | 121 ++++++++++++++++++ .../src/activities/post/create.rs | 10 +- .../src/activities/post/mod.rs | 0 .../src/activities/post/update.rs | 20 +-- .../src/activities/private_message/create.rs | 7 +- .../src/activities/private_message/delete.rs | 0 .../src/activities/private_message/mod.rs | 0 .../activities/private_message/undo_delete.rs | 0 .../src/activities/private_message/update.rs | 7 +- .../src/activities/removal/mod.rs | 0 .../src/activities/removal/remove.rs | 26 ++-- .../src/activities/removal/undo_remove.rs | 26 ++-- .../src/activities/voting/dislike.rs | 0 .../src/activities/voting/like.rs | 0 .../src/activities/voting/mod.rs | 12 +- .../src/activities/voting/undo_dislike.rs | 0 .../src/activities/voting/undo_like.rs | 0 crates/apub/src/fetcher/community.rs | 14 +- .../src/http/comment.rs | 6 +- .../src/http/community.rs | 24 ++-- .../src/http/inbox_enums.rs | 0 crates/{apub_receive => apub}/src/http/mod.rs | 16 +-- .../{apub_receive => apub}/src/http/person.rs | 18 ++- .../{apub_receive => apub}/src/http/post.rs | 6 +- .../{apub_receive => apub}/src/http/routes.rs | 30 +++-- crates/apub/src/lib.rs | 1 + crates/apub_receive/Cargo.toml | 46 ------- crates/apub_receive/src/activities/mod.rs | 121 ------------------ crates/apub_receive/src/lib.rs | 2 - docker/dev/docker-compose.yml | 2 +- docker/federation/docker-compose.yml | 10 +- docker/prod/docker-compose.yml | 2 +- src/main.rs | 2 +- 56 files changed, 341 insertions(+), 412 deletions(-) rename crates/{apub_receive => apub}/src/activities/comment/create.rs (90%) rename crates/{apub_receive => apub}/src/activities/comment/mod.rs (96%) rename crates/{apub_receive => apub}/src/activities/comment/remove.rs (94%) rename crates/{apub_receive => apub}/src/activities/comment/undo_remove.rs (95%) rename crates/{apub_receive => apub}/src/activities/comment/update.rs (90%) rename crates/{apub_receive => apub}/src/activities/community/add_mod.rs (94%) rename crates/{apub_receive => apub}/src/activities/community/announce.rs (98%) rename crates/{apub_receive => apub}/src/activities/community/block_user.rs (91%) rename crates/{apub_receive => apub}/src/activities/community/mod.rs (100%) rename crates/{apub_receive => apub}/src/activities/community/undo_block_user.rs (87%) rename crates/{apub_receive => apub}/src/activities/community/update.rs (92%) rename crates/{apub_receive => apub}/src/activities/deletion/delete.rs (94%) rename crates/{apub_receive => apub}/src/activities/deletion/mod.rs (100%) rename crates/{apub_receive => apub}/src/activities/deletion/undo_delete.rs (91%) rename crates/{apub_receive => apub}/src/activities/following/accept.rs (89%) rename crates/{apub_receive => apub}/src/activities/following/follow.rs (96%) rename crates/{apub_receive => apub}/src/activities/following/mod.rs (100%) rename crates/{apub_receive => apub}/src/activities/following/undo.rs (90%) rename crates/{apub_receive => apub}/src/activities/post/create.rs (92%) rename crates/{apub_receive => apub}/src/activities/post/mod.rs (100%) rename crates/{apub_receive => apub}/src/activities/post/update.rs (94%) rename crates/{apub_receive => apub}/src/activities/private_message/create.rs (91%) rename crates/{apub_receive => apub}/src/activities/private_message/delete.rs (100%) rename crates/{apub_receive => apub}/src/activities/private_message/mod.rs (100%) rename crates/{apub_receive => apub}/src/activities/private_message/undo_delete.rs (100%) rename crates/{apub_receive => apub}/src/activities/private_message/update.rs (91%) rename crates/{apub_receive => apub}/src/activities/removal/mod.rs (100%) rename crates/{apub_receive => apub}/src/activities/removal/remove.rs (93%) rename crates/{apub_receive => apub}/src/activities/removal/undo_remove.rs (91%) rename crates/{apub_receive => apub}/src/activities/voting/dislike.rs (100%) rename crates/{apub_receive => apub}/src/activities/voting/like.rs (100%) rename crates/{apub_receive => apub}/src/activities/voting/mod.rs (96%) rename crates/{apub_receive => apub}/src/activities/voting/undo_dislike.rs (100%) rename crates/{apub_receive => apub}/src/activities/voting/undo_like.rs (100%) rename crates/{apub_receive => apub}/src/http/comment.rs (90%) rename crates/{apub_receive => apub}/src/http/community.rs (96%) rename crates/{apub_receive => apub}/src/http/inbox_enums.rs (100%) rename crates/{apub_receive => apub}/src/http/mod.rs (98%) rename crates/{apub_receive => apub}/src/http/person.rs (91%) rename crates/{apub_receive => apub}/src/http/post.rs (89%) rename crates/{apub_receive => apub}/src/http/routes.rs (84%) delete mode 100644 crates/apub_receive/Cargo.toml delete mode 100644 crates/apub_receive/src/activities/mod.rs delete mode 100644 crates/apub_receive/src/lib.rs diff --git a/Cargo.lock b/Cargo.lock index 31492222f..53e3e0071 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1726,6 +1726,7 @@ dependencies = [ "itertools", "lazy_static", "lemmy_api_common", + "lemmy_apub_lib", "lemmy_db_queries", "lemmy_db_schema", "lemmy_db_views", @@ -1772,51 +1773,6 @@ dependencies = [ "trybuild", ] -[[package]] -name = "lemmy_apub_receive" -version = "0.1.0" -dependencies = [ - "activitystreams", - "activitystreams-ext", - "actix", - "actix-rt", - "actix-web", - "anyhow", - "async-trait", - "awc", - "backtrace", - "base64 0.13.0", - "bcrypt", - "chrono", - "diesel", - "futures", - "http", - "http-signature-normalization-actix", - "http-signature-normalization-reqwest", - "itertools", - "lemmy_api_common", - "lemmy_apub", - "lemmy_apub_lib", - "lemmy_db_queries", - "lemmy_db_schema", - "lemmy_db_views", - "lemmy_db_views_actor", - "lemmy_utils", - "lemmy_websocket", - "log", - "openssl", - "percent-encoding", - "rand 0.8.4", - "serde", - "serde_json", - "sha2", - "strum", - "strum_macros", - "thiserror", - "tokio", - "url", -] - [[package]] name = "lemmy_db_queries" version = "0.1.0" @@ -1932,7 +1888,6 @@ dependencies = [ "lemmy_api_common", "lemmy_api_crud", "lemmy_apub", - "lemmy_apub_receive", "lemmy_db_queries", "lemmy_db_schema", "lemmy_db_views", diff --git a/Cargo.toml b/Cargo.toml index 2352a7d64..0259f69dd 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -17,7 +17,6 @@ members = [ "crates/apub_lib", "crates/apub_lib_derive", "crates/apub", - "crates/apub_receive", "crates/utils", "crates/db_queries", "crates/db_schema", @@ -32,7 +31,6 @@ members = [ lemmy_api = { path = "./crates/api" } lemmy_api_crud = { path = "./crates/api_crud" } lemmy_apub = { path = "./crates/apub" } -lemmy_apub_receive = { path = "./crates/apub_receive" } lemmy_utils = { path = "./crates/utils" } lemmy_db_schema = { path = "./crates/db_schema" } lemmy_db_queries = { path = "./crates/db_queries" } diff --git a/ansible/templates/docker-compose.yml b/ansible/templates/docker-compose.yml index 03053d347..1d2609e63 100644 --- a/ansible/templates/docker-compose.yml +++ b/ansible/templates/docker-compose.yml @@ -7,7 +7,7 @@ services: - "127.0.0.1:8536:8536" restart: always environment: - - RUST_LOG="warn,lemmy_server=info,lemmy_api=info,lemmy_api_common=info,lemmy_api_crud=info,lemmy_apub=info,lemmy_apub_receive=info,lemmy_db_queries=info,lemmy_db_schema=info,lemmy_db_views=info,lemmy_db_views_actor=info,lemmy_db_views_moderator=info,lemmy_routes=info,lemmy_utils=info,lemmy_websocket=info" + - RUST_LOG="warn,lemmy_server=info,lemmy_api=info,lemmy_api_common=info,lemmy_api_crud=info,lemmy_apub=info,lemmy_db_queries=info,lemmy_db_schema=info,lemmy_db_views=info,lemmy_db_views_actor=info,lemmy_db_views_moderator=info,lemmy_routes=info,lemmy_utils=info,lemmy_websocket=info" volumes: - ./lemmy.hjson:/config/config.hjson:ro depends_on: diff --git a/api_tests/prepare-drone-federation-test.sh b/api_tests/prepare-drone-federation-test.sh index c2c7805aa..7a8fb2bd8 100755 --- a/api_tests/prepare-drone-federation-test.sh +++ b/api_tests/prepare-drone-federation-test.sh @@ -3,7 +3,7 @@ set -e export LEMMY_TEST_SEND_SYNC=1 export RUST_BACKTRACE=1 -export RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_apub_receive=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" +export RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" for INSTANCE in lemmy_alpha lemmy_beta lemmy_gamma lemmy_delta lemmy_epsilon; do psql "${LEMMY_DATABASE_URL}/lemmy" -c "DROP DATABASE IF EXISTS $INSTANCE" diff --git a/crates/apub/Cargo.toml b/crates/apub/Cargo.toml index 9f5b3e504..ac4453bbc 100644 --- a/crates/apub/Cargo.toml +++ b/crates/apub/Cargo.toml @@ -10,6 +10,7 @@ doctest = false [dependencies] lemmy_utils = { path = "../utils" } +lemmy_apub_lib = { path = "../apub_lib" } lemmy_db_queries = { path = "../db_queries" } lemmy_db_schema = { path = "../db_schema" } lemmy_db_views = { path = "../db_views" } @@ -31,7 +32,6 @@ log = "0.4.14" rand = "0.8.4" strum = "0.21.0" strum_macros = "0.21.1" -lazy_static = "1.4.0" url = { version = "2.2.2", features = ["serde"] } percent-encoding = "2.1.0" openssl = "0.10.35" @@ -50,3 +50,5 @@ thiserror = "1.0.26" background-jobs = "0.9.0" reqwest = { version = "0.11.4", features = ["json"] } backtrace = "0.3.60" +lazy_static = "1.4.0" + diff --git a/crates/apub_receive/src/activities/comment/create.rs b/crates/apub/src/activities/comment/create.rs similarity index 90% rename from crates/apub_receive/src/activities/comment/create.rs rename to crates/apub/src/activities/comment/create.rs index 7ce5d09af..84dab1071 100644 --- a/crates/apub_receive/src/activities/comment/create.rs +++ b/crates/apub/src/activities/comment/create.rs @@ -1,10 +1,13 @@ -use crate::activities::{ - comment::{get_notif_recipients, send_websocket_message}, - verify_activity, - verify_person_in_community, +use crate::{ + activities::{ + comment::{get_notif_recipients, send_websocket_message}, + verify_activity, + verify_person_in_community, + }, + objects::FromApub, + NoteExt, }; use activitystreams::{activity::kind::CreateType, base::BaseExt}; -use lemmy_apub::{objects::FromApub, NoteExt}; use lemmy_apub_lib::{verify_domains_match_opt, ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_schema::source::comment::Comment; use lemmy_utils::LemmyError; diff --git a/crates/apub_receive/src/activities/comment/mod.rs b/crates/apub/src/activities/comment/mod.rs similarity index 96% rename from crates/apub_receive/src/activities/comment/mod.rs rename to crates/apub/src/activities/comment/mod.rs index e5cdb4dd6..292d57bf4 100644 --- a/crates/apub_receive/src/activities/comment/mod.rs +++ b/crates/apub/src/activities/comment/mod.rs @@ -1,5 +1,5 @@ +use crate::fetcher::person::get_or_fetch_and_upsert_person; use lemmy_api_common::{blocking, comment::CommentResponse, send_local_notifs}; -use lemmy_apub::fetcher::person::get_or_fetch_and_upsert_person; use lemmy_db_queries::Crud; use lemmy_db_schema::{ source::{comment::Comment, post::Post}, diff --git a/crates/apub_receive/src/activities/comment/remove.rs b/crates/apub/src/activities/comment/remove.rs similarity index 94% rename from crates/apub_receive/src/activities/comment/remove.rs rename to crates/apub/src/activities/comment/remove.rs index 53e69b658..d60e3f804 100644 --- a/crates/apub_receive/src/activities/comment/remove.rs +++ b/crates/apub/src/activities/comment/remove.rs @@ -1,7 +1,7 @@ use crate::activities::{comment::send_websocket_message, verify_mod_action}; use activitystreams::activity::kind::RemoveType; use lemmy_api_common::blocking; -use lemmy_apub::{check_is_apub_id_valid, fetcher::objects::get_or_fetch_and_insert_comment}; +use crate::{check_is_apub_id_valid, fetcher::objects::get_or_fetch_and_insert_comment}; use lemmy_apub_lib::{verify_domains_match, ActivityCommonFields, ActivityHandlerNew, PublicUrl}; use lemmy_db_queries::source::comment::Comment_; use lemmy_db_schema::source::comment::Comment; diff --git a/crates/apub_receive/src/activities/comment/undo_remove.rs b/crates/apub/src/activities/comment/undo_remove.rs similarity index 95% rename from crates/apub_receive/src/activities/comment/undo_remove.rs rename to crates/apub/src/activities/comment/undo_remove.rs index 444f3ce40..f3ebdf385 100644 --- a/crates/apub_receive/src/activities/comment/undo_remove.rs +++ b/crates/apub/src/activities/comment/undo_remove.rs @@ -4,7 +4,7 @@ use crate::activities::{ }; use activitystreams::activity::kind::UndoType; use lemmy_api_common::blocking; -use lemmy_apub::{check_is_apub_id_valid, fetcher::objects::get_or_fetch_and_insert_comment}; +use crate::{check_is_apub_id_valid, fetcher::objects::get_or_fetch_and_insert_comment}; use lemmy_apub_lib::{verify_domains_match, ActivityCommonFields, ActivityHandlerNew, PublicUrl}; use lemmy_db_queries::source::comment::Comment_; use lemmy_db_schema::source::comment::Comment; diff --git a/crates/apub_receive/src/activities/comment/update.rs b/crates/apub/src/activities/comment/update.rs similarity index 90% rename from crates/apub_receive/src/activities/comment/update.rs rename to crates/apub/src/activities/comment/update.rs index c07837e39..142656f50 100644 --- a/crates/apub_receive/src/activities/comment/update.rs +++ b/crates/apub/src/activities/comment/update.rs @@ -1,10 +1,13 @@ -use crate::activities::{ - comment::{get_notif_recipients, send_websocket_message}, - verify_activity, - verify_person_in_community, +use crate::{ + activities::{ + comment::{get_notif_recipients, send_websocket_message}, + verify_activity, + verify_person_in_community, + }, + objects::FromApub, + NoteExt, }; use activitystreams::{activity::kind::UpdateType, base::BaseExt}; -use lemmy_apub::{objects::FromApub, NoteExt}; use lemmy_apub_lib::{verify_domains_match_opt, ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_schema::source::comment::Comment; use lemmy_utils::LemmyError; diff --git a/crates/apub_receive/src/activities/community/add_mod.rs b/crates/apub/src/activities/community/add_mod.rs similarity index 94% rename from crates/apub_receive/src/activities/community/add_mod.rs rename to crates/apub/src/activities/community/add_mod.rs index 2cf64f717..2785856c1 100644 --- a/crates/apub_receive/src/activities/community/add_mod.rs +++ b/crates/apub/src/activities/community/add_mod.rs @@ -1,15 +1,15 @@ -use crate::activities::{ - verify_activity, - verify_add_remove_moderator_target, - verify_mod_action, - verify_person_in_community, -}; -use activitystreams::{activity::kind::AddType, base::AnyBase}; -use lemmy_api_common::blocking; -use lemmy_apub::{ +use crate::{ + activities::{ + verify_activity, + verify_add_remove_moderator_target, + verify_mod_action, + verify_person_in_community, + }, fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, CommunityType, }; +use activitystreams::{activity::kind::AddType, base::AnyBase}; +use lemmy_api_common::blocking; use lemmy_apub_lib::{ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::{source::community::CommunityModerator_, Joinable}; use lemmy_db_schema::source::community::{CommunityModerator, CommunityModeratorForm}; diff --git a/crates/apub_receive/src/activities/community/announce.rs b/crates/apub/src/activities/community/announce.rs similarity index 98% rename from crates/apub_receive/src/activities/community/announce.rs rename to crates/apub/src/activities/community/announce.rs index 09f51a7ea..301ccc648 100644 --- a/crates/apub_receive/src/activities/community/announce.rs +++ b/crates/apub/src/activities/community/announce.rs @@ -25,9 +25,9 @@ use crate::{ }, }, http::is_activity_already_known, + insert_activity, }; use activitystreams::activity::kind::AnnounceType; -use lemmy_apub::insert_activity; use lemmy_apub_lib::{ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_utils::LemmyError; use lemmy_websocket::LemmyContext; diff --git a/crates/apub_receive/src/activities/community/block_user.rs b/crates/apub/src/activities/community/block_user.rs similarity index 91% rename from crates/apub_receive/src/activities/community/block_user.rs rename to crates/apub/src/activities/community/block_user.rs index 03a19e9c7..c20652b02 100644 --- a/crates/apub_receive/src/activities/community/block_user.rs +++ b/crates/apub/src/activities/community/block_user.rs @@ -1,10 +1,9 @@ -use crate::activities::{verify_activity, verify_mod_action, verify_person_in_community}; +use crate::{ + activities::{verify_activity, verify_mod_action, verify_person_in_community}, + fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, +}; use activitystreams::activity::kind::BlockType; use lemmy_api_common::blocking; -use lemmy_apub::fetcher::{ - community::get_or_fetch_and_upsert_community, - person::get_or_fetch_and_upsert_person, -}; use lemmy_apub_lib::{ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::{Bannable, Followable}; use lemmy_db_schema::source::community::{ diff --git a/crates/apub_receive/src/activities/community/mod.rs b/crates/apub/src/activities/community/mod.rs similarity index 100% rename from crates/apub_receive/src/activities/community/mod.rs rename to crates/apub/src/activities/community/mod.rs diff --git a/crates/apub_receive/src/activities/community/undo_block_user.rs b/crates/apub/src/activities/community/undo_block_user.rs similarity index 87% rename from crates/apub_receive/src/activities/community/undo_block_user.rs rename to crates/apub/src/activities/community/undo_block_user.rs index 88518385b..025c498a6 100644 --- a/crates/apub_receive/src/activities/community/undo_block_user.rs +++ b/crates/apub/src/activities/community/undo_block_user.rs @@ -1,15 +1,14 @@ -use crate::activities::{ - community::block_user::BlockUserFromCommunity, - verify_activity, - verify_mod_action, - verify_person_in_community, +use crate::{ + activities::{ + community::block_user::BlockUserFromCommunity, + verify_activity, + verify_mod_action, + verify_person_in_community, + }, + fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, }; use activitystreams::activity::kind::UndoType; use lemmy_api_common::blocking; -use lemmy_apub::fetcher::{ - community::get_or_fetch_and_upsert_community, - person::get_or_fetch_and_upsert_person, -}; use lemmy_apub_lib::{ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::Bannable; use lemmy_db_schema::source::community::{CommunityPersonBan, CommunityPersonBanForm}; diff --git a/crates/apub_receive/src/activities/community/update.rs b/crates/apub/src/activities/community/update.rs similarity index 92% rename from crates/apub_receive/src/activities/community/update.rs rename to crates/apub/src/activities/community/update.rs index a333c1bbf..cfee29da7 100644 --- a/crates/apub_receive/src/activities/community/update.rs +++ b/crates/apub/src/activities/community/update.rs @@ -1,12 +1,15 @@ -use crate::activities::{ - community::send_websocket_message, - verify_activity, - verify_mod_action, - verify_person_in_community, +use crate::{ + activities::{ + community::send_websocket_message, + verify_activity, + verify_mod_action, + verify_person_in_community, + }, + objects::FromApubToForm, + GroupExt, }; use activitystreams::activity::kind::UpdateType; use lemmy_api_common::blocking; -use lemmy_apub::{objects::FromApubToForm, GroupExt}; use lemmy_apub_lib::{ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::{ApubObject, Crud}; use lemmy_db_schema::source::community::{Community, CommunityForm}; diff --git a/crates/apub_receive/src/activities/deletion/delete.rs b/crates/apub/src/activities/deletion/delete.rs similarity index 94% rename from crates/apub_receive/src/activities/deletion/delete.rs rename to crates/apub/src/activities/deletion/delete.rs index 0276516dd..f0f4185a7 100644 --- a/crates/apub_receive/src/activities/deletion/delete.rs +++ b/crates/apub/src/activities/deletion/delete.rs @@ -1,14 +1,12 @@ -use crate::activities::{ - comment::send_websocket_message as send_comment_message, - community::send_websocket_message as send_community_message, - post::send_websocket_message as send_post_message, - verify_activity, - verify_mod_action, - verify_person_in_community, -}; -use activitystreams::activity::kind::DeleteType; -use lemmy_api_common::blocking; -use lemmy_apub::{ +use crate::{ + activities::{ + comment::send_websocket_message as send_comment_message, + community::send_websocket_message as send_community_message, + post::send_websocket_message as send_post_message, + verify_activity, + verify_mod_action, + verify_person_in_community, + }, fetcher::{ community::get_or_fetch_and_upsert_community, objects::get_or_fetch_and_insert_post_or_comment, @@ -18,6 +16,8 @@ use lemmy_apub::{ CommunityType, PostOrComment, }; +use activitystreams::activity::kind::DeleteType; +use lemmy_api_common::blocking; use lemmy_apub_lib::{verify_urls_match, ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::{ source::{comment::Comment_, community::Community_, post::Post_}, diff --git a/crates/apub_receive/src/activities/deletion/mod.rs b/crates/apub/src/activities/deletion/mod.rs similarity index 100% rename from crates/apub_receive/src/activities/deletion/mod.rs rename to crates/apub/src/activities/deletion/mod.rs diff --git a/crates/apub_receive/src/activities/deletion/undo_delete.rs b/crates/apub/src/activities/deletion/undo_delete.rs similarity index 91% rename from crates/apub_receive/src/activities/deletion/undo_delete.rs rename to crates/apub/src/activities/deletion/undo_delete.rs index 9875a2a9a..1de5ca587 100644 --- a/crates/apub_receive/src/activities/deletion/undo_delete.rs +++ b/crates/apub/src/activities/deletion/undo_delete.rs @@ -1,15 +1,13 @@ -use crate::activities::{ - comment::send_websocket_message as send_comment_message, - community::send_websocket_message as send_community_message, - deletion::delete::DeletePostCommentOrCommunity, - post::send_websocket_message as send_post_message, - verify_activity, - verify_mod_action, - verify_person_in_community, -}; -use activitystreams::activity::kind::UndoType; -use lemmy_api_common::blocking; -use lemmy_apub::{ +use crate::{ + activities::{ + comment::send_websocket_message as send_comment_message, + community::send_websocket_message as send_community_message, + deletion::delete::DeletePostCommentOrCommunity, + post::send_websocket_message as send_post_message, + verify_activity, + verify_mod_action, + verify_person_in_community, + }, fetcher::{ community::get_or_fetch_and_upsert_community, objects::get_or_fetch_and_insert_post_or_comment, @@ -18,6 +16,8 @@ use lemmy_apub::{ CommunityType, PostOrComment, }; +use activitystreams::activity::kind::UndoType; +use lemmy_api_common::blocking; use lemmy_apub_lib::{verify_urls_match, ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::source::{comment::Comment_, community::Community_, post::Post_}; use lemmy_db_schema::source::{comment::Comment, community::Community, post::Post}; diff --git a/crates/apub_receive/src/activities/following/accept.rs b/crates/apub/src/activities/following/accept.rs similarity index 89% rename from crates/apub_receive/src/activities/following/accept.rs rename to crates/apub/src/activities/following/accept.rs index d5cf474d4..6bd5d272f 100644 --- a/crates/apub_receive/src/activities/following/accept.rs +++ b/crates/apub/src/activities/following/accept.rs @@ -1,10 +1,9 @@ -use crate::activities::{following::follow::FollowCommunity, verify_activity, verify_community}; +use crate::{ + activities::{following::follow::FollowCommunity, verify_activity, verify_community}, + fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, +}; use activitystreams::activity::kind::AcceptType; use lemmy_api_common::blocking; -use lemmy_apub::fetcher::{ - community::get_or_fetch_and_upsert_community, - person::get_or_fetch_and_upsert_person, -}; use lemmy_apub_lib::{verify_urls_match, ActivityCommonFields, ActivityHandler}; use lemmy_db_queries::Followable; use lemmy_db_schema::source::community::CommunityFollower; diff --git a/crates/apub_receive/src/activities/following/follow.rs b/crates/apub/src/activities/following/follow.rs similarity index 96% rename from crates/apub_receive/src/activities/following/follow.rs rename to crates/apub/src/activities/following/follow.rs index fd0649f19..49c9970c0 100644 --- a/crates/apub_receive/src/activities/following/follow.rs +++ b/crates/apub/src/activities/following/follow.rs @@ -1,14 +1,14 @@ -use crate::activities::{verify_activity, verify_person}; +use crate::{ + activities::{verify_activity, verify_person}, + fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, + CommunityType, +}; use activitystreams::{ activity::{kind::FollowType, Follow}, base::{AnyBase, ExtendsExt}, }; use anyhow::Context; use lemmy_api_common::blocking; -use lemmy_apub::{ - fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, - CommunityType, -}; use lemmy_apub_lib::{verify_urls_match, ActivityCommonFields, ActivityHandler}; use lemmy_db_queries::Followable; use lemmy_db_schema::source::community::{CommunityFollower, CommunityFollowerForm}; diff --git a/crates/apub_receive/src/activities/following/mod.rs b/crates/apub/src/activities/following/mod.rs similarity index 100% rename from crates/apub_receive/src/activities/following/mod.rs rename to crates/apub/src/activities/following/mod.rs diff --git a/crates/apub_receive/src/activities/following/undo.rs b/crates/apub/src/activities/following/undo.rs similarity index 90% rename from crates/apub_receive/src/activities/following/undo.rs rename to crates/apub/src/activities/following/undo.rs index 1f3d12e61..1936997f4 100644 --- a/crates/apub_receive/src/activities/following/undo.rs +++ b/crates/apub/src/activities/following/undo.rs @@ -1,10 +1,9 @@ -use crate::activities::{following::follow::FollowCommunity, verify_activity, verify_person}; +use crate::{ + activities::{following::follow::FollowCommunity, verify_activity, verify_person}, + fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, +}; use activitystreams::activity::kind::UndoType; use lemmy_api_common::blocking; -use lemmy_apub::fetcher::{ - community::get_or_fetch_and_upsert_community, - person::get_or_fetch_and_upsert_person, -}; use lemmy_apub_lib::{verify_urls_match, ActivityCommonFields, ActivityHandler}; use lemmy_db_queries::Followable; use lemmy_db_schema::source::community::{CommunityFollower, CommunityFollowerForm}; diff --git a/crates/apub/src/activities/mod.rs b/crates/apub/src/activities/mod.rs index 5c9ff6943..d9f3dcdde 100644 --- a/crates/apub/src/activities/mod.rs +++ b/crates/apub/src/activities/mod.rs @@ -1 +1,122 @@ +use crate::{ + check_community_or_site_ban, + check_is_apub_id_valid, + fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, + generate_moderators_url, +}; +use anyhow::anyhow; +use lemmy_api_common::blocking; +use lemmy_apub_lib::{verify_domains_match, ActivityCommonFields}; +use lemmy_db_queries::ApubObject; +use lemmy_db_schema::{ + source::{community::Community, person::Person}, + DbUrl, +}; +use lemmy_db_views_actor::community_view::CommunityView; +use lemmy_utils::LemmyError; +use lemmy_websocket::LemmyContext; +use url::Url; + +pub mod comment; +pub mod community; +pub mod deletion; +pub mod following; +pub mod post; +pub mod private_message; +pub mod removal; pub mod send; +pub mod voting; + +/// Checks that the specified Url actually identifies a Person (by fetching it), and that the person +/// doesn't have a site ban. +async fn verify_person( + person_id: &Url, + context: &LemmyContext, + request_counter: &mut i32, +) -> Result<(), LemmyError> { + let person = get_or_fetch_and_upsert_person(person_id, context, request_counter).await?; + if person.banned { + return Err(anyhow!("Person {} is banned", person_id).into()); + } + Ok(()) +} + +/// Fetches the person and community to verify their type, then checks if person is banned from site +/// or community. +async fn verify_person_in_community( + person_id: &Url, + cc: &[Url], + context: &LemmyContext, + request_counter: &mut i32, +) -> Result { + let person = get_or_fetch_and_upsert_person(person_id, context, request_counter).await?; + let mut cc_iter = cc.iter(); + let community: Community = loop { + if let Some(cid) = cc_iter.next() { + if let Ok(c) = get_or_fetch_and_upsert_community(cid, context, request_counter).await { + break c; + } + } else { + return Err(anyhow!("No community found in cc").into()); + } + }; + check_community_or_site_ban(&person, community.id, context.pool()).await?; + Ok(community) +} + +/// Simply check that the url actually refers to a valid group. +async fn verify_community( + community_id: &Url, + context: &LemmyContext, + request_counter: &mut i32, +) -> Result<(), LemmyError> { + get_or_fetch_and_upsert_community(community_id, context, request_counter).await?; + Ok(()) +} + +fn verify_activity(common: &ActivityCommonFields) -> Result<(), LemmyError> { + check_is_apub_id_valid(&common.actor, false)?; + verify_domains_match(common.id_unchecked(), &common.actor)?; + Ok(()) +} + +async fn verify_mod_action( + actor_id: &Url, + activity_cc: Url, + context: &LemmyContext, +) -> Result<(), LemmyError> { + let community = blocking(context.pool(), move |conn| { + Community::read_from_apub_id(conn, &activity_cc.into()) + }) + .await??; + + if community.local { + let actor_id: DbUrl = actor_id.clone().into(); + let actor = blocking(context.pool(), move |conn| { + Person::read_from_apub_id(conn, &actor_id) + }) + .await??; + + // Note: this will also return true for admins in addition to mods, but as we dont know about + // remote admins, it doesnt make any difference. + let community_id = community.id; + let actor_id = actor.id; + let is_mod_or_admin = blocking(context.pool(), move |conn| { + CommunityView::is_mod_or_admin(conn, actor_id, community_id) + }) + .await?; + if !is_mod_or_admin { + return Err(anyhow!("Not a mod").into()); + } + } + Ok(()) +} + +/// For Add/Remove community moderator activities, check that the target field actually contains +/// /c/community/moderators. Any different values are unsupported. +fn verify_add_remove_moderator_target(target: &Url, community: Url) -> Result<(), LemmyError> { + if target != &generate_moderators_url(&community.into())?.into_inner() { + return Err(anyhow!("Unkown target url").into()); + } + Ok(()) +} diff --git a/crates/apub_receive/src/activities/post/create.rs b/crates/apub/src/activities/post/create.rs similarity index 92% rename from crates/apub_receive/src/activities/post/create.rs rename to crates/apub/src/activities/post/create.rs index 2d31fa0d1..a2ccf4ce5 100644 --- a/crates/apub_receive/src/activities/post/create.rs +++ b/crates/apub/src/activities/post/create.rs @@ -1,15 +1,11 @@ -use crate::activities::{ - post::send_websocket_message, - verify_activity, - verify_person_in_community, -}; -use activitystreams::{activity::kind::CreateType, base::BaseExt}; -use lemmy_apub::{ +use crate::{ + activities::{post::send_websocket_message, verify_activity, verify_person_in_community}, fetcher::person::get_or_fetch_and_upsert_person, objects::FromApub, ActorType, PageExt, }; +use activitystreams::{activity::kind::CreateType, base::BaseExt}; use lemmy_apub_lib::{verify_domains_match_opt, ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_schema::source::post::Post; use lemmy_utils::LemmyError; diff --git a/crates/apub_receive/src/activities/post/mod.rs b/crates/apub/src/activities/post/mod.rs similarity index 100% rename from crates/apub_receive/src/activities/post/mod.rs rename to crates/apub/src/activities/post/mod.rs diff --git a/crates/apub_receive/src/activities/post/update.rs b/crates/apub/src/activities/post/update.rs similarity index 94% rename from crates/apub_receive/src/activities/post/update.rs rename to crates/apub/src/activities/post/update.rs index 1f5924929..13456dcd8 100644 --- a/crates/apub_receive/src/activities/post/update.rs +++ b/crates/apub/src/activities/post/update.rs @@ -1,17 +1,17 @@ -use crate::activities::{ - post::send_websocket_message, - verify_activity, - verify_mod_action, - verify_person_in_community, -}; -use activitystreams::{activity::kind::UpdateType, base::BaseExt}; -use anyhow::Context; -use lemmy_api_common::blocking; -use lemmy_apub::{ +use crate::{ + activities::{ + post::send_websocket_message, + verify_activity, + verify_mod_action, + verify_person_in_community, + }, objects::{FromApub, FromApubToForm}, ActorType, PageExt, }; +use activitystreams::{activity::kind::UpdateType, base::BaseExt}; +use anyhow::Context; +use lemmy_api_common::blocking; use lemmy_apub_lib::{verify_domains_match_opt, ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::ApubObject; use lemmy_db_schema::{ diff --git a/crates/apub_receive/src/activities/private_message/create.rs b/crates/apub/src/activities/private_message/create.rs similarity index 91% rename from crates/apub_receive/src/activities/private_message/create.rs rename to crates/apub/src/activities/private_message/create.rs index 2d766565e..5e6db4ea8 100644 --- a/crates/apub_receive/src/activities/private_message/create.rs +++ b/crates/apub/src/activities/private_message/create.rs @@ -1,6 +1,9 @@ -use crate::activities::{private_message::send_websocket_message, verify_activity, verify_person}; +use crate::{ + activities::{private_message::send_websocket_message, verify_activity, verify_person}, + objects::FromApub, + NoteExt, +}; use activitystreams::{activity::kind::CreateType, base::BaseExt}; -use lemmy_apub::{objects::FromApub, NoteExt}; use lemmy_apub_lib::{verify_domains_match_opt, ActivityCommonFields, ActivityHandler}; use lemmy_db_schema::source::private_message::PrivateMessage; use lemmy_utils::LemmyError; diff --git a/crates/apub_receive/src/activities/private_message/delete.rs b/crates/apub/src/activities/private_message/delete.rs similarity index 100% rename from crates/apub_receive/src/activities/private_message/delete.rs rename to crates/apub/src/activities/private_message/delete.rs diff --git a/crates/apub_receive/src/activities/private_message/mod.rs b/crates/apub/src/activities/private_message/mod.rs similarity index 100% rename from crates/apub_receive/src/activities/private_message/mod.rs rename to crates/apub/src/activities/private_message/mod.rs diff --git a/crates/apub_receive/src/activities/private_message/undo_delete.rs b/crates/apub/src/activities/private_message/undo_delete.rs similarity index 100% rename from crates/apub_receive/src/activities/private_message/undo_delete.rs rename to crates/apub/src/activities/private_message/undo_delete.rs diff --git a/crates/apub_receive/src/activities/private_message/update.rs b/crates/apub/src/activities/private_message/update.rs similarity index 91% rename from crates/apub_receive/src/activities/private_message/update.rs rename to crates/apub/src/activities/private_message/update.rs index 56a79f8e8..72ac0749a 100644 --- a/crates/apub_receive/src/activities/private_message/update.rs +++ b/crates/apub/src/activities/private_message/update.rs @@ -1,6 +1,9 @@ -use crate::activities::{private_message::send_websocket_message, verify_activity, verify_person}; +use crate::{ + activities::{private_message::send_websocket_message, verify_activity, verify_person}, + objects::FromApub, + NoteExt, +}; use activitystreams::{activity::kind::UpdateType, base::BaseExt}; -use lemmy_apub::{objects::FromApub, NoteExt}; use lemmy_apub_lib::{verify_domains_match_opt, ActivityCommonFields, ActivityHandler}; use lemmy_db_schema::source::private_message::PrivateMessage; use lemmy_utils::LemmyError; diff --git a/crates/apub_receive/src/activities/removal/mod.rs b/crates/apub/src/activities/removal/mod.rs similarity index 100% rename from crates/apub_receive/src/activities/removal/mod.rs rename to crates/apub/src/activities/removal/mod.rs diff --git a/crates/apub_receive/src/activities/removal/remove.rs b/crates/apub/src/activities/removal/remove.rs similarity index 93% rename from crates/apub_receive/src/activities/removal/remove.rs rename to crates/apub/src/activities/removal/remove.rs index bb1c307b1..a30f23327 100644 --- a/crates/apub_receive/src/activities/removal/remove.rs +++ b/crates/apub/src/activities/removal/remove.rs @@ -1,16 +1,13 @@ -use crate::activities::{ - comment::send_websocket_message as send_comment_message, - community::send_websocket_message as send_community_message, - post::send_websocket_message as send_post_message, - verify_activity, - verify_add_remove_moderator_target, - verify_mod_action, - verify_person_in_community, -}; -use activitystreams::{activity::kind::RemoveType, base::AnyBase}; -use anyhow::anyhow; -use lemmy_api_common::blocking; -use lemmy_apub::{ +use crate::{ + activities::{ + comment::send_websocket_message as send_comment_message, + community::send_websocket_message as send_community_message, + post::send_websocket_message as send_post_message, + verify_activity, + verify_add_remove_moderator_target, + verify_mod_action, + verify_person_in_community, + }, fetcher::{ community::get_or_fetch_and_upsert_community, objects::get_or_fetch_and_insert_post_or_comment, @@ -19,6 +16,9 @@ use lemmy_apub::{ CommunityType, PostOrComment, }; +use activitystreams::{activity::kind::RemoveType, base::AnyBase}; +use anyhow::anyhow; +use lemmy_api_common::blocking; use lemmy_apub_lib::{ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::{ source::{comment::Comment_, community::Community_, post::Post_}, diff --git a/crates/apub_receive/src/activities/removal/undo_remove.rs b/crates/apub/src/activities/removal/undo_remove.rs similarity index 91% rename from crates/apub_receive/src/activities/removal/undo_remove.rs rename to crates/apub/src/activities/removal/undo_remove.rs index e19c4194c..997d527d8 100644 --- a/crates/apub_receive/src/activities/removal/undo_remove.rs +++ b/crates/apub/src/activities/removal/undo_remove.rs @@ -1,22 +1,22 @@ -use crate::activities::{ - comment::send_websocket_message as send_comment_message, - community::send_websocket_message as send_community_message, - post::send_websocket_message as send_post_message, - removal::remove::RemovePostCommentCommunityOrMod, - verify_activity, - verify_mod_action, - verify_person_in_community, -}; -use activitystreams::activity::kind::UndoType; -use anyhow::anyhow; -use lemmy_api_common::blocking; -use lemmy_apub::{ +use crate::{ + activities::{ + comment::send_websocket_message as send_comment_message, + community::send_websocket_message as send_community_message, + post::send_websocket_message as send_post_message, + removal::remove::RemovePostCommentCommunityOrMod, + verify_activity, + verify_mod_action, + verify_person_in_community, + }, fetcher::{ community::get_or_fetch_and_upsert_community, objects::get_or_fetch_and_insert_post_or_comment, }, PostOrComment, }; +use activitystreams::activity::kind::UndoType; +use anyhow::anyhow; +use lemmy_api_common::blocking; use lemmy_apub_lib::{ActivityCommonFields, ActivityHandler, PublicUrl}; use lemmy_db_queries::source::{comment::Comment_, community::Community_, post::Post_}; use lemmy_db_schema::source::{comment::Comment, community::Community, post::Post}; diff --git a/crates/apub_receive/src/activities/voting/dislike.rs b/crates/apub/src/activities/voting/dislike.rs similarity index 100% rename from crates/apub_receive/src/activities/voting/dislike.rs rename to crates/apub/src/activities/voting/dislike.rs diff --git a/crates/apub_receive/src/activities/voting/like.rs b/crates/apub/src/activities/voting/like.rs similarity index 100% rename from crates/apub_receive/src/activities/voting/like.rs rename to crates/apub/src/activities/voting/like.rs diff --git a/crates/apub_receive/src/activities/voting/mod.rs b/crates/apub/src/activities/voting/mod.rs similarity index 96% rename from crates/apub_receive/src/activities/voting/mod.rs rename to crates/apub/src/activities/voting/mod.rs index 123523e22..739c43051 100644 --- a/crates/apub_receive/src/activities/voting/mod.rs +++ b/crates/apub/src/activities/voting/mod.rs @@ -1,15 +1,15 @@ -use crate::activities::{ - comment::send_websocket_message as send_comment_message, - post::send_websocket_message as send_post_message, -}; -use lemmy_api_common::blocking; -use lemmy_apub::{ +use crate::{ + activities::{ + comment::send_websocket_message as send_comment_message, + post::send_websocket_message as send_post_message, + }, fetcher::{ objects::get_or_fetch_and_insert_post_or_comment, person::get_or_fetch_and_upsert_person, }, PostOrComment, }; +use lemmy_api_common::blocking; use lemmy_db_queries::Likeable; use lemmy_db_schema::source::{ comment::{Comment, CommentLike, CommentLikeForm}, diff --git a/crates/apub_receive/src/activities/voting/undo_dislike.rs b/crates/apub/src/activities/voting/undo_dislike.rs similarity index 100% rename from crates/apub_receive/src/activities/voting/undo_dislike.rs rename to crates/apub/src/activities/voting/undo_dislike.rs diff --git a/crates/apub_receive/src/activities/voting/undo_like.rs b/crates/apub/src/activities/voting/undo_like.rs similarity index 100% rename from crates/apub_receive/src/activities/voting/undo_like.rs rename to crates/apub/src/activities/voting/undo_like.rs diff --git a/crates/apub/src/fetcher/community.rs b/crates/apub/src/fetcher/community.rs index f0a759c54..670493a98 100644 --- a/crates/apub/src/fetcher/community.rs +++ b/crates/apub/src/fetcher/community.rs @@ -1,4 +1,5 @@ use crate::{ + activities::community::announce::AnnounceActivity, fetcher::{ fetch::fetch_remote_object, is_deleted, @@ -15,6 +16,7 @@ use activitystreams::{ use anyhow::Context; use diesel::result::Error::NotFound; use lemmy_api_common::blocking; +use lemmy_apub_lib::ActivityHandler; use lemmy_db_queries::{source::community::Community_, ApubObject, Joinable}; use lemmy_db_schema::source::community::{Community, CommunityModerator, CommunityModeratorForm}; use lemmy_db_views_actor::community_moderator_view::CommunityModeratorView; @@ -84,7 +86,7 @@ async fn fetch_remote_community( // only fetch outbox for new communities, otherwise this can create an infinite loop if old_community.is_none() { let outbox = group.inner.outbox()?.context(location_info!())?; - fetch_community_outbox(context, outbox, &community, request_counter).await? + fetch_community_outbox(context, outbox, request_counter).await? } Ok(community) @@ -143,7 +145,6 @@ async fn update_community_mods( async fn fetch_community_outbox( context: &LemmyContext, outbox: &Url, - community: &Community, recursion_counter: &mut i32, ) -> Result<(), LemmyError> { let outbox = @@ -154,9 +155,12 @@ async fn fetch_community_outbox( outbox_activities = outbox_activities[0..20].to_vec(); } - for activity in outbox_activities { - todo!("{:?} {:?} {:?}", activity, community, recursion_counter); - //receive_announce(context, activity, community, recursion_counter).await?; + for announce in outbox_activities { + // TODO: instead of converting like this, we should create a struct CommunityOutbox with + // AnnounceActivity as inner type, but that gives me stackoverflow + let ser = serde_json::to_string(&announce)?; + let announce: AnnounceActivity = serde_json::from_str(&ser)?; + announce.receive(context, recursion_counter).await?; } Ok(()) diff --git a/crates/apub_receive/src/http/comment.rs b/crates/apub/src/http/comment.rs similarity index 90% rename from crates/apub_receive/src/http/comment.rs rename to crates/apub/src/http/comment.rs index 001879e00..4f63d89d3 100644 --- a/crates/apub_receive/src/http/comment.rs +++ b/crates/apub/src/http/comment.rs @@ -1,8 +1,10 @@ -use crate::http::{create_apub_response, create_apub_tombstone_response}; +use crate::{ + http::{create_apub_response, create_apub_tombstone_response}, + objects::ToApub, +}; use actix_web::{body::Body, web, web::Path, HttpResponse}; use diesel::result::Error::NotFound; use lemmy_api_common::blocking; -use lemmy_apub::objects::ToApub; use lemmy_db_queries::Crud; use lemmy_db_schema::{source::comment::Comment, CommentId}; use lemmy_utils::LemmyError; diff --git a/crates/apub_receive/src/http/community.rs b/crates/apub/src/http/community.rs similarity index 96% rename from crates/apub_receive/src/http/community.rs rename to crates/apub/src/http/community.rs index 106eeff2f..3173bca12 100644 --- a/crates/apub_receive/src/http/community.rs +++ b/crates/apub/src/http/community.rs @@ -1,9 +1,15 @@ -use crate::http::{ - create_apub_response, - create_apub_tombstone_response, - inbox_enums::GroupInboxActivities, - payload_to_string, - receive_activity, +use crate::{ + extensions::context::lemmy_context, + generate_moderators_url, + http::{ + create_apub_response, + create_apub_tombstone_response, + inbox_enums::GroupInboxActivities, + payload_to_string, + receive_activity, + }, + objects::ToApub, + ActorType, }; use activitystreams::{ base::{AnyBase, BaseExt}, @@ -12,12 +18,6 @@ use activitystreams::{ }; use actix_web::{body::Body, web, web::Payload, HttpRequest, HttpResponse}; use lemmy_api_common::blocking; -use lemmy_apub::{ - extensions::context::lemmy_context, - generate_moderators_url, - objects::ToApub, - ActorType, -}; use lemmy_db_queries::source::{activity::Activity_, community::Community_}; use lemmy_db_schema::source::{activity::Activity, community::Community}; use lemmy_db_views_actor::{ diff --git a/crates/apub_receive/src/http/inbox_enums.rs b/crates/apub/src/http/inbox_enums.rs similarity index 100% rename from crates/apub_receive/src/http/inbox_enums.rs rename to crates/apub/src/http/inbox_enums.rs diff --git a/crates/apub_receive/src/http/mod.rs b/crates/apub/src/http/mod.rs similarity index 98% rename from crates/apub_receive/src/http/mod.rs rename to crates/apub/src/http/mod.rs index 44302d8d9..f366cb48c 100644 --- a/crates/apub_receive/src/http/mod.rs +++ b/crates/apub/src/http/mod.rs @@ -1,4 +1,11 @@ -use crate::http::inbox_enums::SharedInboxActivities; +use crate::{ + check_is_apub_id_valid, + extensions::signatures::verify_signature, + fetcher::get_or_fetch_and_upsert_actor, + http::inbox_enums::SharedInboxActivities, + insert_activity, + APUB_JSON_CONTENT_TYPE, +}; use actix_web::{ body::Body, web, @@ -10,13 +17,6 @@ use anyhow::{anyhow, Context}; use futures::StreamExt; use http::StatusCode; use lemmy_api_common::blocking; -use lemmy_apub::{ - check_is_apub_id_valid, - extensions::signatures::verify_signature, - fetcher::get_or_fetch_and_upsert_actor, - insert_activity, - APUB_JSON_CONTENT_TYPE, -}; use lemmy_apub_lib::ActivityHandler; use lemmy_db_queries::{source::activity::Activity_, DbPool}; use lemmy_db_schema::source::activity::Activity; diff --git a/crates/apub_receive/src/http/person.rs b/crates/apub/src/http/person.rs similarity index 91% rename from crates/apub_receive/src/http/person.rs rename to crates/apub/src/http/person.rs index 59cc86970..2c96aafd8 100644 --- a/crates/apub_receive/src/http/person.rs +++ b/crates/apub/src/http/person.rs @@ -1,9 +1,14 @@ -use crate::http::{ - create_apub_response, - create_apub_tombstone_response, - inbox_enums::PersonInboxActivities, - payload_to_string, - receive_activity, +use crate::{ + extensions::context::lemmy_context, + http::{ + create_apub_response, + create_apub_tombstone_response, + inbox_enums::PersonInboxActivities, + payload_to_string, + receive_activity, + }, + objects::ToApub, + ActorType, }; use activitystreams::{ base::BaseExt, @@ -11,7 +16,6 @@ use activitystreams::{ }; use actix_web::{body::Body, web, web::Payload, HttpRequest, HttpResponse}; use lemmy_api_common::blocking; -use lemmy_apub::{extensions::context::lemmy_context, objects::ToApub, ActorType}; use lemmy_db_queries::source::person::Person_; use lemmy_db_schema::source::person::Person; use lemmy_utils::LemmyError; diff --git a/crates/apub_receive/src/http/post.rs b/crates/apub/src/http/post.rs similarity index 89% rename from crates/apub_receive/src/http/post.rs rename to crates/apub/src/http/post.rs index 45a0191eb..324bb7da9 100644 --- a/crates/apub_receive/src/http/post.rs +++ b/crates/apub/src/http/post.rs @@ -1,8 +1,10 @@ -use crate::http::{create_apub_response, create_apub_tombstone_response}; +use crate::{ + http::{create_apub_response, create_apub_tombstone_response}, + objects::ToApub, +}; use actix_web::{body::Body, web, HttpResponse}; use diesel::result::Error::NotFound; use lemmy_api_common::blocking; -use lemmy_apub::objects::ToApub; use lemmy_db_queries::Crud; use lemmy_db_schema::{source::post::Post, PostId}; use lemmy_utils::LemmyError; diff --git a/crates/apub_receive/src/http/routes.rs b/crates/apub/src/http/routes.rs similarity index 84% rename from crates/apub_receive/src/http/routes.rs rename to crates/apub/src/http/routes.rs index 929df38bb..1afc3f1e5 100644 --- a/crates/apub_receive/src/http/routes.rs +++ b/crates/apub/src/http/routes.rs @@ -1,21 +1,23 @@ -use crate::http::{ - comment::get_apub_comment, - community::{ - community_inbox, - get_apub_community_followers, - get_apub_community_http, - get_apub_community_inbox, - get_apub_community_moderators, - get_apub_community_outbox, +use crate::{ + http::{ + comment::get_apub_comment, + community::{ + community_inbox, + get_apub_community_followers, + get_apub_community_http, + get_apub_community_inbox, + get_apub_community_moderators, + get_apub_community_outbox, + }, + get_activity, + person::{get_apub_person_http, get_apub_person_inbox, get_apub_person_outbox, person_inbox}, + post::get_apub_post, + shared_inbox, }, - get_activity, - person::{get_apub_person_http, get_apub_person_inbox, get_apub_person_outbox, person_inbox}, - post::get_apub_post, - shared_inbox, + APUB_JSON_CONTENT_TYPE, }; use actix_web::*; use http_signature_normalization_actix::digest::middleware::VerifyDigest; -use lemmy_apub::APUB_JSON_CONTENT_TYPE; use lemmy_utils::settings::structs::Settings; use sha2::{Digest, Sha256}; diff --git a/crates/apub/src/lib.rs b/crates/apub/src/lib.rs index 6bb976754..bbc6d515a 100644 --- a/crates/apub/src/lib.rs +++ b/crates/apub/src/lib.rs @@ -5,6 +5,7 @@ pub mod activities; pub mod activity_queue; pub mod extensions; pub mod fetcher; +pub mod http; pub mod objects; use crate::{ diff --git a/crates/apub_receive/Cargo.toml b/crates/apub_receive/Cargo.toml deleted file mode 100644 index ca21787c1..000000000 --- a/crates/apub_receive/Cargo.toml +++ /dev/null @@ -1,46 +0,0 @@ -[package] -name = "lemmy_apub_receive" -version = "0.1.0" -edition = "2018" - -[dependencies] -lemmy_utils = { path = "../utils" } -lemmy_apub_lib = { path = "../apub_lib" } -lemmy_apub = { path = "../apub" } -lemmy_db_queries = { path = "../db_queries" } -lemmy_db_schema = { path = "../db_schema" } -lemmy_db_views = { path = "../db_views" } -lemmy_db_views_actor = { path = "../db_views_actor" } -lemmy_api_common = { path = "../api_common" } -lemmy_websocket = { path = "../websocket" } -diesel = "1.4.7" -activitystreams = "0.7.0-alpha.11" -activitystreams-ext = "0.1.0-alpha.2" -bcrypt = "0.10.0" -chrono = { version = "0.4.19", features = ["serde"] } -serde_json = { version = "1.0.64", features = ["preserve_order"] } -serde = { version = "1.0.126", features = ["derive"] } -actix = "0.12.0" -actix-web = { version = "4.0.0-beta.8", default-features = false } -actix-rt = { version = "2.2.0", default-features = false } -awc = { version = "3.0.0-beta.7", default-features = false } -log = "0.4.14" -rand = "0.8.4" -strum = "0.21.0" -strum_macros = "0.21.1" -url = { version = "2.2.2", features = ["serde"] } -percent-encoding = "2.1.0" -openssl = "0.10.35" -http = "0.2.4" -http-signature-normalization-actix = { version = "0.5.0-beta.6", default-features = false, features = ["sha-2"] } -http-signature-normalization-reqwest = { version = "0.2.0", default-features = false, features = ["sha-2"] } -base64 = "0.13.0" -tokio = "1.8.0" -futures = "0.3.15" -itertools = "0.10.1" -sha2 = "0.9.5" -async-trait = "0.1.50" -anyhow = "1.0.41" -thiserror = "1.0.26" -backtrace = "0.3.60" - diff --git a/crates/apub_receive/src/activities/mod.rs b/crates/apub_receive/src/activities/mod.rs deleted file mode 100644 index 098d209f7..000000000 --- a/crates/apub_receive/src/activities/mod.rs +++ /dev/null @@ -1,121 +0,0 @@ -use anyhow::anyhow; -use lemmy_api_common::blocking; -use lemmy_apub::{ - check_community_or_site_ban, - check_is_apub_id_valid, - fetcher::{community::get_or_fetch_and_upsert_community, person::get_or_fetch_and_upsert_person}, - generate_moderators_url, -}; -use lemmy_apub_lib::{verify_domains_match, ActivityCommonFields}; -use lemmy_db_queries::ApubObject; -use lemmy_db_schema::{ - source::{community::Community, person::Person}, - DbUrl, -}; -use lemmy_db_views_actor::community_view::CommunityView; -use lemmy_utils::LemmyError; -use lemmy_websocket::LemmyContext; -use url::Url; - -pub mod comment; -pub mod community; -pub mod deletion; -pub mod following; -pub mod post; -pub mod private_message; -pub mod removal; -pub mod voting; - -/// Checks that the specified Url actually identifies a Person (by fetching it), and that the person -/// doesn't have a site ban. -async fn verify_person( - person_id: &Url, - context: &LemmyContext, - request_counter: &mut i32, -) -> Result<(), LemmyError> { - let person = get_or_fetch_and_upsert_person(person_id, context, request_counter).await?; - if person.banned { - return Err(anyhow!("Person {} is banned", person_id).into()); - } - Ok(()) -} - -/// Fetches the person and community to verify their type, then checks if person is banned from site -/// or community. -async fn verify_person_in_community( - person_id: &Url, - cc: &[Url], - context: &LemmyContext, - request_counter: &mut i32, -) -> Result { - let person = get_or_fetch_and_upsert_person(person_id, context, request_counter).await?; - let mut cc_iter = cc.iter(); - let community: Community = loop { - if let Some(cid) = cc_iter.next() { - if let Ok(c) = get_or_fetch_and_upsert_community(cid, context, request_counter).await { - break c; - } - } else { - return Err(anyhow!("No community found in cc").into()); - } - }; - check_community_or_site_ban(&person, community.id, context.pool()).await?; - Ok(community) -} - -/// Simply check that the url actually refers to a valid group. -async fn verify_community( - community_id: &Url, - context: &LemmyContext, - request_counter: &mut i32, -) -> Result<(), LemmyError> { - get_or_fetch_and_upsert_community(community_id, context, request_counter).await?; - Ok(()) -} - -fn verify_activity(common: &ActivityCommonFields) -> Result<(), LemmyError> { - check_is_apub_id_valid(&common.actor, false)?; - verify_domains_match(common.id_unchecked(), &common.actor)?; - Ok(()) -} - -async fn verify_mod_action( - actor_id: &Url, - activity_cc: Url, - context: &LemmyContext, -) -> Result<(), LemmyError> { - let community = blocking(context.pool(), move |conn| { - Community::read_from_apub_id(conn, &activity_cc.into()) - }) - .await??; - - if community.local { - let actor_id: DbUrl = actor_id.clone().into(); - let actor = blocking(context.pool(), move |conn| { - Person::read_from_apub_id(conn, &actor_id) - }) - .await??; - - // Note: this will also return true for admins in addition to mods, but as we dont know about - // remote admins, it doesnt make any difference. - let community_id = community.id; - let actor_id = actor.id; - let is_mod_or_admin = blocking(context.pool(), move |conn| { - CommunityView::is_mod_or_admin(conn, actor_id, community_id) - }) - .await?; - if !is_mod_or_admin { - return Err(anyhow!("Not a mod").into()); - } - } - Ok(()) -} - -/// For Add/Remove community moderator activities, check that the target field actually contains -/// /c/community/moderators. Any different values are unsupported. -fn verify_add_remove_moderator_target(target: &Url, community: Url) -> Result<(), LemmyError> { - if target != &generate_moderators_url(&community.into())?.into_inner() { - return Err(anyhow!("Unkown target url").into()); - } - Ok(()) -} diff --git a/crates/apub_receive/src/lib.rs b/crates/apub_receive/src/lib.rs deleted file mode 100644 index dadc76b6a..000000000 --- a/crates/apub_receive/src/lib.rs +++ /dev/null @@ -1,2 +0,0 @@ -mod activities; -pub mod http; diff --git a/docker/dev/docker-compose.yml b/docker/dev/docker-compose.yml index 1e532d555..a9e580a4b 100644 --- a/docker/dev/docker-compose.yml +++ b/docker/dev/docker-compose.yml @@ -8,7 +8,7 @@ services: - "8536:8536" restart: always environment: - - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_apub_receive=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" + - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" volumes: - ../lemmy.hjson:/config/config.hjson depends_on: diff --git a/docker/federation/docker-compose.yml b/docker/federation/docker-compose.yml index fca363a4d..a9d8863d3 100644 --- a/docker/federation/docker-compose.yml +++ b/docker/federation/docker-compose.yml @@ -43,7 +43,7 @@ services: environment: - LEMMY_TEST_SEND_SYNC=1 - RUST_BACKTRACE=1 - - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_apub_receive=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" + - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" depends_on: - postgres_alpha ports: @@ -72,7 +72,7 @@ services: environment: - LEMMY_TEST_SEND_SYNC=1 - RUST_BACKTRACE=1 - - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_apub_receive=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" + - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" depends_on: - postgres_beta ports: @@ -101,7 +101,7 @@ services: environment: - LEMMY_TEST_SEND_SYNC=1 - RUST_BACKTRACE=1 - - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_apub_receive=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" + - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" depends_on: - postgres_gamma ports: @@ -131,7 +131,7 @@ services: environment: - LEMMY_TEST_SEND_SYNC=1 - RUST_BACKTRACE=1 - - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_apub_receive=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" + - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" depends_on: - postgres_delta ports: @@ -161,7 +161,7 @@ services: environment: - LEMMY_TEST_SEND_SYNC=1 - RUST_BACKTRACE=1 - - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_apub_receive=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" + - RUST_LOG="warn,lemmy_server=debug,lemmy_api=debug,lemmy_api_common=debug,lemmy_api_crud=debug,lemmy_apub=debug,lemmy_db_queries=debug,lemmy_db_schema=debug,lemmy_db_views=debug,lemmy_db_views_actor=debug,lemmy_db_views_moderator=debug,lemmy_routes=debug,lemmy_utils=debug,lemmy_websocket=debug" depends_on: - postgres_epsilon ports: diff --git a/docker/prod/docker-compose.yml b/docker/prod/docker-compose.yml index 0e8578e4d..5d8bf5680 100644 --- a/docker/prod/docker-compose.yml +++ b/docker/prod/docker-compose.yml @@ -17,7 +17,7 @@ services: - "127.0.0.1:8536:8536" restart: always environment: - - RUST_LOG="warn,lemmy_server=info,lemmy_api=info,lemmy_api_common=info,lemmy_api_crud=info,lemmy_apub=info,lemmy_apub_receive=info,lemmy_db_queries=info,lemmy_db_schema=info,lemmy_db_views=info,lemmy_db_views_actor=info,lemmy_db_views_moderator=info,lemmy_routes=info,lemmy_utils=info,lemmy_websocket=info" + - RUST_LOG="warn,lemmy_server=info,lemmy_api=info,lemmy_api_common=info,lemmy_api_crud=info,lemmy_apub=info,lemmy_db_queries=info,lemmy_db_schema=info,lemmy_db_views=info,lemmy_db_views_actor=info,lemmy_db_views_moderator=info,lemmy_routes=info,lemmy_utils=info,lemmy_websocket=info" volumes: - ./lemmy.hjson:/config/config.hjson depends_on: diff --git a/src/main.rs b/src/main.rs index fd5394fca..8076fb365 100644 --- a/src/main.rs +++ b/src/main.rs @@ -91,7 +91,7 @@ async fn main() -> Result<(), LemmyError> { .app_data(Data::new(context)) // The routes .configure(|cfg| api_routes::config(cfg, &rate_limiter)) - .configure(lemmy_apub_receive::http::routes::config) + .configure(lemmy_apub::http::routes::config) .configure(feeds::config) .configure(|cfg| images::config(cfg, &rate_limiter)) .configure(nodeinfo::config)