Cargo.toml

@@ -90,7 +90,7 @@ lemmy_db_views = { version = "=0.19.6-beta.7", path = "./crates/db_views" }
 lemmy_db_views_actor = { version = "=0.19.6-beta.7", path = "./crates/db_views_actor" }
 lemmy_db_views_moderator = { version = "=0.19.6-beta.7", path = "./crates/db_views_moderator" }
 lemmy_federate = { version = "=0.19.6-beta.7", path = "./crates/federate" }
-activitypub_federation = { version = "0.6.0-alpha2", default-features = false, features = [
+activitypub_federation = { version = "0.6.0-alpha1", default-features = false, features = [
   "actix-web",
 ] }
 diesel = "2.1.6"

api_tests/src/comment.spec.ts

@@ -858,26 +858,3 @@ test("Dont send a comment reply to a blocked community", async () => {
   blockRes = await blockCommunity(beta, newCommunityId, false);
   expect(blockRes.blocked).toBe(false);
 });
-
-/// Fetching a deeply nested comment can lead to stack overflow as all parent comments are also
-/// fetched recursively. Ensure that it works properly.
-test("Fetch a deeply nested comment", async () => {
-  let lastComment;
-  for (let i = 0; i < 50; i++) {
-    let commentRes = await createComment(
-      alpha,
-      postOnAlphaRes.post_view.post.id,
-      lastComment?.comment_view.comment.id,
-    );
-    expect(commentRes.comment_view.comment).toBeDefined();
-    lastComment = commentRes;
-  }
-
-  let betaComment = await resolveComment(
-    beta,
-    lastComment!.comment_view.comment,
-  );
-
-  expect(betaComment!.comment!.comment).toBeDefined();
-  expect(betaComment?.comment?.post).toBeDefined();
-});

crates/api/src/site/leave_admin.rs

@@ -76,7 +76,5 @@ pub async fn leave_admin(
     admin_oauth_providers: None,
     blocked_urls,
     tagline,
-    taglines: vec![],
-    custom_emojis: vec![],
   }))
 }

crates/api_common/src/oauth_provider.rs

@@ -5,7 +5,6 @@ use serde_with::skip_serializing_none;
 use ts_rs::TS;
 use url::Url;
 
-#[skip_serializing_none]
 #[derive(Debug, Serialize, Deserialize, Clone)]
 #[cfg_attr(feature = "full", derive(TS))]
 #[cfg_attr(feature = "full", ts(export))]

crates/api_common/src/site.rs

@@ -306,8 +306,6 @@ pub struct EditSite {
 /// The response for a site.
 pub struct SiteResponse {
   pub site_view: SiteView,
-  /// deprecated, use field `tagline` or /api/v3/tagline/list
-  pub taglines: Vec<()>,
 }
 
 #[skip_serializing_none]
@@ -322,10 +320,6 @@ pub struct GetSiteResponse {
   pub my_user: Option<MyUserInfo>,
   pub all_languages: Vec<Language>,
   pub discussion_languages: Vec<LanguageId>,
-  /// deprecated, use field `tagline` or /api/v3/tagline/list
-  pub taglines: Vec<()>,
-  /// deprecated, use /api/v3/custom_emoji/list
-  pub custom_emojis: Vec<()>,
   /// If the site has any taglines, a random one is included here for displaying
   pub tagline: Option<Tagline>,
   /// A list of external auth methods your site supports.

crates/api_crud/src/comment/create.rs

@@ -30,9 +30,10 @@ use lemmy_db_views::structs::{LocalUserView, PostView};
 use lemmy_utils::{
   error::{LemmyErrorExt, LemmyErrorType, LemmyResult},
   utils::{mention::scrape_text_for_mentions, validation::is_valid_body_field},
-  MAX_COMMENT_DEPTH_LIMIT,
 };
 
+const MAX_COMMENT_DEPTH_LIMIT: usize = 100;
+
 #[tracing::instrument(skip(context))]
 pub async fn create_comment(
   data: Json<CreateComment>,

crates/api_crud/src/site/create.rs

@@ -139,10 +139,7 @@ pub async fn create_site(
     local_site_rate_limit_to_rate_limit_config(&site_view.local_site_rate_limit);
   context.rate_limit_cell().set_config(rate_limit_config);
 
-  Ok(Json(SiteResponse {
-    site_view,
-    taglines: vec![],
-  }))
+  Ok(Json(SiteResponse { site_view }))
 }
 
 fn validate_create_payload(local_site: &LocalSite, create_site: &CreateSite) -> LemmyResult<()> {

crates/api_crud/src/site/read.rs

@@ -59,8 +59,6 @@ pub async fn get_site(
         tagline,
         oauth_providers: Some(oauth_providers),
         admin_oauth_providers: Some(admin_oauth_providers),
-        taglines: vec![],
-        custom_emojis: vec![],
       })
     })
     .await

crates/api_crud/src/site/update.rs

@@ -193,10 +193,7 @@ pub async fn update_site(
     local_site_rate_limit_to_rate_limit_config(&site_view.local_site_rate_limit);
   context.rate_limit_cell().set_config(rate_limit_config);
 
-  Ok(Json(SiteResponse {
-    site_view,
-    taglines: vec![],
-  }))
+  Ok(Json(SiteResponse { site_view }))
 }
 
 fn validate_update_payload(local_site: &LocalSite, edit_site: &EditSite) -> LemmyResult<()> {

crates/apub/src/api/user_settings_backup.rs

@@ -103,16 +103,13 @@ pub async fn import_settings(
   context: Data<LemmyContext>,
 ) -> LemmyResult<Json<SuccessResponse>> {
   let person_form = PersonUpdateForm {
-    display_name: data.display_name.clone().map(Some),
-    bio: data.bio.clone().map(Some),
-    matrix_user_id: data.bio.clone().map(Some),
+    display_name: Some(data.display_name.clone()),
+    bio: Some(data.bio.clone()),
+    matrix_user_id: Some(data.matrix_id.clone()),
     bot_account: data.bot_account,
     ..Default::default()
   };
-  // ignore error in case form is empty
-  Person::update(&mut context.pool(), local_user_view.person.id, &person_form)
-    .await
-    .ok();
+  Person::update(&mut context.pool(), local_user_view.person.id, &person_form).await?;
 
   let local_user_form = LocalUserUpdateForm {
     show_nsfw: data.settings.as_ref().map(|s| s.show_nsfw),
@@ -315,9 +312,8 @@ where
 #[expect(clippy::indexing_slicing)]
 mod tests {
 
-  use crate::api::user_settings_backup::{export_settings, import_settings};
+  use crate::api::user_settings_backup::{export_settings, import_settings, UserSettingsBackup};
   use activitypub_federation::config::Data;
-  use actix_web::web::Json;
   use lemmy_api_common::context::LemmyContext;
   use lemmy_db_schema::{
     source::{
@@ -405,6 +401,45 @@ mod tests {
     Ok(())
   }
 
+  #[tokio::test]
+  #[serial]
+  async fn test_settings_partial_import() -> LemmyResult<()> {
+    let context = LemmyContext::init_test_context().await;
+
+    let export_user =
+      create_user("hanna".to_string(), Some("my bio".to_string()), &context).await?;
+
+    let community_form = CommunityInsertForm::new(
+      export_user.person.instance_id,
+      "testcom".to_string(),
+      "testcom".to_string(),
+      "pubkey".to_string(),
+    );
+    let community = Community::create(&mut context.pool(), &community_form).await?;
+    let follower_form = CommunityFollowerForm {
+      community_id: community.id,
+      person_id: export_user.person.id,
+      pending: false,
+    };
+    CommunityFollower::follow(&mut context.pool(), &follower_form).await?;
+
+    let backup = export_settings(export_user.clone(), context.reset_request_count()).await?;
+
+    let import_user = create_user("charles".to_string(), None, &context).await?;
+
+    let backup2 = UserSettingsBackup {
+      followed_communities: backup.followed_communities.clone(),
+      ..Default::default()
+    };
+    import_settings(
+      actix_web::web::Json(backup2),
+      import_user.clone(),
+      context.reset_request_count(),
+    )
+    .await?;
+    Ok(())
+  }
+
   #[tokio::test]
   #[serial]
   async fn disallow_large_backup() -> LemmyResult<()> {
@@ -440,33 +475,4 @@ mod tests {
     LocalUser::delete(&mut context.pool(), import_user.local_user.id).await?;
     Ok(())
   }
-
-  #[tokio::test]
-  #[serial]
-  async fn import_partial_backup() -> LemmyResult<()> {
-    let context = LemmyContext::init_test_context().await;
-
-    let import_user =
-      create_user("hanna".to_string(), Some("my bio".to_string()), &context).await?;
-
-    let backup =
-      serde_json::from_str("{\"bot_account\": true, \"settings\": {\"theme\": \"my_theme\"}}")?;
-    import_settings(
-      Json(backup),
-      import_user.clone(),
-      context.reset_request_count(),
-    )
-    .await?;
-
-    let import_user_updated =
-      LocalUserView::read(&mut context.pool(), import_user.local_user.id).await?;
-    // mark as bot account
-    assert!(import_user_updated.person.bot_account);
-    // dont remove existing bio
-    assert_eq!(import_user.person.bio, import_user_updated.person.bio);
-    // local_user can be deserialized without id/person_id fields
-    assert_eq!("my_theme", import_user_updated.local_user.theme);
-
-    Ok(())
-  }
 }

crates/apub/src/protocol/objects/note.rs

@@ -20,9 +20,10 @@ use lemmy_db_schema::{
   source::{community::Community, post::Post},
   traits::Crud,
 };
-use lemmy_utils::{error::LemmyResult, LemmyErrorType, MAX_COMMENT_DEPTH_LIMIT};
+use lemmy_utils::error::LemmyResult;
 use serde::{Deserialize, Serialize};
 use serde_with::skip_serializing_none;
+use std::ops::Deref;
 use url::Url;
 
 #[skip_serializing_none]
@@ -57,19 +58,9 @@ impl Note {
     &self,
     context: &Data<LemmyContext>,
   ) -> LemmyResult<(ApubPost, Option<ApubComment>)> {
-    // We use recursion here to fetch the entire comment chain up to the top-level parent. This is
-    // necessary because we need to know the post and parent comment in order to insert a new
-    // comment. However it can also lead to stack overflow when fetching many comments recursively.
-    // To avoid this we check the request count against max comment depth, which based on testing
-    // can be handled without risking stack overflow. This is not a perfect solution, because in
-    // some cases we have to fetch user profiles too, and reach the limit after only 25 comments
-    // or so.
-    // A cleaner solution would be converting the recursion into a loop, but that is tricky.
-    if context.request_count() > MAX_COMMENT_DEPTH_LIMIT as u32 {
-      Err(LemmyErrorType::MaxCommentDepthReached)?;
-    }
-    let parent = self.in_reply_to.dereference(context).await?;
-    match parent {
+    // Fetch parent comment chain in a box, otherwise it can cause a stack overflow.
+    let parent = Box::pin(self.in_reply_to.dereference(context).await?);
+    match parent.deref() {
       PostOrComment::Post(p) => Ok((p.clone(), None)),
       PostOrComment::Comment(c) => {
         let post_id = c.post_id;

crates/db_schema/src/impls/post.rs

@@ -257,9 +257,9 @@ impl Post {
     post::table
       .inner_join(person::table)
       .inner_join(community::table)
-      // find all posts which have scheduled_publish_time that is in the  future
+      // find all posts which have scheduled_publish_time that is in the  past
       .filter(post::scheduled_publish_time.is_not_null())
-      .filter(coalesce(post::scheduled_publish_time, now()).gt(now()))
+      .filter(coalesce(post::scheduled_publish_time, now()).lt(now()))
       // make sure the post and community are still around
       .filter(not(post::deleted.or(post::removed)))
       .filter(not(community::removed.or(community::deleted)))
@@ -404,7 +404,6 @@ mod tests {
     traits::{Crud, Likeable, Saveable},
     utils::build_db_pool_for_tests,
   };
-  use chrono::DateTime;
   use lemmy_utils::error::LemmyResult;
   use pretty_assertions::assert_eq;
   use serial_test::serial;
@@ -445,12 +444,6 @@ mod tests {
     );
     let inserted_post2 = Post::create(pool, &new_post2).await?;
 
-    let new_scheduled_post = PostInsertForm {
-      scheduled_publish_time: Some(DateTime::from_timestamp_nanos(i64::MAX)),
-      ..PostInsertForm::new("beans".into(), inserted_person.id, inserted_community.id)
-    };
-    let inserted_scheduled_post = Post::create(pool, &new_scheduled_post).await?;
-
     let expected_post = Post {
       id: inserted_post.id,
       name: "A test post".into(),
@@ -520,10 +513,6 @@ mod tests {
     };
     let updated_post = Post::update(pool, inserted_post.id, &new_post_update).await?;
 
-    // Scheduled post count
-    let scheduled_post_count = Post::user_scheduled_post_count(inserted_person.id, pool).await?;
-    assert_eq!(1, scheduled_post_count);
-
     let like_removed = PostLike::remove(pool, inserted_person.id, inserted_post.id).await?;
     assert_eq!(1, like_removed);
     let saved_removed = PostSaved::unsave(pool, &post_saved_form).await?;
@@ -537,13 +526,10 @@ mod tests {
       PostRead::mark_as_unread(pool, inserted_post2.id, inserted_person.id).await?;
     assert_eq!(1, read_removed_2);
 
-    let num_deleted = Post::delete(pool, inserted_post.id).await?
-      + Post::delete(pool, inserted_post2.id).await?
-      + Post::delete(pool, inserted_scheduled_post.id).await?;
-
-    assert_eq!(3, num_deleted);
+    let num_deleted =
+      Post::delete(pool, inserted_post.id).await? + Post::delete(pool, inserted_post2.id).await?;
+    assert_eq!(2, num_deleted);
     Community::delete(pool, inserted_community.id).await?;
-
     Person::delete(pool, inserted_person.id).await?;
     Instance::delete(pool, inserted_instance.id).await?;
 

crates/db_schema/src/schema.rs

@@ -769,7 +769,7 @@ diesel::table! {
         featured_local -> Bool,
         url_content_type -> Nullable<Text>,
         alt_text -> Nullable<Text>,
-        scheduled_publish_time -> Nullable<Timestamptz>,
+        scheduled_publish_time -> Nullable<Timestamptz>
     }
 }
 

crates/db_schema/src/source/local_user.rs

@@ -14,12 +14,11 @@ use serde_with::skip_serializing_none;
 use ts_rs::TS;
 
 #[skip_serializing_none]
-#[derive(Clone, PartialEq, Eq, Debug, Serialize, Deserialize, Default)]
+#[derive(Clone, PartialEq, Eq, Debug, Serialize, Deserialize)]
 #[cfg_attr(feature = "full", derive(Queryable, Selectable, Identifiable, TS))]
 #[cfg_attr(feature = "full", diesel(table_name = local_user))]
 #[cfg_attr(feature = "full", diesel(check_for_backend(diesel::pg::Pg)))]
 #[cfg_attr(feature = "full", ts(export))]
-#[serde(default)]
 /// A local user.
 pub struct LocalUser {
   pub id: LocalUserId,

crates/utils/src/lib.rs

@@ -29,8 +29,6 @@ pub const CACHE_DURATION_FEDERATION: Duration = Duration::from_secs(60);
 
 pub const CACHE_DURATION_API: Duration = Duration::from_secs(1);
 
-pub const MAX_COMMENT_DEPTH_LIMIT: usize = 50;
-
 #[macro_export]
 macro_rules! location_info {
   () => {