mqtt.js源码2
由于代码过长，博客不支持，故分为了几个部分,这部分是续接源码1的
d.gs = function (dscr, get, set /*, options*/ ) {
var c, e, options, desc;if (typeof dscr !== 'string') {
options = set;set = get;get = dscr;dscr = null;} else {
options = arguments[3];}if (get == null) {
get = undefined;} else if (!isCallable(get)) {
options = get;get = set = undefined;} else if (set == null) {
set = undefined;} else if (!isCallable(set)) {
options = set;set = undefined;}if (dscr == null) {
c = true;e = false;} else {
c = contains.call(dscr, 'c');e = contains.call(dscr, 'e');}desc = {
get: get,set: set,configurable: c,enumerable: e};return !options ? desc : assign(normalizeOpts(options), desc);};}, {
"es5-ext/object/assign": 36,"es5-ext/object/is-callable": 42,"es5-ext/object/normalize-options": 49,"es5-ext/string/#/contains": 56}],17: [function (require, module, exports) {
(function (process, Buffer) {
var stream = require('readable-stream')var eos = require('end-of-stream')var inherits = require('inherits')var shift = require('stream-shift')var SIGNAL_FLUSH = (Buffer.from && Buffer.from !== Uint8Array.from) ?Buffer.from([0]) :new Buffer([0])var onuncork = function (self, fn) {
if (self._corked) self.once('uncork', fn)else fn()}var autoDestroy = function (self, err) {
if (self._autoDestroy) self.destroy(err)}var destroyer = function (self, end) {
return function (err) {
if (err) autoDestroy(self, err.message === 'premature close' ? null : err)else if (end && !self._ended) self.end()}}var end = function (ws, fn) {
if (!ws) return fn()if (ws._writableState && ws._writableState.finished) return fn()if (ws._writableState) return ws.end(fn)ws.end()fn()}var toStreams2 = function (rs) {
return new(stream.Readable)({
objectMode: true,highWaterMark: 16}).wrap(rs)}var Duplexify = function (writable, readable, opts) {
if (!(this instanceof Duplexify)) return new Duplexify(writable, readable, opts)stream.Duplex.call(this, opts)this._writable = nullthis._readable = nullthis._readable2 = nullthis._autoDestroy = !opts || opts.autoDestroy !== falsethis._forwardDestroy = !opts || opts.destroy !== falsethis._forwardEnd = !opts || opts.end !== falsethis._corked = 1 // start corkedthis._ondrain = nullthis._drained = falsethis._forwarding = falsethis._unwrite = nullthis._unread = nullthis._ended = falsethis.destroyed = falseif (writable) this.setWritable(writable)if (readable) this.setReadable(readable)}inherits(Duplexify, stream.Duplex)Duplexify.obj = function (writable, readable, opts) {
if (!opts) opts = {
}opts.objectMode = trueopts.highWaterMark = 16return new Duplexify(writable, readable, opts)}Duplexify.prototype.cork = function () {
if (++this._corked === 1) this.emit('cork')}Duplexify.prototype.uncork = function () {
if (this._corked && --this._corked === 0) this.emit('uncork')}Duplexify.prototype.setWritable = function (writable) {
if (this._unwrite) this._unwrite()if (this.destroyed) {
if (writable && writable.destroy) writable.destroy()return}if (writable === null || writable === false) {
this.end()return}var self = thisvar unend = eos(writable, {
writable: true,readable: false}, destroyer(this, this._forwardEnd))var ondrain = function () {
var ondrain = self._ondrainself._ondrain = nullif (ondrain) ondrain()}var clear = function () {
self._writable.removeListener('drain', ondrain)unend()}if (this._unwrite) process.nextTick(ondrain) // force a drain on stream reset to avoid livelocksthis._writable = writablethis._writable.on('drain', ondrain)this._unwrite = clearthis.uncork() // always uncork setWritable}Duplexify.prototype.setReadable = function (readable) {
if (this._unread) this._unread()if (this.destroyed) {
if (readable && readable.destroy) readable.destroy()return}if (readable === null || readable === false) {
this.push(null)this.resume()return}var self = thisvar unend = eos(readable, {
writable: false,readable: true}, destroyer(this))var onreadable = function () {
self._forward()}var onend = function () {
self.push(null)}var clear = function () {
self._readable2.removeListener('readable', onreadable)self._readable2.removeListener('end', onend)unend()}this._drained = truethis._readable = readablethis._readable2 = readable._readableState ? readable : toStreams2(readable)this._readable2.on('readable', onreadable)this._readable2.on('end', onend)this._unread = clearthis._forward()}Duplexify.prototype._read = function () {
this._drained = truethis._forward()}Duplexify.prototype._forward = function () {
if (this._forwarding || !this._readable2 || !this._drained) returnthis._forwarding = truevar datawhile (this._drained && (data = shift(this._readable2)) !== null) {
if (this.destroyed) continuethis._drained = this.push(data)}this._forwarding = false}Duplexify.prototype.destroy = function (err) {
if (this.destroyed) returnthis.destroyed = truevar self = thisprocess.nextTick(function () {
self._destroy(err)})}Duplexify.prototype._destroy = function (err) {
if (err) {
var ondrain = this._ondrainthis._ondrain = nullif (ondrain) ondrain(err)else this.emit('error', err)}if (this._forwardDestroy) {
if (this._readable && this._readable.destroy) this._readable.destroy()if (this._writable && this._writable.destroy) this._writable.destroy()}this.emit('close')}Duplexify.prototype._write = function (data, enc, cb) {
if (this.destroyed) return cb()if (this._corked) return onuncork(this, this._write.bind(this, data, enc, cb))if (data === SIGNAL_FLUSH) return this._finish(cb)if (!this._writable) return cb()if (this._writable.write(data) === false) this._ondrain = cbelse cb()}Duplexify.prototype._finish = function (cb) {
var self = thisthis.emit('preend')onuncork(this, function () {
end(self._forwardEnd && self._writable, function () {
// haxx to not emit prefinish twiceif (self._writableState.prefinished === false) self._writableState.prefinished = trueself.emit('prefinish')onuncork(self, cb)})})}Duplexify.prototype.end = function (data, enc, cb) {
if (typeof data === 'function') return this.end(null, null, data)if (typeof enc === 'function') return this.end(data, null, enc)this._ended = trueif (data) this.write(data)if (!this._writableState.ending) this.write(SIGNAL_FLUSH)return stream.Writable.prototype.end.call(this, cb)}module.exports = Duplexify}).call(this, require('_process'), require("buffer").Buffer)}, {
"_process": 92,"buffer": 12,"end-of-stream": 18,"inherits": 80,"readable-stream": 108,"stream-shift": 111}],18: [function (require, module, exports) {
var once = require('once');var noop = function () {
};var isRequest = function (stream) {
return stream.setHeader && typeof stream.abort === 'function';};var isChildProcess = function (stream) {
return stream.stdio && Array.isArray(stream.stdio) && stream.stdio.length === 3};var eos = function (stream, opts, callback) {
if (typeof opts === 'function') return eos(stream, null, opts);if (!opts) opts = {
};callback = once(callback || noop);var ws = stream._writableState;var rs = stream._readableState;var readable = opts.readable || (opts.readable !== false && stream.readable);var writable = opts.writable || (opts.writable !== false && stream.writable);var onlegacyfinish = function () {
if (!stream.writable) onfinish();};var onfinish = function () {
writable = false;if (!readable) callback.call(stream);};var onend = function () {
readable = false;if (!writable) callback.call(stream);};var onexit = function (exitCode) {
callback.call(stream, exitCode ? new Error('exited with error code: ' + exitCode) : null);};var onerror = function (err) {
callback.call(stream, err);};var onclose = function () {
if (readable && !(rs && rs.ended)) return callback.call(stream, new Error('premature close'));if (writable && !(ws && ws.ended)) return callback.call(stream, new Error('premature close'));};var onrequest = function () {
stream.req.on('finish', onfinish);};if (isRequest(stream)) {
stream.on('complete', onfinish);stream.on('abort', onclose);if (stream.req) onrequest();else stream.on('request', onrequest);} else if (writable && !ws) {
// legacy streamsstream.on('end', onlegacyfinish);stream.on('close', onlegacyfinish);}if (isChildProcess(stream)) stream.on('exit', onexit);stream.on('end', onend);stream.on('finish', onfinish);if (opts.error !== false) stream.on('error', onerror);stream.on('close', onclose);return function () {
stream.removeListener('complete', onfinish);stream.removeListener('abort', onclose);stream.removeListener('request', onrequest);if (stream.req) stream.req.removeListener('finish', onfinish);stream.removeListener('end', onlegacyfinish);stream.removeListener('close', onlegacyfinish);stream.removeListener('finish', onfinish);stream.removeListener('exit', onexit);stream.removeListener('end', onend);stream.removeListener('error', onerror);stream.removeListener('close', onclose);};};module.exports = eos;}, {
"once": 90}],19: [function (require, module, exports) {
// Inspired by Google Closure:// http://closure-library.googlecode.com/svn/docs/// closure_goog_array_array.js.html#goog.array.clear"use strict";var value = require("../../object/valid-value");module.exports = function () {
value(this).length = 0;return this;};}, {
"../../object/valid-value": 55}],20: [function (require, module, exports) {
"use strict";var numberIsNaN = require("../../number/is-nan"),toPosInt = require("../../number/to-pos-integer"),value = require("../../object/valid-value"),indexOf = Array.prototype.indexOf,objHasOwnProperty = Object.prototype.hasOwnProperty,abs = Math.abs,floor = Math.floor;module.exports = function (searchElement /*, fromIndex*/ ) {
var i, length, fromIndex, val;if (!numberIsNaN(searchElement)) return indexOf.apply(this, arguments);length = toPosInt(value(this).length);fromIndex = arguments[1];if (isNaN(fromIndex)) fromIndex = 0;else if (fromIndex >= 0) fromIndex = floor(fromIndex);else fromIndex = toPosInt(this.length) - floor(abs(fromIndex));for (i = fromIndex; i < length; ++i) {
if (objHasOwnProperty.call(this, i)) {
val = this[i];if (numberIsNaN(val)) return i; // Jslint: ignore}}return -1;};}, {
"../../number/is-nan": 30,"../../number/to-pos-integer": 34,"../../object/valid-value": 55}],21: [function (require, module, exports) {
"use strict";module.exports = require("./is-implemented")() ?Array.from :require("./shim");}, {
"./is-implemented": 22,"./shim": 23}],22: [function (require, module, exports) {
"use strict";module.exports = function () {
var from = Array.from,arr, result;if (typeof from !== "function") return false;arr = ["raz", "dwa"];result = from(arr);return Boolean(result && (result !== arr) && (result[1] === "dwa"));};}, {
}],23: [function (require, module, exports) {
"use strict";var iteratorSymbol = require("es6-symbol").iterator,isArguments = require("../../function/is-arguments"),isFunction = require("../../function/is-function"),toPosInt = require("../../number/to-pos-integer"),callable = require("../../object/valid-callable"),validValue = require("../../object/valid-value"),isValue = require("../../object/is-value"),isString = require("../../string/is-string"),isArray = Array.isArray,call = Function.prototype.call,desc = {
configurable: true,enumerable: true,writable: true,value: null},defineProperty = Object.defineProperty;// eslint-disable-next-line complexitymodule.exports = function (arrayLike /*, mapFn, thisArg*/ ) {
var mapFn = arguments[1],thisArg = arguments[2],Context, i, j, arr, length, code, iterator, result, getIterator, value;arrayLike = Object(validValue(arrayLike));if (isValue(mapFn)) callable(mapFn);if (!this || this === Array || !isFunction(this)) {
// Result: Plain arrayif (!mapFn) {
if (isArguments(arrayLike)) {
// Source: Argumentslength = arrayLike.length;if (length !== 1) return Array.apply(null, arrayLike);arr = new Array(1);arr[0] = arrayLike[0];return arr;}if (isArray(arrayLike)) {
// Source: Arrayarr = new Array(length = arrayLike.length);for (i = 0; i < length; ++i) arr[i] = arrayLike[i];return arr;}}arr = [];} else {
// Result: Non plain arrayContext = this;}if (!isArray(arrayLike)) {
if ((getIterator = arrayLike[iteratorSymbol]) !== undefined) {
// Source: Iteratoriterator = callable(getIterator).call(arrayLike);if (Context) arr = new Context();result = iterator.next();i = 0;while (!result.done) {
value = mapFn ? call.call(mapFn, thisArg, result.value, i) : result.value;if (Context) {
desc.value = value;defineProperty(arr, i, desc);} else {
arr[i] = value;}result = iterator.next();++i;}length = i;} else if (isString(arrayLike)) {
// Source: Stringlength = arrayLike.length;if (Context) arr = new Context();for (i = 0, j = 0; i < length; ++i) {
value = arrayLike[i];if (i + 1 < length) {
code = value.charCodeAt(0);// eslint-disable-next-line max-depthif (code >= 0xd800 && code <= 0xdbff) value += arrayLike[++i];}value = mapFn ? call.call(mapFn, thisArg, value, j) : value;if (Context) {
desc.value = value;defineProperty(arr, j, desc);} else {
arr[j] = value;}++j;}length = j;}}if (length === undefined) {
// Source: array or array-likelength = toPosInt(arrayLike.length);if (Context) arr = new Context(length);for (i = 0; i < length; ++i) {
value = mapFn ? call.call(mapFn, thisArg, arrayLike[i], i) : arrayLike[i];if (Context) {
desc.value = value;defineProperty(arr, i, desc);} else {
arr[i] = value;}}}if (Context) {
desc.value = null;arr.length = length;}return arr;};}, {
"../../function/is-arguments": 24,"../../function/is-function": 25,"../../number/to-pos-integer": 34,"../../object/is-value": 44,"../../object/valid-callable": 54,"../../object/valid-value": 55,"../../string/is-string": 59,"es6-symbol": 73}],24: [function (require, module, exports) {
"use strict";var objToString = Object.prototype.toString,id = objToString.call((function () {
return arguments;})());module.exports = function (value) {
return objToString.call(value) === id;};}, {
}],25: [function (require, module, exports) {
"use strict";var objToString = Object.prototype.toString,id = objToString.call(require("./noop"));module.exports = function (value) {
return typeof value === "function" && objToString.call(value) === id;};}, {
"./noop": 26}],26: [function (require, module, exports) {
"use strict";// eslint-disable-next-line no-empty-functionmodule.exports = function () {
};}, {
}],27: [function (require, module, exports) {
"use strict";module.exports = require("./is-implemented")() ?Math.sign :require("./shim");}, {
"./is-implemented": 28,"./shim": 29}],28: [function (require, module, exports) {
"use strict";module.exports = function () {
var sign = Math.sign;if (typeof sign !== "function") return false;return (sign(10) === 1) && (sign(-20) === -1);};}, {
}],29: [function (require, module, exports) {
"use strict";module.exports = function (value) {
value = Number(value);if (isNaN(value) || (value === 0)) return value;return value > 0 ? 1 : -1;};}, {
}],30: [function (require, module, exports) {
"use strict";module.exports = require("./is-implemented")() ?Number.isNaN :require("./shim");}, {
"./is-implemented": 31,"./shim": 32}],31: [function (require, module, exports) {
"use strict";module.exports = function () {
var numberIsNaN = Number.isNaN;if (typeof numberIsNaN !== "function") return false;return !numberIsNaN({
}) && numberIsNaN(NaN) && !numberIsNaN(34);};}, {
}],32: [function (require, module, exports) {
"use strict";module.exports = function (value) {
// eslint-disable-next-line no-self-comparereturn value !== value;};}, {
}],33: [function (require, module, exports) {
"use strict";var sign = require("../math/sign"),abs = Math.abs,floor = Math.floor;module.exports = function (value) {
if (isNaN(value)) return 0;value = Number(value);if ((value === 0) || !isFinite(value)) return value;return sign(value) * floor(abs(value));};}, {
"../math/sign": 27}],34: [function (require, module, exports) {
"use strict";var toInteger = require("./to-integer"),max = Math.max;module.exports = function (value) {
return max(0, toInteger(value));};}, {
"./to-integer": 33}],35: [function (require, module, exports) {
// Internal method, used by iteration functions.// Calls a function for each key-value pair found in object// Optionally takes compareFn to iterate object in specific order"use strict";var callable = require("./valid-callable"),value = require("./valid-value"),bind = Function.prototype.bind,call = Function.prototype.call,keys = Object.keys,objPropertyIsEnumerable = Object.prototype.propertyIsEnumerable;module.exports = function (method, defVal) {
return function (obj, cb /*, thisArg, compareFn*/ ) {
var list, thisArg = arguments[2],compareFn = arguments[3];obj = Object(value(obj));callable(cb);list = keys(obj);if (compareFn) {
list.sort(typeof compareFn === "function" ? bind.call(compareFn, obj) : undefined);}if (typeof method !== "function") method = list[method];return call.call(method, list, function (key, index) {
if (!objPropertyIsEnumerable.call(obj, key)) return defVal;return call.call(cb, thisArg, obj[key], key, obj, index);});};};}, {
"./valid-callable": 54,"./valid-value": 55}],36: [function (require, module, exports) {
"use strict";module.exports = require("./is-implemented")() ?Object.assign :require("./shim");}, {
"./is-implemented": 37,"./shim": 38}],37: [function (require, module, exports) {
"use strict";module.exports = function () {
var assign = Object.assign,obj;if (typeof assign !== "function") return false;obj = {
foo: "raz"};assign(obj, {
bar: "dwa"}, {
trzy: "trzy"});return (obj.foo + obj.bar + obj.trzy) === "razdwatrzy";};}, {
}],38: [function (require, module, exports) {
"use strict";var keys = require("../keys"),value = require("../valid-value"),max = Math.max;module.exports = function (dest, src /*, …srcn*/ ) {
var error, i, length = max(arguments.length, 2),assign;dest = Object(value(dest));assign = function (key) {
try {
dest[key] = src[key];} catch (e) {
if (!error) error = e;}};for (i = 1; i < length; ++i) {
src = arguments[i];keys(src).forEach(assign);}if (error !== undefined) throw error;return dest;};}, {
"../keys": 45,"../valid-value": 55}],39: [function (require, module, exports) {
"use strict";var aFrom = require("../array/from"),assign = require("./assign"),value = require("./valid-value");module.exports = function (obj /*, propertyNames, options*/ ) {
var copy = Object(value(obj)),propertyNames = arguments[1],options = Object(arguments[2]);if (copy !== obj && !propertyNames) return copy;var result = {
};if (propertyNames) {
aFrom(propertyNames, function (propertyName) {
if (options.ensure || propertyName in obj) result[propertyName] = obj[propertyName];});} else {
assign(result, obj);}return result;};}, {
"../array/from": 21,"./assign": 36,"./valid-value": 55}],40: [function (require, module, exports) {
// Workaround for http://code.google.com/p/v8/issues/detail?id=2804"use strict";var create = Object.create,shim;if (!require("./set-prototype-of/is-implemented")()) {
shim = require("./set-prototype-of/shim");}module.exports = (function () {
var nullObject, polyProps, desc;if (!shim) return create;if (shim.level !== 1) return create;nullObject = {
};polyProps = {
};desc = {
configurable: false,enumerable: false,writable: true,value: undefined};Object.getOwnPropertyNames(Object.prototype).forEach(function (name) {
if (name === "__proto__") {
polyProps[name] = {
configurable: true,enumerable: false,writable: true,value: undefined};return;}polyProps[name] = desc;});Object.defineProperties(nullObject, polyProps);Object.defineProperty(shim, "nullPolyfill", {
configurable: false,enumerable: false,writable: false,value: nullObject});return function (prototype, props) {
return create(prototype === null ? nullObject : prototype, props);};}());}, {
"./set-prototype-of/is-implemented": 52,"./set-prototype-of/shim": 53}],41: [function (require, module, exports) {
"use strict";module.exports = require("./_iterate")("forEach");}, {
"./_iterate": 35}],42: [function (require, module, exports) {
// Deprecated"use strict";module.exports = function (obj) {
return typeof obj === "function";};}, {
}],43: [function (require, module, exports) {
"use strict";var isValue = require("./is-value");var map = {
function: true,object: true};module.exports = function (value) {
return (isValue(value) && map[typeof value]) || false;};}, {
"./is-value": 44}],44: [function (require, module, exports) {
"use strict";var _undefined = require("../function/noop")(); // Support ES3 enginesmodule.exports = function (val) {
return (val !== _undefined) && (val !== null);};}, {
"../function/noop": 26}],45: [function (require, module, exports) {
"use strict";module.exports = require("./is-implemented")() ? Object.keys : require("./shim");}, {
"./is-implemented": 46,"./shim": 47}],46: [function (require, module, exports) {
"use strict";module.exports = function () {
try {
Object.keys("primitive");return true;} catch (e) {
return false;}};}, {
}],47: [function (require, module, exports) {
"use strict";var isValue = require("../is-value");var keys = Object.keys;module.exports = function (object) {
return keys(isValue(object) ? Object(object) : object);};}, {
"../is-value": 44}],48: [function (require, module, exports) {
"use strict";var callable = require("./valid-callable"),forEach = require("./for-each"),call = Function.prototype.call;module.exports = function (obj, cb /*, thisArg*/ ) {
var result = {
},thisArg = arguments[2];callable(cb);forEach(obj, function (value, key, targetObj, index) {
result[key] = call.call(cb, thisArg, value, key, targetObj, index);});return result;};}, {
"./for-each": 41,"./valid-callable": 54}],49: [function (require, module, exports) {
"use strict";var isValue = require("./is-value");var forEach = Array.prototype.forEach,create = Object.create;var process = function (src, obj) {
var key;for (key in src) obj[key] = src[key];};// eslint-disable-next-line no-unused-varsmodule.exports = function (opts1 /*, …options*/ ) {
var result = create(null);forEach.call(arguments, function (options) {
if (!isValue(options)) return;process(Object(options), result);});return result;};}, {
"./is-value": 44}],50: [function (require, module, exports) {
"use strict";var forEach = Array.prototype.forEach,create = Object.create;// eslint-disable-next-line no-unused-varsmodule.exports = function (arg /*, …args*/ ) {
var set = create(null);forEach.call(arguments, function (name) {
set[name] = true;});return set;};}, {
}],51: [function (require, module, exports) {
"use strict";module.exports = require("./is-implemented")() ?Object.setPrototypeOf :require("./shim");}, {
"./is-implemented": 52,"./shim": 53}],52: [function (require, module, exports) {
"use strict";var create = Object.create,getPrototypeOf = Object.getPrototypeOf,plainObject = {
};module.exports = function ( /* CustomCreate*/ ) {
var setPrototypeOf = Object.setPrototypeOf,customCreate = arguments[0] || create;if (typeof setPrototypeOf !== "function") return false;return getPrototypeOf(setPrototypeOf(customCreate(null), plainObject)) === plainObject;};}, {
}],53: [function (require, module, exports) {
/* eslint no-proto: "off" */// Big thanks to @WebReflection for sorting this out// https://gist.github.com/WebReflection/5593554"use strict";var isObject = require("../is-object"),value = require("../valid-value"),objIsPrototypeOf = Object.prototype.isPrototypeOf,defineProperty = Object.defineProperty,nullDesc = {
configurable: true,enumerable: false,writable: true,value: undefined},validate;validate = function (obj, prototype) {
value(obj);if (prototype === null || isObject(prototype)) return obj;throw new TypeError("Prototype must be null or an object");};module.exports = (function (status) {
var fn, set;if (!status) return null;if (status.level === 2) {
if (status.set) {
set = status.set;fn = function (obj, prototype) {
set.call(validate(obj, prototype), prototype);return obj;};} else {
fn = function (obj, prototype) {
validate(obj, prototype).__proto__ = prototype;return obj;};}} else {
fn = function self(obj, prototype) {
var isNullBase;validate(obj, prototype);isNullBase = objIsPrototypeOf.call(self.nullPolyfill, obj);if (isNullBase) delete self.nullPolyfill.__proto__;if (prototype === null) prototype = self.nullPolyfill;obj.__proto__ = prototype;if (isNullBase) defineProperty(self.nullPolyfill, "__proto__", nullDesc);return obj;};}return Object.defineProperty(fn, "level", {
configurable: false,enumerable: false,writable: false,value: status.level});}((function () {
var tmpObj1 = Object.create(null),tmpObj2 = {
},set, desc = Object.getOwnPropertyDescriptor(Object.prototype, "__proto__");if (desc) {
try {
set = desc.set; // Opera crashes at this pointset.call(tmpObj1, tmpObj2);} catch (ignore) {
}if (Object.getPrototypeOf(tmpObj1) === tmpObj2) return {
set: set,level: 2};}tmpObj1.__proto__ = tmpObj2;if (Object.getPrototypeOf(tmpObj1) === tmpObj2) return {
level: 2};tmpObj1 = {
};tmpObj1.__proto__ = tmpObj2;if (Object.getPrototypeOf(tmpObj1) === tmpObj2) return {
level: 1};return false;})()));require("../create");}, {
"../create": 40,"../is-object": 43,"../valid-value": 55}],54: [function (require, module, exports) {
"use strict";module.exports = function (fn) {
if (typeof fn !== "function") throw new TypeError(fn + " is not a function");return fn;};}, {
}],55: [function (require, module, exports) {
"use strict";var isValue = require("./is-value");module.exports = function (value) {
if (!isValue(value)) throw new TypeError("Cannot use null or undefined");return value;};}, {
"./is-value": 44}],56: [function (require, module, exports) {
"use strict";module.exports = require("./is-implemented")() ?String.prototype.contains :require("./shim");}, {
"./is-implemented": 57,"./shim": 58}],57: [function (require, module, exports) {
"use strict";var str = "razdwatrzy";module.exports = function () {
if (typeof str.contains !== "function") return false;return (str.contains("dwa") === true) && (str.contains("foo") === false);};}, {
}],58: [function (require, module, exports) {
"use strict";var indexOf = String.prototype.indexOf;module.exports = function (searchString /*, position*/ ) {
return indexOf.call(this, searchString, arguments[1]) > -1;};}, {
}],59: [function (require, module, exports) {
"use strict";var objToString = Object.prototype.toString,id = objToString.call("");module.exports = function (value) {
return (typeof value === "string" ||(value &&typeof value === "object" &&(value instanceof String || objToString.call(value) === id)) ||false);};}, {
}],60: [function (require, module, exports) {
"use strict";var setPrototypeOf = require("es5-ext/object/set-prototype-of"),contains = require("es5-ext/string/#/contains"),d = require("d"),Symbol = require("es6-symbol"),Iterator = require("./");var defineProperty = Object.defineProperty,ArrayIterator;ArrayIterator = module.exports = function (arr, kind) {
if (!(this instanceof ArrayIterator)) throw new TypeError("Constructor requires 'new'");Iterator.call(this, arr);if (!kind) kind = "value";else if (contains.call(kind, "key+value")) kind = "key+value";else if (contains.call(kind, "key")) kind = "key";else kind = "value";defineProperty(this, "__kind__", d("", kind));};if (setPrototypeOf) setPrototypeOf(ArrayIterator, Iterator);// Internal %ArrayIteratorPrototype% doesn't expose its constructordelete ArrayIterator.prototype.constructor;ArrayIterator.prototype = Object.create(Iterator.prototype, {
_resolve: d(function (i) {
if (this.__kind__ === "value") return this.__list__[i];if (this.__kind__ === "key+value") return [i, this.__list__[i]];return i;})});defineProperty(ArrayIterator.prototype, Symbol.toStringTag, d("c", "Array Iterator"));}, {
"./": 63,"d": 16,"es5-ext/object/set-prototype-of": 51,"es5-ext/string/#/contains": 56,"es6-symbol": 73}],61: [function (require, module, exports) {
"use strict";var isArguments = require("es5-ext/function/is-arguments"),callable = require("es5-ext/object/valid-callable"),isString = require("es5-ext/string/is-string"),get = require("./get");var isArray = Array.isArray,call = Function.prototype.call,some = Array.prototype.some;module.exports = function (iterable, cb /*, thisArg*/ ) {
var mode, thisArg = arguments[2],result, doBreak, broken, i, length, char, code;if (isArray(iterable) || isArguments(iterable)) mode = "array";else if (isString(iterable)) mode = "string";else iterable = get(iterable);callable(cb);doBreak = function () {
broken = true;};if (mode === "array") {
some.call(iterable, function (value) {
call.call(cb, thisArg, value, doBreak);return broken;});return;}if (mode === "string") {
length = iterable.length;for (i = 0; i < length; ++i) {
char = iterable[i];if (i + 1 < length) {
code = char.charCodeAt(0);if (code >= 0xd800 && code <= 0xdbff) char += iterable[++i];}call.call(cb, thisArg, char, doBreak);if (broken) break;}return;}result = iterable.next();while (!result.done) {
call.call(cb, thisArg, result.value, doBreak);if (broken) return;result = iterable.next();}};}, {
"./get": 62,"es5-ext/function/is-arguments": 24,"es5-ext/object/valid-callable": 54,"es5-ext/string/is-string": 59}],62: [function (require, module, exports) {
"use strict";var isArguments = require("es5-ext/function/is-arguments"),isString = require("es5-ext/string/is-string"),ArrayIterator = require("./array"),StringIterator = require("./string"),iterable = require("./valid-iterable"),iteratorSymbol = require("es6-symbol").iterator;module.exports = function (obj) {
if (typeof iterable(obj)[iteratorSymbol] === "function") return obj[iteratorSymbol]();if (isArguments(obj)) return new ArrayIterator(obj);if (isString(obj)) return new StringIterator(obj);return new ArrayIterator(obj);};}, {
"./array": 60,"./string": 65,"./valid-iterable": 66,"es5-ext/function/is-arguments": 24,"es5-ext/string/is-string": 59,"es6-symbol": 73}],63: [function (require, module, exports) {
"use strict";var clear = require("es5-ext/array/#/clear"),assign = require("es5-ext/object/assign"),callable = require("es5-ext/object/valid-callable"),value = require("es5-ext/object/valid-value"),d = require("d"),autoBind = require("d/auto-bind"),Symbol = require("es6-symbol");var defineProperty = Object.defineProperty,defineProperties = Object.defineProperties,Iterator;module.exports = Iterator = function (list, context) {
if (!(this instanceof Iterator)) throw new TypeError("Constructor requires 'new'");defineProperties(this, {
__list__: d("w", value(list)),__context__: d("w", context),__nextIndex__: d("w", 0)});if (!context) return;callable(context.on);context.on("_add", this._onAdd);context.on("_delete", this._onDelete);context.on("_clear", this._onClear);};// Internal %IteratorPrototype% doesn't expose its constructordelete Iterator.prototype.constructor;defineProperties(Iterator.prototype,assign({
_next: d(function () {
var i;if (!this.__list__) return undefined;if (this.__redo__) {
i = this.__redo__.shift();if (i !== undefined) return i;}if (this.__nextIndex__ < this.__list__.length) return this.__nextIndex__++;this._unBind();return undefined;}),next: d(function () {
return this._createResult(this._next());}),_createResult: d(function (i) {
if (i === undefined) return {
done: true,value: undefined};return {
done: false,value: this._resolve(i)};}),_resolve: d(function (i) {
return this.__list__[i];}),_unBind: d(function () {
this.__list__ = null;delete this.__redo__;if (!this.__context__) return;this.__context__.off("_add", this._onAdd);this.__context__.off("_delete", this._onDelete);this.__context__.off("_clear", this._onClear);this.__context__ = null;}),toString: d(function () {
return "[object " + (this[Symbol.toStringTag] || "Object") + "]";})},autoBind({
_onAdd: d(function (index) {
if (index >= this.__nextIndex__) return;++this.__nextIndex__;if (!this.__redo__) {
defineProperty(this, "__redo__", d("c", [index]));return;}this.__redo__.forEach(function (redo, i) {
if (redo >= index) this.__redo__[i] = ++redo;}, this);this.__redo__.push(index);}),_onDelete: d(function (index) {
var i;if (index >= this.__nextIndex__) return;--this.__nextIndex__;if (!this.__redo__) return;i = this.__redo__.indexOf(index);if (i !== -1) this.__redo__.splice(i, 1);this.__redo__.forEach(function (redo, j) {
if (redo > index) this.__redo__[j] = --redo;}, this);}),_onClear: d(function () {
if (this.__redo__) clear.call(this.__redo__);this.__nextIndex__ = 0;})})));defineProperty(Iterator.prototype,Symbol.iterator,d(function () {
return this;}));}, {
"d": 16,"d/auto-bind": 15,"es5-ext/array/#/clear": 19,"es5-ext/object/assign": 36,"es5-ext/object/valid-callable": 54,"es5-ext/object/valid-value": 55,"es6-symbol": 73}],64: [function (require, module, exports) {
"use strict";var isArguments = require("es5-ext/function/is-arguments"),isValue = require("es5-ext/object/is-value"),isString = require("es5-ext/string/is-string");var iteratorSymbol = require("es6-symbol").iterator,isArray = Array.isArray;module.exports = function (value) {
if (!isValue(value)) return false;if (isArray(value)) return true;if (isString(value)) return true;if (isArguments(value)) return true;return typeof value[iteratorSymbol] === "function";};}, {
"es5-ext/function/is-arguments": 24,"es5-ext/object/is-value": 44,"es5-ext/string/is-string": 59,"es6-symbol": 73}],65: [function (require, module, exports) {
// Thanks @mathiasbynens// http://mathiasbynens.be/notes/javascript-unicode#iterating-over-symbols"use strict";var setPrototypeOf = require("es5-ext/object/set-prototype-of"),d = require("d"),Symbol = require("es6-symbol"),Iterator = require("./");var defineProperty = Object.defineProperty,StringIterator;StringIterator = module.exports = function (str) {
if (!(this instanceof StringIterator)) throw new TypeError("Constructor requires 'new'");str = String(str);Iterator.call(this, str);defineProperty(this, "__length__", d("", str.length));};if (setPrototypeOf) setPrototypeOf(StringIterator, Iterator);// Internal %ArrayIteratorPrototype% doesn't expose its constructordelete StringIterator.prototype.constructor;StringIterator.prototype = Object.create(Iterator.prototype, {
_next: d(function () {
if (!this.__list__) return undefined;if (this.__nextIndex__ < this.__length__) return this.__nextIndex__++;this._unBind();return undefined;}),_resolve: d(function (i) {
var char = this.__list__[i],code;if (this.__nextIndex__ === this.__length__) return char;code = char.charCodeAt(0);if (code >= 0xd800 && code <= 0xdbff) return char + this.__list__[this.__nextIndex__++];return char;})});defineProperty(StringIterator.prototype, Symbol.toStringTag, d("c", "String Iterator"));}, {
"./": 63,"d": 16,"es5-ext/object/set-prototype-of": 51,"es6-symbol": 73}],66: [function (require, module, exports) {
"use strict";var isIterable = require("./is-iterable");module.exports = function (value) {
if (!isIterable(value)) throw new TypeError(value + " is not iterable");return value;};}, {
"./is-iterable": 64}],67: [function (require, module, exports) {
'use strict';module.exports = require('./is-implemented')() ? Map : require('./polyfill');}, {
"./is-implemented": 68,"./polyfill": 72}],68: [function (require, module, exports) {
'use strict';module.exports = function () {
var map, iterator, result;if (typeof Map !== 'function') return false;try {
// WebKit doesn't support arguments and crashesmap = new Map([['raz', 'one'],['dwa', 'two'],['trzy', 'three']]);} catch (e) {
return false;}if (String(map) !== '[object Map]') return false;if (map.size !== 3) return false;if (typeof map.clear !== 'function') return false;if (typeof map.delete !== 'function') return false;if (typeof map.entries !== 'function') return false;if (typeof map.forEach !== 'function') return false;if (typeof map.get !== 'function') return false;if (typeof map.has !== 'function') return false;if (typeof map.keys !== 'function') return false;if (typeof map.set !== 'function') return false;if (typeof map.values !== 'function') return false;iterator = map.entries();result = iterator.next();if (result.done !== false) return false;if (!result.value) return false;if (result.value[0] !== 'raz') return false;if (result.value[1] !== 'one') return false;return true;};}, {
}],69: [function (require, module, exports) {
// Exports true if environment provides native `Map` implementation,// whatever that is.'use strict';module.exports = (function () {
if (typeof Map === 'undefined') return false;return (Object.prototype.toString.call(new Map()) === '[object Map]');}());}, {
}],70: [function (require, module, exports) {
'use strict';module.exports = require('es5-ext/object/primitive-set')('key','value', 'key+value');}, {
"es5-ext/object/primitive-set": 50}],71: [function (require, module, exports) {
'use strict';var setPrototypeOf = require('es5-ext/object/set-prototype-of'),d = require('d'),Iterator = require('es6-iterator'),toStringTagSymbol = require('es6-symbol').toStringTag,kinds = require('./iterator-kinds'),defineProperties = Object.defineProperties,unBind = Iterator.prototype._unBind,MapIterator;MapIterator = module.exports = function (map, kind) {
if (!(this instanceof MapIterator)) return new MapIterator(map, kind);Iterator.call(this, map.__mapKeysData__, map);if (!kind || !kinds[kind]) kind = 'key+value';defineProperties(this, {
__kind__: d('', kind),__values__: d('w', map.__mapValuesData__)});};if (setPrototypeOf) setPrototypeOf(MapIterator, Iterator);MapIterator.prototype = Object.create(Iterator.prototype, {
constructor: d(MapIterator),_resolve: d(function (i) {
if (this.__kind__ === 'value') return this.__values__[i];if (this.__kind__ === 'key') return this.__list__[i];return [this.__list__[i], this.__values__[i]];}),_unBind: d(function () {
this.__values__ = null;unBind.call(this);}),toString: d(function () {
return '[object Map Iterator]';})});Object.defineProperty(MapIterator.prototype, toStringTagSymbol,d('c', 'Map Iterator'));}, {
"./iterator-kinds": 70,"d": 16,"es5-ext/object/set-prototype-of": 51,"es6-iterator": 63,"es6-symbol": 73}],72: [function (require, module, exports) {
'use strict';var clear = require('es5-ext/array/#/clear'),eIndexOf = require('es5-ext/array/#/e-index-of'),setPrototypeOf = require('es5-ext/object/set-prototype-of'),callable = require('es5-ext/object/valid-callable'),validValue = require('es5-ext/object/valid-value'),d = require('d'),ee = require('event-emitter'),Symbol = require('es6-symbol'),iterator = require('es6-iterator/valid-iterable'),forOf = require('es6-iterator/for-of'),Iterator = require('./lib/iterator'),isNative = require('./is-native-implemented'),call = Function.prototype.call,defineProperties = Object.defineProperties,getPrototypeOf = Object.getPrototypeOf,MapPoly;module.exports = MapPoly = function ( /*iterable*/ ) {
var iterable = arguments[0],keys, values, self;if (!(this instanceof MapPoly)) throw new TypeError('Constructor requires \'new\'');if (isNative && setPrototypeOf && (Map !== MapPoly)) {
self = setPrototypeOf(new Map(), getPrototypeOf(this));} else {
self = this;}if (iterable != null) iterator(iterable);defineProperties(self, {
__mapKeysData__: d('c', keys = []),__mapValuesData__: d('c', values = [])});if (!iterable) return self;forOf(iterable, function (value) {
var key = validValue(value)[0];value = value[1];if (eIndexOf.call(keys, key) !== -1) return;keys.push(key);values.push(value);}, self);return self;};if (isNative) {
if (setPrototypeOf) setPrototypeOf(MapPoly, Map);MapPoly.prototype = Object.create(Map.prototype, {
constructor: d(MapPoly)});}ee(defineProperties(MapPoly.prototype, {
clear: d(function () {
if (!this.__mapKeysData__.length) return;clear.call(this.__mapKeysData__);clear.call(this.__mapValuesData__);this.emit('_clear');}),delete: d(function (key) {
var index = eIndexOf.call(this.__mapKeysData__, key);if (index === -1) return false;this.__mapKeysData__.splice(index, 1);this.__mapValuesData__.splice(index, 1);this.emit('_delete', index, key);return true;}),entries: d(function () {
return new Iterator(this, 'key+value');}),forEach: d(function (cb /*, thisArg*/ ) {
var thisArg = arguments[1],iterator, result;callable(cb);iterator = this.entries();result = iterator._next();while (result !== undefined) {
call.call(cb, thisArg, this.__mapValuesData__[result],this.__mapKeysData__[result], this);result = iterator._next();}}),get: d(function (key) {
var index = eIndexOf.call(this.__mapKeysData__, key);if (index === -1) return;return this.__mapValuesData__[index];}),has: d(function (key) {
return (eIndexOf.call(this.__mapKeysData__, key) !== -1);}),keys: d(function () {
return new Iterator(this, 'key');}),set: d(function (key, value) {
var index = eIndexOf.call(this.__mapKeysData__, key),emit;if (index === -1) {
index = this.__mapKeysData__.push(key) - 1;emit = true;}this.__mapValuesData__[index] = value;if (emit) this.emit('_add', index, key);return this;}),size: d.gs(function () {
return this.__mapKeysData__.length;}),values: d(function () {
return new Iterator(this, 'value');}),toString: d(function () {
return '[object Map]';})}));Object.defineProperty(MapPoly.prototype, Symbol.iterator, d(function () {
return this.entries();}));Object.defineProperty(MapPoly.prototype, Symbol.toStringTag, d('c', 'Map'));}, {
"./is-native-implemented": 69,"./lib/iterator": 71,"d": 16,"es5-ext/array/#/clear": 19,"es5-ext/array/#/e-index-of": 20,"es5-ext/object/set-prototype-of": 51,"es5-ext/object/valid-callable": 54,"es5-ext/object/valid-value": 55,"es6-iterator/for-of": 61,"es6-iterator/valid-iterable": 66,"es6-symbol": 73,"event-emitter": 78}],73: [function (require, module, exports) {
'use strict';module.exports = require('./is-implemented')() ? Symbol : require('./polyfill');}, {
"./is-implemented": 74,"./polyfill": 76}],74: [function (require, module, exports) {
'use strict';var validTypes = {
object: true,symbol: true};module.exports = function () {
var symbol;if (typeof Symbol !== 'function') return false;symbol = Symbol('test symbol');try {
String(symbol);} catch (e) {
return false;}// Return 'true' also for polyfillsif (!validTypes[typeof Symbol.iterator]) return false;if (!validTypes[typeof Symbol.toPrimitive]) return false;if (!validTypes[typeof Symbol.toStringTag]) return false;return true;};}, {
}],75: [function (require, module, exports) {
'use strict';module.exports = function (x) {
if (!x) return false;if (typeof x === 'symbol') return true;if (!x.constructor) return false;if (x.constructor.name !== 'Symbol') return false;return (x[x.constructor.toStringTag] === 'Symbol');};}, {
}],76: [function (require, module, exports) {
// ES2015 Symbol polyfill for environments that do not (or partially) support it'use strict';var d = require('d'),validateSymbol = require('./validate-symbol'),create = Object.create,defineProperties = Object.defineProperties,defineProperty = Object.defineProperty,objPrototype = Object.prototype,NativeSymbol, SymbolPolyfill, HiddenSymbol, globalSymbols = create(null),isNativeSafe;if (typeof Symbol === 'function') {
NativeSymbol = Symbol;try {
String(NativeSymbol());isNativeSafe = true;} catch (ignore) {
}}var generateName = (function () {
var created = create(null);return function (desc) {
var postfix = 0,name, ie11BugWorkaround;while (created[desc + (postfix || '')]) ++postfix;desc += (postfix || '');created[desc] = true;name = '@@' + desc;defineProperty(objPrototype, name, d.gs(null, function (value) {
// For IE11 issue see:// https://connect.microsoft.com/IE/feedbackdetail/view/1928508/// ie11-broken-getters-on-dom-objects// https://github.com/medikoo/es6-symbol/issues/12if (ie11BugWorkaround) return;ie11BugWorkaround = true;defineProperty(this, name, d(value));ie11BugWorkaround = false;}));return name;};}());// Internal constructor (not one exposed) for creating Symbol instances.// This one is used to ensure that `someSymbol instanceof Symbol` always return falseHiddenSymbol = function Symbol(description) {
if (this instanceof HiddenSymbol) throw new TypeError('Symbol is not a constructor');return SymbolPolyfill(description);};// Exposed `Symbol` constructor// (returns instances of HiddenSymbol)module.exports = SymbolPolyfill = function Symbol(description) {
var symbol;if (this instanceof Symbol) throw new TypeError('Symbol is not a constructor');if (isNativeSafe) return NativeSymbol(description);symbol = create(HiddenSymbol.prototype);description = (description === undefined ? '' : String(description));return defineProperties(symbol, {
__description__: d('', description),__name__: d('', generateName(description))});};defineProperties(SymbolPolyfill, {
for: d(function (key) {
if (globalSymbols[key]) return globalSymbols[key];return (globalSymbols[key] = SymbolPolyfill(String(key)));}),keyFor: d(function (s) {
var key;validateSymbol(s);for (key in globalSymbols)if (globalSymbols[key] === s) return key;}),// To ensure proper interoperability with other native functions (e.g. Array.from)// fallback to eventual native implementation of given symbolhasInstance: d('', (NativeSymbol && NativeSymbol.hasInstance) || SymbolPolyfill('hasInstance')),isConcatSpreadable: d('', (NativeSymbol && NativeSymbol.isConcatSpreadable) ||SymbolPolyfill('isConcatSpreadable')),iterator: d('', (NativeSymbol && NativeSymbol.iterator) || SymbolPolyfill('iterator')),match: d('', (NativeSymbol && NativeSymbol.match) || SymbolPolyfill('match')),replace: d('', (NativeSymbol && NativeSymbol.replace) || SymbolPolyfill('replace')),search: d('', (NativeSymbol && NativeSymbol.search) || SymbolPolyfill('search')),species: d('', (NativeSymbol && NativeSymbol.species) || SymbolPolyfill('species')),split: d('', (NativeSymbol && NativeSymbol.split) || SymbolPolyfill('split')),toPrimitive: d('', (NativeSymbol && NativeSymbol.toPrimitive) || SymbolPolyfill('toPrimitive')),toStringTag: d('', (NativeSymbol && NativeSymbol.toStringTag) || SymbolPolyfill('toStringTag')),unscopables: d('', (NativeSymbol && NativeSymbol.unscopables) || SymbolPolyfill('unscopables'))});// Internal tweaks for real symbol producerdefineProperties(HiddenSymbol.prototype, {
constructor: d(SymbolPolyfill),toString: d('', function () {
return this.__name__;})});// Proper implementation of methods exposed on Symbol.prototype// They won't be accessible on produced symbol instances as they derive from HiddenSymbol.prototypedefineProperties(SymbolPolyfill.prototype, {
toString: d(function () {
return 'Symbol (' + validateSymbol(this).__description__ + ')';}),valueOf: d(function () {
return validateSymbol(this);})});defineProperty(SymbolPolyfill.prototype, SymbolPolyfill.toPrimitive, d('', function () {
var symbol = validateSymbol(this);if (typeof symbol === 'symbol') return symbol;return symbol.toString();}));defineProperty(SymbolPolyfill.prototype, SymbolPolyfill.toStringTag, d('c', 'Symbol'));// Proper implementaton of toPrimitive and toStringTag for returned symbol instancesdefineProperty(HiddenSymbol.prototype, SymbolPolyfill.toStringTag,d('c', SymbolPolyfill.prototype[SymbolPolyfill.toStringTag]));// Note: It's important to define `toPrimitive` as last one, as some implementations// implement `toPrimitive` natively without implementing `toStringTag` (or other specified symbols)// And that may invoke error in definition flow:// See: https://github.com/medikoo/es6-symbol/issues/13#issuecomment-164146149defineProperty(HiddenSymbol.prototype, SymbolPolyfill.toPrimitive,d('c', SymbolPolyfill.prototype[SymbolPolyfill.toPrimitive]));}, {
"./validate-symbol": 77,"d": 16}],77: [function (require, module, exports) {
'use strict';var isSymbol = require('./is-symbol');module.exports = function (value) {
if (!isSymbol(value)) throw new TypeError(value + " is not a symbol");return value;};}, {
"./is-symbol": 75}],78: [function (require, module, exports) {
'use strict';var d = require('d'),callable = require('es5-ext/object/valid-callable'),apply = Function.prototype.apply,call = Function.prototype.call,create = Object.create,defineProperty = Object.defineProperty,defineProperties = Object.defineProperties,hasOwnProperty = Object.prototype.hasOwnProperty,descriptor = {
configurable: true,enumerable: false,writable: true},on, once, off, emit, methods, descriptors, base;on = function (type, listener) {
var data;callable(listener);if (!hasOwnProperty.call(this, '__ee__')) {
data = descriptor.value = create(null);defineProperty(this, '__ee__', descriptor);descriptor.value = null;} else {
data = this.__ee__;}if (!data[type]) data[type] = listener;else if (typeof data[type] === 'object') data[type].push(listener);else data[type] = [data[type], listener];return this;};once = function (type, listener) {
var once, self;callable(listener);self = this;on.call(this, type, once = function () {
off.call(self, type, once);apply.call(listener, this, arguments);});once.__eeOnceListener__ = listener;return this;};off = function (type, listener) {
var data, listeners, candidate, i;callable(listener);if (!hasOwnProperty.call(this, '__ee__')) return this;data = this.__ee__;if (!data[type]) return this;listeners = data[type];if (typeof listeners === 'object') {
for (i = 0;(candidate = listeners[i]); ++i) {
if ((candidate === listener) ||(candidate.__eeOnceListener__ === listener)) {
if (listeners.length === 2) data[type] = listeners[i ? 0 : 1];else listeners.splice(i, 1);}}} else {
if ((listeners === listener) ||(listeners.__eeOnceListener__ === listener)) {
delete data[type];}}return this;};emit = function (type) {
var i, l, listener, listeners, args;if (!hasOwnProperty.call(this, '__ee__')) return;listeners = this.__ee__[type];if (!listeners) return;if (typeof listeners === 'object') {
l = arguments.length;args = new Array(l - 1);for (i = 1; i < l; ++i) args[i - 1] = arguments[i];listeners = listeners.slice();for (i = 0;(listener = listeners[i]); ++i) {
apply.call(listener, this, args);}} else {
switch (arguments.length) {
case 1:call.call(listeners, this);break;case 2:call.call(listeners, this, arguments[1]);break;case 3:call.call(listeners, this, arguments[1], arguments[2]);break;default:l = arguments.length;args = new Array(l - 1);for (i = 1; i < l; ++i) {
args[i - 1] = arguments[i];}apply.call(listeners, this, args);}}};methods = {
on: on,once: once,off: off,emit: emit};descriptors = {
on: d(on),once: d(once),off: d(off),emit: d(emit)};base = defineProperties({
}, descriptors);module.exports = exports = function (o) {
return (o == null) ? create(base) : defineProperties(Object(o), descriptors);};exports.methods = methods;}, {
"d": 16,"es5-ext/object/valid-callable": 54}],79: [function (require, module, exports) {
exports.read = function (buffer, offset, isLE, mLen, nBytes) {
var e, mvar eLen = (nBytes * 8) - mLen - 1var eMax = (1 << eLen) - 1var eBias = eMax >> 1var nBits = -7var i = isLE ? (nBytes - 1) : 0var d = isLE ? -1 : 1var s = buffer[offset + i]i += de = s & ((1 << (-nBits)) - 1)s >>= (-nBits)nBits += eLenfor (; nBits > 0; e = (e * 256) + buffer[offset + i], i += d, nBits -= 8) {
}m = e & ((1 << (-nBits)) - 1)e >>= (-nBits)nBits += mLenfor (; nBits > 0; m = (m * 256) + buffer[offset + i], i += d, nBits -= 8) {
}if (e === 0) {
e = 1 - eBias} else if (e === eMax) {
return m ? NaN : ((s ? -1 : 1) * Infinity)} else {
m = m + Math.pow(2, mLen)e = e - eBias}return (s ? -1 : 1) * m * Math.pow(2, e - mLen)}exports.write = function (buffer, value, offset, isLE, mLen, nBytes) {
var e, m, cvar eLen = (nBytes * 8) - mLen - 1var eMax = (1 << eLen) - 1var eBias = eMax >> 1var rt = (mLen === 23 ? Math.pow(2, -24) - Math.pow(2, -77) : 0)var i = isLE ? 0 : (nBytes - 1)var d = isLE ? 1 : -1var s = value < 0 || (value === 0 && 1 / value < 0) ? 1 : 0value = Math.abs(value)if (isNaN(value) || value === Infinity) {
m = isNaN(value) ? 1 : 0e = eMax} else {
e = Math.floor(Math.log(value) / Math.LN2)if (value * (c = Math.pow(2, -e)) < 1) {
e--c *= 2}if (e + eBias >= 1) {
value += rt / c} else {
value += rt * Math.pow(2, 1 - eBias)}if (value * c >= 2) {
e++c /= 2}if (e + eBias >= eMax) {
m = 0e = eMax} else if (e + eBias >= 1) {
m = ((value * c) - 1) * Math.pow(2, mLen)e = e + eBias} else {
m = value * Math.pow(2, eBias - 1) * Math.pow(2, mLen)e = 0}}for (; mLen >= 8; buffer[offset + i] = m & 0xff, i += d, m /= 256, mLen -= 8) {
}e = (e << mLen) | meLen += mLenfor (; eLen > 0; buffer[offset + i] = e & 0xff, i += d, e /= 256, eLen -= 8) {
}buffer[offset + i - d] |= s * 128}}, {
}],80: [function (require, module, exports) {
if (typeof Object.create === 'function') {
// implementation from standard node.js 'util' modulemodule.exports = function inherits(ctor, superCtor) {
ctor.super_ = superCtorctor.prototype = Object.create(superCtor.prototype, {
constructor: {
value: ctor,enumerable: false,writable: true,configurable: true}});};} else {
// old school shim for old browsersmodule.exports = function inherits(ctor, superCtor) {
ctor.super_ = superCtorvar TempCtor = function () {
}TempCtor.prototype = superCtor.prototypector.prototype = new TempCtor()ctor.prototype.constructor = ctor}}}, {
}],81: [function (require, module, exports) {
/*!* Determine if an object is a Buffer** @author Feross Aboukhadijeh <https://feross.org>* @license MIT*/// The _isBuffer check is for Safari 5-7 support, because it's missing// Object.prototype.constructor. Remove this eventuallymodule.exports = function (obj) {
return obj != null && (isBuffer(obj) || isSlowBuffer(obj) || !!obj._isBuffer)}function isBuffer(obj) {
return !!obj.constructor && typeof obj.constructor.isBuffer === 'function' && obj.constructor.isBuffer(obj)}// For Node v0.10 support. Remove this eventually.function isSlowBuffer(obj) {
return typeof obj.readFloatLE === 'function' && typeof obj.slice === 'function' && isBuffer(obj.slice(0, 0))}}, {
}],82: [function (require, module, exports) {
'use strict'var Buffer = require('safe-buffer').Buffer/* Protocol - protocol constants */var protocol = module.exports/* Command code => mnemonic */protocol.types = {
0: 'reserved',1: 'connect',2: 'connack',3: 'publish',4: 'puback',5: 'pubrec',6: 'pubrel',7: 'pubcomp',8: 'subscribe',9: 'suback',10: 'unsubscribe',11: 'unsuback',12: 'pingreq',13: 'pingresp',14: 'disconnect',15: 'auth'}/* Mnemonic => Command code */protocol.codes = {
}for (var k in protocol.types) {
var v = protocol.types[k]protocol.codes[v] = k}/* Header */protocol.CMD_SHIFT = 4protocol.CMD_MASK = 0xF0protocol.DUP_MASK = 0x08protocol.QOS_MASK = 0x03protocol.QOS_SHIFT = 1protocol.RETAIN_MASK = 0x01/* Length */protocol.LENGTH_MASK = 0x7Fprotocol.LENGTH_FIN_MASK = 0x80/* Connack */protocol.SESSIONPRESENT_MASK = 0x01protocol.SESSIONPRESENT_HEADER = Buffer.from([protocol.SESSIONPRESENT_MASK])protocol.CONNACK_HEADER = Buffer.from([protocol.codes['connack'] << protocol.CMD_SHIFT])/* Connect */protocol.USERNAME_MASK = 0x80protocol.PASSWORD_MASK = 0x40protocol.WILL_RETAIN_MASK = 0x20protocol.WILL_QOS_MASK = 0x18protocol.WILL_QOS_SHIFT = 3protocol.WILL_FLAG_MASK = 0x04protocol.CLEAN_SESSION_MASK = 0x02protocol.CONNECT_HEADER = Buffer.from([protocol.codes['connect'] << protocol.CMD_SHIFT])/* Properties */protocol.properties = {
sessionExpiryInterval: 17,willDelayInterval: 24,receiveMaximum: 33,maximumPacketSize: 39,topicAliasMaximum: 34,requestResponseInformation: 25,requestProblemInformation: 23,userProperties: 38,authenticationMethod: 21,authenticationData: 22,payloadFormatIndicator: 1,messageExpiryInterval: 2,contentType: 3,responseTopic: 8,correlationData: 9,maximumQoS: 36,retainAvailable: 37,assignedClientIdentifier: 18,reasonString: 31,wildcardSubscriptionAvailable: 40,subscriptionIdentifiersAvailable: 41,sharedSubscriptionAvailable: 42,serverKeepAlive: 19,responseInformation: 26,serverReference: 28,topicAlias: 35,subscriptionIdentifier: 11}protocol.propertiesCodes = {
}for (var prop in protocol.properties) {
var id = protocol.properties[prop]protocol.propertiesCodes[id] = prop}protocol.propertiesTypes = {
sessionExpiryInterval: 'int32',willDelayInterval: 'int32',receiveMaximum: 'int16',maximumPacketSize: 'int32',topicAliasMaximum: 'int16',requestResponseInformation: 'byte',requestProblemInformation: 'byte',userProperties: 'pair',authenticationMethod: 'string',authenticationData: 'binary',payloadFormatIndicator: 'byte',messageExpiryInterval: 'int32',contentType: 'string',responseTopic: 'string',correlationData: 'binary',maximumQoS: 'int8',retainAvailable: 'byte',assignedClientIdentifier: 'string',reasonString: 'string',wildcardSubscriptionAvailable: 'byte',subscriptionIdentifiersAvailable: 'byte',sharedSubscriptionAvailable: 'byte',serverKeepAlive: 'int32',responseInformation: 'string',serverReference: 'string',topicAlias: 'int16',subscriptionIdentifier: 'var'}function genHeader(type) {
return [0, 1, 2].map(function (qos) {
return [0, 1].map(function (dup) {
return [0, 1].map(function (retain) {
var buf = new Buffer(1)buf.writeUInt8(protocol.codes[type] << protocol.CMD_SHIFT |(dup ? protocol.DUP_MASK : 0) |qos << protocol.QOS_SHIFT | retain, 0, true)return buf})})})}/* Publish */protocol.PUBLISH_HEADER = genHeader('publish')/* Subscribe */protocol.SUBSCRIBE_HEADER = genHeader('subscribe')protocol.SUBSCRIBE_OPTIONS_QOS_MASK = 0x03protocol.SUBSCRIBE_OPTIONS_NL_MASK = 0x01protocol.SUBSCRIBE_OPTIONS_NL_SHIFT = 2protocol.SUBSCRIBE_OPTIONS_RAP_MASK = 0x01protocol.SUBSCRIBE_OPTIONS_RAP_SHIFT = 3protocol.SUBSCRIBE_OPTIONS_RH_MASK = 0x03protocol.SUBSCRIBE_OPTIONS_RH_SHIFT = 4protocol.SUBSCRIBE_OPTIONS_RH = [0x00, 0x10, 0x20]protocol.SUBSCRIBE_OPTIONS_NL = 0x04protocol.SUBSCRIBE_OPTIONS_RAP = 0x08protocol.SUBSCRIBE_OPTIONS_QOS = [0x00, 0x01, 0x02]/* Unsubscribe */protocol.UNSUBSCRIBE_HEADER = genHeader('unsubscribe')/* Confirmations */protocol.ACKS = {
unsuback: genHeader('unsuback'),puback: genHeader('puback'),pubcomp: genHeader('pubcomp'),pubrel: genHeader('pubrel'),pubrec: genHeader('pubrec')}protocol.SUBACK_HEADER = Buffer.from([protocol.codes['suback'] << protocol.CMD_SHIFT])/* Protocol versions */protocol.VERSION3 = Buffer.from([3])protocol.VERSION4 = Buffer.from([4])protocol.VERSION5 = Buffer.from([5])/* QoS */protocol.QOS = [0, 1, 2].map(function (qos) {
return Buffer.from([qos])})/* Empty packets */protocol.EMPTY = {
pingreq: Buffer.from([protocol.codes['pingreq'] << 4, 0]),pingresp: Buffer.from([protocol.codes['pingresp'] << 4, 0]),disconnect: Buffer.from([protocol.codes['disconnect'] << 4, 0])}}, {
"safe-buffer": 110}],83: [function (require, module, exports) {
'use strict'var Buffer = require('safe-buffer').Buffervar writeToStream = require('./writeToStream')var EE = require('events').EventEmittervar inherits = require('inherits')function generate(packet, opts) {
var stream = new Accumulator()writeToStream(packet, stream, opts)return stream.concat()}function Accumulator() {
this._array = new Array(20)this._i = 0}inherits(Accumulator, EE)Accumulator.prototype.write = function (chunk) {
this._array[this._i++] = chunkreturn true}Accumulator.prototype.concat = function () {
var length = 0var lengths = new Array(this._array.length)var list = this._arrayvar pos = 0var ivar resultfor (i = 0; i < list.length && list[i] !== undefined; i++) {
if (typeof list[i] !== 'string') lengths[i] = list[i].lengthelse lengths[i] = Buffer.byteLength(list[i])length += lengths[i]}result = Buffer.allocUnsafe(length)for (i = 0; i < list.length && list[i] !== undefined; i++) {
if (typeof list[i] !== 'string') {
list[i].copy(result, pos)pos += lengths[i]} else {
result.write(list[i], pos)pos += lengths[i]}}return result}module.exports = generate}, {
"./writeToStream": 89,"events": 13,"inherits": 80,"safe-buffer": 110}],84: [function (require, module, exports) {
'use strict'exports.parser = require('./parser')exports.generate = require('./generate')exports.writeToStream = require('./writeToStream')}, {
"./generate": 83,"./parser": 88,"./writeToStream": 89}],85: [function (require, module, exports) {
var DuplexStream = require('readable-stream/duplex'),util = require('util'),Buffer = require('safe-buffer').Bufferfunction BufferList(callback) {
if (!(this instanceof BufferList))return new BufferList(callback)this._bufs = []this.length = 0if (typeof callback == 'function') {
this._callback = callbackvar piper = function piper(err) {
if (this._callback) {
this._callback(err)this._callback = null}}.bind(this)this.on('pipe', function onPipe(src) {
src.on('error', piper)})this.on('unpipe', function onUnpipe(src) {
src.removeListener('error', piper)})} else {
this.append(callback)}DuplexStream.call(this)}util.inherits(BufferList, DuplexStream)BufferList.prototype._offset = function _offset(offset) {
var tot = 0,i = 0,_tif (offset === 0) return [0, 0]for (; i < this._bufs.length; i++) {
_t = tot + this._bufs[i].lengthif (offset < _t || i == this._bufs.length - 1)return [i, offset - tot]tot = _t}}BufferList.prototype.append = function append(buf) {
var i = 0if (Buffer.isBuffer(buf)) {
this._appendBuffer(buf);} else if (Array.isArray(buf)) {
for (; i < buf.length; i++)this.append(buf[i])} else if (buf instanceof BufferList) {
// unwrap argument into individual BufferListsfor (; i < buf._bufs.length; i++)this.append(buf._bufs[i])} else if (buf != null) {
// coerce number arguments to strings, since Buffer(number) does// uninitialized memory allocationif (typeof buf == 'number')buf = buf.toString()this._appendBuffer(Buffer.from(buf));}return this}BufferList.prototype._appendBuffer = function appendBuffer(buf) {
this._bufs.push(buf)this.length += buf.length}BufferList.prototype._write = function _write(buf, encoding, callback) {
this._appendBuffer(buf)if (typeof callback == 'function')callback()}BufferList.prototype._read = function _read(size) {
if (!this.length)return this.push(null)size = Math.min(size, this.length)this.push(this.slice(0, size))this.consume(size)}BufferList.prototype.end = function end(chunk) {
DuplexStream.prototype.end.call(this, chunk)if (this._callback) {
this._callback(null, this.slice())this._callback = null}}BufferList.prototype.get = function get(index) {
return this.slice(index, index + 1)[0]}BufferList.prototype.slice = function slice(start, end) {
if (typeof start == 'number' && start < 0)start += this.lengthif (typeof end == 'number' && end < 0)end += this.lengthreturn this.copy(null, 0, start, end)}BufferList.prototype.copy = function copy(dst, dstStart, srcStart, srcEnd) {
if (typeof srcStart != 'number' || srcStart < 0)srcStart = 0if (typeof srcEnd != 'number' || srcEnd > this.length)srcEnd = this.lengthif (srcStart >= this.length)return dst || Buffer.alloc(0)if (srcEnd <= 0)return dst || Buffer.alloc(0)var copy = !!dst,off = this._offset(srcStart),len = srcEnd - srcStart,bytes = len,bufoff = (copy && dstStart) || 0,start = off[1],l, i// copy/slice everythingif (srcStart === 0 && srcEnd == this.length) {
if (!copy) {
// slice, but full concat if multiple buffersreturn this._bufs.length === 1 ?this._bufs[0] :Buffer.concat(this._bufs, this.length)}// copy, need to copy individual buffersfor (i = 0; i < this._bufs.length; i++) {
this._bufs[i].copy(dst, bufoff)bufoff += this._bufs[i].length}return dst}// easy, cheap case where it's a subset of one of the buffersif (bytes <= this._bufs[off[0]].length - start) {
return copy ?this._bufs[off[0]].copy(dst, dstStart, start, start + bytes) :this._bufs[off[0]].slice(start, start + bytes)}if (!copy) // a slice, we need something to copy in todst = Buffer.allocUnsafe(len)for (i = off[0]; i < this._bufs.length; i++) {
l = this._bufs[i].length - startif (bytes > l) {
this._bufs[i].copy(dst, bufoff, start)} else {
this._bufs[i].copy(dst, bufoff, start, start + bytes)break}bufoff += lbytes -= lif (start)start = 0}return dst}BufferList.prototype.shallowSlice = function shallowSlice(start, end) {
start = start || 0end = end || this.lengthif (start < 0)start += this.lengthif (end < 0)end += this.lengthvar startOffset = this._offset(start),endOffset = this._offset(end),buffers = this._bufs.slice(startOffset[0], endOffset[0] + 1)if (endOffset[1] == 0)buffers.pop()elsebuffers[buffers.length - 1] = buffers[buffers.length - 1].slice(0, endOffset[1])if (startOffset[1] != 0)buffers[0] = buffers[0].slice(startOffset[1])return new BufferList(buffers)}BufferList.prototype.toString = function toString(encoding, start, end) {
return this.slice(start, end).toString(encoding)}BufferList.prototype.consume = function consume(bytes) {
while (this._bufs.length) {
if (bytes >= this._bufs[0].length) {
bytes -= this._bufs[0].lengththis.length -= this._bufs[0].lengththis._bufs.shift()} else {
this._bufs[0] = this._bufs[0].slice(bytes)this.length -= bytesbreak}}return this}BufferList.prototype.duplicate = function duplicate() {
var i = 0,copy = new BufferList()for (; i < this._bufs.length; i++)copy.append(this._bufs[i])return copy}BufferList.prototype.destroy = function destroy() {
this._bufs.length = 0this.length = 0this.push(null)};(function () {
var methods = {
'readDoubleBE': 8,'readDoubleLE': 8,'readFloatBE': 4,'readFloatLE': 4,'readInt32BE': 4,'readInt32LE': 4,'readUInt32BE': 4,'readUInt32LE': 4,'readInt16BE': 2,'readInt16LE': 2,'readUInt16BE': 2,'readUInt16LE': 2,'readInt8': 1,'readUInt8': 1}for (var m in methods) {
(function (m) {
BufferList.prototype[m] = function (offset) {
return this.slice(offset, offset + methods[m])[m](0)}}(m))}}())module.exports = BufferList}, {
"readable-stream/duplex": 97,"safe-buffer": 110,"util": 117}],86: [function (require, module, exports) {
'use strict'var Buffer = require('safe-buffer').Buffervar max = 65536var cache = {
}function generateBuffer(i) {
var buffer = Buffer.allocUnsafe(2)buffer.writeUInt8(i >> 8, 0)buffer.writeUInt8(i & 0x00FF, 0 + 1)return buffer}function generateCache() {
for (var i = 0; i < max; i++) {
cache[i] = generateBuffer(i)}}/*** calcVariableByteIntLength - calculate the variable byte integer* length field** @api private*/function calcVariableByteIntLength(length) {
if (length >= 0 && length < 128) return 1else if (length >= 128 && length < 16384) return 2else if (length >= 16384 && length < 2097152) return 3else if (length >= 2097152 && length < 268435456) return 4else return 0}function genBufVariableByteInt(num) {
var digit = 0var pos = 0var length = calcVariableByteIntLength(num)var buffer = Buffer.allocUnsafe(length)do {
digit = num % 128 | 0num = num / 128 | 0if (num > 0) digit = digit | 0x80buffer.writeUInt8(digit, pos++)} while (num > 0)return {
data: buffer,length: length}}function generate4ByteBuffer(num) {
var buffer = Buffer.allocUnsafe(4)buffer.writeUInt32BE(num, 0)return buffer}module.exports = {
cache: cache,generateCache: generateCache,generateNumber: generateBuffer,genBufVariableByteInt: genBufVariableByteInt,generate4ByteBuffer: generate4ByteBuffer}}, {
"safe-buffer": 110}],87: [function (require, module, exports) {
function Packet() {
this.cmd = nullthis.retain = falsethis.qos = 0this.dup = falsethis.length = -1this.topic = nullthis.payload = null}module.exports = Packet}, {
}],88: [function (require, module, exports) {
'use strict'var bl = require('bl')var inherits = require('inherits')var EE = require('events').EventEmittervar Packet = require('./packet')var constants = require('./constants')function Parser(opt) {
if (!(this instanceof Parser)) return new Parser(opt)this.settings = opt || {
}this._states = ['_parseHeader','_parseLength','_parsePayload','_newPacket']this._resetState()}inherits(Parser, EE)Parser.prototype._resetState = function () {
this.packet = new Packet()this.error = nullthis._list = bl()this._stateCounter = 0}Parser.prototype.parse = function (buf) {
if (this.error) this._resetState()this._list.append(buf)while ((this.packet.length !== -1 || this._list.length > 0) &&this[this._states[this._stateCounter]]() &&!this.error) {
this._stateCounter++if (this._stateCounter >= this._states.length) this._stateCounter = 0}return this._list.length}Parser.prototype._parseHeader = function () {
// There is at least one byte in the buffervar zero = this._list.readUInt8(0)this.packet.cmd = constants.types[zero >> constants.CMD_SHIFT]this.packet.retain = (zero & constants.RETAIN_MASK) !== 0this.packet.qos = (zero >> constants.QOS_SHIFT) & constants.QOS_MASKthis.packet.dup = (zero & constants.DUP_MASK) !== 0this._list.consume(1)return true}Parser.prototype._parseLength = function () {
// There is at least one byte in the listvar result = this._parseVarByteNum(true)if (result) {
this.packet.length = result.valuethis._list.consume(result.bytes)}return !!result}Parser.prototype._parsePayload = function () {
var result = false// Do we have a payload? Do we have enough data to complete the payload?// PINGs have no payloadif (this.packet.length === 0 || this._list.length >= this.packet.length) {
this._pos = 0switch (this.packet.cmd) {
case 'connect':this._parseConnect()breakcase 'connack':this._parseConnack()breakcase 'publish':this._parsePublish()breakcase 'puback':case 'pubrec':case 'pubrel':case 'pubcomp':this._parseConfirmation()breakcase 'subscribe':this._parseSubscribe()breakcase 'suback':this._parseSuback()breakcase 'unsubscribe':this._parseUnsubscribe()breakcase 'unsuback':this._parseUnsuback()breakcase 'pingreq':case 'pingresp':// These are empty, nothing to dobreakcase 'disconnect':this._parseDisconnect()breakcase 'auth':this._parseAuth()breakdefault:this._emitError(new Error('Not supported'))}result = true}return result}Parser.prototype._parseConnect = function () {
var protocolId // Protocol IDvar clientId // Client IDvar topic // Will topicvar payload // Will payloadvar password // Passwordvar username // Usernamevar flags = {
}var packet = this.packet// Parse protocolIdprotocolId = this._parseString()if (protocolId === null) return this._emitError(new Error('Cannot parse protocolId'))if (protocolId !== 'MQTT' && protocolId !== 'MQIsdp') {
return this._emitError(new Error('Invalid protocolId'))}packet.protocolId = protocolId// Parse constants version numberif (this._pos >= this._list.length) return this._emitError(new Error('Packet too short'))packet.protocolVersion = this._list.readUInt8(this._pos)if (packet.protocolVersion !== 3 && packet.protocolVersion !== 4 && packet.protocolVersion !== 5) {
return this._emitError(new Error('Invalid protocol version'))}this._pos++if (this._pos >= this._list.length) {
return this._emitError(new Error('Packet too short'))}// Parse connect flagsflags.username = (this._list.readUInt8(this._pos) & constants.USERNAME_MASK)flags.password = (this._list.readUInt8(this._pos) & constants.PASSWORD_MASK)flags.will = (this._list.readUInt8(this._pos) & constants.WILL_FLAG_MASK)if (flags.will) {
packet.will = {
}packet.will.retain = (this._list.readUInt8(this._pos) & constants.WILL_RETAIN_MASK) !== 0packet.will.qos = (this._list.readUInt8(this._pos) &constants.WILL_QOS_MASK) >> constants.WILL_QOS_SHIFT}packet.clean = (this._list.readUInt8(this._pos) & constants.CLEAN_SESSION_MASK) !== 0this._pos++// Parse keepalivepacket.keepalive = this._parseNum()if (packet.keepalive === -1) return this._emitError(new Error('Packet too short'))// parse propertiesif (packet.protocolVersion === 5) {
var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}}// Parse clientIdclientId = this._parseString()if (clientId === null) return this._emitError(new Error('Packet too short'))packet.clientId = clientIdif (flags.will) {
if (packet.protocolVersion === 5) {
var willProperties = this._parseProperties()if (Object.getOwnPropertyNames(willProperties).length) {
packet.will.properties = willProperties}}// Parse will topictopic = this._parseString()if (topic === null) return this._emitError(new Error('Cannot parse will topic'))packet.will.topic = topic// Parse will payloadpayload = this._parseBuffer()if (payload === null) return this._emitError(new Error('Cannot parse will payload'))packet.will.payload = payload}// Parse usernameif (flags.username) {
username = this._parseString()if (username === null) return this._emitError(new Error('Cannot parse username'))packet.username = username}// Parse passwordif (flags.password) {
password = this._parseBuffer()if (password === null) return this._emitError(new Error('Cannot parse password'))packet.password = password}// need for right parse auth packet and self set upthis.settings = packetreturn packet}Parser.prototype._parseConnack = function () {
var packet = this.packetif (this._list.length < 2) return nullpacket.sessionPresent = !!(this._list.readUInt8(this._pos++) & constants.SESSIONPRESENT_MASK)if (this.settings.protocolVersion === 5) {
packet.reasonCode = this._list.readUInt8(this._pos++)} else {
packet.returnCode = this._list.readUInt8(this._pos++)}if (packet.returnCode === -1 || packet.reasonCode === -1) return this._emitError(new Error('Cannot parse return code'))// mqtt 5 propertiesif (this.settings.protocolVersion === 5) {
var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}}}Parser.prototype._parsePublish = function () {
var packet = this.packetpacket.topic = this._parseString()if (packet.topic === null) return this._emitError(new Error('Cannot parse topic'))// Parse messageIdif (packet.qos > 0)if (!this._parseMessageId()) {
return}// Properties mqtt 5if (this.settings.protocolVersion === 5) {
var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}}packet.payload = this._list.slice(this._pos, packet.length)}Parser.prototype._parseSubscribe = function () {
var packet = this.packetvar topicvar optionsvar qosvar rhvar rapvar nlvar subscriptionif (packet.qos !== 1) {
return this._emitError(new Error('Wrong subscribe header'))}packet.subscriptions = []if (!this._parseMessageId()) {
return}// Properties mqtt 5if (this.settings.protocolVersion === 5) {
var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}}while (this._pos < packet.length) {
// Parse topictopic = this._parseString()if (topic === null) return this._emitError(new Error('Cannot parse topic'))options = this._parseByte()qos = options & constants.SUBSCRIBE_OPTIONS_QOS_MASKnl = ((options >> constants.SUBSCRIBE_OPTIONS_NL_SHIFT) & constants.SUBSCRIBE_OPTIONS_NL_MASK) !== 0rap = ((options >> constants.SUBSCRIBE_OPTIONS_RAP_SHIFT) & constants.SUBSCRIBE_OPTIONS_RAP_MASK) !== 0rh = (options >> constants.SUBSCRIBE_OPTIONS_RH_SHIFT) & constants.SUBSCRIBE_OPTIONS_RH_MASKsubscription = {
topic: topic,qos: qos}// mqtt 5 optionsif (this.settings.protocolVersion === 5) {
subscription.nl = nlsubscription.rap = rapsubscription.rh = rh}// Push pair to subscriptionspacket.subscriptions.push(subscription)}}Parser.prototype._parseSuback = function () {
var packet = this.packetthis.packet.granted = []if (!this._parseMessageId()) {
return}// Properties mqtt 5if (this.settings.protocolVersion === 5) {
var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}}// Parse granted QoSeswhile (this._pos < this.packet.length) {
this.packet.granted.push(this._list.readUInt8(this._pos++))}}Parser.prototype._parseUnsubscribe = function () {
var packet = this.packetpacket.unsubscriptions = []// Parse messageIdif (!this._parseMessageId()) {
return}// Properties mqtt 5if (this.settings.protocolVersion === 5) {
var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}}while (this._pos < packet.length) {
var topic// Parse topictopic = this._parseString()if (topic === null) return this._emitError(new Error('Cannot parse topic'))// Push topic to unsubscriptionspacket.unsubscriptions.push(topic)}}Parser.prototype._parseUnsuback = function () {
var packet = this.packetif (!this._parseMessageId()) return this._emitError(new Error('Cannot parse messageId'))// Properties mqtt 5if (this.settings.protocolVersion === 5) {
var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}// Parse granted QoSespacket.granted = []while (this._pos < this.packet.length) {
this.packet.granted.push(this._list.readUInt8(this._pos++))}}}// parse packets like puback, pubrec, pubrel, pubcompParser.prototype._parseConfirmation = function () {
var packet = this.packetthis._parseMessageId()if (this.settings.protocolVersion === 5) {
if (packet.length > 2) {
// response codepacket.reasonCode = this._parseByte()// properies mqtt 5var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}}}return true}// parse disconnect packetParser.prototype._parseDisconnect = function () {
var packet = this.packetif (this.settings.protocolVersion === 5) {
// response codepacket.reasonCode = this._parseByte()// properies mqtt 5var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}}return true}// parse auth packetParser.prototype._parseAuth = function () {
var packet = this.packetif (this.settings.protocolVersion !== 5) {
return this._emitError(new Error('Not supported auth packet for this version MQTT'))}// response codepacket.reasonCode = this._parseByte()// properies mqtt 5var properties = this._parseProperties()if (Object.getOwnPropertyNames(properties).length) {
packet.properties = properties}return true}Parser.prototype._parseMessageId = function () {
var packet = this.packetpacket.messageId = this._parseNum()if (packet.messageId === null) {
this._emitError(new Error('Cannot parse messageId'))return false}return true}Parser.prototype._parseString = function (maybeBuffer) {
var length = this._parseNum()var resultvar end = length + this._posif (length === -1 || end > this._list.length || end > this.packet.length) return nullresult = this._list.toString('utf8', this._pos, end)this._pos += lengthreturn result}Parser.prototype._parseStringPair = function () {
return {
name: this._parseString(),value: this._parseString()}}Parser.prototype._parseBuffer = function () {
var length = this._parseNum()var resultvar end = length + this._posif (length === -1 || end > this._list.length || end > this.packet.length) return nullresult = this._list.slice(this._pos, end)this._pos += lengthreturn result}Parser.prototype._parseNum = function () {
if (this._list.length - this._pos < 2) return -1var result = this._list.readUInt16BE(this._pos)this._pos += 2return result}Parser.prototype._parse4ByteNum = function () {
if (this._list.length - this._pos < 4) return -1var result = this._list.readUInt32BE(this._pos)this._pos += 4return result}Parser.prototype._parseVarByteNum = function (fullInfoFlag) {
var bytes = 0var mul = 1var length = 0var result = truevar currentvar padding = this._pos ? this._pos : 0while (bytes < 5) {
current = this._list.readUInt8(padding + bytes++)length += mul * (current & constants.LENGTH_MASK)mul *= 0x80if ((current & constants.LENGTH_FIN_MASK) === 0) breakif (this._list.length <= bytes) {
result = falsebreak}}if (padding) {
this._pos += bytes}result = result ?fullInfoFlag ? {
bytes: bytes,value: length} : length :falsereturn result}Parser.prototype._parseByte = function () {
var result = this._list.readUInt8(this._pos)this._pos++return result}Parser.prototype._parseByType = function (type) {
switch (type) {
case 'byte': {
return this._parseByte() !== 0}case 'int8': {
return this._parseByte()}case 'int16': {
return this._parseNum()}case 'int32': {
return this._parse4ByteNum()}case 'var': {
return this._parseVarByteNum()}case 'string': {
return this._parseString()}case 'pair': {
return this._parseStringPair()}case 'binary': {
return this._parseBuffer()}}}Parser.prototype._parseProperties = function () {
var length = this._parseVarByteNum()var start = this._posvar end = start + lengthvar result = {
}while (this._pos < end) {
var type = this._parseByte()var name = constants.propertiesCodes[type]if (!name) {
this._emitError(new Error('Unknown property'))return false}// user properties processif (name === 'userProperties') {
if (!result[name]) {
result[name] = {
}}var currentUserProperty = this._parseByType(constants.propertiesTypes[name])result[name][currentUserProperty.name] = currentUserProperty.valuecontinue}result[name] = this._parseByType(constants.propertiesTypes[name])}return result}Parser.prototype._newPacket = function () {
if (this.packet) {
this._list.consume(this.packet.length)this.emit('packet', this.packet)}this.packet = new Packet()this._pos = 0return true}Parser.prototype._emitError = function (err) {
this.error = errthis.emit('error', err)}module.exports = Parser}, {
"./constants": 82,"./packet": 87,"bl": 85,"events": 13,"inherits": 80}],89: [function (require, module, exports) {
'use strict'var protocol = require('./constants')var Buffer = require('safe-buffer').Buffervar empty = Buffer.allocUnsafe(0)var zeroBuf = Buffer.from([0])var numbers = require('./numbers')var nextTick = require('process-nextick-args').nextTickvar numCache = numbers.cachevar generateNumber = numbers.generateNumbervar generateCache = numbers.generateCachevar genBufVariableByteInt = numbers.genBufVariableByteIntvar generate4ByteBuffer = numbers.generate4ByteBuffervar writeNumber = writeNumberCachedvar toGenerate = truefunction generate(packet, stream, opts) {
if (stream.cork) {
stream.cork()nextTick(uncork, stream)}if (toGenerate) {
toGenerate = falsegenerateCache()}switch (packet.cmd) {
case 'connect':return connect(packet, stream, opts)case 'connack':return connack(packet, stream, opts)case 'publish':return publish(packet, stream, opts)case 'puback':case 'pubrec':case 'pubrel':case 'pubcomp':return confirmation(packet, stream, opts)case 'subscribe':return subscribe(packet, stream, opts)case 'suback':return suback(packet, stream, opts)case 'unsubscribe':return unsubscribe(packet, stream, opts)case 'unsuback':return unsuback(packet, stream, opts)case 'pingreq':case 'pingresp':return emptyPacket(packet, stream, opts)case 'disconnect':return disconnect(packet, stream, opts)case 'auth':return auth(packet, stream, opts)default:stream.emit('error', new Error('Unknown command'))return false}}/*** Controls numbers cache.* Set to "false" to allocate buffers on-the-flight instead of pre-generated cache*/Object.defineProperty(generate, 'cacheNumbers', {
get: function () {
return writeNumber === writeNumberCached},set: function (value) {
if (value) {
if (!numCache || Object.keys(numCache).length === 0) toGenerate = truewriteNumber = writeNumberCached} else {
toGenerate = falsewriteNumber = writeNumberGenerated}}})function uncork(stream) {
stream.uncork()}function connect(packet, stream, opts) {
var settings = packet || {
}var protocolId = settings.protocolId || 'MQTT'var protocolVersion = settings.protocolVersion || 4var will = settings.willvar clean = settings.cleanvar keepalive = settings.keepalive || 0var clientId = settings.clientId || ''var username = settings.usernamevar password = settings.password/* mqtt5 new oprions */var properties = settings.propertiesif (clean === undefined) clean = truevar length = 0// Must be a string and non-falsyif (!protocolId ||(typeof protocolId !== 'string' && !Buffer.isBuffer(protocolId))) {
stream.emit('error', new Error('Invalid protocolId'))return false} else length += protocolId.length + 2// Must be 3 or 4 or 5if (protocolVersion !== 3 && protocolVersion !== 4 && protocolVersion !== 5) {
stream.emit('error', new Error('Invalid protocol version'))return false} else length += 1// ClientId might be omitted in 3.1.1, but only if cleanSession is set to 1if ((typeof clientId === 'string' || Buffer.isBuffer(clientId)) &&(clientId || protocolVersion === 4) && (clientId || clean)) {
length += clientId.length + 2} else {
if (protocolVersion < 4) {
stream.emit('error', new Error('clientId must be supplied before 3.1.1'))return false}if ((clean * 1) === 0) {
stream.emit('error', new Error('clientId must be given if cleanSession set to 0'))return false}}// Must be a two byte numberif (typeof keepalive !== 'number' ||keepalive < 0 ||keepalive > 65535 ||keepalive % 1 !== 0) {
stream.emit('error', new Error('Invalid keepalive'))return false} else length += 2// Connect flagslength += 1// Propertiesif (protocolVersion === 5) {
var propertiesData = getProperties(stream, properties)length += propertiesData.length}// If will exists...if (will) {
// It must be an objectif (typeof will !== 'object') {
stream.emit('error', new Error('Invalid will'))return false}// It must have topic typeof stringif (!will.topic || typeof will.topic !== 'string') {
stream.emit('error', new Error('Invalid will topic'))return false} else {
length += Buffer.byteLength(will.topic) + 2}// Payloadif (will.payload) {
if (will.payload.length >= 0) {
if (typeof will.payload === 'string') {
length += Buffer.byteLength(will.payload) + 2} else {
length += will.payload.length + 2}} else {
stream.emit('error', new Error('Invalid will payload'))return false}// will propertiesvar willProperties = {
}if (protocolVersion === 5) {
willProperties = getProperties(stream, will.properties)length += willProperties.length}}}// Usernamevar providedUsername = falseif (username != null) {
if (isStringOrBuffer(username)) {
providedUsername = truelength += Buffer.byteLength(username) + 2} else {
stream.emit('error', new Error('Invalid username'))return false}}// Passwordif (password != null) {
if (!providedUsername) {
stream.emit('error', new Error('Username is required to use password'))return false}if (isStringOrBuffer(password)) {
length += byteLength(password) + 2} else {
stream.emit('error', new Error('Invalid password'))return false}}// Generate headerstream.write(protocol.CONNECT_HEADER)// Generate lengthwriteVarByteInt(stream, length)// Generate protocol IDwriteStringOrBuffer(stream, protocolId)stream.write(protocolVersion === 4 ?protocol.VERSION4 :protocolVersion === 5 ?protocol.VERSION5 :protocol.VERSION3)// Connect flagsvar flags = 0flags |= (username != null) ? protocol.USERNAME_MASK : 0flags |= (password != null) ? protocol.PASSWORD_MASK : 0flags |= (will && will.retain) ? protocol.WILL_RETAIN_MASK : 0flags |= (will && will.qos) ? will.qos << protocol.WILL_QOS_SHIFT : 0flags |= will ? protocol.WILL_FLAG_MASK : 0flags |= clean ? protocol.CLEAN_SESSION_MASK : 0stream.write(Buffer.from([flags]))// KeepalivewriteNumber(stream, keepalive)// Propertiesif (protocolVersion === 5) {
propertiesData.write()}// Client IDwriteStringOrBuffer(stream, clientId)// Willif (will) {
if (protocolVersion === 5) {
willProperties.write()}writeString(stream, will.topic)writeStringOrBuffer(stream, will.payload)}// Username and passwordif (username != null) {
writeStringOrBuffer(stream, username)}if (password != null) {
writeStringOrBuffer(stream, password)}// This is a small packet that happens only once on a stream// We assume the stream is always free to receive more data after thisreturn true}function connack(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var rc = version === 5 ? settings.reasonCode : settings.returnCodevar properties = settings.propertiesvar length = 2 // length of rc and sessionHeader// Check return codeif (typeof rc !== 'number') {
stream.emit('error', new Error('Invalid return code'))return false}// mqtt5 propertiesvar propertiesData = nullif (version === 5) {
propertiesData = getProperties(stream, properties)length += propertiesData.length}stream.write(protocol.CONNACK_HEADER)// lengthwriteVarByteInt(stream, length)stream.write(settings.sessionPresent ? protocol.SESSIONPRESENT_HEADER : zeroBuf)stream.write(Buffer.from([rc]))if (propertiesData != null) {
propertiesData.write()}return true}function publish(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var qos = settings.qos || 0var retain = settings.retain ? protocol.RETAIN_MASK : 0var topic = settings.topicvar payload = settings.payload || emptyvar id = settings.messageIdvar properties = settings.propertiesvar length = 0// Topic must be a non-empty string or Bufferif (typeof topic === 'string') length += Buffer.byteLength(topic) + 2else if (Buffer.isBuffer(topic)) length += topic.length + 2else {
stream.emit('error', new Error('Invalid topic'))return false}// Get the payload lengthif (!Buffer.isBuffer(payload)) length += Buffer.byteLength(payload)else length += payload.length// Message ID must a number if qos > 0if (qos && typeof id !== 'number') {
stream.emit('error', new Error('Invalid messageId'))return false} else if (qos) length += 2// mqtt5 propertiesvar propertiesData = nullif (version === 5) {
propertiesData = getProperties(stream, properties)length += propertiesData.length}// Headerstream.write(protocol.PUBLISH_HEADER[qos][settings.dup ? 1 : 0][retain ? 1 : 0])// Remaining lengthwriteVarByteInt(stream, length)// TopicwriteNumber(stream, byteLength(topic))stream.write(topic)// Message IDif (qos > 0) writeNumber(stream, id)// Propertiesif (propertiesData != null) {
propertiesData.write()}// Payloadreturn stream.write(payload)}/* Puback, pubrec, pubrel and pubcomp */function confirmation(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var type = settings.cmd || 'puback'var id = settings.messageIdvar dup = (settings.dup && type === 'pubrel') ? protocol.DUP_MASK : 0var qos = 0var reasonCode = settings.reasonCodevar properties = settings.propertiesvar length = version === 5 ? 3 : 2if (type === 'pubrel') qos = 1// Check message IDif (typeof id !== 'number') {
stream.emit('error', new Error('Invalid messageId'))return false}// properies mqtt 5var propertiesData = nullif (version === 5) {
propertiesData = getPropertiesByMaximumPacketSize(stream, properties, opts, length)if (!propertiesData) {
return false}length += propertiesData.length}// Headerstream.write(protocol.ACKS[type][qos][dup][0])// LengthwriteVarByteInt(stream, length)// Message IDwriteNumber(stream, id)// reason code in headerif (version === 5) {
stream.write(Buffer.from([reasonCode]))}// properies mqtt 5if (propertiesData !== null) {
propertiesData.write()}return true}function subscribe(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var dup = settings.dup ? protocol.DUP_MASK : 0var id = settings.messageIdvar subs = settings.subscriptionsvar properties = settings.propertiesvar length = 0// Check message IDif (typeof id !== 'number') {
stream.emit('error', new Error('Invalid messageId'))return false} else length += 2// properies mqtt 5var propertiesData = nullif (version === 5) {
propertiesData = getProperties(stream, properties)length += propertiesData.length}// Check subscriptionsif (typeof subs === 'object' && subs.length) {
for (var i = 0; i < subs.length; i += 1) {
var itopic = subs[i].topicvar iqos = subs[i].qosif (typeof itopic !== 'string') {
stream.emit('error', new Error('Invalid subscriptions - invalid topic'))return false}if (typeof iqos !== 'number') {
stream.emit('error', new Error('Invalid subscriptions - invalid qos'))return false}if (version === 5) {
var nl = subs[i].nl || falseif (typeof nl !== 'boolean') {
stream.emit('error', new Error('Invalid subscriptions - invalid No Local'))return false}var rap = subs[i].rap || falseif (typeof rap !== 'boolean') {
stream.emit('error', new Error('Invalid subscriptions - invalid Retain as Published'))return false}var rh = subs[i].rh || 0if (typeof rh !== 'number' || rh > 2) {
stream.emit('error', new Error('Invalid subscriptions - invalid Retain Handling'))return false}}length += Buffer.byteLength(itopic) + 2 + 1}} else {
stream.emit('error', new Error('Invalid subscriptions'))return false}// Generate headerstream.write(protocol.SUBSCRIBE_HEADER[1][dup ? 1 : 0][0])// Generate lengthwriteVarByteInt(stream, length)// Generate message IDwriteNumber(stream, id)// properies mqtt 5if (propertiesData !== null) {
propertiesData.write()}var result = true// Generate subsfor (var j = 0; j < subs.length; j++) {
var sub = subs[j]var jtopic = sub.topicvar jqos = sub.qosvar jnl = +sub.nlvar jrap = +sub.rapvar jrh = sub.rhvar joptions// Write topic stringwriteString(stream, jtopic)// options processjoptions = protocol.SUBSCRIBE_OPTIONS_QOS[jqos]if (version === 5) {
joptions |= jnl ? protocol.SUBSCRIBE_OPTIONS_NL : 0joptions |= jrap ? protocol.SUBSCRIBE_OPTIONS_RAP : 0joptions |= jrh ? protocol.SUBSCRIBE_OPTIONS_RH[jrh] : 0}// Write optionsresult = stream.write(Buffer.from([joptions]))}return result}function suback(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var id = settings.messageIdvar granted = settings.grantedvar properties = settings.propertiesvar length = 0// Check message IDif (typeof id !== 'number') {
stream.emit('error', new Error('Invalid messageId'))return false} else length += 2// Check granted qos vectorif (typeof granted === 'object' && granted.length) {
for (var i = 0; i < granted.length; i += 1) {
if (typeof granted[i] !== 'number') {
stream.emit('error', new Error('Invalid qos vector'))return false}length += 1}} else {
stream.emit('error', new Error('Invalid qos vector'))return false}// properies mqtt 5var propertiesData = nullif (version === 5) {
propertiesData = getPropertiesByMaximumPacketSize(stream, properties, opts, length)if (!propertiesData) {
return false}length += propertiesData.length}// headerstream.write(protocol.SUBACK_HEADER)// LengthwriteVarByteInt(stream, length)// Message IDwriteNumber(stream, id)// properies mqtt 5if (propertiesData !== null) {
propertiesData.write()}return stream.write(Buffer.from(granted))}function unsubscribe(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var id = settings.messageIdvar dup = settings.dup ? protocol.DUP_MASK : 0var unsubs = settings.unsubscriptionsvar properties = settings.propertiesvar length = 0// Check message IDif (typeof id !== 'number') {
stream.emit('error', new Error('Invalid messageId'))return false} else {
length += 2}// Check unsubsif (typeof unsubs === 'object' && unsubs.length) {
for (var i = 0; i < unsubs.length; i += 1) {
if (typeof unsubs[i] !== 'string') {
stream.emit('error', new Error('Invalid unsubscriptions'))return false}length += Buffer.byteLength(unsubs[i]) + 2}} else {
stream.emit('error', new Error('Invalid unsubscriptions'))return false}// properies mqtt 5var propertiesData = nullif (version === 5) {
propertiesData = getProperties(stream, properties)length += propertiesData.length}// Headerstream.write(protocol.UNSUBSCRIBE_HEADER[1][dup ? 1 : 0][0])// LengthwriteVarByteInt(stream, length)// Message IDwriteNumber(stream, id)// properies mqtt 5if (propertiesData !== null) {
propertiesData.write()}// Unsubsvar result = truefor (var j = 0; j < unsubs.length; j++) {
result = writeString(stream, unsubs[j])}return result}function unsuback(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var id = settings.messageIdvar dup = settings.dup ? protocol.DUP_MASK : 0var granted = settings.grantedvar properties = settings.propertiesvar type = settings.cmdvar qos = 0var length = 2// Check message IDif (typeof id !== 'number') {
stream.emit('error', new Error('Invalid messageId'))return false}// Check grantedif (version === 5) {
if (typeof granted === 'object' && granted.length) {
for (var i = 0; i < granted.length; i += 1) {
if (typeof granted[i] !== 'number') {
stream.emit('error', new Error('Invalid qos vector'))return false}length += 1}} else {
stream.emit('error', new Error('Invalid qos vector'))return false}}// properies mqtt 5var propertiesData = nullif (version === 5) {
propertiesData = getPropertiesByMaximumPacketSize(stream, properties, opts, length)if (!propertiesData) {
return false}length += propertiesData.length}// Headerstream.write(protocol.ACKS[type][qos][dup][0])// LengthwriteVarByteInt(stream, length)// Message IDwriteNumber(stream, id)// properies mqtt 5if (propertiesData !== null) {
propertiesData.write()}// payloadif (version === 5) {
stream.write(Buffer.from(granted))}return true}function emptyPacket(packet, stream, opts) {
return stream.write(protocol.EMPTY[packet.cmd])}function disconnect(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var reasonCode = settings.reasonCodevar properties = settings.propertiesvar length = version === 5 ? 1 : 0// properies mqtt 5var propertiesData = nullif (version === 5) {
propertiesData = getPropertiesByMaximumPacketSize(stream, properties, opts, length)if (!propertiesData) {
return false}length += propertiesData.length}// Headerstream.write(Buffer.from([protocol.codes['disconnect'] << 4]))// LengthwriteVarByteInt(stream, length)// reason code in headerif (version === 5) {
stream.write(Buffer.from([reasonCode]))}// properies mqtt 5if (propertiesData !== null) {
propertiesData.write()}return true}function auth(packet, stream, opts) {
var version = opts ? opts.protocolVersion : 4var settings = packet || {
}var reasonCode = settings.reasonCodevar properties = settings.propertiesvar length = version === 5 ? 1 : 0if (version !== 5) stream.emit('error', new Error('Invalid mqtt version for auth packet'))// properies mqtt 5var propertiesData = getPropertiesByMaximumPacketSize(stream, properties, opts, length)if (!propertiesData) {
return false}length += propertiesData.length// Headerstream.write(Buffer.from([protocol.codes['auth'] << 4]))// LengthwriteVarByteInt(stream, length)// reason code in headerstream.write(Buffer.from([reasonCode]))// properies mqtt 5if (propertiesData !== null) {
propertiesData.write()}return true}/*** writeVarByteInt - write an MQTT style variable byte integer to the buffer** @param <Buffer> buffer - destination* @param <Number> pos - offset* @param <Number> length - length (>0)* @returns <Number> number of bytes written** @api private*/var varByteIntCache = {
}function writeVarByteInt(stream, num) {
var buffer = varByteIntCache[num]if (!buffer) {
buffer = genBufVariableByteInt(num).dataif (num < 16384) varByteIntCache[num] = buffer}stream.write(buffer)}/*** writeString - write a utf8 string to the buffer** @param <Buffer> buffer - destination* @param <Number> pos - offset* @param <String> string - string to write* @return <Number> number of bytes written** @api private*/function writeString(stream, string) {
var strlen = Buffer.byteLength(string)writeNumber(stream, strlen)stream.write(string, 'utf8')}/*** writeStringPair - write a utf8 string pairs to the buffer** @param <Buffer> buffer - destination* @param <String> name - string name to write* @param <String> value - string value to write* @return <Number> number of bytes written** @api private*/function writeStringPair(stream, name, value) {
writeString(stream, name)writeString(stream, value)}/*** writeNumber - write a two byte number to the buffer** @param <Buffer> buffer - destination* @param <Number> pos - offset* @param <String> number - number to write* @return <Number> number of bytes written** @api private*/function writeNumberCached(stream, number) {
return stream.write(numCache[number])}function writeNumberGenerated(stream, number) {
return stream.write(generateNumber(number))}function write4ByteNumber(stream, number) {
return stream.write(generate4ByteBuffer(number))}/*** writeStringOrBuffer - write a String or Buffer with the its length prefix** @param <Buffer> buffer - destination* @param <Number> pos - offset* @param <String> toWrite - String or Buffer* @return <Number> number of bytes written*/function writeStringOrBuffer(stream, toWrite) {
if (typeof toWrite === 'string') {
writeString(stream, toWrite)} else if (toWrite) {
writeNumber(stream, toWrite.length)stream.write(toWrite)} else writeNumber(stream, 0)}function getProperties(stream, properties) {
/* connect properties */if (typeof properties !== 'object' || properties.length != null) {
return {
length: 1,write: function () {
writeProperties(stream, {
}, 0)}}}var propertiesLength = 0function getLengthProperty(name) {
var type = protocol.propertiesTypes[name]var value = properties[name]var length = 0switch (type) {
case 'byte': {
if (typeof value !== 'boolean') {
stream.emit('error', new Error('Invalid ' + name))return false}length += 1 + 1break}case 'int8': {
if (typeof value !== 'number') {
stream.emit('error', new Error('Invalid ' + name))return false}length += 1 + 1break}case 'binary': {
if (value && value === null) {
stream.emit('error', new Error('Invalid ' + name))return false}length += 1 + Buffer.byteLength(value) + 2break}case 'int16': {
if (typeof value !== 'number') {
stream.emit('error', new Error('Invalid ' + name))return false}length += 1 + 2break}case 'int32': {
if (typeof value !== 'number') {
stream.emit('error', new Error('Invalid ' + name))return false}length += 1 + 4break}case 'var': {
if (typeof value !== 'number') {
stream.emit('error', new Error('Invalid ' + name))return false}length += 1 + genBufVariableByteInt(value).lengthbreak}case 'string': {
if (typeof value !== 'string') {
stream.emit('error', new Error('Invalid ' + name))return false}length += 1 + 2 + Buffer.byteLength(value.toString())break}case 'pair': {
if (typeof value !== 'object') {
stream.emit('error', new Error('Invalid ' + name))return false}length += Object.getOwnPropertyNames(value).reduce(function (result, name) {
result += 1 + 2 + Buffer.byteLength(name.toString()) + 2 + Buffer.byteLength(value[name].toString())return result}, 0)break}default: {
stream.emit('error', new Error('Invalid property ' + name))return false}}return length}if (properties) {
for (var propName in properties) {
var propLength = getLengthProperty(propName)if (!propLength) return falsepropertiesLength += propLength}}var propertiesLengthLength = genBufVariableByteInt(propertiesLength).lengthreturn {
length: propertiesLengthLength + propertiesLength,write: function () {
writeProperties(stream, properties, propertiesLength)}}}function getPropertiesByMaximumPacketSize(stream, properties, opts, length) {
var mayEmptyProps = ['reasonString', 'userProperties']var maximumPacketSize = opts && opts.properties && opts.properties.maximumPacketSize ? opts.properties.maximumPacketSize : 0var propertiesData = getProperties(stream, properties)if (maximumPacketSize) {
while (length + propertiesData.length > maximumPacketSize) {
var currentMayEmptyProp = mayEmptyProps.shift()if (currentMayEmptyProp && properties[currentMayEmptyProp]) {
delete properties[currentMayEmptyProp]propertiesData = getProperties(stream, properties)} else {
return false}}}return propertiesData}function writeProperties(stream, properties, propertiesLength) {
/* write properties to stream */writeVarByteInt(stream, propertiesLength)for (var propName in properties) {
if (properties.hasOwnProperty(propName) && properties[propName] !== null) {
var value = properties[propName]var type = protocol.propertiesTypes[propName]switch (type) {
case 'byte': {
stream.write(Buffer.from([protocol.properties[propName]]))stream.write(Buffer.from([+value]))break}case 'int8': {
stream.write(Buffer.from([protocol.properties[propName]]))stream.write(Buffer.from([value]))break}case 'binary': {
stream.write(Buffer.from([protocol.properties[propName]]))writeStringOrBuffer(stream, value)break}case 'int16': {
stream.write(Buffer.from([protocol.properties[propName]]))writeNumber(stream, value)break}case 'int32': {
stream.write(Buffer.from([protocol.properties[propName]]))write4ByteNumber(stream, value)break}case 'var': {
stream.write(Buffer.from([protocol.properties[propName]]))writeVarByteInt(stream, value)break}case 'string': {
stream.write(Buffer.from([protocol.properties[propName]]))writeString(stream, value)break}case 'pair': {
Object.getOwnPropertyNames(value).forEach(function (name) {
stream.write(Buffer.from([protocol.properties[propName]]))writeStringPair(stream, name.toString(), value[name].toString())})break}default: {
stream.emit('error', new Error('Invalid property ' + propName))return false}}}}}function byteLength(bufOrString) {
if (!bufOrString) return 0else if (bufOrString instanceof Buffer) return bufOrString.lengthelse return Buffer.byteLength(bufOrString)}function isStringOrBuffer(field) {
return typeof field === 'string' || field instanceof Buffer}module.exports = generate}, {
"./constants": 82,"./numbers": 86,"process-nextick-args": 91,"safe-buffer": 110}],90: [function (require, module, exports) {
var wrappy = require('wrappy')module.exports = wrappy(once)module.exports.strict = wrappy(onceStrict)once.proto = once(function () {
Object.defineProperty(Function.prototype, 'once', {
value: function () {
return once(this)},configurable: true})Object.defineProperty(Function.prototype, 'onceStrict', {
value: function () {
return onceStrict(this)},configurable: true})})function once(fn) {
var f = function () {
if (f.called) return f.valuef.called = truereturn f.value = fn.apply(this, arguments)}f.called = falsereturn f}function onceStrict(fn) {
var f = function () {
if (f.called)throw new Error(f.onceError)f.called = truereturn f.value = fn.apply(this, arguments)}var name = fn.name || 'Function wrapped with `once`'f.onceError = name + " shouldn't be called more than once"f.called = falsereturn f}}, {
"wrappy": 120}],91: [function (require, module, exports) {
(function (process) {
'use strict';if (!process.version ||process.version.indexOf('v0.') === 0 ||process.version.indexOf('v1.') === 0 && process.version.indexOf('v1.8.') !== 0) {
module.exports = {
nextTick: nextTick};} else {
module.exports = process}function nextTick(fn, arg1, arg2, arg3) {
if (typeof fn !== 'function') {
throw new TypeError('"callback" argument must be a function');}var len = arguments.length;var args, i;switch (len) {
case 0:case 1:return process.nextTick(fn);case 2:return process.nextTick(function afterTickOne() {
fn.call(null, arg1);});case 3:return process.nextTick(function afterTickTwo() {
fn.call(null, arg1, arg2);});case 4:return process.nextTick(function afterTickThree() {
fn.call(null, arg1, arg2, arg3);});default:args = new Array(len - 1);i = 0;while (i < args.length) {
args[i++] = arguments[i];}return process.nextTick(function afterTick() {
fn.apply(null, args);});}}}).call(this, require('_process'))}, {
"_process": 92}],92: [function (require, module, exports) {
// shim for using process in browservar process = module.exports = {
};// cached from whatever global is present so that test runners that stub it// don't break things. But we need to wrap it in a try catch in case it is// wrapped in strict mode code which doesn't define any globals. It's inside a// function because try/catches deoptimize in certain engines.var cachedSetTimeout;var cachedClearTimeout;function defaultSetTimout() {
throw new Error('setTimeout has not been defined');}function defaultClearTimeout() {
throw new Error('clearTimeout has not been defined');}(function () {
try {
if (typeof setTimeout === 'function') {
cachedSetTimeout = setTimeout;} else {
cachedSetTimeout = defaultSetTimout;}} catch (e) {
cachedSetTimeout = defaultSetTimout;}try {
if (typeof clearTimeout === 'function') {
cachedClearTimeout = clearTimeout;} else {
cachedClearTimeout = defaultClearTimeout;}} catch (e) {
cachedClearTimeout = defaultClearTimeout;}}())function runTimeout(fun) {
if (cachedSetTimeout === setTimeout) {
//normal enviroments in sane situationsreturn setTimeout(fun, 0);}// if setTimeout wasn't available but was latter definedif ((cachedSetTimeout === defaultSetTimout || !cachedSetTimeout) && setTimeout) {
cachedSetTimeout = setTimeout;return setTimeout(fun, 0);}try {
// when when somebody has screwed with setTimeout but no I.E. maddnessreturn cachedSetTimeout(fun, 0);} catch (e) {
try {
// When we are in I.E. but the script has been evaled so I.E. doesn't trust the global object when called normallyreturn cachedSetTimeout.call(null, fun, 0);} catch (e) {
// same as above but when it's a version of I.E. that must have the global object for 'this', hopfully our context correct otherwise it will throw a global errorreturn cachedSetTimeout.call(this, fun, 0);}}}function runClearTimeout(marker) {
if (cachedClearTimeout === clearTimeout) {
//normal enviroments in sane situationsreturn clearTimeout(marker);}// if clearTimeout wasn't available but was latter definedif ((cachedClearTimeout === defaultClearTimeout || !cachedClearTimeout) && clearTimeout) {
cachedClearTimeout = clearTimeout;return clearTimeout(marker);}try {
// when when somebody has screwed with setTimeout but no I.E. maddnessreturn cachedClearTimeout(marker);} catch (e) {
try {
// When we are in I.E. but the script has been evaled so I.E. doesn't trust the global object when called normallyreturn cachedClearTimeout.call(null, marker);} catch (e) {
// same as above but when it's a version of I.E. that must have the global object for 'this', hopfully our context correct otherwise it will throw a global error.// Some versions of I.E. have different rules for clearTimeout vs setTimeoutreturn cachedClearTimeout.call(this, marker);}}}var queue = [];var draining = false;var currentQueue;var queueIndex = -1;function cleanUpNextTick() {
if (!draining || !currentQueue) {
return;}draining = false;if (currentQueue.length) {
queue = currentQueue.concat(queue);} else {
queueIndex = -1;}if (queue.length) {
drainQueue();}}function drainQueue() {
if (draining) {
return;}var timeout = runTimeout(cleanUpNextTick);draining = true;var len = queue.length;while (len) {
currentQueue = queue;queue = [];while (++queueIndex < len) {
if (currentQueue) {
currentQueue[queueIndex].run();}}queueIndex = -1;len = queue.length;}currentQueue = null;draining = false;runClearTimeout(timeout);}process.nextTick = function (fun) {
var args = new Array(arguments.length - 1);if (arguments.length > 1) {
for (var i = 1; i < arguments.length; i++) {
args[i - 1] = arguments[i];}}queue.push(new Item(fun, args));if (queue.length === 1 && !draining) {
runTimeout(drainQueue);}};// v8 likes predictible objectsfunction Item(fun, array) {
this.fun = fun;this.array = array;}Item.prototype.run = function () {
this.fun.apply(null, this.array);};process.title = 'browser';process.browser = true;process.env = {
};process.argv = [];process.version = ''; // empty string to avoid regexp issuesprocess.versions = {
};function noop() {
}process.on = noop;process.addListener = noop;process.once = noop;process.off = noop;process.removeListener = noop;process.removeAllListeners = noop;process.emit = noop;process.prependListener = noop;process.prependOnceListener = noop;process.listeners = function (name) {
return []}process.binding = function (name) {
throw new Error('process.binding is not supported');};process.cwd = function () {
return '/'};process.chdir = function (dir) {
throw new Error('process.chdir is not supported');};process.umask = function () {
return 0;};}, {
}],93: [function (require, module, exports) {
(function (global) {
/*! https://mths.be/punycode v1.4.1 by @mathias */;(function (root) {
/** Detect free variables */var freeExports = typeof exports == 'object' && exports &&!exports.nodeType && exports;var freeModule = typeof module == 'object' && module &&!module.nodeType && module;var freeGlobal = typeof global == 'object' && global;if (freeGlobal.global === freeGlobal ||freeGlobal.window === freeGlobal ||freeGlobal.self === freeGlobal) {
root = freeGlobal;}/*** The `punycode` object.* @name punycode* @type Object*/var punycode,/** Highest positive signed 32-bit float value */maxInt = 2147483647, // aka. 0x7FFFFFFF or 2^31-1/** Bootstring parameters */base = 36,tMin = 1,tMax = 26,skew = 38,damp = 700,initialBias = 72,initialN = 128, // 0x80delimiter = '-', // '\x2D'/** Regular expressions */regexPunycode = /^xn--/,regexNonASCII = /[^\x20-\x7E]/, // unprintable ASCII chars + non-ASCII charsregexSeparators = /[\x2E\u3002\uFF0E\uFF61]/g, // RFC 3490 separators/** Error messages */errors = {
'overflow': 'Overflow: input needs wider integers to process','not-basic': 'Illegal input >= 0x80 (not a basic code point)','invalid-input': 'Invalid input'},/** Convenience shortcuts */baseMinusTMin = base - tMin,floor = Math.floor,stringFromCharCode = String.fromCharCode,/** Temporary variable */key;/*--------------------------------------------------------------------------*//*** A generic error utility function.* @private* @param {String} type The error type.* @returns {Error} Throws a `RangeError` with the applicable error message.*/function error(type) {
throw new RangeError(errors[type]);}/*** A generic `Array#map` utility function.* @private* @param {Array} array The array to iterate over.* @param {Function} callback The function that gets called for every array* item.* @returns {Array} A new array of values returned by the callback function.*/function map(array, fn) {
var length = array.length;var result = [];while (length--) {
result[length] = fn(array[length]);}return result;}/*** A simple `Array#map`-like wrapper to work with domain name strings or email* addresses.* @private* @param {String} domain The domain name or email address.* @param {Function} callback The function that gets called for every* character.* @returns {Array} A new string of characters returned by the callback* function.*/function mapDomain(string, fn) {
var parts = string.split('@');var result = '';if (parts.length > 1) {
// In email addresses, only the domain name should be punycoded. Leave// the local part (i.e. everything up to `@`) intact.result = parts[0] + '@';string = parts[1];}// Avoid `split(regex)` for IE8 compatibility. See #17.string = string.replace(regexSeparators, '\x2E');var labels = string.split('.');var encoded = map(labels, fn).join('.');return result + encoded;}/*** Creates an array containing the numeric code points of each Unicode* character in the string. While JavaScript uses UCS-2 internally,* this function will convert a pair of surrogate halves (each of which* UCS-2 exposes as separate characters) into a single code point,* matching UTF-16.* @see `punycode.ucs2.encode`* @see <https://mathiasbynens.be/notes/javascript-encoding>* @memberOf punycode.ucs2* @name decode* @param {String} string The Unicode input string (UCS-2).* @returns {Array} The new array of code points.*/function ucs2decode(string) {
var output = [],counter = 0,length = string.length,value,extra;while (counter < length) {
value = string.charCodeAt(counter++);if (value >= 0xD800 && value <= 0xDBFF && counter < length) {
// high surrogate, and there is a next characterextra = string.charCodeAt(counter++);if ((extra & 0xFC00) == 0xDC00) {
// low surrogateoutput.push(((value & 0x3FF) << 10) + (extra & 0x3FF) + 0x10000);} else {
// unmatched surrogate; only append this code unit, in case the next// code unit is the high surrogate of a surrogate pairoutput.push(value);counter--;}} else {
output.push(value);}}return output;}/*** Creates a string based on an array of numeric code points.* @see `punycode.ucs2.decode`* @memberOf punycode.ucs2* @name encode* @param {Array} codePoints The array of numeric code points.* @returns {String} The new Unicode string (UCS-2).*/function ucs2encode(array) {
return map(array, function (value) {
var output = '';if (value > 0xFFFF) {
value -= 0x10000;output += stringFromCharCode(value >>> 10 & 0x3FF | 0xD800);value = 0xDC00 | value & 0x3FF;}output += stringFromCharCode(value);return output;}).join('');}