1 files changed, 19 insertions, 1 deletions

diff --git a/src/sync/rejected_index.rs b/src/sync/rejected_index.rs
index f89783a..80d6b5b 100644
--- a/src/sync/rejected_index.rs
+++ b/src/sync/rejected_index.rs
@@ -85,7 +85,7 @@
 //! ```
 
 use nostr_sdk::{Event, EventId, PublicKey};
-use std::collections::HashMap;
+use std::collections::{HashMap, HashSet};
 use std::sync::{Arc, RwLock};
 use std::time::{Duration, Instant};
 
@@ -396,6 +396,24 @@ impl RejectedEventsIndex {
     pub fn cold_index_len(&self) -> usize {
         self.cold_index.len()
     }
+
+    /// Get all rejected event IDs (from both hot cache and cold index)
+    ///
+    /// Used for excluding rejected events from negentropy sync.
+    /// Note: This creates a snapshot - events may be added/removed concurrently.
+    pub fn get_all_event_ids(&self) -> HashSet<EventId> {
+        let mut ids = HashSet::new();
+
+        // Add from hot cache
+        let hot_entries = self.hot_cache.entries.read().unwrap();
+        ids.extend(hot_entries.keys().cloned());
+
+        // Add from cold index
+        let cold_entries = self.cold_index.entries.read().unwrap();
+        ids.extend(cold_entries.keys().cloned());
+
+        ids
+    }
 }
 
 #[cfg(test)]