From 541f34a207047b26547154e7d631005d456f12fd Mon Sep 17 00:00:00 2001
From: DanConwayDev <DanConwayDev@protonmail.com>
Date: Mon, 22 Dec 2025 14:23:46 +0000
Subject: sync: add req rate-limit detection and cooldown

---
 src/sync/relay_connection.rs | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'src/sync/relay_connection.rs')

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 _ =
-- 
cgit v1.2.3