feat: IMAP COMPRESS support

Author: link2xt

Cargo.lock

@@ -41,7 +41,7 @@ ratelimit = { path = "./deltachat-ratelimit" }
 anyhow = { workspace = true }
 async-broadcast = "0.7.1"
 async-channel = { workspace = true }
-async-imap = { version = "0.10.1", default-features = false, features = ["runtime-tokio"] }
+async-imap = { git = "https://github.com/async-email/async-imap.git", default-features = false, features = ["runtime-tokio", "compress"], branch = "link2xt/imap-compress" }
 async-native-tls = { version = "0.5", default-features = false, features = ["runtime-tokio"] }
 async-smtp = { version = "0.9", default-features = false, features = ["runtime-tokio"] }
 async_zip = { version = "0.0.12", default-features = false, features = ["deflate", "fs"] }

Cargo.toml

@@ -90,7 +90,14 @@ impl Client {
             .await
             .map_err(|(err, _client)| err)?;
         let capabilities = determine_capabilities(&mut session).await?;
-        Ok(Session::new(session, capabilities))
+        let compressed_session = session
+            .compress(|s| {
+                let session_stream: Box<dyn SessionStream> = Box::new(s);
+                session_stream
+            })
+            .await?
+            .unwrap();
+        Ok(Session::new(compressed_session, capabilities))
     }
 
     pub(crate) async fn authenticate(

src/imap/client.rs

@@ -50,6 +50,11 @@ impl<T: SessionStream> SessionStream for ShadowsocksStream<T> {
         self.stream.get_mut().set_read_timeout(timeout)
     }
 }
+impl<T: SessionStream> SessionStream for async_imap::deflate::DeflateStream<T> {
+    fn set_read_timeout(&mut self, timeout: Option<Duration>) {
+        //self.stream.get_mut().set_read_timeout(timeout)
+    }
+}
 
 /// Session stream with a read buffer.
 pub(crate) trait SessionBufStream: SessionStream + AsyncBufRead {}