diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2026-02-26 15:42:09 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2026-02-26 15:42:09 +0000 |
| commit | 9d86cf15f0275ffeee4519bd054e3b61dc8992ac (patch) | |
| tree | 65b5d5ffb2a11b5ecd05d01e63fb5a4a0f8b6e06 /tests/sync/maintainer_reprocessing.rs | |
| parent | a2ecfc5a63311570f0f90c7ee40117e289639cb8 (diff) | |
chore: apply cargo fmt and fix clippy warnings
Fix pre-existing clippy lints:
- &PathBuf -> &Path in audit_cleanup.rs
- too_many_arguments on process_newly_available_git_data,
process_purgatory_announcements, and HttpService::new
- clone_on_copy for PublicKey (Copy type) in purgatory cleanup loop
Diffstat (limited to 'tests/sync/maintainer_reprocessing.rs')
| -rw-r--r-- | tests/sync/maintainer_reprocessing.rs | 25 |
1 files changed, 14 insertions, 11 deletions
diff --git a/tests/sync/maintainer_reprocessing.rs b/tests/sync/maintainer_reprocessing.rs index ff1eb43..9154ee5 100644 --- a/tests/sync/maintainer_reprocessing.rs +++ b/tests/sync/maintainer_reprocessing.rs | |||
| @@ -70,17 +70,15 @@ async fn test_maintainer_announcement_reprocessed_immediately() { | |||
| 70 | identifier | 70 | identifier |
| 71 | )], | 71 | )], |
| 72 | ), | 72 | ), |
| 73 | Tag::custom( | 73 | Tag::custom(TagKind::custom("relays"), vec![relay_a.url().to_string()]), |
| 74 | TagKind::custom("relays"), | ||
| 75 | vec![relay_a.url().to_string()], | ||
| 76 | ), | ||
| 77 | ]) | 74 | ]) |
| 78 | .sign_with_keys(&maintainer_keys) | 75 | .sign_with_keys(&maintainer_keys) |
| 79 | .unwrap(); | 76 | .unwrap(); |
| 80 | send_to_relay(&relay_a, &maintainer_announcement).await.unwrap(); | 77 | send_to_relay(&relay_a, &maintainer_announcement) |
| 78 | .await | ||
| 79 | .unwrap(); | ||
| 81 | let _git_dir_maintainer = | 80 | let _git_dir_maintainer = |
| 82 | push_git_data_to_relay(&relay_a, &maintainer_keys, identifier, &[&relay_a.domain()]) | 81 | push_git_data_to_relay(&relay_a, &maintainer_keys, identifier, &[&relay_a.domain()]).await; |
| 83 | .await; | ||
| 84 | println!("✓ Maintainer announcement + git data pushed to relay_a"); | 82 | println!("✓ Maintainer announcement + git data pushed to relay_a"); |
| 85 | 83 | ||
| 86 | // Step 2: Start relay_b with relay_a as bootstrap so its SyncManager connects immediately. | 84 | // Step 2: Start relay_b with relay_a as bootstrap so its SyncManager connects immediately. |
| @@ -134,7 +132,9 @@ async fn test_maintainer_announcement_reprocessed_immediately() { | |||
| 134 | // re-processing of the maintainer announcement via our new code path. | 132 | // re-processing of the maintainer announcement via our new code path. |
| 135 | let _git_dir_owner = | 133 | let _git_dir_owner = |
| 136 | push_git_data_to_relay(&relay_b, &owner_keys, identifier, &[&relay_b.domain()]).await; | 134 | push_git_data_to_relay(&relay_b, &owner_keys, identifier, &[&relay_b.domain()]).await; |
| 137 | println!("✓ Owner git data pushed to relay_b (owner announcement promoted, hot cache re-processed)"); | 135 | println!( |
| 136 | "✓ Owner git data pushed to relay_b (owner announcement promoted, hot cache re-processed)" | ||
| 137 | ); | ||
| 138 | 138 | ||
| 139 | // Step 5: Wait briefly for async processing to complete. | 139 | // Step 5: Wait briefly for async processing to complete. |
| 140 | tokio::time::sleep(Duration::from_secs(1)).await; | 140 | tokio::time::sleep(Duration::from_secs(1)).await; |
| @@ -363,9 +363,12 @@ async fn test_multiple_maintainers_all_reprocessed() { | |||
| 363 | .kind(Kind::GitRepoAnnouncement) | 363 | .kind(Kind::GitRepoAnnouncement) |
| 364 | .author(keys.public_key()) | 364 | .author(keys.public_key()) |
| 365 | .identifier(identifier); | 365 | .identifier(identifier); |
| 366 | let found = | 366 | let found = wait_for_event_on_relay(relay_a.url(), filter, Duration::from_secs(10)).await; |
| 367 | wait_for_event_on_relay(relay_a.url(), filter, Duration::from_secs(10)).await; | 367 | assert!( |
| 368 | assert!(found, "{} announcement should be in relay_a before starting relay_b", name); | 368 | found, |
| 369 | "{} announcement should be in relay_a before starting relay_b", | ||
| 370 | name | ||
| 371 | ); | ||
| 369 | } | 372 | } |
| 370 | println!("✓ All three maintainer announcements confirmed in relay_a's DB"); | 373 | println!("✓ All three maintainer announcements confirmed in relay_a's DB"); |
| 371 | 374 | ||