4300fe3 feat: tweak logging of incoming events, for debugging — radicle-ci-broker

Radicle CI broker

feat: tweak logging of incoming events, for debugging

Lars Wirzenius committed 1 year ago

commit 4300fe34596453897143e8a6266bdd3dc367b8e9
parent c3a4c5f7aa3c6173f940c6fa0e26a4379d13e943

1 file changed +3 -2

modified src/event.rs

@@ -115,6 +115,7 @@ impl NodeEventSource {

                         debug!("got node event {:#?}", event);
                         let mut result = vec![];
                         if let Some(broker_events) = BrokerEvent::from_event(&event) {
                             info!("node event became {} broker events", broker_events.len());
                             for e in broker_events {
                                 if self.allowed(&e) {
                                     info!("allowed event {e:?}");

@@ -124,12 +125,12 @@ impl NodeEventSource {

                             info!("got {} allowed broker events from node event", result.len());
                             return Ok(result);
                         }
                         info!("got event, but it was not allowed by filter, go to next event");
                         info!("got event, but did not result in broker events");
                     }
                     Err(radicle::node::Error::Io(err))
                         if err.kind() == std::io::ErrorKind::ConnectionReset =>
                     {
                         info!("connection to node control socket broke");
                         error!("connection to node control socket broke");
                         return Err(NodeEventError::BrokenConnection);
                     }
                     Err(err) => {