Deuxfleurs/aerogramme
15
0
Fork 1
Code Issues 33 Pull requests 1 Projects 11 Releases 5 Wiki Activity

in-memory storage #32

Merged
quentin merged 65 commits from in-memory into main 2023-12-27 16:35:43 +00:00
Conversation 0 Commits 65 Files changed 21 +6 -7
3 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 26f14df3f4 - Show all commits

5
src/mail/incoming.rs
View file

@ -23,6 +23,7 @@ use crate::mail::unique_ident::*;
use crate::mail::user::User; use crate::mail::user::User;
use crate::mail::IMF; use crate::mail::IMF;
use crate::time::now_msec; use crate::time::now_msec;
use crate::storage::Sto;
const INCOMING_PK: &str = "incoming"; const INCOMING_PK: &str = "incoming";
const INCOMING_LOCK_SK: &str = "lock"; const INCOMING_LOCK_SK: &str = "lock";
@ -139,14 +140,14 @@ async fn incoming_mail_watch_process_internal(
Ok(()) Ok(())
} }
async fn handle_incoming_mail( async fn handle_incoming_mail<X: Sto>(
user: &Arc<User>, user: &Arc<User>,
s3: &S3Client, s3: &S3Client,
inbox: &Arc<Mailbox>, inbox: &Arc<Mailbox>,
lock_held: &watch::Receiver<bool>, lock_held: &watch::Receiver<bool>,
) -> Result<()> { ) -> Result<()> {
let lor = ListObjectsV2Request { let lor = ListObjectsV2Request {
bucket: user.creds.storage.bucket.clone(), bucket: user.creds.storage.engine::<X>().bucket.clone(),
max_keys: Some(1000), max_keys: Some(1000),
prefix: Some("incoming/".into()), prefix: Some("incoming/".into()),
..Default::default() ..Default::default()

2
src/mail/user.rs
View file

@ -30,8 +30,6 @@ pub const INBOX: &str = "INBOX";
const MAILBOX_LIST_PK: &str = "mailboxes"; const MAILBOX_LIST_PK: &str = "mailboxes";
const MAILBOX_LIST_SK: &str = "list"; const MAILBOX_LIST_SK: &str = "list";
use crate::storage::*;
pub struct User { pub struct User {
pub username: String, pub username: String,
pub creds: Credentials, pub creds: Credentials,

6
src/storage/mod.rs
View file

@ -36,8 +36,8 @@ pub trait Sto: Sized {
} }
pub struct Engine<T: Sto> { pub struct Engine<T: Sto> {
bucket: String, pub bucket: String,
row: T::Builder, pub row: T::Builder,
} }
pub enum AnyEngine { pub enum AnyEngine {
@ -45,7 +45,7 @@ pub enum AnyEngine {
Garage(Engine<garage::GrgTypes>), Garage(Engine<garage::GrgTypes>),
} }
impl AnyEngine { impl AnyEngine {
fn engine<X: Sto>(&self) -> &Engine<X> { pub fn engine<X: Sto>(&self) -> &Engine<X> {
match self { match self {
Self::InMemory(x) => x, Self::InMemory(x) => x,
Self::Garage(x) => x, Self::Garage(x) => x,