mycelium-notifier 6.0.0

Provide message adapters to the mycelium project.
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

use crate::models::QueueConfig;

use lazy_static::lazy_static;
use mycelium_base::utils::errors::MappedErrors;
use redis::Client;
use std::sync::Mutex;

lazy_static! {
    #[derive(Debug)]
    pub(super) static ref QUEUE_CLIENT: Mutex<Option<Client>> = Mutex::new(None);
}

/// Initialize the queue client from a given URL
///
/// This function should be used to initialize the queue client on the
/// application startup.
pub async fn init_queue_client_from_url(
    config: QueueConfig,
) -> Result<(), MappedErrors> {
    let url = format!(
        "{}://:{}@{}",
        config.protocol,
        config.password.get_or_error()?,
        config.hostname.get_or_error()?
    );

    QUEUE_CLIENT
        .lock()
        .expect("Could not fix the queue config")
        .replace(Client::open(url).expect("Could not connect to the queue"));

    Ok(())
}

/// Get the queue client
///
/// This function should be used to get the queue client instance from the
/// application.
pub(crate) async fn get_client() -> Client {
    match QUEUE_CLIENT
        .lock()
        .expect("Could not connect to the queue")
        .as_ref()
    {
        Some(client) => client.clone(),
        None => panic!("Queue client is not initialized"),
    }
}