diff --git a/src/imap/command/anonymous.rs b/src/imap/command/anonymous.rs index 8de27cb..2ab3f97 100644 --- a/src/imap/command/anonymous.rs +++ b/src/imap/command/anonymous.rs @@ -1,8 +1,8 @@ use anyhow::{Error, Result}; -use boitalettres::proto::Response; +use boitalettres::proto::{res::body::Data as Body, Response}; use imap_codec::types::command::CommandBody; -use imap_codec::types::core::AString; -use imap_codec::types::response::{Capability, Data, Response as ImapRes, Status}; +use imap_codec::types::core::{AString, Atom}; +use imap_codec::types::response::{Capability, Code, Data, Response as ImapRes, Status}; use crate::imap::flow; use crate::imap::session::InnerContext; @@ -13,6 +13,7 @@ pub async fn dispatch<'a>(ctx: InnerContext<'a>) -> Result<(Response, flow::Tran match &ctx.req.command.body { CommandBody::Noop => Ok((Response::ok("Noop completed.")?, flow::Transition::No)), CommandBody::Capability => capability(ctx).await, + CommandBody::Logout => logout(ctx).await, CommandBody::Login { username, password } => login(ctx, username, password).await, _ => Ok(( Response::no("This command is not available in the ANONYMOUS state.")?, @@ -59,3 +60,17 @@ async fn login<'a>( flow::Transition::Authenticate(user), )) } +// C: 10 logout +// S: * BYE Logging out +// S: 10 OK Logout completed. +async fn logout<'a>(ctx: InnerContext<'a>) -> Result<(Response, flow::Transition)> { + // @FIXME we should implement From> and From> in + // boitalettres/src/proto/res/body.rs + Ok(( + Response::ok("Logout completed")?.with_body(vec![Body::Status( + Status::bye(None, "Logging out") + .map_err(|e| Error::msg(e).context("Unable to generate IMAP status"))?, + )]), + flow::Transition::Logout, + )) +} diff --git a/src/imap/command/authenticated.rs b/src/imap/command/authenticated.rs index 4ba4968..f22fcc4 100644 --- a/src/imap/command/authenticated.rs +++ b/src/imap/command/authenticated.rs @@ -144,7 +144,9 @@ impl<'a> StateContext<'a> { res.push(Body::Status(permanent_flags)); Ok(( - Response::ok("Select completed")?.with_body(res), + Response::ok("Select completed")? + .with_extra_code(Code::ReadWrite) + .with_body(res), flow::Transition::Select(mb), )) } diff --git a/src/imap/session.rs b/src/imap/session.rs index d45a989..2fa413e 100644 --- a/src/imap/session.rs +++ b/src/imap/session.rs @@ -127,7 +127,7 @@ impl Instance { //@FIXME remove unwrap self.state = self.state.apply(tr).unwrap(); - //@FIXME enrich here the command with some status + //@FIXME enrich here the command with some global status Ok(res) }