| |
/// no more events from this source, or there's an error.
|
| |
pub fn event(&mut self) -> Result<Vec<BrokerEvent>, NodeEventError> {
|
| |
loop {
|
| - |
trace!("getting next event from local node");
|
| + |
info!("getting next event from local node");
|
| |
if let Some(event) = self.events.next() {
|
| - |
trace!("got event from local node: {event:#?}");
|
| + |
info!("got event from local node");
|
| |
match event {
|
| |
Ok(event) => {
|
| - |
trace!("got node event {:#?}", event);
|
| + |
debug!("got node event {:#?}", event);
|
| |
let mut result = vec![];
|
| |
if let Some(broker_events) = BrokerEvent::from_event(&event) {
|
| |
for e in broker_events {
|
| |
if self.allowed(&e) {
|
| + |
info!("allowed event {e:?}");
|
| |
result.push(e);
|
| |
}
|
| |
}
|
| |
return Ok(result);
|
| |
}
|
| - |
trace!("got event, but it was not allowed by filter, go to next event");
|
| + |
info!("got event, but it was not allowed by filter, go to next event");
|
| |
}
|
| |
Err(radicle::node::Error::Io(err))
|
| |
if err.kind() == std::io::ErrorKind::ConnectionReset =>
|
| |
{
|
| - |
trace!("connection to node control socket broke");
|
| + |
info!("connection to node control socket broke");
|
| |
return Err(NodeEventError::BrokenConnection);
|
| |
}
|
| |
Err(err) => {
|
| + |
error!("error reading event from node: {err}");
|
| |
return Err(NodeEventError::Node(err));
|
| |
}
|
| |
}
|
| |
} else {
|
| - |
trace!("no more node events from control socket: iterator ended");
|
| + |
info!("no more node events from control socket: iterator ended");
|
| |
return Ok(vec![]);
|
| |
}
|
| |
}
|