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