File Explorer

1'use strict'2 3const MqttClient = require('../client')4const Store = require('../store')5const url = require('url')6const xtend = require('xtend')7const debug = require('debug')('mqttjs')8 9const protocols = {}10 11// eslint-disable-next-line camelcase12if ((typeof process !== 'undefined' && process.title !== 'browser') || typeof __webpack_require__ !== 'function') {13  protocols.mqtt = require('./tcp')14  protocols.tcp = require('./tcp')15  protocols.ssl = require('./tls')16  protocols.tls = require('./tls')17  protocols.mqtts = require('./tls')18} else {19  protocols.wx = require('./wx')20  protocols.wxs = require('./wx')21 22  protocols.ali = require('./ali')23  protocols.alis = require('./ali')24}25 26protocols.ws = require('./ws')27protocols.wss = require('./ws')28 29/**30 * Parse the auth attribute and merge username and password in the options object.31 *32 * @param {Object} [opts] option object33 */34function parseAuthOptions (opts) {35  let matches36  if (opts.auth) {37    matches = opts.auth.match(/^(.+):(.+)$/)38    if (matches) {39      opts.username = matches[1]40      opts.password = matches[2]41    } else {42      opts.username = opts.auth43    }44  }45}46 47/**48 * connect - connect to an MQTT broker.49 *50 * @param {String} [brokerUrl] - url of the broker, optional51 * @param {Object} opts - see MqttClient#constructor52 */53function connect (brokerUrl, opts) {54  debug('connecting to an MQTT broker...')55  if ((typeof brokerUrl === 'object') && !opts) {56    opts = brokerUrl57    brokerUrl = null58  }59 60  opts = opts || {}61 62  if (brokerUrl) {63    // eslint-disable-next-line64    const parsed = url.parse(brokerUrl, true)65    if (parsed.port != null) {66      parsed.port = Number(parsed.port)67    }68 69    opts = xtend(parsed, opts)70 71    if (opts.protocol === null) {72      throw new Error('Missing protocol')73    }74 75    opts.protocol = opts.protocol.replace(/:$/, '')76  }77 78  // merge in the auth options if supplied79  parseAuthOptions(opts)80 81  // support clientId passed in the query string of the url82  if (opts.query && typeof opts.query.clientId === 'string') {83    opts.clientId = opts.query.clientId84  }85 86  if (opts.cert && opts.key) {87    if (opts.protocol) {88      if (['mqtts', 'wss', 'wxs', 'alis'].indexOf(opts.protocol) === -1) {89        switch (opts.protocol) {90          case 'mqtt':91            opts.protocol = 'mqtts'92            break93          case 'ws':94            opts.protocol = 'wss'95            break96          case 'wx':97            opts.protocol = 'wxs'98            break99          case 'ali':100            opts.protocol = 'alis'101            break102          default:103            throw new Error('Unknown protocol for secure connection: "' + opts.protocol + '"!')104        }105      }106    } else {107      // A cert and key was provided, however no protocol was specified, so we will throw an error.108      throw new Error('Missing secure protocol key')109    }110  }111 112  if (!protocols[opts.protocol]) {113    const isSecure = ['mqtts', 'wss'].indexOf(opts.protocol) !== -1114    opts.protocol = [115      'mqtt',116      'mqtts',117      'ws',118      'wss',119      'wx',120      'wxs',121      'ali',122      'alis'123    ].filter(function (key, index) {124      if (isSecure && index % 2 === 0) {125        // Skip insecure protocols when requesting a secure one.126        return false127      }128      return (typeof protocols[key] === 'function')129    })[0]130  }131 132  if (opts.clean === false && !opts.clientId) {133    throw new Error('Missing clientId for unclean clients')134  }135 136  if (opts.protocol) {137    opts.defaultProtocol = opts.protocol138  }139 140  function wrapper (client) {141    if (opts.servers) {142      if (!client._reconnectCount || client._reconnectCount === opts.servers.length) {143        client._reconnectCount = 0144      }145 146      opts.host = opts.servers[client._reconnectCount].host147      opts.port = opts.servers[client._reconnectCount].port148      opts.protocol = (!opts.servers[client._reconnectCount].protocol ? opts.defaultProtocol : opts.servers[client._reconnectCount].protocol)149      opts.hostname = opts.host150 151      client._reconnectCount++152    }153 154    debug('calling streambuilder for', opts.protocol)155    return protocols[opts.protocol](client, opts)156  }157  const client = new MqttClient(wrapper, opts)158  client.on('error', function () { /* Automatically set up client error handling */ })159  return client160}161 162module.exports = connect163module.exports.connect = connect164module.exports.MqttClient = MqttClient165module.exports.Store = Store166