Fix var to avoid pollution
Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
parent
c301f05f66
commit
512c4ed435
|
@ -17,32 +17,32 @@ requiredHeaders.push(Constants.BINARY_HEADERS_02.SPEC_VERSION);
|
|||
requiredHeaders.push(Constants.BINARY_HEADERS_02.SOURCE);
|
||||
requiredHeaders.push(Constants.BINARY_HEADERS_02.ID);
|
||||
|
||||
const setterReflections = {};
|
||||
setterReflections[Constants.BINARY_HEADERS_02.TYPE] = {
|
||||
const setterByHeader = {};
|
||||
setterByHeader[Constants.BINARY_HEADERS_02.TYPE] = {
|
||||
name : "type",
|
||||
parser : (v) => v
|
||||
};
|
||||
setterReflections[Constants.BINARY_HEADERS_02.SPEC_VERSION] = {
|
||||
setterByHeader[Constants.BINARY_HEADERS_02.SPEC_VERSION] = {
|
||||
name : "specversion",
|
||||
parser : (v) => "0.2"
|
||||
};
|
||||
setterReflections[Constants.BINARY_HEADERS_02.SOURCE] = {
|
||||
setterByHeader[Constants.BINARY_HEADERS_02.SOURCE] = {
|
||||
name : "source",
|
||||
parser: (v) => v
|
||||
};
|
||||
setterReflections[Constants.BINARY_HEADERS_02.ID] = {
|
||||
setterByHeader[Constants.BINARY_HEADERS_02.ID] = {
|
||||
name : "id",
|
||||
parser : (v) => v
|
||||
};
|
||||
setterReflections[Constants.BINARY_HEADERS_02.TIME] = {
|
||||
setterByHeader[Constants.BINARY_HEADERS_02.TIME] = {
|
||||
name : "time",
|
||||
parser : (v) => new Date(Date.parse(v))
|
||||
};
|
||||
setterReflections[Constants.BINARY_HEADERS_02.SCHEMA_URL] = {
|
||||
setterByHeader[Constants.BINARY_HEADERS_02.SCHEMA_URL] = {
|
||||
name: "schemaurl",
|
||||
parser: (v) => v
|
||||
};
|
||||
setterReflections[Constants.HEADER_CONTENT_TYPE] = {
|
||||
setterByHeader[Constants.HEADER_CONTENT_TYPE] = {
|
||||
name: "contenttype",
|
||||
parser: (v) => v
|
||||
};
|
||||
|
@ -110,11 +110,11 @@ Receiver.prototype.parse = function(payload, headers) {
|
|||
var cloudevent = new Cloudevent(Spec02);
|
||||
|
||||
// dont worry, check() have seen what was required or not
|
||||
Array.from(Object.keys(setterReflections))
|
||||
Array.from(Object.keys(setterByHeader))
|
||||
.filter(header => sanityHeaders[header])
|
||||
.forEach(header => {
|
||||
var setterName = setterReflections[header].name;
|
||||
var parserFun = setterReflections[header].parser;
|
||||
var setterName = setterByHeader[header].name;
|
||||
var parserFun = setterByHeader[header].parser;
|
||||
|
||||
// invoke the setter function
|
||||
cloudevent[setterName](parserFun(sanityHeaders[header]));
|
||||
|
|
Loading…
Reference in New Issue