mycommon-utils 0.2.1

Common utilities library for database operations, Redis caching and system utilities
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

use crate::database::redis_util::RedisAsync;
use serde::{Serialize, de::DeserializeOwned};
pub async fn cached_query<T, E, F>(
    cache_key: &str,
    expiry_seconds: u64,
    func: F,
) -> Result<T, E>
where
    T: Serialize + DeserializeOwned + Send + Sync + 'static,
    E: From<redis::RedisError> + From<serde_json::Error> + Send + 'static,
    F: std::future::Future<Output = Result<T, E>> + Send,
{
    if let Ok(Some(cached)) = RedisAsync::get::<Vec<u8>>(cache_key).await {
        if let Ok(value) = serde_json::from_slice::<T>(&cached) {
            tracing::info!("Cache hit for key: {}", cache_key);
            return Ok(value);
        }
    }

    let result = func.await;
    if let Ok(ref value) = result {
        let serialized_value = serde_json::to_vec(value).map_err(E::from)?;
        RedisAsync::set_with_expiry(
            cache_key,
            &serialized_value,
            expiry_seconds,
        ).await.map_err(E::from)?;
    }

    result
}