fix: excludeMappedFields utility

package.json

@@ -65,7 +65,7 @@
     "@ndhoule/extend": "^2.0.0",
     "@pyroscope/nodejs": "^0.2.9",
     "@rudderstack/integrations-lib": "^0.2.10",
-    "@rudderstack/json-template-engine": "^0.17.1",
+    "@rudderstack/json-template-engine": "^0.18.0",
     "@rudderstack/workflow-engine": "^0.8.13",
     "@shopify/jest-koa-mocks": "^5.1.1",
     "ajv": "^8.12.0",

src/cdk/v2/destinations/webhook_v2/rtWorkflow.yaml

@@ -22,7 +22,7 @@ steps:
         "batchedRequest": .,
         "batched": false,
         "destination": ^[idx].destination,
-        "metadata": ^[idx].metadata,
+        "metadata": ^[idx].metadata[],
         "statusCode": 200
       })[]
 

src/cdk/v2/destinations/webhook_v2/utils.js

@@ -42,7 +42,10 @@ const addPathParams = (message, webhookUrl) => webhookUrl;
 const excludeMappedFields = (payload, mapping) => {
   const rawPayload = { ...payload };
   if (mapping) {
-    mapping.forEach(({ from }) => {
+    mapping.forEach(({ from, to }) => {
+      // continue when from === to
+      if (from === to) return;
+
       // Remove the '$.' prefix and split the remaining string by '.'
       const keys = from.replace(/^\$\./, '').split('.');
       let current = rawPayload;
@@ -78,7 +81,7 @@ const getMergedEvents = (batch) => {
   return events;
 };
 
-const mergeMetadata = (batch) => batch.map((event) => event.metadata);
+const mergeMetadata = (batch) => batch.map((event) => event.metadata[0]);
 
 const createHashKey = (endpoint, headers, params) => {
   const hash = createHash('md5');