From 80a358ee54ee8933a5bb0a2827d8fdf523fd7956 Mon Sep 17 00:00:00 2001 From: ThetaDev Date: Sun, 9 Feb 2025 02:20:55 +0100 Subject: [PATCH] Revert "refactor!: rename n_http_retries option to n_request_attempts to be less misleading" This reverts commit b8cfe1b034a7470a9c4a587d709de7542d459091. --- src/client/mod.rs | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/src/client/mod.rs b/src/client/mod.rs index b3df2b2..8a2c31b 100644 --- a/src/client/mod.rs +++ b/src/client/mod.rs @@ -381,7 +381,7 @@ struct RustyPipeRef { http: Client, storage: Option>, reporter: Option>, - n_request_attempts: u32, + n_http_retries: u32, cache: CacheHolder, default_opts: RustyPipeOpts, user_agent: Cow<'static, str>, @@ -405,7 +405,7 @@ struct RustyPipeOpts { pub struct RustyPipeBuilder { storage: DefaultOpt>, reporter: DefaultOpt>, - n_request_attempts: u32, + n_http_retries: u32, timeout: DefaultOpt, user_agent: Option, default_opts: RustyPipeOpts, @@ -677,7 +677,7 @@ impl RustyPipeBuilder { storage: DefaultOpt::Default, reporter: DefaultOpt::Default, timeout: DefaultOpt::Default, - n_request_attempts: 2, + n_http_retries: 2, user_agent: None, storage_dir: None, botguard_bin: DefaultOpt::Default, @@ -783,7 +783,7 @@ impl RustyPipeBuilder { report_dir.push(DEFAULT_REPORT_DIR); Box::new(FileReporter::new(report_dir)) }), - n_request_attempts: self.n_request_attempts, + n_http_retries: self.n_http_retries, cache: CacheHolder { clients: cache_clients, deobf: AsyncRwLock::new(cdata.deobf), @@ -862,7 +862,7 @@ impl RustyPipeBuilder { self } - /// Set the maximum number of attempts for YouTube requests (at least 1). + /// Set the maximum number of retries for YouTube requests. /// /// If a request fails because of a serverside error and retries are enabled, /// RustyPipe waits 1 second before the next attempt. @@ -872,8 +872,8 @@ impl RustyPipeBuilder { /// /// **Default value**: 2 #[must_use] - pub fn n_request_attempts(mut self, n_retries: u32) -> Self { - self.n_request_attempts = n_retries.max(1); + pub fn n_http_retries(mut self, n_retries: u32) -> Self { + self.n_http_retries = n_retries.max(1); self } @@ -1091,7 +1091,7 @@ impl RustyPipe { /// Execute the given http request. async fn http_request(&self, request: &Request) -> Result { let mut last_resp = None; - for n in 0..=self.inner.n_request_attempts { + for n in 0..=self.inner.n_http_retries { let resp = self.inner.http.execute(request.try_clone().unwrap()).await; let err = match resp { @@ -1117,7 +1117,7 @@ impl RustyPipe { }; // Retry in case of a recoverable status code (server err, too many requests) - if n != self.inner.n_request_attempts { + if n != self.inner.n_http_retries { let ms = util::retry_delay(n, 1000, 60000, 3); tracing::warn!( "Retry attempt #{}. Error: {}. Waiting {} ms", @@ -2413,7 +2413,7 @@ impl RustyPipeQuery { ctx_src: &MapRespOptions<'_>, ) -> Result, Error> { let mut last_resp = None; - for n in 0..=self.client.inner.n_request_attempts { + for n in 0..=self.client.inner.n_http_retries { let resp = self .execute_request_attempt::(ctype, id, endpoint, body, ctx_src) .await?; @@ -2431,7 +2431,7 @@ impl RustyPipeQuery { // Remove the used visitor data from cache if the request resulted in a recoverable error self.remove_visitor_data(&resp.visitor_data); - if n != self.client.inner.n_request_attempts { + if n != self.client.inner.n_http_retries { let ms = util::retry_delay(n, 1000, 60000, 3); tracing::warn!( "Retry attempt #{}. Error: {}. Waiting {} ms",