io-email 0.1.0

Email client library
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

//! m2dir message-delete coroutine wrapping
//! [`io_m2dir::entry::delete::M2dirEntryDelete`]: removes the entry
//! and every .meta/\<id\>.* sidecar.
//!
//! # Example
//!
//! ```rust,ignore
//! use io_email::message::m2dir::delete::M2dirMessageDelete;
//!
//! client.run(M2dirMessageDelete::new(&client.root, "INBOX", "msg-id")?)?;
//! ```

use std::path::PathBuf;

use io_m2dir::{
    coroutine::*,
    entry::delete::{
        M2dirEntryDelete as InnerDelete, M2dirEntryDeleteError as InnerErr,
        M2dirEntryDeleteOptions as InnerOpts,
    },
};
use log::trace;
use thiserror::Error;

use crate::m2dir::convert::{InvalidMailboxName, resolve_mailbox};

/// Errors produced by [`M2dirMessageDelete`].
#[derive(Debug, Error)]
pub enum M2dirMessageDeleteError {
    #[error(transparent)]
    Delete(#[from] InnerErr),
    #[error(transparent)]
    InvalidMailbox(#[from] InvalidMailboxName),
}

/// I/O-free coroutine deleting a single m2dir message.
pub struct M2dirMessageDelete {
    inner: InnerDelete,
}

impl M2dirMessageDelete {
    pub fn new(
        root: impl Into<PathBuf>,
        mailbox: &str,
        id: &str,
    ) -> Result<Self, M2dirMessageDeleteError> {
        trace!("prepare m2dir message delete");
        let m2dir = resolve_mailbox(root, mailbox)?;
        Ok(Self {
            inner: InnerDelete::new(m2dir, id, InnerOpts::default()),
        })
    }
}

impl M2dirCoroutine for M2dirMessageDelete {
    type Yield = M2dirYield;
    type Return = Result<(), M2dirMessageDeleteError>;

    fn resume(&mut self, arg: Option<M2dirArg>) -> M2dirCoroutineState<Self::Yield, Self::Return> {
        match self.inner.resume(arg) {
            M2dirCoroutineState::Yielded(y) => M2dirCoroutineState::Yielded(y),
            M2dirCoroutineState::Complete(r) => {
                M2dirCoroutineState::Complete(r.map_err(Into::into))
            }
        }
    }
}