rs-smtp 0.1.0

An ESMTP server library written in Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use std::sync::{Arc, Mutex};

use anyhow::Result;
use thiserror::Error;
use tokio::io::{AsyncWrite, AsyncRead};

use super::pipeline::Pipeline;
use super::writer::Writer;

#[derive(Error, Debug)]
struct MyError {
    code: u16,
    msg: String,
}

impl std::fmt::Display for MyError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "{} {}", self.code, self.msg)
    }
}

pub struct Conn<W: AsyncWrite + Unpin> {
    pub writer: Writer<W>,
    pub pipeline: Pipeline,
}

impl<W: AsyncWrite + Unpin> Conn<W> {
    pub fn new(stream: Arc<tokio::sync::Mutex<W>>) -> Self {

        Self {
            writer: Writer::new(stream),
            pipeline: Pipeline::new(),
        }
    }

    pub async fn cmd(&mut self, line: &str) -> Result<u64> {
        let id = self.pipeline.next();
        self.pipeline.start_request(id).await;
        let res = self.writer.print_line(line).await;
        self.pipeline.end_request(id);
        res?;
        Ok(id)
    }
}