cachekit-rs 0.13.1

//! Intent-based cache presets.
//!
//! Pre-configured factory methods that build a [`CacheKit`] client from a
//! single declarative call. Each intent sets sensible defaults for a specific
//! use case and returns a [`CacheKitBuilder`] so callers can override any
//! setting before building.
//!
//! The preset matrix and per-intent resilience contract live in the
//! crate-level docs (`lib.rs`) — the single rustdoc-rendered copy. This
//! module is private, so docs here reach source readers only; the per-method
//! docs below are what docs.rs renders.
//!
//! Reliability defaults come from
//! [`ReliabilityConfig::default()`](crate::reliability::ReliabilityConfig)
//! (requires the `reliability` feature, on by default). Override via
//! [`CacheKitBuilder::reliability`];
//! [`ReliabilityConfig::disabled()`](crate::reliability::ReliabilityConfig::disabled)
//! turns the stack off entirely.

use crate::client::CacheKit;
// Only the presets use these, and each preset is gated on a backend feature;
// gate them (and `wrap`) the same way so lean feature sets lint clean.
#[cfg(any(
    feature = "redis",
    all(feature = "cachekitio", not(target_arch = "wasm32"))
))]
use {
    crate::client::{CacheKitBuilder, SharedBackend},
    crate::error::CachekitError,
    std::time::Duration,
};

// ── SharedBackend wrapping ───────────────────────────────────────────────────

#[cfg(all(
    any(
        feature = "redis",
        all(feature = "cachekitio", not(target_arch = "wasm32"))
    ),
    not(any(target_arch = "wasm32", feature = "unsync"))
))]
fn wrap(b: impl crate::backend::Backend + 'static) -> SharedBackend {
    std::sync::Arc::new(b)
}

#[cfg(all(
    any(
        feature = "redis",
        all(feature = "cachekitio", not(target_arch = "wasm32"))
    ),
    any(target_arch = "wasm32", feature = "unsync")
))]
fn wrap(b: impl crate::backend::Backend + 'static) -> SharedBackend {
    std::rc::Rc::new(b)
}

// ── Intent presets ───────────────────────────────────────────────────────────

/// `minimal` builder defaults, split from the eager Redis connect so the
/// L1-on / SWR-off contract (`protocol/spec/intent-presets.md` § L1 Posture)
/// is unit-testable without a live server.
#[cfg(feature = "redis")]
fn minimal_defaults(backend: SharedBackend) -> CacheKitBuilder {
    let builder = CacheKitBuilder::default()
        .backend(backend)
        .default_ttl(Duration::from_secs(300))
        .l1_capacity(1000);
    // Builder default is SWR-on; spec § L1 Posture says minimal MUST NOT.
    #[cfg(all(feature = "l1", not(feature = "unsync"), not(target_arch = "wasm32")))]
    let builder = builder.swr_enabled(false);
    builder
}

/// `secure` builder defaults, split from the eager Redis connect so the key
/// path is unit-testable without a live server. Takes hex-decoded key bytes
/// only (so `>= 32`, not the raw-bytes exactly-32 rule) and reads no
/// environment: [`CacheKit::secure`] passes no previous keys.
#[cfg(all(feature = "redis", feature = "encryption"))]
fn secure_defaults(
    master_key: &[u8],
    previous_keys: &[zeroize::Zeroizing<Vec<u8>>],
) -> Result<CacheKitBuilder, CachekitError> {
    let previous: Vec<&[u8]> = previous_keys.iter().map(|k| k.as_slice()).collect();
    let builder = CacheKitBuilder::default()
        .default_ttl(Duration::from_secs(600))
        .l1_capacity(1000)
        .encryption_from_hex_decoded(master_key, &previous, "default")?;
    #[cfg(all(feature = "reliability", not(target_arch = "wasm32")))]
    let builder = builder.reliability(crate::reliability::ReliabilityConfig::default());
    Ok(builder)
}

/// The key handling of [`CacheKit::secure`] — decode the hex key, then the
/// `secure` defaults — before any Redis I/O; the hex counterpart of
/// [`secure_env_defaults`].
#[cfg(all(feature = "redis", feature = "encryption"))]
fn secure_hex_defaults(master_key_hex: &str) -> Result<CacheKitBuilder, CachekitError> {
    let master_key = crate::config::decode_master_key_hex(master_key_hex, "master_key_hex")?;
    secure_defaults(&master_key, &[])
}

/// The whole environment read of [`CacheKit::secure_from_env`] — the current
/// key and `CACHEKIT_PREVIOUS_MASTER_KEYS` — resolved into `secure` defaults
/// before any Redis I/O. The same reader as
/// [`CacheKitBuilder::encryption_from_env`].
#[cfg(all(feature = "redis", feature = "encryption"))]
fn secure_env_defaults() -> Result<CacheKitBuilder, CachekitError> {
    let (master_key, previous) =
        crate::config::master_keys_from_env("CacheKit::secure(url, master_key_hex)")?;
    secure_defaults(&master_key, &previous)
}

/// Attach an eagerly connected, auto-reconnecting Redis backend to a
/// `secure` builder. Takes the builder, not the key, so key validation has
/// already happened: a bad key must not be masked by (or pay for) Redis I/O.
#[cfg(all(feature = "redis", feature = "encryption"))]
async fn connect_secure(
    redis_url: &str,
    builder: CacheKitBuilder,
) -> Result<CacheKitBuilder, CachekitError> {
    let backend = reconnecting_redis(redis_url)?;
    drop(backend.connect().await?);
    Ok(builder.backend(wrap(backend)))
}

/// The unconnected Redis backend of `production` and `secure`: the public
/// [`auto_reconnect`](crate::backend::redis::RedisBackendBuilder::auto_reconnect)
/// policy, so a caller building their own backend gets the same one.
#[cfg(feature = "redis")]
fn reconnecting_redis(
    redis_url: &str,
) -> Result<crate::backend::redis::RedisBackend, CachekitError> {
    crate::backend::redis::RedisBackend::builder()
        .url(redis_url)
        .auto_reconnect()
        .build()
}

impl CacheKit {
    /// **Minimal** — speed-first Redis cache, no extras.
    ///
    /// * Backend: Redis (connects eagerly; **fails fast** — a dropped
    ///   connection is not re-established)
    /// * L1 cache: **on** (1 000 entries, **no SWR / invalidation**) — an L1
    ///   hit is served as-is until it expires, so a read may return an entry
    ///   up to its TTL (300 s by default) after another process changed it
    ///   in Redis. Chain
    ///   [`.no_l1()`](CacheKitBuilder::no_l1) to read through every time.
    /// * Encryption: **no**
    /// * Reliability: **off** — no retry, no circuit breaker, no
    ///   backpressure; every backend error propagates on first failure and
    ///   backend concurrency is unbounded
    /// * Default TTL: **300 s**
    ///
    /// Good for: product catalogs, public data, development.
    ///
    /// # Errors
    ///
    /// Returns [`CachekitError`] if the URL is invalid or Redis is unreachable.
    ///
    /// # Example
    ///
    /// ```no_run
    /// # async fn example() -> Result<(), cachekit::CachekitError> {
    /// let cache = cachekit::CacheKit::minimal("redis://localhost:6379").await?
    ///     .namespace("myapp")
    ///     .build()?;
    /// # Ok(())
    /// # }
    /// ```
    #[cfg(feature = "redis")]
    pub async fn minimal(redis_url: &str) -> Result<CacheKitBuilder, CachekitError> {
        let backend = crate::backend::redis::RedisBackend::builder()
            .url(redis_url)
            .build()?;
        drop(backend.connect().await?);

        Ok(minimal_defaults(wrap(backend)))
    }

    /// **Production** — reliability-first Redis cache with L1.
    ///
    /// * Backend: Redis (connects eagerly, failing fast if unreachable;
    ///   **auto-reconnects** after a dropped connection with exponential
    ///   backoff, 100 ms → 30 s, retrying indefinitely)
    /// * L1 cache: **on** (1 000 entries)
    /// * Encryption: **no**
    /// * Reliability: **on** — retry with backoff + jitter, circuit
    ///   breaker, backpressure (max 100 concurrent backend ops)
    /// * Default TTL: **600 s**
    ///
    /// Good for: user sessions, API responses, production services.
    ///
    /// # Errors
    ///
    /// Returns [`CachekitError`] if the URL is invalid or Redis is unreachable.
    ///
    /// # Example
    ///
    /// ```no_run
    /// # async fn example() -> Result<(), cachekit::CachekitError> {
    /// let cache = cachekit::CacheKit::production("redis://localhost:6379").await?
    ///     .namespace("api")
    ///     .build()?;
    /// # Ok(())
    /// # }
    /// ```
    #[cfg(feature = "redis")]
    pub async fn production(redis_url: &str) -> Result<CacheKitBuilder, CachekitError> {
        let backend = reconnecting_redis(redis_url)?;
        drop(backend.connect().await?);

        let builder = CacheKitBuilder::default()
            .backend(wrap(backend))
            .default_ttl(Duration::from_secs(600))
            .l1_capacity(1000);
        #[cfg(all(feature = "reliability", not(target_arch = "wasm32")))]
        let builder = builder.reliability(crate::reliability::ReliabilityConfig::default());
        Ok(builder)
    }

    /// **Secure** — zero-knowledge encrypted Redis cache.
    ///
    /// * Backend: Redis (connects eagerly, failing fast if unreachable;
    ///   **auto-reconnects** after a dropped connection with exponential
    ///   backoff, 100 ms → 30 s, retrying indefinitely)
    /// * L1 cache: **on** (1 000 entries, stores ciphertext)
    /// * Encryption: **AES-256-GCM** with HKDF-SHA256, on every value read
    ///   and write, not only those through the
    ///   [`secure_cache()`](CacheKit::secure_cache) handle (see
    ///   [Encryption](CacheKit#encryption))
    /// * Reliability: **on** — retry with backoff + jitter, circuit
    ///   breaker, backpressure (max 100 concurrent backend ops)
    /// * Default TTL: **600 s**
    /// * Tenant ID: `"default"` for both key derivation and AAD (override via
    ///   [`.encryption()`](CacheKitBuilder::encryption))
    ///
    /// Good for: PII, payments, GDPR/HIPAA-sensitive data.
    ///
    /// `master_key_hex` is the master key as a **hex string** — the same
    /// string `CACHEKIT_MASTER_KEY` holds, decoded to the same key bytes by
    /// every CacheKit SDK. This is the cross-SDK-portable key path. Use
    /// exactly **32 bytes (64 hex chars)**: shorter is rejected, and longer
    /// is accepted here but not by every SDK. Generate one with
    /// `openssl rand -hex 32`.
    ///
    /// Use [`CacheKit::secure_from_env`] to read the key from
    /// `CACHEKIT_MASTER_KEY`. There is no raw-bytes preset: exactly 32
    /// decoded key bytes go to [`CacheKitBuilder::encryption_from_bytes`],
    /// which rejects any other length — including the 64 ASCII bytes of a
    /// hex string, which would derive a key no other SDK derives.
    ///
    /// The key is validated **before** any Redis connection is attempted — a
    /// bad key is a deterministic local error, never masked by (or paying
    /// for) network I/O.
    ///
    /// # Errors
    ///
    /// Returns [`CachekitError::Config`] if `master_key_hex` is not hex or
    /// decodes to fewer than 32 bytes, or if the URL is invalid; another
    /// [`CachekitError`] if Redis is unreachable.
    ///
    /// # Example
    ///
    /// ```no_run
    /// # async fn example() -> Result<(), Box<dyn std::error::Error>> {
    /// // 64 hex chars (32 bytes) from your secret store — `openssl rand -hex 32`.
    /// let master_key_hex = std::env::var("APP_CACHE_MASTER_KEY")?;
    /// let cache = cachekit::CacheKit::secure("redis://localhost:6379", &master_key_hex)
    ///     .await?
    ///     .build()?;
    /// // Encrypted before it leaves the process; L1 holds the ciphertext.
    /// cache.set("user:42:ssn", &"123-45-6789").await?;
    /// # Ok(())
    /// # }
    /// ```
    #[cfg(all(feature = "redis", feature = "encryption"))]
    pub async fn secure(
        redis_url: &str,
        master_key_hex: &str,
    ) -> Result<CacheKitBuilder, CachekitError> {
        connect_secure(redis_url, secure_hex_defaults(master_key_hex)?).await
    }

    /// **Secure**, keys from the environment — [`CacheKit::secure`] with the
    /// hex key read from `CACHEKIT_MASTER_KEY`, plus decrypt-only rotation
    /// keys from `CACHEKIT_PREVIOUS_MASTER_KEYS`.
    ///
    /// Reads exactly two variables:
    ///
    /// * `CACHEKIT_MASTER_KEY` (required) — the current key; writes encrypt
    ///   under it. Same hex decoding as [`secure`](CacheKit::secure), so the
    ///   same value derives the same key bytes as every other CacheKit SDK.
    ///   Use exactly **32 bytes (64 hex chars)**, the only length every SDK
    ///   accepts.
    /// * `CACHEKIT_PREVIOUS_MASTER_KEYS` (optional) — comma-separated hex
    ///   keys, at most 3, tried in order when the current key fails to
    ///   decrypt. Unset or blank means none. Validated exactly as
    ///   [`CachekitConfig::from_env`](crate::CachekitConfig::from_env)
    ///   validates it; the current key must not appear in the list.
    ///
    /// Otherwise the identical preset to [`secure`](CacheKit::secure), tenant
    /// `"default"` for every key. Never falls back to plaintext.
    ///
    /// # Errors
    ///
    /// Returns [`CachekitError::Config`] — all before any Redis I/O — when
    /// `CACHEKIT_MASTER_KEY` is unset, empty, not hex, or shorter than 32
    /// bytes, or when `CACHEKIT_PREVIOUS_MASTER_KEYS` is set but not valid
    /// UTF-8, or is non-blank with an empty or invalid entry, more than 3
    /// entries, or a repeat of the current key.
    /// Otherwise as [`secure`](CacheKit::secure).
    ///
    /// # Example
    ///
    /// ```no_run
    /// # async fn example() -> Result<(), cachekit::CachekitError> {
    /// let cache = cachekit::CacheKit::secure_from_env("redis://localhost:6379")
    ///     .await?
    ///     .build()?;
    /// cache.set("user:42:ssn", &"123-45-6789").await?; // encrypted
    /// // Reads served by each CACHEKIT_PREVIOUS_MASTER_KEYS entry, for rotation.
    /// let drain = cache.secure_cache()?.previous_key_hits();
    /// # Ok(())
    /// # }
    /// ```
    #[cfg(all(feature = "redis", feature = "encryption"))]
    pub async fn secure_from_env(redis_url: &str) -> Result<CacheKitBuilder, CachekitError> {
        connect_secure(redis_url, secure_env_defaults()?).await
    }

    /// **CachekitIO** — managed SaaS cache, zero infrastructure.
    ///
    /// * Backend: [cachekit.io](https://cachekit.io) HTTP API
    /// * L1 cache: **on** (1 000 entries)
    /// * Encryption: **no** (add via
    ///   [`.encryption()`](CacheKitBuilder::encryption), which then encrypts
    ///   every value read and write)
    /// * Reliability: **on** — retry with backoff + jitter, circuit
    ///   breaker, backpressure (max 100 concurrent backend ops)
    /// * Default TTL: **3 600 s**
    ///
    /// Good for: serverless, edge compute, managed caching without Redis.
    ///
    /// Use [`CacheKit::io_from_env`] to read the key from `CACHEKIT_API_KEY`.
    ///
    /// # Errors
    ///
    /// Returns [`CachekitError::Config`] if `api_key` is empty.
    ///
    /// # Example
    ///
    /// ```no_run
    /// # fn example() -> Result<(), Box<dyn std::error::Error>> {
    /// let api_key = std::env::var("CACHEKIT_API_KEY")?;
    /// let cache = cachekit::CacheKit::io(&api_key)?
    ///     .namespace("edge")
    ///     .build()?;
    /// # Ok(())
    /// # }
    /// ```
    #[cfg(all(feature = "cachekitio", not(target_arch = "wasm32")))]
    pub fn io(api_key: &str) -> Result<CacheKitBuilder, CachekitError> {
        let backend = crate::backend::cachekitio::CachekitIO::builder()
            .api_key(api_key)
            .build()?;

        let builder = CacheKitBuilder::default()
            .backend(wrap(backend))
            .default_ttl(Duration::from_secs(3600))
            .l1_capacity(1000);
        #[cfg(all(feature = "reliability", not(target_arch = "wasm32")))]
        let builder = {
            let mut builder = builder.reliability(crate::reliability::ReliabilityConfig::default());
            builder.retry_deadlines = Some(crate::reliability::CACHEKITIO_DEADLINES);
            builder
        };
        Ok(builder)
    }

    /// **CachekitIO**, API key from the environment — [`CacheKit::io`] with
    /// the key read from `CACHEKIT_API_KEY`.
    ///
    /// Identical preset to [`io`](CacheKit::io). Reads **only**
    /// `CACHEKIT_API_KEY`, never `CACHEKIT_MASTER_KEY`: like every
    /// constructor but `secure`, it does not encrypt unless you chain an
    /// encryption call such as
    /// [`.encryption_from_env()`](CacheKitBuilder::encryption_from_env).
    ///
    /// # Errors
    ///
    /// Returns [`CachekitError::Config`] when `CACHEKIT_API_KEY` is unset or
    /// empty.
    ///
    /// # Example
    ///
    /// ```no_run
    /// # fn example() -> Result<(), cachekit::CachekitError> {
    /// let cache = cachekit::CacheKit::io_from_env()?
    ///     .namespace("edge")
    ///     .build()?;
    /// # Ok(())
    /// # }
    /// ```
    #[cfg(all(feature = "cachekitio", not(target_arch = "wasm32")))]
    pub fn io_from_env() -> Result<CacheKitBuilder, CachekitError> {
        let api_key = std::env::var("CACHEKIT_API_KEY")
            .ok()
            .map(zeroize::Zeroizing::new)
            .filter(|k| !k.is_empty())
            .ok_or_else(|| {
                CachekitError::Config(
                    "CACHEKIT_API_KEY is unset or empty: set it or pass the key to CacheKit::io(api_key)"
                        .to_owned(),
                )
            })?;
        Self::io(&api_key)
    }
}

#[cfg(all(test, feature = "redis", feature = "l1"))]
#[allow(clippy::expect_used)] // test-only: a failing build here should panic loudly
mod tests {
    /// `RedisBackend::build()` does not connect, so the preset's defaults
    /// are observable without a live server.
    #[test]
    fn minimal_enables_l1_without_swr() {
        let backend = crate::backend::redis::RedisBackend::builder()
            .url("redis://localhost:6379")
            .build()
            .expect("valid URL");
        let cache = super::minimal_defaults(super::wrap(backend))
            .build()
            .expect("minimal defaults must build");

        assert!(
            cache.l1.is_some(),
            "spec/intent-presets.md § L1 Posture: minimal MUST enable L1"
        );
        #[cfg(all(not(feature = "unsync"), not(target_arch = "wasm32")))]
        assert!(
            !cache.swr_enabled,
            "spec/intent-presets.md § L1 Posture: minimal MUST NOT enable SWR"
        );
    }
}

#[cfg(all(test, feature = "redis", feature = "encryption"))]
#[allow(clippy::expect_used)] // test-only: a failing build here should panic loudly
mod secure_tests {
    // protocol test-vectors/encryption.json `default_tenant.vectors[0]`
    // (unchanged since v1.2.0; the vendored copy is tests/vectors/encryption.json)
    // (`default_tenant_interop`): spec/intent-presets.md § Master Key Input
    // rule 5 — with no tenant configured, the preset must derive and bind AAD
    // under the literal "default", byte-for-byte with every other SDK.
    const MASTER_KEY_HEX: &str = "6161616161616161616161616161616161616161616161616161616161616161";
    const CACHE_KEY: &str =
        "users:get_user:61598716255080080f6456eb065c2e51badfaa4320b0efe97469c29cffee8875";
    const CIPHERTEXT_HEX: &str =
        "0d0e0f1011121314151617183c29af318238925ee76d081934adce133c0b4a7c5eb5704102b04582dcbf278ffd"; // pragma: allowlist secret
    const PLAINTEXT_HEX: &str = "82a36167651ea46e616d65a5616c696365"; // pragma: allowlist secret

    fn assert_decrypts_default_tenant_vector(builder: crate::CacheKitBuilder) {
        let layer = builder
            .encryption
            .expect("secure preset must configure encryption");
        assert_eq!(layer.tenant_id(), "default");
        let ciphertext = hex::decode(CIPHERTEXT_HEX).expect("vector hex");
        let plaintext = layer
            .decrypt(&ciphertext, CACHE_KEY)
            .expect("default-tenant vector must decrypt");
        assert_eq!(hex::encode(plaintext), PLAINTEXT_HEX);
    }

    /// § Encryption Activation rule 1 on the preset: plain `set` on a
    /// `secure` client puts only ciphertext in the backend and in L1, and
    /// plain `get` decrypts it. Driven through `secure_defaults` so it runs
    /// without Redis.
    #[tokio::test]
    async fn plain_set_on_secure_preset_stores_ciphertext() {
        const VALUE: &str = "ssn 123-45-6789";
        let backend = crate::backend::MemoryBackend::default();
        let master_key = hex::decode(MASTER_KEY_HEX).expect("vector hex");
        let cache = super::secure_defaults(&master_key, &[])
            .expect("valid key")
            .backend(super::wrap(backend.clone()))
            .build()
            .expect("secure defaults must build");

        cache.set(CACHE_KEY, &VALUE).await.expect("plain set");

        let stored = backend
            .store
            .lock()
            .await
            .get(CACHE_KEY)
            .cloned()
            .expect("plain set reached the backend");
        let plaintext = crate::serializer::serialize(&VALUE).expect("serializes");
        assert_ne!(stored, plaintext, "backend holds plaintext");
        let independent = crate::EncryptionLayer::new(&master_key, "default").expect("valid key");
        assert_eq!(
            independent
                .decrypt(&stored, CACHE_KEY)
                .expect("backend bytes are ciphertext under the preset's key and tenant"),
            plaintext
        );
        #[cfg(feature = "l1")]
        assert_eq!(
            cache
                .l1
                .as_ref()
                .expect("secure preset enables L1")
                .get_shared(CACHE_KEY)
                .as_deref(),
            Some(stored.as_slice()),
            "L1 holds the same ciphertext as the backend"
        );

        assert_eq!(
            cache.get::<String>(CACHE_KEY).await.expect("plain get"),
            Some(VALUE.to_owned())
        );
    }

    #[test]
    fn hex_path_decrypts_default_tenant_vector() {
        assert_decrypts_default_tenant_vector(
            super::secure_defaults(&hex::decode(MASTER_KEY_HEX).expect("vector hex"), &[])
                .expect("valid key"),
        );
    }

    /// Rule 3: the hex path accepts a key decoding to more than 32 bytes;
    /// the raw-bytes exactly-32 rule must not leak into it.
    #[test]
    fn hex_path_accepts_48_byte_key() {
        let long = [0x61u8; 48];
        assert!(super::secure_defaults(&long, &[]).is_ok());
        let previous = [zeroize::Zeroizing::new(vec![0x62u8; 48])];
        assert!(super::secure_defaults(&long, &previous).is_ok());
    }

    #[test]
    #[serial_test::serial]
    fn env_path_accepts_48_byte_keys() {
        let (k2, k1) = ("22".repeat(48), "11".repeat(48));
        assert!(secure_env_defaults_with(Some(&k2), Some(&k1)).is_ok());
        assert!(secure_env_defaults_with(Some(&"22".repeat(32)), None).is_ok());
    }

    /// Run `f` with each variable set (`Some`) or removed (`None`),
    /// restoring every one before anything can panic.
    fn with_env<R>(vars: &[(&str, Option<&str>)], f: impl FnOnce() -> R) -> R {
        let saved: Vec<_> = vars
            .iter()
            .map(|(var, _)| (*var, std::env::var_os(var)))
            .collect();
        for (var, val) in vars {
            match val {
                Some(v) => std::env::set_var(var, v),
                None => std::env::remove_var(var),
            }
        }
        let out = f();
        for (var, val) in saved {
            match val {
                Some(v) => std::env::set_var(var, v),
                None => std::env::remove_var(var),
            }
        }
        out
    }

    /// Run `secure_env_defaults` under the given env.
    fn secure_env_defaults_with(
        master: Option<&str>,
        previous: Option<&str>,
    ) -> Result<crate::CacheKitBuilder, crate::CachekitError> {
        with_env(
            &[
                ("CACHEKIT_MASTER_KEY", master),
                ("CACHEKIT_PREVIOUS_MASTER_KEYS", previous),
            ],
            super::secure_env_defaults,
        )
    }

    #[test]
    #[serial_test::serial]
    fn env_path_decrypts_default_tenant_vector() {
        assert_decrypts_default_tenant_vector(
            secure_env_defaults_with(Some(MASTER_KEY_HEX), None).expect("valid key"),
        );
    }

    /// The env constructor with no tenant: `.encryption_from_env()` on the
    /// builder `from_env()` returns resolves "default", and a namespace on
    /// that builder never becomes the tenant.
    #[cfg(feature = "cachekitio")]
    #[test]
    #[serial_test::serial]
    fn from_env_encryption_from_env_decrypts_default_tenant_vector(
    ) -> Result<(), crate::CachekitError> {
        let builder = with_env(
            &[
                ("CACHEKIT_MASTER_KEY", Some(MASTER_KEY_HEX)),
                ("CACHEKIT_PREVIOUS_MASTER_KEYS", None),
                ("CACHEKIT_API_KEY", Some("test-key")),
                ("CACHEKIT_API_URL", None),
            ],
            || {
                crate::CacheKit::from_env()?
                    .namespace("my-app")
                    .encryption_from_env()
            },
        )?;
        assert_decrypts_default_tenant_vector(builder);
        Ok(())
    }

    /// An entry written under k1 must still decrypt after the
    /// env-var rotation runbook promotes k2 and moves k1 to the previous list.
    #[test]
    #[serial_test::serial]
    fn env_path_decrypts_under_previous_key_after_rotation() {
        let k2 = "22".repeat(32);
        let rotated = secure_env_defaults_with(Some(&k2), Some(MASTER_KEY_HEX))
            .expect("valid rotation config");
        // The default-tenant vector was written under k1 (MASTER_KEY_HEX).
        assert_decrypts_default_tenant_vector(rotated);

        // Control: without the previous key, k2 alone fails closed.
        let layer = secure_env_defaults_with(Some(&k2), None)
            .expect("valid key")
            .encryption
            .expect("secure preset must configure encryption");
        let ciphertext = hex::decode(CIPHERTEXT_HEX).expect("vector hex");
        assert!(layer.decrypt(&ciphertext, CACHE_KEY).is_err());
    }

    /// protocol `encryption.json` 1.5.0 `master_key_input.accept_vectors`:
    /// `master_key_every_hex_digit` (a leading 00 byte, bytes above 7f and
    /// every hex digit in both places) and `master_key_first_byte_80` (the top
    /// bit set), each sealed under tenant "default". Read from the copy
    /// `tests/master_key_input_tests.rs` pins.
    struct AcceptRow {
        name: String,
        master_key_hex: String,
        cache_key: String,
        ciphertext: Vec<u8>,
        plaintext_hex: String,
    }

    fn accept_rows() -> Vec<AcceptRow> {
        let all: serde_json::Value =
            serde_json::from_str(include_str!("../tests/vectors/encryption.json"))
                .expect("vendored vector file must be valid JSON");
        all["master_key_input"]["accept_vectors"]
            .as_array()
            .expect("accept_vectors must be an array")
            .iter()
            .map(|row| {
                let get = |k: &str| row[k].as_str().expect("accept row field").to_owned();
                AcceptRow {
                    name: get("name"),
                    master_key_hex: get("master_key_hex"),
                    cache_key: get("cache_key"),
                    ciphertext: hex::decode(get("ciphertext_hex")).expect("vector hex"),
                    plaintext_hex: get("plaintext_hex"),
                }
            })
            .collect()
    }

    fn assert_decrypts_accept_row(builder: &crate::CacheKitBuilder, row: &AcceptRow) {
        let layer = builder
            .encryption
            .as_ref()
            .expect("secure preset must configure encryption");
        assert_eq!(layer.tenant_id(), "default");
        let plaintext = layer
            .decrypt(&row.ciphertext, &row.cache_key)
            .map(hex::encode)
            .map_err(|e| format!("{e:?}"));
        assert_eq!(
            plaintext.as_deref(),
            Ok(row.plaintext_hex.as_str()),
            "{} must decrypt",
            row.name
        );
    }

    /// Everything `CacheKit::secure` does before it connects, with no tenant.
    #[test]
    fn hex_path_decrypts_master_key_input_accept_rows() {
        for row in accept_rows() {
            let builder = super::secure_hex_defaults(&row.master_key_hex).expect("valid key");
            assert_decrypts_accept_row(&builder, &row);
        }
    }

    #[test]
    #[serial_test::serial]
    fn env_path_decrypts_master_key_input_accept_rows() {
        for row in accept_rows() {
            let builder =
                secure_env_defaults_with(Some(&row.master_key_hex), None).expect("valid key");
            assert_decrypts_accept_row(&builder, &row);
        }
    }

    /// PRE-51: each `master_key_input.accept_vectors` row (current key) and
    /// `default_tenant.vectors[0]` (previous key), all sealed under tenant
    /// "default", read through one client. A client that ignores
    /// `CACHEKIT_PREVIOUS_MASTER_KEYS` reads only the first.
    #[test]
    #[serial_test::serial]
    fn env_path_reads_accept_rows_and_default_tenant_vector_across_rotation() {
        for row in accept_rows() {
            let builder = secure_env_defaults_with(Some(&row.master_key_hex), Some(MASTER_KEY_HEX))
                .expect("valid rotation config");
            assert_decrypts_accept_row(&builder, &row);
            assert_decrypts_default_tenant_vector(builder);
        }
    }

    #[test]
    #[serial_test::serial]
    fn env_path_blank_previous_keys_is_unset() {
        assert_decrypts_default_tenant_vector(
            secure_env_defaults_with(Some(MASTER_KEY_HEX), Some("  ")).expect("blank is unset"),
        );
    }

    /// Set but unreadable is not unset: a non-UTF-8 value must fail, never
    /// silently drop the decrypt-only keys.
    #[cfg(unix)]
    #[test]
    #[serial_test::serial]
    fn env_path_rejects_non_utf8_previous_keys() {
        use std::os::unix::ffi::OsStringExt;
        let saved = std::env::var_os("CACHEKIT_PREVIOUS_MASTER_KEYS");
        std::env::set_var(
            "CACHEKIT_PREVIOUS_MASTER_KEYS",
            std::ffi::OsString::from_vec(vec![0x31, 0xff, 0x31]),
        );
        let saved_master = std::env::var_os("CACHEKIT_MASTER_KEY");
        std::env::set_var("CACHEKIT_MASTER_KEY", MASTER_KEY_HEX);
        let resolved = super::secure_env_defaults();
        for (var, val) in [
            ("CACHEKIT_PREVIOUS_MASTER_KEYS", saved),
            ("CACHEKIT_MASTER_KEY", saved_master),
        ] {
            match val {
                Some(v) => std::env::set_var(var, v),
                None => std::env::remove_var(var),
            }
        }
        assert!(
            matches!(
                &resolved,
                Err(crate::CachekitError::Config(msg)) if msg.contains("CACHEKIT_PREVIOUS_MASTER_KEYS")
            ),
            "non-UTF-8 previous keys must be a Config error naming the variable; got {:?}",
            resolved.err()
        );
    }

    #[test]
    #[serial_test::serial]
    fn env_path_rejects_invalid_previous_keys() {
        let k2 = "22".repeat(32);
        let four = ["11", "33", "44", "55"].map(|b| b.repeat(32)).join(",");
        for (previous, why) in [
            ("not-hex", "invalid hex"),
            (&*format!("{MASTER_KEY_HEX},"), "empty entry"),
            (&*"11".repeat(31), "short key"),
            (&*four, "more than 3"),
            (&*k2, "current key repeated"),
        ] {
            assert!(
                matches!(
                    secure_env_defaults_with(Some(&k2), Some(previous)),
                    Err(crate::CachekitError::Config(_))
                ),
                "{why} must be a Config error"
            );
        }
    }
}

#[cfg(all(
    test,
    feature = "cachekitio",
    feature = "reliability",
    not(target_arch = "wasm32")
))]
#[allow(clippy::expect_used)] // test-only
mod io_deadline_tests {
    use crate::reliability::CACHEKITIO_DEADLINES;
    use crate::CacheKit;

    #[test]
    fn io_sets_the_cachekitio_retry_deadlines() {
        let builder = CacheKit::io("ck_test_key").expect("io builds");
        assert_eq!(builder.retry_deadlines, Some(CACHEKITIO_DEADLINES));
    }

    /// A backend swapped in after `io` must not inherit budgets sized for
    /// cachekit.io.
    #[test]
    fn replacing_the_backend_drops_the_deadlines() {
        let other = crate::backend::cachekitio::CachekitIO::builder()
            .api_key("ck_test_key")
            .build()
            .expect("builds");
        let builder = CacheKit::io("ck_test_key")
            .expect("io builds")
            .backend(super::wrap(other));
        assert_eq!(builder.retry_deadlines, None);
    }
}

#[cfg(all(test, feature = "redis"))]
#[allow(clippy::expect_used)] // test-only
mod redis_reconnect_tests {
    use fred::prelude::ClientLike;

    use crate::backend::redis::RedisBackend;

    /// `production` and `secure` build their backend with the same reconnect
    /// policy and unresponsive check a caller gets from the public builder.
    #[test]
    fn presets_and_the_public_builder_share_one_reconnect_policy() {
        let url = "redis://localhost:6379";
        let preset = super::reconnecting_redis(url).expect("builds");
        let public = RedisBackend::builder()
            .url(url)
            .auto_reconnect()
            .build()
            .expect("builds");

        let policy = preset.client().client_reconnect_policy();
        assert!(policy.is_some(), "presets reconnect");
        assert_eq!(policy, public.client().client_reconnect_policy());
        assert_eq!(
            preset.client().connection_config().unresponsive.max_timeout,
            public.client().connection_config().unresponsive.max_timeout
        );
        assert_eq!(
            preset.client().perf_config().default_command_timeout,
            public.client().perf_config().default_command_timeout
        );
    }
}