Function test_full_pipeline

atomic-core/src/change/format_v3/chunking.rs:1187–1218

()

    #[test]
    fn test_full_pipeline() {
        // Simulate a realistic scenario: source code content
        let mut data = Vec::new();
        for i in 0..5000 {
            let line = format!(
                "/// Documentation for function {}\nfn func_{}(x: i32) -> i32 {{ x + {} }}\n\n",
                i,
                i,
                i * 7
            );
            data.extend_from_slice(line.as_bytes());
        }

        // Chunk
        let (chunks, chunk_stats) = chunk_content_with_stats(&data, &ChunkingOptions::default());
        assert!(chunk_stats.chunk_count >= 1);
        assert_eq!(chunk_stats.total_input_bytes, data.len());

        // Compress in parallel
        let (compressed, comp_stats) = compress_chunks_parallel_with_stats(&data, &chunks, 3);
        assert_eq!(comp_stats.chunk_count, chunks.len());
        assert!(comp_stats.total_compressed < comp_stats.total_uncompressed);

        // Decompress and reassemble
        let mut reassembled = Vec::with_capacity(data.len());
        for cc in &compressed {
            let decompressed = zstd::decode_all(&cc.compressed_data[..]).unwrap();
            reassembled.extend_from_slice(&decompressed);
        }

        assert_eq!(reassembled, data, "reassembled data should match original");
    }

    #[test]
    fn test_full_pipeline_with_different_compression_levels() {