Extension processing and cloudevent right parse

Signed-off-by: Fabio José <[email protected]>

Author: fabiojose

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 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;
 
-  var cloudevent = parser.parse(payload);
+    // invoke the setter function
+    cloudevent[setter_name](parser_fn(event[attribute]));
+
+    // to use ahead, for extensions processing
+    processed_attributes.push(attribute);
+  }
 
-  // Must follow the spec
-  spec02.check(cloudevent);
+  // 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;
 }