zebflow 0.10.3

Reactive web automation platform — pipelines, templates, and real-time collaboration in a single binary.
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

//! In-process cache implementation.

use std::collections::HashMap;
use std::sync::Mutex;
use std::time::{Duration, Instant};

use serde_json::Value;

use super::interface::CacheStore;

#[derive(Debug, Clone)]
struct CacheEntry {
    value: Value,
    expires_at: Option<Instant>,
}

impl CacheEntry {
    fn is_expired(&self) -> bool {
        self.expires_at.map(|v| Instant::now() > v).unwrap_or(false)
    }
}

/// Simple in-process cache suitable for standalone or per-worker local caches.
#[derive(Debug, Default)]
pub struct MemoryCacheStore {
    entries: Mutex<HashMap<String, CacheEntry>>,
}

impl MemoryCacheStore {
    fn scoped(namespace: &str, key: &str) -> String {
        format!("{namespace}::{key}")
    }
}

impl CacheStore for MemoryCacheStore {
    fn id(&self) -> &'static str {
        "cache.memory"
    }

    fn get_json(&self, namespace: &str, key: &str) -> Option<Value> {
        let scoped = Self::scoped(namespace, key);
        let mut guard = self.entries.lock().unwrap_or_else(|e| e.into_inner());
        let entry = guard.get(&scoped)?;
        if entry.is_expired() {
            guard.remove(&scoped);
            return None;
        }
        Some(entry.value.clone())
    }

    fn put_json(&self, namespace: &str, key: &str, value: Value, ttl_secs: Option<u64>) {
        let scoped = Self::scoped(namespace, key);
        let expires_at = ttl_secs
            .filter(|ttl| *ttl > 0)
            .map(|ttl| Instant::now() + Duration::from_secs(ttl));
        self.entries
            .lock()
            .unwrap_or_else(|e| e.into_inner())
            .insert(scoped, CacheEntry { value, expires_at });
    }

    fn delete(&self, namespace: &str, key: &str) -> bool {
        self.entries
            .lock()
            .unwrap_or_else(|e| e.into_inner())
            .remove(&Self::scoped(namespace, key))
            .is_some()
    }

    fn clear_namespace(&self, namespace: &str) {
        let prefix = format!("{namespace}::");
        self.entries
            .lock()
            .unwrap_or_else(|e| e.into_inner())
            .retain(|key, _| !key.starts_with(&prefix));
    }
}