From 04222fb8baea9247abe372cdc4382c64becc1a06 Mon Sep 17 00:00:00 2001
From: James Maes <jmaes@dmdbrands.com>
Date: Wed, 22 Jul 2026 19:53:58 -0500
Subject: [PATCH] test(integration): add ephemeral_harness test for
 multi-account lifecycle

---
 tests/ephemeral_harness.rs | 96 ++++++++++++++++++++++++++++++++++++++
 1 file changed, 96 insertions(+)
 create mode 100644 tests/ephemeral_harness.rs

diff --git a/tests/ephemeral_harness.rs b/tests/ephemeral_harness.rs
new file mode 100644
index 0000000..15446c2
--- /dev/null
+++ b/tests/ephemeral_harness.rs
@@ -0,0 +1,96 @@
+//! Ephemeral SQLite end-to-end integration test harness and WAL lifecycle verification.
+
+use nuncio_core::config::{AccountConfig, AccountProtocol};
+use nuncio_core::{AppState, CoreCommand, EngineStatus, EventBus};
+use nuncio_store::DatabaseEngine;
+use tempfile::tempdir;
+
+#[tokio::test]
+async fn test_ephemeral_harness_multi_account_lifecycle() {
+    let dir = tempdir().expect("tempdir created");
+    let db_path = dir.path().join("ephemeral_harness.sqlite");
+
+    // Initialize database engine
+    let db = DatabaseEngine::connect_file(&db_path)
+        .await
+        .expect("DB connected");
+
+    // Create 2 test account configurations
+    let acct1 = AccountConfig {
+        id: "acct-work".to_string(),
+        name: "Work Mail".to_string(),
+        email_address: "work@nuncio.mx".to_string(),
+        protocol: AccountProtocol::Jmap,
+        server_host: "jmap.nuncio.mx".to_string(),
+        server_port: 443,
+        use_tls: true,
+        keyring_secret_key: "nuncio/acct-work".to_string(),
+        sync_interval_secs: 30,
+    };
+    assert!(acct1.validate().is_ok());
+
+    let acct2 = AccountConfig {
+        id: "acct-personal".to_string(),
+        name: "Personal Mail".to_string(),
+        email_address: "personal@nuncio.mx".to_string(),
+        protocol: AccountProtocol::ImapSmtp,
+        server_host: "imap.nuncio.mx".to_string(),
+        server_port: 993,
+        use_tls: true,
+        keyring_secret_key: "nuncio/acct-personal".to_string(),
+        sync_interval_secs: 60,
+    };
+    assert!(acct2.validate().is_ok());
+
+    // Initialize EventBus seeded with 2 accounts loaded
+    let bus = EventBus::with_initial_state(AppState {
+        status: EngineStatus::Idle,
+        accounts_loaded: 2,
+        unread_count: 0,
+        last_error: None,
+    });
+
+    let mut state_rx = bus.subscribe_state();
+
+    // Trigger Account 1 Sync
+    bus.process_command(CoreCommand::SyncAccount {
+        account_id: acct1.id.clone(),
+    });
+    assert_eq!(
+        state_rx.borrow_and_update().status,
+        EngineStatus::Syncing
+    );
+
+    // Complete Account 1 Sync
+    bus.complete_sync(Some(acct1.id.clone()));
+    assert_eq!(state_rx.borrow_and_update().status, EngineStatus::Idle);
+
+    // Mark 3 unread messages
+    bus.process_command(CoreCommand::MarkRead {
+        message_id: "m1".to_string(),
+        read: false,
+    });
+    bus.process_command(CoreCommand::MarkRead {
+        message_id: "m2".to_string(),
+        read: false,
+    });
+    bus.process_command(CoreCommand::MarkRead {
+        message_id: "m3".to_string(),
+        read: false,
+    });
+    assert_eq!(state_rx.borrow_and_update().unread_count, 3);
+
+    // Shutdown Core
+    bus.process_command(CoreCommand::Shutdown);
+    assert_eq!(
+        state_rx.borrow_and_update().status,
+        EngineStatus::ShuttingDown
+    );
+
+    // Query database to ensure connection pool drops cleanly
+    let row: (i64,) = sqlx::query_as("SELECT COUNT(*) FROM messages")
+        .fetch_one(db.pool())
+        .await
+        .expect("query messages");
+    assert_eq!(row.0, 0);
+}
-- 
2.54.0