@befaas/lib
Advanced tools
Comparing version 8.19.0 to 8.20.0
@@ -1,12 +0,10 @@ | ||
## 8.19.0 (2022-05-19) | ||
## 8.20.0 (2022-05-19) | ||
#### Feature | ||
* change azureHandler (azure-function-express does only support http trigger) (1a0c77cd) | ||
* clean up debugging output (aa95f1fb) | ||
#### Bug Fixes | ||
* typo (6cef6330) | ||
* typo (025693ca) | ||
* handler definition, forward payload to app function only (019a3fa8) | ||
* comment typos (2a6b2014) | ||
@@ -26,3 +26,2 @@ const _ = require('lodash') | ||
console.log("fn is: " + fn) | ||
if (!_.isObject(payload)) throw new Error('payload is not an object') | ||
@@ -32,10 +31,10 @@ | ||
if (fn === "publisher") { | ||
console.log("Will call publisher...") | ||
// console.log("Will call publisher...") | ||
var functionName = payload.fun | ||
provider = _.get(experiment, `program.functions.${functionName}.provider`) | ||
console.log("provider is " + 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) | ||
// console.log("provider is " + provider) | ||
if (!endpoints[provider]) throw new Error('unknown provider') | ||
@@ -42,0 +41,0 @@ } |
@@ -50,3 +50,3 @@ { | ||
}, | ||
"version": "8.19.0" | ||
"version": "8.20.0" | ||
} |
@@ -58,18 +58,2 @@ const _ = require('lodash') | ||
JSON.safeStringify = (obj, indent = 2) => { | ||
let cache = []; | ||
const retVal = JSON.stringify( | ||
obj, | ||
(key, value) => | ||
typeof value === "object" && value !== null | ||
? cache.includes(value) | ||
? undefined // Duplicate reference found, discard key | ||
: cache.push(value) && value // Store value in our collection | ||
: value, | ||
indent | ||
); | ||
cache = null; | ||
return retVal; | ||
}; | ||
async function handleErrors (ctx, next) { | ||
@@ -111,4 +95,2 @@ try { | ||
} | ||
console.log("Options: " + JSON.safeStringify(options)) | ||
console.log("routerFn: " + JSON.safeStringify(routerFn)) | ||
@@ -192,3 +174,3 @@ const app = new Koa() | ||
googleHandler: async (event, ctx) => { | ||
console.log("Event: " + JSON.stringify(event)) | ||
// console.log("Event: " + JSON.stringify(event)) | ||
const msg = event.data | ||
@@ -211,6 +193,6 @@ ? Buffer.from(event.data, 'base64').toString() | ||
azureHandler: async (ctx, event) => { | ||
console.log("azureHandler called."); | ||
console.log("Subject: " + event.subject); | ||
console.log("Time: " + event.eventTime); | ||
console.log("Data: " + JSON.stringify(event.data)); | ||
// console.log("azureHandler called."); | ||
// console.log("Subject: " + event.subject); | ||
// console.log("Time: " + event.eventTime); | ||
// console.log("Data: " + JSON.stringify(event.data)); | ||
@@ -217,0 +199,0 @@ const contextId = event.data.contextId || helper.generateRandomID() |
55112195
485