feat(trasmitter): use stdout except log stderr to transmit events

bombini/Cargo.toml

@@ -15,7 +15,7 @@ env_logger = "0.11.8"
 libc = "0.2.174"
 log = "0.4.27"
 procfs = "0.17.0"
-tokio = { version = "1.46.1", features = ["fs", "io-util", "macros", "rt", "rt-multi-thread", "net", "signal", "sync"] }
+tokio = { version = "1.46.1", features = ["fs", "io-std", "io-util", "macros", "rt", "rt-multi-thread", "net", "signal", "sync"] }
 futures-executor = "0.3.31"
 prost = "0.14.1"
 serde = { version = "1.0.219", features = ["derive"] }

bombini/src/main.rs

@@ -14,7 +14,7 @@ use config::{Config, CONFIG};
 use monitor::Monitor;
 use registry::Registry;
 use transmitter::file::FileTransmitter;
-use transmitter::log::LogTransmitter;
+use transmitter::stdout::StdoutTransmitter;
 use transmitter::unix_sock::USockTransmitter;
 
 #[tokio::main]
@@ -56,7 +56,7 @@ async fn start_monitor(config: &Config, monitor: &Monitor<'_>) -> Result<(), any
         Ok(())
     } else {
         // default: send events to stdout
-        monitor.monitor(LogTransmitter).await;
+        monitor.monitor(StdoutTransmitter).await;
         Ok(())
     }
 }

bombini/src/transmitter/mod.rs

@@ -1,7 +1,7 @@
 //! Transmitter provides interface to send serialized event into different sources
 
 pub mod file;
-pub mod log;
+pub mod stdout;
 pub mod unix_sock;
 
 pub trait Transmitter {

bombini/src/transmitter/stdout.rs

@@ -0,0 +1,16 @@
+//! Transmit serialized event into stdout
+
+use tokio::io::{self, AsyncWriteExt};
+
+use super::Transmitter;
+
+pub struct StdoutTransmitter;
+
+impl Transmitter for StdoutTransmitter {
+    async fn transmit(&mut self, mut data: Vec<u8>) -> Result<(), anyhow::Error> {
+        data.push(b'\n');
+        let mut stdout = io::stdout();
+        stdout.write_all(&data).await?;
+        Ok(())
+    }
+}

bombini/tests/tests.rs

@@ -67,6 +67,7 @@ fn test_detectors_load() {
         ])
         .env("RUST_LOG", "debug")
         .stderr(bombini_log.try_clone().unwrap())
+        .stdout(Stdio::null())
         .spawn();
     if bombini.is_err() {
         panic!("{:?}", bombini.err().unwrap());