Move startup logic over to server plugin file and call from index.js

elastic · Nov 19, 2019 · afcfe02 · afcfe02
1 parent 7593926
commit afcfe02
Show file tree

Hide file tree

Showing 2 changed files with 56 additions and 26 deletions.
diff --git a/x-pack/legacy/plugins/file_upload/index.js b/x-pack/legacy/plugins/file_upload/index.js
@@ -3,10 +3,7 @@
  * or more contributor license agreements. Licensed under the Elastic License;
  * you may not use this file except in compliance with the Elastic License.
  */
-import { mirrorPluginStatus } from '../../server/lib/mirror_plugin_status';
-import { getImportRouteHandler } from './server/routes/file_upload';
-import { getTelemetry, initTelemetry } from './server/telemetry/telemetry';
-import { MAX_BYTES } from './common/constants/file_import';
+import { FileUploadPlugin } from './server/plugin';
 import { mappings } from './mappings';
 
 export const fileUpload = kibana => {
@@ -24,31 +21,27 @@ export const fileUpload = kibana => {
     },
 
     init(server) {
-      const elasticsearchPlugin = server.plugins.elasticsearch;
-      const getSavedObjectsRepository = server.savedObjects.getSavedObjectsRepository;
-      const xpackMainPlugin = server.plugins.xpack_main;
-      const makeUsageCollector = server.usage.collectorSet.makeUsageCollector;
+      const coreSetup = server.newPlatform.setup.core;
+      const pluginsSetup = {};
 
-      mirrorPluginStatus(xpackMainPlugin, this);
-
-      // Set up route
-      server.route({
-        method: 'POST',
-        path: '/api/fileupload/import',
-        handler: getImportRouteHandler(elasticsearchPlugin, getSavedObjectsRepository),
-        config: {
-          payload: { maxBytes: MAX_BYTES },
+      // legacy dependencies
+      const __LEGACY = {
+        route: server.route.bind(server),
+        plugins: {
+          elasticsearch: server.plugins.elasticsearch,
+        },
+        savedObjects: {
+          getSavedObjectsRepository:
+            server.savedObjects.getSavedObjectsRepository
+        },
+        usage: {
+          collectorSet: {
+            makeUsageCollector: server.usage.collectorSet.makeUsageCollector
+          }
         }
-      });
+      };
 
-      // Make usage collector
-      const TELEMETRY_TYPE = 'fileUploadTelemetry';
-      makeUsageCollector({
-        type: TELEMETRY_TYPE,
-        isReady: () => true,
-        fetch: async () =>
-          (await getTelemetry(elasticsearchPlugin, getSavedObjectsRepository)) || initTelemetry()
-      });
+      new FileUploadPlugin().setup(coreSetup, pluginsSetup, __LEGACY);
     }
   });
 };
diff --git a/x-pack/legacy/plugins/file_upload/server/plugin.js b/x-pack/legacy/plugins/file_upload/server/plugin.js
@@ -0,0 +1,37 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { getImportRouteHandler } from './routes/file_upload';
+import { getTelemetry, initTelemetry } from './telemetry/telemetry';
+import { MAX_BYTES } from '../common/constants/file_import';
+
+const TELEMETRY_TYPE = 'fileUploadTelemetry';
+
+export class FileUploadPlugin {
+  setup(core, plugins, __LEGACY) {
+    const elasticsearchPlugin = __LEGACY.plugins.elasticsearch;
+    const getSavedObjectsRepository = __LEGACY.savedObjects.getSavedObjectsRepository;
+    const makeUsageCollector = __LEGACY.usage.collectorSet.makeUsageCollector;
+
+    // Set up route
+    __LEGACY.route({
+      method: 'POST',
+      path: '/api/fileupload/import',
+      handler: getImportRouteHandler(elasticsearchPlugin, getSavedObjectsRepository),
+      config: {
+        payload: { maxBytes: MAX_BYTES },
+      }
+    });
+
+    // Make usage collector
+    makeUsageCollector({
+      type: TELEMETRY_TYPE,
+      isReady: () => true,
+      fetch: async () =>
+        (await getTelemetry(elasticsearchPlugin, getSavedObjectsRepository)) || initTelemetry()
+    });
+  }
+}