eb92396 feat: adjust logging of incoming events, again — radicle-ci-broker

Radicle CI broker

feat: adjust logging of incoming events, again

Lars Wirzenius committed 1 year ago

commit eb923962bbfeecfa49eead258f83722e1b5d70e4
parent 4300fe34596453897143e8a6266bdd3dc367b8e9

1 file changed +4 -1

modified src/event.rs

@@ -109,7 +109,7 @@ impl NodeEventSource {

         loop {
             debug!("getting next event from local node");
             if let Some(event) = self.events.next() {
                 info!("got event from local node: {event:?}");
                 info!("got event from local node");
                 match event {
                     Ok(event) => {
                         debug!("got node event {:#?}", event);

@@ -339,12 +339,15 @@ impl BrokerEvent {

                     RefUpdate::Skipped { name, oid }
                         if name.as_str() == "shutdown" && oid.is_zero() =>
                     {
                         info!("received shutdown event from node");
                         events.push(Self::shutdown());
                     }
                     RefUpdate::Created { name, oid } => {
                         info!("ref created {name} {oid}");
                         events.push(Self::new(rid, name, oid, None));
                     }
                     RefUpdate::Updated { name, old, new } => {
                         info!("ref updated {name} {old} => {new}");
                         events.push(Self::new(rid, name, new, Some(*old)));
                     }
                     _ => (),