diff --git a/Cargo.lock b/Cargo.lock
index 00d9878..765f771 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -477,7 +477,6 @@ dependencies = [
 name = "msg"
 version = "0.1.0"
 dependencies = [
- "anyhow",
  "async-std",
  "chrono",
  "futures",
@@ -488,6 +487,7 @@ dependencies = [
  "serde",
  "serde_json",
  "structopt",
+ "thiserror",
  "toml",
  "uuid",
 ]
diff --git a/Cargo.toml b/Cargo.toml
index 22c6fad..f8865e2 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -18,4 +18,4 @@ toml = "0.5.6"
 # ilmp = { git = "https://github.com/izzabelle/ilmp" }
 ilmp = { path = "../ilmp"}
 ring = "0.16.13"
-anyhow = "1.0.31"
+thiserror = "1.0.18"
diff --git a/src/client.rs b/src/client.rs
index eaeb292..c1e3668 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -2,19 +2,27 @@
 use crate::config::ClientConfig as Config;
 use crate::Result;
 use async_std::net::TcpStream;
+use futures::io::ReadHalf;
+use futures_util::io::AsyncReadExt;
 
 /// wraps the client
 pub async fn client(port: u16) -> Result<()> {
     let _config = Config::load()?;
 
     let mut stream = TcpStream::connect(format!("127.0.0.1:{}", &port)).await?;
-    println!("connection established to: {}:{}", stream.peer_addr()?.ip(), port);
+    println!(
+        "connection established to: {}:{}",
+        stream.peer_addr()?.ip(),
+        port
+    );
 
-    /*let (_read, mut write) = stream.split();*/
+    let message = ilmp::Message::new(
+        "Isabelle".to_owned(),
+        "oh god oh fuck this shit actually works".to_owned(),
+    );
+    ilmp::write(&mut stream, message);
 
-    let message =
-        ilmp::Message::new("Isabelle".to_string(), "new message protocol working".to_string());
-    ilmp::write(&mut stream, message).await?;
+    let (read, mut write) = stream.split();
 
-    loop {}
+    Ok(())
 }
diff --git a/src/lib.rs b/src/lib.rs
index 34c9995..6c27e89 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -3,9 +3,38 @@ mod client;
 mod config;
 mod server;
 
+use ring::{agreement, rand};
+use thiserror::Error;
+
 // re-exports
 pub use client::client;
 pub use server::server;
 
 // lazy idiot error/result type
-pub type Result<T> = anyhow::Result<T>;
+pub type Result<T> = std::result::Result<T, MsgError>;
+#[derive(Debug, Error)]
+pub enum MsgError {
+    #[error("message protocol error")]
+    Ilmp(#[from] ilmp::IlmpError),
+    #[error("std::io error")]
+    StdIo(#[from] std::io::Error),
+    #[error("toml error")]
+    Toml(#[from] toml::de::Error),
+}
+
+pub struct AsymmetricKeys {
+    pub private: agreement::EphemeralPrivateKey,
+    pub public: agreement::PublicKey,
+}
+
+impl AsymmetricKeys {
+    pub fn generate() -> AsymmetricKeys {
+        let rng = rand::SystemRandom::new();
+        let private = agreement::EphemeralPrivateKey::generate(&agreement::X25519, &rng)
+            .expect("failed to create private key");
+        let public = private
+            .compute_public_key()
+            .expect("failed to create public key");
+        AsymmetricKeys { private, public }
+    }
+}
diff --git a/src/main.rs b/src/main.rs
index 8ec83ce..2c4f7fd 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -3,7 +3,10 @@ use structopt::StructOpt;
 
 // cli options
 #[derive(StructOpt)]
-#[structopt(name = "msg", about = "I have no idea what i'm doing but this is async")]
+#[structopt(
+    name = "msg",
+    about = "I have no idea what i'm doing but this is async"
+)]
 struct Opt {
     /// start the application as a server
     #[structopt(short = "s", long = "server")]
@@ -17,7 +20,11 @@ struct Opt {
 #[async_std::main]
 async fn main() {
     let options = Opt::from_args();
-    let port = if let Some(port) = options.port { port } else { 1337 };
+    let port = if let Some(port) = options.port {
+        port
+    } else {
+        1337
+    };
     match options.server {
         true => {
             if let Err(err) = msg::server(port).await {
diff --git a/src/server.rs b/src/server.rs
index 7c43762..78707d4 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -18,8 +18,15 @@ lazy_static! {
 
 /// wraps the server
 pub async fn server(port: u16) -> Result<()> {
+    let asym_keys = crate::AsymmetricKeys::generate();
     let listener = TcpListener::bind(format!("127.0.0.1:{}", &port)).await?;
-    println!("online as server at: {}:{}", listener.local_addr()?.ip(), port);
+
+    println!(
+        "online as server at: {}:{}",
+        listener.local_addr()?.ip(),
+        port
+    );
+
     let mut incoming = listener.incoming();
 
     while let Some(stream) = incoming.next().await {
@@ -31,28 +38,37 @@ pub async fn server(port: u16) -> Result<()> {
         let (read, write) = stream.split();
         let stream_id = Uuid::new_v4();
 
-        WRITE_STREAMS.lock().expect("could not aqcuire lock").insert(stream_id.clone(), write);
+        WRITE_STREAMS
+            .lock()
+            .expect("could not aqcuire lock")
+            .insert(stream_id.clone(), write);
+
         task::spawn(handle_stream(read, stream_id));
     }
 
     Ok(())
 }
 
-async fn handle_stream(mut stream: ReadHalf<TcpStream>, _stream_id: Uuid) -> Result<()> {
+async fn handle_stream(mut stream: ReadHalf<TcpStream>, stream_id: Uuid) -> Result<()> {
     loop {
         let packet = ilmp::read(&mut stream).await?;
         if let Some(packet) = packet {
             let res = match packet.kind {
                 ilmp::PacketKind::Message => ilmp::Message::from_packet(packet),
+                _ => unimplemented!(),
             };
             println!("{:?}", res);
+        } else {
+            // if no packet was received the stream is closed
+            break;
         }
     }
-    /*    println!("disconnecting");
-
-    WRITE_STREAMS.lock().expect("failed to aqcuire lock").remove(&stream_id);
-
-    Ok(())*/
+    println!("stream disconnected");
+    WRITE_STREAMS
+        .lock()
+        .expect("failed to aqcuire lock")
+        .remove(&stream_id);
+    Ok(())
 }
 
 /*async fn relay_packet<T: Clone + Sendable>(packet: T) -> Result<()> {