missive 0.6.2

Compose, deliver, preview, and test emails in Rust - pluggable providers with zero configuration code
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

//! Local adapter tests.
//!
//! Ported from Swoosh's local_test.exs

use missive::providers::LocalMailer;
use missive::{Email, Mailer};

// ============================================================================
// Basic Delivery Tests (matching Swoosh local_test.exs)
// ============================================================================

#[tokio::test]
async fn deliver_returns_ok() {
    let mailer = LocalMailer::new();

    let email = Email::new()
        .from("tony.stark@example.com")
        .to("steve.rogers@example.com")
        .subject("Hello, Avengers!")
        .text_body("Hello!");

    let result = mailer.deliver(&email).await;
    assert!(result.is_ok());
}

#[tokio::test]
async fn deliver_many_returns_ok() {
    let mailer = LocalMailer::new();

    let email_to_steve = Email::new()
        .from("tony.stark@example.com")
        .to("steve.rogers@example.com")
        .subject("Hello, Avengers!")
        .text_body("Hello!");

    let email_to_natasha = Email::new()
        .from("tony.stark@example.com")
        .to("natasha.romanoff@example.com")
        .subject("Hello, Avengers!")
        .text_body("Hello!");

    let result = mailer
        .deliver_many(&[email_to_steve, email_to_natasha])
        .await;
    assert!(result.is_ok());
    let ids = result.unwrap();
    assert_eq!(ids.len(), 2);
}

// ============================================================================
// Storage Tests
// ============================================================================

#[tokio::test]
async fn captures_sent_emails() {
    let mailer = LocalMailer::new();

    let email = Email::new()
        .from("tony.stark@example.com")
        .to("steve.rogers@example.com")
        .subject("Hello, Avengers!")
        .text_body("Hello!");

    mailer.deliver(&email).await.unwrap();

    assert!(mailer.has_emails());
    assert_eq!(mailer.email_count(), 1);
    assert!(mailer.sent_to("steve.rogers@example.com"));
    assert!(mailer.sent_with_subject("Hello, Avengers!"));
}

#[tokio::test]
async fn can_flush_emails() {
    let mailer = LocalMailer::new();

    mailer
        .deliver(&Email::new().from("a@b.com").to("c@d.com").subject("Test 1"))
        .await
        .unwrap();
    mailer
        .deliver(&Email::new().from("a@b.com").to("c@d.com").subject("Test 2"))
        .await
        .unwrap();

    let flushed = mailer.flush();
    assert_eq!(flushed.len(), 2);
    assert_eq!(mailer.email_count(), 0);
}

// ============================================================================
// Failure Simulation Tests
// ============================================================================

#[tokio::test]
async fn can_simulate_failure() {
    let mailer = LocalMailer::new();
    mailer.set_failure("SMTP connection refused");

    let email = Email::new()
        .from("tony.stark@example.com")
        .to("steve.rogers@example.com")
        .subject("Test");

    let result = mailer.deliver(&email).await;
    assert!(result.is_err());
    assert!(result
        .unwrap_err()
        .to_string()
        .contains("SMTP connection refused"));

    // Clear failure
    mailer.clear_failure();
    let result = mailer.deliver(&email).await;
    assert!(result.is_ok());
}

// ============================================================================
// Provider Name Test
// ============================================================================

#[test]
fn provider_name_returns_local() {
    let mailer = LocalMailer::new();
    assert_eq!(mailer.provider_name(), "local");
}