better-auth-api 1.0.0-alpha.4

Plugin implementations for better-auth
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

use super::{EmailVerificationCallbacks, EmailVerificationConfig, VerificationEmail};
use crate::plugins::endpoint_context::EndpointContext;
use better_auth_core::{AuthContext, AuthResult, AuthSchema, background::BackgroundFuture};
use std::sync::Arc;

pub(crate) fn available<S: AuthSchema>(
    config: Option<&EmailVerificationConfig>,
    ctx: &AuthContext<S>,
) -> bool {
    ctx.extensions
        .get::<Arc<EmailVerificationCallbacks<S>>>()
        .is_some()
        || config.is_some_and(|config| config.send_verification_email.is_some())
        || ctx.email_verification_policy.override_sender.is_some()
        || crate::plugins::email_otp::callbacks::overrides_verification(ctx)
        || (config.is_some_and(|config| config.send_email_notifications)
            && ctx.email_provider.is_some())
}

/// Construct delivery before scheduling so synchronous callback errors reach the endpoint.
pub(crate) fn delivery<S: AuthSchema>(
    config: Option<&EmailVerificationConfig>,
    message: VerificationEmail,
    endpoint: &EndpointContext<'_, S>,
) -> AuthResult<Option<BackgroundFuture>> {
    let ctx = endpoint.auth;
    if ctx
        .extensions
        .get::<Arc<EmailVerificationCallbacks<S>>>()
        .is_none()
        && config.is_none_or(|config| config.send_verification_email.is_none())
        && crate::plugins::email_otp::callbacks::overrides_verification(ctx)
    {
        let retained = endpoint.to_owned();
        let email = message.user.email.unwrap_or_default();
        return Ok(Some(Box::pin(async move {
            crate::plugins::email_otp::callbacks::send_verification_override(
                &email,
                &retained.as_endpoint(),
            )
            .await
        })));
    }
    if let Some(callbacks) = ctx.extensions.get::<Arc<EmailVerificationCallbacks<S>>>() {
        return (callbacks.sender)(&message, endpoint);
    }
    if let Some(sender) = config
        .and_then(|config| config.send_verification_email.as_ref())
        .or(ctx.email_verification_policy.override_sender.as_ref())
    {
        let sender = sender.clone();
        return Ok(Some(Box::pin(async move {
            sender
                .send(&message.user, &message.url, &message.token)
                .await
        })));
    }
    if config.is_some_and(|config| config.send_email_notifications) {
        if let Some(provider) = ctx.email_provider.clone() {
            return Ok(Some(Box::pin(async move {
                let html = format!(
                    "<p>Click the link below to verify your email address:</p><p><a href=\"{url}\">Verify Email</a></p>",
                    url = message.url
                );
                let text = format!("Verify your email address: {}", message.url);
                provider
                    .send(
                        message.user.email.as_deref().unwrap_or_default(),
                        "Verify your email address",
                        &html,
                        &text,
                    )
                    .await
            })));
        }
        better_auth_core::observability::logger::current().warn(
            "No email provider configured, skipping verification email",
            &[],
        );
    }
    Ok(None)
}