Structured http receiver for spec 1.0

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

lib/bindings/http/receiver_structured_1.js

@@ -0,0 +1,76 @@
+const Constants = require("./constants.js");
+const Spec      = require("../../specs/spec_1.js");
+var JSONParser  = require("../../formats/json/parser.js");
+
+const StructuredHTTPReceiver = require("./receiver_structured.js");
+
+const {
+  isDefinedOrThrow,
+  isStringOrObjectOrThrow
+} = require("../../utils/fun.js");
+
+const jsonParserSpec = new JSONParser();
+
+const parserByMime = {};
+parserByMime[Constants.MIME_JSON]    = jsonParserSpec;
+parserByMime[Constants.MIME_CE_JSON] = jsonParserSpec;
+
+const allowedContentTypes = [];
+allowedContentTypes.push(Constants.MIME_CE_JSON);
+
+const setterByAttribute = {};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.TYPE] = {
+  name : "type",
+  parser : (v) => v
+};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.SPEC_VERSION] = {
+  name : "specversion",
+  parser : (v) => v
+};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.SOURCE] = {
+  name : "source",
+  parser: (v) => v
+};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.ID] = {
+  name : "id",
+  parser : (v) => v
+};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.TIME] = {
+  name : "time",
+  parser : (v) => new Date(Date.parse(v))
+};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.DATA_SCHEMA] = {
+  name: "dataschema",
+  parser: (v) => v
+};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.CONTENT_TYPE] = {
+  name: "dataContentType",
+  parser: (v) => v
+};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.SUBJECT] = {
+  name: "subject",
+  parser: (v) => v
+};
+setterByAttribute[Constants.STRUCTURED_ATTRS_1.DATA] = {
+  name: "data",
+  parser: (v) => v
+};
+
+function Receiver(configuration) {
+  this.receiver = new StructuredHTTPReceiver(
+    parserByMime,
+    setterByAttribute,
+    allowedContentTypes,
+    Spec
+  );
+}
+
+Receiver.prototype.check = function(payload, headers) {
+  this.receiver.check(payload, headers);
+};
+
+Receiver.prototype.parse = function(payload, headers) {
+  return this.receiver.parse(payload, headers);
+};
+
+module.exports = Receiver;

test/bindings/http/receiver_structured_1_test.js

@@ -0,0 +1,185 @@
+var expect     = require("chai").expect;
+var v1 = require("../../../v1/index.js");
+var Cloudevent = require("../../../index.js");
+var Spec     = require("../../../lib/specs/spec_1.js");
+
+var HTTPStructuredReceiver =
+  require("../../../lib/bindings/http/receiver_structured_1.js");
+
+var receiver = new HTTPStructuredReceiver();
+
+const type        = "com.github.pull.create";
+const source      = "urn:event:from:myapi/resourse/123";
+const webhook     = "https://cloudevents.io/webhook";
+const contentEncoding = "base64";
+const contentType = "application/cloudevents+json; charset=utf-8";
+const now         = new Date();
+const dataschema  = "http://cloudevents.io/schema.json";
+
+const ceContentType = "application/json";
+
+const data = {
+  foo: "bar"
+};
+
+const ext1Name  = "extension1";
+const ext1Value = "foobar";
+const ext2Name  = "extension2";
+const ext2Value = "acme";
+
+describe("HTTP Transport Binding Structured Receiver for CloudEvents v1.0", () => {
+  describe("Check", () => {
+    it("Throw error when payload arg is null or undefined", () => {
+      // setup
+      var payload = null;
+      var attributes = {};
+
+      // act and assert
+      expect(receiver.check.bind(receiver, payload, attributes))
+        .to.throw("payload is null or undefined");
+    });
+
+    it("Throw error when attributes arg is null or undefined", () => {
+      // setup
+      var payload = {};
+      var attributes = null;
+
+      // act and assert
+      expect(receiver.check.bind(receiver, payload, attributes))
+        .to.throw("attributes is null or undefined");
+    });
+
+    it("Throw error when payload is not an object or string", () => {
+      // setup
+      var payload = 1.0;
+      var attributes = {};
+
+      // act and assert
+      expect(receiver.check.bind(receiver, payload, attributes))
+        .to.throw("payload must be an object or string");
+    });
+
+    it("Throw error when the content-type is invalid", () => {
+      // setup
+      var payload = {};
+      var attributes = {
+        "Content-Type" : "text/html"
+      };
+
+      // act and assert
+      expect(receiver.check.bind(receiver, payload, attributes))
+        .to.throw("invalid content type");
+    });
+
+    it("No error when all required stuff are in place", () => {
+      // setup
+      var payload = {};
+      var attributes = {
+        "Content-Type" : "application/cloudevents+json"
+      };
+
+      // act and assert
+      expect(receiver.check.bind(receiver, payload, attributes))
+        .to.not.throw();
+    });
+  });
+
+  describe("Parse", () => {
+    it("Throw error when the event does not follow the spec", () => {
+      // setup
+      var payload =
+        new Cloudevent()
+          .type(type)
+          .source(source)
+          .time(now)
+          .data(data)
+          .toString();
+
+      var headers = {
+        "Content-Type":"application/cloudevents+json"
+      };
+
+      // act and assert
+      expect(receiver.parse.bind(receiver, payload, headers))
+        .to.throw("invalid payload");
+    });
+
+    it("Should accept event that follows the spec", () => {
+      // setup
+      var id = "id-x0dk";
+      var payload = v1.event()
+          .type(type)
+          .source(source)
+          .id(id)
+          .dataContentType(ceContentType)
+          .time(now)
+          .dataschema(dataschema)
+          .data(data)
+          .toString();
+      var headers = {
+        "content-type":"application/cloudevents+json"
+      };
+
+      // act
+      var actual = receiver.parse(payload, headers);
+
+      // assert
+      expect(actual)
+          .to.be.an("object");
+
+      expect(actual)
+          .to.have.property("format");
+
+      expect(actual.getId())
+          .to.equals(id);
+    });
+
+    it("Should accept 'extension1'", () => {
+      // setup
+      var extension1 = "mycuston-ext1"
+      var payload = v1.event()
+          .type(type)
+          .source(source)
+          .dataContentType(ceContentType)
+          .time(now)
+          .dataschema(dataschema)
+          .data(data)
+          .addExtension("extension1", extension1)
+          .toString();
+
+      var headers = {
+        "content-type":"application/cloudevents+json"
+      };
+
+      // act
+      var actual = receiver.parse(payload, headers);
+      var actualExtensions = actual.getExtensions();
+
+      // assert
+      expect(actualExtensions["extension1"])
+          .to.equal(extension1);
+    });
+
+    it("Should parse 'data' stringfied json to json object", () => {
+      // setup
+      var payload = v1.event()
+          .type(type)
+          .source(source)
+          .dataContentType(ceContentType)
+          .time(now)
+          .dataschema(dataschema)
+          .data(JSON.stringify(data))
+          .toString();
+
+      var headers = {
+        "content-type":"application/cloudevents+json"
+      };
+
+      // act
+      var actual = receiver.parse(payload, headers);
+
+      // assert
+      expect(actual.getData()).to.deep.equal(data);
+    });
+  });
+});