chore: rt_batch_tests

rudderlabs · Jan 9, 2024 · 579785b · 579785b
1 parent 7e5f44e
commit 579785b
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 2 deletions.
diff --git a/test/__tests__/mailmodo.test.js b/test/__tests__/mailmodo.test.js
@@ -44,7 +44,7 @@ describe(`${name} Tests`, () => {
         const routerOutput = await transformer.processRouterDest(
           inputRouterData
         );
-        //assertRouterOutput(routerOutput, inputRouterData);
+        //assertRouterOutput(routerOutput, inputRouterData); //TODO fix
         expect(routerOutput).toEqual(expectedRouterData);
       } catch (error) {
         expect(error.message).toEqual(expectedRouterData.error);

diff --git a/test/__tests__/utilities/test-utils.js b/test/__tests__/utilities/test-utils.js
@@ -2,6 +2,7 @@ const fs = require("fs");
 const _ = require("lodash");
 const path = require("path");
 const { ConfigFactory, Executor } = require("rudder-transformer-cdk");
+const { assertRouterOutput } = require('../../testHelper');
 
 // TODO: separate this out later as the list grows
 const cdkEnabledDestinations = {
@@ -95,7 +96,9 @@ function executeTransformationTest(dest, transformAt) {
             if (transformAt == "processor") {
               actualData = await transformer.process(tcInput);
             } else {
-              actualData = (await transformer.processRouterDest([tcInput]))[0];
+              actual = await transformer.processRouterDest([tcInput])
+              assertRouterOutput(actual, [tcInput]);
+              actualData = (d)[0];
             }
           }
           // Compare actual and expected data
@@ -115,6 +118,7 @@ function executeTransformationTest(dest, transformAt) {
           const version = "v0";
           const transformer = require(`../../../src/${version}/destinations/${dest}/transform`);
           actualData = await transformer.processRouterDest(commonInput);
+          assertRouterOutput(actualData, commonInput);
           const cloneActual = _.cloneDeep(actualData);
           cloneActual[0].statTags = "undefined";
           // Compare actual and expected data

diff --git a/test/testHelper.js b/test/testHelper.js
@@ -20,6 +20,10 @@ const setResponsesForMockAxiosAdapter = ({url, method, data, options}, {response
 }
 
 const assertRouterOutput = (output, input) => {
+  if (!input.metadata) {
+    return;
+  }
+
   const returnedJobids = {};
   output.forEach((outEvent) => {
     //Assert that metadata is present and is an array