diff --git a/lib/bindings/http/receiver_binary_0_2.js b/lib/bindings/http/receiver_binary_0_2.js index 6d1abd2..ce6560e 100644 --- a/lib/bindings/http/receiver_binary_0_2.js +++ b/lib/bindings/http/receiver_binary_0_2.js @@ -5,49 +5,49 @@ const Spec02 = require("../../specs/spec_0_2.js"); const JSONParser = require("../../formats/json/parser.js"); -const parser_by_type = {}; -parser_by_type[Constants.MIME_JSON] = new JSONParser(); +const parserByType = {}; +parserByType[Constants.MIME_JSON] = new JSONParser(); -const allowed_content_types = []; -allowed_content_types.push(Constants.MIME_JSON); +const allowedContentTypes = []; +allowedContentTypes.push(Constants.MIME_JSON); -const required_headers = []; -required_headers.push(Constants.BINARY_HEADERS_02.TYPE); -required_headers.push(Constants.BINARY_HEADERS_02.SPEC_VERSION); -required_headers.push(Constants.BINARY_HEADERS_02.SOURCE); -required_headers.push(Constants.BINARY_HEADERS_02.ID); +const requiredHeaders = []; +requiredHeaders.push(Constants.BINARY_HEADERS_02.TYPE); +requiredHeaders.push(Constants.BINARY_HEADERS_02.SPEC_VERSION); +requiredHeaders.push(Constants.BINARY_HEADERS_02.SOURCE); +requiredHeaders.push(Constants.BINARY_HEADERS_02.ID); -const setter_reflections = {}; -setter_reflections[Constants.BINARY_HEADERS_02.TYPE] = { +const setterReflections = {}; +setterReflections[Constants.BINARY_HEADERS_02.TYPE] = { name : "type", parser : (v) => v }; -setter_reflections[Constants.BINARY_HEADERS_02.SPEC_VERSION] = { +setterReflections[Constants.BINARY_HEADERS_02.SPEC_VERSION] = { name : "specversion", parser : (v) => "0.2" }; -setter_reflections[Constants.BINARY_HEADERS_02.SOURCE] = { +setterReflections[Constants.BINARY_HEADERS_02.SOURCE] = { name : "source", parser: (v) => v }; -setter_reflections[Constants.BINARY_HEADERS_02.ID] = { +setterReflections[Constants.BINARY_HEADERS_02.ID] = { name : "id", parser : (v) => v }; -setter_reflections[Constants.BINARY_HEADERS_02.TIME] = { +setterReflections[Constants.BINARY_HEADERS_02.TIME] = { name : "time", parser : (v) => new Date(Date.parse(v)) }; -setter_reflections[Constants.BINARY_HEADERS_02.SCHEMA_URL] = { +setterReflections[Constants.BINARY_HEADERS_02.SCHEMA_URL] = { name: "schemaurl", parser: (v) => v }; -setter_reflections[Constants.HEADER_CONTENT_TYPE] = { +setterReflections[Constants.HEADER_CONTENT_TYPE] = { name: "contenttype", parser: (v) => v }; -function validate_args(payload, attributes) { +function validateArgs(payload, attributes) { if(!payload){ throw {message: "payload is null or undefined"}; } @@ -70,30 +70,30 @@ function Receiver(configuration) { Receiver.prototype.check = function(payload, headers) { // Validation Level 0 - validate_args(payload, headers); + validateArgs(payload, headers); // Clone and low case all headers names - 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]] }; } - for(i in required_headers){ - if(!sanity_headers[required_headers[i]]){ - throw {message: "header '" + required_headers[i] + "' not found"}; + for(i in requiredHeaders){ + if(!sanityHeaders[requiredHeaders[i]]){ + throw {message: "header '" + requiredHeaders[i] + "' not found"}; } } - if(sanity_headers[Constants.BINARY_HEADERS_02.SPEC_VERSION] !== "0.2"){ + if(sanityHeaders[Constants.BINARY_HEADERS_02.SPEC_VERSION] !== "0.2"){ throw { message: "invalid spec version", - errors: [sanity_headers[Constants.BINARY_HEADERS_02.SPEC_VERSION]] + errors: [sanityHeaders[Constants.BINARY_HEADERS_02.SPEC_VERSION]] }; } @@ -104,43 +104,43 @@ Receiver.prototype.parse = function(payload, headers) { this.check(payload, headers); // Clone and low case all headers names - var sanity_headers = Commons.sanity_and_clone(headers); + var sanityHeaders = Commons.sanity_and_clone(headers); - var processed_headers = []; + var processedHeaders = []; var cloudevent = new Cloudevent(Spec02); - for(header in setter_reflections) { + for(header in setterReflections) { // dont worry, check() have seen what was required or not - if(sanity_headers[header]){ - var setter_name = setter_reflections[header].name; - var parser_fn = setter_reflections[header].parser; + if(sanityHeaders[header]){ + var setter_name = setterReflections[header].name; + var parserFun = setterReflections[header].parser; // invoke the setter function - cloudevent[setter_name](parser_fn(sanity_headers[header])); + cloudevent[setter_name](parserFun(sanityHeaders[header])); // to use ahead, for extensions processing - processed_headers.push(header); + processedHeaders.push(header); } } // Parses the payload - var parsed_payload = - parser_by_type[sanity_headers[Constants.HEADER_CONTENT_TYPE]] + var parsedPayload = + parserByType[sanityHeaders[Constants.HEADER_CONTENT_TYPE]] .parse(payload); // Every unprocessed header should be an extension - Array.from(Object.keys(sanity_headers)) - .filter(value => !processed_headers.includes(value)) + Array.from(Object.keys(sanityHeaders)) + .filter(value => !processedHeaders.includes(value)) .filter(value => value.startsWith(Constants.BINARY_HEADERS_02.EXTENSIONS_PREFIX)) .map(extension => extension.substring(Constants.BINARY_HEADERS_02.EXTENSIONS_PREFIX.length) ).forEach(extension => cloudevent.addExtension(extension, - sanity_headers[Constants.BINARY_HEADERS_02.EXTENSIONS_PREFIX+extension]) + sanityHeaders[Constants.BINARY_HEADERS_02.EXTENSIONS_PREFIX+extension]) ); // Sets the data - cloudevent.data(parsed_payload); + cloudevent.data(parsedPayload); // Checks the event spec cloudevent.format();