From 466a009d8248aab274a9da419e4c0d83a4b9f466 Mon Sep 17 00:00:00 2001 From: DanConwayDev Date: Wed, 10 Dec 2025 21:24:21 +0000 Subject: feat(sync): broadcast synced events to WebSocket subscribers Enable recursive relay discovery by broadcasting synced events to WebSocket subscribers via LocalRelay.notify_event(). This allows the SelfSubscriber to receive 30617 announcements synced from external relays and discover additional relay URLs to connect to. Changes: - Pass LocalRelay to SyncManager::new() from main.rs - Add local_relay field to SyncManager struct - Call notify_event() after saving synced events to database - Enable test_recursive_relay_discovery_syncs_announcement test The test verifies that when relay_a syncs announcement_x from bootstrap relay_b (which lists relay_c), relay_a discovers and connects to relay_c to sync announcement_y. Fixes recursive relay discovery from bootstrap sync. --- src/main.rs | 1 + 1 file changed, 1 insertion(+) (limited to 'src/main.rs') diff --git a/src/main.rs b/src/main.rs index f887e42..31c7b63 100644 --- a/src/main.rs +++ b/src/main.rs @@ -58,6 +58,7 @@ async fn main() -> Result<()> { config.domain.clone(), relay_with_db.database.clone(), relay_with_db.write_policy.clone(), + relay_with_db.relay.clone(), &config, ); -- cgit v1.2.3