diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-10 21:24:21 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-10 21:24:21 +0000 |
| commit | 466a009d8248aab274a9da419e4c0d83a4b9f466 (patch) | |
| tree | 19d69825c5013e8ba39721b5ccaf9a84665ce570 /src/main.rs | |
| parent | b6c908599c1e63852b8d3b4b20caae344e37a34a (diff) | |
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.
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 1 |
1 files changed, 1 insertions, 0 deletions
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<()> { | |||
| 58 | config.domain.clone(), | 58 | config.domain.clone(), |
| 59 | relay_with_db.database.clone(), | 59 | relay_with_db.database.clone(), |
| 60 | relay_with_db.write_policy.clone(), | 60 | relay_with_db.write_policy.clone(), |
| 61 | relay_with_db.relay.clone(), | ||
| 61 | &config, | 62 | &config, |
| 62 | ); | 63 | ); |
| 63 | 64 | ||