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-10 14:36:06 +0000
committerDanConwayDev <DanConwayDev@protonmail.com>2025-12-10 14:37:19 +0000
commit8148c27a1350189046bc8e215f29f918dd8747f5 (patch)
tree4630db969a5f5b3e288a806ff8f85cd507820dab /src/sync/self_subscriber.rs
parente0eedf25f3218ee54563229257c1ce949bfafd10 (diff)
sync: fix connection registration issue
Diffstat (limited to 'src/sync/self_subscriber.rs')
-rw-r--r--src/sync/self_subscriber.rs17
1 files changed, 16 insertions, 1 deletions
diff --git a/src/sync/self_subscriber.rs b/src/sync/self_subscriber.rs
index e9e61ff..27e7e64 100644
--- a/src/sync/self_subscriber.rs
+++ b/src/sync/self_subscriber.rs
@@ -443,6 +443,15 @@ impl SelfSubscriber {
443 "Processing batch of repo updates" 443 "Processing batch of repo updates"
444 ); 444 );
445 445
446 // Log what repos and relays we discovered
447 for (repo_id, needs) in &updates {
448 tracing::info!(
449 repo_id = %repo_id,
450 relay_urls = ?needs.relays,
451 "Discovered repo with relay URLs"
452 );
453 }
454
446 // Update RepoSyncIndex 455 // Update RepoSyncIndex
447 let mut index = self.repo_sync_index.write().await; 456 let mut index = self.repo_sync_index.write().await;
448 457
@@ -482,6 +491,10 @@ impl SelfSubscriber {
482 None, 491 None,
483 ); 492 );
484 493
494 // Log before moving values
495 let repo_count = needs.repos.len();
496 let event_count = needs.root_events.len();
497
485 let action = AddFilters { 498 let action = AddFilters {
486 relay_url: relay_url.clone(), 499 relay_url: relay_url.clone(),
487 repos: needs.repos, 500 repos: needs.repos,
@@ -496,8 +509,10 @@ impl SelfSubscriber {
496 "Failed to send AddFilters action" 509 "Failed to send AddFilters action"
497 ); 510 );
498 } else { 511 } else {
499 tracing::debug!( 512 tracing::info!(
500 relay = %relay_url, 513 relay = %relay_url,
514 repo_count = repo_count,
515 event_count = event_count,
501 "Sent AddFilters action to SyncManager" 516 "Sent AddFilters action to SyncManager"
502 ); 517 );
503 } 518 }