sabiql 1.10.0

use std::collections::HashMap;
use std::hash::Hash;
use std::sync::Arc;
use std::time::Duration;

use tokio::sync::RwLock;
use tokio::time::Instant;

struct CacheEntry<V> {
    value: V,
    created_at: Instant,
}

impl<V> CacheEntry<V> {
    fn new(value: V) -> Self {
        Self {
            value,
            created_at: Instant::now(),
        }
    }

    fn is_expired(&self, ttl: Duration) -> bool {
        self.created_at.elapsed() > ttl
    }
}

pub struct TtlCache<K, V> {
    inner: Arc<RwLock<HashMap<K, CacheEntry<V>>>>,
    ttl: Duration,
}

impl<K, V> TtlCache<K, V>
where
    K: Eq + Hash + Clone,
    V: Clone,
{
    pub fn new(ttl_seconds: u64) -> Self {
        Self {
            inner: Arc::new(RwLock::new(HashMap::new())),
            ttl: Duration::from_secs(ttl_seconds),
        }
    }

    pub async fn get(&self, key: &K) -> Option<V> {
        let cache = self.inner.read().await;
        cache.get(key).and_then(|entry| {
            if entry.is_expired(self.ttl) {
                None
            } else {
                Some(entry.value.clone())
            }
        })
    }

    pub async fn set(&self, key: K, value: V) {
        let mut cache = self.inner.write().await;
        cache.insert(key, CacheEntry::new(value));
    }

    pub async fn invalidate(&self, key: &K) {
        let mut cache = self.inner.write().await;
        cache.remove(key);
    }

    pub async fn cleanup_expired(&self) {
        let mut cache = self.inner.write().await;
        cache.retain(|_, entry| !entry.is_expired(self.ttl));
    }
}

impl<K, V> Clone for TtlCache<K, V> {
    fn clone(&self) -> Self {
        Self {
            inner: Arc::clone(&self.inner),
            ttl: self.ttl,
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    async fn test_cache_get_set() {
        let cache = TtlCache::new(60);
        cache.set("key1".to_string(), "value1".to_string()).await;

        let result = cache.get(&"key1".to_string()).await;
        assert_eq!(result, Some("value1".to_string()));
    }

    #[tokio::test]
    async fn test_cache_invalidate() {
        let cache = TtlCache::new(60);
        cache.set("key1".to_string(), "value1".to_string()).await;
        cache.invalidate(&"key1".to_string()).await;

        let result = cache.get(&"key1".to_string()).await;
        assert_eq!(result, None);
    }

    #[tokio::test]
    async fn test_cache_miss() {
        let cache: TtlCache<String, String> = TtlCache::new(60);
        let result = cache.get(&"nonexistent".to_string()).await;
        assert_eq!(result, None);
    }

    #[tokio::test(start_paused = true)]
    async fn test_cache_returns_none_for_expired_entry() {
        use tokio::time::advance;

        let cache = TtlCache::new(60);
        cache.set("key".to_string(), "value".to_string()).await;

        // Value should exist immediately
        assert_eq!(
            cache.get(&"key".to_string()).await,
            Some("value".to_string())
        );

        // Advance time past TTL
        advance(Duration::from_secs(61)).await;

        // Value should be expired
        assert_eq!(cache.get(&"key".to_string()).await, None);
    }

    #[tokio::test(start_paused = true)]
    async fn cleanup_expired_removes_stale_entries() {
        use tokio::time::advance;

        let cache = TtlCache::new(60);
        cache.set("key1".to_string(), "value1".to_string()).await;
        cache.set("key2".to_string(), "value2".to_string()).await;

        // Advance time past TTL
        advance(Duration::from_secs(61)).await;

        // Entries are expired but still in HashMap
        {
            let inner = cache.inner.read().await;
            assert_eq!(inner.len(), 2);
        }

        // Cleanup removes expired entries
        cache.cleanup_expired().await;

        // HashMap is now empty
        {
            let inner = cache.inner.read().await;
            assert_eq!(inner.len(), 0);
        }
    }

    #[tokio::test(start_paused = true)]
    async fn cleanup_expired_preserves_valid_entries() {
        use tokio::time::advance;

        let cache = TtlCache::new(60);
        cache.set("old".to_string(), "old_value".to_string()).await;

        // Advance time but not past TTL
        advance(Duration::from_secs(30)).await;

        cache.set("new".to_string(), "new_value".to_string()).await;

        // Advance time so "old" is expired but "new" is not
        advance(Duration::from_secs(35)).await;

        cache.cleanup_expired().await;

        // "old" is removed, "new" is preserved
        {
            let inner = cache.inner.read().await;
            assert_eq!(inner.len(), 1);
            assert!(inner.contains_key(&"new".to_string()));
        }
    }
}