A generic structured http receiver for reusable purposes

Signed-off-by: Fabio José <fabiojose@gmail.com>

lib/bindings/http/receiver_structured.js

@@ -0,0 +1,90 @@
+const Constants  = require("./constants.js");
+const Commons    = require("./commons.js");
+const Cloudevent = require("../../cloudevent.js");
+
+const {
+  isDefinedOrThrow,
+  isStringOrObjectOrThrow
+} = require("../../utils/fun.js");
+
+function validateArgs(payload, attributes) {
+  Array.of(payload)
+    .filter((p) => isDefinedOrThrow(p,
+              {message: "payload is null or undefined"}))
+    .filter((p) => isStringOrObjectOrThrow(p,
+              {message: "payload must be an object or string"}))
+    .shift();
+
+  Array.of(attributes)
+    .filter((a) => isDefinedOrThrow(a,
+                {message: "attributes is null or undefined"}))
+    .shift();
+}
+
+function StructuredHTTPReceiver(
+  parserByMime,
+  setterByAttribute,
+  allowedContentTypes,
+  Spec) {
+
+  this.parserByMime = parserByMime;
+  this.setterByAttribute = setterByAttribute;
+  this.allowedContentTypes = allowedContentTypes;
+  this.Spec = Spec;
+  this.spec = new Spec();
+}
+
+StructuredHTTPReceiver.prototype.check = function(payload, headers) {
+  validateArgs(payload, headers);
+
+  var sanityHeaders = Commons.sanityAndClone(headers);
+
+  // Validation Level 1
+  if(!this.allowedContentTypes
+      .includes(sanityHeaders[Constants.HEADER_CONTENT_TYPE])){
+        throw {
+          message: "invalid content type",
+          errors: [sanityHeaders[Constants.HEADER_CONTENT_TYPE]]
+        };
+  }
+
+  // No erros! Its contains the minimum required attributes
+};
+
+StructuredHTTPReceiver.prototype.parse = function(payload, headers) {
+  this.check(payload, headers);
+
+  var sanityHeaders = Commons.sanityAndClone(headers);
+
+  var contentType = sanityHeaders[Constants.HEADER_CONTENT_TYPE];
+
+  var parser = this.parserByMime[contentType];
+  var event  = parser.parse(payload);
+  this.spec.check(event);
+
+  var processedAttributes = [];
+  var cloudevent = new Cloudevent(this.Spec);
+
+  Array.from(Object.keys(this.setterByAttribute))
+    .forEach((attribute) => {
+      var setterName = this.setterByAttribute[attribute].name;
+      var parserFun  = this.setterByAttribute[attribute].parser;
+
+      // invoke the setter function
+      cloudevent[setterName](parserFun(event[attribute]));
+
+      // to use ahead, for extensions processing
+      processedAttributes.push(attribute);
+    });
+
+  // Every unprocessed attribute should be an extension
+  Array.from(Object.keys(event))
+    .filter((attribute) => !processedAttributes.includes(attribute))
+    .forEach((extension) =>
+      cloudevent.addExtension(extension, event[extension])
+    );
+
+  return cloudevent;
+};
+
+module.exports = StructuredHTTPReceiver;

lib/bindings/http/receiver_structured_0_2.js

@@ -1,16 +1,14 @@
-const Constants  = require("./constants.js");
-const Commons    = require("./commons.js");
-const Cloudevent = require("../../cloudevent.js");
-const Spec02     = require("../../specs/spec_0_2.js");
+const Constants = require("./constants.js");
+const Spec02    = require("../../specs/spec_0_2.js");
+var JSONParser  = require("../../formats/json/parser.js");
 
-var JSONParser = require("../../formats/json/parser.js");
+const StructuredHTTPReceiver = require("./receiver_structured.js");
 
 const {
   isDefinedOrThrow,
   isStringOrObjectOrThrow
 } = require("../../utils/fun.js");
 
-const spec02 = new Spec02();
 const jsonParserSpec02 = new JSONParser();
 
 const parserByMime = {};
@@ -54,76 +52,21 @@ setterByAttribute[Constants.STRUCTURED_ATTRS_02.DATA] = {
   parser: (v) => v
 };
 
-function validateArgs(payload, attributes) {
-
-  Array.of(payload)
-    .filter((p) => isDefinedOrThrow(p,
-              {message: "payload is null or undefined"}))
-    .filter((p) => isStringOrObjectOrThrow(p,
-              {message: "payload must be an object or string"}))
-    .shift();
-
-  Array.of(attributes)
-    .filter((a) => isDefinedOrThrow(a,
-                {message: "attributes is null or undefined"}))
-    .shift();
-}
-
 function Receiver(configuration) {
-
+  this.receiver = new StructuredHTTPReceiver(
+    parserByMime,
+    setterByAttribute,
+    allowedContentTypes,
+    Spec02
+  );
 }
 
 Receiver.prototype.check = function(payload, headers) {
-  validateArgs(payload, headers);
-
-  var sanityHeaders = Commons.sanityAndClone(headers);
-
-  // Validation Level 1
-  if(!allowedContentTypes
-      .includes(sanityHeaders[Constants.HEADER_CONTENT_TYPE])){
-        throw {
-          message: "invalid content type",
-          errors: [sanityHeaders[Constants.HEADER_CONTENT_TYPE]]
-        };
-  }
-
-  // No erros! Its contains the minimum required attributes
+  this.receiver.check(payload, headers);
 };
 
 Receiver.prototype.parse = function(payload, headers) {
-  this.check(payload, headers);
-
-  var sanityHeaders = Commons.sanityAndClone(headers);
-
-  var contentType = sanityHeaders[Constants.HEADER_CONTENT_TYPE];
-
-  var parser = parserByMime[contentType];
-  var event  = parser.parse(payload);
-  spec02.check(event);
-
-  var processedAttributes = [];
-  var cloudevent = new Cloudevent(Spec02);
-
-  Array.from(Object.keys(setterByAttribute))
-    .forEach((attribute) => {
-      var setterName = setterByAttribute[attribute].name;
-      var parserFun   = setterByAttribute[attribute].parser;
-
-      // invoke the setter function
-      cloudevent[setterName](parserFun(event[attribute]));
-
-      // to use ahead, for extensions processing
-      processedAttributes.push(attribute);
-    });
-
-  // Every unprocessed attribute should be an extension
-  Array.from(Object.keys(event))
-    .filter((attribute) => !processedAttributes.includes(attribute))
-    .forEach((extension) =>
-      cloudevent.addExtension(extension, event[extension])
-    );
-
-  return cloudevent;
+  return this.receiver.parse(payload, headers);
 };
 
 module.exports = Receiver;