Checking optional attributes

Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
Fabio José 2018-12-17 21:34:25 -02:00
parent d866d6d3db
commit e025138a3f
1 changed files with 8 additions and 5 deletions

View File

@ -15,15 +15,18 @@ HTTPBinary.prototype.emit = function(cloudevent){
// Always set stuff in _config
var _headers = _config["headers"];
_headers["Content-Type"] = cloudevent.getContenttype();
_headers["CE-EventType"] = cloudevent.getType();
_headers["CE-EventTypeVersion"] = cloudevent.getEventTypeVersion();
if(cloudevent.getContenttype())
_headers["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();
_headers["CE-EventTime"] = cloudevent.getTime();
if(cloudevent.getTime())
_headers["CE-EventTime"] = cloudevent.getTime();
_headers["CE-SchemaURL"] = cloudevent.getSchemaurl();
// Set the cloudevent payload