Onboard copy ingest processor (opensearch-project#561)

Signed-off-by: Tyler Ohlsen <ohltyler@amazon.com>

Author: ohltyler

common/constants.ts

@@ -186,6 +186,7 @@ export enum PROCESSOR_TYPE {
   RERANK = 'rerank',
   TEXT_EMBEDDING = 'text_embedding',
   TEXT_IMAGE_EMBEDDING = 'text_image_embedding',
+  COPY = 'copy',
 }
 
 export enum MODEL_TYPE {

public/configs/ingest_processors/copy_ingest_processor.ts

@@ -0,0 +1,60 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+import { PROCESSOR_TYPE } from '../../../common';
+import { generateId } from '../../utils';
+import { Processor } from '../processor';
+
+/**
+ * The copy ingest processor
+ */
+export class CopyIngestProcessor extends Processor {
+  constructor() {
+    super();
+    this.name = 'Copy Processor';
+    this.type = PROCESSOR_TYPE.COPY;
+    this.id = generateId('copy_processor_ingest');
+    this.fields = [
+      {
+        id: 'source_field',
+        type: 'string',
+      },
+      {
+        id: 'target_field',
+        type: 'string',
+      },
+    ];
+    this.optionalFields = [
+      {
+        id: 'ignore_missing',
+        type: 'boolean',
+        value: false,
+      },
+      {
+        id: 'override_target',
+        type: 'boolean',
+        value: false,
+      },
+      {
+        id: 'remove_source',
+        type: 'boolean',
+        value: false,
+      },
+      {
+        id: 'ignore_failure',
+        type: 'boolean',
+        value: false,
+      },
+      {
+        id: 'description',
+        type: 'string',
+      },
+      {
+        id: 'tag',
+        type: 'string',
+      },
+    ];
+  }
+}

public/configs/ingest_processors/index.ts

@@ -9,3 +9,4 @@ export * from './sort_ingest_processor';
 export * from './text_chunking_ingest_processor';
 export * from './text_embedding_ingest_processor';
 export * from './text_image_embedding_ingest_processor';
+export * from './copy_ingest_processor';

public/pages/workflow_detail/workflow_inputs/processors_list.tsx

@@ -29,6 +29,7 @@ import { formikToUiConfig, getDataSourceFromURL } from '../../../utils';
 
 import {
   CollapseProcessor,
+  CopyIngestProcessor,
   MLIngestProcessor,
   MLSearchRequestProcessor,
   MLSearchResponseProcessor,
@@ -164,6 +165,13 @@ export function ProcessorsList(props: ProcessorsListProps) {
           addProcessor(new TextChunkingIngestProcessor().toObj());
         },
       },
+      {
+        name: 'Copy Processor',
+        onClick: () => {
+          closePopover();
+          addProcessor(new CopyIngestProcessor().toObj());
+        },
+      },
     ];
 
     const searchRequestProcessors = [

public/utils/config_to_workspace_utils.ts

@@ -355,6 +355,14 @@ function processorsConfigToWorkspaceFlow(
         );
         break;
       }
+      case PROCESSOR_TYPE.COPY: {
+        transformer = new BaseTransformer(
+          processorConfig.name,
+          'Copy an entire object in an existing field to another field',
+          context
+        );
+        break;
+      }
       case PROCESSOR_TYPE.NORMALIZATION: {
         componentData = new BaseTransformer(
           processorConfig.name,