habsi/elasticsearch-js
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove Node.js v8 support (#1402)

Browse Source
This commit is contained in:
Tomas Della Vedova
2021-02-19 08:27:20 +01:00
committed by delvedor
parent ae3bb7031f
commit 28370acf49
43 changed files with 246 additions and 290 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
test/utils/MockConnection.js
View File

@ -30,7 +30,7 @@ const intoStream = require('into-stream')
class MockConnection extends Connection {
request (params, callback) {
var aborted = false
let aborted = false
const stream = intoStream(JSON.stringify({ hello: 'world' }))
stream.statusCode = setStatusCode(params.path)
stream.headers = {
@ -54,7 +54,7 @@ class MockConnection extends Connection {
class MockConnectionTimeout extends Connection {
request (params, callback) {
var aborted = false
let aborted = false
process.nextTick(() => {
if (!aborted) {
callback(new TimeoutError('Request timed out', params), null)
@ -70,7 +70,7 @@ class MockConnectionTimeout extends Connection {
class MockConnectionError extends Connection {
request (params, callback) {
var aborted = false
let aborted = false
process.nextTick(() => {
if (!aborted) {
callback(new ConnectionError('Kaboom'), null)
@ -86,7 +86,7 @@ class MockConnectionError extends Connection {
class MockConnectionSniff extends Connection {
request (params, callback) {
var aborted = false
let aborted = false
const sniffResult = {
nodes: {
'node-1': {
@ -133,11 +133,11 @@ function buildMockConnection (opts) {
class MockConnection extends Connection {
request (params, callback) {
var { body, statusCode } = opts.onRequest(params)
let { body, statusCode } = opts.onRequest(params)
if (typeof body !== 'string') {
body = JSON.stringify(body)
}
var aborted = false
let aborted = false
const stream = intoStream(body)
stream.statusCode = statusCode || 200
stream.headers = {