diff options
| author | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-11-23 15:16:44 +0100 |
|---|---|---|
| committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-11-23 15:16:44 +0100 |
| commit | 8cd9801030e24c58621b3bed8723e8a8a4722ef8 (patch) | |
| tree | 4272b416e50705288dc568d5b65a309a59037c3c /src/mail/incoming.rs | |
| parent | 14c7a96c282e20ff0d5343a7a378554f34983d21 (diff) | |
| download | aerogramme-8cd9801030e24c58621b3bed8723e8a8a4722ef8.tar.gz aerogramme-8cd9801030e24c58621b3bed8723e8a8a4722ef8.zip | |
various fixes
Diffstat (limited to 'src/mail/incoming.rs')
| -rw-r--r-- | src/mail/incoming.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mail/incoming.rs b/src/mail/incoming.rs index da4c819..e3c729f 100644 --- a/src/mail/incoming.rs +++ b/src/mail/incoming.rs @@ -361,7 +361,7 @@ async fn k2v_lock_loop_internal( Some(orphan) => k2v.from_orphan(orphan).expect("Source & target must be storage compatible"), None => k2v.row(pk, sk), }; - if let Err(e) = row.set_value(lock).push().await { + if let Err(e) = row.set_value(&lock).push().await { error!("Could not take lock: {}", e); tokio::time::sleep(Duration::from_secs(30)).await; } @@ -432,7 +432,7 @@ impl EncryptedMessage { send.push().await?; // Update watch key to signal new mail - watch_ct.set_value(gen_ident().0.to_vec()).push().await?; + watch_ct.set_value(gen_ident().0.as_ref()).push().await?; Ok(()) } |