143 lines
3.7 KiB
JavaScript
143 lines
3.7 KiB
JavaScript
var expect = require("chai").expect;
|
|
var Cloudevent = require("../../../index.js");
|
|
var Spec02 = require("../../../lib/specs/spec_0_2.js");
|
|
|
|
var HTTPStructuredReceiver02 =
|
|
require("../../../lib/bindings/http/receiver_structured_0_2.js");
|
|
|
|
var receiver = new HTTPStructuredReceiver02();
|
|
|
|
const type = "com.github.pull.create";
|
|
const source = "urn:event:from:myapi/resourse/123";
|
|
const webhook = "https://cloudevents.io/webhook";
|
|
const contentType = "application/cloudevents+json; charset=utf-8";
|
|
const now = new Date();
|
|
const schemaurl = "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";
|
|
|
|
var cloudevent =
|
|
new Cloudevent(Spec02)
|
|
.type(type)
|
|
.source(source)
|
|
.contenttype(ceContentType)
|
|
.time(now)
|
|
.schemaurl(schemaurl)
|
|
.data(data)
|
|
.addExtension(ext1Name, ext1Value)
|
|
.addExtension(ext2Name, ext2Value);
|
|
|
|
describe("HTTP Transport Binding Structured Receiver for CloudEvents v0.2", () => {
|
|
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 0.2", () => {
|
|
// setup
|
|
var payload =
|
|
new Cloudevent()
|
|
.type(type)
|
|
.source(source)
|
|
.contenttype(ceContentType)
|
|
.time(now)
|
|
.schemaurl(schemaurl)
|
|
.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 follow the spec 0.2", () => {
|
|
// setup
|
|
var payload =
|
|
new Cloudevent(Cloudevent.specs["0.2"])
|
|
.type(type)
|
|
.source(source)
|
|
.contenttype(ceContentType)
|
|
.time(now)
|
|
.schemaurl(schemaurl)
|
|
.data(data)
|
|
.toString();
|
|
|
|
var headers = {
|
|
"content-type":"application/cloudevents+json"
|
|
};
|
|
|
|
// act
|
|
var actual = receiver.parse(payload, headers);
|
|
|
|
// assert
|
|
expect(actual)
|
|
.to.be.an("object");
|
|
});
|
|
});
|
|
});
|