cachet_memory 0.2.0

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

//! Integration tests for `InMemoryCache`.

use std::time::Duration;

use cachet_memory::{InMemoryCache, InMemoryCacheBuilder};
use cachet_tier::{CacheEntry, CacheTier};

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn new_creates_unbounded_cache() {
    let cache = InMemoryCache::<String, i32>::new();
    assert_eq!(cache.len().await.unwrap(), 0);
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn with_max_capacity_creates_bounded_cache() {
    let cache = InMemoryCache::<String, i32>::with_max_capacity(100);
    assert_eq!(cache.len().await.unwrap(), 0);
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn default_creates_unbounded_cache() {
    let cache = InMemoryCache::<String, i32>::default();
    assert_eq!(cache.len().await.unwrap(), 0);
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn get_returns_none_for_missing_key() {
    let cache = InMemoryCache::<String, i32>::new();
    let result = cache.get(&"missing".to_string()).await.expect("get failed");
    assert!(result.is_none());
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn insert_and_get_returns_value() {
    let cache = InMemoryCache::<String, i32>::new();
    cache.insert("key".to_string(), CacheEntry::new(42)).await.expect("insert failed");

    let entry = cache
        .get(&"key".to_string())
        .await
        .expect("get failed")
        .expect("entry should exist");
    assert_eq!(*entry.value(), 42);
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn insert_overwrites_existing_value() {
    let cache = InMemoryCache::<String, i32>::new();
    cache.insert("key".to_string(), CacheEntry::new(42)).await.expect("insert failed");
    cache.insert("key".to_string(), CacheEntry::new(100)).await.expect("insert failed");

    let entry = cache
        .get(&"key".to_string())
        .await
        .expect("get failed")
        .expect("entry should exist");
    assert_eq!(*entry.value(), 100);
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn get_returns_ok() {
    let cache = InMemoryCache::<String, i32>::new();

    let result = cache.get(&"missing".to_string()).await;
    assert!(result.is_ok());
    assert!(result.expect("get failed").is_none());

    cache.insert("key".to_string(), CacheEntry::new(42)).await.expect("insert failed");
    let result = cache.get(&"key".to_string()).await;
    assert!(result.is_ok());
    assert!(result.expect("get failed").is_some());
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn insert_returns_ok() {
    let cache = InMemoryCache::<String, i32>::new();
    cache.insert("key".to_string(), CacheEntry::new(42)).await.expect("insert failed");
    assert!(cache.get(&"key".to_string()).await.expect("get failed").is_some());
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn invalidate_removes_entry() {
    let cache = InMemoryCache::<String, i32>::new();
    cache.insert("key".to_string(), CacheEntry::new(42)).await.expect("insert failed");

    cache.invalidate(&"key".to_string()).await.expect("invalidate failed");

    let result = cache.get(&"key".to_string()).await.expect("get failed");
    assert!(result.is_none());
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn invalidate_nonexistent_key_succeeds() {
    let cache = InMemoryCache::<String, i32>::new();
    cache.invalidate(&"nonexistent".to_string()).await.expect("invalidate failed");
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn invalidate_returns_ok() {
    let cache = InMemoryCache::<String, i32>::new();
    cache.insert("key".to_string(), CacheEntry::new(42)).await.expect("insert failed");

    cache.invalidate(&"key".to_string()).await.expect("invalidate failed");
    assert!(cache.get(&"key".to_string()).await.expect("get failed").is_none());
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn clear_removes_all_entries() {
    let cache = InMemoryCache::<String, i32>::new();
    cache.insert("key1".to_string(), CacheEntry::new(1)).await.expect("insert failed");
    cache.insert("key2".to_string(), CacheEntry::new(2)).await.expect("insert failed");
    cache.insert("key3".to_string(), CacheEntry::new(3)).await.expect("insert failed");

    cache.clear().await.expect("clear failed");

    assert!(cache.get(&"key1".to_string()).await.expect("get failed").is_none());
    assert!(cache.get(&"key2".to_string()).await.expect("get failed").is_none());
    assert!(cache.get(&"key3".to_string()).await.expect("get failed").is_none());
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn clear_returns_ok() {
    let cache = InMemoryCache::<String, i32>::new();
    cache.insert("key".to_string(), CacheEntry::new(42)).await.expect("insert failed");

    cache.clear().await.expect("clear failed");
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn len_returns_some_zero_for_empty_cache() {
    let cache = InMemoryCache::<String, i32>::new();
    assert_eq!(cache.len().await.unwrap(), 0);
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn clone_shares_underlying_cache() {
    let cache1 = InMemoryCache::<String, i32>::new();
    let cache2 = cache1.clone();

    cache1.insert("key".to_string(), CacheEntry::new(42)).await.expect("insert failed");

    let entry = cache2
        .get(&"key".to_string())
        .await
        .expect("get failed")
        .expect("entry should exist");
    assert_eq!(*entry.value(), 42);
}

// Builder tests

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn builder_default_creates_unbounded_cache() {
    let cache = InMemoryCacheBuilder::<String, i32>::default().build().expect("build failed");
    assert_eq!(cache.len().await.unwrap(), 0);
}

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn builder_all_options_combined() {
    let cache = InMemoryCacheBuilder::<String, i32>::new()
        .max_capacity(1000)
        .initial_capacity(100)
        .time_to_live(Duration::from_secs(300))
        .time_to_idle(Duration::from_secs(60))
        .name("full-config-cache")
        .build()
        .expect("build failed");

    assert_eq!(cache.len().await.unwrap(), 0);
}