sync: add req rate-limit detection and cooldown

1 files changed, 7 insertions, 0 deletions

diff --git a/src/sync/relay_connection.rs b/src/sync/relay_connection.rs
index 5a61777..d69e1ce 100644
--- a/src/sync/relay_connection.rs
+++ b/src/sync/relay_connection.rs
@@ -27,6 +27,8 @@ pub enum RelayEvent {
     Event(Event, SubscriptionId),
     /// End of stored events for a subscription
     EndOfStoredEvents(SubscriptionId),
+    /// NOTICE message from relay
+    Notice(String),
     /// Connection was closed
     Closed(String),
     /// Shutdown notification
@@ -238,6 +240,11 @@ impl RelayConnection {
                                     break;
                                 }
                             }
+                            RelayMessage::Notice(msg) => {
+                                tracing::debug!(relay = %url, message = %msg, "Received NOTICE");
+                                let _ = event_sender.send(RelayEvent::Notice(msg.to_string())).await;
+                                // Don't break - continue processing events
+                            }
                             RelayMessage::Closed { message: msg, .. } => {
                                 tracing::info!(relay = %url, message = %msg, "Relay closed subscription");
                                 let _ =