manually set headers in test

Author: PSeitz

quickwit/quickwit-serve/src/decompression.rs

@@ -21,10 +21,10 @@ use std::io::Read;
 
 use bytes::Bytes;
 use flate2::read::GzDecoder;
+use thiserror::Error;
 use tokio::task;
 use warp::reject::Reject;
 use warp::Filter;
-use thiserror::Error;
 
 /// There are two ways to decompress the body:
 /// - Stream the body through an async decompressor

quickwit/rest-api-tests/run_tests.py

@@ -95,10 +95,6 @@ def run_request_step(method, step, previous_result):
     if body_from_file is not None:
         body_from_file = osp.join(step["cwd"], body_from_file)
         kvargs["data"] = open(body_from_file, 'rb').read()
-        if body_from_file.endswith("gz"):
-            kvargs.setdefault("headers")["content-encoding"] = "gzip"
-        if body_from_file.endswith("zst"):
-            kvargs.setdefault("headers")["content-encoding"] = "zstd"
 
     kvargs = resolve_previous_result(kvargs, previous_result)
     ndjson = step.get("ndjson", None)

quickwit/rest-api-tests/scenarii/es_compatibility/_setup.elasticsearch.yaml

@@ -102,6 +102,6 @@ method: POST
 endpoint: _bulk
 params:
   refresh: "true"
-headers: {"Content-Type": "application/json"}
+headers: {"Content-Type": "application/json", "content-encoding": "gzip"}
 body_from_file: gharchive-bulk.json.gz
 

quickwit/rest-api-tests/scenarii/es_compatibility/_setup.quickwit.yaml

@@ -56,6 +56,6 @@ endpoint: _bulk
 num_retries: 10
 params:
   refresh: "true"
-headers: {"Content-Type": "application/json"}
+headers: {"Content-Type": "application/json", "content-encoding": "gzip"}
 body_from_file: gharchive-bulk.json.gz
 sleep_after: 3