purgatory: git data sync applies state and saves event

2 files changed, 20 insertions, 0 deletions

diff --git a/src/nostr/policy/mod.rs b/src/nostr/policy/mod.rs
index 2a446fe..c3c5829 100644
--- a/src/nostr/policy/mod.rs
+++ b/src/nostr/policy/mod.rs
@@ -17,6 +17,7 @@ pub use state::{AlignmentResult, StatePolicy, StateResult};
 
 use super::SharedDatabase;
 use crate::purgatory::Purgatory;
+use nostr_relay_builder::LocalRelay;
 use std::sync::Arc;
 
 /// Shared context for all sub-policies
@@ -26,6 +27,8 @@ pub struct PolicyContext {
     pub database: SharedDatabase,
     pub git_data_path: std::path::PathBuf,
     pub purgatory: Arc<Purgatory>,
+    /// Local relay for notifying WebSocket subscribers (set after relay creation)
+    pub local_relay: Arc<std::sync::RwLock<Option<LocalRelay>>>,
 }
 
 impl PolicyContext {
@@ -40,6 +43,22 @@ impl PolicyContext {
             database,
             git_data_path: git_data_path.into(),
             purgatory,
+            local_relay: Arc::new(std::sync::RwLock::new(None)),
         }
     }
+
+    /// Set the local relay after it's been created.
+    ///
+    /// This is called after the relay is built since the relay depends on the policy
+    /// but the policy needs the relay for purgatory notifications.
+    pub fn set_local_relay(&self, relay: LocalRelay) {
+        let mut guard = self.local_relay.write().unwrap();
+        *guard = Some(relay);
+    }
+
+    /// Get a clone of the local relay if it's been set.
+    pub fn get_local_relay(&self) -> Option<LocalRelay> {
+        let guard = self.local_relay.read().unwrap();
+        guard.clone()
+    }
 }
diff --git a/src/nostr/policy/state.rs b/src/nostr/policy/state.rs
index 9ca3ee6..7521ef1 100644
--- a/src/nostr/policy/state.rs
+++ b/src/nostr/policy/state.rs
@@ -179,6 +179,7 @@ impl StatePolicy {
                 state.clone(),
                 self.ctx.database.clone(),
                 Some(self.ctx.domain.clone()),
+                self.ctx.get_local_relay(),
             );
 
             tracing::info!(