edits in testUtils.js

rudderlabs · Feb 23, 2022 · ed03148 · ed03148
1 parent 5644203
commit ed03148
Show file tree

Hide file tree

Showing 2 changed files with 54 additions and 48 deletions.
diff --git a/__tests__/appsFlyer.test.js b/__tests__/appsFlyer.test.js
@@ -1,49 +1,55 @@
-const integration = "af";
-const name = "AppsFlyer";
-const fs = require("fs");
-const path = require("path");
-const version = "v0";
-
-const transformer = require(`../${version}/destinations/${integration}/transform`);
-const inputDataFile = fs.readFileSync(
-  path.resolve(__dirname, `./data/${integration}_input.json`)
-);
-const outputDataFile = fs.readFileSync(
-  path.resolve(__dirname, `./data/${integration}_output.json`)
-);
-const inputData = JSON.parse(inputDataFile);
-const expectedData = JSON.parse(outputDataFile);
-
-// Router Test Data
-const inputRouterDataFile = fs.readFileSync(
-  path.resolve(__dirname, `./data/${integration}_router_input.json`)
-);
-const outputRouterDataFile = fs.readFileSync(
-  path.resolve(__dirname, `./data/${integration}_router_output.json`)
-);
-const inputRouterData = JSON.parse(inputRouterDataFile);
-const expectedRouterData = JSON.parse(outputRouterDataFile);
-
-inputData.forEach((input, index) => {
-  test(`${name} Tests - Payload ${index}`, () => {
-    try {
-      // ignored
-      const output = transformer.process(input);
-      expect(output).toEqual(expectedData[index]);
-    } catch (error) {
-      expect(error.message).toEqual(expectedData[index].error);
-    }
-  });
+// const integration = "af";
+// const name = "AppsFlyer";
+// const fs = require("fs");
+// const path = require("path");
+// const version = "v0";
+
+// const transformer = require(`../${version}/destinations/${integration}/transform`);
+// const inputDataFile = fs.readFileSync(
+//   path.resolve(__dirname, `./data/${integration}_input.json`)
+// );
+// const outputDataFile = fs.readFileSync(
+//   path.resolve(__dirname, `./data/${integration}_output.json`)
+// );
+// const inputData = JSON.parse(inputDataFile);
+// const expectedData = JSON.parse(outputDataFile);
+
+// // Router Test Data
+// const inputRouterDataFile = fs.readFileSync(
+//   path.resolve(__dirname, `./data/${integration}_router_input.json`)
+// );
+// const outputRouterDataFile = fs.readFileSync(
+//   path.resolve(__dirname, `./data/${integration}_router_output.json`)
+// );
+// const inputRouterData = JSON.parse(inputRouterDataFile);
+// const expectedRouterData = JSON.parse(outputRouterDataFile);
+
+// inputData.forEach((input, index) => {
+//   test(`${name} Tests - Payload ${index}`, () => {
+//     try {
+//       // ignored
+//       const output = transformer.process(input);
+//       expect(output).toEqual(expectedData[index]);
+//     } catch (error) {
+//       expect(error.message).toEqual(expectedData[index].error);
+//     }
+//   });
 
-});
+// });
+
+// describe(`${name} Tests`, () => {
+
+// describe("Router Tests", () => {
+//   it("Payload", async () => {
+//     const routerOutput = await transformer.processRouterDest(inputRouterData);
+//     expect(routerOutput).toEqual(expectedRouterData);
+//   });
+// });
+
+// });
 
-describe(`${name} Tests`, () => {
+const { getDestFromTestFile, executeTransformationTest } = require("./utilities/test-utils");
 
-describe("Router Tests", () => {
-  it("Payload", async () => {
-    const routerOutput = await transformer.processRouterDest(inputRouterData);
-    expect(routerOutput).toEqual(expectedRouterData);
-  });
-});
+executeTransformationTest('af','processor')
+executeTransformationTest('af','router')
 
-});
diff --git a/__tests__/utilities/test-utils.js b/__tests__/utilities/test-utils.js
@@ -22,11 +22,11 @@ function formTestParams(dest, transformAt) {
   );
   const inputData = JSON.parse(inputDataFile);
   const expected = JSON.parse(outputDataFile);
-	const cdkDest = ['variance', 'autopilot', 'statsig'].filter(({ name }) => name === dest)[0];
+	const cdkDest = ['variance', 'autopilot', 'statsig'].filter((name) => name === dest)[0];
 	return {
 		input: inputData,
 		expected,
-		iscdkDest: _.isEmpty(cdkDest)
+		iscdkDest: !_.isEmpty(cdkDest)
 	};
 }
 
@@ -45,7 +45,7 @@ function executeTransformationTest(dest, transformAt) {
           if(iscdkDest && transformAt === 'processor') {
             // We currently support processor transformation only in CDK
             actualData = await RudderCDK.Executor.executeStages(
-              inp,
+                tcInput,
               factory.getConfig(dest)
             )
           } else {