Struct vsmtp_server::Connection

pub struct Connection<S>where
    S: AsyncRead + AsyncWrite + Send + Unpin + Debug,{
    pub kind: ConnectionKind,
    pub context: ConnectionContext,
    pub config: Arc<Config>,
    pub inner: AbstractIO<S>,
}

Instance containing connection to the server’s information

Fields

kind: ConnectionKind

Kind of connection

context: ConnectionContext

Data related to this connection

config: Arc<Config>

server’s configuration

inner: AbstractIO<S>

inner stream

Implementations

impl<S> Connection<S>where
    S: AsyncRead + AsyncWrite + Send + Unpin + Debug,

pub fn new(
    kind: ConnectionKind,
    client_addr: SocketAddr,
    server_addr: SocketAddr,
    config: Arc<Config>,
    inner: S
) -> Self

impl<S> Connection<S>where
    S: AsyncRead + AsyncWrite + Send + Unpin + Debug,

pub async fn send_reply_or_code(
    &mut self,
    reply_or_code: ReplyOrCodeID
) -> Result<()>

Errors

• see Connection::send_code and Connection::send_reply

pub async fn send_code(&mut self, code_id: CodeID) -> Result<()>

Errors

pub async fn send_reply(&mut self, reply: Reply) -> Result<()>

send a reply code to the client

Errors

pub async fn send(&mut self, reply: &str) -> Result<()>

Send a buffer

Errors

• internal connection writer error

pub async fn read(&mut self, timeout: Duration) -> Result<Option<String>>

Read a line from the client

Errors

• timed-out
• internal connection reader error

impl<S> Connection<S>where
    S: AsyncRead + AsyncWrite + Send + Unpin + Sync + Debug,

pub async fn receive<M>(
    &mut self,
    tls_config: Option<Arc<ServerConfig>>,
    rule_engine: Arc<RuleEngine>,
    resolvers: Arc<DnsResolvers>,
    queue_manager: Arc<dyn GenericQueueManager>,
    mail_handler: &mut M
) -> Result<()>where
    M: OnMail + Send,

Receives the incomings mail of a connection

Errors

• server failed to send a message
• a transaction failed
• the pre-queue processing of the mail failed

Trait Implementations

impl<S> Debug for Connection<S>where
    S: AsyncRead + AsyncWrite + Send + Unpin + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.