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:
authorDanConwayDev <DanConwayDev@protonmail.com>2025-12-16 15:26:55 +0000
committerDanConwayDev <DanConwayDev@protonmail.com>2025-12-16 15:26:55 +0000
commit7821b107190cc116a30a4c339f935bc16a1d5197 (patch)
treed9cc8f440304f383aa75689eb6c1f87cc75fd20d /src/sync/self_subscriber.rs
parent2164f075d441d7337b2b3d7ed85993fc69b8057e (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.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