box

kitsune-soc · Dec 3, 2023 · 4112216 · 4112216
1 parent b2bf32f
commit 4112216
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/crates/kitsune-activitypub/src/fetcher/object.rs b/crates/kitsune-activitypub/src/fetcher/object.rs
@@ -9,7 +9,7 @@ use scoped_futures::ScopedFutureExt;
 
 // Maximum call depth of fetching new posts. Prevents unbounded recursion.
 // Setting this to >=40 would cause the `fetch_infinitely_long_reply_chain` test to run into stack overflow
-pub const MAX_FETCH_DEPTH: u32 = 15;
+pub const MAX_FETCH_DEPTH: u32 = 20;
 
 impl Fetcher {
     #[instrument(skip(self))]

diff --git a/crates/kitsune-activitypub/src/lib.rs b/crates/kitsune-activitypub/src/lib.rs
@@ -8,7 +8,7 @@ extern crate tracing;
 use crate::error::{Error, Result};
 use diesel::{ExpressionMethods, SelectableHelper};
 use diesel_async::{AsyncPgConnection, RunQueryDsl};
-use futures_util::{stream, StreamExt, TryStreamExt};
+use futures_util::{stream, FutureExt, StreamExt, TryStreamExt};
 use http::Uri;
 use iso8601_timestamp::Timestamp;
 use kitsune_core::traits::{fetcher::PostFetchOptions, Fetcher as FetcherTrait};
@@ -286,7 +286,7 @@ pub async fn process_new_object(process_data: ProcessNewObject<'_>) -> Result<Po
         object,
         fetcher,
         search_backend,
-    } = preprocess_object(process_data).await?;
+    } = preprocess_object(process_data).boxed().await?;
 
     let post = db_pool
         .with_transaction(|tx| {