1 files changed, 37 insertions, 0 deletions

diff --git a/src/nostr/policy/mod.rs b/src/nostr/policy/mod.rs
index 1566b6c..78a09fc 100644
--- a/src/nostr/policy/mod.rs
+++ b/src/nostr/policy/mod.rs
@@ -20,6 +20,7 @@ pub use crate::git::sync::AlignmentResult;
 
 use super::SharedDatabase;
 use crate::purgatory::Purgatory;
+use crate::sync::{AddFilters, RepoSyncIndex};
 use nostr_relay_builder::LocalRelay;
 use std::sync::Arc;
 
@@ -34,6 +35,16 @@ pub struct PolicyContext {
     pub local_relay: Arc<std::sync::RwLock<Option<LocalRelay>>>,
     /// Configuration reference for policy settings (includes blacklists)
     pub config: crate::config::Config,
+    /// Optional repo sync index for triggering relay discovery when announcements
+    /// go to purgatory via user submission (not via the sync path).
+    /// Wrapped in Arc<RwLock> for interior mutability (PolicyContext is Clone).
+    pub repo_sync_index: Arc<std::sync::RwLock<Option<RepoSyncIndex>>>,
+    /// Optional sender for AddFilters actions to SyncManager.
+    /// Used to trigger relay discovery when user-submitted purgatory announcements
+    /// are registered with StateOnly sync level.
+    /// Wrapped in Arc<RwLock> for interior mutability (PolicyContext is Clone).
+    pub sync_action_tx:
+        Arc<std::sync::RwLock<Option<tokio::sync::mpsc::Sender<AddFilters>>>>,
 }
 
 impl PolicyContext {
@@ -51,6 +62,8 @@ impl PolicyContext {
             purgatory,
             local_relay: Arc::new(std::sync::RwLock::new(None)),
             config,
+            repo_sync_index: Arc::new(std::sync::RwLock::new(None)),
+            sync_action_tx: Arc::new(std::sync::RwLock::new(None)),
         }
     }
 
@@ -68,4 +81,28 @@ impl PolicyContext {
         let guard = self.local_relay.read().unwrap();
         guard.clone()
     }
+
+    /// Set the repo sync index for relay discovery from user-submitted purgatory announcements.
+    pub fn set_repo_sync_index(&self, index: RepoSyncIndex) {
+        let mut guard = self.repo_sync_index.write().unwrap();
+        *guard = Some(index);
+    }
+
+    /// Get a clone of the repo sync index if it's been set.
+    pub fn get_repo_sync_index(&self) -> Option<RepoSyncIndex> {
+        let guard = self.repo_sync_index.read().unwrap();
+        guard.clone()
+    }
+
+    /// Set the sync action sender for sending AddFilters actions to SyncManager.
+    pub fn set_sync_action_tx(&self, tx: tokio::sync::mpsc::Sender<AddFilters>) {
+        let mut guard = self.sync_action_tx.write().unwrap();
+        *guard = Some(tx);
+    }
+
+    /// Get a clone of the sync action sender if it's been set.
+    pub fn get_sync_action_tx(&self) -> Option<tokio::sync::mpsc::Sender<AddFilters>> {
+        let guard = self.sync_action_tx.read().unwrap();
+        guard.clone()
+    }
 }