aboutsummaryrefslogtreecommitdiff
path: root/src/mail/incoming.rs
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2023-11-02 10:38:47 +0100
committerQuentin Dufour <quentin@deuxfleurs.fr>2023-11-02 10:38:47 +0100
commit9aa58194d44fef8b0b916f6c96edd124ce13bf7b (patch)
tree7d8fecdddad2212096fd8a36a03805d5aaee3114 /src/mail/incoming.rs
parent415f51ac4cfc723bbf6f0c08d57fb86e96c665a2 (diff)
downloadaerogramme-9aa58194d44fef8b0b916f6c96edd124ce13bf7b.tar.gz
aerogramme-9aa58194d44fef8b0b916f6c96edd124ce13bf7b.zip
try dynamic dispatch
Diffstat (limited to 'src/mail/incoming.rs')
-rw-r--r--src/mail/incoming.rs5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/mail/incoming.rs b/src/mail/incoming.rs
index 7094b42..b7d2f48 100644
--- a/src/mail/incoming.rs
+++ b/src/mail/incoming.rs
@@ -23,7 +23,6 @@ use crate::mail::unique_ident::*;
use crate::mail::user::User;
use crate::mail::IMF;
use crate::time::now_msec;
-use crate::storage::Sto;
const INCOMING_PK: &str = "incoming";
const INCOMING_LOCK_SK: &str = "lock";
@@ -140,14 +139,14 @@ async fn incoming_mail_watch_process_internal(
Ok(())
}
-async fn handle_incoming_mail<X: Sto>(
+async fn handle_incoming_mail(
user: &Arc<User>,
s3: &S3Client,
inbox: &Arc<Mailbox>,
lock_held: &watch::Receiver<bool>,
) -> Result<()> {
let lor = ListObjectsV2Request {
- bucket: user.creds.storage.engine::<X>().bucket.clone(),
+ bucket: user.creds.storage.bucket.clone(),
max_keys: Some(1000),
prefix: Some("incoming/".into()),
..Default::default()