diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-10 14:36:06 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-10 14:37:19 +0000 |
| commit | 8148c27a1350189046bc8e215f29f918dd8747f5 (patch) | |
| tree | 4630db969a5f5b3e288a806ff8f85cd507820dab /src/sync/self_subscriber.rs | |
| parent | e0eedf25f3218ee54563229257c1ce949bfafd10 (diff) | |
sync: fix connection registration issue
Diffstat (limited to 'src/sync/self_subscriber.rs')
| -rw-r--r-- | src/sync/self_subscriber.rs | 17 |
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 | } |