feat: timeout for relay connection

Author: sergey3bv

settings.tpl.toml

@@ -21,6 +21,8 @@ payment_retries_interval = 60
 [nostr]
 nsec_privkey = 'nsec1...'
 relays = ['ws://localhost:7000']
+# Seconds to wait for relay connections at startup before continuing (default: 5)
+# relay_connection_timeout_secs = 5
 
 [mostro]
 # NIP-01 Kind 0 Metadata (optional)

src/app/context.rs

@@ -262,6 +262,7 @@ pub mod test_utils {
                 nsec_privkey: "nsec13as48eum93hkg7plv526r9gjpa0uc52zysqm93pmnkca9e69x6tsdjmdxd"
                     .to_string(),
                 relays: vec!["wss://relay.test".to_string()],
+                relay_connection_timeout_secs: 5,
             },
             mostro: MostroSettings::default(),
             lightning: LightningSettings::default(),

src/config/types.rs

@@ -129,6 +129,13 @@ pub struct NostrSettings {
     pub nsec_privkey: String,
     /// Nostr relays list
     pub relays: Vec<String>,
+    /// Seconds to wait for relay connections at startup before continuing (default: 5)
+    #[serde(default = "default_relay_connection_timeout_secs")]
+    pub relay_connection_timeout_secs: u64,
+}
+
+fn default_relay_connection_timeout_secs() -> u64 {
+    5
 }
 /// RPC configuration settings
 #[derive(Debug, Deserialize, Clone)]

src/util.rs

@@ -779,8 +779,10 @@ pub async fn connect_nostr() -> Result<Client, MostroError> {
             .map_err(|e| MostroInternalErr(ServiceError::NostrError(e.to_string())))?;
     }
 
-    // Connect to relays and keep connection alive
+    let timeout =
+        std::time::Duration::from_secs(nostr_settings.relay_connection_timeout_secs);
     client.connect().await;
+    client.wait_for_connection(timeout).await;
 
     Ok(client)
 }