sevenz-rust2 0.21.0

use std::io::Read;

use crc32fast::Hasher;

/// A wrapper around a reader that tracks read count and CRC32.
///
/// Used during compression to track how much data has been read and compute
/// the CRC32 checksum of the data.
pub struct SourceReader<R> {
    reader: R,
    size: usize,
    crc: Hasher,
    crc_value: u32,
}

impl<R> From<R> for SourceReader<R> {
    fn from(value: R) -> Self {
        Self::new(value)
    }
}

impl<R: Read> Read for SourceReader<R> {
    fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
        let n = self.reader.read(buf)?;
        if self.crc_value == 0 {
            if n > 0 {
                self.size += n;
                self.crc.update(&buf[..n]);
            } else {
                let crc = std::mem::replace(&mut self.crc, Hasher::new());
                self.crc_value = crc.finalize();
            }
        }
        Ok(n)
    }
}

impl<R> SourceReader<R> {
    /// Creates a new source reader wrapper.
    ///
    /// # Arguments
    /// * `reader` - The underlying reader to wrap
    pub fn new(reader: R) -> Self {
        Self {
            reader,
            size: 0,
            crc: Hasher::new(),
            crc_value: 0,
        }
    }

    /// Returns the total number of bytes read so far.
    pub fn read_count(&self) -> usize {
        self.size
    }

    /// Returns the CRC32 value of all data read.
    ///
    /// The CRC is only computed once all data has been read (when read returns 0).
    pub fn crc_value(&self) -> u32 {
        self.crc_value
    }
}