Add blank lines under each line with conn =

crates/api/src/comment/save.rs

@@ -19,6 +19,7 @@ impl Perform for SaveComment {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<CommentResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &SaveComment = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/comment_report/create.rs

@@ -26,6 +26,7 @@ impl Perform for CreateCommentReport {
     context: &Data<LemmyContext>,
   ) -> Result<CommentReportResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &CreateCommentReport = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
     let local_site = LocalSite::read(&mut conn).await?;

crates/api/src/comment_report/resolve.rs

@@ -20,6 +20,7 @@ impl Perform for ResolveCommentReport {
     context: &Data<LemmyContext>,
   ) -> Result<CommentReportResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &ResolveCommentReport = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/community/add_mod.rs

@@ -25,6 +25,7 @@ impl Perform for AddModToCommunity {
     context: &Data<LemmyContext>,
   ) -> Result<AddModToCommunityResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &AddModToCommunity = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/community/ban.rs

@@ -33,6 +33,7 @@ impl Perform for BanFromCommunity {
     context: &Data<LemmyContext>,
   ) -> Result<BanFromCommunityResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &BanFromCommunity = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/community/block.rs

@@ -25,6 +25,7 @@ impl Perform for BlockCommunity {
     context: &Data<LemmyContext>,
   ) -> Result<BlockCommunityResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &BlockCommunity = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/community/follow.rs

@@ -22,6 +22,7 @@ impl Perform for FollowCommunity {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<CommunityResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &FollowCommunity = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/community/hide.rs

@@ -22,6 +22,7 @@ impl Perform for HideCommunity {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<CommunityResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &HideCommunity = self;
 
     // Verify its a admin (only admin can hide or unhide it)

crates/api/src/community/transfer.rs

@@ -28,6 +28,7 @@ impl Perform for TransferCommunity {
     context: &Data<LemmyContext>,
   ) -> Result<GetCommunityResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &TransferCommunity = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/lib.rs

@@ -70,6 +70,7 @@ mod tests {
   #[serial]
   async fn test_should_not_validate_user_token_after_password_change() {
     let conn = &mut build_db_conn_for_tests().await;
+
     let secret = Secret::init(conn).await.unwrap();
     let settings = &SETTINGS.to_owned();
 

crates/api/src/local_user/add_admin.rs

@@ -22,6 +22,7 @@ impl Perform for AddAdmin {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<AddAdminResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &AddAdmin = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/local_user/ban_person.rs

@@ -25,6 +25,7 @@ impl Perform for BanPerson {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<BanPersonResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &BanPerson = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/local_user/block.rs

@@ -19,6 +19,7 @@ impl Perform for BlockPerson {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<BlockPersonResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &BlockPerson = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/local_user/change_password.rs

@@ -16,6 +16,7 @@ impl Perform for ChangePassword {
   #[tracing::instrument(skip(self, context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<LoginResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &ChangePassword = self;
     let local_user_view = local_user_view_from_jwt(data.auth.as_ref(), context).await?;
 

crates/api/src/local_user/change_password_after_reset.rs

@@ -19,6 +19,7 @@ impl Perform for PasswordChangeAfterReset {
   #[tracing::instrument(skip(self, context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<LoginResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &PasswordChangeAfterReset = self;
 
     // Fetch the user_id from the token

crates/api/src/local_user/get_captcha.rs

@@ -18,6 +18,7 @@ impl Perform for GetCaptcha {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let local_site = LocalSite::read(&mut conn).await?;
 
     if !local_site.captcha_enabled {

crates/api/src/local_user/list_banned.rs

@@ -14,6 +14,7 @@ impl Perform for GetBannedPersons {
 
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &GetBannedPersons = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/local_user/login.rs

@@ -16,6 +16,7 @@ impl Perform for Login {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<LoginResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &Login = self;
 
     let site_view = SiteView::read_local(&mut conn).await?;

crates/api/src/local_user/notifications/list_mentions.rs

@@ -28,6 +28,7 @@ impl Perform for GetPersonMentions {
     let show_bot_accounts = Some(local_user_view.local_user.show_bot_accounts);
 
     let mut conn = context.conn().await?;
+
     let mentions = PersonMentionQuery::builder()
       .conn(&mut conn)
       .recipient_id(person_id)

crates/api/src/local_user/notifications/list_replies.rs

@@ -25,6 +25,7 @@ impl Perform for GetReplies {
     let show_bot_accounts = Some(local_user_view.local_user.show_bot_accounts);
 
     let mut conn = context.conn().await?;
+
     let replies = CommentReplyQuery::builder()
       .conn(&mut conn)
       .recipient_id(person_id)

crates/api/src/local_user/notifications/mark_all_read.rs

@@ -19,6 +19,7 @@ impl Perform for MarkAllAsRead {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<GetRepliesResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &MarkAllAsRead = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
     let person_id = local_user_view.person.id;

crates/api/src/local_user/notifications/mark_mention_read.rs

@@ -22,6 +22,7 @@ impl Perform for MarkPersonMentionAsRead {
     context: &Data<LemmyContext>,
   ) -> Result<PersonMentionResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &MarkPersonMentionAsRead = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/local_user/notifications/mark_reply_read.rs

@@ -22,6 +22,7 @@ impl Perform for MarkCommentReplyAsRead {
     context: &Data<LemmyContext>,
   ) -> Result<CommentReplyResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/local_user/notifications/unread_count.rs

@@ -16,6 +16,7 @@ impl Perform for GetUnreadCount {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/local_user/report_count.rs

@@ -18,6 +18,7 @@ impl Perform for GetReportCount {
     context: &Data<LemmyContext>,
   ) -> Result<GetReportCountResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &GetReportCount = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/local_user/reset_password.rs

@@ -19,6 +19,7 @@ impl Perform for PasswordReset {
     context: &Data<LemmyContext>,
   ) -> Result<PasswordResetResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &PasswordReset = self;
 
     // Fetch that email

crates/api/src/local_user/save_settings.rs

@@ -34,6 +34,7 @@ impl Perform for SaveUserSettings {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<LoginResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &SaveUserSettings = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
     let site_view = SiteView::read_local(&mut conn).await?;

crates/api/src/local_user/verify_email.rs

@@ -19,6 +19,7 @@ impl Perform for VerifyEmail {
 
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let token = self.token.clone();
     let verification = EmailVerification::read_for_token(&mut conn, &token)
       .await

crates/api/src/post/feature.rs

@@ -29,6 +29,7 @@ impl Perform for FeaturePost {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<PostResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &FeaturePost = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/post/like.rs

@@ -28,6 +28,7 @@ impl Perform for CreatePostLike {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<PostResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &CreatePostLike = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
     let local_site = LocalSite::read(&mut conn).await?;

crates/api/src/post/lock.rs

@@ -27,6 +27,7 @@ impl Perform for LockPost {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<PostResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &LockPost = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/post/mark_read.rs

@@ -15,6 +15,7 @@ impl Perform for MarkPostAsRead {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/post/save.rs

@@ -19,6 +19,7 @@ impl Perform for SavePost {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<PostResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &SavePost = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/post_report/create.rs

@@ -23,6 +23,7 @@ impl Perform for CreatePostReport {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<PostReportResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &CreatePostReport = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
     let local_site = LocalSite::read(&mut conn).await?;

crates/api/src/post_report/list.rs

@@ -30,6 +30,7 @@ impl Perform for ListPostReports {
     let page = data.page;
     let limit = data.limit;
     let mut conn = context.conn().await?;
+
     let post_reports = PostReportQuery::builder()
       .conn(&mut conn)
       .my_person_id(person_id)

crates/api/src/post_report/resolve.rs

@@ -17,6 +17,7 @@ impl Perform for ResolvePostReport {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<PostReportResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &ResolvePostReport = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/private_message/mark_read.rs

@@ -22,6 +22,7 @@ impl Perform for MarkPrivateMessageAsRead {
     context: &Data<LemmyContext>,
   ) -> Result<PrivateMessageResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &MarkPrivateMessageAsRead = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/private_message_report/create.rs

@@ -23,6 +23,7 @@ impl Perform for CreatePrivateMessageReport {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let local_user_view = local_user_view_from_jwt(&self.auth, context).await?;
     let local_site = LocalSite::read(&mut conn).await?;
 

crates/api/src/private_message_report/list.rs

@@ -22,6 +22,7 @@ impl Perform for ListPrivateMessageReports {
     let page = self.page;
     let limit = self.limit;
     let mut conn = context.conn().await?;
+
     let private_message_reports = PrivateMessageReportQuery::builder()
       .conn(&mut conn)
       .unresolved_only(unresolved_only)

crates/api/src/private_message_report/resolve.rs

@@ -16,6 +16,7 @@ impl Perform for ResolvePrivateMessageReport {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let local_user_view = local_user_view_from_jwt(&self.auth, context).await?;
 
     is_admin(&local_user_view)?;

crates/api/src/site/federated_instances.rs

@@ -15,6 +15,7 @@ impl Perform for GetFederatedInstances {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let site_view = SiteView::read_local(&mut conn).await?;
     let federated_instances =
       build_federated_instances(&site_view.local_site, context.pool()).await?;

crates/api/src/site/leave_admin.rs

@@ -26,6 +26,7 @@ impl Perform for LeaveAdmin {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<GetSiteResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &LeaveAdmin = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/site/mod_log.rs

@@ -38,6 +38,7 @@ impl Perform for GetModlog {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<GetModlogResponse, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &GetModlog = self;
 
     let local_user_view = local_user_view_from_jwt_opt(data.auth.as_ref(), context).await;

crates/api/src/site/purge/comment.rs

@@ -21,6 +21,7 @@ impl Perform for PurgeComment {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &Self = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/site/purge/community.rs

@@ -22,6 +22,7 @@ impl Perform for PurgeCommunity {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &Self = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/site/purge/person.rs

@@ -22,6 +22,7 @@ impl Perform for PurgePerson {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &Self = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/site/purge/post.rs

@@ -22,6 +22,7 @@ impl Perform for PurgePost {
   #[tracing::instrument(skip(context))]
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data: &Self = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/site/registration_applications/approve.rs

@@ -22,6 +22,7 @@ impl Perform for ApproveRegistrationApplication {
 
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
 

crates/api/src/site/registration_applications/list.rs

@@ -16,6 +16,7 @@ impl Perform for ListRegistrationApplications {
 
   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
     let mut conn = context.conn().await?;
+
     let data = self;
     let local_user_view = local_user_view_from_jwt(&data.auth, context).await?;
     let local_site = LocalSite::read(&mut conn).await?;
@@ -29,6 +30,7 @@ impl Perform for ListRegistrationApplications {
     let page = data.page;
     let limit = data.limit;
     let mut conn = context.conn().await?;
+
     let registration_applications = RegistrationApplicationQuery::builder()
       .conn(&mut conn)
       .unread_only(unread_only)