[Fleet] Add initial config libs and adapters

src/test_utils/kbn_server.ts

@@ -120,8 +120,11 @@ export function createRoot(settings = {}, cliArgs: Partial<CliArgs> = {}) {
  *  @param {Object} [settings={}] Any config overrides for this instance.
  *  @returns {Root}
  */
-export function createRootWithCorePlugins(settings = {}) {
-  return createRootWithSettings(defaultsDeep({}, settings, DEFAULT_SETTINGS_WITH_CORE_PLUGINS));
+export function createRootWithCorePlugins(settings = {}, cliArgs: Partial<CliArgs> = {}) {
+  return createRootWithSettings(
+    defaultsDeep({}, settings, DEFAULT_SETTINGS_WITH_CORE_PLUGINS),
+    cliArgs
+  );
 }
 
 /**

x-pack/index.js

@@ -43,6 +43,7 @@ import { encryptedSavedObjects } from './legacy/plugins/encrypted_saved_objects'
 import { snapshotRestore } from './legacy/plugins/snapshot_restore';
 import { actions } from './legacy/plugins/actions';
 import { alerting } from './legacy/plugins/alerting';
+import { ingest } from './legacy/plugins/ingest';
 import { advancedUiActions } from './legacy/plugins/advanced_ui_actions';
 import { fleet } from './legacy/plugins/fleet';
 
@@ -87,6 +88,7 @@ module.exports = function (kibana) {
     snapshotRestore(kibana),
     actions(kibana),
     alerting(kibana),
+    ingest(kibana),
     advancedUiActions(kibana),
     fleet(kibana),
   ];

x-pack/legacy/plugins/fleet/public/lib/compose/kibana.ts

@@ -12,7 +12,6 @@ import chrome from 'ui/chrome';
 // @ts-ignore not typed yet
 import { management } from 'ui/management';
 import routes from 'ui/routes';
-import { INDEX_NAMES } from '../../../common/constants/index_names';
 import { RestAgentAdapter } from '../adapters/agent/rest_agent_adapter';
 import { RestElasticsearchAdapter } from '../adapters/elasticsearch/rest';
 import { KibanaFrameworkAdapter } from '../adapters/framework/kibana_framework_adapter';
@@ -22,6 +21,7 @@ import { ElasticsearchLib } from '../elasticsearch';
 import { FrontendLibs } from '../types';
 import { PLUGIN } from '../../../common/constants/plugin';
 import { FrameworkLib } from '../framework';
+import { INDEX_NAMES } from '../../../common/constants';
 
 // A super early spot in kibana loading that we can use to hook before most other things
 const onKibanaReady = chrome.dangerouslyGetActiveInjector;

x-pack/legacy/plugins/fleet/public/lib/framework.ts

@@ -31,30 +31,6 @@ export class FrameworkLib {
     );
   }
 
-  public versionGreaterThen(version: string) {
-    const pa = this.adapter.version.split('.');
-    const pb = version.split('.');
-    for (let i = 0; i < 3; i++) {
-      const na = Number(pa[i]);
-      const nb = Number(pb[i]);
-      // version is greater
-      if (na > nb) {
-        return true;
-      }
-      // version is less then
-      if (nb > na) {
-        return false;
-      }
-      if (!isNaN(na) && isNaN(nb)) {
-        return true;
-      }
-      if (isNaN(na) && !isNaN(nb)) {
-        return false;
-      }
-    }
-    return true;
-  }
-
   public currentUserHasOneOfRoles(roles: string[]) {
     // If the user has at least one of the roles requested, the returnd difference will be less
     // then the orig array size. difference only compares based on the left side arg

x-pack/legacy/plugins/ingest/common/constants/plugin.ts

@@ -5,6 +5,6 @@
  */
 
 export const PLUGIN = {
-  ID: 'ingest-data',
+  ID: 'ingest',
 };
 export const CONFIG_PREFIX = 'xpack.ingest-do-not-disable';

x-pack/legacy/plugins/ingest/common/utils/is_version_greater.ts

@@ -0,0 +1,41 @@
+/*
+ * 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.
+ */
+
+export function isVersionGreater(v1: string, v2: string): 1 | 0 | -1 {
+  const v1parts = v1.split('.');
+  const v2parts = v2.split('.');
+
+  function isValidPart(x: string) {
+    return /^\d+$/.test(x);
+  }
+
+  if (!v1parts.every(isValidPart) || !v2parts.every(isValidPart)) {
+    throw new Error('versions are not valid');
+  }
+
+  while (v1parts.length < v2parts.length) v1parts.push('0');
+  while (v2parts.length < v1parts.length) v2parts.push('0');
+
+  for (let i = 0; i < v1parts.length; ++i) {
+    if (v2parts.length === i) {
+      return 1;
+    }
+
+    if (v1parts[i] === v2parts[i]) {
+      continue;
+    } else if (v1parts[i] > v2parts[i]) {
+      return 1;
+    } else {
+      return -1;
+    }
+  }
+
+  if (v1parts.length !== v2parts.length) {
+    return -1;
+  }
+
+  return 0;
+}

x-pack/legacy/plugins/ingest/index.ts

@@ -8,6 +8,7 @@ import { resolve } from 'path';
 import { PLUGIN } from './common/constants';
 import { CONFIG_PREFIX } from './common/constants/plugin';
 import { initServerWithKibana } from './server/kibana.index';
+import { mappings } from './server/mappings';
 
 export const config = Joi.object({
   enabled: Joi.boolean().default(true),
@@ -20,6 +21,9 @@ export function ingest(kibana: any) {
     publicDir: resolve(__dirname, 'public'),
     config: () => config,
     configPrefix: CONFIG_PREFIX,
+    uiExports: {
+      mappings,
+    },
     init(server: any) {
       initServerWithKibana(server);
     },

x-pack/legacy/plugins/ingest/server/libs/__memorize_snapshots__/configurations.contract.test.ts.snap

@@ -0,0 +1,93 @@
+
+exports['Configurations Lib create should create a new configuration - create - {"name":"test","description":"test description","output":"defaut","monitoring_enabled":true,"agent_version":"8.0.0","data_sources":[]} (2)'] = {
+  "results": {
+    "id": "8a8874b0-bd51-11e9-a21b-dbec3e1a8be1"
+  }
+}
+
+exports['Configurations Lib create should create a new configuration - create - {"name":"test","description":"test description","output":"defaut","monitoring_enabled":true,"shared_id":"994528b0-887f-4c71-923e-4ffe5dd302e2","version":0,"agent_version":"8.0.0","data_sources":[]} (2)'] = {
+  "results": {
+    "id": "715d5cb0-bd53-11e9-bb4e-fb77f27555ca",
+    "shared_id": "994528b0-887f-4c71-923e-4ffe5dd302e2",
+    "version": 0
+  }
+}
+
+exports['Configurations Lib create should create a new configuration - create - {"name":"test","description":"test description","output":"defaut","monitoring_enabled":true,"shared_id":"997e6674-d072-475b-89d3-9b9202e0dd99","version":0,"agent_version":"8.0.0","data_sources":[]} (2)'] = {
+  "results": {
+    "id": "9cd167f0-c065-11e9-9b54-89c2396bf183",
+    "shared_id": "997e6674-d072-475b-89d3-9b9202e0dd99",
+    "version": 0
+  }
+}
+
+exports['Configurations Lib create should create a new configuration - create - {"name":"test","description":"test description","output":"defaut","monitoring_enabled":true,"version":0,"agent_version":"8.0.0","data_sources":[],"shared_id":"string"} (2)'] = {
+  "results": {
+    "id": "385d2130-c068-11e9-a90f-d9a51a8c04f8",
+    "shared_id": "de5a13b9-4b80-4983-8e6a-1619e3f97b9a",
+    "version": 0
+  }
+}
+
+exports['Configurations Lib create should create a new configuration - get info (1)'] = {
+  "results": {
+    "kibana": {
+      "version": "8.0.0"
+    },
+    "license": {
+      "type": "trial",
+      "expired": false,
+      "expiry_date_in_millis": 1568580919209
+    },
+    "security": {
+      "enabled": true,
+      "available": true
+    },
+    "watcher": {
+      "enabled": true,
+      "available": true
+    }
+  }
+}
+
+exports['Configurations Lib create should create a new configuration - get info (2)'] = {
+  "results": {
+    "kibana": {
+      "version": "8.0.0"
+    },
+    "license": {
+      "type": "trial",
+      "expired": false,
+      "expiry_date_in_millis": 1568240322629
+    },
+    "security": {
+      "enabled": true,
+      "available": true
+    },
+    "watcher": {
+      "enabled": true,
+      "available": true
+    }
+  }
+}
+
+exports['Configurations Lib create should create a new configuration - get info (3)'] = {
+  "results": {
+    "kibana": {
+      "version": "8.0.0"
+    },
+    "license": {
+      "type": "trial",
+      "expired": false,
+      "expiry_date_in_millis": 1568240322629
+    },
+    "security": {
+      "enabled": true,
+      "available": true
+    },
+    "watcher": {
+      "enabled": true,
+      "available": true
+    }
+  }
+}

x-pack/legacy/plugins/ingest/server/libs/adapters/configurations/adapter_types.ts

@@ -10,7 +10,7 @@ export const RuntimeDatasourceInput = t.interface(
   {
     id: t.string,
     meta: t.union([t.undefined, t.string]),
-    config: t.string,
+    config_id: t.string,
   },
   'DatasourceInput'
 );
@@ -29,6 +29,8 @@ export const NewRuntimeConfigurationFile = t.interface(
     description: t.string,
     output: t.string,
     monitoring_enabled: t.boolean,
+    shared_id: t.string,
+    version: t.number,
     agent_version: t.string,
     data_sources: t.array(DataSource),
   },
@@ -51,7 +53,7 @@ const ExistingDocument = t.interface({
   id: t.string,
   shared_id: t.string,
   version: t.number,
-  active: t.boolean,
+  status: t.union(['active', 'locked', 'inactive'].map(s => t.literal(s))),
   updated_at: t.string,
   created_by: t.union([t.undefined, t.string]),
   updated_on: t.string,