chore: added credentials to javascript transformations

src/types/index.ts

@@ -137,12 +137,19 @@ type UserTransformationLibrary = {
   VersionID: string;
 };
 
+type Credential = {
+  Key: string;
+  Value: string;
+  isPublic: boolean;
+};
+
 type ProcessorTransformationRequest = {
   request?: object;
   message: object;
   metadata: Metadata;
   destination: Destination;
   libraries?: UserTransformationLibrary[];
+  credentials?: Credential[];
 };
 
 type RouterTransformationRequestData = {

src/util/customTransformer-v1.js

@@ -51,6 +51,7 @@ function calculateMsFromIvmTime(value) {
 async function userTransformHandlerV1(
   events,
   userTransformation,
+  credentials,
   libraryVersionIds,
   testMode = false,
 ) {
@@ -62,6 +63,7 @@ async function userTransformHandlerV1(
     userTransformation.code,
     libraryVersionIds,
     userTransformation.versionId,
+    credentials,
     userTransformation.secrets || {},
     testMode,
   );

src/util/customTransformer.js

@@ -285,12 +285,14 @@ async function userTransformHandler(
       events.forEach((ev) => {
         eventsMetadata[ev.message.messageId] = ev.metadata;
       });
+      const credentials = events[0].credentials;
 
       let userTransformedEvents = [];
       let result;
       if (res.codeVersion && res.codeVersion === '1') {
         result = await UserTransformHandlerFactory(res).runUserTransfrom(
           events,
+          credentials,
           testMode,
           libraryVersionIDs,
         );

src/util/customTransformerFactory.js

@@ -13,14 +13,20 @@ const UserTransformHandlerFactory = (userTransformation) => {
       }
     },
 
-    runUserTransfrom: async (events, testMode, libraryVersionIds) => {
+    runUserTransfrom: async (events, credentials, testMode, libraryVersionIds) => {
       switch (userTransformation.language) {
         case 'pythonfaas':
         case 'python':
           return runOpenFaasUserTransform(events, userTransformation, libraryVersionIds, testMode);
 
         default:
-          return userTransformHandlerV1(events, userTransformation, libraryVersionIds, testMode);
+          return userTransformHandlerV1(
+            events,
+            userTransformation,
+            credentials,
+            libraryVersionIds,
+            testMode,
+          );
       }
     },
   };

src/util/ivmFactory.js

@@ -30,7 +30,7 @@
   return module;
 }
 
-async function createIvm(code, libraryVersionIds, versionId, secrets, testMode) {
+async function createIvm(code, libraryVersionIds, versionId, credentials, secrets, testMode) {
   const createIvmStartTime = new Date();
   const logs = [];
   const libraries = await Promise.all(
@@ -243,6 +243,11 @@
     }),
   );
 
+  await jail.set('_credentials', function (...args) {
+    if (args.length == 0 || !credentials || !credentials[args[0]]) return 'ERROR';
+    return credentials[args[0]];
+  });
+
   await jail.set('_rsSecrets', function (...args) {
     if (args.length == 0 || !secrets || !secrets[args[0]]) return 'ERROR';
     return secrets[args[0]];
@@ -321,6 +326,14 @@
         ]);
       };
 
+      let credentials = _credentials;
+      delete _credentials;
+      global.credentials = function(...args) {
+        return credentials([
+          ...args.map(arg => new ivm.ExternalCopy(arg).copyInto())
+        ]);
+      };
+
       return new ivm.Reference(function forwardMainPromise(
         fnRef,
         resolve,
@@ -411,10 +424,10 @@
   return evaluateModule(isolate, context, code);
 }
 
-async function getFactory(code, libraryVersionIds, versionId, secrets, testMode) {
+async function getFactory(code, libraryVersionIds, versionId, credentials, secrets, testMode) {
   const factory = {
     create: async () => {
-      return createIvm(code, libraryVersionIds, versionId, secrets, testMode);
+      return createIvm(code, libraryVersionIds, versionId, credentials, secrets, testMode);
     },
     destroy: async (client) => {
       client.fnRef.release();