lint

Author: Geal

apollo-router/src/axum_factory/axum_http_server_factory.rs

@@ -469,7 +469,7 @@ async fn handle_graphql(
             tracing::info!(counter.apollo_router_session_count_active = -1,);
             let (mut parts, body) = response.response.into_parts();
 
-            println!("will compress response, accept-encoding == {accept_encoding:?}");
+            //println!("will compress response, accept-encoding == {accept_encoding:?}");
 
             let opt_compressor = accept_encoding
                 .as_ref()

apollo-router/src/axum_factory/compression/codec/brotli/encoder.rs

@@ -33,7 +33,7 @@ impl BrotliEncoder {
         op: BrotliEncoderOperation,
     ) -> Result<()> {
         let in_buf = input.unwritten();
-        let mut out_buf = output.unwritten_mut();
+        let out_buf = output.unwritten_mut();
 
         let mut input_len = 0;
         let mut output_len = 0;

apollo-router/src/axum_factory/compression/codec/gzip/header.rs

@@ -1,3 +1,4 @@
+#![allow(dead_code)]
 // All code from this module is extracted from https://github.com/Nemo157/async-compression and is under MIT or Apache-2 licence
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
 use crate::axum_factory::compression::util::PartialBuffer;

apollo-router/src/axum_factory/compression/codec/mod.rs

@@ -7,14 +7,14 @@ mod brotli;
 mod deflate;
 mod flate;
 mod gzip;
-mod zlib;
+//mod zlib;
 mod zstd;
 
 pub(crate) use self::brotli::BrotliEncoder;
 pub(crate) use self::deflate::DeflateEncoder;
 pub(crate) use self::flate::FlateEncoder;
 pub(crate) use self::gzip::GzipEncoder;
-pub(crate) use self::zlib::ZlibEncoder;
+//pub(crate) use self::zlib::ZlibEncoder;
 pub(crate) use self::zstd::ZstdEncoder;
 
 pub(crate) trait Encode {

apollo-router/src/axum_factory/compression/mod.rs

@@ -80,9 +80,9 @@ where {
                                 Ok(()) => {}
                             }
 
-                            let read = partial_input.written().len();
+                            //let read = partial_input.written().len();
                             written += partial_output.written().len();
-                            println!("encode: read from input: {read}, written = {written}");
+                            //println!("encode: read from input: {read}, written = {written}");
 
                             if !partial_input.unwritten().is_empty() {
                                 // there was not enough space in the output buffer to compress everything,
@@ -97,7 +97,7 @@ where {
                                     Err(e) => panic!("{e:?}"),
                                     Ok(_) => {
                                         let flushed = partial_output.written().len() - written;
-                                        println!("flush with buffer of size {flushed}");
+                                        //println!("flush with buffer of size {flushed}");
                                         let _ = partial_output.into_inner();
                                         buf.resize(flushed, 0);
                                         if let Err(_) = tx.send(Ok(buf.freeze())).await {
@@ -119,7 +119,7 @@ where {
                 Err(e) => panic!("{e:?}"),
                 Ok(_) => {
                     let len = partial_output.written().len();
-                    println!("finish with buffer of size {}", len);
+                    //println!("finish with buffer of size {}", len);
 
                     let mut buf = partial_output.into_inner();
                     buf.resize(len, 0);
@@ -128,7 +128,6 @@ where {
                     }
                 }
             }
-            //tx.send(partial_output.into_inner().freeze());
         });
         ReceiverStream::new(rx)
     }

apollo-router/src/axum_factory/compression/util.rs

@@ -1,3 +1,4 @@
+#![allow(dead_code)]
 // All code from this module is extracted from https://github.com/Nemo157/async-compression and is under MIT or Apache-2 licence
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
 pub(crate) fn _assert_send<T: Send>() {}