simplify libexec implementation

Author: rizsotto

bear/src/intercept/mod.rs

@@ -38,13 +38,13 @@ pub fn create_reporter() -> anyhow::Result<Box<dyn Reporter>> {
         std::env::var(KEY_DESTINATION)
         .with_context(|| format!("${} is missing from the environment", KEY_DESTINATION))
         // Create a new reporter
-        .and_then(tcp::ReporterOnTcp::new)?;
+        .map(tcp::ReporterOnTcp::new)?;
     Ok(Box::new(reporter))
 }
 
-pub fn create_reporter_on_tcp(address: &str) -> anyhow::Result<Box<dyn Reporter>> {
-    let reporter = tcp::ReporterOnTcp::new(address.to_string())?;
-    Ok(Box::new(reporter))
+pub fn create_reporter_on_tcp(address: &str) -> Box<dyn Reporter> {
+    let reporter = tcp::ReporterOnTcp::new(address.to_string());
+    Box::new(reporter)
 }
 
 /// Represents the remote sink of supervised process events.

bear/src/intercept/tcp.rs

@@ -135,9 +135,8 @@ impl ReporterOnTcp {
     ///
     /// It does not open the TCP connection yet. Stores the destination
     /// address and creates a unique reporter id.
-    pub fn new(destination: String) -> Result<Self, anyhow::Error> {
-        let result = ReporterOnTcp { destination };
-        Ok(result)
+    pub fn new(destination: String) -> Self {
+        ReporterOnTcp { destination }
     }
 }
 
@@ -192,7 +191,7 @@ mod tests {
     #[test]
     fn tcp_reporter_and_collectors_work() {
         let collector = CollectorOnTcp::create().unwrap();
-        let reporter = ReporterOnTcp::new(collector.address()).unwrap();
+        let reporter = ReporterOnTcp::new(collector.address());
 
         // Create wrapper to share the collector across threads.
         let thread_collector = Arc::new(collector);

intercept-preload/Cargo.toml

@@ -18,8 +18,9 @@ crate-type = ["rlib", "cdylib"]
 [dependencies]
 bear = { path = "../bear" }
 thiserror.workspace = true
-anyhow.workspace = true
 log.workspace = true
+env_logger.workspace = true
+ctor = { version = "0.4" }
 
 [target.'cfg(target_os = "linux")'.dependencies]
 libc.workspace = true