alibi-plugins 0.8.0

Built-in authentication plugins and API metadata for Alibi
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

use alibi_core::{AuthContext, AuthResult, AuthSchema};

/// Log a noncritical callback or a notification whose policy permits continuation.
pub(crate) async fn run_notification(notification: impl Future<Output = AuthResult<()>>) {
    if let Err(error) = notification.await {
        tracing::error!(%error, "Failed to run background task");
    }
}

/// Apply the awaited error policy, or observe already running owned work when
/// the application supplies a background-task handler. Committed auth state is
/// retained; the caller's transaction controls uncommitted writes.
pub(crate) async fn run_owned_notification(
    context: &AuthContext<impl AuthSchema>,
    notification: impl Future<Output = AuthResult<()>> + Send + 'static,
    error_policy: alibi_core::AwaitedNotificationErrorPolicy,
) -> AuthResult<()> {
    if let Some(handler) = &context.config.background_tasks {
        let completion = alibi_core::start_background_task(async move {
            run_notification(notification).await;
            Ok(())
        })
        .await?;
        if let Err(error) = handler.handle(completion) {
            tracing::error!(%error, "Failed to observe background task");
        }
    } else {
        match error_policy {
            alibi_core::AwaitedNotificationErrorPolicy::Propagate => notification.await?,
            alibi_core::AwaitedNotificationErrorPolicy::LogAndContinue => {
                run_notification(notification).await;
            }
        }
    }
    Ok(())
}