initialize aws sdk with our info

1 files changed, 3 insertions, 3 deletions

diff --git a/src/mail/incoming.rs b/src/mail/incoming.rs
index 2a6c947..3eafac7 100644
--- a/src/mail/incoming.rs
+++ b/src/mail/incoming.rs
@@ -51,8 +51,8 @@ async fn incoming_mail_watch_process_internal(
     creds: Credentials,
     mut rx_inbox_id: watch::Receiver<Option<(UniqueIdent, ImapUidvalidity)>>,
 ) -> Result<()> {
-    let mut lock_held = k2v_lock_loop(creds.storage.build()?, storage::RowRef::new(INCOMING_PK, INCOMING_LOCK_SK));
-    let storage = creds.storage.build()?;
+    let mut lock_held = k2v_lock_loop(creds.storage.build().await?, storage::RowRef::new(INCOMING_PK, INCOMING_LOCK_SK));
+    let storage = creds.storage.build().await?;
 
     let mut inbox: Option<Arc<Mailbox>> = None;
     let mut incoming_key = storage::RowRef::new(INCOMING_PK, INCOMING_WATCH_SK);
@@ -411,7 +411,7 @@ impl EncryptedMessage {
     }
 
     pub async fn deliver_to(self: Arc<Self>, creds: PublicCredentials) -> Result<()> {
-        let storage = creds.storage.build()?;
+        let storage = creds.storage.build().await?;
 
         // Get causality token of previous watch key
         let query = storage::RowRef::new(INCOMING_PK, INCOMING_WATCH_SK);