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

use bytes::{Buf, BytesMut};
use tokio_util::codec::Decoder;

use crate::parser::parse_streamed_response;
use crate::response::Response;

#[derive(Default)]
pub struct ImapCodec;

impl Decoder for ImapCodec {
    type Item = Response;
    type Error = anyhow::Error;

    fn decode(&mut self, src: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error> {
        let s = std::str::from_utf8(src)?;
        // trace!("codec parsing {:?}", s);
        match parse_streamed_response(s) {
            Ok((resp, len)) => {
                src.advance(len);
                return Ok(Some(resp));
            }
            // TODO: distinguish between incomplete data and a parse error
            Err(e) => {}
        };

        Ok(None)
    }
}