[esArchiver] upgrade to new ES client

package.json

@@ -568,6 +568,7 @@
     "@welldone-software/why-did-you-render": "^5.0.0",
     "@yarnpkg/lockfile": "^1.1.0",
     "abab": "^2.0.4",
+    "aggregate-error": "^3.1.0",
     "angular-aria": "^1.8.0",
     "angular-mocks": "^1.7.9",
     "angular-recursion": "^1.0.5",

packages/kbn-es-archiver/src/actions/empty_kibana_index.ts

@@ -6,7 +6,7 @@
  * Public License, v 1.
  */
 
-import { Client } from 'elasticsearch';
+import { Client } from '@elastic/elasticsearch';
 import { ToolingLog, KbnClient } from '@kbn/dev-utils';
 
 import { migrateKibanaIndex, createStats, cleanKibanaIndices } from '../lib';

packages/kbn-es-archiver/src/actions/load.ts

@@ -10,7 +10,7 @@ import { resolve } from 'path';
 import { createReadStream } from 'fs';
 import { Readable } from 'stream';
 import { ToolingLog, KbnClient } from '@kbn/dev-utils';
-import { Client } from 'elasticsearch';
+import { Client } from '@elastic/elasticsearch';
 
 import { createPromiseFromStreams, concatStreamProviders } from '@kbn/utils';
 
@@ -92,7 +92,7 @@ export async function loadAction({
 
   await client.indices.refresh({
     index: '_all',
-    allowNoIndices: true,
+    allow_no_indices: true,
   });
 
   // If we affected the Kibana index, we need to ensure it's migrated...

packages/kbn-es-archiver/src/actions/save.ts

@@ -9,7 +9,7 @@
 import { resolve } from 'path';
 import { createWriteStream, mkdirSync } from 'fs';
 import { Readable, Writable } from 'stream';
-import { Client } from 'elasticsearch';
+import { Client } from '@elastic/elasticsearch';
 import { ToolingLog } from '@kbn/dev-utils';
 import { createListStream, createPromiseFromStreams } from '@kbn/utils';
 

packages/kbn-es-archiver/src/actions/unload.ts

@@ -9,7 +9,7 @@
 import { resolve } from 'path';
 import { createReadStream } from 'fs';
 import { Readable, Writable } from 'stream';
-import { Client } from 'elasticsearch';
+import { Client } from '@elastic/elasticsearch';
 import { ToolingLog, KbnClient } from '@kbn/dev-utils';
 import { createPromiseFromStreams } from '@kbn/utils';
 

packages/kbn-es-archiver/src/cli.ts

@@ -19,7 +19,7 @@ import Fs from 'fs';
 
 import { RunWithCommands, createFlagError, KbnClient, CA_CERT_PATH } from '@kbn/dev-utils';
 import { readConfigFile } from '@kbn/test';
-import legacyElasticsearch from 'elasticsearch';
+import { Client } from '@elastic/elasticsearch';
 
 import { EsArchiver } from './es_archiver';
 
@@ -115,10 +115,9 @@ export function runCli() {
         throw createFlagError('--dir or --config must be defined');
       }
 
-      const client = new legacyElasticsearch.Client({
-        host: esUrl,
+      const client = new Client({
+        node: esUrl,
         ssl: esCa ? { ca: esCa } : undefined,
-        log: flags.verbose ? 'trace' : [],
       });
       addCleanupTask(() => client.close());
 

packages/kbn-es-archiver/src/es_archiver.ts

@@ -6,7 +6,7 @@
  * Public License, v 1.
  */
 
-import { Client } from 'elasticsearch';
+import { Client } from '@elastic/elasticsearch';
 import { ToolingLog, KbnClient } from '@kbn/dev-utils';
 
 import {