Bypass filters for empty events
This commit is contained in:
parent
f492bca8c3
commit
7cdb6ac5ad
|
@ -73,19 +73,23 @@ pub async fn worker(
|
|||
Ok(Some(event)) => {
|
||||
trace!(?event, "got event");
|
||||
|
||||
let filtered = working.borrow().filterer.check_event(&event);
|
||||
match filtered {
|
||||
Err(err) => {
|
||||
trace!(%err, "filter errored on event");
|
||||
errors.send(err).await?;
|
||||
continue;
|
||||
}
|
||||
Ok(false) => {
|
||||
trace!("filter rejected event");
|
||||
continue;
|
||||
}
|
||||
Ok(true) => {
|
||||
trace!("filter passed event");
|
||||
if event.is_empty() {
|
||||
trace!("empty event, by-passing filters");
|
||||
} else {
|
||||
let filtered = working.borrow().filterer.check_event(&event);
|
||||
match filtered {
|
||||
Err(err) => {
|
||||
trace!(%err, "filter errored on event");
|
||||
errors.send(err).await?;
|
||||
continue;
|
||||
}
|
||||
Ok(false) => {
|
||||
trace!("filter rejected event");
|
||||
continue;
|
||||
}
|
||||
Ok(true) => {
|
||||
trace!("filter passed event");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue