connect_provider to connect

Author: LeoPatOZ

README.md

@@ -128,7 +128,7 @@ let scanner = EventScanner::latest()
 
 **Global Configuration Options:**
 - `block_read_limit(usize)` – Sets the maximum number of blocks to process per read operation. This prevents RPC provider errors from overly large block range queries.
-- Connect with `connect_ws::<Ethereum>(url)`, `connect_ipc::<Ethereum>(path)`, or `connect_provider(provider)`.
+- Connect with `connect_ws::<Ethereum>(url)`, `connect_ipc::<Ethereum>(path)`, or `connect(provider)`.
 
 **Mode-specific APIs:**
 - Live: `client.stream()` – Start streaming new blocks

src/block_range_scanner.rs

@@ -191,7 +191,7 @@ impl BlockRangeScanner {
     ) -> TransportResult<ConnectedBlockRangeScanner<N>> {
         let provider =
             RootProvider::<N>::new(ClientBuilder::default().ws(WsConnect::new(ws_url)).await?);
-        self.connect_provider(provider)
+        self.connect(provider)
     }
 
     /// Connects to the provider via IPC
@@ -204,15 +204,15 @@ impl BlockRangeScanner {
         ipc_path: String,
     ) -> TransportResult<ConnectedBlockRangeScanner<N>> {
         let provider = RootProvider::<N>::new(ClientBuilder::default().ipc(ipc_path.into()).await?);
-        self.connect_provider(provider)
+        self.connect(provider)
     }
 
     /// Connects to an existing provider
     ///
     /// # Errors
     ///
     /// Returns an error if the connection fails
-    pub fn connect_provider<N: Network>(
+    pub fn connect<N: Network>(
         self,
         provider: RootProvider<N>,
     ) -> TransportResult<ConnectedBlockRangeScanner<N>> {

src/event_lib/modes/historic.rs

@@ -90,12 +90,12 @@ impl HistoricScannerConfig {
     /// # Errors
     ///
     /// Returns an error if the connection fails
-    pub fn connect_provider<N: Network>(
+    pub fn connect<N: Network>(
         self,
         provider: RootProvider<N>,
     ) -> TransportResult<HistoricEventScanner<N>> {
         let HistoricScannerConfig { base, from_block, to_block } = self;
-        let brs = base.block_range_scanner.connect_provider::<N>(provider)?;
+        let brs = base.block_range_scanner.connect::<N>(provider)?;
         let config = HistoricScannerConfig { base, from_block, to_block };
         Ok(HistoricEventScanner { config, inner: EventScannerService::from_config(brs) })
     }

src/event_lib/modes/latest.rs

@@ -149,7 +149,7 @@ impl LatestScannerConfig {
     /// # Errors
     ///
     /// Returns an error if the connection fails
-    pub fn connect_provider<N: Network>(
+    pub fn connect<N: Network>(
         self,
         provider: RootProvider<N>,
     ) -> TransportResult<LatestEventScanner<N>> {
@@ -161,7 +161,7 @@ impl LatestScannerConfig {
             block_confirmations,
             switch_to_live,
         } = self;
-        let brs = base.block_range_scanner.connect_provider::<N>(provider)?;
+        let brs = base.block_range_scanner.connect::<N>(provider)?;
         let config = LatestScannerConfig {
             base,
             count,

src/event_lib/modes/live.rs

@@ -77,12 +77,12 @@ impl LiveScannerConfig {
     /// # Errors
     ///
     /// Returns an error if the connection fails
-    pub fn connect_provider<N: Network>(
+    pub fn connect<N: Network>(
         self,
         provider: RootProvider<N>,
     ) -> TransportResult<LiveEventScanner<N>> {
         let LiveScannerConfig { base, block_confirmations } = self;
-        let brs = base.block_range_scanner.connect_provider::<N>(provider)?;
+        let brs = base.block_range_scanner.connect::<N>(provider)?;
         let config = LiveScannerConfig { base, block_confirmations };
         Ok(LiveEventScanner { config, inner: EventScannerService::from_config(brs) })
     }

src/event_lib/modes/sync.rs

@@ -90,12 +90,12 @@ impl SyncScannerConfig {
     /// # Errors
     ///
     /// Returns an error if the connection fails
-    pub fn connect_provider<N: Network>(
+    pub fn connect<N: Network>(
         self,
         provider: RootProvider<N>,
     ) -> TransportResult<SyncEventScanner<N>> {
         let SyncScannerConfig { base, from_block, block_confirmations } = self;
-        let brs = base.block_range_scanner.connect_provider::<N>(provider)?;
+        let brs = base.block_range_scanner.connect::<N>(provider)?;
         let config = SyncScannerConfig { base, from_block, block_confirmations };
         Ok(SyncEventScanner { config, inner: EventScannerService::from_config(brs) })
     }