feat: announcement purgatory

Extends purgatory to hold repository announcements until git data arrives,
preventing empty repositories from being served to clients.

When an announcement is received, a bare repo is created immediately and the
announcement is held in purgatory. It is only promoted and served once a git
push confirms real content exists. If no push arrives before expiry, the bare
repo is deleted and the announcement is silently discarded.

Key behaviours:
- Soft expiry: announcements are hidden from clients but kept alive while git
  pushes are in progress, reviving on successful push
- Expiry is extended when a matching state event or git push is observed
- NIP-09 deletion events remove announcements from purgatory
- Purgatory state (announcements, state events, PR events, expired set) is
  persisted to disk on graceful shutdown and restored on startup, with elapsed
  downtime subtracted from expiry deadlines
- Purgatory announcements drive StateOnly sync in the sync system so state
  events are fetched from listed relays before promotion
- SyncLevel added to RepoSyncIndex to distinguish purgatory repos (StateOnly)
  from promoted repos (Full L2+L3 sync)

1 files changed, 32 insertions, 227 deletions

diff --git a/tests/sync/discovery.rs b/tests/sync/discovery.rs
index 8ed80b5..d45a290 100644
--- a/tests/sync/discovery.rs
+++ b/tests/sync/discovery.rs
@@ -3,10 +3,6 @@
 //! Tests for relay discovery from announcement events.
 //! When a relay receives an announcement listing another relay,
 //! it should discover and connect to that relay to sync events.
-//!
-//! # Tests
-//! - Test 2: Direct Layer 3 discovery from Layer 2
-//! - Test 3: Recursive multi-hop Layer 3 discovery
 
 use std::time::Duration;
 
@@ -62,29 +58,26 @@ async fn test_discovers_layer3_via_layer2() {
     // 3. Create test keys
     let keys = Keys::generate();
 
-    // 4. Create a repository announcement that lists BOTH relays
-    let announcement = create_repo_announcement(
-        &keys,
-        &[&relay_a.domain(), &relay_b.domain()],
-        "test-repo-discovery",
-    );
-    let announcement_id = announcement.id;
+    // 4. Set up repository announcement on relay_a with git data
+    // (purgatory requires git data before announcements are accepted)
+    let repo_id = "test-repo-discovery";
+    let domains = vec![relay_a.domain(), relay_b.domain()];
+    let domain_refs: Vec<&str> = domains.iter().map(|s| s.as_str()).collect();
 
+    let (announcement, _git_dir_a) =
+        setup_announcement_on_relay(&relay_a, &keys, &domain_refs, repo_id).await;
+    let announcement_id = announcement.id;
     println!(
-        "Created announcement {} (kind {})",
-        announcement_id,
-        announcement.kind.as_u16()
+        "Announcement {} set up on relay_a with git data",
+        announcement_id
     );
-    for tag in announcement.tags.iter() {
-        println!("  Tag: {:?}", tag.as_slice());
-    }
 
     // 5. Build the repo coordinate for the 'a' tag in the patch
     let repo_coord = format!(
         "{}:{}:{}",
         Kind::GitRepoAnnouncement.as_u16(),
         keys.public_key().to_hex(),
-        "test-repo-discovery"
+        repo_id
     );
 
     // 6. Create a patch event (Layer 2) that references the announcement
@@ -97,22 +90,13 @@ async fn test_discovers_layer3_via_layer2() {
     let patch_id = patch.id;
 
     println!("Created patch {} (kind {})", patch_id, patch.kind.as_u16());
-    for tag in patch.tags.iter() {
-        println!("  Tag: {:?}", tag.as_slice());
-    }
 
-    // 7. Send announcement and patch to relay_a ONLY
+    // 7. Send patch to relay_a
     let client_a = TestClient::new(relay_a.url(), keys.clone())
         .await
         .expect("Failed to connect to relay_a");
 
     client_a
-        .send_event(&announcement)
-        .await
-        .expect("Failed to send announcement to relay_a");
-    println!("Announcement sent to relay_a");
-
-    client_a
         .send_event(&patch)
         .await
         .expect("Failed to send patch to relay_a");
@@ -120,18 +104,10 @@ async fn test_discovers_layer3_via_layer2() {
 
     client_a.disconnect().await;
 
-    // 8. Send announcement to relay_b directly (triggers discovery of relay_a)
-    let client_b = TestClient::new(relay_b.url(), keys.clone())
-        .await
-        .expect("Failed to connect to relay_b");
-
-    client_b
-        .send_event(&announcement)
-        .await
-        .expect("Failed to send announcement to relay_b");
-    println!("Announcement sent to relay_b (should trigger discovery of relay_a)");
-
-    client_b.disconnect().await;
+    // 8. Set up announcement on relay_b (triggers discovery of relay_a)
+    let (_announcement_b, _git_dir_b) =
+        setup_announcement_on_relay(&relay_b, &keys, &domain_refs, repo_id).await;
+    println!("Announcement set up on relay_b (should trigger discovery of relay_a)");
 
     // 9. Wait for relay_b to discover relay_a and sync the patch
     println!("Waiting 3s for relay_b to discover relay_a and sync patch...");
@@ -197,19 +173,20 @@ async fn test_relay_discovery_via_announcements_with_historic_sync() {
     // 3. Create test keys
     let keys = Keys::generate();
 
-    // 4. Create the event chain on relay_a:
+    // 4. Set up repository on relay_a with git data and a Layer 2 issue
 
-    // Layer 1: Repository announcement
-    let announcement = create_repo_announcement(
-        &keys,
-        &[&relay_a.domain(), &relay_b.domain()],
-        "test-repo-chain",
-    );
+    // Layer 1: Set up announcement with git data
+    let domains = vec![relay_a.domain(), relay_b.domain()];
+    let domain_refs: Vec<&str> = domains.iter().map(|s| s.as_str()).collect();
+    let repo_id = "test-repo-chain";
+
+    let (announcement, _git_dir_a) =
+        setup_announcement_on_relay(&relay_a, &keys, &domain_refs, repo_id).await;
     let announcement_id = announcement.id;
-    println!("Created announcement {} (Layer 1)", announcement_id);
+    println!("Announcement {} set up on relay_a with git data (Layer 1)", announcement_id);
 
     // Build repo coordinate for Layer 2 reference
-    let repo_coord = repo_coord(&keys, "test-repo-chain");
+    let repo_coord = repo_coord(&keys, repo_id);
 
     // Layer 2: Issue referencing the repo
     let issue = build_layer2_issue_event(&keys, &repo_coord, "Test issue for chain discovery")
@@ -217,35 +194,23 @@ async fn test_relay_discovery_via_announcements_with_historic_sync() {
     let issue_id = issue.id;
     println!("Created issue {} (Layer 2)", issue_id);
 
-    // 5. Send all events to relay_a
+    // 5. Send issue to relay_a
     let client_a = TestClient::new(relay_a.url(), keys.clone())
         .await
         .expect("Failed to connect to relay_a");
 
     client_a
-        .send_event(&announcement)
-        .await
-        .expect("Failed to send announcement");
-    client_a
         .send_event(&issue)
         .await
         .expect("Failed to send issue");
 
-    println!("Events sent to relay_a");
+    println!("Issue sent to relay_a");
     client_a.disconnect().await;
 
-    // 6. Send only the announcement to relay_b (triggers discovery)
-    let client_b = TestClient::new(relay_b.url(), keys.clone())
-        .await
-        .expect("Failed to connect to relay_b");
-
-    client_b
-        .send_event(&announcement)
-        .await
-        .expect("Failed to send announcement to relay_b");
-    println!("Announcement sent to relay_b (should trigger discovery)");
-
-    client_b.disconnect().await;
+    // 6. Set up announcement on relay_b (triggers discovery of relay_a)
+    let (_announcement_b, _git_dir_b) =
+        setup_announcement_on_relay(&relay_b, &keys, &domain_refs, repo_id).await;
+    println!("Announcement set up on relay_b (should trigger discovery of relay_a)");
 
     // 7. Wait for sync
     println!("Waiting 3s for Layer 2 sync...");
@@ -271,163 +236,3 @@ async fn test_relay_discovery_via_announcements_with_historic_sync() {
     );
 }
 
-/// Test 3: 3-relay recursive discovery - relay discovers third relay through bootstrap
-///
-/// Scenario:
-/// ```text
-///     relay_a (SUT)       relay_b (bootstrap)     relay_c (discovered)
-///         │                     │                       │
-///         │                     │ has announcement_x    │ has announcement_y
-///         │                     │ listing A+B+C         │ listing A+C
-///         │                     │                       │
-///         ├────connect──────────►                       │
-///         │◄───sync announcement_x───────────────────────
-///         │                                             │
-///         │    discovers relay_c from announcement_x    │
-///         │                                             │
-///         ├─────────────connect─────────────────────────►
-///         │◄────────────sync announcement_y─────────────┘
-/// ```
-///
-/// This tests that relay_a:
-/// 1. Connects to relay_b (configured as bootstrap)
-/// 2. Receives announcement_x which lists relay_c
-/// 3. Discovers and connects to relay_c
-/// 4. Syncs announcement_y from relay_c
-///
-#[tokio::test]
-async fn test_recursive_relay_discovery_via_announcements_with_historic_sync() {
-    // 1. Start all three relays
-
-    // relay_b - will be the bootstrap relay, has announcement_x
-    let relay_b = TestRelay::start().await;
-    println!(
-        "relay_b (bootstrap) started at {} (domain: {})",
-        relay_b.url(),
-        relay_b.domain()
-    );
-
-    // relay_c - will be discovered via announcement_x, has announcement_y
-    let relay_c = TestRelay::start().await;
-    println!(
-        "relay_c (to be discovered) started at {} (domain: {})",
-        relay_c.url(),
-        relay_c.domain()
-    );
-
-    // relay_a - SUT, starts with relay_b as bootstrap
-    let relay_a = TestRelay::start_with_sync(Some(relay_b.url().to_string())).await;
-    println!(
-        "relay_a (SUT) started at {} (domain: {})",
-        relay_a.url(),
-        relay_a.domain()
-    );
-
-    // 2. Create test keys (one for each announcement)
-    let keys_x = Keys::generate();
-    let keys_y = Keys::generate();
-
-    // 3. Create announcement_x on relay_b (lists all three relays: A+B+C)
-    let announcement_x = create_repo_announcement(
-        &keys_x,
-        &[&relay_a.domain(), &relay_b.domain(), &relay_c.domain()],
-        "repo-x-all-relays",
-    );
-    let announcement_x_id = announcement_x.id;
-    println!("Created announcement_x {} listing A+B+C", announcement_x_id);
-    for tag in announcement_x.tags.iter() {
-        println!("  Tag: {:?}", tag.as_slice());
-    }
-
-    // 4. Create announcement_y on relay_c (lists only A+C, NOT B)
-    let announcement_y = create_repo_announcement(
-        &keys_y,
-        &[&relay_a.domain(), &relay_c.domain()],
-        "repo-y-ac-only",
-    );
-    let announcement_y_id = announcement_y.id;
-    println!(
-        "Created announcement_y {} listing A+C only",
-        announcement_y_id
-    );
-    for tag in announcement_y.tags.iter() {
-        println!("  Tag: {:?}", tag.as_slice());
-    }
-
-    // 5. Send announcement_x to relay_b only
-    let client_b = TestClient::new(relay_b.url(), keys_x.clone())
-        .await
-        .expect("Failed to connect to relay_b");
-
-    client_b
-        .send_event(&announcement_x)
-        .await
-        .expect("Failed to send announcement_x to relay_b");
-    println!("announcement_x sent to relay_b");
-
-    client_b.disconnect().await;
-
-    // 6. Send announcement_y to relay_c only
-    let client_c = TestClient::new(relay_c.url(), keys_y.clone())
-        .await
-        .expect("Failed to connect to relay_c");
-
-    client_c
-        .send_event(&announcement_y)
-        .await
-        .expect("Failed to send announcement_y to relay_c");
-    println!("announcement_y sent to relay_c");
-
-    client_c.disconnect().await;
-
-    // 7. Wait for relay_a to:
-    //    - Sync from bootstrap relay_b (gets announcement_x)
-    //    - Discover relay_c from announcement_x's relays tag
-    //    - Connect to relay_c and sync announcement_y
-    println!("Waiting 5s for recursive relay discovery...");
-    tokio::time::sleep(Duration::from_secs(5)).await;
-
-    // 8. Verify announcement_x was synced to relay_a (from bootstrap relay_b)
-    let filter_x = Filter::new()
-        .kind(Kind::GitRepoAnnouncement)
-        .author(keys_x.public_key());
-
-    let announcement_x_synced =
-        wait_for_event_on_relay(relay_a.url(), filter_x, Duration::from_secs(5)).await;
-
-    println!(
-        "announcement_x {} synced to relay_a: {}",
-        announcement_x_id, announcement_x_synced
-    );
-
-    // 9. Verify announcement_y was synced to relay_a (from discovered relay_c)
-    let filter_y = Filter::new()
-        .kind(Kind::GitRepoAnnouncement)
-        .author(keys_y.public_key());
-
-    let announcement_y_synced =
-        wait_for_event_on_relay(relay_a.url(), filter_y, Duration::from_secs(5)).await;
-
-    println!(
-        "announcement_y {} synced to relay_a: {}",
-        announcement_y_id, announcement_y_synced
-    );
-
-    // 10. Cleanup
-    relay_a.stop().await;
-    relay_b.stop().await;
-    relay_c.stop().await;
-
-    // 11. Assertions
-    assert!(
-        announcement_x_synced,
-        "announcement_x {} should have synced from bootstrap relay_b to relay_a",
-        announcement_x_id
-    );
-
-    assert!(
-        announcement_y_synced,
-        "announcement_y {} should have synced from discovered relay_c to relay_a (recursive discovery)",
-        announcement_y_id
-    );
-}