Added a function to put additional parameters into body if schema con…

…tains them
openintegrationhub · Dec 12, 2024 · fe46950 · fe46950
1 parent 83d835a
commit fe46950
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 2 deletions.
diff --git a/templates/lib/actions/action.js b/templates/lib/actions/action.js
@@ -12,7 +12,7 @@
  */
 
 const spec = require("../spec.json");
-const { mapFieldNames, getMetadata, mapFormDataBody, executeCall } = require("../utils/helpers");
+const { mapFieldNames, getMetadata, mapFormDataBody, putAdditionalParamsInBody, executeCall } = require("../utils/helpers");
 const componentJson = require("../../component.json");
 
 async function processAction(msg, cfg, snapshot, incomingMessageHeaders, tokenData) {
@@ -53,6 +53,11 @@ async function processAction(msg, cfg, snapshot, incomingMessageHeaders, tokenDa
     specPathParameters.push(...specPathGeneralParams);
 
     let body = msg.data;
+
+    if (cfg && cfg.additionalParameters) {
+      body = putAdditionalParamsInBody(this, action, body, cfg.additionalParameters)
+    }
+
     mapFieldNames(body);
     if (requestContentType === "multipart/form-data") {
       logger.info("requestContentType multipart/form-data is defined");

diff --git a/templates/lib/utils/helpers.js b/templates/lib/utils/helpers.js
@@ -142,6 +142,19 @@ const mapFormDataBody = async function (action, body) {
   return body;
 };
 
+const putAdditionalParamsInBody = async function (action, body, additionalParameters) {
+  const newBody = body;
+  const inputMetadataSchema = getInputMetadataSchema(action.metadata.in);
+
+  for (let property in additionalParameters) {
+    if (property in inputMetadataSchema && !(property in body)) {
+      body[property] = additionalParameters[property];
+    }
+  }
+
+  return newBody;
+};
+
 function compareDate(a, b) {
   return dayjs(a).isAfter(b);
 }
@@ -289,5 +302,7 @@ module.exports = {
   mapFormDataBody,
   isMicrosoftJsonDate,
   executeCall,
-  getInitialSnapshotValue
+  getInitialSnapshotValue,
+  getInputMetadataSchema,
+  putAdditionalParamsInBody
 };