zarrs 0.23.10

//! The `adler32` bytes to bytes codec (Experimental).
//!
//! <div class="warning">
//! This codec is experimental and may be incompatible with other Zarr V3 implementations.
//! </div>
//!
//! Appends an adler32 checksum of the input bytestream.
//!
//! This codec requires the `adler32` feature, which is disabled by default.
//!
//! ### Compatible Implementations
//! This codec is fully compatible with the `numcodecs.adler32` codec in `zarr-python`.
//!
//! ### Specification
//! - <https://github.com/zarr-developers/zarr-extensions/tree/numcodecs/codecs/numcodecs.adler32>
//!
//! ### Codec `name` Aliases (Zarr V3)
//! - `numcodecs.adler32`
//!
//! ### Codec `id` Aliases (Zarr V2)
//! - `adler32`
//!
//! ### Codec `configuration` Example - [`Adler32CodecConfiguration`]:
//! ```rust
//! # let JSON = r#"
//! {}
//! # "#;
//! # use zarrs::metadata_ext::codec::adler32::Adler32CodecConfiguration;
//! # serde_json::from_str::<Adler32CodecConfiguration>(JSON).unwrap();
//! ```

mod adler32_codec;

use std::sync::Arc;

pub use adler32_codec::Adler32Codec;
use zarrs_metadata::v2::MetadataV2;
use zarrs_metadata::v3::MetadataV3;

use zarrs_codec::{Codec, CodecPluginV2, CodecPluginV3, CodecTraitsV2, CodecTraitsV3};
pub use zarrs_metadata_ext::codec::adler32::{
    Adler32CodecConfiguration, Adler32CodecConfigurationV1,
};
use zarrs_plugin::PluginCreateError;

zarrs_plugin::impl_extension_aliases!(Adler32Codec,
    v3: "numcodecs.adler32", [],
    v2: "adler32"
);

// Register the V3 codec.
inventory::submit! {
    CodecPluginV3::new::<Adler32Codec>()
}
// Register the V2 codec.
inventory::submit! {
    CodecPluginV2::new::<Adler32Codec>()
}

impl CodecTraitsV3 for Adler32Codec {
    fn create(metadata: &MetadataV3) -> Result<Codec, PluginCreateError> {
        let configuration = metadata.to_typed_configuration()?;
        let codec = Arc::new(Adler32Codec::new_with_configuration(&configuration)?);
        Ok(Codec::BytesToBytes(codec))
    }
}

impl CodecTraitsV2 for Adler32Codec {
    fn create(metadata: &MetadataV2) -> Result<Codec, PluginCreateError> {
        let configuration: Adler32CodecConfiguration = metadata.to_typed_configuration()?;
        let codec = Arc::new(Adler32Codec::new_with_configuration(&configuration)?);
        Ok(Codec::BytesToBytes(codec))
    }
}

const CHECKSUM_SIZE: usize = size_of::<u32>();

#[cfg(test)]
mod tests {
    use std::borrow::Cow;
    use std::sync::Arc;

    use super::*;
    use crate::array::BytesRepresentation;
    use zarrs_codec::{
        BytesPartialDecoderTraits, BytesToBytesCodecTraits, CodecMetadataOptions, CodecOptions,
        CodecTraits,
    };
    use zarrs_storage::byte_range::ByteRange;

    const JSON1: &str = r"{}";
    const JSON2: &str = r#"{"location":"start"}"#;
    const JSON3: &str = r#"{"location":"end"}"#;

    #[test]
    fn codec_adler32_configuration_none() {
        let codec_configuration: Adler32CodecConfiguration = serde_json::from_str(r"{}").unwrap();
        let codec = Adler32Codec::new_with_configuration(&codec_configuration).unwrap();
        let configuration = codec
            .configuration_v3(&CodecMetadataOptions::default())
            .unwrap();
        assert_eq!(serde_json::to_string(&configuration).unwrap(), r"{}");
    }

    #[test]
    fn codec_adler32() {
        let elements: Vec<u8> = (0..6).collect();
        let bytes = elements;
        let bytes_representation = BytesRepresentation::FixedSize(bytes.len() as u64);

        for json in [JSON1, JSON2, JSON3] {
            let codec_configuration: Adler32CodecConfiguration =
                serde_json::from_str(json).unwrap();
            let codec = Adler32Codec::new_with_configuration(&codec_configuration).unwrap();

            let encoded = codec
                .encode(Cow::Borrowed(&bytes), &CodecOptions::default())
                .unwrap();
            let decoded = codec
                .decode(
                    encoded.clone(),
                    &bytes_representation,
                    &CodecOptions::default(),
                )
                .unwrap();
            assert_eq!(bytes, decoded.to_vec());

            // Check that the checksum is correct
            let checksum: &[u8; 4] = if json.contains("end") {
                &encoded[encoded.len() - size_of::<u32>()..]
                    .try_into()
                    .unwrap()
            } else {
                &encoded[..size_of::<u32>()].try_into().unwrap()
            };
            println!("checksum {checksum:?}");
            assert_eq!(checksum, &[16, 0, 41, 0]);
        }
    }

    #[test]
    fn codec_adler32_partial_decode() {
        let elements: Vec<u8> = (0..32).collect();
        let bytes = elements;
        let bytes_representation = BytesRepresentation::FixedSize(bytes.len() as u64);

        for json in [JSON1, JSON2, JSON3] {
            let codec_configuration: Adler32CodecConfiguration =
                serde_json::from_str(json).unwrap();
            let codec =
                Arc::new(Adler32Codec::new_with_configuration(&codec_configuration).unwrap());

            let encoded = codec
                .encode(Cow::Owned(bytes.clone()), &CodecOptions::default())
                .unwrap();
            let decoded_regions = [ByteRange::FromStart(3, Some(2))];
            let input_handle = Arc::new(encoded);
            let partial_decoder = codec
                .partial_decoder(
                    input_handle.clone(),
                    &bytes_representation,
                    &CodecOptions::default(),
                )
                .unwrap();
            assert_eq!(partial_decoder.size_held(), input_handle.size_held()); // adler32 partial decoder does not hold bytes
            let decoded_partial_chunk = partial_decoder
                .partial_decode_many(
                    Box::new(decoded_regions.into_iter()),
                    &CodecOptions::default(),
                )
                .unwrap()
                .unwrap();
            let answer: &[Vec<u8>] = &[vec![3, 4]];
            assert_eq!(
                answer,
                decoded_partial_chunk
                    .into_iter()
                    .map(|v| v.to_vec())
                    .collect::<Vec<_>>()
            );
        }
    }

    #[cfg(feature = "async")]
    #[tokio::test]
    async fn codec_adler32_async_partial_decode() {
        let elements: Vec<u8> = (0..32).collect();
        let bytes = elements;
        let bytes_representation = BytesRepresentation::FixedSize(bytes.len() as u64);

        for json in [JSON1, JSON2, JSON3] {
            let codec_configuration: Adler32CodecConfiguration =
                serde_json::from_str(json).unwrap();
            let codec =
                Arc::new(Adler32Codec::new_with_configuration(&codec_configuration).unwrap());

            let encoded = codec
                .encode(Cow::Owned(bytes.clone()), &CodecOptions::default())
                .unwrap();
            let decoded_regions = [ByteRange::FromStart(3, Some(2))];
            let input_handle = Arc::new(encoded);
            let partial_decoder = codec
                .async_partial_decoder(
                    input_handle,
                    &bytes_representation,
                    &CodecOptions::default(),
                )
                .await
                .unwrap();
            let decoded_partial_chunk = partial_decoder
                .partial_decode_many(
                    Box::new(decoded_regions.into_iter()),
                    &CodecOptions::default(),
                )
                .await
                .unwrap()
                .unwrap();
            let answer: &[Vec<u8>] = &[vec![3, 4]];
            assert_eq!(
                answer,
                decoded_partial_chunk
                    .into_iter()
                    .map(|v| v.to_vec())
                    .collect::<Vec<_>>()
            );
        }
    }
}