Fix negentropy fallback to REQ+EOSE when retry fails

1 files changed, 15 insertions, 6 deletions

diff --git a/src/sync/relay_connection.rs b/src/sync/relay_connection.rs
index 99fc4ea..5bc0fa3 100644
--- a/src/sync/relay_connection.rs
+++ b/src/sync/relay_connection.rs
@@ -282,9 +282,7 @@ impl RelayConnection {
                                     || msg.contains("negentropy");
 
                                 if is_negentropy_notice {
-                                    // Mark relay as not supporting NIP-77
-                                    self.nip77_supported
-                                        .store(2, std::sync::atomic::Ordering::Relaxed);
+                                    self.mark_negentropy_unsupported();
 
                                     tracing::info!(
                                         relay = %url,
@@ -478,6 +476,19 @@ impl RelayConnection {
         true
     }
 
+    /// Mark this relay as not supporting NIP-77 negentropy
+    ///
+    /// Called when we detect negentropy isn't working for this relay:
+    /// - NOTICE message contains negentropy-related error
+    /// - negentropy_sync_diff() fails
+    /// - Negentropy retry returns zero events
+    ///
+    /// Future batches will skip negentropy and use REQ+EOSE directly.
+    pub fn mark_negentropy_unsupported(&self) {
+        self.nip77_supported
+            .store(2, std::sync::atomic::Ordering::Relaxed);
+    }
+
     /// Perform a negentropy sync diff (dry run) to identify missing events
     ///
     /// This method performs NIP-77 negentropy reconciliation without downloading events.
@@ -564,9 +575,7 @@ impl RelayConnection {
                 Ok(reconciliation)
             }
             Err(e) => {
-                // Mark relay as not supporting NIP-77
-                self.nip77_supported
-                    .store(2, std::sync::atomic::Ordering::Relaxed);
+                self.mark_negentropy_unsupported();
 
                 // Log warning only once per relay to avoid spam
                 if !self