From 25d4aa22e80a2beaee25278504010e712734c904 Mon Sep 17 00:00:00 2001
From: Martin Indra <martin.indra@mgn.cz>
Date: Sat, 7 Oct 2023 18:31:04 +0200
Subject: [PATCH] WIP

---
 crates/connector/src/lib.rs  | 11 ++++-------
 crates/connector/src/main.rs | 12 +++++++++---
 2 files changed, 13 insertions(+), 10 deletions(-)

diff --git a/crates/connector/src/lib.rs b/crates/connector/src/lib.rs
index 5fa2100d8..5c2d7b4ba 100644
--- a/crates/connector/src/lib.rs
+++ b/crates/connector/src/lib.rs
@@ -1,7 +1,7 @@
 use anyhow::Context;
 use async_std::task;
 use de_net::Socket;
-use tracing::{error, info};
+use tracing::info;
 
 use crate::server::MainServer;
 
@@ -11,14 +11,11 @@ mod server;
 
 const PORT: u16 = 8082;
 
-pub fn start() {
+pub fn start() -> Result<(), String> {
     info!("Starting...");
-
     task::block_on(task::spawn(async {
-        if let Err(error) = start_inner().await {
-            error!("{:?}", error);
-        }
-    }));
+        start_inner().await.map_err(|error| format!("{:?}", error))
+    }))
 }
 
 async fn start_inner() -> anyhow::Result<()> {
diff --git a/crates/connector/src/main.rs b/crates/connector/src/main.rs
index 9fc5f3f11..c8a27a9c4 100644
--- a/crates/connector/src/main.rs
+++ b/crates/connector/src/main.rs
@@ -1,11 +1,17 @@
 use de_connector_lib::start;
-use tracing::Level;
+use tracing::{error, Level};
 use tracing_subscriber::FmtSubscriber;
 
-fn main() {
+fn main() -> Result<(), String> {
     let subscriber = FmtSubscriber::builder()
         .with_max_level(Level::TRACE)
         .finish();
     tracing::subscriber::set_global_default(subscriber).unwrap();
-    start();
+
+    let result = start();
+    if let Err(message) = result.as_ref() {
+        error!(message);
+    }
+
+    result
 }