diff --git a/lib/bindings/http/receiver_structured_0_2.js b/lib/bindings/http/receiver_structured_0_2.js index dd7e044..773cde7 100644 --- a/lib/bindings/http/receiver_structured_0_2.js +++ b/lib/bindings/http/receiver_structured_0_2.js @@ -15,6 +15,40 @@ parser_by_mime[Constants.MIME_CE_JSON] = jsonParserSpec02; const allowed_content_types = []; allowed_content_types.push(Constants.MIME_CE_JSON); +const setter_reflections = {}; +setter_reflections[Constants.STRUCTURED_ATTRS_02.TYPE] = { + name : "type", + parser : (v) => v +}; +setter_reflections[Constants.STRUCTURED_ATTRS_02.SPEC_VERSION] = { + name : "specversion", + parser : (v) => v +}; +setter_reflections[Constants.STRUCTURED_ATTRS_02.SOURCE] = { + name : "source", + parser: (v) => v +}; +setter_reflections[Constants.STRUCTURED_ATTRS_02.ID] = { + name : "id", + parser : (v) => v +}; +setter_reflections[Constants.STRUCTURED_ATTRS_02.TIME] = { + name : "time", + parser : (v) => new Date(Date.parse(v)) +}; +setter_reflections[Constants.STRUCTURED_ATTRS_02.SCHEMA_URL] = { + name: "schemaurl", + parser: (v) => v +}; +setter_reflections[Constants.STRUCTURED_ATTRS_02.CONTENT_TYPE] = { + name: "contenttype", + parser: (v) => v +}; +setter_reflections[Constants.STRUCTURED_ATTRS_02.DATA] = { + name: "data", + parser: (v) => v +}; + function validate_args(payload, attributes) { if(!payload){ throw {message: "payload is null or undefined"}; @@ -25,8 +59,10 @@ function validate_args(payload, attributes) { } if((typeof payload) !== "object" && (typeof payload) !== "string"){ - throw {message: "payload must be an object or string", - erros: [typeof payload]}; + throw { + message: "payload must be an object or string", + errors: [typeof payload] + }; } } @@ -42,8 +78,10 @@ Receiver.prototype.check = function(payload, headers) { // Validation Level 1 if(!allowed_content_types .includes(sanity_headers[Constants.HEADER_CONTENT_TYPE])){ - throw {message: "invalid content type", - errors: [sanity_headers[Constants.HEADER_CONTENT_TYPE]]}; + throw { + message: "invalid content type", + errors: [sanity_headers[Constants.HEADER_CONTENT_TYPE]] + }; } // No erros! Its contains the minimum required attributes @@ -57,11 +95,28 @@ Receiver.prototype.parse = function(payload, headers) { var contentType = sanity_headers[Constants.HEADER_CONTENT_TYPE]; var parser = parser_by_mime[contentType]; + var event = parser.parse(payload); + spec02.check(event); - var cloudevent = parser.parse(payload); + var processed_attributes = []; + var cloudevent = new Cloudevent(Spec02); + for(attribute in setter_reflections) { + var setter_name = setter_reflections[attribute].name; + var parser_fn = setter_reflections[attribute].parser; - // Must follow the spec - spec02.check(cloudevent); + // invoke the setter function + cloudevent[setter_name](parser_fn(event[attribute])); + + // to use ahead, for extensions processing + processed_attributes.push(attribute); + } + + // Every unprocessed attribute should be an extension + Array.from(Object.keys(event)) + .filter(attribute => !processed_attributes.includes(attribute)) + .forEach(extension => + cloudevent.addExtension(extension, event[extension]) + ); return cloudevent; }