diff options
author | Quentin Dufour <quentin@deuxfleurs.fr> | 2022-06-07 12:38:59 +0200 |
---|---|---|
committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2022-06-07 12:38:59 +0200 |
commit | b82df13082869dc4d455e15c2955e20de0b55675 (patch) | |
tree | 05d0644988351b2dd8181862094cd59f98764160 /src/instance.rs | |
parent | 16e66cb56357f81bf026b7da93d8fb48237a7a71 (diff) | |
download | aerogramme-b82df13082869dc4d455e15c2955e20de0b55675.tar.gz aerogramme-b82df13082869dc4d455e15c2955e20de0b55675.zip |
Refactor
Diffstat (limited to 'src/instance.rs')
-rw-r--r-- | src/instance.rs | 34 |
1 files changed, 0 insertions, 34 deletions
diff --git a/src/instance.rs b/src/instance.rs deleted file mode 100644 index 6e11be5..0000000 --- a/src/instance.rs +++ /dev/null @@ -1,34 +0,0 @@ -use std::sync::Arc; -use std::task::{Context, Poll}; - -use anyhow::Result; -use boitalettres::server::accept::addr::AddrStream; -use futures::future::BoxFuture; -use tower::Service; - -use crate::connection::Connection; -use crate::mailstore::Mailstore; - -pub struct Instance { - pub mailstore: Arc<Mailstore>, -} -impl Instance { - pub fn new(mailstore: Arc<Mailstore>) -> Self { - Self { mailstore } - } -} -impl<'a> Service<&'a AddrStream> for Instance { - type Response = Connection; - type Error = anyhow::Error; - type Future = BoxFuture<'static, Result<Self::Response>>; - - fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { - Poll::Ready(Ok(())) - } - - fn call(&mut self, addr: &'a AddrStream) -> Self::Future { - tracing::info!(remote_addr = %addr.remote_addr, local_addr = %addr.local_addr, "accept"); - let ms = self.mailstore.clone(); - Box::pin(async { Ok(Connection::new(ms)) }) - } -} |