Skip to content

Commit d9c14d6

Browse files
committed
chore: move impl to different file
1 parent 972ffd3 commit d9c14d6

File tree

2 files changed

+18
-15
lines changed

2 files changed

+18
-15
lines changed

src/event_lib/error.rs

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,9 @@
11
use std::sync::Arc;
22

3-
use alloy::transports::{RpcError, TransportErrorKind};
3+
use alloy::{
4+
rpc::types::Log,
5+
transports::{RpcError, TransportErrorKind},
6+
};
47
use thiserror::Error;
58

69
use crate::{EventScannerMessage, block_range_scanner::BlockRangeScannerError};
@@ -30,3 +33,12 @@ impl From<BlockRangeScannerError> for EventScannerMessage {
3033
EventScannerMessage::Error(e.into())
3134
}
3235
}
36+
37+
impl From<Result<Vec<Log>, RpcError<TransportErrorKind>>> for EventScannerMessage {
38+
fn from(logs: Result<Vec<Log>, RpcError<TransportErrorKind>>) -> Self {
39+
match logs {
40+
Ok(logs) => EventScannerMessage::Data(logs),
41+
Err(e) => EventScannerMessage::Error(e.into()),
42+
}
43+
}
44+
}

src/event_lib/scanner.rs

Lines changed: 5 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -26,20 +26,6 @@ use tracing::{error, info, warn};
2626

2727
pub type EventScannerMessage = ScannerMessage<Vec<Log>, EventScannerError>;
2828

29-
pub struct EventScannerService<N: Network> {
30-
block_range_scanner: ConnectedBlockRangeScanner<N>,
31-
event_listeners: Vec<EventListener>,
32-
}
33-
34-
impl From<Result<Vec<Log>, RpcError<TransportErrorKind>>> for EventScannerMessage {
35-
fn from(logs: Result<Vec<Log>, RpcError<TransportErrorKind>>) -> Self {
36-
match logs {
37-
Ok(logs) => EventScannerMessage::Data(logs),
38-
Err(e) => EventScannerMessage::Error(e.into()),
39-
}
40-
}
41-
}
42-
4329
impl From<Vec<Log>> for EventScannerMessage {
4430
fn from(logs: Vec<Log>) -> Self {
4531
EventScannerMessage::Data(logs)
@@ -74,6 +60,11 @@ impl<E: SolEvent> PartialEq<&[E]> for EventScannerMessage {
7460
}
7561
}
7662

63+
pub struct EventScannerService<N: Network> {
64+
block_range_scanner: ConnectedBlockRangeScanner<N>,
65+
event_listeners: Vec<EventListener>,
66+
}
67+
7768
#[derive(Copy, Clone)]
7869
enum ConsumerMode {
7970
Stream,

0 commit comments

Comments
 (0)