Fix simulate util fn; handle form_to_pipeline_utils updates

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

Author: ohltyler

public/pages/workflow_detail/workflow_inputs/processor_inputs/ml_processor_inputs/modals/configure_expression_modal.tsx

@@ -466,9 +466,13 @@ export function ConfigureExpressionModal(props: ConfigureExpressionModalProps) {
                                       });
                                   } else {
                                     try {
-                                      const docObjs = JSON.parse(
-                                        values.ingest.docs
-                                      ) as {}[];
+                                      const docObjs = [] as {}[];
+                                      const lines = values?.ingest?.docs?.split(
+                                        '\n'
+                                      ) as string[];
+                                      lines.forEach((line) =>
+                                        docObjs?.push(JSON.parse(line))
+                                      );
                                       if (docObjs.length > 0) {
                                         setSourceInput(
                                           customStringify(docObjs[0])

public/utils/form_to_pipeline_utils.ts

@@ -44,7 +44,8 @@ export function formikToPartialPipeline(
         return !isEmpty(precedingProcessors)
           ? ({
               processors: processorConfigsToTemplateProcessors(
-                precedingProcessors
+                precedingProcessors,
+                context
               ),
             } as IngestPipelineConfig)
           : undefined;
@@ -60,7 +61,8 @@ export function formikToPartialPipeline(
         return !isEmpty(precedingProcessors)
           ? ({
               request_processors: processorConfigsToTemplateProcessors(
-                precedingProcessors
+                precedingProcessors,
+                context
               ),
             } as SearchPipelineConfig)
           : undefined;
@@ -78,10 +80,12 @@ export function formikToPartialPipeline(
         return !isEmpty(precedingProcessors) || !isEmpty(requestProcessors)
           ? ({
               request_processors: processorConfigsToTemplateProcessors(
-                requestProcessors
+                requestProcessors,
+                context
               ),
               response_processors: processorConfigsToTemplateProcessors(
-                precedingProcessors
+                precedingProcessors,
+                context
               ),
             } as SearchPipelineConfig)
           : undefined;

public/utils/utils.tsx

@@ -175,17 +175,18 @@ export function prepareDocsForSimulate(
   const preparedDocs = [] as SimulateIngestPipelineDoc[];
   let docObjs = [] as {}[];
   try {
-    docObjs = JSON.parse(docs) as {}[];
     const lines = docs?.split('\n') as string[];
     lines.forEach((line) => docObjs.push(JSON.parse(line)));
   } catch {}
-  docObjs.forEach((doc) => {
+  docObjs?.forEach((doc) => {
     preparedDocs.push({
       _index: indexName,
       _id: generateId(),
       _source: doc,
     });
   });
+  console.log('docobs: ', docObjs);
+  console.log('prepared docs: ', preparedDocs);
   return preparedDocs;
 }