cloudevents
/
sdk-javascript
mirror of https://github.com/cloudevents/sdk-javascript.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove HTTPUnmarshaller 

Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
Fabio José 2019-11-04 10:13:04 -03:00
parent 43c6bfe9dc
commit cf701e423c
4 changed files with 0 additions and 273 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
lib/bindings/http/unmarshaller_1.js
View File

@ -1,19 +0,0 @@
const GenericUnmarshaller = require("./unmarshaller.js");
var StructuredReceiver = require("./receiver_structured_1.js");
var BinaryReceiver = require("./receiver_binary_1.js");
const RECEIVER_BY_BINDING = {
structured : new StructuredReceiver(),
binary : new BinaryReceiver(),
};
var Unmarshaller = function() {
this.unmarshaller = new GenericUnmarshaller(RECEIVER_BY_BINDING);
};
Unmarshaller.prototype.unmarshall = function(payload, headers) {
return this.unmarshaller.unmarshall(payload, headers);
};
module.exports = Unmarshaller;

247
test/bindings/http/unmarshaller_1_tests.js
View File

@ -1,247 +0,0 @@
const expect = require("chai").expect;
const Unmarshaller = require("../../../lib/bindings/http/unmarshaller_1.js");
const Cloudevent = require("../../../index.js");
const v1 = require("../../../v1/index.js");
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 dataschema = "http://cloudevents.io/schema.json";
const subject = "subject.ext";
const ceContentType = "application/json";
const data = {
foo: "bar"
};
describe("HTTP Transport Binding Unmarshaller for CloudEvents v1.0", () => {
it("Throw error when payload is null", () => {
// setup
var payload = null;
var un = new Unmarshaller();
// act and assert
return un.unmarshall(payload)
.then(actual => {throw {message: "failed"}})
.catch(err =>
expect(err.message).to.equal("payload is null or undefined"));
});
it("Throw error when headers is null", () => {
// setup
var payload = {};
var headers = null;
var un = new Unmarshaller();
// act and assert
return un.unmarshall(payload, headers)
.then(actual => {throw {message: "failed"}})
.catch(err =>
expect(err.message).to.equal("headers is null or undefined"));
});
it("Throw error when there is no content-type header", () => {
// setup
var payload = {};
var headers = {};
var un = new Unmarshaller();
// act and assert
un.unmarshall(payload, headers)
.then(actual => {throw {message: "failed"}})
.catch(err =>
expect(err.message).to.equal("content-type header not found"));
});
it("Throw error when content-type is not allowed", () => {
// setup
var payload = {};
var headers = {
"content-type":"text/xml"
};
var un = new Unmarshaller();
// act and assert
un.unmarshall(payload, headers)
.then(actual => {throw {message: "failed"}})
.catch(err =>
expect(err.message).to.equal("content type not allowed"));
});
describe("Structured", () => {
it("Throw error when has not allowed mime", () => {
// setup
var payload = {};
var headers = {
"content-type":"application/cloudevents+zip"
};
var un = new Unmarshaller();
// act and assert
un.unmarshall(payload, headers)
.then(actual => {throw {message: "failed"}})
.catch(err =>
expect(err.message).to.equal("structured+type not allowed"));
});
it("Throw error when the event does not follow the spec 1.0", () => {
// setup
var payload =
new Cloudevent()
.type(type)
.source(source)
.time(now)
.data(data)
.toString();
var headers = {
"content-type":"application/cloudevents+json"
};
var un = new Unmarshaller();
// act and assert
un.unmarshall(payload, headers)
.then(actual => {throw {message: "failed"}})
.catch(err =>
expect(err.message).to.equal("invalid payload"));
});
it("Should accept event that follow the spec 1.0", () => {
// setup
var payload =
new Cloudevent(v1.Spec)
.type(type)
.source(source)
.dataContentType(ceContentType)
.time(now)
.dataschema(dataschema)
.subject(subject)
.data(data)
.toString();
var headers = {
"content-type":"application/cloudevents+json"
};
var un = new Unmarshaller();
// act and assert
return un.unmarshall(payload, headers)
.then(actual =>
expect(actual).to.be.an("object"))
.catch((err) => {
console.log(err);
throw err;
});
});
it("Should parse 'data' stringfied json to json object", () => {
// setup
var payload =
new Cloudevent(v1.Spec)
.type(type)
.source(source)
.dataContentType(ceContentType)
.time(now)
.dataschema(dataschema)
.subject(subject)
.data(JSON.stringify(data))
.toString();
var headers = {
"content-type":"application/cloudevents+json"
};
var un = new Unmarshaller();
// act and assert
return un.unmarshall(payload, headers)
.then(actual => {
expect(actual.getData()).to.deep.equal(data)
})
.catch((err) => {
console.log(err);
throw err;
});
});
});
describe("Binary", () => {
it("Throw error when has not allowed mime", () => {
// setup
var payload = {
"data" : "dataString"
};
var attributes = {
"ce-type" : "type",
"ce-specversion" : "1.0",
"ce-source" : "source",
"ce-id" : "id",
"ce-time" : "2019-06-16T11:42:00Z",
"ce-datdaschema" : "http://schema.registry/v1",
"Content-Type" : "text/html"
};
var un = new Unmarshaller();
// act and assert
un.unmarshall(payload, attributes)
.then(actual => {throw {message: "failed"}})
.catch(err =>
expect(err.message).to.equal("content type not allowed"));
});
it("Throw error when the event does not follow the spec 1.0", () => {
// setup
var payload = {
"data" : "dataString"
};
var attributes = {
"ce-type" : "type",
"CE-CloudEventsVersion" : "0.1",
"ce-source" : "source",
"ce-id" : "id",
"ce-time" : "2019-06-16T11:42:00Z",
"ce-schemaurl" : "http://schema.registry/v1",
"Content-Type" : "application/json"
};
var un = new Unmarshaller();
// act and assert
un.unmarshall(payload, attributes)
.then(actual => {throw {message: "failed"}})
.catch(err =>
expect(err.message).to.not.empty);
});
it("No error when all attributes are in place", () => {
// setup
var payload = {
"data" : "dataString"
};
var attributes = {
"ce-type" : "type",
"ce-specversion" : "1.0",
"ce-source" : "source",
"ce-id" : "id",
"ce-time" : "2019-06-16T11:42:00Z",
"ce-dataschema" : "http://schema.registry/v1",
"Content-Type" : "application/json"
};
var un = new Unmarshaller();
// act and assert
un.unmarshall(payload, attributes)
.then(actual => expect(actual).to.be.an("object"));
});
});
});

4
test/sdk_test.js
View File

@ -97,10 +97,6 @@ describe("The SDK Requirements", () => {
expect(v1).to.have.property("BinaryHTTPReceiver"); expect(v1).to.have.property("BinaryHTTPReceiver");
}); });
it("should exports 'HTTPUnmarshaller'", () => {
expect(v1).to.have.property("HTTPUnmarshaller");
});
it("should exports 'event'", () => { it("should exports 'event'", () => {
expect(v1).to.have.property("event"); expect(v1).to.have.property("event");
}); });

3
v1/index.js
View File

@ -12,8 +12,6 @@ const StructuredHTTPReceiver =
const BinaryHTTPReceiver = const BinaryHTTPReceiver =
require("../lib/bindings/http/receiver_binary_1.js"); require("../lib/bindings/http/receiver_binary_1.js");
const HTTPUnmarshaller = require("../lib/bindings/http/unmarshaller_1.js");
function event() { function event() {
return new Cloudevent(Spec); return new Cloudevent(Spec);
} }
@ -24,6 +22,5 @@ module.exports = {
BinaryHTTPEmitter, BinaryHTTPEmitter,
StructuredHTTPReceiver, StructuredHTTPReceiver,
BinaryHTTPReceiver, BinaryHTTPReceiver,
HTTPUnmarshaller,
event event
}; };