move from request to axios (#97)

* move from request to axios

* update moment to 2.29.4

* create instance of axios

* update from axiosIn to axiosInstance fix linting

README.md

@@ -60,6 +60,9 @@ A few notes are worth mentioning regarding the use of the UDP protocol:
 
 
 ## Update log
+**2.1.4**
+- Replace from request to axios
+
 **2.0.4**
 - Add parameter to manage User-agent
 

example.js

@@ -18,7 +18,6 @@ const logger = logzioLogger.createLogger({
     timeout: 1000,
 });
 
-
 logger.log('some testing');
 
 for (let i = 0; i < count; i++) {

lib/axiosInstance.js

@@ -0,0 +1,5 @@
+const axios = require('axios');
+
+const axiosInstance = axios.create();
+
+module.exports = axiosInstance;

lib/logzio-nodejs.js

@@ -1,8 +1,9 @@
-const request = require('request-promise');
 const stringifySafe = require('json-stringify-safe');
 const assign = require('lodash.assign');
 const dgram = require('dgram');
 const zlib = require('zlib');
+const axiosInstance = require('./axiosInstance');
+
 
 const nanoSecDigits = 9;
 
@@ -78,6 +79,17 @@ class LogzioLogger {
 
         this.protocol = protocol;
         this._setProtocol(port);
+        this.url = `${this.protocol}://${this.host}:${this.port}?token=${this.token}`;
+
+        this.axiosInstance = axiosInstance;
+        this.axiosInstance.defaults.headers.post = {
+            Host: this.host,
+            Accept: '*/*',
+            'Content-Type': 'text/plain',
+            ...(this.setUserAgent ? { 'user-agent': USER_AGENT } : {}),
+            ...(this.compress ? { 'content-encoding': 'gzip' } : {}),
+
+        };
 
         /*
           Callback method executed on each bulk of messages sent to logzio.
@@ -92,7 +104,6 @@ class LogzioLogger {
         this.timeout = timeout;
 
         // build the url for logging
-        this.url = `${this.protocol}://${this.host}:${this.port}?token=${this.token}`;
 
         this.messages = [];
         this.bulkId = 1;
@@ -254,44 +265,33 @@ class LogzioLogger {
 
     _send(bulk) {
         const body = messagesToBody(bulk.msgs);
-        const options = {
-            uri: this.url,
-            headers: {
-                host: this.host,
-                accept: '*/*',
-                'content-type': 'text/plain',
-                ...(this.setUserAgent ? { 'user-agent': USER_AGENT } : {}),
-            },
-        };
 
         if (typeof this.timeout !== 'undefined') {
-            options.timeout = this.timeout;
+            this.axiosInstance.defaults.timeout = this.timeout;
         }
 
         return Promise.resolve()
             .then(() => {
                 if (this.compress) {
-                    options.headers['content-encoding'] = 'gzip';
                     return zlibPromised(body);
                 }
                 return body;
             })
             .then((finalBody) => {
-                options.body = finalBody;
-                this._tryToSend(options, bulk);
+                this._tryToSend(finalBody, bulk);
             });
     }
 
-    _tryToSend(options, bulk) {
-        this._debug(`Sending bulk of ${bulk.msgs.length} logs`)
-        return request.post(options)
+    _tryToSend(body, bulk) {
+        this._debug(`Sending bulk of ${bulk.msgs.length} logs`);
+        return this.axiosInstance.post(this.url, body)
             .then(() => {
                 this._debug(`Bulk #${bulk.id} - sent successfully`);
                 this.callback();
             })
             .catch((err) => {
                 // In rare cases server is busy
-                const errorCode = err.cause && err.cause.code;
+                const errorCode = err.code;
                 if (UNAVAILABLE_CODES.includes(errorCode)) {
                     if (bulk.attemptNumber >= this.numberOfRetries) {
                         return this.callback(new Error(`Failed after ${bulk.attemptNumber} retries on error = ${err}`), bulk);