aboutsummaryrefslogtreecommitdiff
path: root/src/mail/mod.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-06-29 13:16:58 +0200
committerAlex Auvolat <alex@adnab.me>2022-06-29 13:16:58 +0200
commit1bc109df72a3d785211a128b3f28746232258924 (patch)
tree7f9698fb3b61aa506d0a1d8e0835db23b882e23a /src/mail/mod.rs
parent3cf91429c7eb675639fbcbf006e04d790645cf77 (diff)
downloadaerogramme-1bc109df72a3d785211a128b3f28746232258924.tar.gz
aerogramme-1bc109df72a3d785211a128b3f28746232258924.zip
Refactoring
Diffstat (limited to 'src/mail/mod.rs')
-rw-r--r--src/mail/mod.rs151
1 files changed, 2 insertions, 149 deletions
diff --git a/src/mail/mod.rs b/src/mail/mod.rs
index a130073..f696f6d 100644
--- a/src/mail/mod.rs
+++ b/src/mail/mod.rs
@@ -1,4 +1,6 @@
pub mod mail_ident;
+pub mod user;
+pub mod mailbox;
mod uidindex;
use std::convert::TryFrom;
@@ -16,152 +18,3 @@ use crate::mail::uidindex::*;
// Internet Message Format
// aka RFC 822 - RFC 2822 - RFC 5322
pub struct IMF(Vec<u8>);
-
-pub struct Summary<'a> {
- pub validity: ImapUidvalidity,
- pub next: ImapUid,
- pub exists: u32,
- pub recent: u32,
- pub flags: FlagIter<'a>,
- pub unseen: Option<&'a ImapUid>,
-}
-impl std::fmt::Display for Summary<'_> {
- fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
- write!(
- f,
- "uidvalidity: {}, uidnext: {}, exists: {}",
- self.validity, self.next, self.exists
- )
- }
-}
-
-// Non standard but common flags:
-// https://www.iana.org/assignments/imap-jmap-keywords/imap-jmap-keywords.xhtml
-pub struct Mailbox {
- bucket: String,
- pub name: String,
- key: Key,
-
- k2v: K2vClient,
- s3: S3Client,
-
- uid_index: Bayou<UidIndex>,
-}
-
-impl Mailbox {
- pub fn new(creds: &Credentials, name: String) -> Result<Self> {
- let uid_index = Bayou::<UidIndex>::new(creds, name.clone())?;
-
- Ok(Self {
- bucket: creds.bucket().to_string(),
- name,
- key: creds.keys.master.clone(),
- k2v: creds.k2v_client()?,
- s3: creds.s3_client()?,
- uid_index,
- })
- }
-
- // Get a summary of the mailbox, useful for the SELECT command for example
- pub async fn summary(&mut self) -> Result<Summary> {
- self.uid_index.sync().await?;
- let state = self.uid_index.state();
-
- let unseen = state
- .idx_by_flag
- .get(&"$unseen".to_string())
- .and_then(|os| os.get_min());
- let recent = state
- .idx_by_flag
- .get(&"\\Recent".to_string())
- .map(|os| os.len())
- .unwrap_or(0);
-
- return Ok(Summary {
- validity: state.uidvalidity,
- next: state.uidnext,
- exists: u32::try_from(state.idx_by_uid.len())?,
- recent: u32::try_from(recent)?,
- flags: state.idx_by_flag.flags(),
- unseen,
- });
- }
-
- // Insert an email in the mailbox
- pub async fn append(&mut self, _msg: IMF) -> Result<()> {
- Ok(())
- }
-
- // Copy an email from an external to this mailbox
- // @FIXME is it needed or could we implement it with append?
- pub async fn copy(&mut self, _mailbox: String, _uid: ImapUid) -> Result<()> {
- Ok(())
- }
-
- // Delete all emails with the \Delete flag in the mailbox
- // Can be called by CLOSE and EXPUNGE
- // @FIXME do we want to implement this feature or a simpler "delete" command
- // The controller could then "fetch \Delete" and call delete on each email?
- pub async fn expunge(&mut self) -> Result<()> {
- Ok(())
- }
-
- // Update flags of a range of emails
- pub async fn store(&mut self) -> Result<()> {
- Ok(())
- }
-
- pub async fn fetch(&mut self) -> Result<()> {
- Ok(())
- }
-
- pub async fn test(&mut self) -> Result<()> {
- self.uid_index.sync().await?;
-
- dump(&self.uid_index);
-
- let add_mail_op = self
- .uid_index
- .state()
- .op_mail_add(gen_ident(), vec!["\\Unseen".into()]);
- self.uid_index.push(add_mail_op).await?;
-
- dump(&self.uid_index);
-
- if self.uid_index.state().idx_by_uid.len() > 6 {
- for i in 0..2 {
- let (_, ident) = self
- .uid_index
- .state()
- .idx_by_uid
- .iter()
- .skip(3 + i)
- .next()
- .unwrap();
- let del_mail_op = self.uid_index.state().op_mail_del(*ident);
- self.uid_index.push(del_mail_op).await?;
-
- dump(&self.uid_index);
- }
- }
-
- Ok(())
- }
-}
-
-fn dump(uid_index: &Bayou<UidIndex>) {
- let s = uid_index.state();
- println!("---- MAILBOX STATE ----");
- println!("UIDVALIDITY {}", s.uidvalidity);
- println!("UIDNEXT {}", s.uidnext);
- println!("INTERNALSEQ {}", s.internalseq);
- for (uid, ident) in s.idx_by_uid.iter() {
- println!(
- "{} {} {}",
- uid,
- hex::encode(ident.0),
- s.table.get(ident).cloned().unwrap().1.join(", ")
- );
- }
- println!("");
-}