apicize_lib 0.40.0

Library supporting Apicize request dispatch, testing and serialization
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

use serde::{Deserialize, Serialize};
use std::collections::HashMap;
use std::sync::LazyLock;
use tokio::sync::Mutex;

/// Cached OAuth2 token
#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)]
#[serde(rename_all = "camelCase")]
pub struct CachedTokenInfo {
    /// Access token
    pub access_token: String,
    /// Refresh token
    pub refresh_token: Option<String>,
    /// Expiration of token in seconds past Unix epoch
    pub expiration: Option<u64>,
}

pub static OAUTH2_TOKEN_CACHE: LazyLock<Mutex<HashMap<String, CachedTokenInfo>>> =
    LazyLock::new(|| Mutex::new(HashMap::new()));

/// Retrieve cached OAuth2 token
pub async fn retrieve_oauth2_token_from_cache(authorization_id: &str) -> Option<CachedTokenInfo> {
    let locked_cache = OAUTH2_TOKEN_CACHE.lock().await;
    locked_cache.get(authorization_id).cloned()
}

/// Store OAuth2 token in cache
pub async fn store_oauth2_token_in_cache(authorization_id: &str, token_info: CachedTokenInfo) {
    let mut locked_cache = OAUTH2_TOKEN_CACHE.lock().await;
    locked_cache.insert(authorization_id.to_owned(), token_info);
}

/// Clear all cached OAuth2 tokens
pub async fn clear_all_oauth2_tokens_from_cache() -> usize {
    let mut locked_cache = OAUTH2_TOKEN_CACHE.lock().await;
    let count = locked_cache.len();
    locked_cache.clear();
    count
}

/// Clear specified cached OAuth2 credentials, returning true if value was cached
pub async fn clear_oauth2_token_from_cache(id: &str) -> bool {
    let mut locked_cache = OAUTH2_TOKEN_CACHE.lock().await;
    locked_cache.remove(&String::from(id)).is_some()
}