upleb.uk

Public git repos — served from a NIP-34 GRASP relay at git.upleb.uk

summaryrefslogtreecommitdiff
path: root/src/sync/self_subscriber.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/sync/self_subscriber.rs')
-rw-r--r--src/sync/self_subscriber.rs8
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