restless-wasm-cache 0.1.0

Wasm-Cache integration for restless
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

use async_trait::async_trait;
use restless_gloo::GlooRequest;
use std::{borrow::Cow, fmt::Debug, hash::Hash};
use wasm_cache::{CacheItem, Invalidatable};

/// Cached request.
#[derive(PartialEq, Eq, PartialOrd, Ord, Hash, Clone, Debug)]
pub struct CachedRequest<R: GlooRequest + Clone + Ord + Eq + Hash + Debug> {
    /// Prefix of request URI.
    pub prefix: Cow<'static, str>,
    /// Request to send.
    pub request: R,
}

impl<R: GlooRequest + Clone + Ord + Eq + Hash + Debug, M: 'static> Invalidatable<M>
    for CachedRequest<R>
where
    R: Invalidatable<M>,
{
    fn invalidated_by(&self, value: &M) -> bool {
        self.request.invalidated_by(value)
    }
}

#[async_trait(?Send)]
impl<
        R: GlooRequest + PartialEq + Eq + PartialOrd + Ord + Hash + Clone + Debug + 'static,
        M: 'static,
    > CacheItem<M> for CachedRequest<R>
where
    R::Response: Clone + Debug + PartialEq,
    R: Invalidatable<M>,
{
    type Value = R::Response;
    type Error = R::Error;

    async fn send(&self) -> Result<Self::Value, Self::Error> {
        self.request.send_prefix(&self.prefix).await
    }
}