From 0907b7b8b7bd152b972134c92b9f51b841ce5d6e Mon Sep 17 00:00:00 2001 From: Pavel Binar Date: Thu, 27 Jun 2019 14:01:19 +0200 Subject: [PATCH] Removed unnecessary assert causing assertion error --- index.js | 31 ++++++++++++++++++++----------- 1 file changed, 20 insertions(+), 11 deletions(-) diff --git a/index.js b/index.js index 3ee9abc..fcd1cca 100644 --- a/index.js +++ b/index.js @@ -157,18 +157,27 @@ TunnelingAgent.prototype.createSocket = function createSocket(options, cb) { socket.removeAllListeners() if (res.statusCode === 200) { - assert.equal(head.length, 0) - debug('tunneling connection has established') - self.sockets[self.sockets.indexOf(placeholder)] = socket - cb(socket) - } else { - debug('tunneling socket could not be established, statusCode=%d', res.statusCode) - var error = new Error('tunneling socket could not be established, ' + 'statusCode=' + res.statusCode) - error.code = 'ECONNRESET' - options.request.emit('error', error) - self.removeSocket(placeholder) + if(head.length === 0){ + debug('tunneling connection has established') + self.sockets[self.sockets.indexOf(placeholder)] = socket + cb(socket) + } + else { + debug('tunneling socket could not be established, statusCode=%d', res.statusCode) + var error = new Error('tunneling socket could not be established - head length is not 0, ' + 'statusCode=' + res.statusCode) + error.code = 'ECONNRESET' + options.request.emit('error', error) + self.removeSocket(placeholder) + } + + } else { + debug('tunneling socket could not be established, statusCode=%d', res.statusCode) + var error = new Error('tunneling socket could not be established, ' + 'statusCode=' + res.statusCode) + error.code = 'ECONNRESET' + options.request.emit('error', error) + self.removeSocket(placeholder) + } } - } function onError(cause) { connectReq.removeAllListeners()