support bulk ingest over PUT (#4997)

* accept bulk request over PUT

* add test for bulk over put

quickwit/quickwit-serve/src/elasticsearch_api/filter.rs

@@ -74,7 +74,7 @@ pub(crate) fn elasticsearch_filter(
 pub(crate) fn elastic_bulk_filter(
 ) -> impl Filter<Extract = (Body, ElasticBulkOptions), Error = Rejection> + Clone {
     warp::path!("_elastic" / "_bulk")
-        .and(warp::post())
+        .and(warp::post().or(warp::put()).unify())
         .and(warp::body::content_length_limit(
             CONTENT_LENGTH_LIMIT.as_u64(),
         ))
@@ -97,7 +97,7 @@ pub(crate) fn elastic_bulk_filter(
 pub(crate) fn elastic_index_bulk_filter(
 ) -> impl Filter<Extract = (String, Body, ElasticBulkOptions), Error = Rejection> + Clone {
     warp::path!("_elastic" / String / "_bulk")
-        .and(warp::post())
+        .and(warp::post().or(warp::put()).unify())
         .and(warp::body::content_length_limit(
             CONTENT_LENGTH_LIMIT.as_u64(),
         ))

quickwit/rest-api-tests/scenarii/es_compatibility/bulk/0004-put-request.yaml

@@ -0,0 +1,4 @@
+method: PUT
+ndjson:
+  - index: { "_index": "test-index", "_id": "1" }
+  - message: Hello, World!

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

@@ -0,0 +1,18 @@
+# Delete possibly remaining index
+method: DELETE
+endpoint: test-index
+status_code: null
+---
+method: PUT
+endpoint: test-index
+json: {
+  "mappings": {
+    "properties": {
+      "message": {
+        "type": "text",
+        "store": true
+      }
+    }
+  }
+}
+

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

@@ -0,0 +1,17 @@
+# Delete possibly remaining index
+method: DELETE
+api_root: http://localhost:7280/api/v1/
+endpoint: indexes/test-index
+status_code: null
+---
+method: POST
+api_root: http://localhost:7280/api/v1/
+endpoint: indexes/
+json:
+  version: "0.7"
+  index_id: test-index
+  doc_mapping:
+    field_mappings:
+        - name: message
+          type: text
+sleep_after: 3

quickwit/rest-api-tests/scenarii/es_compatibility/bulk/_teardown.elasticsearch.yaml

@@ -0,0 +1,3 @@
+method: DELETE
+endpoint: test-index
+---

quickwit/rest-api-tests/scenarii/es_compatibility/bulk/_teardown.quickwit.yaml

@@ -0,0 +1,3 @@
+method: DELETE
+api_root: http://localhost:7280/api/v1/
+endpoint: indexes/test-index

quickwit/rest-api-tests/scenarii/sort_orders/_teardown.quickwit.yaml

@@ -1,3 +1,3 @@
 # # Delete index
-# method: DELETE
-# endpoint: indexes/simple
+method: DELETE
+endpoint: indexes/sortorder