Move setting http_fetch_retry_limit into federation block (#2314)

diff --git a/config/defaults.hjson b/config/defaults.hjson
index acd956a8e3b5228bd07b379c20c68b2e60530220..69fc34755fba86e5b95bf18cf6cb963b79d8fa73 100644 (file)
--- a/config/defaults.hjson
+++ b/config/defaults.hjson
@@ -62,6 +62,8 @@
     # use allowlist only for remote communities, and posts/comments in local communities
     # (meaning remote communities will show content from arbitrary instances).
     strict_allowlist: true
+    # Maximum number of HTTP requests allowed to handle a single incoming activity (or a single object fetch through the search).
+    http_fetch_retry_limit: 25
     # Number of workers for sending outgoing activities. Search logs for Activity queue stats to
     # see information. If running number is consistently close to the worker_count, you should
     # increase it.
@@ -119,6 +121,4 @@
   slur_filter: "(\bThis\b)|(\bis\b)|(\bsample\b)"
   # Maximum length of local community and user names
   actor_name_max_length: 20
-  # Maximum number of HTTP requests allowed to handle a single incoming activity (or a single object fetch through the search).
-  http_fetch_retry_limit: 25
 }

diff --git a/crates/apub/src/fetcher/webfinger.rs b/crates/apub/src/fetcher/webfinger.rs
index c46935426b47a7014154c6a026e20a9ec4461ff7..8dda8ae1b26d0b672f7ac49255841d63b56cd735 100644 (file)
--- a/crates/apub/src/fetcher/webfinger.rs
+++ b/crates/apub/src/fetcher/webfinger.rs
@@ -47,7 +47,7 @@ where
   debug!("Fetching webfinger url: {}", &fetch_url);
 
   *request_counter += 1;
-  if *request_counter > context.settings().http_fetch_retry_limit {
+  if *request_counter > context.settings().federation.http_fetch_retry_limit {
     return Err(LemmyError::from_message("Request retry limit reached"));
   }
 

diff --git a/crates/apub/src/lib.rs b/crates/apub/src/lib.rs
index 910c66a70195d8a3bb181d7805bb68a67cb3b4f5..2f014e0dd1730dfa180a68a2a685f823aaca2e3a 100644 (file)
--- a/crates/apub/src/lib.rs
+++ b/crates/apub/src/lib.rs
@@ -31,7 +31,7 @@ fn local_instance(context: &LemmyContext) -> &'static LocalInstance {
   static LOCAL_INSTANCE: OnceCell<LocalInstance> = OnceCell::new();
   LOCAL_INSTANCE.get_or_init(|| {
     let settings = InstanceSettingsBuilder::default()
-      .http_fetch_retry_limit(context.settings().http_fetch_retry_limit)
+      .http_fetch_retry_limit(context.settings().federation.http_fetch_retry_limit)
       .worker_count(context.settings().federation.worker_count)
       .debug(context.settings().federation.debug)
       .verify_url_function(|url| check_apub_id_valid(url, &Settings::get()))

diff --git a/crates/utils/src/settings/structs.rs b/crates/utils/src/settings/structs.rs
index d6846f18551b8ef3d8688d55c5c1965ef881f035..70d91bde38a13edfbb7b5c2f5a7935b6a8ea73cb 100644 (file)
--- a/crates/utils/src/settings/structs.rs
+++ b/crates/utils/src/settings/structs.rs
@@ -46,9 +46,6 @@ pub struct Settings {
   /// Maximum length of local community and user names
   #[default(20)]
   pub actor_name_max_length: usize,
-  /// Maximum number of HTTP requests allowed to handle a single incoming activity (or a single object fetch through the search).
-  #[default(25)]
-  pub http_fetch_retry_limit: i32,
 
   /// Set the URL for opentelemetry exports. If you do not have an opentelemetry collector, do not set this option
   #[default(None)]
@@ -142,6 +139,9 @@ pub struct FederationConfig {
   /// (meaning remote communities will show content from arbitrary instances).
   #[default(true)]
   pub strict_allowlist: bool,
+  /// Maximum number of HTTP requests allowed to handle a single incoming activity (or a single object fetch through the search).
+  #[default(25)]
+  pub http_fetch_retry_limit: i32,
   /// Number of workers for sending outgoing activities. Search logs for "Activity queue stats" to
   /// see information. If "running" number is consistently close to the worker_count, you should
   /// increase it.