diff --git a/noxis-rs/Cargo.toml b/noxis-rs/Cargo.toml
index cf86d18..62c917f 100644
--- a/noxis-rs/Cargo.toml
+++ b/noxis-rs/Cargo.toml
@@ -16,3 +16,4 @@ serde = { version = "1.0.203", features = ["derive"] }
 serde_json = "1.0.118"
 sysinfo = "0.32.0"
 tokio = { version = "1.38.0", features = ["full", "time"] }
+noxis-cli = { path = "../noxis-cli" }
diff --git a/noxis-rs/src/options/cli_pipeline.rs b/noxis-rs/src/options/cli_pipeline.rs
index 3b9897c..ad6a670 100644
--- a/noxis-rs/src/options/cli_pipeline.rs
+++ b/noxis-rs/src/options/cli_pipeline.rs
@@ -5,6 +5,8 @@ use tokio::time::{sleep, Duration};
 use std::{borrow::BorrowMut, net::{IpAddr, Ipv4Addr}};
 // use std::io::BufReader;
 use tokio::io::{BufReader, AsyncWriteExt, AsyncBufReadExt};
+use noxis_cli::Cli;
+use serde_json::from_str;
 
 /// # Fn `init_cli_pipeline`
 /// ## for catching all input requests from CLI
@@ -85,7 +87,16 @@ async fn process_connection(mut stream: TcpStream) {
 
     while let Ok(Some(line)) = rqst.next_line().await {
         if line.is_empty() {
-            break;
+            break
+        }
+        match from_str::<Cli>(&line) {
+            Ok(req) => {
+                // TODO: func wrapper
+                dbg!(req);
+            },
+            Err(_) => {
+                break
+            },
         }
         println!("{}", line);
     }