summaryrefslogtreecommitdiffstats
path: root/server/src/apub
diff options
context:
space:
mode:
Diffstat (limited to 'server/src/apub')
-rw-r--r--server/src/apub/comment.rs17
-rw-r--r--server/src/apub/community.rs18
-rw-r--r--server/src/apub/fetcher.rs7
-rw-r--r--server/src/apub/mod.rs3
-rw-r--r--server/src/apub/post.rs14
-rw-r--r--server/src/apub/private_message.rs13
-rw-r--r--server/src/apub/shared_inbox.rs21
-rw-r--r--server/src/apub/user.rs12
-rw-r--r--server/src/apub/user_inbox.rs9
9 files changed, 85 insertions, 29 deletions
diff --git a/server/src/apub/comment.rs b/server/src/apub/comment.rs
index 84d11275..9e5e53a7 100644
--- a/server/src/apub/comment.rs
+++ b/server/src/apub/comment.rs
@@ -1,16 +1,25 @@
use crate::{
apub::{
activities::{populate_object_props, send_activity_to_community},
- create_apub_response, create_apub_tombstone_response, create_tombstone, fetch_webfinger_url,
+ create_apub_response,
+ create_apub_tombstone_response,
+ create_tombstone,
+ fetch_webfinger_url,
fetcher::{
- get_or_fetch_and_insert_remote_comment, get_or_fetch_and_insert_remote_post,
+ get_or_fetch_and_insert_remote_comment,
+ get_or_fetch_and_insert_remote_post,
get_or_fetch_and_upsert_remote_user,
},
- ActorType, ApubLikeableType, ApubObjectType, FromApub, ToApub,
+ ActorType,
+ ApubLikeableType,
+ ApubObjectType,
+ FromApub,
+ ToApub,
},
blocking,
routes::DbPoolParam,
- DbPool, LemmyError,
+ DbPool,
+ LemmyError,
};
use activitystreams::{
activity::{Create, Delete, Dislike, Like, Remove, Undo, Update},
diff --git a/server/src/apub/community.rs b/server/src/apub/community.rs
index 587977a3..529039fc 100644
--- a/server/src/apub/community.rs
+++ b/server/src/apub/community.rs
@@ -1,18 +1,28 @@
use crate::{
apub::{
activities::{populate_object_props, send_activity},
- create_apub_response, create_apub_tombstone_response, create_tombstone,
+ create_apub_response,
+ create_apub_tombstone_response,
+ create_tombstone,
extensions::group_extensions::GroupExtension,
fetcher::get_or_fetch_and_upsert_remote_user,
- get_shared_inbox, insert_activity, ActorType, FromApub, GroupExt, ToApub,
+ get_shared_inbox,
+ insert_activity,
+ ActorType,
+ FromApub,
+ GroupExt,
+ ToApub,
},
blocking,
routes::DbPoolParam,
- DbPool, LemmyError,
+ DbPool,
+ LemmyError,
};
use activitystreams::{
activity::{Accept, Announce, Delete, Remove, Undo},
- Activity, Base, BaseBox,
+ Activity,
+ Base,
+ BaseBox,
};
use activitystreams_ext::Ext2;
use activitystreams_new::{
diff --git a/server/src/apub/fetcher.rs b/server/src/apub/fetcher.rs
index 4251cb76..f20c9eab 100644
--- a/server/src/apub/fetcher.rs
+++ b/server/src/apub/fetcher.rs
@@ -4,7 +4,8 @@ use crate::{
blocking,
request::{retry, RecvError},
routes::nodeinfo::{NodeInfo, NodeInfoWellKnown},
- DbPool, LemmyError,
+ DbPool,
+ LemmyError,
};
use activitystreams::object::Note;
use activitystreams_new::{base::BaseExt, prelude::*, primitives::XsdAnyUri};
@@ -21,7 +22,9 @@ use lemmy_db::{
post_view::PostView,
user::{UserForm, User_},
user_view::UserView,
- Crud, Joinable, SearchType,
+ Crud,
+ Joinable,
+ SearchType,
};
use lemmy_utils::get_apub_protocol_string;
use log::debug;
diff --git a/server/src/apub/mod.rs b/server/src/apub/mod.rs
index 499f0352..cfb539fb 100644
--- a/server/src/apub/mod.rs
+++ b/server/src/apub/mod.rs
@@ -19,7 +19,8 @@ use crate::{
blocking,
request::{retry, RecvError},
routes::webfinger::WebFingerResponse,
- DbPool, LemmyError,
+ DbPool,
+ LemmyError,
};
use activitystreams::object::Page;
use activitystreams_ext::{Ext1, Ext2};
diff --git a/server/src/apub/post.rs b/server/src/apub/post.rs
index c4e98f11..36922e4f 100644
--- a/server/src/apub/post.rs
+++ b/server/src/apub/post.rs
@@ -1,14 +1,22 @@
use crate::{
apub::{
activities::{populate_object_props, send_activity_to_community},
- create_apub_response, create_apub_tombstone_response, create_tombstone,
+ create_apub_response,
+ create_apub_tombstone_response,
+ create_tombstone,
extensions::page_extension::PageExtension,
fetcher::{get_or_fetch_and_upsert_remote_community, get_or_fetch_and_upsert_remote_user},
- ActorType, ApubLikeableType, ApubObjectType, FromApub, PageExt, ToApub,
+ ActorType,
+ ApubLikeableType,
+ ApubObjectType,
+ FromApub,
+ PageExt,
+ ToApub,
},
blocking,
routes::DbPoolParam,
- DbPool, LemmyError,
+ DbPool,
+ LemmyError,
};
use activitystreams::{
activity::{Create, Delete, Dislike, Like, Remove, Undo, Update},
diff --git a/server/src/apub/private_message.rs b/server/src/apub/private_message.rs
index 228cc684..bc685b23 100644
--- a/server/src/apub/private_message.rs
+++ b/server/src/apub/private_message.rs
@@ -1,9 +1,16 @@
use crate::{
apub::{
- activities::send_activity, create_tombstone, fetcher::get_or_fetch_and_upsert_remote_user,
- insert_activity, ApubObjectType, FromApub, ToApub,
+ activities::send_activity,
+ create_tombstone,
+ fetcher::get_or_fetch_and_upsert_remote_user,
+ insert_activity,
+ ApubObjectType,
+ FromApub,
+ ToApub,
},
- blocking, DbPool, LemmyError,
+ blocking,
+ DbPool,
+ LemmyError,
};
use activitystreams::{
activity::{Create, Delete, Undo, Update},
diff --git a/server/src/apub/shared_inbox.rs b/server/src/apub/shared_inbox.rs
index f0f5bbfd..7319f1ae 100644
--- a/server/src/apub/shared_inbox.rs
+++ b/server/src/apub/shared_inbox.rs
@@ -8,10 +8,15 @@ use crate::{
community::do_announce,
extensions::signatures::verify,
fetcher::{
- get_or_fetch_and_insert_remote_comment, get_or_fetch_and_insert_remote_post,
- get_or_fetch_and_upsert_remote_community, get_or_fetch_and_upsert_remote_user,
+ get_or_fetch_and_insert_remote_comment,
+ get_or_fetch_and_insert_remote_post,
+ get_or_fetch_and_upsert_remote_community,
+ get_or_fetch_and_upsert_remote_user,
},
- insert_activity, FromApub, GroupExt, PageExt,
+ insert_activity,
+ FromApub,
+ GroupExt,
+ PageExt,
},
blocking,
routes::{ChatServerParam, DbPoolParam},
@@ -19,12 +24,15 @@ use crate::{
server::{SendComment, SendCommunityRoomMessage, SendPost},
UserOperation,
},
- DbPool, LemmyError,
+ DbPool,
+ LemmyError,
};
use activitystreams::{
activity::{Announce, Create, Delete, Dislike, Like, Remove, Undo, Update},
object::Note,
- Activity, Base, BaseBox,
+ Activity,
+ Base,
+ BaseBox,
};
use actix_web::{client::Client, web, HttpRequest, HttpResponse};
use lemmy_db::{
@@ -35,7 +43,8 @@ use lemmy_db::{
naive_now,
post::{Post, PostForm, PostLike, PostLikeForm},
post_view::PostView,
- Crud, Likeable,
+ Crud,
+ Likeable,
};
use lemmy_utils::scrape_text_for_mentions;
use log::debug;
diff --git a/server/src/apub/user.rs b/server/src/apub/user.rs
index 997c03ea..2b02486d 100644
--- a/server/src/apub/user.rs
+++ b/server/src/apub/user.rs
@@ -1,12 +1,18 @@
use crate::{
api::claims::Claims,
apub::{
- activities::send_activity, create_apub_response, insert_activity, ActorType, FromApub,
- PersonExt, ToApub,
+ activities::send_activity,
+ create_apub_response,
+ insert_activity,
+ ActorType,
+ FromApub,
+ PersonExt,
+ ToApub,
},
blocking,
routes::DbPoolParam,
- DbPool, LemmyError,
+ DbPool,
+ LemmyError,
};
use activitystreams_ext::Ext1;
use activitystreams_new::{
diff --git a/server/src/apub/user_inbox.rs b/server/src/apub/user_inbox.rs
index 2bf26957..9bc102a7 100644
--- a/server/src/apub/user_inbox.rs
+++ b/server/src/apub/user_inbox.rs
@@ -3,12 +3,14 @@ use crate::{
apub::{
extensions::signatures::verify,
fetcher::{get_or_fetch_and_upsert_remote_community, get_or_fetch_and_upsert_remote_user},
- insert_activity, FromApub,
+ insert_activity,
+ FromApub,
},
blocking,
routes::{ChatServerParam, DbPoolParam},
websocket::{server::SendUserRoomMessage, UserOperation},
- DbPool, LemmyError,
+ DbPool,
+ LemmyError,
};
use activitystreams::{
activity::{Accept, Create, Delete, Undo, Update},
@@ -21,7 +23,8 @@ use lemmy_db::{
private_message::{PrivateMessage, PrivateMessageForm},
private_message_view::PrivateMessageView,
user::User_,
- Crud, Followable,
+ Crud,
+ Followable,
};
use log::debug;
use serde::Deserialize;