start working towards http connector

rama-old/Cargo.toml

@@ -11,7 +11,7 @@ license = "MIT OR Apache-2.0"
 repository = "/~https://github.com/plabayo/rama"
 
 [[bin]]
-name = "rama"
+name = "rama-old"
 path = "./bin/main.rs"
 
 [features]

rama/src/server/http/conn.rs

@@ -0,0 +1 @@
+pub struct HttpConnection;

rama/src/server/http/mod.rs

@@ -1 +1,4 @@
 pub mod service;
+
+mod conn;
+pub use conn::HttpConnection;

rama/src/server/tcp/stream.rs

@@ -10,7 +10,7 @@ use tokio::{
     net::TcpStream as TokioTcpStream,
 };
 
-use crate::state::Extensions;
+use crate::state::{Extendable, Extensions};
 
 pin_project_lite::pin_project! {
     #[derive(Debug)]
@@ -29,14 +29,6 @@ impl TcpStream {
         }
     }
 
-    pub fn extensions(&self) -> &Extensions {
-        &self.extensions
-    }
-
-    pub fn extensions_mut(&mut self) -> &mut Extensions {
-        &mut self.extensions
-    }
-
     pub fn peer_addr(&self) -> io::Result<SocketAddr> {
         self.inner.peer_addr()
     }
@@ -54,6 +46,16 @@ impl TcpStream {
     }
 }
 
+impl Extendable for TcpStream {
+    fn extensions(&self) -> &Extensions {
+        &self.extensions
+    }
+
+    fn extensions_mut(&mut self) -> &mut Extensions {
+        &mut self.extensions
+    }
+}
+
 impl AsyncRead for TcpStream {
     fn poll_read(
         self: Pin<&mut Self>,

rama/src/state.rs

@@ -1 +1,36 @@
 pub use http::Extensions;
+
+pub trait Extendable {
+    fn extensions(&self) -> &Extensions;
+    fn extensions_mut(&mut self) -> &mut Extensions;
+}
+
+impl Extendable for Extensions {
+    fn extensions(&self) -> &Extensions {
+        self
+    }
+
+    fn extensions_mut(&mut self) -> &mut Extensions {
+        self
+    }
+}
+
+impl<T> Extendable for http::Request<T> {
+    fn extensions(&self) -> &Extensions {
+        self.extensions()
+    }
+
+    fn extensions_mut(&mut self) -> &mut Extensions {
+        self.extensions_mut()
+    }
+}
+
+impl<T> Extendable for http::Response<T> {
+    fn extensions(&self) -> &Extensions {
+        self.extensions()
+    }
+
+    fn extensions_mut(&mut self) -> &mut Extensions {
+        self.extensions_mut()
+    }
+}