[7.x] Legacy ES plugin pre-removal cleanup (#75779)

src/core/server/ui_settings/integration_tests/index.test.ts

@@ -24,22 +24,6 @@ import { docMissingSuite } from './doc_missing';
 import { docMissingAndIndexReadOnlySuite } from './doc_missing_and_index_read_only';
 
 describe('uiSettings/routes', function () {
-  /**
-   *  The "doc missing" and "index missing" tests verify how the uiSettings
-   *  API behaves in between healthChecks, so they interact with the healthCheck
-   *  in somewhat weird ways (can't wait until we get to https://github.com/elastic/kibana/issues/14163)
-   *
-   *  To make this work we have a `waitUntilNextHealthCheck()` function in ./lib/servers.js
-   *  that deletes the kibana index and then calls `plugins.elasticsearch.waitUntilReady()`.
-   *
-   *  waitUntilReady() waits for the kibana index to exist and then for the
-   *  elasticsearch plugin to go green. Since we have verified that the kibana index
-   *  does not exist we know that the plugin will also turn yellow while waiting for
-   *  it and then green once the health check is complete, ensuring that we run our
-   *  tests right after the health check. All of this is to say that the tests are
-   *  stupidly fragile and timing sensitive. #14163 should fix that, but until then
-   *  this is the most stable way I've been able to get this to work.
-   */
   jest.setTimeout(10000);
 
   beforeAll(startServers);

src/core/server/ui_settings/integration_tests/lib/servers.ts

@@ -39,7 +39,6 @@ interface AllServices {
   savedObjectsClient: SavedObjectsClientContract;
   callCluster: LegacyAPICaller;
   uiSettings: IUiSettingsClient;
-  deleteKibanaIndex: typeof deleteKibanaIndex;
 }
 
 let services: AllServices;
@@ -62,20 +61,6 @@ export async function startServers() {
   kbnServer = kbn.kbnServer;
 }
 
-async function deleteKibanaIndex(callCluster: LegacyAPICaller) {
-  const kibanaIndices = await callCluster('cat.indices', { index: '.kibana*', format: 'json' });
-  const indexNames = kibanaIndices.map((x: any) => x.index);
-  if (!indexNames.length) {
-    return;
-  }
-  await callCluster('indices.putSettings', {
-    index: indexNames,
-    body: { index: { blocks: { read_only: false } } },
-  });
-  await callCluster('indices.delete', { index: indexNames });
-  return indexNames;
-}
-
 export function getServices() {
   if (services) {
     return services;
@@ -97,7 +82,6 @@ export function getServices() {
     callCluster,
     savedObjectsClient,
     uiSettings,
-    deleteKibanaIndex,
   };
 
   return services;

src/legacy/core_plugins/elasticsearch/index.d.ts

@@ -523,6 +523,4 @@ export interface CallCluster {
 export interface ElasticsearchPlugin {
   status: { on: (status: string, cb: () => void) => void };
   getCluster(name: string): Cluster;
-  createCluster(name: string, config: ClusterConfig): Cluster;
-  waitUntilReady(): Promise<void>;
 }

src/legacy/core_plugins/elasticsearch/index.js

@@ -19,14 +19,12 @@
 import { first } from 'rxjs/operators';
 import { Cluster } from './lib/cluster';
 import { createProxy } from './lib/create_proxy';
-import { handleESError } from './lib/handle_es_error';
-import { versionHealthCheck } from './lib/version_health_check';
 
 export default function (kibana) {
   let defaultVars;
 
   return new kibana.Plugin({
-    require: ['kibana'],
+    require: [],
 
     uiExports: { injectDefaultVars: () => defaultVars },
 
@@ -61,25 +59,6 @@ export default function (kibana) {
         return clusters.get(name);
       });
 
-      server.expose('createCluster', (name, clientConfig = {}) => {
-        // NOTE: Not having `admin` and `data` clients provided by the core in `clusters`
-        // map implicitly allows to create custom `data` and `admin` clients. This is
-        // allowed intentionally to support custom `admin` cluster client created by the
-        // x-pack/monitoring bulk uploader. We should forbid that as soon as monitoring
-        // bulk uploader is refactored, see https://github.com/elastic/kibana/issues/31934.
-        if (clusters.has(name)) {
-          throw new Error(`cluster '${name}' already exists`);
-        }
-
-        const cluster = new Cluster(
-          server.newPlatform.setup.core.elasticsearch.legacy.createClient(name, clientConfig)
-        );
-
-        clusters.set(name, cluster);
-
-        return cluster;
-      });
-
       server.events.on('stop', () => {
         for (const cluster of clusters.values()) {
           cluster.close();
@@ -88,17 +67,7 @@ export default function (kibana) {
         clusters.clear();
       });
 
-      server.expose('handleESError', handleESError);
-
       createProxy(server);
-
-      const waitUntilHealthy = versionHealthCheck(
-        this,
-        server.logWithMetadata,
-        server.newPlatform.__internals.elasticsearch.esNodesCompatibility$
-      );
-
-      server.expose('waitUntilReady', () => waitUntilHealthy);
     },
   });
 }