use fastest compression encoding

Author: Snd-R

src/http_compression.rs

@@ -1,8 +1,10 @@
 use std::io::Result;
 use std::ops::Deref;
 
+use async_compression::Level;
 use async_compression::tokio::write::{BrotliDecoder, BrotliEncoder, DeflateDecoder, DeflateEncoder, GzipDecoder, GzipEncoder};
 use bytes::Bytes;
+use Level::Fastest;
 use tokio::io::AsyncWriteExt;
 
 pub async fn decompress(bytes: Bytes, algorithm: Algorithm) -> Result<Bytes> {
@@ -31,19 +33,19 @@ pub async fn decompress(bytes: Bytes, algorithm: Algorithm) -> Result<Bytes> {
 pub async fn compress(bytes: Bytes, algorithm: Algorithm) -> Result<Bytes> {
     match algorithm {
         Algorithm::Brotli => {
-            let mut encoder = BrotliEncoder::new(Vec::new());
+            let mut encoder = BrotliEncoder::with_quality(Vec::new(), Fastest);
             encoder.write_all(bytes.deref()).await?;
             encoder.shutdown().await?;
             Ok(Bytes::from(encoder.into_inner()))
         }
         Algorithm::Gzip => {
-            let mut encoder = GzipEncoder::new(Vec::new());
+            let mut encoder = GzipEncoder::with_quality(Vec::new(), Fastest);
             encoder.write_all(bytes.deref()).await?;
             encoder.shutdown().await?;
             Ok(Bytes::from(encoder.into_inner()))
         }
         Algorithm::Deflate => {
-            let mut encoder = DeflateEncoder::new(Vec::new());
+            let mut encoder = DeflateEncoder::with_quality(Vec::new(), Fastest);
             encoder.write_all(bytes.deref()).await?;
             encoder.shutdown().await?;
             Ok(Bytes::from(encoder.into_inner()))

src/routes.rs

@@ -18,8 +18,7 @@ pub async fn routes() {
         .map(move |_id, _page| (config.upstream_url.clone(), "".to_string()))
         .untuple_one()
         .and(extract_request_data_filter())
-        .and_then(proxy_upscale_and_forward)
-        .with(warp::compression::brotli());
+        .and_then(proxy_upscale_and_forward);
 
     let kavita_upscale = warp::path!("api"/"reader"/"image")
         .map(|| (config.upstream_url.clone(), "".to_string()))
@@ -50,6 +49,7 @@ async fn proxy_upscale_and_forward(
     body: Bytes,
 ) -> Result<Response<Bytes>, Rejection> {
     let uri_str = format!("{} {}", method, uri.as_str());
+    // TODO do not request compressed data to avoid decode and re-encode
     let response = proxy_to_and_forward_response(proxy_address, base_path, uri, params, method, headers, body).await?;
     let status = response.status();