cleanning the code
Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
parent
c1e858fbd6
commit
1e278c0025
|
@ -7,9 +7,9 @@ var JSONParser = require("../../formats/json/parser.js");
|
||||||
|
|
||||||
const jsonParserSpec02 = new JSONParser(new Spec02());
|
const jsonParserSpec02 = new JSONParser(new Spec02());
|
||||||
|
|
||||||
const parsers = {};
|
const parser_by_mime = {};
|
||||||
parsers[Constants.MIME_JSON] = jsonParserSpec02;
|
parser_by_mime[Constants.MIME_JSON] = jsonParserSpec02;
|
||||||
parsers[Constants.MIME_CE_JSON] = jsonParserSpec02;
|
parser_by_mime[Constants.MIME_CE_JSON] = jsonParserSpec02;
|
||||||
|
|
||||||
const allowed_content_types = [];
|
const allowed_content_types = [];
|
||||||
allowed_content_types.push(Constants.MIME_CE_JSON);
|
allowed_content_types.push(Constants.MIME_CE_JSON);
|
||||||
|
@ -54,8 +54,9 @@ Receiver.prototype.parse = function(payload, headers) {
|
||||||
var sanity_headers = Commons.sanity_and_clone(headers);
|
var sanity_headers = Commons.sanity_and_clone(headers);
|
||||||
|
|
||||||
var contentType = sanity_headers[Constants.HEADER_CONTENT_TYPE];
|
var contentType = sanity_headers[Constants.HEADER_CONTENT_TYPE];
|
||||||
|
|
||||||
|
var parser = parser_by_mime[contentType];
|
||||||
|
|
||||||
var parser = parsers[contentType];
|
|
||||||
var cloudevent = parser.parse(payload);
|
var cloudevent = parser.parse(payload);
|
||||||
|
|
||||||
return cloudevent;
|
return cloudevent;
|
||||||
|
|
Loading…
Reference in New Issue