Something went wrong. Try again.
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256use chrono::Utc;
use super::StandardFolder;use crate::store::{ Database, model::OwnerType, repo::{infra, mail},};
fn now_stamp() -> String { Utc::now().format("%Y-%m-%dT%H:%M:%SZ").to_string()}
pub(super) async fn toggle_star(db: Database, character_id: i64, mail_id: i64) { let overlay = mail::overlay_state(&db, character_id, mail_id) .await .unwrap_or_default(); set_triage(&db, character_id, mail_id, !overlay.is_starred).await;}
async fn set_triage(db: &Database, character_id: i64, mail_id: i64, star: bool) { if star { let _ = mail::set_triage(db, character_id, mail_id, star).await; } else { let _ = mail::clear_triage(db, character_id, mail_id).await; }}
pub(super) async fn archive(db: Database, character_id: i64, mail_id: i64) { let _ = mail::assign_folder(&db, character_id, mail_id, "archive", None, false, &now_stamp()).await;}
pub(super) async fn trash(db: Database, character_id: i64, mail_id: i64) { let _ = mail::assign_folder(&db, character_id, mail_id, "trash", None, false, &now_stamp()).await;}
/// Permanently deletes a trashed mail from both Pod and the EVE mailbox. Snapshots every local row,/// purges them optimistically (the row vanishes immediately), then appends a `mail.delete` outbox/// row carrying the snapshot. The SAGA executes the ESI delete and, only on permanent failure,/// restores the mail from the snapshot. A no-op when the mail has already been purged.pub(super) async fn delete(db: Database, character_id: i64, mail_id: i64) { let Ok(Some(snapshot)) = mail::snapshot_mail(&db, character_id, mail_id).await else { return; }; let _ = mail::purge_mail(&db, character_id, mail_id).await;
let Ok(payload) = serde_json::to_string(&snapshot) else { return; }; let dedupe = format!("delete_mail:{mail_id}"); let _ = infra::append( &db, OwnerType::Character, character_id, "mail.delete", &payload, Some(&dedupe), ) .await;}
/// Move a dragged message into one of the standard boxes as a pure local move (no ESI write)./// Any active snooze is cleared first so the mail surfaces in its new box immediately. Inbox is the/// "no overlay" state, so it clears any folder assignment; Archive/Trash file the mail into that box.pub(super) async fn move_to_box(db: Database, character_id: i64, mail_id: i64, folder: StandardFolder) { let _ = mail::delete_snoozed_mail(&db, character_id, mail_id).await; match folder { StandardFolder::Inbox => { let _ = mail::clear_folder(&db, character_id, mail_id).await; } StandardFolder::Archive => { let _ = mail::assign_folder(&db, character_id, mail_id, "archive", None, false, &now_stamp()).await; } StandardFolder::Trash => { let _ = mail::assign_folder(&db, character_id, mail_id, "trash", None, false, &now_stamp()).await; } StandardFolder::Drafts | StandardFolder::Sent | StandardFolder::Snoozed | StandardFolder::Starred => {} }}
#[cfg(test)]mod tests { use pretty_assertions::assert_eq;
use super::*; use crate::store::{ self, model::{Alliance, Bloodline, Character, Corporation, Gender, Race}, repo::character, };
async fn seed_character(db: &Database, id: i64) { let corp_id = 90_000_001; let alliance_id = 99_000_001; let alliance = Alliance::new(alliance_id, corp_id, id, "2003-01-01", "Test Alliance", "TST"); let race = Race::new(2, alliance_id, "A race.", "Caldari"); let mut corp = Corporation::new(corp_id, "Test Corp", "TSC"); corp.set_ceo_id(id); corp.set_creator_id(id); corp.set_member_count(1); corp.set_tax_rate(0.0); let bloodline = Bloodline::new(1, corp_id, 2, 3, "A bloodline.", 4, 5, "Civire", 4, 4); let character = Character::new(id, 1, corp_id, 2, "2003-05-12", Gender::Male, "Pilot"); character::insert_with_org(db, &character, &bloodline, &race, &corp, Some(&alliance), None) .await .unwrap(); }
#[tokio::test] async fn it_archives_as_a_pure_local_move_with_no_outbox_write() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await;
archive(db.clone(), 42, 7).await;
assert_eq!(mail::folder(&db, 42, 7).await.unwrap().unwrap().folder(), "archive"); let outbox = sqlx::query_scalar::<_, i64>("SELECT COUNT(*) FROM outbox") .fetch_one(&db.0) .await .unwrap(); assert_eq!(outbox, 0); }
#[tokio::test] async fn it_clears_the_triage_row_when_the_star_drops_to_false() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await; mail::set_triage(&db, 42, 7, true).await.unwrap();
toggle_star(db.clone(), 42, 7).await;
assert!(mail::triage(&db, 42, 7).await.unwrap().is_none()); assert!(mail::starred_mail_ids(&db, 42).await.unwrap().is_empty()); }
#[tokio::test] async fn it_stars_an_unstarred_mail() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await;
toggle_star(db.clone(), 42, 7).await;
let row = mail::triage(&db, 42, 7).await.unwrap().unwrap(); assert!(row.star()); }
#[tokio::test] async fn it_trashes_as_a_pure_local_move_with_no_outbox_write() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await;
trash(db.clone(), 42, 7).await;
assert_eq!(mail::folder(&db, 42, 7).await.unwrap().unwrap().folder(), "trash"); let outbox = sqlx::query_scalar::<_, i64>("SELECT COUNT(*) FROM outbox") .fetch_one(&db.0) .await .unwrap(); assert_eq!(outbox, 0); }
async fn store_mail(db: &Database, character_id: i64, mail_id: i64) { use crate::store::model::{CharacterMail, CharacterMailBody}; let header = CharacterMail { character_id, from_id: 95_000_001, from_name: "Sender".to_owned(), mail_id, subject: Some("Subject".to_owned()), timestamp: "2026-06-01T10:00:00Z".to_owned(), ..Default::default() }; let body = CharacterMailBody { body: "<p>hi</p>".to_owned(), character_id, mail_id, }; mail::upsert_complete(db, &header, &body, &[]).await.unwrap(); }
#[tokio::test] async fn it_optimistically_purges_the_mail_and_enqueues_a_delete_on_delete() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await; store_mail(&db, 42, 7).await; mail::assign_folder(&db, 42, 7, "trash", None, false, "2026-06-01T00:00:00Z") .await .unwrap();
delete(db.clone(), 42, 7).await;
assert!(mail::snapshot_mail(&db, 42, 7).await.unwrap().is_none()); let outbox = sqlx::query_scalar::<_, i64>("SELECT COUNT(*) FROM outbox WHERE kind = 'mail.delete'") .fetch_one(&db.0) .await .unwrap(); assert_eq!(outbox, 1); }
#[tokio::test] async fn it_is_a_no_op_when_the_mail_is_already_gone_on_delete() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await;
delete(db.clone(), 42, 7).await;
let outbox = sqlx::query_scalar::<_, i64>("SELECT COUNT(*) FROM outbox") .fetch_one(&db.0) .await .unwrap(); assert_eq!(outbox, 0); }
#[tokio::test] async fn it_clears_the_snooze_when_a_snoozed_mail_is_dropped_into_a_box() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await; mail::upsert_snoozed_mail(&db, 42, 7, "2099-01-01T00:00:00Z") .await .unwrap();
move_to_box(db.clone(), 42, 7, StandardFolder::Archive).await;
assert!(mail::all_snoozed_mails(&db, 42).await.unwrap().is_empty()); assert_eq!(mail::folder(&db, 42, 7).await.unwrap().unwrap().folder(), "archive"); }
#[tokio::test] async fn it_returns_a_trashed_mail_to_the_inbox_by_clearing_its_folder() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await; mail::assign_folder(&db, 42, 7, "trash", None, false, "2026-06-01T00:00:00Z") .await .unwrap();
move_to_box(db.clone(), 42, 7, StandardFolder::Inbox).await;
assert!(mail::folder(&db, 42, 7).await.unwrap().is_none()); let outbox = sqlx::query_scalar::<_, i64>("SELECT COUNT(*) FROM outbox") .fetch_one(&db.0) .await .unwrap(); assert_eq!(outbox, 0); }
#[tokio::test] async fn it_trashes_a_mail_dropped_onto_the_trash_box() { let db = store::open_test().await.unwrap(); seed_character(&db, 42).await;
move_to_box(db.clone(), 42, 7, StandardFolder::Trash).await;
assert_eq!(mail::folder(&db, 42, 7).await.unwrap().unwrap().folder(), "trash"); }}