cloudevents
/
sdk-javascript
mirror of https://github.com/cloudevents/sdk-javascript.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix the for guard 

Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
Fabio José 2019-07-16 14:29:25 -03:00
parent cfed4af49c
commit bcfd20bff4
1 changed files with 23 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
lib/bindings/http/receiver_structured_0_2.js
View File

@ -15,36 +15,36 @@ parserByMime[Constants.MIME_CE_JSON] = jsonParserSpec02;
const allowedContentTypes = []; const allowedContentTypes = [];
allowedContentTypes.push(Constants.MIME_CE_JSON); allowedContentTypes.push(Constants.MIME_CE_JSON);
const setterReflections = {}; const setterByAttribute = {};
setterReflections[Constants.STRUCTURED_ATTRS_02.TYPE] = { setterByAttribute[Constants.STRUCTURED_ATTRS_02.TYPE] = {
name : "type", name : "type",
parser : (v) => v parser : (v) => v
}; };
setterReflections[Constants.STRUCTURED_ATTRS_02.SPEC_VERSION] = { setterByAttribute[Constants.STRUCTURED_ATTRS_02.SPEC_VERSION] = {
name : "specversion", name : "specversion",
parser : (v) => v parser : (v) => v
}; };
setterReflections[Constants.STRUCTURED_ATTRS_02.SOURCE] = { setterByAttribute[Constants.STRUCTURED_ATTRS_02.SOURCE] = {
name : "source", name : "source",
parser: (v) => v parser: (v) => v
}; };
setterReflections[Constants.STRUCTURED_ATTRS_02.ID] = { setterByAttribute[Constants.STRUCTURED_ATTRS_02.ID] = {
name : "id", name : "id",
parser : (v) => v parser : (v) => v
}; };
setterReflections[Constants.STRUCTURED_ATTRS_02.TIME] = { setterByAttribute[Constants.STRUCTURED_ATTRS_02.TIME] = {
name : "time", name : "time",
parser : (v) => new Date(Date.parse(v)) parser : (v) => new Date(Date.parse(v))
}; };
setterReflections[Constants.STRUCTURED_ATTRS_02.SCHEMA_URL] = { setterByAttribute[Constants.STRUCTURED_ATTRS_02.SCHEMA_URL] = {
name: "schemaurl", name: "schemaurl",
parser: (v) => v parser: (v) => v
}; };
setterReflections[Constants.STRUCTURED_ATTRS_02.CONTENT_TYPE] = { setterByAttribute[Constants.STRUCTURED_ATTRS_02.CONTENT_TYPE] = {
name: "contenttype", name: "contenttype",
parser: (v) => v parser: (v) => v
}; };
setterReflections[Constants.STRUCTURED_ATTRS_02.DATA] = { setterByAttribute[Constants.STRUCTURED_ATTRS_02.DATA] = {
name: "data", name: "data",
parser: (v) => v parser: (v) => v
}; };
@ -100,23 +100,25 @@ Receiver.prototype.parse = function(payload, headers) {
var processedAttributes = []; var processedAttributes = [];
var cloudevent = new Cloudevent(Spec02); var cloudevent = new Cloudevent(Spec02);
for(attribute in setterReflections) {
var setterName = setterReflections[attribute].name;
var parserFun = setterReflections[attribute].parser;
// invoke the setter function Array.from(Object.keys(setterByAttribute))
cloudevent[setterName](parserFun(event[attribute])); .forEach(attribute => {
var setterName = setterByAttribute[attribute].name;
var parserFun = setterByAttribute[attribute].parser;
// to use ahead, for extensions processing // invoke the setter function
processedAttributes.push(attribute); cloudevent[setterName](parserFun(event[attribute]));
}
// to use ahead, for extensions processing
processedAttributes.push(attribute);
});
// Every unprocessed attribute should be an extension // Every unprocessed attribute should be an extension
Array.from(Object.keys(event)) Array.from(Object.keys(event))
.filter(attribute => !processedAttributes.includes(attribute)) .filter(attribute => !processedAttributes.includes(attribute))
.forEach(extension => .forEach(extension =>
cloudevent.addExtension(extension, event[extension]) cloudevent.addExtension(extension, event[extension])
); );
return cloudevent; return cloudevent;
} }