d2324ca feat: log received node events — radicle-ci-broker

Radicle CI broker

feat: log received node events

Lars Wirzenius committed 1 year ago

commit d2324ca652f5f0a623c37042d1fbbdd2986fa7aa
parent 21b14a2328be75f233f70a1eb7be35e87efb2f92

2 files changed +13 -2

modified src/logger.rs

@@ -4,7 +4,7 @@

 use std::sync::Once;
 use std::{path::Path, sync::Mutex, time::Duration};
 use radicle::{git::raw::Oid, identity::RepoId};
 use radicle::{git::raw::Oid, identity::RepoId, node::Event};
 use slog::{debug, error, info, o, warn, Drain};
 use slog_scope::GlobalLoggerGuard;

@@ -79,6 +79,14 @@ pub fn node_event_source_created(source: &NodeEventSource) {

     );
 }
 pub fn node_event_source_got_event(event: &Event) {
     info!(
         slog_scope::logger(),
         "node event source received event";
         "node_event" => format!("{event:#?}")
     );
 }
 pub fn loaded_config(config: &Config) {
     debug!(slog_scope::logger(), "loaded configuration {config:#?}");
 }

modified src/node_event_source.rs

@@ -45,7 +45,10 @@ impl NodeEventSource {

     pub fn node_event(&mut self) -> Result<Option<Event>, NodeEventError> {
         if let Some(event) = self.events.next() {
             match event {
                 Ok(event) => Ok(Some(event)),
                 Ok(event) => {
                     logger::node_event_source_got_event(&event);
                     Ok(Some(event))
                 }
                 Err(radicle::node::Error::Io(err))
                     if err.kind() == std::io::ErrorKind::ConnectionReset =>
                 {