1 files changed, 21 insertions, 0 deletions

diff --git a/src/git/sync.rs b/src/git/sync.rs
index 4b35023..b3fa11a 100644
--- a/src/git/sync.rs
+++ b/src/git/sync.rs
@@ -44,6 +44,7 @@ use crate::git::{self, oid_exists};
 use crate::nostr::builder::SharedDatabase;
 use crate::nostr::events::RepositoryState;
 use crate::purgatory::{can_apply_state, Purgatory};
+use crate::sync::{RepoSyncIndex, SyncLevel};
 
 /// Result of processing newly available git data.
 ///
@@ -809,6 +810,7 @@ pub fn extract_identifier_from_pr_event(event: &Event) -> Option<String> {
 /// * `local_relay` - Local relay for notifying WebSocket subscribers (optional)
 /// * `purgatory` - Purgatory instance to check for satisfiable events
 /// * `git_data_path` - Base path for git repositories
+/// * `repo_sync_index` - Optional repo sync index for upgrading sync level on promotion
 ///
 /// # Returns
 /// A `ProcessResult` describing what was processed
@@ -819,6 +821,7 @@ pub async fn process_newly_available_git_data(
     local_relay: Option<&nostr_relay_builder::LocalRelay>,
     purgatory: &Purgatory,
     git_data_path: &Path,
+    repo_sync_index: Option<RepoSyncIndex>,
 ) -> anyhow::Result<ProcessResult> {
     let mut result = ProcessResult::default();
 
@@ -848,6 +851,7 @@ pub async fn process_newly_available_git_data(
         local_relay,
         purgatory,
         git_data_path,
+        repo_sync_index.as_ref(),
     )
     .await;
     result.merge(announcement_result);
@@ -1284,6 +1288,7 @@ async fn process_purgatory_announcements(
     local_relay: Option<&nostr_relay_builder::LocalRelay>,
     purgatory: &Purgatory,
     git_data_path: &Path,
+    repo_sync_index: Option<&RepoSyncIndex>,
 ) -> ProcessResult {
     let mut result = ProcessResult::default();
 
@@ -1338,6 +1343,22 @@ async fn process_purgatory_announcements(
                     }
                 }
 
+                // Upgrade sync level to Full in repo_sync_index
+                if let Some(index) = repo_sync_index {
+                    let mut index = index.write().await;
+                    // Use hex pubkey format to match how repo_sync_index keys are built
+                    // (sync/mod.rs uses event.pubkey which is hex, not bech32)
+                    let repo_id = format!("30617:{}:{}", owner.to_hex(), identifier);
+                    if let Some(entry) = index.get_mut(&repo_id) {
+                        entry.sync_level = SyncLevel::Full;
+                        debug!(
+                            identifier = %identifier,
+                            repo_id = %repo_id,
+                            "Upgraded sync level to Full after announcement promotion"
+                        );
+                    }
+                }
+
                 result.announcements_released += 1;
             }
             Err(e) => {