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