-
Notifications
You must be signed in to change notification settings - Fork 4
Improve logging in event scanner #264
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
| .expect("pending blocks not supported"); | ||
| // Check if in reorg recovery and past the reorg range | ||
| if reorg_ancestor.is_some_and(|a| last_log_block_num <= a) { | ||
| debug!( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Im not sure this is useful since is expected internal state ?
| Ok(ScannerMessage::Notification(Notification::ReorgDetected { | ||
| common_ancestor, | ||
| })) => { | ||
| debug!( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| // since logs haven't been sent yet | ||
| } | ||
| Ok(ScannerMessage::Notification(notification)) => { | ||
| debug!(notification = ?notification, "Received notification"); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Notification gets streamed
| ) -> Result<Vec<Log>, RobustProviderError> { | ||
| let log_filter = log_filter.clone().from_block(*range.start()).to_block(*range.end()); | ||
|
|
||
| match provider.get_logs(&log_filter).await { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Removed these are these are both streamed to the consumer so not sure how helpful logs here are
Towards #52