test: remove redundant test name prefixes

Author: 0xNeshi

tests/historic/basic.rs

@@ -5,13 +5,9 @@ use crate::common::{TestCounter, setup_historic_scanner};
 
 #[tokio::test]
 async fn processes_events_within_specified_historical_range() -> anyhow::Result<()> {
-    let setup = setup_historic_scanner(
-        Some(0.1),
-        None,
-        BlockNumberOrTag::Earliest,
-        BlockNumberOrTag::Latest,
-    )
-    .await?;
+    let setup =
+        setup_historic_scanner(None, None, BlockNumberOrTag::Earliest, BlockNumberOrTag::Latest)
+            .await?;
     let contract = setup.contract;
     let scanner = setup.scanner;
     let mut stream = setup.stream;

tests/latest_events/basic.rs

@@ -6,7 +6,7 @@ use crate::common::{TestCounter, deploy_counter, setup_common, setup_latest_scan
 use event_scanner::{EventFilter, EventScannerBuilder, assert_closed, assert_next};
 
 #[tokio::test]
-async fn latest_scanner_exact_count_returns_last_events_in_order() -> anyhow::Result<()> {
+async fn exact_count_returns_last_events_in_order() -> anyhow::Result<()> {
     let count = 5;
     let setup = setup_latest_scanner(None, None, count, None, None).await?;
     let contract = setup.contract;
@@ -36,7 +36,7 @@ async fn latest_scanner_exact_count_returns_last_events_in_order() -> anyhow::Re
 }
 
 #[tokio::test]
-async fn latest_scanner_fewer_available_than_count_returns_all() -> anyhow::Result<()> {
+async fn fewer_available_than_count_returns_all() -> anyhow::Result<()> {
     let count = 5;
     let setup = setup_latest_scanner(None, None, count, None, None).await?;
     let contract = setup.contract;
@@ -64,7 +64,7 @@ async fn latest_scanner_fewer_available_than_count_returns_all() -> anyhow::Resu
 }
 
 #[tokio::test]
-async fn latest_scanner_no_events_returns_empty() -> anyhow::Result<()> {
+async fn no_events_returns_empty() -> anyhow::Result<()> {
     let count = 5;
     let setup = setup_latest_scanner(None, None, count, None, None).await?;
     let scanner = setup.scanner;
@@ -81,7 +81,7 @@ async fn latest_scanner_no_events_returns_empty() -> anyhow::Result<()> {
 }
 
 #[tokio::test]
-async fn latest_scanner_respects_range_subset() -> anyhow::Result<()> {
+async fn respects_range_subset() -> anyhow::Result<()> {
     let (_anvil, provider, contract, default_filter) = setup_common(None, None).await?;
     // Mine 6 events, one per tx (auto-mined), then manually mint 2 empty blocks to widen range
     contract.increase().send().await?.watch().await?;
@@ -118,8 +118,7 @@ async fn latest_scanner_respects_range_subset() -> anyhow::Result<()> {
 }
 
 #[tokio::test]
-async fn latest_scanner_multiple_listeners_to_same_event_receive_same_results() -> anyhow::Result<()>
-{
+async fn multiple_listeners_to_same_event_receive_same_results() -> anyhow::Result<()> {
     let count = 5;
     let setup = setup_latest_scanner(None, None, count, None, None).await?;
     let contract = setup.contract;
@@ -161,7 +160,7 @@ async fn latest_scanner_multiple_listeners_to_same_event_receive_same_results()
 }
 
 #[tokio::test]
-async fn latest_scanner_different_filters_receive_different_results() -> anyhow::Result<()> {
+async fn different_filters_receive_different_results() -> anyhow::Result<()> {
     let count = 3;
     let setup = setup_latest_scanner(None, None, count, None, None).await?;
     let contract = setup.contract;
@@ -216,7 +215,7 @@ async fn latest_scanner_different_filters_receive_different_results() -> anyhow:
 }
 
 #[tokio::test]
-async fn latest_scanner_mixed_events_and_filters_return_correct_streams() -> anyhow::Result<()> {
+async fn mixed_events_and_filters_return_correct_streams() -> anyhow::Result<()> {
     let count = 2;
     let setup = setup_latest_scanner(None, None, count, None, None).await?;
     let contract = setup.contract;
@@ -259,7 +258,7 @@ async fn latest_scanner_mixed_events_and_filters_return_correct_streams() -> any
 }
 
 #[tokio::test]
-async fn latest_scanner_ignores_non_tracked_contract() -> anyhow::Result<()> {
+async fn ignores_non_tracked_contract() -> anyhow::Result<()> {
     // Manual setup to deploy two contracts
     let setup = setup_latest_scanner(None, None, 5, None, None).await?;
     let provider = setup.provider;
@@ -294,7 +293,7 @@ async fn latest_scanner_ignores_non_tracked_contract() -> anyhow::Result<()> {
 }
 
 #[tokio::test]
-async fn latest_scanner_large_gaps_and_empty_ranges() -> anyhow::Result<()> {
+async fn large_gaps_and_empty_ranges() -> anyhow::Result<()> {
     // Manual setup to mine empty blocks
     let (_anvil, provider, contract, default_filter) = setup_common(None, None).await?;
 
@@ -331,7 +330,7 @@ async fn latest_scanner_large_gaps_and_empty_ranges() -> anyhow::Result<()> {
 }
 
 #[tokio::test]
-async fn latest_scanner_boundary_range_single_block() -> anyhow::Result<()> {
+async fn boundary_range_single_block() -> anyhow::Result<()> {
     let (_anvil, provider, contract, default_filter) = setup_common(None, None).await?;
 
     contract.increase().send().await?.watch().await?;

tests/live/basic.rs

@@ -155,7 +155,7 @@ async fn signature_matching_ignores_irrelevant_events() -> anyhow::Result<()> {
 }
 
 #[tokio::test]
-async fn live_filters_malformed_signature_graceful() -> anyhow::Result<()> {
+async fn filters_malformed_signature_graceful() -> anyhow::Result<()> {
     let setup = setup_live_scanner(Some(0.1), None, 0).await?;
     let contract = setup.contract.clone();
 

tests/live/reorg.rs

@@ -9,7 +9,7 @@ use alloy::{
 use event_scanner::{ScannerStatus, assert_empty, assert_event_sequence, assert_next};
 
 #[tokio::test]
-async fn reorg_rescans_events_within_same_block() -> anyhow::Result<()> {
+async fn rescans_events_within_same_block() -> anyhow::Result<()> {
     let LiveScannerSetup { provider, contract, scanner, mut stream, anvil: _anvil } =
         setup_live_scanner(None, None, 0).await?;
 
@@ -58,7 +58,7 @@ async fn reorg_rescans_events_within_same_block() -> anyhow::Result<()> {
 }
 
 #[tokio::test]
-async fn reorg_rescans_events_with_ascending_blocks() -> anyhow::Result<()> {
+async fn rescans_events_with_ascending_blocks() -> anyhow::Result<()> {
     let LiveScannerSetup { provider, contract, scanner, mut stream, anvil: _anvil } =
         setup_live_scanner(None, None, 0).await?;
 
@@ -107,7 +107,7 @@ async fn reorg_rescans_events_with_ascending_blocks() -> anyhow::Result<()> {
 }
 
 #[tokio::test]
-async fn reorg_depth_one() -> anyhow::Result<()> {
+async fn depth_one() -> anyhow::Result<()> {
     let LiveScannerSetup { provider, contract, scanner, mut stream, anvil: _anvil } =
         setup_live_scanner(None, None, 0).await?;
 
@@ -145,7 +145,7 @@ async fn reorg_depth_one() -> anyhow::Result<()> {
 }
 
 #[tokio::test]
-async fn reorg_depth_two() -> anyhow::Result<()> {
+async fn depth_two() -> anyhow::Result<()> {
     let LiveScannerSetup { provider, contract, scanner, mut stream, anvil: _anvil } =
         setup_live_scanner(None, None, 0).await?;
 

tests/sync/from_latest.rs

@@ -4,7 +4,7 @@ use crate::common::{TestCounter, setup_sync_from_latest_scanner};
 use event_scanner::{ScannerStatus, assert_empty, assert_event_sequence, assert_next};
 
 #[tokio::test]
-async fn scan_latest_then_live_happy_path_no_duplicates() -> anyhow::Result<()> {
+async fn happy_path_no_duplicates() -> anyhow::Result<()> {
     let setup = setup_sync_from_latest_scanner(None, None, 3, 0).await?;
     let contract = setup.contract;
     let scanner = setup.scanner;
@@ -49,7 +49,7 @@ async fn scan_latest_then_live_happy_path_no_duplicates() -> anyhow::Result<()>
 }
 
 #[tokio::test]
-async fn scan_latest_then_live_fewer_historical_then_continues_live() -> anyhow::Result<()> {
+async fn fewer_historical_then_continues_live() -> anyhow::Result<()> {
     let setup = setup_sync_from_latest_scanner(None, None, 5, 0).await?;
     let contract = setup.contract;
     let scanner = setup.scanner;
@@ -87,7 +87,7 @@ async fn scan_latest_then_live_fewer_historical_then_continues_live() -> anyhow:
 }
 
 #[tokio::test]
-async fn scan_latest_then_live_exact_historical_count_then_live() -> anyhow::Result<()> {
+async fn exact_historical_count_then_live() -> anyhow::Result<()> {
     let setup = setup_sync_from_latest_scanner(None, None, 4, 0).await?;
     let contract = setup.contract;
     let scanner = setup.scanner;
@@ -120,7 +120,7 @@ async fn scan_latest_then_live_exact_historical_count_then_live() -> anyhow::Res
 }
 
 #[tokio::test]
-async fn scan_latest_then_live_no_historical_only_live_streams() -> anyhow::Result<()> {
+async fn no_historical_only_live_streams() -> anyhow::Result<()> {
     let setup = setup_sync_from_latest_scanner(None, None, 5, 0).await?;
     let contract = setup.contract;
     let scanner = setup.scanner;
@@ -149,7 +149,7 @@ async fn scan_latest_then_live_no_historical_only_live_streams() -> anyhow::Resu
 }
 
 #[tokio::test]
-async fn scan_latest_then_live_boundary_no_duplication() -> anyhow::Result<()> {
+async fn block_gaps_do_not_affect_number_of_events_streamed() -> anyhow::Result<()> {
     let setup = setup_sync_from_latest_scanner(None, None, 3, 0).await?;
     let provider = setup.provider;
     let contract = setup.contract;
@@ -178,16 +178,18 @@ async fn scan_latest_then_live_boundary_no_duplication() -> anyhow::Result<()> {
         ]
     );
     assert_next!(stream, ScannerStatus::SwitchingToLive);
+    let mut stream = assert_empty!(stream);
 
     // Immediately produce a new live event in a new block
     contract.increase().send().await?.watch().await?;
+
     assert_next!(stream, &[TestCounter::CountIncreased { newCount: U256::from(4) }]);
 
     Ok(())
 }
 
 #[tokio::test]
-async fn scan_latest_then_live_waiting_on_live_logs_arriving() -> anyhow::Result<()> {
+async fn waiting_on_live_logs_arriving() -> anyhow::Result<()> {
     let setup = setup_sync_from_latest_scanner(None, None, 3, 0).await?;
     let contract = setup.contract;
     let scanner = setup.scanner;