From 7a4473b11a477b3ba81750f51eebecff10e57597 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fabio=20Jos=C3=A9?= Date: Sun, 4 Aug 2019 13:27:25 -0300 Subject: [PATCH] Remove the 0.2 references MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Fabio José --- lib/bindings/http/receiver_binary.js | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/lib/bindings/http/receiver_binary.js b/lib/bindings/http/receiver_binary.js index 1c5102e..cb8f2b6 100644 --- a/lib/bindings/http/receiver_binary.js +++ b/lib/bindings/http/receiver_binary.js @@ -27,7 +27,9 @@ function BinaryHTTPReceiver( setterByHeader, allowedContentTypes, requiredHeaders, - Spec) { + Spec, + specversion, + extensionsPrefix) { this.parserByType = parserByType; this.setterByHeader = setterByHeader; @@ -35,6 +37,8 @@ function BinaryHTTPReceiver( this.requiredHeaders = requiredHeaders; this.Spec = Spec; this.spec = new Spec(); + this.specversion = specversion; + this.extensionsPrefix = extensionsPrefix; } BinaryHTTPReceiver.prototype.check = function(payload, headers) { @@ -59,10 +63,10 @@ BinaryHTTPReceiver.prototype.check = function(payload, headers) { throw {message: "header '" + required + "' not found"}; }); - if(sanityHeaders[Constants.BINARY_HEADERS_02.SPEC_VERSION] !== "0.2"){ + if(sanityHeaders[Constants.DEFAULT_SPEC_VERSION_HEADER] !== this.specversion){ throw { message: "invalid spec version", - errors: [sanityHeaders[Constants.BINARY_HEADERS_02.SPEC_VERSION]] + errors: [sanityHeaders[Constants.DEFAULT_SPEC_VERSION_HEADER]] }; } @@ -101,12 +105,12 @@ BinaryHTTPReceiver.prototype.parse = function(payload, headers) { Array.from(Object.keys(sanityHeaders)) .filter((value) => !processedHeaders.includes(value)) .filter((value) => - value.startsWith(Constants.BINARY_HEADERS_02.EXTENSIONS_PREFIX)) + value.startsWith(this.extensionsPrefix)) .map((extension) => - extension.substring(Constants.BINARY_HEADERS_02.EXTENSIONS_PREFIX.length) + extension.substring(this.extensionsPrefix.length) ).forEach((extension) => cloudevent.addExtension(extension, - sanityHeaders[Constants.BINARY_HEADERS_02.EXTENSIONS_PREFIX+extension]) + sanityHeaders[this.extensionsPrefix+extension]) ); // Sets the data