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

lib: Changed Array instantiation and object creation (#159) 

Signed-off-by: Helio Frota <00hf11@gmail.com>
This commit is contained in:
Helio Frota 2020-05-14 17:18:34 -03:00 committed by GitHub
parent 250a0a144c
commit 70de8af9ed
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 31 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

92
lib/bindings/http/receiver_binary_1.js
View File

@ -1,9 +1,15 @@
const Constants = require("./constants.js"); const {
const Spec = require("../../specs/spec_1.js"); MIME_JSON,
MIME_OCTET_STREAM,
ENCODING_BASE64,
BINARY_HEADERS_1,
HEADER_CONTENT_TYPE,
SPEC_V1
} = require("./constants.js");
const Spec = require("../../specs/spec_1.js");
const JSONParser = require("../../formats/json/parser.js"); const JSONParser = require("../../formats/json/parser.js");
const Base64Parser = require("../../formats/base64.js"); const Base64Parser = require("../../formats/base64.js");
const BinaryHTTPReceiver = require("./receiver_binary.js"); const BinaryHTTPReceiver = require("./receiver_binary.js");
const { const {
@ -11,72 +17,36 @@ const {
isBase64 isBase64
} = require("../../utils/fun.js"); } = require("../../utils/fun.js");
const parserByType = {}; const parserByType = {
parserByType[Constants.MIME_JSON] = new JSONParser(); [MIME_JSON] : new JSONParser(),
parserByType[Constants.MIME_OCTET_STREAM] = { [MIME_OCTET_STREAM] : { parse(payload) { return payload; } }
parse(payload) { return payload; }
}; };
const parsersByEncoding = {}; const parsersByEncoding = { [null] : parserByType, [undefined] : parserByType, [ENCODING_BASE64] : {} };
parsersByEncoding.null = parserByType; parsersByEncoding[ENCODING_BASE64][MIME_JSON] = new JSONParser(new Base64Parser());
parsersByEncoding[undefined] = parserByType; parsersByEncoding[ENCODING_BASE64][MIME_OCTET_STREAM] = {
parse(payload) { return payload; }
// base64
parsersByEncoding[Constants.ENCODING_BASE64] = {};
parsersByEncoding[Constants.ENCODING_BASE64][Constants.MIME_JSON] =
new JSONParser(new Base64Parser());
parsersByEncoding[Constants.ENCODING_BASE64][Constants.MIME_OCTET_STREAM] = {
parse(payload) { return payload; }
}; };
const allowedContentTypes = []; const allowedContentTypes = [MIME_JSON, MIME_OCTET_STREAM];
allowedContentTypes.push(Constants.MIME_JSON);
allowedContentTypes.push(Constants.MIME_OCTET_STREAM);
const requiredHeaders = []; const requiredHeaders = [BINARY_HEADERS_1.TYPE, BINARY_HEADERS_1.SPEC_VERSION,
requiredHeaders.push(Constants.BINARY_HEADERS_1.TYPE); BINARY_HEADERS_1.SOURCE, BINARY_HEADERS_1.ID];
requiredHeaders.push(Constants.BINARY_HEADERS_1.SPEC_VERSION);
requiredHeaders.push(Constants.BINARY_HEADERS_1.SOURCE);
requiredHeaders.push(Constants.BINARY_HEADERS_1.ID);
const setterByHeader = {}; const setterByHeader = {
setterByHeader[Constants.BINARY_HEADERS_1.TYPE] = { [BINARY_HEADERS_1.TYPE] : { name: "type", parser: (v) => v },
name: "type", [BINARY_HEADERS_1.SPEC_VERSION] : { name: "specversion", parser: () => "1.0" },
parser: (v) => v [BINARY_HEADERS_1.SOURCE] : { name: "source", parser: (v) => v },
}; [BINARY_HEADERS_1.ID] : { name: "id", parser: (v) => v },
setterByHeader[Constants.BINARY_HEADERS_1.SPEC_VERSION] = { [BINARY_HEADERS_1.TIME] : { name: "time", parser: (v) => new Date(Date.parse(v)) },
name: "specversion", [BINARY_HEADERS_1.DATA_SCHEMA] : { name: "dataschema", parser: (v) => v },
parser: () => "1.0" [HEADER_CONTENT_TYPE] : { name: "dataContentType", parser: (v) => v },
}; [BINARY_HEADERS_1.SUBJECT] : { name: "subject", parser: (v) => v }
setterByHeader[Constants.BINARY_HEADERS_1.SOURCE] = {
name: "source",
parser: (v) => v
};
setterByHeader[Constants.BINARY_HEADERS_1.ID] = {
name: "id",
parser: (v) => v
};
setterByHeader[Constants.BINARY_HEADERS_1.TIME] = {
name: "time",
parser: (v) => new Date(Date.parse(v))
};
setterByHeader[Constants.BINARY_HEADERS_1.DATA_SCHEMA] = {
name: "dataschema",
parser: (v) => v
};
setterByHeader[Constants.HEADER_CONTENT_TYPE] = {
name: "dataContentType",
parser: (v) => v
};
setterByHeader[Constants.BINARY_HEADERS_1.SUBJECT] = {
name: "subject",
parser: (v) => v
}; };
// Leaving these in place for now. TODO: fixme // Leaving these in place for now. TODO: fixme
// eslint-disable-next-line // eslint-disable-next-line
function checkDecorator(payload, headers) { function checkDecorator(payload, headers) {}
}
// Leaving this in place for now. TODO: fixme // Leaving this in place for now. TODO: fixme
// eslint-disable-next-line // eslint-disable-next-line
@ -87,8 +57,8 @@ function Receiver(configuration) {
allowedContentTypes, allowedContentTypes,
requiredHeaders, requiredHeaders,
Spec, Spec,
Constants.SPEC_V1, SPEC_V1,
Constants.BINARY_HEADERS_1.EXTENSIONS_PREFIX, BINARY_HEADERS_1.EXTENSIONS_PREFIX,
checkDecorator checkDecorator
); );
} }