cachekit_core/

byte_storage.rs

//! LZ4 compression and xxHash3 checksums for raw byte storage.
//!
//! Provides integrity-protected byte storage with security validation:
//! - 512MB size limits for decompression bomb protection
//! - 1000x max compression ratio enforcement
//! - xxHash3-64 checksums for corruption detection (19x faster than Blake3)

use crate::metrics::OperationMetrics;
#[cfg(feature = "compression")]
use lz4_flex;
use serde::{Deserialize, Serialize};
use std::sync::{Arc, Mutex};
use std::time::Instant;
use thiserror::Error;
#[cfg(feature = "checksum")]
use xxhash_rust::xxh3::xxh3_64;

/// Error types for ByteStorage operations
#[derive(Debug, Error, Clone, PartialEq)]
pub enum ByteStorageError {
    #[error("input exceeds maximum size")]
    InputTooLarge,

    #[error("decompression ratio exceeds safety limit")]
    DecompressionBomb,

    #[error("integrity check failed")]
    ChecksumMismatch,

    #[error("compression failed")]
    CompressionFailed,

    #[error("decompression failed")]
    DecompressionFailed,

    #[error("size validation failed")]
    SizeValidationFailed,

    #[error("serialization failed: {0}")]
    SerializationFailed(String),

    #[error("deserialization failed: {0}")]
    DeserializationFailed(String),
}

// Security constants - Production-safe limits
const MAX_UNCOMPRESSED_SIZE: usize = 512 * 1024 * 1024; // 512MB limit
const MAX_COMPRESSED_SIZE: usize = 512 * 1024 * 1024; // 512MB limit
/// Maximum allowed compression ratio (1000:1)
/// Uses u64 for integer-only arithmetic to prevent floating-point precision bypass attacks
const MAX_COMPRESSION_RATIO: u64 = 1000;

/// Storage envelope for raw byte storage
/// Contains compressed data with integrity checking
#[derive(Serialize, Deserialize)]
pub struct StorageEnvelope {
    /// Compressed payload data
    pub compressed_data: Vec<u8>,
    /// xxHash3-64 checksum for integrity (8 bytes)
    pub checksum: [u8; 8],
    /// Original size for validation
    pub original_size: u32,
    /// Format identifier (e.g., "msgpack")
    pub format: String,
}

impl StorageEnvelope {
    /// Create new envelope with data compression and checksum
    #[cfg(all(feature = "compression", feature = "checksum"))]
    pub fn new(data: Vec<u8>, format: String) -> Result<Self, ByteStorageError> {
        // Security: Check input size before compression
        if data.len() > MAX_UNCOMPRESSED_SIZE {
            return Err(ByteStorageError::InputTooLarge);
        }

        let original_size = data.len() as u32;

        // Compress with LZ4
        let compressed_data = lz4_flex::compress(&data);

        // Security: Check compressed size
        if compressed_data.len() > MAX_COMPRESSED_SIZE {
            return Err(ByteStorageError::InputTooLarge);
        }

        // Generate xxHash3-64 checksum of original data (big-endian = xxhash canonical format)
        let checksum = xxh3_64(&data).to_be_bytes();

        Ok(StorageEnvelope {
            compressed_data,
            checksum,
            original_size,
            format,
        })
    }

    /// Extract and validate data from envelope
    #[cfg(all(feature = "compression", feature = "checksum"))]
    pub fn extract(&self) -> Result<Vec<u8>, ByteStorageError> {
        // Security: Validate envelope structure first
        if self.compressed_data.len() > MAX_COMPRESSED_SIZE {
            return Err(ByteStorageError::InputTooLarge);
        }

        if self.original_size as usize > MAX_UNCOMPRESSED_SIZE {
            return Err(ByteStorageError::InputTooLarge);
        }

        // Security: Check compression ratio for decompression bomb protection
        // Uses integer arithmetic to prevent floating-point precision bypass attacks
        let compressed_size = self.compressed_data.len() as u64;

        // Step 1: Zero check - empty compressed data with non-zero original is a bomb
        if compressed_size == 0 {
            return Err(ByteStorageError::DecompressionBomb);
        }

        // Step 2: Checked multiplication - overflow = bomb (fail-safe)
        let max_allowed_original = MAX_COMPRESSION_RATIO
            .checked_mul(compressed_size)
            .ok_or(ByteStorageError::DecompressionBomb)?;

        // Step 3: Compare original_size against computed maximum
        if (self.original_size as u64) > max_allowed_original {
            return Err(ByteStorageError::DecompressionBomb);
        }

        // Decompress (with validated sizes)
        let decompressed = lz4_flex::decompress(&self.compressed_data, self.original_size as usize)
            .map_err(|_| ByteStorageError::DecompressionFailed)?;

        // Verify checksum (checksum validation happens AFTER decompression to prevent processing corrupted data)
        // Note: xxHash3 is non-cryptographic, so we use simple equality (not constant-time)
        // Security against tampering is provided by AES-GCM authentication tag, not the checksum
        let computed_checksum = xxh3_64(&decompressed).to_be_bytes();
        if computed_checksum != self.checksum {
            return Err(ByteStorageError::ChecksumMismatch);
        }

        // Verify size (final safety check)
        if decompressed.len() != self.original_size as usize {
            return Err(ByteStorageError::SizeValidationFailed);
        }

        Ok(decompressed)
    }
}

/// Raw byte storage engine (pure Rust core)
/// Simple store/retrieve interface with no type awareness
pub struct ByteStorage {
    default_format: String,
    /// Last operation metrics (interior mutability for observability)
    last_metrics: Arc<Mutex<OperationMetrics>>,
}

impl ByteStorage {
    /// Create new ByteStorage instance
    pub fn new(default_format: Option<String>) -> Self {
        ByteStorage {
            default_format: default_format.unwrap_or_else(|| "msgpack".to_string()),
            last_metrics: Arc::new(Mutex::new(OperationMetrics::new())),
        }
    }

    /// Store arbitrary bytes with compression and checksums
    ///
    /// Returns serialized StorageEnvelope bytes
    #[cfg(all(feature = "compression", feature = "checksum", feature = "messagepack"))]
    pub fn store(&self, data: &[u8], format: Option<String>) -> Result<Vec<u8>, ByteStorageError> {
        // Security: Check input size before processing
        if data.len() > MAX_UNCOMPRESSED_SIZE {
            return Err(ByteStorageError::InputTooLarge);
        }

        let format = format.unwrap_or_else(|| self.default_format.clone());

        // Time compression operation
        let compression_start = Instant::now();
        let original_size = data.len();

        let envelope = StorageEnvelope::new(data.to_vec(), format)?;

        let compression_elapsed = compression_start.elapsed();
        let compression_micros = compression_elapsed.as_micros() as u64;
        let compressed_size = envelope.compressed_data.len();

        // Serialize envelope with MessagePack
        let envelope_bytes = rmp_serde::to_vec(&envelope)
            .map_err(|e| ByteStorageError::SerializationFailed(e.to_string()))?;

        // Security: Final check on serialized envelope size
        if envelope_bytes.len() > MAX_COMPRESSED_SIZE {
            return Err(ByteStorageError::InputTooLarge);
        }

        // Update metrics for observability
        if let Ok(mut metrics) = self.last_metrics.lock() {
            *metrics = OperationMetrics::new().with_compression(
                compression_micros,
                original_size,
                compressed_size,
            );
        }

        Ok(envelope_bytes)
    }

    /// Retrieve and validate stored bytes
    ///
    /// Returns (original_data, format_identifier)
    #[cfg(all(feature = "compression", feature = "checksum", feature = "messagepack"))]
    pub fn retrieve(&self, envelope_bytes: &[u8]) -> Result<(Vec<u8>, String), ByteStorageError> {
        // Security: Check envelope size before deserializing
        if envelope_bytes.len() > MAX_COMPRESSED_SIZE {
            return Err(ByteStorageError::InputTooLarge);
        }

        // Deserialize envelope
        let envelope: StorageEnvelope = rmp_serde::from_slice(envelope_bytes)
            .map_err(|e| ByteStorageError::DeserializationFailed(e.to_string()))?;

        // Time decompression and checksum operations
        let decompress_start = Instant::now();

        // Extract and validate data (all security checks happen inside extract())
        let data = envelope.extract()?;

        let decompress_elapsed = decompress_start.elapsed();
        let decompress_micros = decompress_elapsed.as_micros() as u64;

        // Calculate compression ratio from stored metadata
        let compressed_size = envelope.compressed_data.len();
        let original_size = envelope.original_size as usize;

        // Update metrics for observability
        if let Ok(mut metrics) = self.last_metrics.lock() {
            *metrics = OperationMetrics::new().with_compression(
                decompress_micros,
                original_size,
                compressed_size,
            );
        }

        Ok((data, envelope.format))
    }

    /// Get compression ratio for given data
    #[cfg(feature = "compression")]
    pub fn estimate_compression(&self, data: &[u8]) -> Result<f64, ByteStorageError> {
        // Security: Check size before compression
        if data.len() > MAX_UNCOMPRESSED_SIZE {
            return Err(ByteStorageError::InputTooLarge);
        }

        let compressed = lz4_flex::compress(data);

        Ok(data.len() as f64 / compressed.len() as f64)
    }

    /// Validate envelope without extracting data
    #[cfg(all(feature = "compression", feature = "checksum", feature = "messagepack"))]
    pub fn validate(&self, envelope_bytes: &[u8]) -> bool {
        // Security: Check size before validating
        if envelope_bytes.len() > MAX_COMPRESSED_SIZE {
            return false; // Invalid due to size limit
        }

        match rmp_serde::from_slice::<StorageEnvelope>(envelope_bytes) {
            Ok(envelope) => envelope.extract().is_ok(),
            Err(_) => false,
        }
    }

    /// Get metrics from last operation
    ///
    /// Returns a snapshot of metrics from the most recent store() or retrieve() call
    pub fn get_last_metrics(&self) -> OperationMetrics {
        self.last_metrics
            .lock()
            .map(|metrics| metrics.clone())
            .unwrap_or_else(|_| OperationMetrics::new())
    }

    /// Get security limits
    pub fn max_uncompressed_size(&self) -> usize {
        MAX_UNCOMPRESSED_SIZE
    }

    pub fn max_compressed_size(&self) -> usize {
        MAX_COMPRESSED_SIZE
    }

    pub fn max_compression_ratio(&self) -> u64 {
        MAX_COMPRESSION_RATIO
    }
}

impl Default for ByteStorage {
    fn default() -> Self {
        Self::new(None)
    }
}

#[cfg(all(
    test,
    feature = "compression",
    feature = "checksum",
    feature = "messagepack"
))]
mod tests {
    use super::*;

    #[test]
    fn test_storage_envelope_roundtrip() {
        let data = b"Hello, World! This is test data for compression.".to_vec();
        let envelope = StorageEnvelope::new(data.clone(), "test".to_string()).unwrap();
        let extracted = envelope.extract().unwrap();
        assert_eq!(data, extracted);
    }

    #[test]
    fn test_compression_works() {
        let data = b"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa".to_vec(); // Highly compressible
        let envelope = StorageEnvelope::new(data.clone(), "test".to_string()).unwrap();
        assert!(envelope.compressed_data.len() < data.len());
    }

    #[test]
    fn test_checksum_validation() {
        let mut envelope = StorageEnvelope::new(b"test".to_vec(), "test".to_string()).unwrap();
        // Corrupt the checksum
        envelope.checksum[0] = !envelope.checksum[0];
        assert!(envelope.extract().is_err());
    }

    #[test]
    fn test_raw_persistence_roundtrip() {
        let storage = ByteStorage::new(None);
        let test_data = b"test data for persistence";

        let stored = storage.store(test_data, None).unwrap();
        let (retrieved_data, format) = storage.retrieve(&stored).unwrap();
        assert_eq!(test_data, retrieved_data.as_slice());
        assert_eq!("msgpack", format);
    }

    #[test]
    fn test_size_limits_input() {
        let storage = ByteStorage::new(None);

        // Create data larger than MAX_UNCOMPRESSED_SIZE (512MB)
        let large_data = vec![0u8; MAX_UNCOMPRESSED_SIZE + 1];

        let result = storage.store(&large_data, None);
        assert!(matches!(result, Err(ByteStorageError::InputTooLarge)));
    }

    #[test]
    fn test_size_limits_envelope() {
        // Create data exactly at the limit
        let max_data = vec![0u8; MAX_UNCOMPRESSED_SIZE];
        let envelope_result = StorageEnvelope::new(max_data, "test".to_string());

        // Should succeed at exactly the limit
        assert!(envelope_result.is_ok());
    }

    #[test]
    fn test_compression_ratio_bomb_protection() {
        // Simulate a decompression bomb scenario
        let malicious_envelope = StorageEnvelope {
            compressed_data: vec![0u8; 1000], // Small compressed size
            checksum: [0u8; 8],               // Fake checksum
            original_size: 200 * 1024 * 1024, // Claims 200MB original (200x expansion)
            format: "test".to_string(),
        };

        let result = malicious_envelope.extract();
        assert!(matches!(result, Err(ByteStorageError::DecompressionBomb)));
    }

    // ============================================================================
    // Decompression Bomb Edge Case Tests (Task 6.1)
    // ============================================================================

    #[test]
    fn test_decompression_bomb_zero_compressed_size() {
        // WHY: Empty compressed data claiming non-zero original is always a bomb
        let malicious_envelope = StorageEnvelope {
            compressed_data: vec![], // Zero compressed size
            checksum: [0u8; 8],
            original_size: 1000, // Claims 1KB original
            format: "test".to_string(),
        };

        let result = malicious_envelope.extract();
        assert!(
            matches!(result, Err(ByteStorageError::DecompressionBomb)),
            "Zero compressed size should be rejected as decompression bomb"
        );
    }

    #[test]
    fn test_decompression_bomb_extreme_ratio() {
        // WHY: Test extreme ratio that exceeds 1000:1
        // compressed_size=1, original_size=2000 → 2000:1 ratio exceeds limit
        // Note: u32::MAX would be caught by InputTooLarge first (> MAX_UNCOMPRESSED_SIZE)
        let malicious_envelope = StorageEnvelope {
            compressed_data: vec![0u8; 1], // 1 byte compressed
            checksum: [0u8; 8],
            original_size: 2000, // 2000:1 ratio (exceeds 1000:1 limit)
            format: "test".to_string(),
        };

        let result = malicious_envelope.extract();
        assert!(
            matches!(result, Err(ByteStorageError::DecompressionBomb)),
            "Extreme ratio should be rejected as bomb: {:?}",
            result
        );
    }

    #[test]
    fn test_decompression_u32_max_original_size() {
        // WHY: u32::MAX original_size exceeds MAX_UNCOMPRESSED_SIZE
        // Should fail with InputTooLarge, not DecompressionBomb
        // This validates the check order (size limits before ratio)
        let malicious_envelope = StorageEnvelope {
            compressed_data: vec![0u8; 1000],
            checksum: [0u8; 8],
            original_size: u32::MAX, // ~4GB exceeds 512MB limit
            format: "test".to_string(),
        };

        let result = malicious_envelope.extract();
        assert!(
            matches!(result, Err(ByteStorageError::InputTooLarge)),
            "u32::MAX should be rejected as InputTooLarge (exceeds 512MB limit): {:?}",
            result
        );
    }

    #[test]
    fn test_decompression_exactly_at_threshold() {
        // WHY: Exactly 1000:1 ratio should be accepted (pass ratio check)
        // The test verifies the ratio check passes - subsequent failures are expected
        // (invalid LZ4 data will fail at decompression or checksum)
        let envelope = StorageEnvelope {
            compressed_data: vec![0u8; 100], // 100 bytes compressed (not valid LZ4)
            checksum: [0u8; 8],
            original_size: 100_000, // 100KB = exactly 1000:1 ratio
            format: "test".to_string(),
        };

        let result = envelope.extract();
        // KEY: Should NOT fail with DecompressionBomb (ratio check should pass)
        // Will fail with DecompressionFailed, ChecksumMismatch, or SizeValidationFailed
        assert!(
            !matches!(result, Err(ByteStorageError::DecompressionBomb)),
            "Exactly 1000:1 ratio should pass bomb check: {:?}",
            result
        );
        assert!(
            result.is_err(),
            "Invalid data should still fail after ratio check"
        );
    }

    #[test]
    fn test_decompression_just_over_threshold() {
        // WHY: 1001:1 ratio should be rejected
        let malicious_envelope = StorageEnvelope {
            compressed_data: vec![0u8; 100], // 100 bytes compressed
            checksum: [0u8; 8],
            original_size: 100_001, // 100.001KB = 1000.01:1 ratio (just over)
            format: "test".to_string(),
        };

        let result = malicious_envelope.extract();
        assert!(
            matches!(result, Err(ByteStorageError::DecompressionBomb)),
            "Just over 1000:1 ratio should be rejected as bomb"
        );
    }

    #[test]
    fn test_decompression_bomb_integer_boundary() {
        // WHY: Test near u64 overflow boundary
        // MAX_COMPRESSION_RATIO (1000) * compressed_size must not overflow
        // u64::MAX / 1000 ≈ 18,446,744,073,709,551 is max safe compressed_size
        // But we're constrained by MAX_COMPRESSED_SIZE (512MB), so overflow is unlikely
        // This test verifies the check works at realistic boundary

        let envelope = StorageEnvelope {
            compressed_data: vec![0u8; 1_000_000], // 1MB compressed
            checksum: [0u8; 8],
            original_size: 1_000_000_000, // 1GB = exactly 1000:1 ratio
            format: "test".to_string(),
        };

        // Should fail due to size limit (1GB > MAX_UNCOMPRESSED_SIZE)
        let result = envelope.extract();
        assert!(
            matches!(result, Err(ByteStorageError::InputTooLarge)),
            "Should fail size check before ratio check: {:?}",
            result
        );
    }

    #[test]
    fn test_envelope_size_validation() {
        let storage = ByteStorage::new(None);

        // Create oversized envelope bytes
        let oversized_envelope = vec![0u8; MAX_COMPRESSED_SIZE + 1];

        let result = storage.retrieve(&oversized_envelope);
        assert!(matches!(result, Err(ByteStorageError::InputTooLarge)));
    }

    #[test]
    fn test_security_limits_getters() {
        let storage = ByteStorage::new(None);

        assert_eq!(storage.max_uncompressed_size(), MAX_UNCOMPRESSED_SIZE);
        assert_eq!(storage.max_compressed_size(), MAX_COMPRESSED_SIZE);
        assert_eq!(storage.max_compression_ratio(), 1000u64);
    }

    #[test]
    fn test_compression_estimate_security() {
        let storage = ByteStorage::new(None);

        // Test with oversized data
        let large_data = vec![0u8; MAX_UNCOMPRESSED_SIZE + 1];
        let result = storage.estimate_compression(&large_data);
        assert!(matches!(result, Err(ByteStorageError::InputTooLarge)));
    }

    #[test]
    fn test_validate_security() {
        let storage = ByteStorage::new(None);

        // Test with oversized envelope
        let large_envelope = vec![0u8; MAX_COMPRESSED_SIZE + 1];
        let result = storage.validate(&large_envelope);
        assert!(!result); // Should be invalid due to size
    }

    #[test]
    fn test_edge_case_exactly_at_limits() {
        // Test data exactly at 512MB
        let storage = ByteStorage::new(None);
        let max_size_data = vec![1u8; MAX_UNCOMPRESSED_SIZE]; // Fill with 1s to ensure it's compressible

        // Should succeed at exactly the limit
        let result = storage.store(&max_size_data, None);
        assert!(result.is_ok());
    }

    #[test]
    fn test_zero_size_edge_case() {
        let storage = ByteStorage::new(None);
        let empty_data = vec![];

        let stored = storage.store(&empty_data, None).unwrap();
        let (retrieved_data, format) = storage.retrieve(&stored).unwrap();
        assert_eq!(empty_data, retrieved_data);
        assert_eq!("msgpack", format);
    }

    #[test]
    fn test_metrics_collection_on_store() {
        let storage = ByteStorage::new(None);
        let test_data = b"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa".to_vec(); // Compressible

        // Store data
        storage.store(&test_data, None).unwrap();
        let metrics = storage.get_last_metrics();

        // Verify metrics were collected
        assert!(metrics.compression_ratio > 0.0); // Should have valid compression ratio
    }

    #[test]
    fn test_metrics_collection_on_retrieve() {
        let storage = ByteStorage::new(None);
        let test_data = b"test data for retrieval metrics";

        // Store then retrieve
        let stored = storage.store(test_data, None).unwrap();
        storage.retrieve(&stored).unwrap();
        let metrics = storage.get_last_metrics();

        // Verify retrieve metrics were collected
        assert!(metrics.compression_ratio > 0.0); // Should have valid ratio
    }
}

// Kani Formal Verification Proofs
// These proofs use bounded model checking to verify critical security properties
// Bounded to complete within 10 minutes as per specification requirements
#[cfg(kani)]
mod kani_proofs {
    use super::*;

    /// Verify checksum integrity (corruption detection)
    /// Property: Any single-bit checksum corruption is always detected
    #[kani::proof]
    #[kani::unwind(10)] // Need 8+ for memcmp of 8-byte xxHash3-64 checksum
    fn verify_checksum_detects_corruption() {
        // Create symbolic checksum (xxHash3-64 produces 8 bytes)
        let checksum_a: [u8; 8] = kani::any();
        let mut checksum_b = checksum_a;

        // Flip exactly one bit
        let byte_index: usize = kani::any();
        let bit_index: usize = kani::any();
        kani::assume(byte_index < 8);
        kani::assume(bit_index < 8);

        checksum_b[byte_index] ^= 1 << bit_index;

        // Property: Corrupted checksum must differ from original
        assert_ne!(checksum_a, checksum_b);
    }

    /// Verify decompression bomb protection (compression ratio limits)
    /// Property: Malicious compression ratios exceeding 1000x are always rejected
    /// Uses integer arithmetic to match production implementation
    #[kani::proof]
    #[kani::unwind(3)]
    fn verify_decompression_bomb_protection() {
        // Symbolic envelope parameters
        let compressed_size: u64 = kani::any();
        let original_size: u64 = kani::any();

        // Constrain to reasonable test ranges
        kani::assume(compressed_size > 0 && compressed_size <= 1000);
        kani::assume(original_size > 0);

        // Simulate the 3-step check from StorageEnvelope::extract()
        // Step 1: Zero check already covered by assume
        // Step 2: Checked multiplication
        let max_allowed = MAX_COMPRESSION_RATIO.checked_mul(compressed_size);

        // Property: If original_size exceeds max_allowed, extraction must fail
        if let Some(max) = max_allowed {
            let would_reject = original_size > max;
            let exceeds_ratio = original_size > MAX_COMPRESSION_RATIO * compressed_size;
            assert_eq!(would_reject, exceeds_ratio);
        } else {
            // Overflow case: always reject (fail-safe)
            assert!(true); // Overflow is always rejected
        }
    }

    /// Verify size limit enforcement on input
    /// Property: Inputs exceeding MAX_UNCOMPRESSED_SIZE are always rejected
    #[kani::proof]
    #[kani::unwind(3)]
    fn verify_input_size_limits() {
        let size: usize = kani::any();

        // Test boundary conditions around the limit
        kani::assume(size <= MAX_UNCOMPRESSED_SIZE + 100);

        // Property: Size check logic is correct
        let exceeds_limit = size > MAX_UNCOMPRESSED_SIZE;
        let should_reject = size > MAX_UNCOMPRESSED_SIZE;

        assert_eq!(exceeds_limit, should_reject);
    }

    /// Verify size limit enforcement on compressed data
    /// Property: Compressed data exceeding MAX_COMPRESSED_SIZE is rejected
    #[kani::proof]
    #[kani::unwind(3)]
    fn verify_compressed_size_limits() {
        let compressed_size: usize = kani::any();

        // Test boundary conditions
        kani::assume(compressed_size <= MAX_COMPRESSED_SIZE + 100);

        // Property: Size check logic is correct
        let exceeds_limit = compressed_size > MAX_COMPRESSED_SIZE;
        let should_reject = compressed_size > MAX_COMPRESSED_SIZE;

        assert_eq!(exceeds_limit, should_reject);
    }

    /// Verify compression ratio calculation is safe (integer arithmetic)
    /// Property: Ratio check never panics and correctly identifies bombs
    #[kani::proof]
    #[kani::unwind(3)]
    fn verify_compression_ratio_calculation_safety() {
        let original_size: u64 = kani::any();
        let compressed_size: u64 = kani::any();

        // Constrain to prevent division by zero and keep ranges manageable
        kani::assume(compressed_size > 0);
        kani::assume(compressed_size <= 10000);
        kani::assume(original_size <= 100_000_000); // 100MB max for test

        // Property 1: checked_mul never panics (it returns None on overflow)
        let result = MAX_COMPRESSION_RATIO.checked_mul(compressed_size);

        // Property 2: If multiplication succeeds, comparison is valid
        if let Some(max_allowed) = result {
            // The check `original_size > max_allowed` is always safe
            let is_bomb = original_size > max_allowed;

            // Verify equivalence: is_bomb == (original_size > 1000 * compressed_size)
            // This holds when no overflow occurred
            if original_size <= max_allowed {
                assert!(!is_bomb);
            } else {
                assert!(is_bomb);
            }
        }

        // Property 3: Zero compressed_size is handled by separate check (not tested here)
    }
}