revolt-database 0.13.7

Revolt Backend: Database Implementation
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

use async_std::channel::{unbounded, Receiver, Sender};
use authifier::AuthifierEvent;
use once_cell::sync::Lazy;

use crate::events::client::EventV1;

static Q: Lazy<(Sender<AuthifierEvent>, Receiver<AuthifierEvent>)> = Lazy::new(unbounded);

/// Get sender
pub fn sender() -> Sender<AuthifierEvent> {
    Q.0.clone()
}

/// Start a new worker
pub async fn worker() {
    loop {
        let event = Q.1.recv().await.unwrap();
        match &event {
            AuthifierEvent::CreateSession { .. } | AuthifierEvent::CreateAccount { .. } => {
                EventV1::Auth(event).global().await
            }
            AuthifierEvent::DeleteSession { user_id, .. }
            | AuthifierEvent::DeleteAllSessions { user_id, .. } => {
                let id = user_id.to_string();
                EventV1::Auth(event).private(id).await
            }
        }
    }
}