email/email/message/get/
imap.rs

1use async_trait::async_trait;
2use imap_client::imap_next::imap_types::sequence::{Sequence, SequenceSet};
3use tracing::{debug, info};
4use utf7_imap::encode_utf7_imap as encode_utf7;
5
6use super::{GetMessages, Messages};
7use crate::{envelope::Id, imap::ImapContext, AnyResult};
8
9#[derive(Clone, Debug)]
10pub struct GetImapMessages {
11    ctx: ImapContext,
12}
13
14impl GetImapMessages {
15    pub fn new(ctx: &ImapContext) -> Self {
16        Self { ctx: ctx.clone() }
17    }
18
19    pub fn new_boxed(ctx: &ImapContext) -> Box<dyn GetMessages> {
20        Box::new(Self::new(ctx))
21    }
22
23    pub fn some_new_boxed(ctx: &ImapContext) -> Option<Box<dyn GetMessages>> {
24        Some(Self::new_boxed(ctx))
25    }
26}
27
28#[async_trait]
29impl GetMessages for GetImapMessages {
30    async fn get_messages(&self, folder: &str, id: &Id) -> AnyResult<Messages> {
31        info!("getting messages {id} from folder {folder}");
32
33        let mut client = self.ctx.client().await;
34        let config = &client.account_config;
35
36        let folder = config.get_folder_alias(folder);
37        let folder_encoded = encode_utf7(folder.clone());
38        debug!("utf7 encoded folder: {folder_encoded}");
39
40        let uids: SequenceSet = match id {
41            Id::Single(id) => Sequence::try_from(id.as_str()).unwrap().into(),
42            Id::Multiple(ids) => ids
43                .iter()
44                .filter_map(|id| Sequence::try_from(id.as_str()).ok())
45                .collect::<Vec<_>>()
46                .try_into()
47                .unwrap(),
48        };
49
50        client.select_mailbox(&folder_encoded).await?;
51        let msgs = client.fetch_messages(uids).await?;
52
53        Ok(msgs)
54    }
55}
email/email/message/get/imap.rs

email/email/message/get/
imap.rs
