diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-16 15:26:55 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-16 15:26:55 +0000 |
| commit | 7821b107190cc116a30a4c339f935bc16a1d5197 (patch) | |
| tree | d9cc8f440304f383aa75689eb6c1f87cc75fd20d /src/sync/self_subscriber.rs | |
| parent | 2164f075d441d7337b2b3d7ed85993fc69b8057e (diff) | |
proactive sync prep - some helper functions written but not enabled
Diffstat (limited to 'src/sync/self_subscriber.rs')
| -rw-r--r-- | src/sync/self_subscriber.rs | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/sync/self_subscriber.rs b/src/sync/self_subscriber.rs index 0379fe4..9643fc0 100644 --- a/src/sync/self_subscriber.rs +++ b/src/sync/self_subscriber.rs | |||
| @@ -499,7 +499,7 @@ impl SelfSubscriber { | |||
| 499 | drop(index); // Release lock before async operations | 499 | drop(index); // Release lock before async operations |
| 500 | 500 | ||
| 501 | // For each relay, send AddFilters action directly | 501 | // For each relay, send AddFilters action directly |
| 502 | // SyncManager's handle_add_filters auto-spawns connection for unknown relays | 502 | // SyncManager's handle_new_sync_filters auto-spawns connection for unknown relays |
| 503 | for (relay_url, needs) in targets { | 503 | for (relay_url, needs) in targets { |
| 504 | // Skip our own relay URL (we're subscribed to ourselves via self-subscription) | 504 | // Skip our own relay URL (we're subscribed to ourselves via self-subscription) |
| 505 | if relay_url.contains(&self.relay_domain) { | 505 | if relay_url.contains(&self.relay_domain) { |
| @@ -519,8 +519,10 @@ impl SelfSubscriber { | |||
| 519 | 519 | ||
| 520 | let action = AddFilters { | 520 | let action = AddFilters { |
| 521 | relay_url: relay_url.clone(), | 521 | relay_url: relay_url.clone(), |
| 522 | repos: needs.repos, | 522 | items: crate::sync::PendingItems { |
| 523 | root_events: needs.root_events, | 523 | repos: needs.repos, |
| 524 | root_events: needs.root_events, | ||
| 525 | }, | ||
| 524 | filters, | 526 | filters, |
| 525 | }; | 527 | }; |
| 526 | 528 | ||