From 391f2286ce6248e4ccbc66d0d40605ff0a16ea41 Mon Sep 17 00:00:00 2001
From: spalger <email@spalger.com>
Date: Mon, 16 Nov 2015 17:36:15 -0600
Subject: [PATCH] [transport] set the content-type header based on the
 serialization type

---
 src/lib/serializers/json.js |  4 ++++
 src/lib/transport.js        | 21 ++++++++++++++++-----
 2 files changed, 20 insertions(+), 5 deletions(-)

diff --git a/src/lib/serializers/json.js b/src/lib/serializers/json.js
index 47799b9e5..03025cba0 100755
--- a/src/lib/serializers/json.js
+++ b/src/lib/serializers/json.js
@@ -28,6 +28,8 @@ Json.prototype.serialize = function (val, replacer, spaces) {
   }
 };
 
+Json.prototype.serialize.contentType = 'application/json';
+
 /**
  * Parse a JSON string, if it is already parsed it is ignored
  * @param  {String} str - the string to parse
@@ -57,3 +59,5 @@ Json.prototype.bulkBody = function (val) {
 
   return body;
 };
+
+Json.prototype.bulkBody.contentType = 'application/x-ldjson';
diff --git a/src/lib/transport.js b/src/lib/transport.js
index dc3062c0e..03e0fb177 100644
--- a/src/lib/transport.js
+++ b/src/lib/transport.js
@@ -136,6 +136,11 @@ Transport.prototype.request = function (params, cb) {
   var ret; // the object returned to the user, might be a promise
   var defer; // the defer object, will be set when we are using promises.
 
+  var body = params.body;
+  var headers = !params.headers ? {} : _.transform(params.headers, function (headers, val, name) {
+    headers[String(name).toLowerCase()] = val;
+  });
+
   self.log.debug('starting request', params);
 
   // determine the response based on the presense of a callback
@@ -153,14 +158,20 @@ Transport.prototype.request = function (params, cb) {
     ret.abort = abortRequest;
   }
 
-  if (params.body && params.method === 'GET') {
+  if (body && params.method === 'GET') {
     _.nextTick(respond, new TypeError('Body can not be sent with method "GET"'));
     return ret;
   }
 
   // serialize the body
-  if (params.body) {
-    params.body = self.serializer[params.bulkBody ? 'bulkBody' : 'serialize'](params.body);
+  if (body) {
+    var serializer = self.serializer;
+    var serializeFn = serializer[params.bulkBody ? 'bulkBody' : 'serialize'];
+
+    body = serializeFn.call(serializer, body);
+    if (!headers['content-type']) {
+      headers['content-type'] = serializeFn.contentType;
+    }
   }
 
   if (params.hasOwnProperty('maxRetries')) {
@@ -175,8 +186,8 @@ Transport.prototype.request = function (params, cb) {
     method: params.method,
     path: params.path || '/',
     query: params.query,
-    body: params.body,
-    headers: params.headers
+    body: body,
+    headers: headers
   };
 
   function sendReqWithConnection(err, _connection) {