@elastic/elasticsearch-canary - npm Package Compare versions

Comparing version 8.1.0-canary.3 to 8.2.0-canary.1

lib/api/api/_internal.d.ts

@@ -16,2 +16,5 @@ import { Transport, TransportRequestOptions, TransportRequestOptionsWithMeta, TransportRequestOptionsWithOutMeta, TransportResult } from '@elastic/transport';
     getDesiredNodes(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
+    health(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
+    health(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
+    health(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
     updateDesiredNodes(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
@@ -18,0 +21,0 @@ updateDesiredNodes(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;

lib/api/api/_internal.js

@@ -65,2 +65,19 @@ "use strict";
     }
+    async health(params, options) {
+        const acceptedPath = [];
+        const querystring = {};
+        const body = undefined;
+        params = params !== null && params !== void 0 ? params : {};
+        for (const key in params) {
+            if (acceptedPath.includes(key)) {
+                continue;
+            }
+            else if (key !== 'body') {
+                querystring[key] = params[key];
+            }
+        }
+        const method = 'GET';
+        const path = '/_internal/_health';
+        return await this.transport.request({ path, method, querystring, body }, options);
+    }
     async updateDesiredNodes(params, options) {
@@ -67,0 +84,0 @@ const acceptedPath = ['history_id', 'version'];

lib/api/api/async_search.d.ts

@@ -16,5 +16,5 @@ import { Transport, TransportRequestOptions, TransportRequestOptionsWithMeta, TransportRequestOptionsWithOutMeta, TransportResult } from '@elastic/transport';
     get<TDocument = unknown>(this: That, params: T.AsyncSearchGetRequest | TB.AsyncSearchGetRequest, options?: TransportRequestOptions): Promise<T.AsyncSearchGetResponse<TDocument>>;
-    status<TDocument = unknown>(this: That, params: T.AsyncSearchStatusRequest | TB.AsyncSearchStatusRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.AsyncSearchStatusResponse<TDocument>>;
-    status<TDocument = unknown>(this: That, params: T.AsyncSearchStatusRequest | TB.AsyncSearchStatusRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.AsyncSearchStatusResponse<TDocument>, unknown>>;
-    status<TDocument = unknown>(this: That, params: T.AsyncSearchStatusRequest | TB.AsyncSearchStatusRequest, options?: TransportRequestOptions): Promise<T.AsyncSearchStatusResponse<TDocument>>;
+    status(this: That, params: T.AsyncSearchStatusRequest | TB.AsyncSearchStatusRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.AsyncSearchStatusResponse>;
+    status(this: That, params: T.AsyncSearchStatusRequest | TB.AsyncSearchStatusRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.AsyncSearchStatusResponse, unknown>>;
+    status(this: That, params: T.AsyncSearchStatusRequest | TB.AsyncSearchStatusRequest, options?: TransportRequestOptions): Promise<T.AsyncSearchStatusResponse>;
     submit<TDocument = unknown>(this: That, params?: T.AsyncSearchSubmitRequest | TB.AsyncSearchSubmitRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.AsyncSearchSubmitResponse<TDocument>>;
@@ -21,0 +21,0 @@ submit<TDocument = unknown>(this: That, params?: T.AsyncSearchSubmitRequest | TB.AsyncSearchSubmitRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.AsyncSearchSubmitResponse<TDocument>, unknown>>;

lib/api/api/migration.d.ts

@@ -13,9 +13,9 @@ import { Transport, TransportRequestOptions, TransportRequestOptionsWithMeta, TransportRequestOptionsWithOutMeta, TransportResult } from '@elastic/transport';
     deprecations(this: That, params?: T.MigrationDeprecationsRequest | TB.MigrationDeprecationsRequest, options?: TransportRequestOptions): Promise<T.MigrationDeprecationsResponse>;
-    getFeatureUpgradeStatus(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
-    getFeatureUpgradeStatus(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
-    getFeatureUpgradeStatus(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
-    postFeatureUpgrade(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
-    postFeatureUpgrade(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
-    postFeatureUpgrade(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
+    getFeatureUpgradeStatus(this: That, params?: T.MigrationGetFeatureUpgradeStatusRequest | TB.MigrationGetFeatureUpgradeStatusRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.MigrationGetFeatureUpgradeStatusResponse>;
+    getFeatureUpgradeStatus(this: That, params?: T.MigrationGetFeatureUpgradeStatusRequest | TB.MigrationGetFeatureUpgradeStatusRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.MigrationGetFeatureUpgradeStatusResponse, unknown>>;
+    getFeatureUpgradeStatus(this: That, params?: T.MigrationGetFeatureUpgradeStatusRequest | TB.MigrationGetFeatureUpgradeStatusRequest, options?: TransportRequestOptions): Promise<T.MigrationGetFeatureUpgradeStatusResponse>;
+    postFeatureUpgrade(this: That, params?: T.MigrationPostFeatureUpgradeRequest | TB.MigrationPostFeatureUpgradeRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.MigrationPostFeatureUpgradeResponse>;
+    postFeatureUpgrade(this: That, params?: T.MigrationPostFeatureUpgradeRequest | TB.MigrationPostFeatureUpgradeRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.MigrationPostFeatureUpgradeResponse, unknown>>;
+    postFeatureUpgrade(this: That, params?: T.MigrationPostFeatureUpgradeRequest | TB.MigrationPostFeatureUpgradeRequest, options?: TransportRequestOptions): Promise<T.MigrationPostFeatureUpgradeResponse>;
 }
 export {};

lib/api/api/migration.js

@@ -67,2 +67,3 @@ "use strict";
             else if (key !== 'body') {
+                // @ts-expect-error
                 querystring[key] = params[key];
@@ -85,2 +86,3 @@ }
             else if (key !== 'body') {
+                // @ts-expect-error
                 querystring[key] = params[key];
@@ -87,0 +89,0 @@ }

lib/api/api/ml.d.ts

@@ -100,2 +100,5 @@ import { Transport, TransportRequestOptions, TransportRequestOptionsWithMeta, TransportRequestOptionsWithOutMeta, TransportResult } from '@elastic/transport';
     getJobs(this: That, params?: T.MlGetJobsRequest | TB.MlGetJobsRequest, options?: TransportRequestOptions): Promise<T.MlGetJobsResponse>;
+    getMemoryStats(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
+    getMemoryStats(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
+    getMemoryStats(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
     getModelSnapshotUpgradeStats(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
@@ -102,0 +105,0 @@ getModelSnapshotUpgradeStats(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;

lib/api/api/security.d.ts

@@ -10,2 +10,5 @@ import { Transport, TransportRequestOptions, TransportRequestOptionsWithMeta, TransportRequestOptionsWithOutMeta, TransportResult } from '@elastic/transport';
     constructor(transport: Transport);
+    activateUserProfile(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
+    activateUserProfile(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
+    activateUserProfile(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
     authenticate(this: That, params?: T.SecurityAuthenticateRequest | TB.SecurityAuthenticateRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.SecurityAuthenticateResponse>;
@@ -95,2 +98,5 @@ authenticate(this: That, params?: T.SecurityAuthenticateRequest | TB.SecurityAuthenticateRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.SecurityAuthenticateResponse, unknown>>;
     getUserPrivileges(this: That, params?: T.SecurityGetUserPrivilegesRequest | TB.SecurityGetUserPrivilegesRequest, options?: TransportRequestOptions): Promise<T.SecurityGetUserPrivilegesResponse>;
+    getUserProfile(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
+    getUserProfile(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
+    getUserProfile(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
     grantApiKey(this: That, params: T.SecurityGrantApiKeyRequest | TB.SecurityGrantApiKeyRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.SecurityGrantApiKeyResponse>;
@@ -108,2 +114,11 @@ grantApiKey(this: That, params: T.SecurityGrantApiKeyRequest | TB.SecurityGrantApiKeyRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.SecurityGrantApiKeyResponse, unknown>>;
     invalidateToken(this: That, params?: T.SecurityInvalidateTokenRequest | TB.SecurityInvalidateTokenRequest, options?: TransportRequestOptions): Promise<T.SecurityInvalidateTokenResponse>;
+    oidcAuthenticate(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
+    oidcAuthenticate(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
+    oidcAuthenticate(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
+    oidcLogout(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
+    oidcLogout(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
+    oidcLogout(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
+    oidcPrepareAuthentication(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
+    oidcPrepareAuthentication(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
+    oidcPrepareAuthentication(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
     putPrivileges(this: That, params: T.SecurityPutPrivilegesRequest | TB.SecurityPutPrivilegesRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.SecurityPutPrivilegesResponse>;
@@ -142,3 +157,6 @@ putPrivileges(this: That, params: T.SecurityPutPrivilegesRequest | TB.SecurityPutPrivilegesRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.SecurityPutPrivilegesResponse, unknown>>;
     samlServiceProviderMetadata(this: That, params: T.SecuritySamlServiceProviderMetadataRequest | TB.SecuritySamlServiceProviderMetadataRequest, options?: TransportRequestOptions): Promise<T.SecuritySamlServiceProviderMetadataResponse>;
+    updateUserProfileData(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>;
+    updateUserProfileData(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>;
+    updateUserProfileData(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>;
 }
 export {};

lib/api/api/security.js

@@ -31,2 +31,19 @@ "use strict";
     }
+    async activateUserProfile(params, options) {
+        const acceptedPath = [];
+        const querystring = {};
+        const body = undefined;
+        params = params !== null && params !== void 0 ? params : {};
+        for (const key in params) {
+            if (acceptedPath.includes(key)) {
+                continue;
+            }
+            else if (key !== 'body') {
+                querystring[key] = params[key];
+            }
+        }
+        const method = 'POST';
+        const path = '/_security/profile/_activate';
+        return await this.transport.request({ path, method, querystring, body }, options);
+    }
     async authenticate(params, options) {
@@ -628,2 +645,19 @@ const acceptedPath = [];
     }
+    async getUserProfile(params, options) {
+        const acceptedPath = ['uid'];
+        const querystring = {};
+        const body = undefined;
+        params = params !== null && params !== void 0 ? params : {};
+        for (const key in params) {
+            if (acceptedPath.includes(key)) {
+                continue;
+            }
+            else if (key !== 'body') {
+                querystring[key] = params[key];
+            }
+        }
+        const method = 'GET';
+        const path = `/_security/profile/${encodeURIComponent(params.uid.toString())}`;
+        return await this.transport.request({ path, method, querystring, body }, options);
+    }
     async grantApiKey(params, options) {
@@ -764,2 +798,53 @@ const acceptedPath = [];
     }
+    async oidcAuthenticate(params, options) {
+        const acceptedPath = [];
+        const querystring = {};
+        const body = undefined;
+        params = params !== null && params !== void 0 ? params : {};
+        for (const key in params) {
+            if (acceptedPath.includes(key)) {
+                continue;
+            }
+            else if (key !== 'body') {
+                querystring[key] = params[key];
+            }
+        }
+        const method = 'POST';
+        const path = '/_security/oidc/authenticate';
+        return await this.transport.request({ path, method, querystring, body }, options);
+    }
+    async oidcLogout(params, options) {
+        const acceptedPath = [];
+        const querystring = {};
+        const body = undefined;
+        params = params !== null && params !== void 0 ? params : {};
+        for (const key in params) {
+            if (acceptedPath.includes(key)) {
+                continue;
+            }
+            else if (key !== 'body') {
+                querystring[key] = params[key];
+            }
+        }
+        const method = 'POST';
+        const path = '/_security/oidc/logout';
+        return await this.transport.request({ path, method, querystring, body }, options);
+    }
+    async oidcPrepareAuthentication(params, options) {
+        const acceptedPath = [];
+        const querystring = {};
+        const body = undefined;
+        params = params !== null && params !== void 0 ? params : {};
+        for (const key in params) {
+            if (acceptedPath.includes(key)) {
+                continue;
+            }
+            else if (key !== 'body') {
+                querystring[key] = params[key];
+            }
+        }
+        const method = 'POST';
+        const path = '/_security/oidc/prepare';
+        return await this.transport.request({ path, method, querystring, body }, options);
+    }
     async putPrivileges(params, options) {
@@ -1087,4 +1172,21 @@ var _a;
     }
+    async updateUserProfileData(params, options) {
+        const acceptedPath = ['uid'];
+        const querystring = {};
+        const body = undefined;
+        params = params !== null && params !== void 0 ? params : {};
+        for (const key in params) {
+            if (acceptedPath.includes(key)) {
+                continue;
+            }
+            else if (key !== 'body') {
+                querystring[key] = params[key];
+            }
+        }
+        const method = 'POST';
+        const path = `/_security/profile/_data/${encodeURIComponent(params.uid.toString())}`;
+        return await this.transport.request({ path, method, querystring, body }, options);
+    }
 }
 exports.default = Security;
 //# sourceMappingURL=security.js.map

lib/helpers.js

@@ -258,16 +258,20 @@ "use strict";
             timeoutRef = setTimeout(onFlushTimeout, flushInterval); // eslint-disable-line
-            for await (const operation of operationsStream) {
-                timeoutRef.refresh();
-                loadedOperations += 1;
-                msearchBody.push(operation[0], operation[1]);
-                callbacks.push(operation[2]);
-                if (loadedOperations >= operations) {
-                    const send = await semaphore();
-                    send(msearchBody.slice(), callbacks.slice());
-                    msearchBody.length = 0;
-                    callbacks.length = 0;
-                    loadedOperations = 0;
+            try {
+                for await (const operation of operationsStream) {
+                    timeoutRef.refresh();
+                    loadedOperations += 1;
+                    msearchBody.push(operation[0], operation[1]);
+                    callbacks.push(operation[2]);
+                    if (loadedOperations >= operations) {
+                        const send = await semaphore();
+                        send(msearchBody.slice(), callbacks.slice());
+                        msearchBody.length = 0;
+                        callbacks.length = 0;
+                        loadedOperations = 0;
+                    }
                 }
             }
-            clearTimeout(timeoutRef);
+            finally {
+                clearTimeout(timeoutRef);
+            }
             // In some cases the previos http call does not have finished,
@@ -274,0 +278,0 @@ // or we didn't reach the flush bytes threshold, so we force one last operation.

package.json

 {
   "name": "@elastic/elasticsearch-canary",
-  "version": "8.1.0-canary.3",
-  "versionCanary": "8.1.0-canary.3",
+  "version": "8.2.0-canary.1",
+  "versionCanary": "8.2.0-canary.1",
   "description": "The official Elasticsearch client for Node.js",
@@ -93,3 +93,3 @@ "main": "index.js",
   },
-  "commitHash": "63073e95"
+  "commitHash": "904c3bb2"
 }

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

Worsened metrics

Total package byte prevSize

2229432

decreased by-3.07%

Number of package files

259

decreased by-1.15%

Lines of code

46367

decreased by-0.59%

No dependency changes