closes #18

Signed-off-by: Fabio José <[email protected]>

Author: fabiojose

lib/bindings/http/emitter_binary_0_1.js

@@ -3,15 +3,15 @@ var axios = require("axios");
 const Constants = require("./constants.js");
 
 function HTTPBinary(configuration){
-  this.config = configuration;
+  this.config = JSON.parse(JSON.stringify(configuration));
 
   if(!this.config["headers"]){
     this.config["headers"] = {};
   }
 
   this.config["headers"]
     [Constants.HEADER_CONTENT_TYPE] =
-      Constants.MIME_CE_JSON + "; charset=" + Constants.CHARSET_DEFAULT;
+      Constants.MIME_JSON + "; charset=" + Constants.CHARSET_DEFAULT;
 }
 
 HTTPBinary.prototype.emit = function(cloudevent){
@@ -22,25 +22,39 @@ HTTPBinary.prototype.emit = function(cloudevent){
   // Always set stuff in _config
   var _headers = _config["headers"];
 
+  // OPTIONAL CONTENT TYPE ATTRIBUTE
   if(cloudevent.getContenttype()) {
     _headers[Constants.HEADER_CONTENT_TYPE] = cloudevent.getContenttype();
   }
 
   _headers["CE-EventType"] = cloudevent.getType();
-  if(cloudevent.getEventTypeVersion()) {
-    _headers["CE-EventTypeVersion"] = cloudevent.getEventTypeVersion();
-  }
   _headers["CE-CloudEventsVersion"] = cloudevent.getSpecversion();
   _headers["CE-Source"] = cloudevent.getSource();
   _headers["CE-EventID"] = cloudevent.getId();
+
+  if(cloudevent.getEventTypeVersion()) {
+    _headers["CE-EventTypeVersion"] = cloudevent.getEventTypeVersion();
+  }
+
   if(cloudevent.getTime()) {
     _headers["CE-EventTime"] = cloudevent.getTime();
   }
-  _headers["CE-SchemaURL"] = cloudevent.getSchemaurl();
+  if(cloudevent.getSchemaurl()) {
+   _headers["CE-SchemaURL"] = cloudevent.getSchemaurl();
+  }
 
   // Set the cloudevent payload
   _config["data"] = cloudevent.format().data;
 
+  // EXTENSION CONTEXT ATTRIBUTES
+  var exts = cloudevent.getExtensions();
+  for(var ext in exts){
+    if({}.hasOwnProperty.call(exts, ext)){
+      let capsExt = ext.charAt(0).toUpperCase() + ext.slice(1)
+      _headers["CE-X-" + capsExt] = exts[ext];
+    }
+  }
+
   // Return the Promise
   return axios.request(_config);
 };

lib/bindings/http/emitter_binary_0_2.js

@@ -4,15 +4,15 @@ var empty = require("is-empty");
 const Constants = require("./constants.js");
 
 function HTTPBinary02(configuration){
-  this.config = configuration;
+  this.config = JSON.parse(JSON.stringify(configuration));
 
   if(!this.config["headers"]){
     this.config["headers"] = {};
   }
 
   this.config["headers"]
     [Constants.HEADER_CONTENT_TYPE] =
-      Constants.MIME_CE_JSON + "; charset=" + Constants.CHARSET_DEFAULT;
+      Constants.MIME_JSON + "; charset=" + Constants.CHARSET_DEFAULT;
 }
 
 HTTPBinary02.prototype.emit = function(cloudevent){
@@ -23,17 +23,24 @@ HTTPBinary02.prototype.emit = function(cloudevent){
   // Always set stuff in _config
   var _headers = _config["headers"];
 
-  _headers[Constants.HEADER_CONTENT_TYPE] = cloudevent.getContenttype();
+  // OPTIONAL CONTENT TYPE ATTRIBUTE
+  if (cloudevent.getContenttype()) {
+    _headers[Constants.HEADER_CONTENT_TYPE] = cloudevent.getContenttype();
+  }
 
   _headers[Constants.BINARY_HEADERS_02.TYPE] = cloudevent.getType();
   _headers[Constants.BINARY_HEADERS_02.SPEC_VERSION] =
     cloudevent.getSpecversion();
   _headers[Constants.BINARY_HEADERS_02.SOURCE] = cloudevent.getSource();
   _headers[Constants.BINARY_HEADERS_02.ID] = cloudevent.getId();
+
   if(cloudevent.getTime()) {
     _headers[Constants.BINARY_HEADERS_02.TIME] = cloudevent.getTime();
   }
-  _headers[Constants.BINARY_HEADERS_02.SCHEMA_URL] = cloudevent.getSchemaurl();
+
+  if (cloudevent.getSchemaurl()) {
+    _headers[Constants.BINARY_HEADERS_02.SCHEMA_URL] = cloudevent.getSchemaurl();
+  }
 
   // Set the cloudevent payload
   _config["data"] = cloudevent.format().data;

lib/bindings/http/emitter_structured_0_1.js

@@ -3,7 +3,7 @@ var axios = require("axios");
 const Constants = require("./constants.js");
 
 function HTTPStructured(configuration){
-  this.config = configuration;
+  this.config = JSON.parse(JSON.stringify(configuration));
 
   if(!this.config["headers"]){
     this.config["headers"] = {};

lib/bindings/http/emitter_structured_0_2.js

@@ -3,7 +3,7 @@ var axios = require("axios");
 const Constants = require("./constants.js");
 
 function HTTPStructured(configuration){
-  this.config = configuration;
+  this.config = JSON.parse(JSON.stringify(configuration));
 
   if(!this.config["headers"]){
     this.config["headers"] = {};