041e736 feat: when CI event source closes, log the error — radicle-ci-broker

rad:zwTxygwuz5LDGBq255RA2CbNGrz8

Radicle CI broker

feat: when CI event source closes, log the error

Lars Wirzenius committed 1 year ago

commit 041e736a2365006e1f359b8195837c6f9c074188
parent 6ef5675

2 files changed +4 -3

modified src/logger.rs

@@ -11,7 +11,7 @@ use tracing_subscriber::{fmt, layer::SubscriberExt, util::SubscriberInitExt, Env

 use crate::{
     adapter::Adapter,
     ci_event::CiEvent,
     ci_event_source::CiEventSource,
     ci_event_source::{CiEventSource, CiEventSourceError},
     config::Config,
     db::{QueueId, QueuedCiEvent},
     filter::EventFilter,

@@ -529,10 +529,11 @@ pub fn queueadd_start() {

     );
 }
 pub fn queueadd_control_socket_close() {
 pub fn queueadd_control_socket_close(error: &CiEventSourceError) {
     info!(
         msg_id = ?Id::QueueAddEndEvents,
         kind = %Kind::Debug,
         ?error,
         "no more events from node control socket"
     );
 }

modified src/queueadd.rs

@@ -61,7 +61,7 @@ impl QueueAdder {

             let events = source.event();
             match events {
                 Err(e) => {
                     logger::queueadd_control_socket_close();
                     logger::queueadd_control_socket_close(&e);
                     return Err(e.into());
                 }
                 Ok(None) => {