Add server example binary

Co-authored-by: Matthias Beyer <mail@matthiasbeyer.de>
Signed-off-by: Marcel Müller <neikos@neikos.email>

2 files changed, 28 insertions, 0 deletions

diff --git a/Cargo.toml b/Cargo.toml
index d6a3f71..d5ed2a6 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -19,6 +19,10 @@ members = ["mqtt-format"]
 name = "cloudmqtt-client"
 required-features = ["bin"]
 
+[[bin]]
+name = "cloudmqtt-server"
+required-features = ["bin"]
+
 [features]
 bin = [
     "clap",
diff --git a/src/bin/cloudmqtt-server.rs b/src/bin/cloudmqtt-server.rs
new file mode 100644
index 0000000..9f6b501
--- /dev/null
+++ b/src/bin/cloudmqtt-server.rs
@@ -0,0 +1,24 @@
+use cloudmqtt::server::MqttServer;
+use tracing_subscriber::layer::SubscriberExt;
+use tracing_subscriber::util::SubscriberInitExt;
+
+
+#[tokio::main]
+async fn main() {
+    let fmt_layer = tracing_subscriber::fmt::layer()
+        .pretty()
+        .with_timer(tracing_subscriber::fmt::time::uptime());
+
+    let filter_layer = tracing_subscriber::EnvFilter::from_default_env();
+
+    tracing_subscriber::registry()
+        .with(fmt_layer)
+        .with(filter_layer)
+        .init();
+
+    tracing::info!("Starting server");
+
+    let mut server = MqttServer::serve_v3_unsecured_tcp("0.0.0.0:1883").await.unwrap();
+
+    server.accept_new_clients().await.unwrap();
+}