File Explorer

1'use strict'2const tls = require('tls')3const net = require('net')4const debug = require('debug')('mqttjs:tls')5 6function buildBuilder (mqttClient, opts) {7  opts.port = opts.port || 88838  opts.host = opts.hostname || opts.host || 'localhost'9 10  if (net.isIP(opts.host) === 0) {11    opts.servername = opts.host12  }13 14  opts.rejectUnauthorized = opts.rejectUnauthorized !== false15 16  delete opts.path17 18  debug('port %d host %s rejectUnauthorized %b', opts.port, opts.host, opts.rejectUnauthorized)19 20  const connection = tls.connect(opts)21  /* eslint no-use-before-define: [2, "nofunc"] */22  connection.on('secureConnect', function () {23    if (opts.rejectUnauthorized && !connection.authorized) {24      connection.emit('error', new Error('TLS not authorized'))25    } else {26      connection.removeListener('error', handleTLSerrors)27    }28  })29 30  function handleTLSerrors (err) {31    // How can I get verify this error is a tls error?32    if (opts.rejectUnauthorized) {33      mqttClient.emit('error', err)34    }35 36    // close this connection to match the behaviour of net37    // otherwise all we get is an error from the connection38    // and close event doesn't fire. This is a work around39    // to enable the reconnect code to work the same as with40    // net.createConnection41    connection.end()42  }43 44  connection.on('error', handleTLSerrors)45  return connection46}47 48module.exports = buildBuilder49