pool: rename BATCH_EVENT_ITERATION_TIMEOUT to WAIT_FOR_OK_TIMEOUT

Signed-off-by: Yuki Kishimoto <[email protected]>

Author: yukibtc

crates/nostr-relay-pool/src/relay/constants.rs

@@ -7,7 +7,7 @@
 use core::ops::RangeInclusive;
 use core::time::Duration;
 
-pub(super) const BATCH_EVENT_ITERATION_TIMEOUT: Duration = Duration::from_secs(15);
+pub(super) const WAIT_FOR_OK_TIMEOUT: Duration = Duration::from_secs(15);
 pub(super) const WAIT_FOR_AUTHENTICATION_TIMEOUT: Duration = Duration::from_secs(7);
 pub(super) const DEFAULT_CONNECTION_TIMEOUT: Duration = Duration::from_secs(60);
 

crates/nostr-relay-pool/src/relay/inner.rs

@@ -23,9 +23,9 @@ use tokio::sync::mpsc::{self, Receiver, Sender};
 use tokio::sync::{broadcast, Mutex, MutexGuard, Notify, RwLock};
 
 use super::constants::{
-    BATCH_EVENT_ITERATION_TIMEOUT, DEFAULT_CONNECTION_TIMEOUT, JITTER_RANGE, MAX_RETRY_INTERVAL,
-    MIN_ATTEMPTS, MIN_SUCCESS_RATE, NEGENTROPY_BATCH_SIZE_DOWN, NEGENTROPY_FRAME_SIZE_LIMIT,
-    NEGENTROPY_HIGH_WATER_UP, NEGENTROPY_LOW_WATER_UP, PING_INTERVAL, WEBSOCKET_TX_TIMEOUT,
+    DEFAULT_CONNECTION_TIMEOUT, JITTER_RANGE, MAX_RETRY_INTERVAL, MIN_ATTEMPTS, MIN_SUCCESS_RATE,
+    NEGENTROPY_BATCH_SIZE_DOWN, NEGENTROPY_FRAME_SIZE_LIMIT, NEGENTROPY_HIGH_WATER_UP,
+    NEGENTROPY_LOW_WATER_UP, PING_INTERVAL, WAIT_FOR_OK_TIMEOUT, WEBSOCKET_TX_TIMEOUT,
 };
 use super::flags::AtomicRelayServiceFlags;
 use super::options::{RelayOptions, ReqExitPolicy, SubscribeAutoCloseOptions, SyncOptions};
@@ -1132,7 +1132,7 @@ impl InnerRelay {
         // Wait for OK
         // The event ID is already checked in `wait_for_ok` method
         let (status, message) = self
-            .wait_for_ok(&mut notifications, &event.id, BATCH_EVENT_ITERATION_TIMEOUT)
+            .wait_for_ok(&mut notifications, &event.id, WAIT_FOR_OK_TIMEOUT)
             .await?;
 
         // Check status

crates/nostr-relay-pool/src/relay/mod.rs

@@ -26,7 +26,7 @@ mod ping;
 pub mod stats;
 mod status;
 
-use self::constants::{BATCH_EVENT_ITERATION_TIMEOUT, WAIT_FOR_AUTHENTICATION_TIMEOUT};
+use self::constants::{WAIT_FOR_AUTHENTICATION_TIMEOUT, WAIT_FOR_OK_TIMEOUT};
 pub use self::error::Error;
 pub use self::flags::{AtomicRelayServiceFlags, FlagCheck, RelayServiceFlags};
 use self::inner::InnerRelay;
@@ -344,7 +344,7 @@ impl Relay {
 
         // Wait for OK
         self.inner
-            .wait_for_ok(notifications, &event.id, BATCH_EVENT_ITERATION_TIMEOUT)
+            .wait_for_ok(notifications, &event.id, WAIT_FOR_OK_TIMEOUT)
             .await
     }