use app_error::AppError;
use brotli::Decompressor;
use std::io::Read;

pub const X_COMPRESSION_TYPE: &str = "X-Compression-Type";

pub const X_COMPRESSION_BUFFER_SIZE: &str = "X-Compression-Buffer-Size";
pub enum CompressionType {
  Brotli { buffer_size: usize },
}

pub async fn decompress(data: Vec<u8>, buffer_size: usize) -> Result<Vec<u8>, AppError> {
  tokio::task::spawn_blocking(move || {
    let mut decompressor = Decompressor::new(&*data, buffer_size);
    let mut decompressed_data = Vec::new();
    decompressor
      .read_to_end(&mut decompressed_data)
      .map_err(|err| {
        AppError::InvalidRequest(format!("Failed to decompress data:{} {}", data.len(), err))
      })?;
    Ok(decompressed_data)
  })
  .await
  .map_err(AppError::from)?
}