Minor changes

Author: Igor Drobiazko

lib/actions/write.js

@@ -1,7 +1,6 @@
 const request = require('request-promise');
 const co = require('co');
 const csv = require('csv');
-const _ = require('lodash');
 const messages = require('elasticio-node').messages;
 const client = require('elasticio-rest-node')();
 
@@ -27,10 +26,7 @@ function init() {
         let putUrl = signedUrl.put_url;
         console.log('CSV file to be uploaded file to uri=%s', putUrl);
 
-        stringifier
-            .pipe(request.put({
-                'uri': putUrl
-            }));
+        stringifier.pipe(request.put(putUrl));
     });
 }
 
@@ -46,6 +42,7 @@ function processAction(msg) {
         co(function* gen() {
             console.log('The resulting CSV file contains %s rows', rowCount);
             stringifier.end();
+
             const messageToEmit = messages.newMessageWithBody({
                 rowCount
             });