@befaas/lib - npm Package Compare versions

Comparing version 8.7.2 to 8.8.0

.generated-go-semantic-release-changelog.md

@@ -1,6 +0,10 @@
-## 8.7.2 (2022-04-25)
+## 8.8.0 (2022-04-25)
 
+#### Feature
+
+* call publisher endpoint(s) (42b6add3)
+
 #### Bug Fixes
 
-* just .Value (3ff352cc)
+* var functionName (785d7c89)
 

call.js

@@ -17,16 +17,47 @@ const _ = require('lodash')
 
+const publisherEndpoints = {
+  aws: process.env.PUBLISHER_AWS_ENDPOINT
+}
+
 module.exports = async (fn, contextId, xPair, payload) => {
+
+  console.log("fn is: " + fn)
   if (!_.isObject(payload)) throw new Error('payload is not an object')
-  const provider = _.get(experiment, `program.functions.${fn}.provider`)
-  if (!endpoints[provider]) throw new Error('unknown provider')
-  const res = await fetch(`${endpoints[provider]}/${fn}/call`, {
-    method: 'post',
-    body: JSON.stringify(payload || {}),
-    headers: {
-      'Content-Type': 'application/json',
-      'X-Context': contextId,
-      'X-Pair': xPair
-    }
-  })
-  return res.json()
+  
+  var provider = ""
+  if (fn === "publisher") {
+    console.log("Will call publisher...")
+    var functionName = payload.fun
+    provider = _.get(experiment, `program.functions.${functionName}.provider`)
+    console.log("provider is " + provider)
+	if (!publisherEndpoints[provider]) throw new Error('unknown publisher provider')
+  } else {
+    provider = _.get(experiment, `program.functions.${fn}.provider`)
+    console.log("provider is " + provider)
+    if (!endpoints[provider]) throw new Error('unknown provider')
+  } 
+  
+  if (fn === "publisher") {
+    const res = await fetch(`${publisherEndpoints[provider]}/call`, {
+      method: 'post',
+      body: JSON.stringify(payload || {}),
+      headers: {
+        'Content-Type': 'application/json',
+        'X-Context': contextId,
+        'X-Pair': xPair
+      }
+    })
+    return res.json()
+  } else {	  
+    const res = await fetch(`${endpoints[provider]}/${fn}/call`, {
+      method: 'post',
+      body: JSON.stringify(payload || {}),
+      headers: {
+        'Content-Type': 'application/json',
+        'X-Context': contextId,
+        'X-Pair': xPair
+      }
+    })
+    return res.json()
+  }
 }

package.json

@@ -50,3 +50,3 @@ {
   },
-  "version": "8.7.2"
+  "version": "8.8.0"
 }

New alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

55110751

Lines of code

452

increased by6.35%

Worsened metrics

Number of low supply chain risk alerts

25

increased by4.17%

Number of medium supply chain risk alerts

6

increased by20%

No dependency changes