Add support for http auth

.gitignore

@@ -1,2 +1,3 @@
 /coverage
 /node_modules
+/package-lock.json

handlers/shipElasticsearch.js

@@ -7,6 +7,10 @@ exports.process = function(config) {
     host: config.elasticsearch.host
   };
 
+  if (config.elasticsearch.httpAuth) {
+    esConfig.httpAuth = config.elasticsearch.httpAuth;
+  }
+
   if (config.elasticsearch.useAWS) {
     esConfig.connectionClass = require('http-aws-es');
     esConfig.amazonES = {

index.js

@@ -46,7 +46,12 @@ exports.handler = function(config, event, context, callback) {
     return callback(null, 'Event did not match any mappings.');
   }
 
-  console.log('Running ' + taskNames.length + ' handlers with config:', config);
+
+  _config = JSON.parse(JSON.stringify(config)) // Deep clone object to prevent modifying the real config.httpAuth key
+  if (_config.elasticsearch.httpAuth) {
+    _config.elasticsearch.httpAuth = "*****"
+  }
+  console.log('Running ' + taskNames.length + ' handlers with _config:', _config);
   var tasks = [];
   var processor;
   _.some(taskNames, function(taskName) {

package.json

@@ -6,7 +6,7 @@
   "dependencies": {
     "aws-sdk": "^2.3.18",
     "csv-parse": "^1.1.1",
-    "elasticsearch": "^11.0.1",
+    "elasticsearch": "^13.3.1",
     "http-aws-es": "tphummel/http-aws-es",
     "lodash": "^4.13.1"
   },

test/shipElasticsearch.spec.js

@@ -12,13 +12,41 @@ describe('handler/shipElasticsearch.js', function() {
       handler = require('../handlers/shipElasticsearch');
     });
 
+    it('should allow http auth',
+      function(done) {
+        var config = {
+          elasticsearch: {
+            httpAuth: 'asdf:wut',
+            index: 'index',
+            type: 'type'
+          },
+          data: [
+            {
+              value: '1'
+            },
+            {
+              value: '2'
+            }
+          ],
+          test: 'test'
+        };
+        var es = require('elasticsearch');
+        es.Client = function(config) {
+          assert.strictEqual(config.httpAuth, 'asdf:wut',
+            'httpAuth param provided');
+          done();
+        };
+        handler.process(config);
+      });
+
     it('should split data by the maxChunkSize',
       function(done) {
         var passVal1 = false;
         var passVal2 = false;
         var es = require('elasticsearch');
         es.Client = function(config) {
           assert.strictEqual(config.host, 'http://mock', 'host param provided');
+          assert.strictEqual(config.httpAuth, undefined, 'httpAuth param not provided');
           return {
             bulk: function(params, callback) {
               if (params.body[1].value === '1') {