@elastic/elasticsearch-canary - npm Package Compare versions

Comparing version 7.12.0-canary.2 to 7.12.0-canary.3

lib/Helpers.d.ts

@@ -28,4 +28,4 @@ /*
   scrollDocuments<TDocument = unknown, TRequestBody extends RequestBody = Record<string, any>>(params: Search<TRequestBody>, options?: TransportRequestOptions): AsyncIterable<TDocument>
-  msearch(options?: MsearchHelperOptions): MsearchHelper
-  bulk<TDocument = unknown>(options: BulkHelperOptions<TDocument>): BulkHelper<BulkStats>
+  msearch(options?: MsearchHelperOptions, reqOptions?: TransportRequestOptions): MsearchHelper
+  bulk<TDocument = unknown>(options: BulkHelperOptions<TDocument>, reqOptions?: TransportRequestOptions): BulkHelper<BulkStats>
 }
@@ -32,0 +32,0 @@

lib/Helpers.js

@@ -161,3 +161,3 @@ /*
     appendFilterPath('hits.hits._source', params, true)
-    for await (const { documents } of this.scrollSearch(params)) {
+    for await (const { documents } of this.scrollSearch(params, options)) {
       for (const document of documents) {
@@ -173,5 +173,6 @@ yield document
    * @param {object} options - The configuration of the msearch operations.
+   * @param {object} reqOptions - The client optional configuration for this request.
    * @return {object} The possible operations to run.
    */
-  msearch (options = {}) {
+  msearch (options = {}, reqOptions = {}) {
     const client = this[kClient]
@@ -383,3 +384,3 @@ const {
       function tryMsearch (msearchBody, callbacks, done) {
-        client.msearch(Object.assign({}, msearchOptions, { body: msearchBody }), (err, results) => {
+        client.msearch(Object.assign({}, msearchOptions, { body: msearchBody }), reqOptions, (err, results) => {
           const retryBody = []
@@ -421,8 +422,12 @@ const retryCallbacks = []
    * @param {object} options - The configuration of the bulk operation.
+   * @param {object} reqOptions - The client optional configuration for this request.
    * @return {object} The possible operations to run with the datasource.
    */
-  bulk (options) {
+  bulk (options, reqOptions = {}) {
     const client = this[kClient]
     const { serialize, deserialize } = client.serializer
-    const reqOptions = this[kMetaHeader] !== null ? { headers: { 'x-elastic-client-meta': this[kMetaHeader] + ',h=bp' } } : {}
+    if (this[kMetaHeader] !== null) {
+      reqOptions.headers = reqOptions.headers || {}
+      reqOptions.headers['x-elastic-client-meta'] = this[kMetaHeader] + ',h=bp'
+    }
     const {
@@ -552,3 +557,3 @@ datasource,
             : '_all'
-        })
+        }, reqOptions)
       }
@@ -555,0 +560,0 @@

package.json

@@ -14,4 +14,4 @@ {
   "homepage": "http://www.elastic.co/guide/en/elasticsearch/client/javascript-api/current/index.html",
-  "version": "7.12.0-canary.2",
-  "versionCanary": "7.12.0-canary.2",
+  "version": "7.12.0-canary.3",
+  "versionCanary": "7.12.0-canary.3",
   "keywords": [
@@ -107,3 +107,3 @@ "elasticsearch",
   },
-  "commitHash": "31b4d41d"
+  "commitHash": "5a25b7cb"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1252791

increased by0.03%

Lines of code

19614

increased by0.03%

No dependency changes