[Ingest Node Pipeline] Pipeline Processors Editor

.github/CODEOWNERS

@@ -198,6 +198,7 @@
 /x-pack/plugins/snapshot_restore/  @elastic/es-ui
 /x-pack/plugins/upgrade_assistant/  @elastic/es-ui
 /x-pack/plugins/watcher/  @elastic/es-ui
+/x-pack/plugins/ingest_pipelines/  @elastic/es-ui
 
 # Endpoint
 /x-pack/plugins/endpoint/ @elastic/endpoint-app-team

x-pack/.i18nrc.json

@@ -21,6 +21,7 @@
     "xpack.indexLifecycleMgmt": "plugins/index_lifecycle_management",
     "xpack.infra": "plugins/infra",
     "xpack.ingestManager": "plugins/ingest_manager",
+    "xpack.ingestPipelines": "plugins/ingest_pipelines",
     "xpack.lens": "legacy/plugins/lens",
     "xpack.licenseMgmt": "plugins/license_management",
     "xpack.licensing": "plugins/licensing",

x-pack/plugins/ingest_pipelines/README.md

@@ -0,0 +1,9 @@
+# ingest_pipelines
+
+> Ingest node pipelines UI
+
+---
+
+## Development
+
+See the [kibana contributing guide](https://github.com/elastic/kibana/blob/master/CONTRIBUTING.md) for instructions setting up your development environment.

x-pack/plugins/ingest_pipelines/common/constants.ts

@@ -0,0 +1,16 @@
+/*
+ * 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 { LicenseType } from '../../licensing/common/types';
+
+const basicLicense: LicenseType = 'basic';
+
+export const PLUGIN_ID = 'ingest_pipelines';
+
+export const PLUGIN_MIN_LICENSE_TYPE = basicLicense;
+
+export const BASE_PATH = '/management/elasticsearch/ingest_pipelines';
+
+export const API_BASE_PATH = '/api/ingest_pipelines';

x-pack/plugins/ingest_pipelines/common/lib/index.ts

@@ -0,0 +1,7 @@
+/*
+ * 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 { deserializePipelines } from './pipeline_serialization';

x-pack/plugins/ingest_pipelines/common/lib/pipeline_serialization.test.ts

@@ -0,0 +1,68 @@
+/*
+ * 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 { deserializePipelines } from './pipeline_serialization';
+
+describe('pipeline_serialization', () => {
+  describe('deserializePipelines()', () => {
+    it('should deserialize pipelines', () => {
+      expect(
+        deserializePipelines({
+          pipeline1: {
+            description: 'pipeline 1 description',
+            version: 1,
+            processors: [
+              {
+                script: {
+                  source: 'ctx._type = null',
+                },
+              },
+            ],
+            on_failure: [
+              {
+                set: {
+                  field: 'error.message',
+                  value: '{{ failure_message }}',
+                },
+              },
+            ],
+          },
+          pipeline2: {
+            description: 'pipeline2 description',
+            version: 1,
+            processors: [],
+          },
+        })
+      ).toEqual([
+        {
+          name: 'pipeline1',
+          description: 'pipeline 1 description',
+          version: 1,
+          processors: [
+            {
+              script: {
+                source: 'ctx._type = null',
+              },
+            },
+          ],
+          on_failure: [
+            {
+              set: {
+                field: 'error.message',
+                value: '{{ failure_message }}',
+              },
+            },
+          ],
+        },
+        {
+          name: 'pipeline2',
+          description: 'pipeline2 description',
+          version: 1,
+          processors: [],
+        },
+      ]);
+    });
+  });
+});

x-pack/plugins/ingest_pipelines/common/lib/pipeline_serialization.ts

@@ -0,0 +1,20 @@
+/*
+ * 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 { PipelinesByName, Pipeline } from '../types';
+
+export function deserializePipelines(pipelinesByName: PipelinesByName): Pipeline[] {
+  const pipelineNames: string[] = Object.keys(pipelinesByName);
+
+  const deserializedPipelines = pipelineNames.map((name: string) => {
+    return {
+      ...pipelinesByName[name],
+      name,
+    };
+  });
+
+  return deserializedPipelines;
+}

x-pack/plugins/ingest_pipelines/common/types.ts

@@ -0,0 +1,33 @@
+/*
+ * 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 interface ESCommonProcessorOptions {
+  on_failure?: Processor[];
+  ignore_failure?: boolean;
+  if?: string;
+  tag?: string;
+}
+
+export interface Processor<Extend = { [key: string]: any }> {
+  [type: string]: ESCommonProcessorOptions & Extend;
+}
+
+export interface Pipeline {
+  name: string;
+  description: string;
+  version?: number;
+  processors: Processor[];
+  on_failure?: Processor[];
+}
+
+export interface PipelinesByName {
+  [key: string]: {
+    description: string;
+    version?: number;
+    processors: Processor[];
+    on_failure?: Processor[];
+  };
+}

x-pack/plugins/ingest_pipelines/kibana.json

@@ -0,0 +1,17 @@
+{
+  "id": "ingestPipelines",
+  "version": "8.0.0",
+  "server": true,
+  "ui": true,
+  "requiredPlugins": [
+    "licensing",
+    "management"
+  ],
+  "optionalPlugins": [
+    "usageCollection"
+  ],
+  "configPath": [
+    "xpack",
+    "ingest_pipelines"
+  ]
+}

x-pack/plugins/ingest_pipelines/public/application/app.tsx

@@ -0,0 +1,26 @@
+/*
+ * 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 React from 'react';
+import { HashRouter, Switch, Route } from 'react-router-dom';
+import { BASE_PATH } from '../../common/constants';
+import { PipelinesList, PipelinesCreate, PipelinesEdit } from './sections';
+
+export const App = () => {
+  return (
+    <HashRouter>
+      <AppWithoutRouter />
+    </HashRouter>
+  );
+};
+
+export const AppWithoutRouter = () => (
+  <Switch>
+    <Route exact path={BASE_PATH} component={PipelinesList} />
+    <Route exact path={`${BASE_PATH}/create`} component={PipelinesCreate} />
+    <Route exact path={`${BASE_PATH}/edit/:name`} component={PipelinesEdit} />
+  </Switch>
+);

x-pack/plugins/ingest_pipelines/public/application/components/index.ts

@@ -0,0 +1,11 @@
+/*
+ * 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 { PipelineForm } from './pipeline_form';
+
+export { SectionError } from './section_error';
+
+export { PipelineRequestFlyoutProvider as PipelineRequestFlyout } from './pipeline_request_flyout_provider';

x-pack/plugins/ingest_pipelines/public/application/components/pipeline_form/index.ts

@@ -0,0 +1,7 @@
+/*
+ * 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 { PipelineForm } from './pipeline_form';