feat: trigger relay refresh on contact updates

Author: tompro

crates/bcr-ebill-transport/src/handler/nostr_contact_processor.rs

@@ -17,18 +17,21 @@ pub struct NostrContactProcessor {
     transport: Arc<dyn TransportClientApi>,
     nostr_contact_store: Arc<dyn NostrContactStoreApi>,
     bitcoin_network: bitcoin::Network,
+    nostr_client: Option<Arc<crate::nostr::NostrClient>>,
 }
 
 impl NostrContactProcessor {
     pub fn new(
         transport: Arc<dyn TransportClientApi>,
         nostr_contact_store: Arc<dyn NostrContactStoreApi>,
         bitcoin_network: bitcoin::Network,
+        nostr_client: Option<Arc<crate::nostr::NostrClient>>,
     ) -> Self {
         Self {
             transport,
             nostr_contact_store,
             bitcoin_network,
+            nostr_client,
         }
     }
 }
@@ -73,8 +76,17 @@ impl NostrContactProcessor {
     async fn upsert_contact(&self, node_id: &NodeId, contact: &NostrContact) {
         if let Err(e) = self.nostr_contact_store.upsert(contact).await {
             error!("Failed to save nostr contact information for node_id {node_id}: {e}");
-        } else if let Err(e) = self.transport.add_contact_subscription(node_id).await {
-            error!("Failed to add nostr contact subscription for contact node_id {node_id}: {e}");
+        } else {
+            if let Err(e) = self.transport.add_contact_subscription(node_id).await {
+                error!("Failed to add nostr contact subscription for contact node_id {node_id}: {e}");
+            }
+            
+            // Trigger relay refresh to include new contact's relays
+            if let Some(ref client) = self.nostr_client {
+                if let Err(e) = client.refresh_relays().await {
+                    warn!("Failed to refresh relays after contact update for {node_id}: {e}");
+                }
+            }
         }
     }
 }

crates/bcr-ebill-transport/src/lib.rs

@@ -130,6 +130,7 @@ pub async fn create_transport_service(
         transport.clone(),
         db_context.nostr_contact_store.clone(),
         get_config().bitcoin_network(),
+        Some(client.clone()),
     ));
     let bill_processor = Arc::new(BillChainEventProcessor::new(
         db_context.bill_blockchain_store.clone(),
@@ -223,6 +224,7 @@ pub async fn create_nostr_consumer(
         transport.clone(),
         db_context.nostr_contact_store.clone(),
         get_config().bitcoin_network(),
+        Some(client.clone()),
     ));
 
     let bill_processor = Arc::new(BillChainEventProcessor::new(
@@ -338,6 +340,7 @@ pub async fn create_restore_account_service(
         nostr_client.clone(),
         db_context.nostr_contact_store.clone(),
         config.bitcoin_network(),
+        Some(nostr_client.clone()),
     ));
 
     let bill_processor = Arc::new(BillChainEventProcessor::new(