Running cargo fmt using old way.

pull/1124/head
Dessalines 2020-09-10 13:08:27 -05:00
parent 413de6286c
commit 3136df3334
51 changed files with 150 additions and 545 deletions

4
.rustfmt.toml vendored
View File

@ -1,5 +1,5 @@
tab_spaces = 2
edition="2018"
imports_layout="HorizontalVertical"
merge_imports=true
# imports_layout="HorizontalVertical"
# merge_imports=true
reorder_imports=true

View File

@ -1,12 +1,6 @@
use lemmy_db::{
category::*,
comment_view::*,
community_view::*,
moderator_views::*,
post_view::*,
site_view::*,
user::*,
user_view::*,
category::*, comment_view::*, community_view::*, moderator_views::*, post_view::*, site_view::*,
user::*, user_view::*,
};
use serde::{Deserialize, Serialize};

View File

@ -1,7 +1,7 @@
use crate::{schema::activity, Crud};
use diesel::{dsl::*, result::Error, *};
use log::debug;
use serde::{Serialize};
use serde::Serialize;
use serde_json::Value;
use std::{
fmt::Debug,
@ -85,9 +85,7 @@ mod tests {
activity::{Activity, ActivityForm},
tests::establish_unpooled_connection,
user::{UserForm, User_},
Crud,
ListingType,
SortType,
Crud, ListingType, SortType,
};
use serde_json::Value;

View File

@ -3,7 +3,7 @@ use crate::{
Crud,
};
use diesel::{dsl::*, result::Error, *};
use serde::{Serialize};
use serde::Serialize;
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize)]
#[table_name = "category"]

View File

@ -2,9 +2,7 @@ use super::post::Post;
use crate::{
naive_now,
schema::{comment, comment_like, comment_saved},
Crud,
Likeable,
Saveable,
Crud, Likeable, Saveable,
};
use diesel::{dsl::*, result::Error, *};
use url::{ParseError, Url};
@ -257,14 +255,8 @@ impl Saveable<CommentSavedForm> for CommentSaved {
#[cfg(test)]
mod tests {
use crate::{
comment::*,
community::*,
post::*,
tests::establish_unpooled_connection,
user::*,
Crud,
ListingType,
SortType,
comment::*, community::*, post::*, tests::establish_unpooled_connection, user::*, Crud,
ListingType, SortType,
};
#[test]

View File

@ -84,9 +84,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "comment_fast_view"]
pub struct CommentView {
pub id: i32,
@ -497,15 +495,8 @@ impl<'a> ReplyQueryBuilder<'a> {
#[cfg(test)]
mod tests {
use crate::{
comment::*,
comment_view::*,
community::*,
post::*,
tests::establish_unpooled_connection,
user::*,
Crud,
Likeable,
*,
comment::*, comment_view::*, community::*, post::*, tests::establish_unpooled_connection,
user::*, Crud, Likeable, *,
};
#[test]

View File

@ -1,10 +1,7 @@
use crate::{
naive_now,
schema::{community, community_follower, community_moderator, community_user_ban},
Bannable,
Crud,
Followable,
Joinable,
Bannable, Crud, Followable, Joinable,
};
use diesel::{dsl::*, result::Error, *};

View File

@ -123,9 +123,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "community_fast_view"]
pub struct CommunityView {
pub id: i32,

View File

@ -1,14 +1,7 @@
use crate::{
schema::{
mod_add,
mod_add_community,
mod_ban,
mod_ban_from_community,
mod_lock_post,
mod_remove_comment,
mod_remove_community,
mod_remove_post,
mod_sticky_post,
mod_add, mod_add_community, mod_ban, mod_ban_from_community, mod_lock_post, mod_remove_comment,
mod_remove_community, mod_remove_post, mod_sticky_post,
},
Crud,
};
@ -392,14 +385,8 @@ impl Crud<ModAddForm> for ModAdd {
#[cfg(test)]
mod tests {
use crate::{
comment::*,
community::*,
moderator::*,
post::*,
tests::establish_unpooled_connection,
user::*,
ListingType,
SortType,
comment::*, community::*, moderator::*, post::*, tests::establish_unpooled_connection, user::*,
ListingType, SortType,
};
// use Crud;

View File

@ -1,6 +1,6 @@
use crate::limit_and_offset;
use diesel::{result::Error, *};
use serde::{Serialize};
use serde::Serialize;
table! {
mod_remove_post_view (id) {
@ -17,9 +17,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_remove_post_view"]
pub struct ModRemovePostView {
pub id: i32,
@ -77,9 +75,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_lock_post_view"]
pub struct ModLockPostView {
pub id: i32,
@ -136,9 +132,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_sticky_post_view"]
pub struct ModStickyPostView {
pub id: i32,
@ -200,9 +194,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_remove_comment_view"]
pub struct ModRemoveCommentView {
pub id: i32,
@ -264,9 +256,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_remove_community_view"]
pub struct ModRemoveCommunityView {
pub id: i32,
@ -320,9 +310,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_ban_from_community_view"]
pub struct ModBanFromCommunityView {
pub id: i32,
@ -381,9 +369,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_ban_view"]
pub struct ModBanView {
pub id: i32,
@ -435,9 +421,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_add_community_view"]
pub struct ModAddCommunityView {
pub id: i32,
@ -492,9 +476,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "mod_add_view"]
pub struct ModAddView {
pub id: i32,

View File

@ -80,11 +80,8 @@ impl PasswordResetRequest {
mod tests {
use super::super::user::*;
use crate::{
password_reset_request::PasswordResetRequest,
tests::establish_unpooled_connection,
Crud,
ListingType,
SortType,
password_reset_request::PasswordResetRequest, tests::establish_unpooled_connection, Crud,
ListingType, SortType,
};
#[test]

View File

@ -1,10 +1,7 @@
use crate::{
naive_now,
schema::{post, post_like, post_read, post_saved},
Crud,
Likeable,
Readable,
Saveable,
Crud, Likeable, Readable, Saveable,
};
use diesel::{dsl::*, result::Error, *};
use url::{ParseError, Url};
@ -328,12 +325,7 @@ impl Readable<PostReadForm> for PostRead {
#[cfg(test)]
mod tests {
use crate::{
community::*,
post::*,
tests::establish_unpooled_connection,
user::*,
ListingType,
SortType,
community::*, post::*, tests::establish_unpooled_connection, user::*, ListingType, SortType,
};
#[test]

View File

@ -106,9 +106,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "post_fast_view"]
pub struct PostView {
pub id: i32,
@ -389,14 +387,8 @@ impl PostView {
#[cfg(test)]
mod tests {
use crate::{
community::*,
post::*,
post_view::*,
tests::establish_unpooled_connection,
user::*,
Crud,
Likeable,
*,
community::*, post::*, post_view::*, tests::establish_unpooled_connection, user::*, Crud,
Likeable, *,
};
#[test]

View File

@ -137,11 +137,7 @@ impl PrivateMessage {
#[cfg(test)]
mod tests {
use crate::{
private_message::*,
tests::establish_unpooled_connection,
user::*,
ListingType,
SortType,
private_message::*, tests::establish_unpooled_connection, user::*, ListingType, SortType,
};
#[test]

View File

@ -1,6 +1,6 @@
use crate::{limit_and_offset, MaybeOptional};
use diesel::{pg::Pg, result::Error, *};
use serde::{Serialize};
use serde::Serialize;
// The faked schema since diesel doesn't do views
table! {
@ -28,9 +28,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "private_message_view"]
pub struct PrivateMessageView {
pub id: i32,

View File

@ -1,5 +1,5 @@
use diesel::{result::Error, *};
use serde::{Serialize};
use serde::Serialize;
table! {
site_view (id) {
@ -24,9 +24,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "site_view"]
pub struct SiteView {
pub id: i32,

View File

@ -1,12 +1,11 @@
use crate::{
is_email_regex,
naive_now,
is_email_regex, naive_now,
schema::{user_, user_::dsl::*},
Crud,
};
use bcrypt::{hash, DEFAULT_COST};
use diesel::{dsl::*, result::Error, *};
use serde::{Serialize};
use serde::Serialize;
#[derive(Clone, Queryable, Identifiable, PartialEq, Debug, Serialize)]
#[table_name = "user_"]

View File

@ -73,14 +73,8 @@ impl UserMention {
#[cfg(test)]
mod tests {
use crate::{
comment::*,
community::*,
post::*,
tests::establish_unpooled_connection,
user::*,
user_mention::*,
ListingType,
SortType,
comment::*, community::*, post::*, tests::establish_unpooled_connection, user::*,
user_mention::*, ListingType, SortType,
};
#[test]

View File

@ -1,6 +1,6 @@
use crate::{limit_and_offset, MaybeOptional, SortType};
use diesel::{dsl::*, pg::Pg, result::Error, *};
use serde::{Serialize};
use serde::Serialize;
// The faked schema since diesel doesn't do views
table! {
@ -83,9 +83,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "user_mention_fast_view"]
pub struct UserMentionView {
pub id: i32,

View File

@ -1,7 +1,7 @@
use super::user_view::user_fast::BoxedQuery;
use crate::{fuzzy_search, limit_and_offset, MaybeOptional, SortType};
use diesel::{dsl::*, pg::Pg, result::Error, *};
use serde::{Serialize};
use serde::Serialize;
table! {
user_view (id) {
@ -51,9 +51,7 @@ table! {
}
}
#[derive(
Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone,
)]
#[derive(Queryable, Identifiable, PartialEq, Debug, Serialize, QueryableByName, Clone)]
#[table_name = "user_fast"]
pub struct UserView {
pub id: i32,

View File

@ -24,9 +24,7 @@ use lettre::{
extension::ClientId,
ConnectionReuseParameters,
},
ClientSecurity,
SmtpClient,
Transport,
ClientSecurity, SmtpClient, Transport,
};
use lettre_email::Email;
use openssl::{pkey::PKey, rsa::Rsa};
@ -223,14 +221,8 @@ pub fn is_valid_post_title(title: &str) -> bool {
#[cfg(test)]
mod tests {
use crate::{
is_valid_community_name,
is_valid_post_title,
is_valid_preferred_username,
is_valid_username,
remove_slurs,
scrape_text_for_mentions,
slur_check,
slurs_vec_to_str,
is_valid_community_name, is_valid_post_title, is_valid_preferred_username, is_valid_username,
remove_slurs, scrape_text_for_mentions, slur_check, slurs_vec_to_str,
};
#[test]

View File

@ -1,10 +1,6 @@
use crate::{
api::{
check_community_ban,
get_post,
get_user_from_jwt,
get_user_from_jwt_opt,
is_mod_or_admin,
check_community_ban, get_post, get_user_from_jwt, get_user_from_jwt_opt, is_mod_or_admin,
Perform,
},
apub::{ApubLikeableType, ApubObjectType},
@ -13,36 +9,17 @@ use crate::{
messages::{JoinCommunityRoom, SendComment},
UserOperation,
},
DbPool,
LemmyContext,
DbPool, LemmyContext,
};
use actix_web::web::Data;
use lemmy_api_structs::comment::*;
use lemmy_db::{
comment::*,
comment_view::*,
moderator::*,
post::*,
site_view::*,
user::*,
user_mention::*,
Crud,
Likeable,
ListingType,
Saveable,
SortType,
comment::*, comment_view::*, moderator::*, post::*, site_view::*, user::*, user_mention::*, Crud,
Likeable, ListingType, Saveable, SortType,
};
use lemmy_utils::{
make_apub_endpoint,
remove_slurs,
scrape_text_for_mentions,
send_email,
settings::Settings,
APIError,
ConnectionId,
EndpointType,
LemmyError,
MentionData,
make_apub_endpoint, remove_slurs, scrape_text_for_mentions, send_email, settings::Settings,
APIError, ConnectionId, EndpointType, LemmyError, MentionData,
};
use log::error;
use std::str::FromStr;

View File

@ -1,12 +1,7 @@
use crate::{
api::{
check_slurs,
check_slurs_opt,
get_user_from_jwt,
get_user_from_jwt_opt,
is_admin,
is_mod_or_admin,
Perform,
check_slurs, check_slurs_opt, get_user_from_jwt, get_user_from_jwt_opt, is_admin,
is_mod_or_admin, Perform,
},
apub::ActorType,
blocking,
@ -20,32 +15,13 @@ use actix_web::web::Data;
use anyhow::Context;
use lemmy_api_structs::community::*;
use lemmy_db::{
comment::Comment,
comment_view::CommentQueryBuilder,
community::*,
community_view::*,
diesel_option_overwrite,
moderator::*,
naive_now,
post::Post,
site::*,
user_view::*,
Bannable,
Crud,
Followable,
Joinable,
SortType,
comment::Comment, comment_view::CommentQueryBuilder, community::*, community_view::*,
diesel_option_overwrite, moderator::*, naive_now, post::Post, site::*, user_view::*, Bannable,
Crud, Followable, Joinable, SortType,
};
use lemmy_utils::{
generate_actor_keypair,
is_valid_community_name,
location_info,
make_apub_endpoint,
naive_from_unix,
APIError,
ConnectionId,
EndpointType,
LemmyError,
generate_actor_keypair, is_valid_community_name, location_info, make_apub_endpoint,
naive_from_unix, APIError, ConnectionId, EndpointType, LemmyError,
};
use std::str::FromStr;

View File

@ -1,11 +1,7 @@
use crate::{api::claims::Claims, blocking, DbPool, LemmyContext};
use actix_web::web::Data;
use lemmy_db::{
community::Community,
community_view::CommunityUserBanView,
post::Post,
user::User_,
Crud,
community::Community, community_view::CommunityUserBanView, post::Post, user::User_, Crud,
};
use lemmy_utils::{slur_check, slurs_vec_to_str, APIError, ConnectionId, LemmyError};

View File

@ -1,16 +1,10 @@
use crate::{
api::{
check_community_ban,
check_slurs,
check_slurs_opt,
get_user_from_jwt,
get_user_from_jwt_opt,
is_mod_or_admin,
Perform,
check_community_ban, check_slurs, check_slurs_opt, get_user_from_jwt, get_user_from_jwt_opt,
is_mod_or_admin, Perform,
},
apub::{ApubLikeableType, ApubObjectType},
blocking,
fetch_iframely_and_pictrs_data,
blocking, fetch_iframely_and_pictrs_data,
websocket::{
messages::{GetPostUsersOnline, JoinCommunityRoom, JoinPostRoom, SendPost},
UserOperation,
@ -20,26 +14,11 @@ use crate::{
use actix_web::web::Data;
use lemmy_api_structs::post::*;
use lemmy_db::{
comment_view::*,
community_view::*,
moderator::*,
naive_now,
post::*,
post_view::*,
site_view::*,
Crud,
Likeable,
ListingType,
Saveable,
SortType,
comment_view::*, community_view::*, moderator::*, naive_now, post::*, post_view::*, site_view::*,
Crud, Likeable, ListingType, Saveable, SortType,
};
use lemmy_utils::{
is_valid_post_title,
make_apub_endpoint,
APIError,
ConnectionId,
EndpointType,
LemmyError,
is_valid_post_title, make_apub_endpoint, APIError, ConnectionId, EndpointType, LemmyError,
};
use std::str::FromStr;
use url::Url;

View File

@ -1,15 +1,9 @@
use crate::{
api::{
check_slurs,
check_slurs_opt,
get_user_from_jwt,
get_user_from_jwt_opt,
is_admin,
Perform,
check_slurs, check_slurs_opt, get_user_from_jwt, get_user_from_jwt_opt, is_admin, Perform,
},
apub::fetcher::search_by_apub_id,
blocking,
version,
blocking, version,
websocket::{
messages::{GetUsersOnline, SendAllMessage},
UserOperation,
@ -20,20 +14,9 @@ use actix_web::web::Data;
use anyhow::Context;
use lemmy_api_structs::{site::*, user::Register};
use lemmy_db::{
category::*,
comment_view::*,
community_view::*,
diesel_option_overwrite,
moderator::*,
moderator_views::*,
naive_now,
post_view::*,
site::*,
site_view::*,
user_view::*,
Crud,
SearchType,
SortType,
category::*, comment_view::*, community_view::*, diesel_option_overwrite, moderator::*,
moderator_views::*, naive_now, post_view::*, site::*, site_view::*, user_view::*, Crud,
SearchType, SortType,
};
use lemmy_utils::{location_info, settings::Settings, APIError, ConnectionId, LemmyError};
use log::{debug, info};

View File

@ -1,8 +1,7 @@
use crate::{
api::{check_slurs, claims::Claims, get_user_from_jwt, get_user_from_jwt_opt, is_admin, Perform},
apub::ApubObjectType,
blocking,
captcha_espeak_wav_base64,
blocking, captcha_espeak_wav_base64,
websocket::{
messages::{CaptchaItem, CheckCaptcha, JoinUserRoom, SendAllMessage, SendUserRoomMessage},
UserOperation,
@ -16,45 +15,15 @@ use captcha::{gen, Difficulty};
use chrono::Duration;
use lemmy_api_structs::user::*;
use lemmy_db::{
comment::*,
comment_view::*,
community::*,
community_view::*,
diesel_option_overwrite,
moderator::*,
naive_now,
password_reset_request::*,
post::*,
post_view::*,
private_message::*,
private_message_view::*,
site::*,
site_view::*,
user::*,
user_mention::*,
user_mention_view::*,
user_view::*,
Crud,
Followable,
Joinable,
ListingType,
SortType,
comment::*, comment_view::*, community::*, community_view::*, diesel_option_overwrite,
moderator::*, naive_now, password_reset_request::*, post::*, post_view::*, private_message::*,
private_message_view::*, site::*, site_view::*, user::*, user_mention::*, user_mention_view::*,
user_view::*, Crud, Followable, Joinable, ListingType, SortType,
};
use lemmy_utils::{
generate_actor_keypair,
generate_random_string,
is_valid_preferred_username,
is_valid_username,
location_info,
make_apub_endpoint,
naive_from_unix,
remove_slurs,
send_email,
settings::Settings,
APIError,
ConnectionId,
EndpointType,
LemmyError,
generate_actor_keypair, generate_random_string, is_valid_preferred_username, is_valid_username,
location_info, make_apub_endpoint, naive_from_unix, remove_slurs, send_email, settings::Settings,
APIError, ConnectionId, EndpointType, LemmyError,
};
use log::error;
use std::str::FromStr;

View File

@ -6,13 +6,7 @@ use activitystreams::{
use anyhow::{anyhow, Context, Error};
use awc::Client;
use background_jobs::{
create_server,
memory_storage::Storage,
ActixJob,
Backoff,
MaxRetries,
QueueHandle,
WorkerConfig,
create_server, memory_storage::Storage, ActixJob, Backoff, MaxRetries, QueueHandle, WorkerConfig,
};
use lemmy_utils::{location_info, settings::Settings, LemmyError};
use log::warn;

View File

@ -1,36 +1,19 @@
use crate::{
apub::{
activities::{generate_activity_id, send_activity_to_community},
check_actor_domain,
create_apub_response,
create_apub_tombstone_response,
create_tombstone,
check_actor_domain, create_apub_response, create_apub_tombstone_response, create_tombstone,
fetch_webfinger_url,
fetcher::{
get_or_fetch_and_insert_comment,
get_or_fetch_and_insert_post,
get_or_fetch_and_upsert_user,
get_or_fetch_and_insert_comment, get_or_fetch_and_insert_post, get_or_fetch_and_upsert_user,
},
ActorType,
ApubLikeableType,
ApubObjectType,
FromApub,
ToApub,
ActorType, ApubLikeableType, ApubObjectType, FromApub, ToApub,
},
blocking,
DbPool,
LemmyContext,
blocking, DbPool, LemmyContext,
};
use activitystreams::{
activity::{
kind::{CreateType, DeleteType, DislikeType, LikeType, RemoveType, UndoType, UpdateType},
Create,
Delete,
Dislike,
Like,
Remove,
Undo,
Update,
Create, Delete, Dislike, Like, Remove, Undo, Update,
},
base::AnyBase,
link::Mention,
@ -49,12 +32,7 @@ use lemmy_db::{
Crud,
};
use lemmy_utils::{
convert_datetime,
location_info,
remove_slurs,
scrape_text_for_mentions,
LemmyError,
MentionData,
convert_datetime, location_info, remove_slurs, scrape_text_for_mentions, LemmyError, MentionData,
};
use log::debug;
use serde::Deserialize;

View File

@ -3,31 +3,17 @@ use crate::{
apub::{
activities::generate_activity_id,
activity_queue::send_activity,
check_actor_domain,
create_apub_response,
create_apub_tombstone_response,
create_tombstone,
check_actor_domain, create_apub_response, create_apub_tombstone_response, create_tombstone,
extensions::group_extensions::GroupExtension,
fetcher::{get_or_fetch_and_upsert_actor, get_or_fetch_and_upsert_user},
insert_activity,
ActorType,
FromApub,
GroupExt,
ToApub,
insert_activity, ActorType, FromApub, GroupExt, ToApub,
},
blocking,
DbPool,
LemmyContext,
blocking, DbPool, LemmyContext,
};
use activitystreams::{
activity::{
kind::{AcceptType, AnnounceType, DeleteType, LikeType, RemoveType, UndoType},
Accept,
Announce,
Delete,
Follow,
Remove,
Undo,
Accept, Announce, Delete, Follow, Remove, Undo,
},
actor::{kind::GroupType, ApActor, Endpoints, Group},
base::{AnyBase, BaseExt},

View File

@ -1,11 +1,6 @@
use crate::{
apub::{
check_is_apub_id_valid,
ActorType,
FromApub,
GroupExt,
PageExt,
PersonExt,
check_is_apub_id_valid, ActorType, FromApub, GroupExt, PageExt, PersonExt,
APUB_JSON_CONTENT_TYPE,
},
blocking,
@ -27,9 +22,7 @@ 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, location_info, LemmyError};
use log::debug;

View File

@ -1,13 +1,8 @@
use crate::{
apub::inbox::{
activities::{
create::receive_create,
delete::receive_delete,
dislike::receive_dislike,
like::receive_like,
remove::receive_remove,
undo::receive_undo,
update::receive_update,
create::receive_create, delete::receive_delete, dislike::receive_dislike, like::receive_like,
remove::receive_remove, undo::receive_undo, update::receive_update,
},
shared_inbox::{get_community_id_from_activity, receive_unhandled_activity},
},

View File

@ -2,13 +2,9 @@ use crate::{
api::comment::send_local_notifs,
apub::{
inbox::shared_inbox::{
announce_if_community_is_local,
get_user_from_activity,
receive_unhandled_activity,
announce_if_community_is_local, get_user_from_activity, receive_unhandled_activity,
},
ActorType,
FromApub,
PageExt,
ActorType, FromApub, PageExt,
},
blocking,
websocket::{

View File

@ -2,14 +2,9 @@ use crate::{
apub::{
fetcher::{get_or_fetch_and_insert_comment, get_or_fetch_and_insert_post},
inbox::shared_inbox::{
announce_if_community_is_local,
get_user_from_activity,
receive_unhandled_activity,
announce_if_community_is_local, get_user_from_activity, receive_unhandled_activity,
},
ActorType,
FromApub,
GroupExt,
PageExt,
ActorType, FromApub, GroupExt, PageExt,
},
blocking,
websocket::{
@ -22,9 +17,7 @@ use activitystreams::{activity::Delete, base::AnyBase, object::Note, prelude::*}
use actix_web::HttpResponse;
use anyhow::Context;
use lemmy_api_structs::{
comment::CommentResponse,
community::CommunityResponse,
post::PostResponse,
comment::CommentResponse, community::CommunityResponse, post::PostResponse,
};
use lemmy_db::{
comment::{Comment, CommentForm},

View File

@ -2,12 +2,9 @@ use crate::{
apub::{
fetcher::{get_or_fetch_and_insert_comment, get_or_fetch_and_insert_post},
inbox::shared_inbox::{
announce_if_community_is_local,
get_user_from_activity,
receive_unhandled_activity,
announce_if_community_is_local, get_user_from_activity, receive_unhandled_activity,
},
FromApub,
PageExt,
FromApub, PageExt,
},
blocking,
websocket::{

View File

@ -2,12 +2,9 @@ use crate::{
apub::{
fetcher::{get_or_fetch_and_insert_comment, get_or_fetch_and_insert_post},
inbox::shared_inbox::{
announce_if_community_is_local,
get_user_from_activity,
receive_unhandled_activity,
announce_if_community_is_local, get_user_from_activity, receive_unhandled_activity,
},
FromApub,
PageExt,
FromApub, PageExt,
},
blocking,
websocket::{

View File

@ -2,15 +2,10 @@ use crate::{
apub::{
fetcher::{get_or_fetch_and_insert_comment, get_or_fetch_and_insert_post},
inbox::shared_inbox::{
announce_if_community_is_local,
get_community_id_from_activity,
get_user_from_activity,
announce_if_community_is_local, get_community_id_from_activity, get_user_from_activity,
receive_unhandled_activity,
},
ActorType,
FromApub,
GroupExt,
PageExt,
ActorType, FromApub, GroupExt, PageExt,
},
blocking,
websocket::{
@ -23,9 +18,7 @@ use activitystreams::{activity::Remove, base::AnyBase, object::Note, prelude::*}
use actix_web::HttpResponse;
use anyhow::{anyhow, Context};
use lemmy_api_structs::{
comment::CommentResponse,
community::CommunityResponse,
post::PostResponse,
comment::CommentResponse, community::CommunityResponse, post::PostResponse,
};
use lemmy_db::{
comment::{Comment, CommentForm},

View File

@ -2,14 +2,9 @@ use crate::{
apub::{
fetcher::{get_or_fetch_and_insert_comment, get_or_fetch_and_insert_post},
inbox::shared_inbox::{
announce_if_community_is_local,
get_user_from_activity,
receive_unhandled_activity,
announce_if_community_is_local, get_user_from_activity, receive_unhandled_activity,
},
ActorType,
FromApub,
GroupExt,
PageExt,
ActorType, FromApub, GroupExt, PageExt,
},
blocking,
websocket::{
@ -27,9 +22,7 @@ use activitystreams::{
use actix_web::HttpResponse;
use anyhow::{anyhow, Context};
use lemmy_api_structs::{
comment::CommentResponse,
community::CommunityResponse,
post::PostResponse,
comment::CommentResponse, community::CommunityResponse, post::PostResponse,
};
use lemmy_db::{
comment::{Comment, CommentForm, CommentLike},
@ -39,8 +32,7 @@ use lemmy_db::{
naive_now,
post::{Post, PostForm, PostLike},
post_view::PostView,
Crud,
Likeable,
Crud, Likeable,
};
use lemmy_utils::{location_info, LemmyError};

View File

@ -3,13 +3,9 @@ use crate::{
apub::{
fetcher::{get_or_fetch_and_insert_comment, get_or_fetch_and_insert_post},
inbox::shared_inbox::{
announce_if_community_is_local,
get_user_from_activity,
receive_unhandled_activity,
announce_if_community_is_local, get_user_from_activity, receive_unhandled_activity,
},
ActorType,
FromApub,
PageExt,
ActorType, FromApub, PageExt,
},
blocking,
websocket::{

View File

@ -1,13 +1,9 @@
use crate::{
apub::{
check_is_apub_id_valid,
extensions::signatures::verify,
fetcher::get_or_fetch_and_upsert_user,
insert_activity,
ActorType,
check_is_apub_id_valid, extensions::signatures::verify, fetcher::get_or_fetch_and_upsert_user,
insert_activity, ActorType,
},
blocking,
LemmyContext,
blocking, LemmyContext,
};
use activitystreams::{
activity::{ActorAndObject, Follow, Undo},

View File

@ -4,18 +4,12 @@ use crate::{
community::do_announce,
extensions::signatures::verify,
fetcher::{
get_or_fetch_and_upsert_actor,
get_or_fetch_and_upsert_community,
get_or_fetch_and_upsert_actor, get_or_fetch_and_upsert_community,
get_or_fetch_and_upsert_user,
},
inbox::activities::{
announce::receive_announce,
create::receive_create,
delete::receive_delete,
dislike::receive_dislike,
like::receive_like,
remove::receive_remove,
undo::receive_undo,
announce::receive_announce, create::receive_create, delete::receive_delete,
dislike::receive_dislike, like::receive_like, remove::receive_remove, undo::receive_undo,
update::receive_update,
},
insert_activity,

View File

@ -3,8 +3,7 @@ use crate::{
check_is_apub_id_valid,
extensions::signatures::verify,
fetcher::{get_or_fetch_and_upsert_actor, get_or_fetch_and_upsert_community},
insert_activity,
FromApub,
insert_activity, FromApub,
},
blocking,
websocket::{messages::SendUserRoomMessage, UserOperation},
@ -25,8 +24,7 @@ use lemmy_db::{
private_message::{PrivateMessage, PrivateMessageForm},
private_message_view::PrivateMessageView,
user::User_,
Crud,
Followable,
Crud, Followable,
};
use lemmy_utils::{location_info, LemmyError};
use log::debug;

View File

@ -18,8 +18,7 @@ use crate::{
blocking,
request::{retry, RecvError},
routes::webfinger::WebFingerResponse,
DbPool,
LemmyContext,
DbPool, LemmyContext,
};
use activitystreams::{
activity::Follow,
@ -35,11 +34,7 @@ use anyhow::{anyhow, Context};
use chrono::NaiveDateTime;
use lemmy_db::{activity::do_insert_activity, user::User_};
use lemmy_utils::{
convert_datetime,
get_apub_protocol_string,
location_info,
settings::Settings,
LemmyError,
convert_datetime, get_apub_protocol_string, location_info, settings::Settings, LemmyError,
MentionData,
};
use log::debug;

View File

@ -2,33 +2,17 @@ use crate::{
api::check_slurs,
apub::{
activities::{generate_activity_id, send_activity_to_community},
check_actor_domain,
create_apub_response,
create_apub_tombstone_response,
create_tombstone,
check_actor_domain, create_apub_response, create_apub_tombstone_response, create_tombstone,
extensions::page_extension::PageExtension,
fetcher::{get_or_fetch_and_upsert_community, get_or_fetch_and_upsert_user},
ActorType,
ApubLikeableType,
ApubObjectType,
FromApub,
PageExt,
ToApub,
ActorType, ApubLikeableType, ApubObjectType, FromApub, PageExt, ToApub,
},
blocking,
DbPool,
LemmyContext,
blocking, DbPool, LemmyContext,
};
use activitystreams::{
activity::{
kind::{CreateType, DeleteType, DislikeType, LikeType, RemoveType, UndoType, UpdateType},
Create,
Delete,
Dislike,
Like,
Remove,
Undo,
Update,
Create, Delete, Dislike, Like, Remove, Undo, Update,
},
object::{kind::PageType, Image, Object, Page, Tombstone},
prelude::*,

View File

@ -1,28 +1,15 @@
use crate::{
apub::{
activities::generate_activity_id,
activity_queue::send_activity,
check_actor_domain,
check_is_apub_id_valid,
create_tombstone,
fetcher::get_or_fetch_and_upsert_user,
insert_activity,
ActorType,
ApubObjectType,
FromApub,
ToApub,
activities::generate_activity_id, activity_queue::send_activity, check_actor_domain,
check_is_apub_id_valid, create_tombstone, fetcher::get_or_fetch_and_upsert_user,
insert_activity, ActorType, ApubObjectType, FromApub, ToApub,
},
blocking,
DbPool,
LemmyContext,
blocking, DbPool, LemmyContext,
};
use activitystreams::{
activity::{
kind::{CreateType, DeleteType, UndoType, UpdateType},
Create,
Delete,
Undo,
Update,
Create, Delete, Undo, Update,
},
object::{kind::NoteType, Note, Tombstone},
prelude::*,

View File

@ -1,26 +1,16 @@
use crate::{
api::{check_slurs, check_slurs_opt},
apub::{
activities::generate_activity_id,
activity_queue::send_activity,
check_actor_domain,
create_apub_response,
fetcher::get_or_fetch_and_upsert_actor,
insert_activity,
ActorType,
FromApub,
PersonExt,
ToApub,
activities::generate_activity_id, activity_queue::send_activity, check_actor_domain,
create_apub_response, fetcher::get_or_fetch_and_upsert_actor, insert_activity, ActorType,
FromApub, PersonExt, ToApub,
},
blocking,
DbPool,
LemmyContext,
blocking, DbPool, LemmyContext,
};
use activitystreams::{
activity::{
kind::{FollowType, UndoType},
Follow,
Undo,
Follow, Undo,
},
actor::{ApActor, Endpoints, Person},
object::{Image, Tombstone},

View File

@ -13,12 +13,8 @@ use lemmy_db::{
Crud,
};
use lemmy_utils::{
generate_actor_keypair,
get_apub_protocol_string,
make_apub_endpoint,
settings::Settings,
EndpointType,
LemmyError,
generate_actor_keypair, get_apub_protocol_string, make_apub_endpoint, settings::Settings,
EndpointType, LemmyError,
};
use log::info;

View File

@ -19,12 +19,8 @@ use lazy_static::lazy_static;
use lemmy_db::get_database_url_from_env;
use lemmy_rate_limit::{rate_limiter::RateLimiter, RateLimit};
use lemmy_server::{
apub::activity_queue::create_activity_queue,
blocking,
code_migrations::run_advanced_migrations,
routes::*,
websocket::chat_server::ChatServer,
LemmyContext,
apub::activity_queue::create_activity_queue, blocking, code_migrations::run_advanced_migrations,
routes::*, websocket::chat_server::ChatServer, LemmyContext,
};
use lemmy_utils::{settings::Settings, LemmyError, CACHE_CONTROL_REGEX};
use reqwest::Client;
@ -102,10 +98,7 @@ async fn main() -> Result<(), LemmyError> {
.configure(|cfg| images::config(cfg, &rate_limiter))
.configure(nodeinfo::config)
.configure(webfinger::config)
.service(actix_files::Files::new(
"/docs",
"/documentation",
))
.service(actix_files::Files::new("/docs", "/documentation"))
})
.bind((settings.bind, settings.port))?
.run()

View File

@ -10,8 +10,7 @@ use lemmy_db::{
site_view::SiteView,
user::User_,
user_mention_view::{UserMentionQueryBuilder, UserMentionView},
ListingType,
SortType,
ListingType, SortType,
};
use lemmy_utils::{markdown_to_html, settings::Settings, LemmyError};
use rss::{CategoryBuilder, ChannelBuilder, GuidBuilder, Item, ItemBuilder};

View File

@ -3,10 +3,7 @@ use actix_web::{error::ErrorBadRequest, web::Query, *};
use anyhow::anyhow;
use lemmy_db::{community::Community, user::User_};
use lemmy_utils::{
settings::Settings,
LemmyError,
WEBFINGER_COMMUNITY_REGEX,
WEBFINGER_USER_REGEX,
settings::Settings, LemmyError, WEBFINGER_COMMUNITY_REGEX, WEBFINGER_USER_REGEX,
};
use serde::{Deserialize, Serialize};

View File

@ -16,14 +16,7 @@ use diesel::{
use lemmy_api_structs::{comment::*, community::*, post::*, site::*, user::*};
use lemmy_rate_limit::RateLimit;
use lemmy_utils::{
location_info,
APIError,
CommunityId,
ConnectionId,
IPAddr,
LemmyError,
PostId,
UserId,
location_info, APIError, CommunityId, ConnectionId, IPAddr, LemmyError, PostId, UserId,
};
use rand::rngs::ThreadRng;
use reqwest::Client;