add tests for deserialization

elastic · Aug 21, 2020 · a86dd6f · a86dd6f
1 parent 7cc7faa
commit a86dd6f
Showing 1 changed file with 120 additions and 48 deletions.
diff --git a/...st_pipelines/public/application/components/pipeline_processors_editor/deserialize.test.ts b/...st_pipelines/public/application/components/pipeline_processors_editor/deserialize.test.ts
@@ -4,71 +4,143 @@
  * you may not use this file except in compliance with the Elastic License.
  */
 
-import { deserialize } from './deserialize';
+import { deserialize, deserializeVerboseTestOutput } from './deserialize';
 
-describe('deserialize', () => {
-  it('tolerates certain bad values correctly', () => {
-    expect(
-      deserialize({
+describe('Deserialization', () => {
+  describe('deserialize()', () => {
+    it('tolerates certain bad values correctly', () => {
+      expect(
+        deserialize({
+          processors: [
+            { set: { field: 'test', value: 123 } },
+            { badType1: null } as any,
+            { badType2: 1 } as any,
+          ],
+          onFailure: [
+            {
+              gsub: {
+                field: '_index',
+                pattern: '(.monitoring-\\w+-)6(-.+)',
+                replacement: '$17$2',
+              },
+            },
+          ],
+        })
+      ).toEqual({
         processors: [
-          { set: { field: 'test', value: 123 } },
-          { badType1: null } as any,
-          { badType2: 1 } as any,
+          {
+            id: expect.any(String),
+            type: 'set',
+            options: {
+              field: 'test',
+              value: 123,
+            },
+          },
+          {
+            id: expect.any(String),
+            onFailure: undefined,
+            type: 'badType1',
+            options: {},
+          },
+          {
+            id: expect.any(String),
+            onFailure: undefined,
+            type: 'badType2',
+            options: {},
+          },
         ],
         onFailure: [
           {
-            gsub: {
+            id: expect.any(String),
+            type: 'gsub',
+            onFailure: undefined,
+            options: {
               field: '_index',
               pattern: '(.monitoring-\\w+-)6(-.+)',
               replacement: '$17$2',
             },
           },
         ],
-      })
-    ).toEqual({
-      processors: [
+      });
+    });
+
+    it('throws for unacceptable values', () => {
+      expect(() => {
+        deserialize({
+          processors: [{ reallyBad: undefined } as any, 1 as any],
+          onFailure: [],
+        });
+      }).toThrow('Invalid processor type');
+    });
+  });
+
+  describe('deserializeVerboseOutput()', () => {
+    it('deserializes the verbose output of a simulated pipeline', () => {
+      expect(
+        deserializeVerboseTestOutput({
+          docs: [
+            {
+              processor_results: [
+                {
+                  doc: {
+                    _id: 'id1',
+                    _source: {
+                      name: 'foo',
+                      foo: 'bar',
+                    },
+                  },
+                  processor_type: 'set',
+                  status: 'success',
+                  tag: 'e457615c-69c9-4d14-9e85-c477ad96e60f',
+                },
+              ],
+            },
+            {
+              processor_results: [
+                {
+                  doc: {
+                    _id: 'id2',
+                    _source: {
+                      name: 'baz',
+                      foo: 'bar',
+                    },
+                  },
+                  processor_type: 'set',
+                  status: 'success',
+                  tag: 'e457615c-69c9-4d14-9e85-c477ad96e60f',
+                },
+              ],
+            },
+          ],
+        })
+      ).toEqual([
         {
-          id: expect.any(String),
-          type: 'set',
-          options: {
-            field: 'test',
-            value: 123,
+          'e457615c-69c9-4d14-9e85-c477ad96e60f': {
+            doc: {
+              _id: 'id1',
+              _source: {
+                name: 'foo',
+                foo: 'bar',
+              },
+            },
+            processor_type: 'set',
+            status: 'success',
           },
         },
         {
-          id: expect.any(String),
-          onFailure: undefined,
-          type: 'badType1',
-          options: {},
-        },
-        {
-          id: expect.any(String),
-          onFailure: undefined,
-          type: 'badType2',
-          options: {},
-        },
-      ],
-      onFailure: [
-        {
-          id: expect.any(String),
-          type: 'gsub',
-          onFailure: undefined,
-          options: {
-            field: '_index',
-            pattern: '(.monitoring-\\w+-)6(-.+)',
-            replacement: '$17$2',
+          'e457615c-69c9-4d14-9e85-c477ad96e60f': {
+            doc: {
+              _id: 'id2',
+              _source: {
+                name: 'baz',
+                foo: 'bar',
+              },
+            },
+            processor_type: 'set',
+            status: 'success',
           },
         },
-      ],
+      ]);
     });
   });
-
-  it('throws for unacceptable values', () => {
-    expect(() => {
-      deserialize({
-        processors: [{ reallyBad: undefined } as any, 1 as any],
-        onFailure: [],
-      });
-    }).toThrow('Invalid processor type');
-  });
 });