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

cammelCase insteadof snake_case 

Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
Fabio José 2019-07-16 14:26:03 -03:00
parent 512c4ed435
commit cfed4af49c
1 changed files with 30 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
lib/bindings/http/receiver_structured_0_2.js
View File

@ -8,48 +8,48 @@ var JSONParser = require("../../formats/json/parser.js");
const spec02 = new Spec02();
const jsonParserSpec02 = new JSONParser();
const parser_by_mime = {};
parser_by_mime[Constants.MIME_JSON] = jsonParserSpec02;
parser_by_mime[Constants.MIME_CE_JSON] = jsonParserSpec02;
const parserByMime = {};
parserByMime[Constants.MIME_JSON] = jsonParserSpec02;
parserByMime[Constants.MIME_CE_JSON] = jsonParserSpec02;
const allowed_content_types = [];
allowed_content_types.push(Constants.MIME_CE_JSON);
const allowedContentTypes = [];
allowedContentTypes.push(Constants.MIME_CE_JSON);
const setter_reflections = {};
setter_reflections[Constants.STRUCTURED_ATTRS_02.TYPE] = {
const setterReflections = {};
setterReflections[Constants.STRUCTURED_ATTRS_02.TYPE] = {
name : "type",
parser : (v) => v
};
setter_reflections[Constants.STRUCTURED_ATTRS_02.SPEC_VERSION] = {
setterReflections[Constants.STRUCTURED_ATTRS_02.SPEC_VERSION] = {
name : "specversion",
parser : (v) => v
};
setter_reflections[Constants.STRUCTURED_ATTRS_02.SOURCE] = {
setterReflections[Constants.STRUCTURED_ATTRS_02.SOURCE] = {
name : "source",
parser: (v) => v
};
setter_reflections[Constants.STRUCTURED_ATTRS_02.ID] = {
setterReflections[Constants.STRUCTURED_ATTRS_02.ID] = {
name : "id",
parser : (v) => v
};
setter_reflections[Constants.STRUCTURED_ATTRS_02.TIME] = {
setterReflections[Constants.STRUCTURED_ATTRS_02.TIME] = {
name : "time",
parser : (v) => new Date(Date.parse(v))
};
setter_reflections[Constants.STRUCTURED_ATTRS_02.SCHEMA_URL] = {
setterReflections[Constants.STRUCTURED_ATTRS_02.SCHEMA_URL] = {
name: "schemaurl",
parser: (v) => v
};
setter_reflections[Constants.STRUCTURED_ATTRS_02.CONTENT_TYPE] = {
setterReflections[Constants.STRUCTURED_ATTRS_02.CONTENT_TYPE] = {
name: "contenttype",
parser: (v) => v
};
setter_reflections[Constants.STRUCTURED_ATTRS_02.DATA] = {
setterReflections[Constants.STRUCTURED_ATTRS_02.DATA] = {
name: "data",
parser: (v) => v
};
function validate_args(payload, attributes) {
function validateArgs(payload, attributes) {
if(!payload){
throw {message: "payload is null or undefined"};
}
@ -71,16 +71,16 @@ function Receiver(configuration) {
}
Receiver.prototype.check = function(payload, headers) {
validate_args(payload, headers);
validateArgs(payload, headers);
var sanity_headers = Commons.sanity_and_clone(headers);
var sanityHeaders = Commons.sanity_and_clone(headers);
// Validation Level 1
if(!allowed_content_types
.includes(sanity_headers[Constants.HEADER_CONTENT_TYPE])){
if(!allowedContentTypes
.includes(sanityHeaders[Constants.HEADER_CONTENT_TYPE])){
throw {
message: "invalid content type",
errors: [sanity_headers[Constants.HEADER_CONTENT_TYPE]]
errors: [sanityHeaders[Constants.HEADER_CONTENT_TYPE]]
};
}
@ -90,30 +90,30 @@ Receiver.prototype.check = function(payload, headers) {
Receiver.prototype.parse = function(payload, headers) {
this.check(payload, headers);
var sanity_headers = Commons.sanity_and_clone(headers);
var sanityHeaders = Commons.sanity_and_clone(headers);
var contentType = sanity_headers[Constants.HEADER_CONTENT_TYPE];
var contentType = sanityHeaders[Constants.HEADER_CONTENT_TYPE];
var parser = parser_by_mime[contentType];
var parser = parserByMime[contentType];
var event = parser.parse(payload);
spec02.check(event);
var processed_attributes = [];
var processedAttributes = [];
var cloudevent = new Cloudevent(Spec02);
for(attribute in setter_reflections) {
var setter_name = setter_reflections[attribute].name;
var parser_fn = setter_reflections[attribute].parser;
for(attribute in setterReflections) {
var setterName = setterReflections[attribute].name;
var parserFun = setterReflections[attribute].parser;
// invoke the setter function
cloudevent[setter_name](parser_fn(event[attribute]));
cloudevent[setterName](parserFun(event[attribute]));
// to use ahead, for extensions processing
processed_attributes.push(attribute);
processedAttributes.push(attribute);
}
// Every unprocessed attribute should be an extension
Array.from(Object.keys(event))
.filter(attribute => !processed_attributes.includes(attribute))
.filter(attribute => !processedAttributes.includes(attribute))
.forEach(extension =>
cloudevent.addExtension(extension, event[extension])
);