From 41122161b40aac8f835ddfd1d144dbc49db32c2f Mon Sep 17 00:00:00 2001
From: aumetra <aumetra@cryptolab.net>
Date: Sun, 3 Dec 2023 20:22:38 +0100
Subject: [PATCH] box

---
 crates/kitsune-activitypub/src/fetcher/object.rs | 2 +-
 crates/kitsune-activitypub/src/lib.rs            | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/crates/kitsune-activitypub/src/fetcher/object.rs b/crates/kitsune-activitypub/src/fetcher/object.rs
index 276d8d15f..f0b337b79 100644
--- 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
index 9d51c83a8..351ab0e3d 100644
--- 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| {