elasticsearch-aws-tunneling
Advanced tools
Comparing version 1.0.0-alpha.28 to 1.0.0-alpha.29
25
index.js
@@ -11,5 +11,8 @@ 'use strict' | ||
*/ | ||
let ElasticsearchClient | ||
let Client | ||
module.exports.ElasticsearchClient = () => ElasticsearchClient | ||
/** | ||
* @type {() => import('@elastic/elasticsearch').Client} | ||
*/ | ||
module.exports.Client = () => Client | ||
@@ -20,5 +23,4 @@ /** | ||
* @async | ||
* @callback | ||
*/ | ||
module.exports.init = (options, callback = null) => { | ||
module.exports.init = options => { | ||
@@ -32,3 +34,3 @@ const environmentValidation = JOI | ||
.validate(options, { allowUnknown: true }) | ||
if (environmentValidation.error) return Promise.reject(environmentValidation.error) | ||
if (environmentValidation.error) throw environmentValidation.error | ||
@@ -43,14 +45,9 @@ const connect = options.env === 'local' | ||
ElasticsearchClient = client | ||
DEBUG(message) | ||
return callback | ||
? callback(null, message) | ||
: Promise.resolve(message) | ||
Client = client | ||
return message | ||
} | ||
) | ||
.catch( | ||
error => callback | ||
? callback(error) | ||
: Promise.resolve(error) | ||
) | ||
} | ||
@@ -57,0 +54,0 @@ |
{ | ||
"name": "elasticsearch-aws-tunneling", | ||
"version": "1.0.0-alpha.28", | ||
"version": "1.0.0-alpha.29", | ||
"description": "Elasticsearch wich allow SSH tunneling into a AWS Elasticsearch VPC by going through a EC2 instance hosted in the same VPC.", | ||
@@ -26,3 +26,3 @@ "main": "index.js", | ||
}, | ||
"gitHead": "51f3c764dd07106c332ddf3084d0ad9dafd0c3a8" | ||
"gitHead": "fb93220d70e2dbac5030e2345e872a6b58dd0213" | ||
} |
12066
230