feat: integrate cdk v2

cdk/v2/utils.js

@@ -1,5 +1,11 @@
 const path = require("path");
 const fs = require("fs");
+const {
+  WorkflowExecutionError
+} = require("rudder-workflow-engine/build/errors");
+const { logger } = require("handlebars");
+const { WorkflowEngineError } = require("rudder-workflow-engine/build/errors");
+const { TRANSFORMER_METRIC } = require("../../v0/util/constant");
 
 const CDK_V2_ROOT_DIR = __dirname;
 
@@ -37,8 +43,39 @@ function getPlatformBindingsPaths() {
   return bindingsPaths;
 }
 
+function getErrorInfo(err) {
+  // Handle various CDK error types
+  let errorInfo = err;
+  if (err instanceof WorkflowExecutionError) {
+    logger.error(
+      "Error occurred during workflow step execution: ",
+      err.stepName
+    );
+    errorInfo = {
+      message: err.message,
+      status: err.status,
+      destinationResponse: err.error.destinationResponse,
+      statTags: err.error.statTags,
+      authErrorCategory: err.error.authErrorCategory
+    };
+    // TODO: Add a special stat tag to bump the priority of the error
+  } else if (err instanceof WorkflowEngineError) {
+    logger.error("Error occurred during workflow step: ", err.stepName);
+    errorInfo = {
+      message: err.message,
+      status: err.status,
+      statTags: {
+        stage: TRANSFORMER_METRIC.TRANSFORMER_STAGE.TRANSFORM,
+        scope: TRANSFORMER_METRIC.MEASUREMENT_TYPE.CDK.SCOPE
+      }
+    };
+  }
+  return errorInfo;
+}
+
 module.exports = {
   getRootPathForDestination,
   getWorkflowPath,
-  getPlatformBindingsPaths
+  getPlatformBindingsPaths,
+  getErrorInfo
 };

versionedRouter.js

@@ -6,10 +6,6 @@ const fs = require("fs");
 const path = require("path");
 const { ConfigFactory, Executor } = require("rudder-transformer-cdk");
 const set = require("set-value");
-const {
-  WorkflowExecutionError,
-  WorkflowEngineError
-} = require("rudder-workflow-engine/build/errors");
 const logger = require("./logger");
 const stats = require("./util/stats");
 const { SUPPORTED_VERSIONS, API_VERSION } = require("./routes/utils/constants");
@@ -39,6 +35,7 @@ const { compileUserLibrary } = require("./util/ivmFactory");
 const { getIntegrations } = require("./routes/utils");
 const { RespStatusError, RetryRequestError } = require("./util/utils");
 const { getWorkflowEngine } = require("./cdk/v2/handler");
+const { getErrorInfo } = require("./cdk/v2/utils");
 
 const CDK_DEST_PATH = "cdk";
 const basePath = path.resolve(__dirname, `./${CDK_DEST_PATH}`);
@@ -104,32 +101,7 @@ async function handleCdkV2(destName, parsedEvent) {
     // TODO: Handle remaining output scenarios
     return result.output;
   } catch (err) {
-    // Handle various CDK error types
-    let errorInfo = err;
-    if (err instanceof WorkflowExecutionError) {
-      logger.error(
-        "Error occurred during workflow step execution: ",
-        err.stepName
-      );
-      errorInfo = {
-        message: err.message,
-        status: err.status,
-        destinationResponse: err.error.destinationResponse,
-        statTags: err.error.statTags,
-        authErrorCategory: err.error.authErrorCategory
-      };
-      // TODO: Add a special stat tag to bump the priority of the error
-    } else if (err instanceof WorkflowEngineError) {
-      logger.error("Error occurred during workflow step: ", err.stepName);
-      errorInfo = {
-        message: err.message,
-        status: err.status,
-        statTags: {
-          stage: TRANSFORMER_METRIC.TRANSFORMER_STAGE.TRANSFORM,
-          scope: TRANSFORMER_METRIC.MEASUREMENT_TYPE.CDK.SCOPE
-        }
-      };
-    }
+    const errorInfo = getErrorInfo(err);
 
     // TODO: Bump the error priority even further as it's an unhandled error in the CDK
     const errObj = generateErrorObject(