Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

home-assistant-js-websocket

Package Overview
Dependencies
Maintainers
1
Versions
102
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

home-assistant-js-websocket - npm Package Compare versions

Comparing version 0.1.4 to 0.2.0

303

dist/haws.cjs.js

@@ -1,302 +0,1 @@

'use strict';
Object.defineProperty(exports, '__esModule', { value: true });
function auth(authToken) {
return {
type: 'auth',
api_password: authToken,
};
}
function states() {
return {
type: 'get_states',
};
}
function config() {
return {
type: 'get_config',
};
}
function services() {
return {
type: 'get_services',
};
}
function panels() {
return {
type: 'get_panels',
};
}
function callService$1(domain, service, serviceData) {
var message = {
type: 'call_service',
domain: domain,
service: service,
};
if (serviceData) {
message.service_data = serviceData;
}
return message;
}
function subscribeEvents$1(eventType) {
var message = {
type: 'subscribe_events',
};
if (eventType) {
message.event_type = eventType;
}
return message;
}
function unsubscribeEvents(subscription) {
return {
type: 'unsubscribe_events',
subscription: subscription,
};
}
function ping$1() {
return {
type: 'ping',
};
}
var ERR_CANNOT_CONNECT = 1;
var ERR_INVALID_AUTH = 2;
function extractResult(message) {
return message.result;
}
var Connection = function Connection(url, options) {
this.url = url;
this.options = options || {};
this.commandId = 1;
this.commands = {};
this.connectionTries = 0;
this.eventListeners = {};
this.closeRequested = false;
};
Connection.prototype.addEventListener = function addEventListener (eventType, callback) {
var listeners = this.eventListeners[eventType];
if (!listeners) {
listeners = this.eventListeners[eventType] = [];
}
listeners.push(callback);
};
Connection.prototype.fireEvent = function fireEvent (eventType) {
var this$1 = this;
(this.eventListeners[eventType] || []).forEach(function (callback) { return callback(this$1); });
};
Connection.prototype.connect = function connect () {
var this$1 = this;
return new Promise(function (resolve, reject) {
// Used for resubscribing in the future
var oldCommands = this$1.commands;
Object.keys(oldCommands).forEach(function (id) {
var info = oldCommands[id];
// Reject stuff still waiting for an answer
if (info.reject) {
info.reject();
}
});
// If invalid auth, we will not try to reconnect.
var invalidAuth = false;
this$1.connectionTries += 1;
this$1.socket = new WebSocket(this$1.url);
this$1.socket.addEventListener('open', function () {
this$1.connectionTries = 0;
});
this$1.socket.addEventListener('message', function (event) {
var message = JSON.parse(event.data);
{
/* eslint-disable no-console */
console.log('Received', message);
/* eslint-enable no-console */
}
switch (message.type) {
case 'event':
this$1.commands[message.id].eventCallback(message.event);
break;
case 'result':
if (message.success) {
this$1.commands[message.id].resolve(message);
} else {
this$1.commands[message.id].reject(message.error);
}
delete this$1.commands[message.id];
break;
case 'pong':
break;
case 'auth_required':
this$1.sendMessage(auth(this$1.options.authToken));
break;
case 'auth_invalid':
reject({ code: ERR_INVALID_AUTH });
invalidAuth = true;
break;
case 'auth_ok':
resolve(this$1);
this$1.fireEvent('ready');
// Re-subscribe to events and update old location of unsub method
// so old unsub method keeps working.
this$1.commandId = 1;
this$1.commands = {};
Object.keys(oldCommands).forEach(function (id) {
var info = oldCommands[id];
if (info.eventType) {
this$1.subscribeEvents(info.eventCallback, info.eventType)
.then(function (unsub) { info.unsubscribe = unsub; });
}
});
break;
default:
{
/* eslint-disable no-console */
console.warn('Unhandled message', message);
/* eslint-enable no-console */
}
}
});
this$1.socket.addEventListener('close', function () {
if (invalidAuth || this$1.closeRequested) {
// When we have invalid auth, let's not reconnect or we get banned.
return;
} else if (this$1.connectionTries === 0) {
// We were connected at some point.
this$1.fireEvent('disconnected');
} else {
// We never were connected
reject(ERR_CANNOT_CONNECT);
}
// Try again
var waitTime = Math.min(this$1.connectionTries, 5) * 1000;
setTimeout(function () { return this$1.connect(); }, waitTime);
});
});
};
Connection.prototype.close = function close () {
this.closeRequested = true;
this.socket.close();
};
Connection.prototype.getStates = function getStates () {
return this.sendMessagePromise(states()).then(extractResult);
};
Connection.prototype.getServices = function getServices () {
return this.sendMessagePromise(services()).then(extractResult);
};
Connection.prototype.getPanels = function getPanels () {
return this.sendMessagePromise(panels()).then(extractResult);
};
Connection.prototype.getConfig = function getConfig () {
return this.sendMessagePromise(config()).then(extractResult);
};
Connection.prototype.callService = function callService (domain, service, serviceData) {
return this.sendMessagePromise(callService$1(domain, service, serviceData));
};
// eventCallback will be called when a new event fires
// Returned promise resolves to an unsubscribe function.
Connection.prototype.subscribeEvents = function subscribeEvents (eventCallback, eventType) {
var this$1 = this;
return this.sendMessagePromise(subscribeEvents$1(eventType)).then(
function (resultMessage) {
// We store unsubscribe on info object. That way we can overwrite it in case
// we get disconnected and we have to subscribe again.
var info = {
eventCallback: eventCallback,
eventType: eventType,
unsubscribe: function () { return this$1.sendMessagePromise(unsubscribeEvents(resultMessage.id))
.then(function () { delete this$1.commands[resultMessage.id]; }); },
};
this$1.commands[resultMessage.id] = info;
return function () { return info.unsubscribe(); };
/* eslint-disable comma-dangle */ /* comma crashes Buble */
}
/* eslint-enable comma-dangle */
);
};
Connection.prototype.ping = function ping () {
return this.sendMessagePromise(ping$1());
};
Connection.prototype.sendMessage = function sendMessage (message) {
{
/* eslint-disable no-console */
console.log('Sending', message);
/* eslint-enable no-console */
}
this.socket.send(JSON.stringify(message));
};
Connection.prototype.sendMessagePromise = function sendMessagePromise (message) {
var this$1 = this;
return new Promise(function (resolve, reject) {
this$1.commandId += 1;
var commandId = this$1.commandId;
/* eslint-disable no-param-reassign */
message.id = commandId;
/* eslint-enable no-param-reassign */
this$1.commands[commandId] = { resolve: resolve, reject: reject };
this$1.sendMessage(message);
});
};
function createConnection(url, options) {
var conn = new Connection(url, options);
return conn.connect();
}
exports.ERR_CANNOT_CONNECT = ERR_CANNOT_CONNECT;
exports.ERR_INVALID_AUTH = ERR_INVALID_AUTH;
exports.createConnection = createConnection;
exports['default'] = createConnection;
//# sourceMappingURL=data:application/json;charset=utf-8;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjpudWxsLCJzb3VyY2VzIjpbIi4uL2xpYi9tZXNzYWdlcy5qcyIsIi4uL2xpYi9pbmRleC5qcyJdLCJzb3VyY2VzQ29udGVudCI6WyJleHBvcnQgZnVuY3Rpb24gYXV0aChhdXRoVG9rZW4pIHtcbiAgcmV0dXJuIHtcbiAgICB0eXBlOiAnYXV0aCcsXG4gICAgYXBpX3Bhc3N3b3JkOiBhdXRoVG9rZW4sXG4gIH07XG59XG5cbmV4cG9ydCBmdW5jdGlvbiBzdGF0ZXMoKSB7XG4gIHJldHVybiB7XG4gICAgdHlwZTogJ2dldF9zdGF0ZXMnLFxuICB9O1xufVxuXG5leHBvcnQgZnVuY3Rpb24gY29uZmlnKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfY29uZmlnJyxcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHNlcnZpY2VzKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfc2VydmljZXMnLFxuICB9O1xufVxuXG5leHBvcnQgZnVuY3Rpb24gcGFuZWxzKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfcGFuZWxzJyxcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNhbGxTZXJ2aWNlKGRvbWFpbiwgc2VydmljZSwgc2VydmljZURhdGEpIHtcbiAgY29uc3QgbWVzc2FnZSA9IHtcbiAgICB0eXBlOiAnY2FsbF9zZXJ2aWNlJyxcbiAgICBkb21haW4sXG4gICAgc2VydmljZSxcbiAgfTtcblxuICBpZiAoc2VydmljZURhdGEpIHtcbiAgICBtZXNzYWdlLnNlcnZpY2VfZGF0YSA9IHNlcnZpY2VEYXRhO1xuICB9XG5cbiAgcmV0dXJuIG1lc3NhZ2U7XG59XG5cbmV4cG9ydCBmdW5jdGlvbiBzdWJzY3JpYmVFdmVudHMoZXZlbnRUeXBlKSB7XG4gIGNvbnN0IG1lc3NhZ2UgPSB7XG4gICAgdHlwZTogJ3N1YnNjcmliZV9ldmVudHMnLFxuICB9O1xuXG4gIGlmIChldmVudFR5cGUpIHtcbiAgICBtZXNzYWdlLmV2ZW50X3R5cGUgPSBldmVudFR5cGU7XG4gIH1cblxuICByZXR1cm4gbWVzc2FnZTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHVuc3Vic2NyaWJlRXZlbnRzKHN1YnNjcmlwdGlvbikge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICd1bnN1YnNjcmliZV9ldmVudHMnLFxuICAgIHN1YnNjcmlwdGlvbixcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHBpbmcoKSB7XG4gIHJldHVybiB7XG4gICAgdHlwZTogJ3BpbmcnLFxuICB9O1xufVxuIiwiaW1wb3J0ICogYXMgbWVzc2FnZXMgZnJvbSAnLi9tZXNzYWdlcyc7XG5cbmV4cG9ydCBjb25zdCBFUlJfQ0FOTk9UX0NPTk5FQ1QgPSAxO1xuZXhwb3J0IGNvbnN0IEVSUl9JTlZBTElEX0FVVEggPSAyO1xuXG5mdW5jdGlvbiBleHRyYWN0UmVzdWx0KG1lc3NhZ2UpIHtcbiAgcmV0dXJuIG1lc3NhZ2UucmVzdWx0O1xufVxuXG5jbGFzcyBDb25uZWN0aW9uIHtcbiAgY29uc3RydWN0b3IodXJsLCBvcHRpb25zKSB7XG4gICAgdGhpcy51cmwgPSB1cmw7XG4gICAgdGhpcy5vcHRpb25zID0gb3B0aW9ucyB8fCB7fTtcbiAgICB0aGlzLmNvbW1hbmRJZCA9IDE7XG4gICAgdGhpcy5jb21tYW5kcyA9IHt9O1xuICAgIHRoaXMuY29ubmVjdGlvblRyaWVzID0gMDtcbiAgICB0aGlzLmV2ZW50TGlzdGVuZXJzID0ge307XG4gICAgdGhpcy5jbG9zZVJlcXVlc3RlZCA9IGZhbHNlO1xuICB9XG5cbiAgYWRkRXZlbnRMaXN0ZW5lcihldmVudFR5cGUsIGNhbGxiYWNrKSB7XG4gICAgbGV0IGxpc3RlbmVycyA9IHRoaXMuZXZlbnRMaXN0ZW5lcnNbZXZlbnRUeXBlXTtcblxuICAgIGlmICghbGlzdGVuZXJzKSB7XG4gICAgICBsaXN0ZW5lcnMgPSB0aGlzLmV2ZW50TGlzdGVuZXJzW2V2ZW50VHlwZV0gPSBbXTtcbiAgICB9XG5cbiAgICBsaXN0ZW5lcnMucHVzaChjYWxsYmFjayk7XG4gIH1cblxuICBmaXJlRXZlbnQoZXZlbnRUeXBlKSB7XG4gICAgKHRoaXMuZXZlbnRMaXN0ZW5lcnNbZXZlbnRUeXBlXSB8fCBbXSkuZm9yRWFjaChjYWxsYmFjayA9PiBjYWxsYmFjayh0aGlzKSk7XG4gIH1cblxuICBjb25uZWN0KCkge1xuICAgIHJldHVybiBuZXcgUHJvbWlzZSgocmVzb2x2ZSwgcmVqZWN0KSA9PiB7XG4gICAgICAvLyBVc2VkIGZvciByZXN1YnNjcmliaW5nIGluIHRoZSBmdXR1cmVcbiAgICAgIGNvbnN0IG9sZENvbW1hbmRzID0gdGhpcy5jb21tYW5kcztcbiAgICAgIE9iamVjdC5rZXlzKG9sZENvbW1hbmRzKS5mb3JFYWNoKChpZCkgPT4ge1xuICAgICAgICBjb25zdCBpbmZvID0gb2xkQ29tbWFuZHNbaWRdO1xuXG4gICAgICAgIC8vIFJlamVjdCBzdHVmZiBzdGlsbCB3YWl0aW5nIGZvciBhbiBhbnN3ZXJcbiAgICAgICAgaWYgKGluZm8ucmVqZWN0KSB7XG4gICAgICAgICAgaW5mby5yZWplY3QoKTtcbiAgICAgICAgfVxuICAgICAgfSk7XG5cbiAgICAgIC8vIElmIGludmFsaWQgYXV0aCwgd2Ugd2lsbCBub3QgdHJ5IHRvIHJlY29ubmVjdC5cbiAgICAgIGxldCBpbnZhbGlkQXV0aCA9IGZhbHNlO1xuXG4gICAgICB0aGlzLmNvbm5lY3Rpb25UcmllcyArPSAxO1xuICAgICAgdGhpcy5zb2NrZXQgPSBuZXcgV2ViU29ja2V0KHRoaXMudXJsKTtcblxuICAgICAgdGhpcy5zb2NrZXQuYWRkRXZlbnRMaXN0ZW5lcignb3BlbicsICgpID0+IHtcbiAgICAgICAgdGhpcy5jb25uZWN0aW9uVHJpZXMgPSAwO1xuICAgICAgfSk7XG5cbiAgICAgIHRoaXMuc29ja2V0LmFkZEV2ZW50TGlzdGVuZXIoJ21lc3NhZ2UnLCAoZXZlbnQpID0+IHtcbiAgICAgICAgY29uc3QgbWVzc2FnZSA9IEpTT04ucGFyc2UoZXZlbnQuZGF0YSk7XG5cbiAgICAgICAgaWYgKF9fREVWX18pIHtcbiAgICAgICAgICAvKiBlc2xpbnQtZGlzYWJsZSBuby1jb25zb2xlICovXG4gICAgICAgICAgY29uc29sZS5sb2coJ1JlY2VpdmVkJywgbWVzc2FnZSk7XG4gICAgICAgICAgLyogZXNsaW50LWVuYWJsZSBuby1jb25zb2xlICovXG4gICAgICAgIH1cblxuICAgICAgICBzd2l0Y2ggKG1lc3NhZ2UudHlwZSkge1xuICAgICAgICAgIGNhc2UgJ2V2ZW50JzpcbiAgICAgICAgICAgIHRoaXMuY29tbWFuZHNbbWVzc2FnZS5pZF0uZXZlbnRDYWxsYmFjayhtZXNzYWdlLmV2ZW50KTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAncmVzdWx0JzpcbiAgICAgICAgICAgIGlmIChtZXNzYWdlLnN1Y2Nlc3MpIHtcbiAgICAgICAgICAgICAgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXS5yZXNvbHZlKG1lc3NhZ2UpO1xuICAgICAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgICAgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXS5yZWplY3QobWVzc2FnZS5lcnJvcik7XG4gICAgICAgICAgICB9XG4gICAgICAgICAgICBkZWxldGUgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAncG9uZyc6XG4gICAgICAgICAgICBicmVhaztcblxuICAgICAgICAgIGNhc2UgJ2F1dGhfcmVxdWlyZWQnOlxuICAgICAgICAgICAgdGhpcy5zZW5kTWVzc2FnZShtZXNzYWdlcy5hdXRoKHRoaXMub3B0aW9ucy5hdXRoVG9rZW4pKTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAnYXV0aF9pbnZhbGlkJzpcbiAgICAgICAgICAgIHJlamVjdCh7IGNvZGU6IEVSUl9JTlZBTElEX0FVVEggfSk7XG4gICAgICAgICAgICBpbnZhbGlkQXV0aCA9IHRydWU7XG4gICAgICAgICAgICBicmVhaztcblxuICAgICAgICAgIGNhc2UgJ2F1dGhfb2snOlxuICAgICAgICAgICAgcmVzb2x2ZSh0aGlzKTtcbiAgICAgICAgICAgIHRoaXMuZmlyZUV2ZW50KCdyZWFkeScpO1xuXG4gICAgICAgICAgICAvLyBSZS1zdWJzY3JpYmUgdG8gZXZlbnRzIGFuZCB1cGRhdGUgb2xkIGxvY2F0aW9uIG9mIHVuc3ViIG1ldGhvZFxuICAgICAgICAgICAgLy8gc28gb2xkIHVuc3ViIG1ldGhvZCBrZWVwcyB3b3JraW5nLlxuICAgICAgICAgICAgdGhpcy5jb21tYW5kSWQgPSAxO1xuICAgICAgICAgICAgdGhpcy5jb21tYW5kcyA9IHt9O1xuXG4gICAgICAgICAgICBPYmplY3Qua2V5cyhvbGRDb21tYW5kcykuZm9yRWFjaCgoaWQpID0+IHtcbiAgICAgICAgICAgICAgY29uc3QgaW5mbyA9IG9sZENvbW1hbmRzW2lkXTtcblxuICAgICAgICAgICAgICBpZiAoaW5mby5ldmVudFR5cGUpIHtcbiAgICAgICAgICAgICAgICB0aGlzLnN1YnNjcmliZUV2ZW50cyhpbmZvLmV2ZW50Q2FsbGJhY2ssIGluZm8uZXZlbnRUeXBlKVxuICAgICAgICAgICAgICAgICAgLnRoZW4oKHVuc3ViKSA9PiB7IGluZm8udW5zdWJzY3JpYmUgPSB1bnN1YjsgfSk7XG4gICAgICAgICAgICAgIH1cbiAgICAgICAgICAgIH0pO1xuICAgICAgICAgICAgYnJlYWs7XG5cbiAgICAgICAgICBkZWZhdWx0OlxuICAgICAgICAgICAgaWYgKF9fREVWX18pIHtcbiAgICAgICAgICAgICAgLyogZXNsaW50LWRpc2FibGUgbm8tY29uc29sZSAqL1xuICAgICAgICAgICAgICBjb25zb2xlLndhcm4oJ1VuaGFuZGxlZCBtZXNzYWdlJywgbWVzc2FnZSk7XG4gICAgICAgICAgICAgIC8qIGVzbGludC1lbmFibGUgbm8tY29uc29sZSAqL1xuICAgICAgICAgICAgfVxuICAgICAgICB9XG4gICAgICB9KTtcblxuICAgICAgdGhpcy5zb2NrZXQuYWRkRXZlbnRMaXN0ZW5lcignY2xvc2UnLCAoKSA9PiB7XG4gICAgICAgIGlmIChpbnZhbGlkQXV0aCB8fCB0aGlzLmNsb3NlUmVxdWVzdGVkKSB7XG4gICAgICAgICAgLy8gV2hlbiB3ZSBoYXZlIGludmFsaWQgYXV0aCwgbGV0J3Mgbm90IHJlY29ubmVjdCBvciB3ZSBnZXQgYmFubmVkLlxuICAgICAgICAgIHJldHVybjtcbiAgICAgICAgfSBlbHNlIGlmICh0aGlzLmNvbm5lY3Rpb25UcmllcyA9PT0gMCkge1xuICAgICAgICAgIC8vIFdlIHdlcmUgY29ubmVjdGVkIGF0IHNvbWUgcG9pbnQuXG4gICAgICAgICAgdGhpcy5maXJlRXZlbnQoJ2Rpc2Nvbm5lY3RlZCcpO1xuICAgICAgICB9IGVsc2Uge1xuICAgICAgICAgIC8vIFdlIG5ldmVyIHdlcmUgY29ubmVjdGVkXG4gICAgICAgICAgcmVqZWN0KEVSUl9DQU5OT1RfQ09OTkVDVCk7XG4gICAgICAgIH1cblxuICAgICAgICAvLyBUcnkgYWdhaW5cbiAgICAgICAgY29uc3Qgd2FpdFRpbWUgPSBNYXRoLm1pbih0aGlzLmNvbm5lY3Rpb25UcmllcywgNSkgKiAxMDAwO1xuICAgICAgICBzZXRUaW1lb3V0KCgpID0+IHRoaXMuY29ubmVjdCgpLCB3YWl0VGltZSk7XG4gICAgICB9KTtcbiAgICB9KTtcbiAgfVxuXG4gIGNsb3NlKCkge1xuICAgIHRoaXMuY2xvc2VSZXF1ZXN0ZWQgPSB0cnVlO1xuICAgIHRoaXMuc29ja2V0LmNsb3NlKCk7XG4gIH1cblxuICBnZXRTdGF0ZXMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnN0YXRlcygpKS50aGVuKGV4dHJhY3RSZXN1bHQpO1xuICB9XG5cbiAgZ2V0U2VydmljZXMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnNlcnZpY2VzKCkpLnRoZW4oZXh0cmFjdFJlc3VsdCk7XG4gIH1cblxuICBnZXRQYW5lbHMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnBhbmVscygpKS50aGVuKGV4dHJhY3RSZXN1bHQpO1xuICB9XG5cbiAgZ2V0Q29uZmlnKCkge1xuICAgIHJldHVybiB0aGlzLnNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlcy5jb25maWcoKSkudGhlbihleHRyYWN0UmVzdWx0KTtcbiAgfVxuXG4gIGNhbGxTZXJ2aWNlKGRvbWFpbiwgc2VydmljZSwgc2VydmljZURhdGEpIHtcbiAgICByZXR1cm4gdGhpcy5zZW5kTWVzc2FnZVByb21pc2UobWVzc2FnZXMuY2FsbFNlcnZpY2UoZG9tYWluLCBzZXJ2aWNlLCBzZXJ2aWNlRGF0YSkpO1xuICB9XG5cbiAgLy8gZXZlbnRDYWxsYmFjayB3aWxsIGJlIGNhbGxlZCB3aGVuIGEgbmV3IGV2ZW50IGZpcmVzXG4gIC8vIFJldHVybmVkIHByb21pc2UgcmVzb2x2ZXMgdG8gYW4gdW5zdWJzY3JpYmUgZnVuY3Rpb24uXG4gIHN1YnNjcmliZUV2ZW50cyhldmVudENhbGxiYWNrLCBldmVudFR5cGUpIHtcbiAgICByZXR1cm4gdGhpcy5zZW5kTWVzc2FnZVByb21pc2UobWVzc2FnZXMuc3Vic2NyaWJlRXZlbnRzKGV2ZW50VHlwZSkpLnRoZW4oXG4gICAgICAocmVzdWx0TWVzc2FnZSkgPT4ge1xuICAgICAgICAvLyBXZSBzdG9yZSB1bnN1YnNjcmliZSBvbiBpbmZvIG9iamVjdC4gVGhhdCB3YXkgd2UgY2FuIG92ZXJ3cml0ZSBpdCBpbiBjYXNlXG4gICAgICAgIC8vIHdlIGdldCBkaXNjb25uZWN0ZWQgYW5kIHdlIGhhdmUgdG8gc3Vic2NyaWJlIGFnYWluLlxuICAgICAgICBjb25zdCBpbmZvID0ge1xuICAgICAgICAgIGV2ZW50Q2FsbGJhY2ssXG4gICAgICAgICAgZXZlbnRUeXBlLFxuICAgICAgICAgIHVuc3Vic2NyaWJlOiAoKSA9PiB0aGlzLnNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlcy51bnN1YnNjcmliZUV2ZW50cyhyZXN1bHRNZXNzYWdlLmlkKSlcbiAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAudGhlbigoKSA9PiB7IGRlbGV0ZSB0aGlzLmNvbW1hbmRzW3Jlc3VsdE1lc3NhZ2UuaWRdOyB9KSxcbiAgICAgICAgfTtcblxuICAgICAgICB0aGlzLmNvbW1hbmRzW3Jlc3VsdE1lc3NhZ2UuaWRdID0gaW5mbztcblxuICAgICAgICByZXR1cm4gKCkgPT4gaW5mby51bnN1YnNjcmliZSgpO1xuICAgICAgLyogZXNsaW50LWRpc2FibGUgY29tbWEtZGFuZ2xlICovIC8qIGNvbW1hIGNyYXNoZXMgQnVibGUgKi9cbiAgICAgIH1cbiAgICAgIC8qIGVzbGludC1lbmFibGUgY29tbWEtZGFuZ2xlICovXG4gICAgKTtcbiAgfVxuXG4gIHBpbmcoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnBpbmcoKSk7XG4gIH1cblxuICBzZW5kTWVzc2FnZShtZXNzYWdlKSB7XG4gICAgaWYgKF9fREVWX18pIHtcbiAgICAgIC8qIGVzbGludC1kaXNhYmxlIG5vLWNvbnNvbGUgKi9cbiAgICAgIGNvbnNvbGUubG9nKCdTZW5kaW5nJywgbWVzc2FnZSk7XG4gICAgICAvKiBlc2xpbnQtZW5hYmxlIG5vLWNvbnNvbGUgKi9cbiAgICB9XG5cbiAgICB0aGlzLnNvY2tldC5zZW5kKEpTT04uc3RyaW5naWZ5KG1lc3NhZ2UpKTtcbiAgfVxuXG4gIHNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlKSB7XG4gICAgcmV0dXJuIG5ldyBQcm9taXNlKChyZXNvbHZlLCByZWplY3QpID0+IHtcbiAgICAgIHRoaXMuY29tbWFuZElkICs9IDE7XG4gICAgICBjb25zdCBjb21tYW5kSWQgPSB0aGlzLmNvbW1hbmRJZDtcbiAgICAgIC8qIGVzbGludC1kaXNhYmxlIG5vLXBhcmFtLXJlYXNzaWduICovXG4gICAgICBtZXNzYWdlLmlkID0gY29tbWFuZElkO1xuICAgICAgLyogZXNsaW50LWVuYWJsZSBuby1wYXJhbS1yZWFzc2lnbiAqL1xuICAgICAgdGhpcy5jb21tYW5kc1tjb21tYW5kSWRdID0geyByZXNvbHZlLCByZWplY3QgfTtcbiAgICAgIHRoaXMuc2VuZE1lc3NhZ2UobWVzc2FnZSk7XG4gICAgfSk7XG4gIH1cbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNyZWF0ZUNvbm5lY3Rpb24odXJsLCBvcHRpb25zKSB7XG4gIGNvbnN0IGNvbm4gPSBuZXcgQ29ubmVjdGlvbih1cmwsIG9wdGlvbnMpO1xuICByZXR1cm4gY29ubi5jb25uZWN0KCk7XG59XG5cbmV4cG9ydCBkZWZhdWx0IGNyZWF0ZUNvbm5lY3Rpb247XG4iXSwibmFtZXMiOlsiY2FsbFNlcnZpY2UiLCJjb25zdCIsInN1YnNjcmliZUV2ZW50cyIsInBpbmciLCJ0aGlzIiwibWVzc2FnZXMuYXV0aCIsIm1lc3NhZ2VzLnN0YXRlcyIsIm1lc3NhZ2VzLnNlcnZpY2VzIiwibWVzc2FnZXMucGFuZWxzIiwibWVzc2FnZXMuY29uZmlnIiwibWVzc2FnZXMuY2FsbFNlcnZpY2UiLCJtZXNzYWdlcy5zdWJzY3JpYmVFdmVudHMiLCJtZXNzYWdlcy51bnN1YnNjcmliZUV2ZW50cyIsIm1lc3NhZ2VzLnBpbmciXSwibWFwcGluZ3MiOiI7Ozs7QUFBTyxTQUFTLElBQUksQ0FBQyxTQUFTLEVBQUU7RUFDOUIsT0FBTztJQUNMLElBQUksRUFBRSxNQUFNO0lBQ1osWUFBWSxFQUFFLFNBQVM7R0FDeEIsQ0FBQztDQUNIOztBQUVELEFBQU8sU0FBUyxNQUFNLEdBQUc7RUFDdkIsT0FBTztJQUNMLElBQUksRUFBRSxZQUFZO0dBQ25CLENBQUM7Q0FDSDs7QUFFRCxBQUFPLFNBQVMsTUFBTSxHQUFHO0VBQ3ZCLE9BQU87SUFDTCxJQUFJLEVBQUUsWUFBWTtHQUNuQixDQUFDO0NBQ0g7O0FBRUQsQUFBTyxTQUFTLFFBQVEsR0FBRztFQUN6QixPQUFPO0lBQ0wsSUFBSSxFQUFFLGNBQWM7R0FDckIsQ0FBQztDQUNIOztBQUVELEFBQU8sU0FBUyxNQUFNLEdBQUc7RUFDdkIsT0FBTztJQUNMLElBQUksRUFBRSxZQUFZO0dBQ25CLENBQUM7Q0FDSDs7QUFFRCxBQUFPLFNBQVNBLGFBQVcsQ0FBQyxNQUFNLEVBQUUsT0FBTyxFQUFFLFdBQVcsRUFBRTtFQUN4REMsSUFBTSxPQUFPLEdBQUc7SUFDZCxJQUFJLEVBQUUsY0FBYztJQUNwQixRQUFBLE1BQU07SUFDTixTQUFBLE9BQU87R0FDUixDQUFDOztFQUVGLElBQUksV0FBVyxFQUFFO0lBQ2YsT0FBTyxDQUFDLFlBQVksR0FBRyxXQUFXLENBQUM7R0FDcEM7O0VBRUQsT0FBTyxPQUFPLENBQUM7Q0FDaEI7O0FBRUQsQUFBTyxTQUFTQyxpQkFBZSxDQUFDLFNBQVMsRUFBRTtFQUN6Q0QsSUFBTSxPQUFPLEdBQUc7SUFDZCxJQUFJLEVBQUUsa0JBQWtCO0dBQ3pCLENBQUM7O0VBRUYsSUFBSSxTQUFTLEVBQUU7SUFDYixPQUFPLENBQUMsVUFBVSxHQUFHLFNBQVMsQ0FBQztHQUNoQzs7RUFFRCxPQUFPLE9BQU8sQ0FBQztDQUNoQjs7QUFFRCxBQUFPLFNBQVMsaUJBQWlCLENBQUMsWUFBWSxFQUFFO0VBQzlDLE9BQU87SUFDTCxJQUFJLEVBQUUsb0JBQW9CO0lBQzFCLGNBQUEsWUFBWTtHQUNiLENBQUM7Q0FDSDs7QUFFRCxBQUFPLFNBQVNFLE1BQUksR0FBRztFQUNyQixPQUFPO0lBQ0wsSUFBSSxFQUFFLE1BQU07R0FDYixDQUFDO0NBQ0g7O0FDbEVNRixJQUFNLGtCQUFrQixHQUFHLENBQUMsQ0FBQztBQUNwQyxBQUFPQSxJQUFNLGdCQUFnQixHQUFHLENBQUMsQ0FBQzs7QUFFbEMsU0FBUyxhQUFhLENBQUMsT0FBTyxFQUFFO0VBQzlCLE9BQU8sT0FBTyxDQUFDLE1BQU0sQ0FBQztDQUN2Qjs7QUFFRCxJQUFNLFVBQVUsR0FBQyxtQkFDSixDQUFDLEdBQUcsRUFBRSxPQUFPLEVBQUU7RUFDMUIsSUFBTSxDQUFDLEdBQUcsR0FBRyxHQUFHLENBQUM7RUFDakIsSUFBTSxDQUFDLE9BQU8sR0FBRyxPQUFPLElBQUksRUFBRSxDQUFDO0VBQy9CLElBQU0sQ0FBQyxTQUFTLEdBQUcsQ0FBQyxDQUFDO0VBQ3JCLElBQU0sQ0FBQyxRQUFRLEdBQUcsRUFBRSxDQUFDO0VBQ3JCLElBQU0sQ0FBQyxlQUFlLEdBQUcsQ0FBQyxDQUFDO0VBQzNCLElBQU0sQ0FBQyxjQUFjLEdBQUcsRUFBRSxDQUFDO0VBQzNCLElBQU0sQ0FBQyxjQUFjLEdBQUcsS0FBSyxDQUFDO0NBQzdCLENBQUE7O0FBRUgscUJBQUUsZ0JBQWdCLDhCQUFDLFNBQVMsRUFBRSxRQUFRLEVBQUU7RUFDdEMsSUFBTSxTQUFTLEdBQUcsSUFBSSxDQUFDLGNBQWMsQ0FBQyxTQUFTLENBQUMsQ0FBQzs7RUFFakQsSUFBTSxDQUFDLFNBQVMsRUFBRTtJQUNoQixTQUFXLEdBQUcsSUFBSSxDQUFDLGNBQWMsQ0FBQyxTQUFTLENBQUMsR0FBRyxFQUFFLENBQUM7R0FDakQ7O0VBRUgsU0FBVyxDQUFDLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQztDQUMxQixDQUFBOztBQUVILHFCQUFFLFNBQVMsdUJBQUMsU0FBUyxFQUFFOzs7RUFDckIsQ0FBRyxJQUFJLENBQUMsY0FBYyxDQUFDLFNBQVMsQ0FBQyxJQUFJLEVBQUUsQ0FBQyxDQUFDLE9BQU8sQ0FBQyxVQUFBLFFBQVEsRUFBQyxTQUFHLFFBQVEsQ0FBQ0csTUFBSSxDQUFDLEdBQUEsQ0FBQyxDQUFDO0NBQzVFLENBQUE7O0FBRUgscUJBQUUsT0FBTyx1QkFBRzs7O0VBQ1YsT0FBUyxJQUFJLE9BQU8sQ0FBQyxVQUFDLE9BQU8sRUFBRSxNQUFNLEVBQUU7O0lBRXJDLElBQVEsV0FBVyxHQUFHQSxNQUFJLENBQUMsUUFBUSxDQUFDO0lBQ3BDLE1BQVEsQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMsT0FBTyxDQUFDLFVBQUMsRUFBRSxFQUFFO01BQ3RDLElBQVEsSUFBSSxHQUFHLFdBQVcsQ0FBQyxFQUFFLENBQUMsQ0FBQzs7O01BRy9CLElBQU0sSUFBSSxDQUFDLE1BQU0sRUFBRTtRQUNqQixJQUFNLENBQUMsTUFBTSxFQUFFLENBQUM7T0FDZjtLQUNGLENBQUMsQ0FBQzs7O0lBR0wsSUFBTSxXQUFXLEdBQUcsS0FBSyxDQUFDOztJQUUxQixNQUFNLENBQUMsZUFBZSxJQUFJLENBQUMsQ0FBQztJQUM1QixNQUFNLENBQUMsTUFBTSxHQUFHLElBQUksU0FBUyxDQUFDQSxNQUFJLENBQUMsR0FBRyxDQUFDLENBQUM7O0lBRXhDLE1BQU0sQ0FBQyxNQUFNLENBQUMsZ0JBQWdCLENBQUMsTUFBTSxFQUFFLFlBQUc7TUFDeEMsTUFBTSxDQUFDLGVBQWUsR0FBRyxDQUFDLENBQUM7S0FDMUIsQ0FBQyxDQUFDOztJQUVMLE1BQU0sQ0FBQyxNQUFNLENBQUMsZ0JBQWdCLENBQUMsU0FBUyxFQUFFLFVBQUMsS0FBSyxFQUFFO01BQ2hELElBQVEsT0FBTyxHQUFHLElBQUksQ0FBQyxLQUFLLENBQUMsS0FBSyxDQUFDLElBQUksQ0FBQyxDQUFDOztNQUV6QyxBQUFNLEFBQU8sQUFBRTs7UUFFYixPQUFTLENBQUMsR0FBRyxDQUFDLFVBQVUsRUFBRSxPQUFPLENBQUMsQ0FBQzs7T0FFbEM7O01BRUgsUUFBVSxPQUFPLENBQUMsSUFBSTtRQUNwQixLQUFPLE9BQU87VUFDWixNQUFNLENBQUMsUUFBUSxDQUFDLE9BQU8sQ0FBQyxFQUFFLENBQUMsQ0FBQyxhQUFhLENBQUMsT0FBTyxDQUFDLEtBQUssQ0FBQyxDQUFDO1VBQ3pELE1BQVE7O1FBRVYsS0FBTyxRQUFRO1VBQ2IsSUFBTSxPQUFPLENBQUMsT0FBTyxFQUFFO1lBQ3JCLE1BQU0sQ0FBQyxRQUFRLENBQUMsT0FBTyxDQUFDLEVBQUUsQ0FBQyxDQUFDLE9BQU8sQ0FBQyxPQUFPLENBQUMsQ0FBQztXQUM1QyxNQUFNO1lBQ1AsTUFBTSxDQUFDLFFBQVEsQ0FBQyxPQUFPLENBQUMsRUFBRSxDQUFDLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztXQUNqRDtVQUNILE9BQVNBLE1BQUksQ0FBQyxRQUFRLENBQUMsT0FBTyxDQUFDLEVBQUUsQ0FBQyxDQUFDO1VBQ25DLE1BQVE7O1FBRVYsS0FBTyxNQUFNO1VBQ1gsTUFBUTs7UUFFVixLQUFPLGVBQWU7VUFDcEIsTUFBTSxDQUFDLFdBQVcsQ0FBQ0MsSUFBYSxDQUFDRCxNQUFJLENBQUMsT0FBTyxDQUFDLFNBQVMsQ0FBQyxDQUFDLENBQUM7VUFDMUQsTUFBUTs7UUFFVixLQUFPLGNBQWM7VUFDbkIsTUFBUSxDQUFDLEVBQUUsSUFBSSxFQUFFLGdCQUFnQixFQUFFLENBQUMsQ0FBQztVQUNyQyxXQUFhLEdBQUcsSUFBSSxDQUFDO1VBQ3JCLE1BQVE7O1FBRVYsS0FBTyxTQUFTO1VBQ2QsT0FBUyxDQUFDQSxNQUFJLENBQUMsQ0FBQztVQUNoQixNQUFNLENBQUMsU0FBUyxDQUFDLE9BQU8sQ0FBQyxDQUFDOzs7O1VBSTFCLE1BQU0sQ0FBQyxTQUFTLEdBQUcsQ0FBQyxDQUFDO1VBQ3JCLE1BQU0sQ0FBQyxRQUFRLEdBQUcsRUFBRSxDQUFDOztVQUVyQixNQUFRLENBQUMsSUFBSSxDQUFDLFdBQVcsQ0FBQyxDQUFDLE9BQU8sQ0FBQyxVQUFDLEVBQUUsRUFBRTtZQUN0QyxJQUFRLElBQUksR0FBRyxXQUFXLENBQUMsRUFBRSxDQUFDLENBQUM7O1lBRS9CLElBQU0sSUFBSSxDQUFDLFNBQVMsRUFBRTtjQUNwQixNQUFNLENBQUMsZUFBZSxDQUFDLElBQUksQ0FBQyxhQUFhLEVBQUUsSUFBSSxDQUFDLFNBQVMsQ0FBQztpQkFDckQsSUFBSSxDQUFDLFVBQUMsS0FBSyxFQUFFLEVBQUssSUFBSSxDQUFDLFdBQVcsR0FBRyxLQUFLLENBQUMsRUFBRSxDQUFDLENBQUM7YUFDbkQ7V0FDRixDQUFDLENBQUM7VUFDTCxNQUFROztRQUVWO1VBQ0UsQUFBTSxBQUFPLEFBQUU7O1lBRWIsT0FBUyxDQUFDLElBQUksQ0FBQyxtQkFBbUIsRUFBRSxPQUFPLENBQUMsQ0FBQzs7V0FFNUM7T0FDSjtLQUNGLENBQUMsQ0FBQzs7SUFFTCxNQUFNLENBQUMsTUFBTSxDQUFDLGdCQUFnQixDQUFDLE9BQU8sRUFBRSxZQUFHO01BQ3pDLElBQU0sV0FBVyxJQUFJQSxNQUFJLENBQUMsY0FBYyxFQUFFOztRQUV4QyxPQUFTO09BQ1IsTUFBTSxJQUFJQSxNQUFJLENBQUMsZUFBZSxLQUFLLENBQUMsRUFBRTs7UUFFdkMsTUFBTSxDQUFDLFNBQVMsQ0FBQyxjQUFjLENBQUMsQ0FBQztPQUNoQyxNQUFNOztRQUVQLE1BQVEsQ0FBQyxrQkFBa0IsQ0FBQyxDQUFDO09BQzVCOzs7TUFHSCxJQUFRLFFBQVEsR0FBRyxJQUFJLENBQUMsR0FBRyxDQUFDQSxNQUFJLENBQUMsZUFBZSxFQUFFLENBQUMsQ0FBQyxHQUFHLElBQUksQ0FBQztNQUM1RCxVQUFZLENBQUMsWUFBRyxTQUFHQSxNQUFJLENBQUMsT0FBTyxFQUFFLEdBQUEsRUFBRSxRQUFRLENBQUMsQ0FBQztLQUM1QyxDQUFDLENBQUM7R0FDSixDQUFDLENBQUM7Q0FDSixDQUFBOztBQUVILHFCQUFFLEtBQUsscUJBQUc7RUFDUixJQUFNLENBQUMsY0FBYyxHQUFHLElBQUksQ0FBQztFQUM3QixJQUFNLENBQUMsTUFBTSxDQUFDLEtBQUssRUFBRSxDQUFDO0NBQ3JCLENBQUE7O0FBRUgscUJBQUUsU0FBUyx5QkFBRztFQUNaLE9BQVMsSUFBSSxDQUFDLGtCQUFrQixDQUFDRSxNQUFlLEVBQUUsQ0FBQyxDQUFDLElBQUksQ0FBQyxhQUFhLENBQUMsQ0FBQztDQUN2RSxDQUFBOztBQUVILHFCQUFFLFdBQVcsMkJBQUc7RUFDZCxPQUFTLElBQUksQ0FBQyxrQkFBa0IsQ0FBQ0MsUUFBaUIsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLGFBQWEsQ0FBQyxDQUFDO0NBQ3pFLENBQUE7O0FBRUgscUJBQUUsU0FBUyx5QkFBRztFQUNaLE9BQVMsSUFBSSxDQUFDLGtCQUFrQixDQUFDQyxNQUFlLEVBQUUsQ0FBQyxDQUFDLElBQUksQ0FBQyxhQUFhLENBQUMsQ0FBQztDQUN2RSxDQUFBOztBQUVILHFCQUFFLFNBQVMseUJBQUc7RUFDWixPQUFTLElBQUksQ0FBQyxrQkFBa0IsQ0FBQ0MsTUFBZSxFQUFFLENBQUMsQ0FBQyxJQUFJLENBQUMsYUFBYSxDQUFDLENBQUM7Q0FDdkUsQ0FBQTs7QUFFSCxxQkFBRSxXQUFXLHlCQUFDLE1BQU0sRUFBRSxPQUFPLEVBQUUsV0FBVyxFQUFFO0VBQzFDLE9BQVMsSUFBSSxDQUFDLGtCQUFrQixDQUFDQyxhQUFvQixDQUFDLE1BQU0sRUFBRSxPQUFPLEVBQUUsV0FBVyxDQUFDLENBQUMsQ0FBQztDQUNwRixDQUFBOzs7O0FBSUgscUJBQUUsZUFBZSw2QkFBQyxhQUFhLEVBQUUsU0FBUyxFQUFFOzs7RUFDMUMsT0FBUyxJQUFJLENBQUMsa0JBQWtCLENBQUNDLGlCQUF3QixDQUFDLFNBQVMsQ0FBQyxDQUFDLENBQUMsSUFBSTtJQUN4RSxVQUFHLGFBQWEsRUFBRTs7O01BR2hCLElBQVEsSUFBSSxHQUFHO1FBQ2IsZUFBRSxhQUFhO1FBQ2YsV0FBRSxTQUFTO1FBQ1gsV0FBYSxFQUFFLFlBQUcsU0FBR1AsTUFBSSxDQUFDLGtCQUFrQixDQUFDUSxpQkFBMEIsQ0FBQyxhQUFhLENBQUMsRUFBRSxDQUFDLENBQUM7OEJBQ2xFLElBQUksQ0FBQyxZQUFHLEVBQUssT0FBT1IsTUFBSSxDQUFDLFFBQVEsQ0FBQyxhQUFhLENBQUMsRUFBRSxDQUFDLENBQUMsRUFBRSxDQUFDLEdBQUE7T0FDOUUsQ0FBQzs7TUFFSixNQUFNLENBQUMsUUFBUSxDQUFDLGFBQWEsQ0FBQyxFQUFFLENBQUMsR0FBRyxJQUFJLENBQUM7O01BRXpDLE9BQVMsWUFBRyxTQUFHLElBQUksQ0FBQyxXQUFXLEVBQUUsR0FBQSxDQUFDOztLQUVqQzs7R0FFRixDQUFDO0NBQ0gsQ0FBQTs7QUFFSCxxQkFBRSxJQUFJLG9CQUFHO0VBQ1AsT0FBUyxJQUFJLENBQUMsa0JBQWtCLENBQUNTLE1BQWEsRUFBRSxDQUFDLENBQUM7Q0FDakQsQ0FBQTs7QUFFSCxxQkFBRSxXQUFXLHlCQUFDLE9BQU8sRUFBRTtFQUNyQixBQUFNLEFBQU8sQUFBRTs7SUFFYixPQUFTLENBQUMsR0FBRyxDQUFDLFNBQVMsRUFBRSxPQUFPLENBQUMsQ0FBQzs7R0FFakM7O0VBRUgsSUFBTSxDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxPQUFPLENBQUMsQ0FBQyxDQUFDO0NBQzNDLENBQUE7O0FBRUgscUJBQUUsa0JBQWtCLGdDQUFDLE9BQU8sRUFBRTs7O0VBQzVCLE9BQVMsSUFBSSxPQUFPLENBQUMsVUFBQyxPQUFPLEVBQUUsTUFBTSxFQUFFO0lBQ3JDLE1BQU0sQ0FBQyxTQUFTLElBQUksQ0FBQyxDQUFDO0lBQ3RCLElBQVEsU0FBUyxHQUFHVCxNQUFJLENBQUMsU0FBUyxDQUFDOztJQUVuQyxPQUFTLENBQUMsRUFBRSxHQUFHLFNBQVMsQ0FBQzs7SUFFekIsTUFBTSxDQUFDLFFBQVEsQ0FBQyxTQUFTLENBQUMsR0FBRyxFQUFFLFNBQUEsT0FBTyxFQUFFLFFBQUEsTUFBTSxFQUFFLENBQUM7SUFDakQsTUFBTSxDQUFDLFdBQVcsQ0FBQyxPQUFPLENBQUMsQ0FBQztHQUMzQixDQUFDLENBQUM7Q0FDSixDQUFBOztBQUdILEFBQU8sU0FBUyxnQkFBZ0IsQ0FBQyxHQUFHLEVBQUUsT0FBTyxFQUFFO0VBQzdDSCxJQUFNLElBQUksR0FBRyxJQUFJLFVBQVUsQ0FBQyxHQUFHLEVBQUUsT0FBTyxDQUFDLENBQUM7RUFDMUMsT0FBTyxJQUFJLENBQUMsT0FBTyxFQUFFLENBQUM7Q0FDdkIsQUFFRCxBQUFnQzs7Ozs7In0=
"use strict";function auth(e){return{type:"auth",api_password:e}}function states(){return{type:"get_states"}}function config(){return{type:"get_config"}}function services(){return{type:"get_services"}}function panels(){return{type:"get_panels"}}function callService$1(e,t,n){var s={type:"call_service",domain:e,service:t};return n&&(s.service_data=n),s}function subscribeEvents$1(e){var t={type:"subscribe_events"};return e&&(t.event_type=e),t}function unsubscribeEvents(e){return{type:"unsubscribe_events",subscription:e}}function ping$1(){return{type:"ping"}}function extractResult(e){return e.result}function createConnection(e,t){var n=new Connection(e,t);return n.connect()}function processEvent(e,t){var n=t.data.new_state;n?e.updateState(n):e.removeState(t.data.entity_id)}function createEntityStore(e){return new Promise(function(t,n){var s=new EntityStore,i=e.subscribeEvents(processEvent.bind(null,s),"state_changed").then(function(e){s.unsubscribe=e}),r=e.getStates().then(function(e){return s.setStates(e)});Promise.all([i,r]).then(function(){return t(s)},function(){return n()})})}Object.defineProperty(exports,"__esModule",{value:!0});var ERR_CANNOT_CONNECT=1,ERR_INVALID_AUTH=2,Connection=function(e,t){this.url=e,this.options=t||{},this.commandId=1,this.commands={},this.connectionTries=0,this.eventListeners={},this.closeRequested=!1};Connection.prototype.addEventListener=function(e,t){var n=this.eventListeners[e];n||(n=this.eventListeners[e]=[]),n.push(t)},Connection.prototype.fireEvent=function(e){var t=this;(this.eventListeners[e]||[]).forEach(function(e){return e(t)})},Connection.prototype.connect=function(){var e=this;return new Promise(function(t,n){var s=e.commands;Object.keys(s).forEach(function(e){var t=s[e];t.reject&&t.reject()});var i=!1;e.connectionTries+=1,e.socket=new WebSocket(e.url),e.socket.addEventListener("open",function(){e.connectionTries=0}),e.socket.addEventListener("message",function(r){var o=JSON.parse(r.data);switch(o.type){case"event":e.commands[o.id].eventCallback(o.event);break;case"result":o.success?e.commands[o.id].resolve(o):e.commands[o.id].reject(o.error),delete e.commands[o.id];break;case"pong":break;case"auth_required":e.sendMessage(auth(e.options.authToken));break;case"auth_invalid":n({code:ERR_INVALID_AUTH}),i=!0;break;case"auth_ok":t(e),e.fireEvent("ready"),e.commandId=1,e.commands={},Object.keys(s).forEach(function(t){var n=s[t];n.eventType&&e.subscribeEvents(n.eventCallback,n.eventType).then(function(e){n.unsubscribe=e})})}}),e.socket.addEventListener("close",function(){if(!i&&!e.closeRequested){0===e.connectionTries?e.fireEvent("disconnected"):n(ERR_CANNOT_CONNECT);var t=1e3*Math.min(e.connectionTries,5);setTimeout(function(){return e.connect()},t)}})})},Connection.prototype.close=function(){this.closeRequested=!0,this.socket.close()},Connection.prototype.getStates=function(){return this.sendMessagePromise(states()).then(extractResult)},Connection.prototype.getServices=function(){return this.sendMessagePromise(services()).then(extractResult)},Connection.prototype.getPanels=function(){return this.sendMessagePromise(panels()).then(extractResult)},Connection.prototype.getConfig=function(){return this.sendMessagePromise(config()).then(extractResult)},Connection.prototype.callService=function(e,t,n){return this.sendMessagePromise(callService$1(e,t,n))},Connection.prototype.subscribeEvents=function(e,t){var n=this;return this.sendMessagePromise(subscribeEvents$1(t)).then(function(s){var i={eventCallback:e,eventType:t,unsubscribe:function(){return n.sendMessagePromise(unsubscribeEvents(s.id)).then(function(){delete n.commands[s.id]})}};return n.commands[s.id]=i,function(){return i.unsubscribe()}})},Connection.prototype.ping=function(){return this.sendMessagePromise(ping$1())},Connection.prototype.sendMessage=function(e){this.socket.send(JSON.stringify(e))},Connection.prototype.sendMessagePromise=function(e){var t=this;return new Promise(function(n,s){t.commandId+=1;var i=t.commandId;e.id=i,t.commands[i]={resolve:n,reject:s},t.sendMessage(e)})};var EntityStore=function(){this.listeners={},this.entities={}};EntityStore.prototype.addEventListener=function(e,t){var n=this.listeners[e];n||(n=this.listeners[e]=[]),n.push(t)},EntityStore.prototype.fireEvent=function(e){var t=this;(this.listeners[e]||[]).forEach(function(e){return e(t.entities)})},EntityStore.prototype.setStates=function(e){for(var t={},n=0;n<e.length;n++){var s=e[n];t[s.entity_id]=s}this.entities=t,this.fireEvent("change")},EntityStore.prototype.updateState=function(e){var t=Object.assign({},this.entities);t[e.entity_id]=e,this.entities=t,this.fireEvent("change")},EntityStore.prototype.removeState=function(e){var t=Object.assign({},this.entities);delete t[e],this.entities=t,this.fireEvent("change")},EntityStore.prototype.unsubscribe=function(){},exports.createConnection=createConnection,exports.createEntityStore=createEntityStore,exports.ERR_CANNOT_CONNECT=ERR_CANNOT_CONNECT,exports.ERR_INVALID_AUTH=ERR_INVALID_AUTH;

296

dist/haws.es.js

@@ -1,295 +0,1 @@

function auth(authToken) {
return {
type: 'auth',
api_password: authToken,
};
}
function states() {
return {
type: 'get_states',
};
}
function config() {
return {
type: 'get_config',
};
}
function services() {
return {
type: 'get_services',
};
}
function panels() {
return {
type: 'get_panels',
};
}
function callService$1(domain, service, serviceData) {
var message = {
type: 'call_service',
domain: domain,
service: service,
};
if (serviceData) {
message.service_data = serviceData;
}
return message;
}
function subscribeEvents$1(eventType) {
var message = {
type: 'subscribe_events',
};
if (eventType) {
message.event_type = eventType;
}
return message;
}
function unsubscribeEvents(subscription) {
return {
type: 'unsubscribe_events',
subscription: subscription,
};
}
function ping$1() {
return {
type: 'ping',
};
}
var ERR_CANNOT_CONNECT = 1;
var ERR_INVALID_AUTH = 2;
function extractResult(message) {
return message.result;
}
var Connection = function Connection(url, options) {
this.url = url;
this.options = options || {};
this.commandId = 1;
this.commands = {};
this.connectionTries = 0;
this.eventListeners = {};
this.closeRequested = false;
};
Connection.prototype.addEventListener = function addEventListener (eventType, callback) {
var listeners = this.eventListeners[eventType];
if (!listeners) {
listeners = this.eventListeners[eventType] = [];
}
listeners.push(callback);
};
Connection.prototype.fireEvent = function fireEvent (eventType) {
var this$1 = this;
(this.eventListeners[eventType] || []).forEach(function (callback) { return callback(this$1); });
};
Connection.prototype.connect = function connect () {
var this$1 = this;
return new Promise(function (resolve, reject) {
// Used for resubscribing in the future
var oldCommands = this$1.commands;
Object.keys(oldCommands).forEach(function (id) {
var info = oldCommands[id];
// Reject stuff still waiting for an answer
if (info.reject) {
info.reject();
}
});
// If invalid auth, we will not try to reconnect.
var invalidAuth = false;
this$1.connectionTries += 1;
this$1.socket = new WebSocket(this$1.url);
this$1.socket.addEventListener('open', function () {
this$1.connectionTries = 0;
});
this$1.socket.addEventListener('message', function (event) {
var message = JSON.parse(event.data);
{
/* eslint-disable no-console */
console.log('Received', message);
/* eslint-enable no-console */
}
switch (message.type) {
case 'event':
this$1.commands[message.id].eventCallback(message.event);
break;
case 'result':
if (message.success) {
this$1.commands[message.id].resolve(message);
} else {
this$1.commands[message.id].reject(message.error);
}
delete this$1.commands[message.id];
break;
case 'pong':
break;
case 'auth_required':
this$1.sendMessage(auth(this$1.options.authToken));
break;
case 'auth_invalid':
reject({ code: ERR_INVALID_AUTH });
invalidAuth = true;
break;
case 'auth_ok':
resolve(this$1);
this$1.fireEvent('ready');
// Re-subscribe to events and update old location of unsub method
// so old unsub method keeps working.
this$1.commandId = 1;
this$1.commands = {};
Object.keys(oldCommands).forEach(function (id) {
var info = oldCommands[id];
if (info.eventType) {
this$1.subscribeEvents(info.eventCallback, info.eventType)
.then(function (unsub) { info.unsubscribe = unsub; });
}
});
break;
default:
{
/* eslint-disable no-console */
console.warn('Unhandled message', message);
/* eslint-enable no-console */
}
}
});
this$1.socket.addEventListener('close', function () {
if (invalidAuth || this$1.closeRequested) {
// When we have invalid auth, let's not reconnect or we get banned.
return;
} else if (this$1.connectionTries === 0) {
// We were connected at some point.
this$1.fireEvent('disconnected');
} else {
// We never were connected
reject(ERR_CANNOT_CONNECT);
}
// Try again
var waitTime = Math.min(this$1.connectionTries, 5) * 1000;
setTimeout(function () { return this$1.connect(); }, waitTime);
});
});
};
Connection.prototype.close = function close () {
this.closeRequested = true;
this.socket.close();
};
Connection.prototype.getStates = function getStates () {
return this.sendMessagePromise(states()).then(extractResult);
};
Connection.prototype.getServices = function getServices () {
return this.sendMessagePromise(services()).then(extractResult);
};
Connection.prototype.getPanels = function getPanels () {
return this.sendMessagePromise(panels()).then(extractResult);
};
Connection.prototype.getConfig = function getConfig () {
return this.sendMessagePromise(config()).then(extractResult);
};
Connection.prototype.callService = function callService (domain, service, serviceData) {
return this.sendMessagePromise(callService$1(domain, service, serviceData));
};
// eventCallback will be called when a new event fires
// Returned promise resolves to an unsubscribe function.
Connection.prototype.subscribeEvents = function subscribeEvents (eventCallback, eventType) {
var this$1 = this;
return this.sendMessagePromise(subscribeEvents$1(eventType)).then(
function (resultMessage) {
// We store unsubscribe on info object. That way we can overwrite it in case
// we get disconnected and we have to subscribe again.
var info = {
eventCallback: eventCallback,
eventType: eventType,
unsubscribe: function () { return this$1.sendMessagePromise(unsubscribeEvents(resultMessage.id))
.then(function () { delete this$1.commands[resultMessage.id]; }); },
};
this$1.commands[resultMessage.id] = info;
return function () { return info.unsubscribe(); };
/* eslint-disable comma-dangle */ /* comma crashes Buble */
}
/* eslint-enable comma-dangle */
);
};
Connection.prototype.ping = function ping () {
return this.sendMessagePromise(ping$1());
};
Connection.prototype.sendMessage = function sendMessage (message) {
{
/* eslint-disable no-console */
console.log('Sending', message);
/* eslint-enable no-console */
}
this.socket.send(JSON.stringify(message));
};
Connection.prototype.sendMessagePromise = function sendMessagePromise (message) {
var this$1 = this;
return new Promise(function (resolve, reject) {
this$1.commandId += 1;
var commandId = this$1.commandId;
/* eslint-disable no-param-reassign */
message.id = commandId;
/* eslint-enable no-param-reassign */
this$1.commands[commandId] = { resolve: resolve, reject: reject };
this$1.sendMessage(message);
});
};
function createConnection(url, options) {
var conn = new Connection(url, options);
return conn.connect();
}
export { ERR_CANNOT_CONNECT, ERR_INVALID_AUTH, createConnection };export default createConnection;
//# sourceMappingURL=data:application/json;charset=utf-8;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjpudWxsLCJzb3VyY2VzIjpbIi4uL2xpYi9tZXNzYWdlcy5qcyIsIi4uL2xpYi9pbmRleC5qcyJdLCJzb3VyY2VzQ29udGVudCI6WyJleHBvcnQgZnVuY3Rpb24gYXV0aChhdXRoVG9rZW4pIHtcbiAgcmV0dXJuIHtcbiAgICB0eXBlOiAnYXV0aCcsXG4gICAgYXBpX3Bhc3N3b3JkOiBhdXRoVG9rZW4sXG4gIH07XG59XG5cbmV4cG9ydCBmdW5jdGlvbiBzdGF0ZXMoKSB7XG4gIHJldHVybiB7XG4gICAgdHlwZTogJ2dldF9zdGF0ZXMnLFxuICB9O1xufVxuXG5leHBvcnQgZnVuY3Rpb24gY29uZmlnKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfY29uZmlnJyxcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHNlcnZpY2VzKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfc2VydmljZXMnLFxuICB9O1xufVxuXG5leHBvcnQgZnVuY3Rpb24gcGFuZWxzKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfcGFuZWxzJyxcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNhbGxTZXJ2aWNlKGRvbWFpbiwgc2VydmljZSwgc2VydmljZURhdGEpIHtcbiAgY29uc3QgbWVzc2FnZSA9IHtcbiAgICB0eXBlOiAnY2FsbF9zZXJ2aWNlJyxcbiAgICBkb21haW4sXG4gICAgc2VydmljZSxcbiAgfTtcblxuICBpZiAoc2VydmljZURhdGEpIHtcbiAgICBtZXNzYWdlLnNlcnZpY2VfZGF0YSA9IHNlcnZpY2VEYXRhO1xuICB9XG5cbiAgcmV0dXJuIG1lc3NhZ2U7XG59XG5cbmV4cG9ydCBmdW5jdGlvbiBzdWJzY3JpYmVFdmVudHMoZXZlbnRUeXBlKSB7XG4gIGNvbnN0IG1lc3NhZ2UgPSB7XG4gICAgdHlwZTogJ3N1YnNjcmliZV9ldmVudHMnLFxuICB9O1xuXG4gIGlmIChldmVudFR5cGUpIHtcbiAgICBtZXNzYWdlLmV2ZW50X3R5cGUgPSBldmVudFR5cGU7XG4gIH1cblxuICByZXR1cm4gbWVzc2FnZTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHVuc3Vic2NyaWJlRXZlbnRzKHN1YnNjcmlwdGlvbikge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICd1bnN1YnNjcmliZV9ldmVudHMnLFxuICAgIHN1YnNjcmlwdGlvbixcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHBpbmcoKSB7XG4gIHJldHVybiB7XG4gICAgdHlwZTogJ3BpbmcnLFxuICB9O1xufVxuIiwiaW1wb3J0ICogYXMgbWVzc2FnZXMgZnJvbSAnLi9tZXNzYWdlcyc7XG5cbmV4cG9ydCBjb25zdCBFUlJfQ0FOTk9UX0NPTk5FQ1QgPSAxO1xuZXhwb3J0IGNvbnN0IEVSUl9JTlZBTElEX0FVVEggPSAyO1xuXG5mdW5jdGlvbiBleHRyYWN0UmVzdWx0KG1lc3NhZ2UpIHtcbiAgcmV0dXJuIG1lc3NhZ2UucmVzdWx0O1xufVxuXG5jbGFzcyBDb25uZWN0aW9uIHtcbiAgY29uc3RydWN0b3IodXJsLCBvcHRpb25zKSB7XG4gICAgdGhpcy51cmwgPSB1cmw7XG4gICAgdGhpcy5vcHRpb25zID0gb3B0aW9ucyB8fCB7fTtcbiAgICB0aGlzLmNvbW1hbmRJZCA9IDE7XG4gICAgdGhpcy5jb21tYW5kcyA9IHt9O1xuICAgIHRoaXMuY29ubmVjdGlvblRyaWVzID0gMDtcbiAgICB0aGlzLmV2ZW50TGlzdGVuZXJzID0ge307XG4gICAgdGhpcy5jbG9zZVJlcXVlc3RlZCA9IGZhbHNlO1xuICB9XG5cbiAgYWRkRXZlbnRMaXN0ZW5lcihldmVudFR5cGUsIGNhbGxiYWNrKSB7XG4gICAgbGV0IGxpc3RlbmVycyA9IHRoaXMuZXZlbnRMaXN0ZW5lcnNbZXZlbnRUeXBlXTtcblxuICAgIGlmICghbGlzdGVuZXJzKSB7XG4gICAgICBsaXN0ZW5lcnMgPSB0aGlzLmV2ZW50TGlzdGVuZXJzW2V2ZW50VHlwZV0gPSBbXTtcbiAgICB9XG5cbiAgICBsaXN0ZW5lcnMucHVzaChjYWxsYmFjayk7XG4gIH1cblxuICBmaXJlRXZlbnQoZXZlbnRUeXBlKSB7XG4gICAgKHRoaXMuZXZlbnRMaXN0ZW5lcnNbZXZlbnRUeXBlXSB8fCBbXSkuZm9yRWFjaChjYWxsYmFjayA9PiBjYWxsYmFjayh0aGlzKSk7XG4gIH1cblxuICBjb25uZWN0KCkge1xuICAgIHJldHVybiBuZXcgUHJvbWlzZSgocmVzb2x2ZSwgcmVqZWN0KSA9PiB7XG4gICAgICAvLyBVc2VkIGZvciByZXN1YnNjcmliaW5nIGluIHRoZSBmdXR1cmVcbiAgICAgIGNvbnN0IG9sZENvbW1hbmRzID0gdGhpcy5jb21tYW5kcztcbiAgICAgIE9iamVjdC5rZXlzKG9sZENvbW1hbmRzKS5mb3JFYWNoKChpZCkgPT4ge1xuICAgICAgICBjb25zdCBpbmZvID0gb2xkQ29tbWFuZHNbaWRdO1xuXG4gICAgICAgIC8vIFJlamVjdCBzdHVmZiBzdGlsbCB3YWl0aW5nIGZvciBhbiBhbnN3ZXJcbiAgICAgICAgaWYgKGluZm8ucmVqZWN0KSB7XG4gICAgICAgICAgaW5mby5yZWplY3QoKTtcbiAgICAgICAgfVxuICAgICAgfSk7XG5cbiAgICAgIC8vIElmIGludmFsaWQgYXV0aCwgd2Ugd2lsbCBub3QgdHJ5IHRvIHJlY29ubmVjdC5cbiAgICAgIGxldCBpbnZhbGlkQXV0aCA9IGZhbHNlO1xuXG4gICAgICB0aGlzLmNvbm5lY3Rpb25UcmllcyArPSAxO1xuICAgICAgdGhpcy5zb2NrZXQgPSBuZXcgV2ViU29ja2V0KHRoaXMudXJsKTtcblxuICAgICAgdGhpcy5zb2NrZXQuYWRkRXZlbnRMaXN0ZW5lcignb3BlbicsICgpID0+IHtcbiAgICAgICAgdGhpcy5jb25uZWN0aW9uVHJpZXMgPSAwO1xuICAgICAgfSk7XG5cbiAgICAgIHRoaXMuc29ja2V0LmFkZEV2ZW50TGlzdGVuZXIoJ21lc3NhZ2UnLCAoZXZlbnQpID0+IHtcbiAgICAgICAgY29uc3QgbWVzc2FnZSA9IEpTT04ucGFyc2UoZXZlbnQuZGF0YSk7XG5cbiAgICAgICAgaWYgKF9fREVWX18pIHtcbiAgICAgICAgICAvKiBlc2xpbnQtZGlzYWJsZSBuby1jb25zb2xlICovXG4gICAgICAgICAgY29uc29sZS5sb2coJ1JlY2VpdmVkJywgbWVzc2FnZSk7XG4gICAgICAgICAgLyogZXNsaW50LWVuYWJsZSBuby1jb25zb2xlICovXG4gICAgICAgIH1cblxuICAgICAgICBzd2l0Y2ggKG1lc3NhZ2UudHlwZSkge1xuICAgICAgICAgIGNhc2UgJ2V2ZW50JzpcbiAgICAgICAgICAgIHRoaXMuY29tbWFuZHNbbWVzc2FnZS5pZF0uZXZlbnRDYWxsYmFjayhtZXNzYWdlLmV2ZW50KTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAncmVzdWx0JzpcbiAgICAgICAgICAgIGlmIChtZXNzYWdlLnN1Y2Nlc3MpIHtcbiAgICAgICAgICAgICAgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXS5yZXNvbHZlKG1lc3NhZ2UpO1xuICAgICAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgICAgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXS5yZWplY3QobWVzc2FnZS5lcnJvcik7XG4gICAgICAgICAgICB9XG4gICAgICAgICAgICBkZWxldGUgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAncG9uZyc6XG4gICAgICAgICAgICBicmVhaztcblxuICAgICAgICAgIGNhc2UgJ2F1dGhfcmVxdWlyZWQnOlxuICAgICAgICAgICAgdGhpcy5zZW5kTWVzc2FnZShtZXNzYWdlcy5hdXRoKHRoaXMub3B0aW9ucy5hdXRoVG9rZW4pKTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAnYXV0aF9pbnZhbGlkJzpcbiAgICAgICAgICAgIHJlamVjdCh7IGNvZGU6IEVSUl9JTlZBTElEX0FVVEggfSk7XG4gICAgICAgICAgICBpbnZhbGlkQXV0aCA9IHRydWU7XG4gICAgICAgICAgICBicmVhaztcblxuICAgICAgICAgIGNhc2UgJ2F1dGhfb2snOlxuICAgICAgICAgICAgcmVzb2x2ZSh0aGlzKTtcbiAgICAgICAgICAgIHRoaXMuZmlyZUV2ZW50KCdyZWFkeScpO1xuXG4gICAgICAgICAgICAvLyBSZS1zdWJzY3JpYmUgdG8gZXZlbnRzIGFuZCB1cGRhdGUgb2xkIGxvY2F0aW9uIG9mIHVuc3ViIG1ldGhvZFxuICAgICAgICAgICAgLy8gc28gb2xkIHVuc3ViIG1ldGhvZCBrZWVwcyB3b3JraW5nLlxuICAgICAgICAgICAgdGhpcy5jb21tYW5kSWQgPSAxO1xuICAgICAgICAgICAgdGhpcy5jb21tYW5kcyA9IHt9O1xuXG4gICAgICAgICAgICBPYmplY3Qua2V5cyhvbGRDb21tYW5kcykuZm9yRWFjaCgoaWQpID0+IHtcbiAgICAgICAgICAgICAgY29uc3QgaW5mbyA9IG9sZENvbW1hbmRzW2lkXTtcblxuICAgICAgICAgICAgICBpZiAoaW5mby5ldmVudFR5cGUpIHtcbiAgICAgICAgICAgICAgICB0aGlzLnN1YnNjcmliZUV2ZW50cyhpbmZvLmV2ZW50Q2FsbGJhY2ssIGluZm8uZXZlbnRUeXBlKVxuICAgICAgICAgICAgICAgICAgLnRoZW4oKHVuc3ViKSA9PiB7IGluZm8udW5zdWJzY3JpYmUgPSB1bnN1YjsgfSk7XG4gICAgICAgICAgICAgIH1cbiAgICAgICAgICAgIH0pO1xuICAgICAgICAgICAgYnJlYWs7XG5cbiAgICAgICAgICBkZWZhdWx0OlxuICAgICAgICAgICAgaWYgKF9fREVWX18pIHtcbiAgICAgICAgICAgICAgLyogZXNsaW50LWRpc2FibGUgbm8tY29uc29sZSAqL1xuICAgICAgICAgICAgICBjb25zb2xlLndhcm4oJ1VuaGFuZGxlZCBtZXNzYWdlJywgbWVzc2FnZSk7XG4gICAgICAgICAgICAgIC8qIGVzbGludC1lbmFibGUgbm8tY29uc29sZSAqL1xuICAgICAgICAgICAgfVxuICAgICAgICB9XG4gICAgICB9KTtcblxuICAgICAgdGhpcy5zb2NrZXQuYWRkRXZlbnRMaXN0ZW5lcignY2xvc2UnLCAoKSA9PiB7XG4gICAgICAgIGlmIChpbnZhbGlkQXV0aCB8fCB0aGlzLmNsb3NlUmVxdWVzdGVkKSB7XG4gICAgICAgICAgLy8gV2hlbiB3ZSBoYXZlIGludmFsaWQgYXV0aCwgbGV0J3Mgbm90IHJlY29ubmVjdCBvciB3ZSBnZXQgYmFubmVkLlxuICAgICAgICAgIHJldHVybjtcbiAgICAgICAgfSBlbHNlIGlmICh0aGlzLmNvbm5lY3Rpb25UcmllcyA9PT0gMCkge1xuICAgICAgICAgIC8vIFdlIHdlcmUgY29ubmVjdGVkIGF0IHNvbWUgcG9pbnQuXG4gICAgICAgICAgdGhpcy5maXJlRXZlbnQoJ2Rpc2Nvbm5lY3RlZCcpO1xuICAgICAgICB9IGVsc2Uge1xuICAgICAgICAgIC8vIFdlIG5ldmVyIHdlcmUgY29ubmVjdGVkXG4gICAgICAgICAgcmVqZWN0KEVSUl9DQU5OT1RfQ09OTkVDVCk7XG4gICAgICAgIH1cblxuICAgICAgICAvLyBUcnkgYWdhaW5cbiAgICAgICAgY29uc3Qgd2FpdFRpbWUgPSBNYXRoLm1pbih0aGlzLmNvbm5lY3Rpb25UcmllcywgNSkgKiAxMDAwO1xuICAgICAgICBzZXRUaW1lb3V0KCgpID0+IHRoaXMuY29ubmVjdCgpLCB3YWl0VGltZSk7XG4gICAgICB9KTtcbiAgICB9KTtcbiAgfVxuXG4gIGNsb3NlKCkge1xuICAgIHRoaXMuY2xvc2VSZXF1ZXN0ZWQgPSB0cnVlO1xuICAgIHRoaXMuc29ja2V0LmNsb3NlKCk7XG4gIH1cblxuICBnZXRTdGF0ZXMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnN0YXRlcygpKS50aGVuKGV4dHJhY3RSZXN1bHQpO1xuICB9XG5cbiAgZ2V0U2VydmljZXMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnNlcnZpY2VzKCkpLnRoZW4oZXh0cmFjdFJlc3VsdCk7XG4gIH1cblxuICBnZXRQYW5lbHMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnBhbmVscygpKS50aGVuKGV4dHJhY3RSZXN1bHQpO1xuICB9XG5cbiAgZ2V0Q29uZmlnKCkge1xuICAgIHJldHVybiB0aGlzLnNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlcy5jb25maWcoKSkudGhlbihleHRyYWN0UmVzdWx0KTtcbiAgfVxuXG4gIGNhbGxTZXJ2aWNlKGRvbWFpbiwgc2VydmljZSwgc2VydmljZURhdGEpIHtcbiAgICByZXR1cm4gdGhpcy5zZW5kTWVzc2FnZVByb21pc2UobWVzc2FnZXMuY2FsbFNlcnZpY2UoZG9tYWluLCBzZXJ2aWNlLCBzZXJ2aWNlRGF0YSkpO1xuICB9XG5cbiAgLy8gZXZlbnRDYWxsYmFjayB3aWxsIGJlIGNhbGxlZCB3aGVuIGEgbmV3IGV2ZW50IGZpcmVzXG4gIC8vIFJldHVybmVkIHByb21pc2UgcmVzb2x2ZXMgdG8gYW4gdW5zdWJzY3JpYmUgZnVuY3Rpb24uXG4gIHN1YnNjcmliZUV2ZW50cyhldmVudENhbGxiYWNrLCBldmVudFR5cGUpIHtcbiAgICByZXR1cm4gdGhpcy5zZW5kTWVzc2FnZVByb21pc2UobWVzc2FnZXMuc3Vic2NyaWJlRXZlbnRzKGV2ZW50VHlwZSkpLnRoZW4oXG4gICAgICAocmVzdWx0TWVzc2FnZSkgPT4ge1xuICAgICAgICAvLyBXZSBzdG9yZSB1bnN1YnNjcmliZSBvbiBpbmZvIG9iamVjdC4gVGhhdCB3YXkgd2UgY2FuIG92ZXJ3cml0ZSBpdCBpbiBjYXNlXG4gICAgICAgIC8vIHdlIGdldCBkaXNjb25uZWN0ZWQgYW5kIHdlIGhhdmUgdG8gc3Vic2NyaWJlIGFnYWluLlxuICAgICAgICBjb25zdCBpbmZvID0ge1xuICAgICAgICAgIGV2ZW50Q2FsbGJhY2ssXG4gICAgICAgICAgZXZlbnRUeXBlLFxuICAgICAgICAgIHVuc3Vic2NyaWJlOiAoKSA9PiB0aGlzLnNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlcy51bnN1YnNjcmliZUV2ZW50cyhyZXN1bHRNZXNzYWdlLmlkKSlcbiAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAudGhlbigoKSA9PiB7IGRlbGV0ZSB0aGlzLmNvbW1hbmRzW3Jlc3VsdE1lc3NhZ2UuaWRdOyB9KSxcbiAgICAgICAgfTtcblxuICAgICAgICB0aGlzLmNvbW1hbmRzW3Jlc3VsdE1lc3NhZ2UuaWRdID0gaW5mbztcblxuICAgICAgICByZXR1cm4gKCkgPT4gaW5mby51bnN1YnNjcmliZSgpO1xuICAgICAgLyogZXNsaW50LWRpc2FibGUgY29tbWEtZGFuZ2xlICovIC8qIGNvbW1hIGNyYXNoZXMgQnVibGUgKi9cbiAgICAgIH1cbiAgICAgIC8qIGVzbGludC1lbmFibGUgY29tbWEtZGFuZ2xlICovXG4gICAgKTtcbiAgfVxuXG4gIHBpbmcoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnBpbmcoKSk7XG4gIH1cblxuICBzZW5kTWVzc2FnZShtZXNzYWdlKSB7XG4gICAgaWYgKF9fREVWX18pIHtcbiAgICAgIC8qIGVzbGludC1kaXNhYmxlIG5vLWNvbnNvbGUgKi9cbiAgICAgIGNvbnNvbGUubG9nKCdTZW5kaW5nJywgbWVzc2FnZSk7XG4gICAgICAvKiBlc2xpbnQtZW5hYmxlIG5vLWNvbnNvbGUgKi9cbiAgICB9XG5cbiAgICB0aGlzLnNvY2tldC5zZW5kKEpTT04uc3RyaW5naWZ5KG1lc3NhZ2UpKTtcbiAgfVxuXG4gIHNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlKSB7XG4gICAgcmV0dXJuIG5ldyBQcm9taXNlKChyZXNvbHZlLCByZWplY3QpID0+IHtcbiAgICAgIHRoaXMuY29tbWFuZElkICs9IDE7XG4gICAgICBjb25zdCBjb21tYW5kSWQgPSB0aGlzLmNvbW1hbmRJZDtcbiAgICAgIC8qIGVzbGludC1kaXNhYmxlIG5vLXBhcmFtLXJlYXNzaWduICovXG4gICAgICBtZXNzYWdlLmlkID0gY29tbWFuZElkO1xuICAgICAgLyogZXNsaW50LWVuYWJsZSBuby1wYXJhbS1yZWFzc2lnbiAqL1xuICAgICAgdGhpcy5jb21tYW5kc1tjb21tYW5kSWRdID0geyByZXNvbHZlLCByZWplY3QgfTtcbiAgICAgIHRoaXMuc2VuZE1lc3NhZ2UobWVzc2FnZSk7XG4gICAgfSk7XG4gIH1cbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNyZWF0ZUNvbm5lY3Rpb24odXJsLCBvcHRpb25zKSB7XG4gIGNvbnN0IGNvbm4gPSBuZXcgQ29ubmVjdGlvbih1cmwsIG9wdGlvbnMpO1xuICByZXR1cm4gY29ubi5jb25uZWN0KCk7XG59XG5cbmV4cG9ydCBkZWZhdWx0IGNyZWF0ZUNvbm5lY3Rpb247XG4iXSwibmFtZXMiOlsiY2FsbFNlcnZpY2UiLCJjb25zdCIsInN1YnNjcmliZUV2ZW50cyIsInBpbmciLCJ0aGlzIiwibWVzc2FnZXMuYXV0aCIsIm1lc3NhZ2VzLnN0YXRlcyIsIm1lc3NhZ2VzLnNlcnZpY2VzIiwibWVzc2FnZXMucGFuZWxzIiwibWVzc2FnZXMuY29uZmlnIiwibWVzc2FnZXMuY2FsbFNlcnZpY2UiLCJtZXNzYWdlcy5zdWJzY3JpYmVFdmVudHMiLCJtZXNzYWdlcy51bnN1YnNjcmliZUV2ZW50cyIsIm1lc3NhZ2VzLnBpbmciXSwibWFwcGluZ3MiOiJBQUFPLFNBQVMsSUFBSSxDQUFDLFNBQVMsRUFBRTtFQUM5QixPQUFPO0lBQ0wsSUFBSSxFQUFFLE1BQU07SUFDWixZQUFZLEVBQUUsU0FBUztHQUN4QixDQUFDO0NBQ0g7O0FBRUQsQUFBTyxTQUFTLE1BQU0sR0FBRztFQUN2QixPQUFPO0lBQ0wsSUFBSSxFQUFFLFlBQVk7R0FDbkIsQ0FBQztDQUNIOztBQUVELEFBQU8sU0FBUyxNQUFNLEdBQUc7RUFDdkIsT0FBTztJQUNMLElBQUksRUFBRSxZQUFZO0dBQ25CLENBQUM7Q0FDSDs7QUFFRCxBQUFPLFNBQVMsUUFBUSxHQUFHO0VBQ3pCLE9BQU87SUFDTCxJQUFJLEVBQUUsY0FBYztHQUNyQixDQUFDO0NBQ0g7O0FBRUQsQUFBTyxTQUFTLE1BQU0sR0FBRztFQUN2QixPQUFPO0lBQ0wsSUFBSSxFQUFFLFlBQVk7R0FDbkIsQ0FBQztDQUNIOztBQUVELEFBQU8sU0FBU0EsYUFBVyxDQUFDLE1BQU0sRUFBRSxPQUFPLEVBQUUsV0FBVyxFQUFFO0VBQ3hEQyxJQUFNLE9BQU8sR0FBRztJQUNkLElBQUksRUFBRSxjQUFjO0lBQ3BCLFFBQUEsTUFBTTtJQUNOLFNBQUEsT0FBTztHQUNSLENBQUM7O0VBRUYsSUFBSSxXQUFXLEVBQUU7SUFDZixPQUFPLENBQUMsWUFBWSxHQUFHLFdBQVcsQ0FBQztHQUNwQzs7RUFFRCxPQUFPLE9BQU8sQ0FBQztDQUNoQjs7QUFFRCxBQUFPLFNBQVNDLGlCQUFlLENBQUMsU0FBUyxFQUFFO0VBQ3pDRCxJQUFNLE9BQU8sR0FBRztJQUNkLElBQUksRUFBRSxrQkFBa0I7R0FDekIsQ0FBQzs7RUFFRixJQUFJLFNBQVMsRUFBRTtJQUNiLE9BQU8sQ0FBQyxVQUFVLEdBQUcsU0FBUyxDQUFDO0dBQ2hDOztFQUVELE9BQU8sT0FBTyxDQUFDO0NBQ2hCOztBQUVELEFBQU8sU0FBUyxpQkFBaUIsQ0FBQyxZQUFZLEVBQUU7RUFDOUMsT0FBTztJQUNMLElBQUksRUFBRSxvQkFBb0I7SUFDMUIsY0FBQSxZQUFZO0dBQ2IsQ0FBQztDQUNIOztBQUVELEFBQU8sU0FBU0UsTUFBSSxHQUFHO0VBQ3JCLE9BQU87SUFDTCxJQUFJLEVBQUUsTUFBTTtHQUNiLENBQUM7Q0FDSDs7QUNsRU1GLElBQU0sa0JBQWtCLEdBQUcsQ0FBQyxDQUFDO0FBQ3BDLEFBQU9BLElBQU0sZ0JBQWdCLEdBQUcsQ0FBQyxDQUFDOztBQUVsQyxTQUFTLGFBQWEsQ0FBQyxPQUFPLEVBQUU7RUFDOUIsT0FBTyxPQUFPLENBQUMsTUFBTSxDQUFDO0NBQ3ZCOztBQUVELElBQU0sVUFBVSxHQUFDLG1CQUNKLENBQUMsR0FBRyxFQUFFLE9BQU8sRUFBRTtFQUMxQixJQUFNLENBQUMsR0FBRyxHQUFHLEdBQUcsQ0FBQztFQUNqQixJQUFNLENBQUMsT0FBTyxHQUFHLE9BQU8sSUFBSSxFQUFFLENBQUM7RUFDL0IsSUFBTSxDQUFDLFNBQVMsR0FBRyxDQUFDLENBQUM7RUFDckIsSUFBTSxDQUFDLFFBQVEsR0FBRyxFQUFFLENBQUM7RUFDckIsSUFBTSxDQUFDLGVBQWUsR0FBRyxDQUFDLENBQUM7RUFDM0IsSUFBTSxDQUFDLGNBQWMsR0FBRyxFQUFFLENBQUM7RUFDM0IsSUFBTSxDQUFDLGNBQWMsR0FBRyxLQUFLLENBQUM7Q0FDN0IsQ0FBQTs7QUFFSCxxQkFBRSxnQkFBZ0IsOEJBQUMsU0FBUyxFQUFFLFFBQVEsRUFBRTtFQUN0QyxJQUFNLFNBQVMsR0FBRyxJQUFJLENBQUMsY0FBYyxDQUFDLFNBQVMsQ0FBQyxDQUFDOztFQUVqRCxJQUFNLENBQUMsU0FBUyxFQUFFO0lBQ2hCLFNBQVcsR0FBRyxJQUFJLENBQUMsY0FBYyxDQUFDLFNBQVMsQ0FBQyxHQUFHLEVBQUUsQ0FBQztHQUNqRDs7RUFFSCxTQUFXLENBQUMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxDQUFDO0NBQzFCLENBQUE7O0FBRUgscUJBQUUsU0FBUyx1QkFBQyxTQUFTLEVBQUU7OztFQUNyQixDQUFHLElBQUksQ0FBQyxjQUFjLENBQUMsU0FBUyxDQUFDLElBQUksRUFBRSxDQUFDLENBQUMsT0FBTyxDQUFDLFVBQUEsUUFBUSxFQUFDLFNBQUcsUUFBUSxDQUFDRyxNQUFJLENBQUMsR0FBQSxDQUFDLENBQUM7Q0FDNUUsQ0FBQTs7QUFFSCxxQkFBRSxPQUFPLHVCQUFHOzs7RUFDVixPQUFTLElBQUksT0FBTyxDQUFDLFVBQUMsT0FBTyxFQUFFLE1BQU0sRUFBRTs7SUFFckMsSUFBUSxXQUFXLEdBQUdBLE1BQUksQ0FBQyxRQUFRLENBQUM7SUFDcEMsTUFBUSxDQUFDLElBQUksQ0FBQyxXQUFXLENBQUMsQ0FBQyxPQUFPLENBQUMsVUFBQyxFQUFFLEVBQUU7TUFDdEMsSUFBUSxJQUFJLEdBQUcsV0FBVyxDQUFDLEVBQUUsQ0FBQyxDQUFDOzs7TUFHL0IsSUFBTSxJQUFJLENBQUMsTUFBTSxFQUFFO1FBQ2pCLElBQU0sQ0FBQyxNQUFNLEVBQUUsQ0FBQztPQUNmO0tBQ0YsQ0FBQyxDQUFDOzs7SUFHTCxJQUFNLFdBQVcsR0FBRyxLQUFLLENBQUM7O0lBRTFCLE1BQU0sQ0FBQyxlQUFlLElBQUksQ0FBQyxDQUFDO0lBQzVCLE1BQU0sQ0FBQyxNQUFNLEdBQUcsSUFBSSxTQUFTLENBQUNBLE1BQUksQ0FBQyxHQUFHLENBQUMsQ0FBQzs7SUFFeEMsTUFBTSxDQUFDLE1BQU0sQ0FBQyxnQkFBZ0IsQ0FBQyxNQUFNLEVBQUUsWUFBRztNQUN4QyxNQUFNLENBQUMsZUFBZSxHQUFHLENBQUMsQ0FBQztLQUMxQixDQUFDLENBQUM7O0lBRUwsTUFBTSxDQUFDLE1BQU0sQ0FBQyxnQkFBZ0IsQ0FBQyxTQUFTLEVBQUUsVUFBQyxLQUFLLEVBQUU7TUFDaEQsSUFBUSxPQUFPLEdBQUcsSUFBSSxDQUFDLEtBQUssQ0FBQyxLQUFLLENBQUMsSUFBSSxDQUFDLENBQUM7O01BRXpDLEFBQU0sQUFBTyxBQUFFOztRQUViLE9BQVMsQ0FBQyxHQUFHLENBQUMsVUFBVSxFQUFFLE9BQU8sQ0FBQyxDQUFDOztPQUVsQzs7TUFFSCxRQUFVLE9BQU8sQ0FBQyxJQUFJO1FBQ3BCLEtBQU8sT0FBTztVQUNaLE1BQU0sQ0FBQyxRQUFRLENBQUMsT0FBTyxDQUFDLEVBQUUsQ0FBQyxDQUFDLGFBQWEsQ0FBQyxPQUFPLENBQUMsS0FBSyxDQUFDLENBQUM7VUFDekQsTUFBUTs7UUFFVixLQUFPLFFBQVE7VUFDYixJQUFNLE9BQU8sQ0FBQyxPQUFPLEVBQUU7WUFDckIsTUFBTSxDQUFDLFFBQVEsQ0FBQyxPQUFPLENBQUMsRUFBRSxDQUFDLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxDQUFDO1dBQzVDLE1BQU07WUFDUCxNQUFNLENBQUMsUUFBUSxDQUFDLE9BQU8sQ0FBQyxFQUFFLENBQUMsQ0FBQyxNQUFNLENBQUMsT0FBTyxDQUFDLEtBQUssQ0FBQyxDQUFDO1dBQ2pEO1VBQ0gsT0FBU0EsTUFBSSxDQUFDLFFBQVEsQ0FBQyxPQUFPLENBQUMsRUFBRSxDQUFDLENBQUM7VUFDbkMsTUFBUTs7UUFFVixLQUFPLE1BQU07VUFDWCxNQUFROztRQUVWLEtBQU8sZUFBZTtVQUNwQixNQUFNLENBQUMsV0FBVyxDQUFDQyxJQUFhLENBQUNELE1BQUksQ0FBQyxPQUFPLENBQUMsU0FBUyxDQUFDLENBQUMsQ0FBQztVQUMxRCxNQUFROztRQUVWLEtBQU8sY0FBYztVQUNuQixNQUFRLENBQUMsRUFBRSxJQUFJLEVBQUUsZ0JBQWdCLEVBQUUsQ0FBQyxDQUFDO1VBQ3JDLFdBQWEsR0FBRyxJQUFJLENBQUM7VUFDckIsTUFBUTs7UUFFVixLQUFPLFNBQVM7VUFDZCxPQUFTLENBQUNBLE1BQUksQ0FBQyxDQUFDO1VBQ2hCLE1BQU0sQ0FBQyxTQUFTLENBQUMsT0FBTyxDQUFDLENBQUM7Ozs7VUFJMUIsTUFBTSxDQUFDLFNBQVMsR0FBRyxDQUFDLENBQUM7VUFDckIsTUFBTSxDQUFDLFFBQVEsR0FBRyxFQUFFLENBQUM7O1VBRXJCLE1BQVEsQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMsT0FBTyxDQUFDLFVBQUMsRUFBRSxFQUFFO1lBQ3RDLElBQVEsSUFBSSxHQUFHLFdBQVcsQ0FBQyxFQUFFLENBQUMsQ0FBQzs7WUFFL0IsSUFBTSxJQUFJLENBQUMsU0FBUyxFQUFFO2NBQ3BCLE1BQU0sQ0FBQyxlQUFlLENBQUMsSUFBSSxDQUFDLGFBQWEsRUFBRSxJQUFJLENBQUMsU0FBUyxDQUFDO2lCQUNyRCxJQUFJLENBQUMsVUFBQyxLQUFLLEVBQUUsRUFBSyxJQUFJLENBQUMsV0FBVyxHQUFHLEtBQUssQ0FBQyxFQUFFLENBQUMsQ0FBQzthQUNuRDtXQUNGLENBQUMsQ0FBQztVQUNMLE1BQVE7O1FBRVY7VUFDRSxBQUFNLEFBQU8sQUFBRTs7WUFFYixPQUFTLENBQUMsSUFBSSxDQUFDLG1CQUFtQixFQUFFLE9BQU8sQ0FBQyxDQUFDOztXQUU1QztPQUNKO0tBQ0YsQ0FBQyxDQUFDOztJQUVMLE1BQU0sQ0FBQyxNQUFNLENBQUMsZ0JBQWdCLENBQUMsT0FBTyxFQUFFLFlBQUc7TUFDekMsSUFBTSxXQUFXLElBQUlBLE1BQUksQ0FBQyxjQUFjLEVBQUU7O1FBRXhDLE9BQVM7T0FDUixNQUFNLElBQUlBLE1BQUksQ0FBQyxlQUFlLEtBQUssQ0FBQyxFQUFFOztRQUV2QyxNQUFNLENBQUMsU0FBUyxDQUFDLGNBQWMsQ0FBQyxDQUFDO09BQ2hDLE1BQU07O1FBRVAsTUFBUSxDQUFDLGtCQUFrQixDQUFDLENBQUM7T0FDNUI7OztNQUdILElBQVEsUUFBUSxHQUFHLElBQUksQ0FBQyxHQUFHLENBQUNBLE1BQUksQ0FBQyxlQUFlLEVBQUUsQ0FBQyxDQUFDLEdBQUcsSUFBSSxDQUFDO01BQzVELFVBQVksQ0FBQyxZQUFHLFNBQUdBLE1BQUksQ0FBQyxPQUFPLEVBQUUsR0FBQSxFQUFFLFFBQVEsQ0FBQyxDQUFDO0tBQzVDLENBQUMsQ0FBQztHQUNKLENBQUMsQ0FBQztDQUNKLENBQUE7O0FBRUgscUJBQUUsS0FBSyxxQkFBRztFQUNSLElBQU0sQ0FBQyxjQUFjLEdBQUcsSUFBSSxDQUFDO0VBQzdCLElBQU0sQ0FBQyxNQUFNLENBQUMsS0FBSyxFQUFFLENBQUM7Q0FDckIsQ0FBQTs7QUFFSCxxQkFBRSxTQUFTLHlCQUFHO0VBQ1osT0FBUyxJQUFJLENBQUMsa0JBQWtCLENBQUNFLE1BQWUsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLGFBQWEsQ0FBQyxDQUFDO0NBQ3ZFLENBQUE7O0FBRUgscUJBQUUsV0FBVywyQkFBRztFQUNkLE9BQVMsSUFBSSxDQUFDLGtCQUFrQixDQUFDQyxRQUFpQixFQUFFLENBQUMsQ0FBQyxJQUFJLENBQUMsYUFBYSxDQUFDLENBQUM7Q0FDekUsQ0FBQTs7QUFFSCxxQkFBRSxTQUFTLHlCQUFHO0VBQ1osT0FBUyxJQUFJLENBQUMsa0JBQWtCLENBQUNDLE1BQWUsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLGFBQWEsQ0FBQyxDQUFDO0NBQ3ZFLENBQUE7O0FBRUgscUJBQUUsU0FBUyx5QkFBRztFQUNaLE9BQVMsSUFBSSxDQUFDLGtCQUFrQixDQUFDQyxNQUFlLEVBQUUsQ0FBQyxDQUFDLElBQUksQ0FBQyxhQUFhLENBQUMsQ0FBQztDQUN2RSxDQUFBOztBQUVILHFCQUFFLFdBQVcseUJBQUMsTUFBTSxFQUFFLE9BQU8sRUFBRSxXQUFXLEVBQUU7RUFDMUMsT0FBUyxJQUFJLENBQUMsa0JBQWtCLENBQUNDLGFBQW9CLENBQUMsTUFBTSxFQUFFLE9BQU8sRUFBRSxXQUFXLENBQUMsQ0FBQyxDQUFDO0NBQ3BGLENBQUE7Ozs7QUFJSCxxQkFBRSxlQUFlLDZCQUFDLGFBQWEsRUFBRSxTQUFTLEVBQUU7OztFQUMxQyxPQUFTLElBQUksQ0FBQyxrQkFBa0IsQ0FBQ0MsaUJBQXdCLENBQUMsU0FBUyxDQUFDLENBQUMsQ0FBQyxJQUFJO0lBQ3hFLFVBQUcsYUFBYSxFQUFFOzs7TUFHaEIsSUFBUSxJQUFJLEdBQUc7UUFDYixlQUFFLGFBQWE7UUFDZixXQUFFLFNBQVM7UUFDWCxXQUFhLEVBQUUsWUFBRyxTQUFHUCxNQUFJLENBQUMsa0JBQWtCLENBQUNRLGlCQUEwQixDQUFDLGFBQWEsQ0FBQyxFQUFFLENBQUMsQ0FBQzs4QkFDbEUsSUFBSSxDQUFDLFlBQUcsRUFBSyxPQUFPUixNQUFJLENBQUMsUUFBUSxDQUFDLGFBQWEsQ0FBQyxFQUFFLENBQUMsQ0FBQyxFQUFFLENBQUMsR0FBQTtPQUM5RSxDQUFDOztNQUVKLE1BQU0sQ0FBQyxRQUFRLENBQUMsYUFBYSxDQUFDLEVBQUUsQ0FBQyxHQUFHLElBQUksQ0FBQzs7TUFFekMsT0FBUyxZQUFHLFNBQUcsSUFBSSxDQUFDLFdBQVcsRUFBRSxHQUFBLENBQUM7O0tBRWpDOztHQUVGLENBQUM7Q0FDSCxDQUFBOztBQUVILHFCQUFFLElBQUksb0JBQUc7RUFDUCxPQUFTLElBQUksQ0FBQyxrQkFBa0IsQ0FBQ1MsTUFBYSxFQUFFLENBQUMsQ0FBQztDQUNqRCxDQUFBOztBQUVILHFCQUFFLFdBQVcseUJBQUMsT0FBTyxFQUFFO0VBQ3JCLEFBQU0sQUFBTyxBQUFFOztJQUViLE9BQVMsQ0FBQyxHQUFHLENBQUMsU0FBUyxFQUFFLE9BQU8sQ0FBQyxDQUFDOztHQUVqQzs7RUFFSCxJQUFNLENBQUMsTUFBTSxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsU0FBUyxDQUFDLE9BQU8sQ0FBQyxDQUFDLENBQUM7Q0FDM0MsQ0FBQTs7QUFFSCxxQkFBRSxrQkFBa0IsZ0NBQUMsT0FBTyxFQUFFOzs7RUFDNUIsT0FBUyxJQUFJLE9BQU8sQ0FBQyxVQUFDLE9BQU8sRUFBRSxNQUFNLEVBQUU7SUFDckMsTUFBTSxDQUFDLFNBQVMsSUFBSSxDQUFDLENBQUM7SUFDdEIsSUFBUSxTQUFTLEdBQUdULE1BQUksQ0FBQyxTQUFTLENBQUM7O0lBRW5DLE9BQVMsQ0FBQyxFQUFFLEdBQUcsU0FBUyxDQUFDOztJQUV6QixNQUFNLENBQUMsUUFBUSxDQUFDLFNBQVMsQ0FBQyxHQUFHLEVBQUUsU0FBQSxPQUFPLEVBQUUsUUFBQSxNQUFNLEVBQUUsQ0FBQztJQUNqRCxNQUFNLENBQUMsV0FBVyxDQUFDLE9BQU8sQ0FBQyxDQUFDO0dBQzNCLENBQUMsQ0FBQztDQUNKLENBQUE7O0FBR0gsQUFBTyxTQUFTLGdCQUFnQixDQUFDLEdBQUcsRUFBRSxPQUFPLEVBQUU7RUFDN0NILElBQU0sSUFBSSxHQUFHLElBQUksVUFBVSxDQUFDLEdBQUcsRUFBRSxPQUFPLENBQUMsQ0FBQztFQUMxQyxPQUFPLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQztDQUN2QixBQUVELEFBQWdDOzsifQ==
function auth(e){return{type:"auth",api_password:e}}function states(){return{type:"get_states"}}function config(){return{type:"get_config"}}function services(){return{type:"get_services"}}function panels(){return{type:"get_panels"}}function callService$1(e,t,n){var s={type:"call_service",domain:e,service:t};return n&&(s.service_data=n),s}function subscribeEvents$1(e){var t={type:"subscribe_events"};return e&&(t.event_type=e),t}function unsubscribeEvents(e){return{type:"unsubscribe_events",subscription:e}}function ping$1(){return{type:"ping"}}function extractResult(e){return e.result}function createConnection(e,t){var n=new Connection(e,t);return n.connect()}function processEvent(e,t){var n=t.data.new_state;n?e.updateState(n):e.removeState(t.data.entity_id)}function createEntityStore(e){return new Promise(function(t,n){var s=new EntityStore,i=e.subscribeEvents(processEvent.bind(null,s),"state_changed").then(function(e){s.unsubscribe=e}),r=e.getStates().then(function(e){return s.setStates(e)});Promise.all([i,r]).then(function(){return t(s)},function(){return n()})})}var ERR_CANNOT_CONNECT=1,ERR_INVALID_AUTH=2,Connection=function(e,t){this.url=e,this.options=t||{},this.commandId=1,this.commands={},this.connectionTries=0,this.eventListeners={},this.closeRequested=!1};Connection.prototype.addEventListener=function(e,t){var n=this.eventListeners[e];n||(n=this.eventListeners[e]=[]),n.push(t)},Connection.prototype.fireEvent=function(e){var t=this;(this.eventListeners[e]||[]).forEach(function(e){return e(t)})},Connection.prototype.connect=function(){var e=this;return new Promise(function(t,n){var s=e.commands;Object.keys(s).forEach(function(e){var t=s[e];t.reject&&t.reject()});var i=!1;e.connectionTries+=1,e.socket=new WebSocket(e.url),e.socket.addEventListener("open",function(){e.connectionTries=0}),e.socket.addEventListener("message",function(r){var o=JSON.parse(r.data);switch(o.type){case"event":e.commands[o.id].eventCallback(o.event);break;case"result":o.success?e.commands[o.id].resolve(o):e.commands[o.id].reject(o.error),delete e.commands[o.id];break;case"pong":break;case"auth_required":e.sendMessage(auth(e.options.authToken));break;case"auth_invalid":n({code:ERR_INVALID_AUTH}),i=!0;break;case"auth_ok":t(e),e.fireEvent("ready"),e.commandId=1,e.commands={},Object.keys(s).forEach(function(t){var n=s[t];n.eventType&&e.subscribeEvents(n.eventCallback,n.eventType).then(function(e){n.unsubscribe=e})})}}),e.socket.addEventListener("close",function(){if(!i&&!e.closeRequested){0===e.connectionTries?e.fireEvent("disconnected"):n(ERR_CANNOT_CONNECT);var t=1e3*Math.min(e.connectionTries,5);setTimeout(function(){return e.connect()},t)}})})},Connection.prototype.close=function(){this.closeRequested=!0,this.socket.close()},Connection.prototype.getStates=function(){return this.sendMessagePromise(states()).then(extractResult)},Connection.prototype.getServices=function(){return this.sendMessagePromise(services()).then(extractResult)},Connection.prototype.getPanels=function(){return this.sendMessagePromise(panels()).then(extractResult)},Connection.prototype.getConfig=function(){return this.sendMessagePromise(config()).then(extractResult)},Connection.prototype.callService=function(e,t,n){return this.sendMessagePromise(callService$1(e,t,n))},Connection.prototype.subscribeEvents=function(e,t){var n=this;return this.sendMessagePromise(subscribeEvents$1(t)).then(function(s){var i={eventCallback:e,eventType:t,unsubscribe:function(){return n.sendMessagePromise(unsubscribeEvents(s.id)).then(function(){delete n.commands[s.id]})}};return n.commands[s.id]=i,function(){return i.unsubscribe()}})},Connection.prototype.ping=function(){return this.sendMessagePromise(ping$1())},Connection.prototype.sendMessage=function(e){this.socket.send(JSON.stringify(e))},Connection.prototype.sendMessagePromise=function(e){var t=this;return new Promise(function(n,s){t.commandId+=1;var i=t.commandId;e.id=i,t.commands[i]={resolve:n,reject:s},t.sendMessage(e)})};var EntityStore=function(){this.listeners={},this.entities={}};EntityStore.prototype.addEventListener=function(e,t){var n=this.listeners[e];n||(n=this.listeners[e]=[]),n.push(t)},EntityStore.prototype.fireEvent=function(e){var t=this;(this.listeners[e]||[]).forEach(function(e){return e(t.entities)})},EntityStore.prototype.setStates=function(e){for(var t={},n=0;n<e.length;n++){var s=e[n];t[s.entity_id]=s}this.entities=t,this.fireEvent("change")},EntityStore.prototype.updateState=function(e){var t=Object.assign({},this.entities);t[e.entity_id]=e,this.entities=t,this.fireEvent("change")},EntityStore.prototype.removeState=function(e){var t=Object.assign({},this.entities);delete t[e],this.entities=t,this.fireEvent("change")},EntityStore.prototype.unsubscribe=function(){};export{createConnection:createConnection,createEntityStore:createEntityStore,ERR_CANNOT_CONNECT:ERR_CANNOT_CONNECT,ERR_INVALID_AUTH:ERR_INVALID_AUTH};

309

dist/haws.umd.js

@@ -1,308 +0,1 @@

(function (global, factory) {
typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports) :
typeof define === 'function' && define.amd ? define(['exports'], factory) :
(factory((global.HAWS = global.HAWS || {})));
}(this, (function (exports) { 'use strict';
function auth(authToken) {
return {
type: 'auth',
api_password: authToken,
};
}
function states() {
return {
type: 'get_states',
};
}
function config() {
return {
type: 'get_config',
};
}
function services() {
return {
type: 'get_services',
};
}
function panels() {
return {
type: 'get_panels',
};
}
function callService$1(domain, service, serviceData) {
var message = {
type: 'call_service',
domain: domain,
service: service,
};
if (serviceData) {
message.service_data = serviceData;
}
return message;
}
function subscribeEvents$1(eventType) {
var message = {
type: 'subscribe_events',
};
if (eventType) {
message.event_type = eventType;
}
return message;
}
function unsubscribeEvents(subscription) {
return {
type: 'unsubscribe_events',
subscription: subscription,
};
}
function ping$1() {
return {
type: 'ping',
};
}
var ERR_CANNOT_CONNECT = 1;
var ERR_INVALID_AUTH = 2;
function extractResult(message) {
return message.result;
}
var Connection = function Connection(url, options) {
this.url = url;
this.options = options || {};
this.commandId = 1;
this.commands = {};
this.connectionTries = 0;
this.eventListeners = {};
this.closeRequested = false;
};
Connection.prototype.addEventListener = function addEventListener (eventType, callback) {
var listeners = this.eventListeners[eventType];
if (!listeners) {
listeners = this.eventListeners[eventType] = [];
}
listeners.push(callback);
};
Connection.prototype.fireEvent = function fireEvent (eventType) {
var this$1 = this;
(this.eventListeners[eventType] || []).forEach(function (callback) { return callback(this$1); });
};
Connection.prototype.connect = function connect () {
var this$1 = this;
return new Promise(function (resolve, reject) {
// Used for resubscribing in the future
var oldCommands = this$1.commands;
Object.keys(oldCommands).forEach(function (id) {
var info = oldCommands[id];
// Reject stuff still waiting for an answer
if (info.reject) {
info.reject();
}
});
// If invalid auth, we will not try to reconnect.
var invalidAuth = false;
this$1.connectionTries += 1;
this$1.socket = new WebSocket(this$1.url);
this$1.socket.addEventListener('open', function () {
this$1.connectionTries = 0;
});
this$1.socket.addEventListener('message', function (event) {
var message = JSON.parse(event.data);
{
/* eslint-disable no-console */
console.log('Received', message);
/* eslint-enable no-console */
}
switch (message.type) {
case 'event':
this$1.commands[message.id].eventCallback(message.event);
break;
case 'result':
if (message.success) {
this$1.commands[message.id].resolve(message);
} else {
this$1.commands[message.id].reject(message.error);
}
delete this$1.commands[message.id];
break;
case 'pong':
break;
case 'auth_required':
this$1.sendMessage(auth(this$1.options.authToken));
break;
case 'auth_invalid':
reject({ code: ERR_INVALID_AUTH });
invalidAuth = true;
break;
case 'auth_ok':
resolve(this$1);
this$1.fireEvent('ready');
// Re-subscribe to events and update old location of unsub method
// so old unsub method keeps working.
this$1.commandId = 1;
this$1.commands = {};
Object.keys(oldCommands).forEach(function (id) {
var info = oldCommands[id];
if (info.eventType) {
this$1.subscribeEvents(info.eventCallback, info.eventType)
.then(function (unsub) { info.unsubscribe = unsub; });
}
});
break;
default:
{
/* eslint-disable no-console */
console.warn('Unhandled message', message);
/* eslint-enable no-console */
}
}
});
this$1.socket.addEventListener('close', function () {
if (invalidAuth || this$1.closeRequested) {
// When we have invalid auth, let's not reconnect or we get banned.
return;
} else if (this$1.connectionTries === 0) {
// We were connected at some point.
this$1.fireEvent('disconnected');
} else {
// We never were connected
reject(ERR_CANNOT_CONNECT);
}
// Try again
var waitTime = Math.min(this$1.connectionTries, 5) * 1000;
setTimeout(function () { return this$1.connect(); }, waitTime);
});
});
};
Connection.prototype.close = function close () {
this.closeRequested = true;
this.socket.close();
};
Connection.prototype.getStates = function getStates () {
return this.sendMessagePromise(states()).then(extractResult);
};
Connection.prototype.getServices = function getServices () {
return this.sendMessagePromise(services()).then(extractResult);
};
Connection.prototype.getPanels = function getPanels () {
return this.sendMessagePromise(panels()).then(extractResult);
};
Connection.prototype.getConfig = function getConfig () {
return this.sendMessagePromise(config()).then(extractResult);
};
Connection.prototype.callService = function callService (domain, service, serviceData) {
return this.sendMessagePromise(callService$1(domain, service, serviceData));
};
// eventCallback will be called when a new event fires
// Returned promise resolves to an unsubscribe function.
Connection.prototype.subscribeEvents = function subscribeEvents (eventCallback, eventType) {
var this$1 = this;
return this.sendMessagePromise(subscribeEvents$1(eventType)).then(
function (resultMessage) {
// We store unsubscribe on info object. That way we can overwrite it in case
// we get disconnected and we have to subscribe again.
var info = {
eventCallback: eventCallback,
eventType: eventType,
unsubscribe: function () { return this$1.sendMessagePromise(unsubscribeEvents(resultMessage.id))
.then(function () { delete this$1.commands[resultMessage.id]; }); },
};
this$1.commands[resultMessage.id] = info;
return function () { return info.unsubscribe(); };
/* eslint-disable comma-dangle */ /* comma crashes Buble */
}
/* eslint-enable comma-dangle */
);
};
Connection.prototype.ping = function ping () {
return this.sendMessagePromise(ping$1());
};
Connection.prototype.sendMessage = function sendMessage (message) {
{
/* eslint-disable no-console */
console.log('Sending', message);
/* eslint-enable no-console */
}
this.socket.send(JSON.stringify(message));
};
Connection.prototype.sendMessagePromise = function sendMessagePromise (message) {
var this$1 = this;
return new Promise(function (resolve, reject) {
this$1.commandId += 1;
var commandId = this$1.commandId;
/* eslint-disable no-param-reassign */
message.id = commandId;
/* eslint-enable no-param-reassign */
this$1.commands[commandId] = { resolve: resolve, reject: reject };
this$1.sendMessage(message);
});
};
function createConnection(url, options) {
var conn = new Connection(url, options);
return conn.connect();
}
exports.ERR_CANNOT_CONNECT = ERR_CANNOT_CONNECT;
exports.ERR_INVALID_AUTH = ERR_INVALID_AUTH;
exports.createConnection = createConnection;
exports['default'] = createConnection;
Object.defineProperty(exports, '__esModule', { value: true });
})));
//# sourceMappingURL=data:application/json;charset=utf-8;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjpudWxsLCJzb3VyY2VzIjpbIi4uL2xpYi9tZXNzYWdlcy5qcyIsIi4uL2xpYi9pbmRleC5qcyJdLCJzb3VyY2VzQ29udGVudCI6WyJleHBvcnQgZnVuY3Rpb24gYXV0aChhdXRoVG9rZW4pIHtcbiAgcmV0dXJuIHtcbiAgICB0eXBlOiAnYXV0aCcsXG4gICAgYXBpX3Bhc3N3b3JkOiBhdXRoVG9rZW4sXG4gIH07XG59XG5cbmV4cG9ydCBmdW5jdGlvbiBzdGF0ZXMoKSB7XG4gIHJldHVybiB7XG4gICAgdHlwZTogJ2dldF9zdGF0ZXMnLFxuICB9O1xufVxuXG5leHBvcnQgZnVuY3Rpb24gY29uZmlnKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfY29uZmlnJyxcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHNlcnZpY2VzKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfc2VydmljZXMnLFxuICB9O1xufVxuXG5leHBvcnQgZnVuY3Rpb24gcGFuZWxzKCkge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICdnZXRfcGFuZWxzJyxcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNhbGxTZXJ2aWNlKGRvbWFpbiwgc2VydmljZSwgc2VydmljZURhdGEpIHtcbiAgY29uc3QgbWVzc2FnZSA9IHtcbiAgICB0eXBlOiAnY2FsbF9zZXJ2aWNlJyxcbiAgICBkb21haW4sXG4gICAgc2VydmljZSxcbiAgfTtcblxuICBpZiAoc2VydmljZURhdGEpIHtcbiAgICBtZXNzYWdlLnNlcnZpY2VfZGF0YSA9IHNlcnZpY2VEYXRhO1xuICB9XG5cbiAgcmV0dXJuIG1lc3NhZ2U7XG59XG5cbmV4cG9ydCBmdW5jdGlvbiBzdWJzY3JpYmVFdmVudHMoZXZlbnRUeXBlKSB7XG4gIGNvbnN0IG1lc3NhZ2UgPSB7XG4gICAgdHlwZTogJ3N1YnNjcmliZV9ldmVudHMnLFxuICB9O1xuXG4gIGlmIChldmVudFR5cGUpIHtcbiAgICBtZXNzYWdlLmV2ZW50X3R5cGUgPSBldmVudFR5cGU7XG4gIH1cblxuICByZXR1cm4gbWVzc2FnZTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHVuc3Vic2NyaWJlRXZlbnRzKHN1YnNjcmlwdGlvbikge1xuICByZXR1cm4ge1xuICAgIHR5cGU6ICd1bnN1YnNjcmliZV9ldmVudHMnLFxuICAgIHN1YnNjcmlwdGlvbixcbiAgfTtcbn1cblxuZXhwb3J0IGZ1bmN0aW9uIHBpbmcoKSB7XG4gIHJldHVybiB7XG4gICAgdHlwZTogJ3BpbmcnLFxuICB9O1xufVxuIiwiaW1wb3J0ICogYXMgbWVzc2FnZXMgZnJvbSAnLi9tZXNzYWdlcyc7XG5cbmV4cG9ydCBjb25zdCBFUlJfQ0FOTk9UX0NPTk5FQ1QgPSAxO1xuZXhwb3J0IGNvbnN0IEVSUl9JTlZBTElEX0FVVEggPSAyO1xuXG5mdW5jdGlvbiBleHRyYWN0UmVzdWx0KG1lc3NhZ2UpIHtcbiAgcmV0dXJuIG1lc3NhZ2UucmVzdWx0O1xufVxuXG5jbGFzcyBDb25uZWN0aW9uIHtcbiAgY29uc3RydWN0b3IodXJsLCBvcHRpb25zKSB7XG4gICAgdGhpcy51cmwgPSB1cmw7XG4gICAgdGhpcy5vcHRpb25zID0gb3B0aW9ucyB8fCB7fTtcbiAgICB0aGlzLmNvbW1hbmRJZCA9IDE7XG4gICAgdGhpcy5jb21tYW5kcyA9IHt9O1xuICAgIHRoaXMuY29ubmVjdGlvblRyaWVzID0gMDtcbiAgICB0aGlzLmV2ZW50TGlzdGVuZXJzID0ge307XG4gICAgdGhpcy5jbG9zZVJlcXVlc3RlZCA9IGZhbHNlO1xuICB9XG5cbiAgYWRkRXZlbnRMaXN0ZW5lcihldmVudFR5cGUsIGNhbGxiYWNrKSB7XG4gICAgbGV0IGxpc3RlbmVycyA9IHRoaXMuZXZlbnRMaXN0ZW5lcnNbZXZlbnRUeXBlXTtcblxuICAgIGlmICghbGlzdGVuZXJzKSB7XG4gICAgICBsaXN0ZW5lcnMgPSB0aGlzLmV2ZW50TGlzdGVuZXJzW2V2ZW50VHlwZV0gPSBbXTtcbiAgICB9XG5cbiAgICBsaXN0ZW5lcnMucHVzaChjYWxsYmFjayk7XG4gIH1cblxuICBmaXJlRXZlbnQoZXZlbnRUeXBlKSB7XG4gICAgKHRoaXMuZXZlbnRMaXN0ZW5lcnNbZXZlbnRUeXBlXSB8fCBbXSkuZm9yRWFjaChjYWxsYmFjayA9PiBjYWxsYmFjayh0aGlzKSk7XG4gIH1cblxuICBjb25uZWN0KCkge1xuICAgIHJldHVybiBuZXcgUHJvbWlzZSgocmVzb2x2ZSwgcmVqZWN0KSA9PiB7XG4gICAgICAvLyBVc2VkIGZvciByZXN1YnNjcmliaW5nIGluIHRoZSBmdXR1cmVcbiAgICAgIGNvbnN0IG9sZENvbW1hbmRzID0gdGhpcy5jb21tYW5kcztcbiAgICAgIE9iamVjdC5rZXlzKG9sZENvbW1hbmRzKS5mb3JFYWNoKChpZCkgPT4ge1xuICAgICAgICBjb25zdCBpbmZvID0gb2xkQ29tbWFuZHNbaWRdO1xuXG4gICAgICAgIC8vIFJlamVjdCBzdHVmZiBzdGlsbCB3YWl0aW5nIGZvciBhbiBhbnN3ZXJcbiAgICAgICAgaWYgKGluZm8ucmVqZWN0KSB7XG4gICAgICAgICAgaW5mby5yZWplY3QoKTtcbiAgICAgICAgfVxuICAgICAgfSk7XG5cbiAgICAgIC8vIElmIGludmFsaWQgYXV0aCwgd2Ugd2lsbCBub3QgdHJ5IHRvIHJlY29ubmVjdC5cbiAgICAgIGxldCBpbnZhbGlkQXV0aCA9IGZhbHNlO1xuXG4gICAgICB0aGlzLmNvbm5lY3Rpb25UcmllcyArPSAxO1xuICAgICAgdGhpcy5zb2NrZXQgPSBuZXcgV2ViU29ja2V0KHRoaXMudXJsKTtcblxuICAgICAgdGhpcy5zb2NrZXQuYWRkRXZlbnRMaXN0ZW5lcignb3BlbicsICgpID0+IHtcbiAgICAgICAgdGhpcy5jb25uZWN0aW9uVHJpZXMgPSAwO1xuICAgICAgfSk7XG5cbiAgICAgIHRoaXMuc29ja2V0LmFkZEV2ZW50TGlzdGVuZXIoJ21lc3NhZ2UnLCAoZXZlbnQpID0+IHtcbiAgICAgICAgY29uc3QgbWVzc2FnZSA9IEpTT04ucGFyc2UoZXZlbnQuZGF0YSk7XG5cbiAgICAgICAgaWYgKF9fREVWX18pIHtcbiAgICAgICAgICAvKiBlc2xpbnQtZGlzYWJsZSBuby1jb25zb2xlICovXG4gICAgICAgICAgY29uc29sZS5sb2coJ1JlY2VpdmVkJywgbWVzc2FnZSk7XG4gICAgICAgICAgLyogZXNsaW50LWVuYWJsZSBuby1jb25zb2xlICovXG4gICAgICAgIH1cblxuICAgICAgICBzd2l0Y2ggKG1lc3NhZ2UudHlwZSkge1xuICAgICAgICAgIGNhc2UgJ2V2ZW50JzpcbiAgICAgICAgICAgIHRoaXMuY29tbWFuZHNbbWVzc2FnZS5pZF0uZXZlbnRDYWxsYmFjayhtZXNzYWdlLmV2ZW50KTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAncmVzdWx0JzpcbiAgICAgICAgICAgIGlmIChtZXNzYWdlLnN1Y2Nlc3MpIHtcbiAgICAgICAgICAgICAgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXS5yZXNvbHZlKG1lc3NhZ2UpO1xuICAgICAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgICAgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXS5yZWplY3QobWVzc2FnZS5lcnJvcik7XG4gICAgICAgICAgICB9XG4gICAgICAgICAgICBkZWxldGUgdGhpcy5jb21tYW5kc1ttZXNzYWdlLmlkXTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAncG9uZyc6XG4gICAgICAgICAgICBicmVhaztcblxuICAgICAgICAgIGNhc2UgJ2F1dGhfcmVxdWlyZWQnOlxuICAgICAgICAgICAgdGhpcy5zZW5kTWVzc2FnZShtZXNzYWdlcy5hdXRoKHRoaXMub3B0aW9ucy5hdXRoVG9rZW4pKTtcbiAgICAgICAgICAgIGJyZWFrO1xuXG4gICAgICAgICAgY2FzZSAnYXV0aF9pbnZhbGlkJzpcbiAgICAgICAgICAgIHJlamVjdCh7IGNvZGU6IEVSUl9JTlZBTElEX0FVVEggfSk7XG4gICAgICAgICAgICBpbnZhbGlkQXV0aCA9IHRydWU7XG4gICAgICAgICAgICBicmVhaztcblxuICAgICAgICAgIGNhc2UgJ2F1dGhfb2snOlxuICAgICAgICAgICAgcmVzb2x2ZSh0aGlzKTtcbiAgICAgICAgICAgIHRoaXMuZmlyZUV2ZW50KCdyZWFkeScpO1xuXG4gICAgICAgICAgICAvLyBSZS1zdWJzY3JpYmUgdG8gZXZlbnRzIGFuZCB1cGRhdGUgb2xkIGxvY2F0aW9uIG9mIHVuc3ViIG1ldGhvZFxuICAgICAgICAgICAgLy8gc28gb2xkIHVuc3ViIG1ldGhvZCBrZWVwcyB3b3JraW5nLlxuICAgICAgICAgICAgdGhpcy5jb21tYW5kSWQgPSAxO1xuICAgICAgICAgICAgdGhpcy5jb21tYW5kcyA9IHt9O1xuXG4gICAgICAgICAgICBPYmplY3Qua2V5cyhvbGRDb21tYW5kcykuZm9yRWFjaCgoaWQpID0+IHtcbiAgICAgICAgICAgICAgY29uc3QgaW5mbyA9IG9sZENvbW1hbmRzW2lkXTtcblxuICAgICAgICAgICAgICBpZiAoaW5mby5ldmVudFR5cGUpIHtcbiAgICAgICAgICAgICAgICB0aGlzLnN1YnNjcmliZUV2ZW50cyhpbmZvLmV2ZW50Q2FsbGJhY2ssIGluZm8uZXZlbnRUeXBlKVxuICAgICAgICAgICAgICAgICAgLnRoZW4oKHVuc3ViKSA9PiB7IGluZm8udW5zdWJzY3JpYmUgPSB1bnN1YjsgfSk7XG4gICAgICAgICAgICAgIH1cbiAgICAgICAgICAgIH0pO1xuICAgICAgICAgICAgYnJlYWs7XG5cbiAgICAgICAgICBkZWZhdWx0OlxuICAgICAgICAgICAgaWYgKF9fREVWX18pIHtcbiAgICAgICAgICAgICAgLyogZXNsaW50LWRpc2FibGUgbm8tY29uc29sZSAqL1xuICAgICAgICAgICAgICBjb25zb2xlLndhcm4oJ1VuaGFuZGxlZCBtZXNzYWdlJywgbWVzc2FnZSk7XG4gICAgICAgICAgICAgIC8qIGVzbGludC1lbmFibGUgbm8tY29uc29sZSAqL1xuICAgICAgICAgICAgfVxuICAgICAgICB9XG4gICAgICB9KTtcblxuICAgICAgdGhpcy5zb2NrZXQuYWRkRXZlbnRMaXN0ZW5lcignY2xvc2UnLCAoKSA9PiB7XG4gICAgICAgIGlmIChpbnZhbGlkQXV0aCB8fCB0aGlzLmNsb3NlUmVxdWVzdGVkKSB7XG4gICAgICAgICAgLy8gV2hlbiB3ZSBoYXZlIGludmFsaWQgYXV0aCwgbGV0J3Mgbm90IHJlY29ubmVjdCBvciB3ZSBnZXQgYmFubmVkLlxuICAgICAgICAgIHJldHVybjtcbiAgICAgICAgfSBlbHNlIGlmICh0aGlzLmNvbm5lY3Rpb25UcmllcyA9PT0gMCkge1xuICAgICAgICAgIC8vIFdlIHdlcmUgY29ubmVjdGVkIGF0IHNvbWUgcG9pbnQuXG4gICAgICAgICAgdGhpcy5maXJlRXZlbnQoJ2Rpc2Nvbm5lY3RlZCcpO1xuICAgICAgICB9IGVsc2Uge1xuICAgICAgICAgIC8vIFdlIG5ldmVyIHdlcmUgY29ubmVjdGVkXG4gICAgICAgICAgcmVqZWN0KEVSUl9DQU5OT1RfQ09OTkVDVCk7XG4gICAgICAgIH1cblxuICAgICAgICAvLyBUcnkgYWdhaW5cbiAgICAgICAgY29uc3Qgd2FpdFRpbWUgPSBNYXRoLm1pbih0aGlzLmNvbm5lY3Rpb25UcmllcywgNSkgKiAxMDAwO1xuICAgICAgICBzZXRUaW1lb3V0KCgpID0+IHRoaXMuY29ubmVjdCgpLCB3YWl0VGltZSk7XG4gICAgICB9KTtcbiAgICB9KTtcbiAgfVxuXG4gIGNsb3NlKCkge1xuICAgIHRoaXMuY2xvc2VSZXF1ZXN0ZWQgPSB0cnVlO1xuICAgIHRoaXMuc29ja2V0LmNsb3NlKCk7XG4gIH1cblxuICBnZXRTdGF0ZXMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnN0YXRlcygpKS50aGVuKGV4dHJhY3RSZXN1bHQpO1xuICB9XG5cbiAgZ2V0U2VydmljZXMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnNlcnZpY2VzKCkpLnRoZW4oZXh0cmFjdFJlc3VsdCk7XG4gIH1cblxuICBnZXRQYW5lbHMoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnBhbmVscygpKS50aGVuKGV4dHJhY3RSZXN1bHQpO1xuICB9XG5cbiAgZ2V0Q29uZmlnKCkge1xuICAgIHJldHVybiB0aGlzLnNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlcy5jb25maWcoKSkudGhlbihleHRyYWN0UmVzdWx0KTtcbiAgfVxuXG4gIGNhbGxTZXJ2aWNlKGRvbWFpbiwgc2VydmljZSwgc2VydmljZURhdGEpIHtcbiAgICByZXR1cm4gdGhpcy5zZW5kTWVzc2FnZVByb21pc2UobWVzc2FnZXMuY2FsbFNlcnZpY2UoZG9tYWluLCBzZXJ2aWNlLCBzZXJ2aWNlRGF0YSkpO1xuICB9XG5cbiAgLy8gZXZlbnRDYWxsYmFjayB3aWxsIGJlIGNhbGxlZCB3aGVuIGEgbmV3IGV2ZW50IGZpcmVzXG4gIC8vIFJldHVybmVkIHByb21pc2UgcmVzb2x2ZXMgdG8gYW4gdW5zdWJzY3JpYmUgZnVuY3Rpb24uXG4gIHN1YnNjcmliZUV2ZW50cyhldmVudENhbGxiYWNrLCBldmVudFR5cGUpIHtcbiAgICByZXR1cm4gdGhpcy5zZW5kTWVzc2FnZVByb21pc2UobWVzc2FnZXMuc3Vic2NyaWJlRXZlbnRzKGV2ZW50VHlwZSkpLnRoZW4oXG4gICAgICAocmVzdWx0TWVzc2FnZSkgPT4ge1xuICAgICAgICAvLyBXZSBzdG9yZSB1bnN1YnNjcmliZSBvbiBpbmZvIG9iamVjdC4gVGhhdCB3YXkgd2UgY2FuIG92ZXJ3cml0ZSBpdCBpbiBjYXNlXG4gICAgICAgIC8vIHdlIGdldCBkaXNjb25uZWN0ZWQgYW5kIHdlIGhhdmUgdG8gc3Vic2NyaWJlIGFnYWluLlxuICAgICAgICBjb25zdCBpbmZvID0ge1xuICAgICAgICAgIGV2ZW50Q2FsbGJhY2ssXG4gICAgICAgICAgZXZlbnRUeXBlLFxuICAgICAgICAgIHVuc3Vic2NyaWJlOiAoKSA9PiB0aGlzLnNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlcy51bnN1YnNjcmliZUV2ZW50cyhyZXN1bHRNZXNzYWdlLmlkKSlcbiAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAudGhlbigoKSA9PiB7IGRlbGV0ZSB0aGlzLmNvbW1hbmRzW3Jlc3VsdE1lc3NhZ2UuaWRdOyB9KSxcbiAgICAgICAgfTtcblxuICAgICAgICB0aGlzLmNvbW1hbmRzW3Jlc3VsdE1lc3NhZ2UuaWRdID0gaW5mbztcblxuICAgICAgICByZXR1cm4gKCkgPT4gaW5mby51bnN1YnNjcmliZSgpO1xuICAgICAgLyogZXNsaW50LWRpc2FibGUgY29tbWEtZGFuZ2xlICovIC8qIGNvbW1hIGNyYXNoZXMgQnVibGUgKi9cbiAgICAgIH1cbiAgICAgIC8qIGVzbGludC1lbmFibGUgY29tbWEtZGFuZ2xlICovXG4gICAgKTtcbiAgfVxuXG4gIHBpbmcoKSB7XG4gICAgcmV0dXJuIHRoaXMuc2VuZE1lc3NhZ2VQcm9taXNlKG1lc3NhZ2VzLnBpbmcoKSk7XG4gIH1cblxuICBzZW5kTWVzc2FnZShtZXNzYWdlKSB7XG4gICAgaWYgKF9fREVWX18pIHtcbiAgICAgIC8qIGVzbGludC1kaXNhYmxlIG5vLWNvbnNvbGUgKi9cbiAgICAgIGNvbnNvbGUubG9nKCdTZW5kaW5nJywgbWVzc2FnZSk7XG4gICAgICAvKiBlc2xpbnQtZW5hYmxlIG5vLWNvbnNvbGUgKi9cbiAgICB9XG5cbiAgICB0aGlzLnNvY2tldC5zZW5kKEpTT04uc3RyaW5naWZ5KG1lc3NhZ2UpKTtcbiAgfVxuXG4gIHNlbmRNZXNzYWdlUHJvbWlzZShtZXNzYWdlKSB7XG4gICAgcmV0dXJuIG5ldyBQcm9taXNlKChyZXNvbHZlLCByZWplY3QpID0+IHtcbiAgICAgIHRoaXMuY29tbWFuZElkICs9IDE7XG4gICAgICBjb25zdCBjb21tYW5kSWQgPSB0aGlzLmNvbW1hbmRJZDtcbiAgICAgIC8qIGVzbGludC1kaXNhYmxlIG5vLXBhcmFtLXJlYXNzaWduICovXG4gICAgICBtZXNzYWdlLmlkID0gY29tbWFuZElkO1xuICAgICAgLyogZXNsaW50LWVuYWJsZSBuby1wYXJhbS1yZWFzc2lnbiAqL1xuICAgICAgdGhpcy5jb21tYW5kc1tjb21tYW5kSWRdID0geyByZXNvbHZlLCByZWplY3QgfTtcbiAgICAgIHRoaXMuc2VuZE1lc3NhZ2UobWVzc2FnZSk7XG4gICAgfSk7XG4gIH1cbn1cblxuZXhwb3J0IGZ1bmN0aW9uIGNyZWF0ZUNvbm5lY3Rpb24odXJsLCBvcHRpb25zKSB7XG4gIGNvbnN0IGNvbm4gPSBuZXcgQ29ubmVjdGlvbih1cmwsIG9wdGlvbnMpO1xuICByZXR1cm4gY29ubi5jb25uZWN0KCk7XG59XG5cbmV4cG9ydCBkZWZhdWx0IGNyZWF0ZUNvbm5lY3Rpb247XG4iXSwibmFtZXMiOlsiY2FsbFNlcnZpY2UiLCJjb25zdCIsInN1YnNjcmliZUV2ZW50cyIsInBpbmciLCJ0aGlzIiwibWVzc2FnZXMuYXV0aCIsIm1lc3NhZ2VzLnN0YXRlcyIsIm1lc3NhZ2VzLnNlcnZpY2VzIiwibWVzc2FnZXMucGFuZWxzIiwibWVzc2FnZXMuY29uZmlnIiwibWVzc2FnZXMuY2FsbFNlcnZpY2UiLCJtZXNzYWdlcy5zdWJzY3JpYmVFdmVudHMiLCJtZXNzYWdlcy51bnN1YnNjcmliZUV2ZW50cyIsIm1lc3NhZ2VzLnBpbmciXSwibWFwcGluZ3MiOiI7Ozs7OztBQUFPLFNBQVMsSUFBSSxDQUFDLFNBQVMsRUFBRTtFQUM5QixPQUFPO0lBQ0wsSUFBSSxFQUFFLE1BQU07SUFDWixZQUFZLEVBQUUsU0FBUztHQUN4QixDQUFDO0NBQ0g7O0FBRUQsQUFBTyxTQUFTLE1BQU0sR0FBRztFQUN2QixPQUFPO0lBQ0wsSUFBSSxFQUFFLFlBQVk7R0FDbkIsQ0FBQztDQUNIOztBQUVELEFBQU8sU0FBUyxNQUFNLEdBQUc7RUFDdkIsT0FBTztJQUNMLElBQUksRUFBRSxZQUFZO0dBQ25CLENBQUM7Q0FDSDs7QUFFRCxBQUFPLFNBQVMsUUFBUSxHQUFHO0VBQ3pCLE9BQU87SUFDTCxJQUFJLEVBQUUsY0FBYztHQUNyQixDQUFDO0NBQ0g7O0FBRUQsQUFBTyxTQUFTLE1BQU0sR0FBRztFQUN2QixPQUFPO0lBQ0wsSUFBSSxFQUFFLFlBQVk7R0FDbkIsQ0FBQztDQUNIOztBQUVELEFBQU8sU0FBU0EsYUFBVyxDQUFDLE1BQU0sRUFBRSxPQUFPLEVBQUUsV0FBVyxFQUFFO0VBQ3hEQyxJQUFNLE9BQU8sR0FBRztJQUNkLElBQUksRUFBRSxjQUFjO0lBQ3BCLFFBQUEsTUFBTTtJQUNOLFNBQUEsT0FBTztHQUNSLENBQUM7O0VBRUYsSUFBSSxXQUFXLEVBQUU7SUFDZixPQUFPLENBQUMsWUFBWSxHQUFHLFdBQVcsQ0FBQztHQUNwQzs7RUFFRCxPQUFPLE9BQU8sQ0FBQztDQUNoQjs7QUFFRCxBQUFPLFNBQVNDLGlCQUFlLENBQUMsU0FBUyxFQUFFO0VBQ3pDRCxJQUFNLE9BQU8sR0FBRztJQUNkLElBQUksRUFBRSxrQkFBa0I7R0FDekIsQ0FBQzs7RUFFRixJQUFJLFNBQVMsRUFBRTtJQUNiLE9BQU8sQ0FBQyxVQUFVLEdBQUcsU0FBUyxDQUFDO0dBQ2hDOztFQUVELE9BQU8sT0FBTyxDQUFDO0NBQ2hCOztBQUVELEFBQU8sU0FBUyxpQkFBaUIsQ0FBQyxZQUFZLEVBQUU7RUFDOUMsT0FBTztJQUNMLElBQUksRUFBRSxvQkFBb0I7SUFDMUIsY0FBQSxZQUFZO0dBQ2IsQ0FBQztDQUNIOztBQUVELEFBQU8sU0FBU0UsTUFBSSxHQUFHO0VBQ3JCLE9BQU87SUFDTCxJQUFJLEVBQUUsTUFBTTtHQUNiLENBQUM7Q0FDSDs7QUNsRU1GLElBQU0sa0JBQWtCLEdBQUcsQ0FBQyxDQUFDO0FBQ3BDLEFBQU9BLElBQU0sZ0JBQWdCLEdBQUcsQ0FBQyxDQUFDOztBQUVsQyxTQUFTLGFBQWEsQ0FBQyxPQUFPLEVBQUU7RUFDOUIsT0FBTyxPQUFPLENBQUMsTUFBTSxDQUFDO0NBQ3ZCOztBQUVELElBQU0sVUFBVSxHQUFDLG1CQUNKLENBQUMsR0FBRyxFQUFFLE9BQU8sRUFBRTtFQUMxQixJQUFNLENBQUMsR0FBRyxHQUFHLEdBQUcsQ0FBQztFQUNqQixJQUFNLENBQUMsT0FBTyxHQUFHLE9BQU8sSUFBSSxFQUFFLENBQUM7RUFDL0IsSUFBTSxDQUFDLFNBQVMsR0FBRyxDQUFDLENBQUM7RUFDckIsSUFBTSxDQUFDLFFBQVEsR0FBRyxFQUFFLENBQUM7RUFDckIsSUFBTSxDQUFDLGVBQWUsR0FBRyxDQUFDLENBQUM7RUFDM0IsSUFBTSxDQUFDLGNBQWMsR0FBRyxFQUFFLENBQUM7RUFDM0IsSUFBTSxDQUFDLGNBQWMsR0FBRyxLQUFLLENBQUM7Q0FDN0IsQ0FBQTs7QUFFSCxxQkFBRSxnQkFBZ0IsOEJBQUMsU0FBUyxFQUFFLFFBQVEsRUFBRTtFQUN0QyxJQUFNLFNBQVMsR0FBRyxJQUFJLENBQUMsY0FBYyxDQUFDLFNBQVMsQ0FBQyxDQUFDOztFQUVqRCxJQUFNLENBQUMsU0FBUyxFQUFFO0lBQ2hCLFNBQVcsR0FBRyxJQUFJLENBQUMsY0FBYyxDQUFDLFNBQVMsQ0FBQyxHQUFHLEVBQUUsQ0FBQztHQUNqRDs7RUFFSCxTQUFXLENBQUMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxDQUFDO0NBQzFCLENBQUE7O0FBRUgscUJBQUUsU0FBUyx1QkFBQyxTQUFTLEVBQUU7OztFQUNyQixDQUFHLElBQUksQ0FBQyxjQUFjLENBQUMsU0FBUyxDQUFDLElBQUksRUFBRSxDQUFDLENBQUMsT0FBTyxDQUFDLFVBQUEsUUFBUSxFQUFDLFNBQUcsUUFBUSxDQUFDRyxNQUFJLENBQUMsR0FBQSxDQUFDLENBQUM7Q0FDNUUsQ0FBQTs7QUFFSCxxQkFBRSxPQUFPLHVCQUFHOzs7RUFDVixPQUFTLElBQUksT0FBTyxDQUFDLFVBQUMsT0FBTyxFQUFFLE1BQU0sRUFBRTs7SUFFckMsSUFBUSxXQUFXLEdBQUdBLE1BQUksQ0FBQyxRQUFRLENBQUM7SUFDcEMsTUFBUSxDQUFDLElBQUksQ0FBQyxXQUFXLENBQUMsQ0FBQyxPQUFPLENBQUMsVUFBQyxFQUFFLEVBQUU7TUFDdEMsSUFBUSxJQUFJLEdBQUcsV0FBVyxDQUFDLEVBQUUsQ0FBQyxDQUFDOzs7TUFHL0IsSUFBTSxJQUFJLENBQUMsTUFBTSxFQUFFO1FBQ2pCLElBQU0sQ0FBQyxNQUFNLEVBQUUsQ0FBQztPQUNmO0tBQ0YsQ0FBQyxDQUFDOzs7SUFHTCxJQUFNLFdBQVcsR0FBRyxLQUFLLENBQUM7O0lBRTFCLE1BQU0sQ0FBQyxlQUFlLElBQUksQ0FBQyxDQUFDO0lBQzVCLE1BQU0sQ0FBQyxNQUFNLEdBQUcsSUFBSSxTQUFTLENBQUNBLE1BQUksQ0FBQyxHQUFHLENBQUMsQ0FBQzs7SUFFeEMsTUFBTSxDQUFDLE1BQU0sQ0FBQyxnQkFBZ0IsQ0FBQyxNQUFNLEVBQUUsWUFBRztNQUN4QyxNQUFNLENBQUMsZUFBZSxHQUFHLENBQUMsQ0FBQztLQUMxQixDQUFDLENBQUM7O0lBRUwsTUFBTSxDQUFDLE1BQU0sQ0FBQyxnQkFBZ0IsQ0FBQyxTQUFTLEVBQUUsVUFBQyxLQUFLLEVBQUU7TUFDaEQsSUFBUSxPQUFPLEdBQUcsSUFBSSxDQUFDLEtBQUssQ0FBQyxLQUFLLENBQUMsSUFBSSxDQUFDLENBQUM7O01BRXpDLEFBQU0sQUFBTyxBQUFFOztRQUViLE9BQVMsQ0FBQyxHQUFHLENBQUMsVUFBVSxFQUFFLE9BQU8sQ0FBQyxDQUFDOztPQUVsQzs7TUFFSCxRQUFVLE9BQU8sQ0FBQyxJQUFJO1FBQ3BCLEtBQU8sT0FBTztVQUNaLE1BQU0sQ0FBQyxRQUFRLENBQUMsT0FBTyxDQUFDLEVBQUUsQ0FBQyxDQUFDLGFBQWEsQ0FBQyxPQUFPLENBQUMsS0FBSyxDQUFDLENBQUM7VUFDekQsTUFBUTs7UUFFVixLQUFPLFFBQVE7VUFDYixJQUFNLE9BQU8sQ0FBQyxPQUFPLEVBQUU7WUFDckIsTUFBTSxDQUFDLFFBQVEsQ0FBQyxPQUFPLENBQUMsRUFBRSxDQUFDLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxDQUFDO1dBQzVDLE1BQU07WUFDUCxNQUFNLENBQUMsUUFBUSxDQUFDLE9BQU8sQ0FBQyxFQUFFLENBQUMsQ0FBQyxNQUFNLENBQUMsT0FBTyxDQUFDLEtBQUssQ0FBQyxDQUFDO1dBQ2pEO1VBQ0gsT0FBU0EsTUFBSSxDQUFDLFFBQVEsQ0FBQyxPQUFPLENBQUMsRUFBRSxDQUFDLENBQUM7VUFDbkMsTUFBUTs7UUFFVixLQUFPLE1BQU07VUFDWCxNQUFROztRQUVWLEtBQU8sZUFBZTtVQUNwQixNQUFNLENBQUMsV0FBVyxDQUFDQyxJQUFhLENBQUNELE1BQUksQ0FBQyxPQUFPLENBQUMsU0FBUyxDQUFDLENBQUMsQ0FBQztVQUMxRCxNQUFROztRQUVWLEtBQU8sY0FBYztVQUNuQixNQUFRLENBQUMsRUFBRSxJQUFJLEVBQUUsZ0JBQWdCLEVBQUUsQ0FBQyxDQUFDO1VBQ3JDLFdBQWEsR0FBRyxJQUFJLENBQUM7VUFDckIsTUFBUTs7UUFFVixLQUFPLFNBQVM7VUFDZCxPQUFTLENBQUNBLE1BQUksQ0FBQyxDQUFDO1VBQ2hCLE1BQU0sQ0FBQyxTQUFTLENBQUMsT0FBTyxDQUFDLENBQUM7Ozs7VUFJMUIsTUFBTSxDQUFDLFNBQVMsR0FBRyxDQUFDLENBQUM7VUFDckIsTUFBTSxDQUFDLFFBQVEsR0FBRyxFQUFFLENBQUM7O1VBRXJCLE1BQVEsQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMsT0FBTyxDQUFDLFVBQUMsRUFBRSxFQUFFO1lBQ3RDLElBQVEsSUFBSSxHQUFHLFdBQVcsQ0FBQyxFQUFFLENBQUMsQ0FBQzs7WUFFL0IsSUFBTSxJQUFJLENBQUMsU0FBUyxFQUFFO2NBQ3BCLE1BQU0sQ0FBQyxlQUFlLENBQUMsSUFBSSxDQUFDLGFBQWEsRUFBRSxJQUFJLENBQUMsU0FBUyxDQUFDO2lCQUNyRCxJQUFJLENBQUMsVUFBQyxLQUFLLEVBQUUsRUFBSyxJQUFJLENBQUMsV0FBVyxHQUFHLEtBQUssQ0FBQyxFQUFFLENBQUMsQ0FBQzthQUNuRDtXQUNGLENBQUMsQ0FBQztVQUNMLE1BQVE7O1FBRVY7VUFDRSxBQUFNLEFBQU8sQUFBRTs7WUFFYixPQUFTLENBQUMsSUFBSSxDQUFDLG1CQUFtQixFQUFFLE9BQU8sQ0FBQyxDQUFDOztXQUU1QztPQUNKO0tBQ0YsQ0FBQyxDQUFDOztJQUVMLE1BQU0sQ0FBQyxNQUFNLENBQUMsZ0JBQWdCLENBQUMsT0FBTyxFQUFFLFlBQUc7TUFDekMsSUFBTSxXQUFXLElBQUlBLE1BQUksQ0FBQyxjQUFjLEVBQUU7O1FBRXhDLE9BQVM7T0FDUixNQUFNLElBQUlBLE1BQUksQ0FBQyxlQUFlLEtBQUssQ0FBQyxFQUFFOztRQUV2QyxNQUFNLENBQUMsU0FBUyxDQUFDLGNBQWMsQ0FBQyxDQUFDO09BQ2hDLE1BQU07O1FBRVAsTUFBUSxDQUFDLGtCQUFrQixDQUFDLENBQUM7T0FDNUI7OztNQUdILElBQVEsUUFBUSxHQUFHLElBQUksQ0FBQyxHQUFHLENBQUNBLE1BQUksQ0FBQyxlQUFlLEVBQUUsQ0FBQyxDQUFDLEdBQUcsSUFBSSxDQUFDO01BQzVELFVBQVksQ0FBQyxZQUFHLFNBQUdBLE1BQUksQ0FBQyxPQUFPLEVBQUUsR0FBQSxFQUFFLFFBQVEsQ0FBQyxDQUFDO0tBQzVDLENBQUMsQ0FBQztHQUNKLENBQUMsQ0FBQztDQUNKLENBQUE7O0FBRUgscUJBQUUsS0FBSyxxQkFBRztFQUNSLElBQU0sQ0FBQyxjQUFjLEdBQUcsSUFBSSxDQUFDO0VBQzdCLElBQU0sQ0FBQyxNQUFNLENBQUMsS0FBSyxFQUFFLENBQUM7Q0FDckIsQ0FBQTs7QUFFSCxxQkFBRSxTQUFTLHlCQUFHO0VBQ1osT0FBUyxJQUFJLENBQUMsa0JBQWtCLENBQUNFLE1BQWUsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLGFBQWEsQ0FBQyxDQUFDO0NBQ3ZFLENBQUE7O0FBRUgscUJBQUUsV0FBVywyQkFBRztFQUNkLE9BQVMsSUFBSSxDQUFDLGtCQUFrQixDQUFDQyxRQUFpQixFQUFFLENBQUMsQ0FBQyxJQUFJLENBQUMsYUFBYSxDQUFDLENBQUM7Q0FDekUsQ0FBQTs7QUFFSCxxQkFBRSxTQUFTLHlCQUFHO0VBQ1osT0FBUyxJQUFJLENBQUMsa0JBQWtCLENBQUNDLE1BQWUsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLGFBQWEsQ0FBQyxDQUFDO0NBQ3ZFLENBQUE7O0FBRUgscUJBQUUsU0FBUyx5QkFBRztFQUNaLE9BQVMsSUFBSSxDQUFDLGtCQUFrQixDQUFDQyxNQUFlLEVBQUUsQ0FBQyxDQUFDLElBQUksQ0FBQyxhQUFhLENBQUMsQ0FBQztDQUN2RSxDQUFBOztBQUVILHFCQUFFLFdBQVcseUJBQUMsTUFBTSxFQUFFLE9BQU8sRUFBRSxXQUFXLEVBQUU7RUFDMUMsT0FBUyxJQUFJLENBQUMsa0JBQWtCLENBQUNDLGFBQW9CLENBQUMsTUFBTSxFQUFFLE9BQU8sRUFBRSxXQUFXLENBQUMsQ0FBQyxDQUFDO0NBQ3BGLENBQUE7Ozs7QUFJSCxxQkFBRSxlQUFlLDZCQUFDLGFBQWEsRUFBRSxTQUFTLEVBQUU7OztFQUMxQyxPQUFTLElBQUksQ0FBQyxrQkFBa0IsQ0FBQ0MsaUJBQXdCLENBQUMsU0FBUyxDQUFDLENBQUMsQ0FBQyxJQUFJO0lBQ3hFLFVBQUcsYUFBYSxFQUFFOzs7TUFHaEIsSUFBUSxJQUFJLEdBQUc7UUFDYixlQUFFLGFBQWE7UUFDZixXQUFFLFNBQVM7UUFDWCxXQUFhLEVBQUUsWUFBRyxTQUFHUCxNQUFJLENBQUMsa0JBQWtCLENBQUNRLGlCQUEwQixDQUFDLGFBQWEsQ0FBQyxFQUFFLENBQUMsQ0FBQzs4QkFDbEUsSUFBSSxDQUFDLFlBQUcsRUFBSyxPQUFPUixNQUFJLENBQUMsUUFBUSxDQUFDLGFBQWEsQ0FBQyxFQUFFLENBQUMsQ0FBQyxFQUFFLENBQUMsR0FBQTtPQUM5RSxDQUFDOztNQUVKLE1BQU0sQ0FBQyxRQUFRLENBQUMsYUFBYSxDQUFDLEVBQUUsQ0FBQyxHQUFHLElBQUksQ0FBQzs7TUFFekMsT0FBUyxZQUFHLFNBQUcsSUFBSSxDQUFDLFdBQVcsRUFBRSxHQUFBLENBQUM7O0tBRWpDOztHQUVGLENBQUM7Q0FDSCxDQUFBOztBQUVILHFCQUFFLElBQUksb0JBQUc7RUFDUCxPQUFTLElBQUksQ0FBQyxrQkFBa0IsQ0FBQ1MsTUFBYSxFQUFFLENBQUMsQ0FBQztDQUNqRCxDQUFBOztBQUVILHFCQUFFLFdBQVcseUJBQUMsT0FBTyxFQUFFO0VBQ3JCLEFBQU0sQUFBTyxBQUFFOztJQUViLE9BQVMsQ0FBQyxHQUFHLENBQUMsU0FBUyxFQUFFLE9BQU8sQ0FBQyxDQUFDOztHQUVqQzs7RUFFSCxJQUFNLENBQUMsTUFBTSxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsU0FBUyxDQUFDLE9BQU8sQ0FBQyxDQUFDLENBQUM7Q0FDM0MsQ0FBQTs7QUFFSCxxQkFBRSxrQkFBa0IsZ0NBQUMsT0FBTyxFQUFFOzs7RUFDNUIsT0FBUyxJQUFJLE9BQU8sQ0FBQyxVQUFDLE9BQU8sRUFBRSxNQUFNLEVBQUU7SUFDckMsTUFBTSxDQUFDLFNBQVMsSUFBSSxDQUFDLENBQUM7SUFDdEIsSUFBUSxTQUFTLEdBQUdULE1BQUksQ0FBQyxTQUFTLENBQUM7O0lBRW5DLE9BQVMsQ0FBQyxFQUFFLEdBQUcsU0FBUyxDQUFDOztJQUV6QixNQUFNLENBQUMsUUFBUSxDQUFDLFNBQVMsQ0FBQyxHQUFHLEVBQUUsU0FBQSxPQUFPLEVBQUUsUUFBQSxNQUFNLEVBQUUsQ0FBQztJQUNqRCxNQUFNLENBQUMsV0FBVyxDQUFDLE9BQU8sQ0FBQyxDQUFDO0dBQzNCLENBQUMsQ0FBQztDQUNKLENBQUE7O0FBR0gsQUFBTyxTQUFTLGdCQUFnQixDQUFDLEdBQUcsRUFBRSxPQUFPLEVBQUU7RUFDN0NILElBQU0sSUFBSSxHQUFHLElBQUksVUFBVSxDQUFDLEdBQUcsRUFBRSxPQUFPLENBQUMsQ0FBQztFQUMxQyxPQUFPLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQztDQUN2QixBQUVELEFBQWdDOzs7Ozs7Ozs7In0=
!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports):"function"==typeof define&&define.amd?define(["exports"],t):t(e.HAWS=e.HAWS||{})}(this,function(e){"use strict";function t(e){return{type:"auth",api_password:e}}function n(){return{type:"get_states"}}function s(){return{type:"get_config"}}function i(){return{type:"get_services"}}function r(){return{type:"get_panels"}}function o(e,t,n){var s={type:"call_service",domain:e,service:t};return n&&(s.service_data=n),s}function c(e){var t={type:"subscribe_events"};return e&&(t.event_type=e),t}function u(e){return{type:"unsubscribe_events",subscription:e}}function a(){return{type:"ping"}}function d(e){return e.result}function f(e,t){var n=new y(e,t);return n.connect()}function p(e,t){var n=t.data.new_state;n?e.updateState(n):e.removeState(t.data.entity_id)}function v(e){return new Promise(function(t,n){var s=new l,i=e.subscribeEvents(p.bind(null,s),"state_changed").then(function(e){s.unsubscribe=e}),r=e.getStates().then(function(e){return s.setStates(e)});Promise.all([i,r]).then(function(){return t(s)},function(){return n()})})}var h=1,m=2,y=function(e,t){this.url=e,this.options=t||{},this.commandId=1,this.commands={},this.connectionTries=0,this.eventListeners={},this.closeRequested=!1};y.prototype.addEventListener=function(e,t){var n=this.eventListeners[e];n||(n=this.eventListeners[e]=[]),n.push(t)},y.prototype.fireEvent=function(e){var t=this;(this.eventListeners[e]||[]).forEach(function(e){return e(t)})},y.prototype.connect=function(){var e=this;return new Promise(function(n,s){var i=e.commands;Object.keys(i).forEach(function(e){var t=i[e];t.reject&&t.reject()});var r=!1;e.connectionTries+=1,e.socket=new WebSocket(e.url),e.socket.addEventListener("open",function(){e.connectionTries=0}),e.socket.addEventListener("message",function(o){var c=JSON.parse(o.data);switch(c.type){case"event":e.commands[c.id].eventCallback(c.event);break;case"result":c.success?e.commands[c.id].resolve(c):e.commands[c.id].reject(c.error),delete e.commands[c.id];break;case"pong":break;case"auth_required":e.sendMessage(t(e.options.authToken));break;case"auth_invalid":s({code:m}),r=!0;break;case"auth_ok":n(e),e.fireEvent("ready"),e.commandId=1,e.commands={},Object.keys(i).forEach(function(t){var n=i[t];n.eventType&&e.subscribeEvents(n.eventCallback,n.eventType).then(function(e){n.unsubscribe=e})})}}),e.socket.addEventListener("close",function(){if(!r&&!e.closeRequested){0===e.connectionTries?e.fireEvent("disconnected"):s(h);var t=1e3*Math.min(e.connectionTries,5);setTimeout(function(){return e.connect()},t)}})})},y.prototype.close=function(){this.closeRequested=!0,this.socket.close()},y.prototype.getStates=function(){return this.sendMessagePromise(n()).then(d)},y.prototype.getServices=function(){return this.sendMessagePromise(i()).then(d)},y.prototype.getPanels=function(){return this.sendMessagePromise(r()).then(d)},y.prototype.getConfig=function(){return this.sendMessagePromise(s()).then(d)},y.prototype.callService=function(e,t,n){return this.sendMessagePromise(o(e,t,n))},y.prototype.subscribeEvents=function(e,t){var n=this;return this.sendMessagePromise(c(t)).then(function(s){var i={eventCallback:e,eventType:t,unsubscribe:function(){return n.sendMessagePromise(u(s.id)).then(function(){delete n.commands[s.id]})}};return n.commands[s.id]=i,function(){return i.unsubscribe()}})},y.prototype.ping=function(){return this.sendMessagePromise(a())},y.prototype.sendMessage=function(e){this.socket.send(JSON.stringify(e))},y.prototype.sendMessagePromise=function(e){var t=this;return new Promise(function(n,s){t.commandId+=1;var i=t.commandId;e.id=i,t.commands[i]={resolve:n,reject:s},t.sendMessage(e)})};var l=function(){this.listeners={},this.entities={}};l.prototype.addEventListener=function(e,t){var n=this.listeners[e];n||(n=this.listeners[e]=[]),n.push(t)},l.prototype.fireEvent=function(e){var t=this;(this.listeners[e]||[]).forEach(function(e){return e(t.entities)})},l.prototype.setStates=function(e){for(var t={},n=0;n<e.length;n++){var s=e[n];t[s.entity_id]=s}this.entities=t,this.fireEvent("change")},l.prototype.updateState=function(e){var t=Object.assign({},this.entities);t[e.entity_id]=e,this.entities=t,this.fireEvent("change")},l.prototype.removeState=function(e){var t=Object.assign({},this.entities);delete t[e],this.entities=t,this.fireEvent("change")},l.prototype.unsubscribe=function(){},e.createConnection=f,e.createEntityStore=v,e.ERR_CANNOT_CONNECT=h,e.ERR_INVALID_AUTH=m,Object.defineProperty(e,"__esModule",{value:!0})});

2

package.json
{
"name": "home-assistant-js-websocket",
"version": "0.1.4",
"version": "0.2.0",
"description": "Home Assistant websocket client",

@@ -5,0 +5,0 @@ "main": "dist/haws.cjs.js",

27

README.md

@@ -6,3 +6,3 @@ # :aerial_tramway: JavaScript websocket client for Home Assistant

```javascript
import createConnection from 'home-assistant-js-websocket';
import { createConnection } from 'home-assistant-js-websocket';

@@ -24,2 +24,4 @@ function stateChanged(event) {

### Initializing connection
Connections to the websocket API are initiated by calling `createConnection(url[, options])`. `createConnection` will return a promise that will resolve to either a `Connection` object or rejects with an error code.

@@ -50,3 +52,3 @@

## Automatic reconnecting
#### Automatic reconnecting

@@ -70,2 +72,19 @@ The connection object will automatically try to reconnect to the server when the connection gets lost. On reconnect, it will automatically resubscribe the event listeners.

### Entities
An Entity Store is available that at all times will represent the latest information about the available entities. It is possible to listen for `change` events on the store to be notified when it gets updated.
```javascript
import { createEntityStore } from 'home-assistant-js-websocket';
// conn is connection from earlier.
createEntityStore(conn).then((entityStore) => {
console.log('Current entities', entityStore.entities);
entityStore.addEventListener('change', entities => console.log('Store updated!', entities));
});
```
## Connection API Reference

@@ -98,1 +117,5 @@

Returns a promise that will resolve to a function that will cancel the subscription once called.
#### `conn.addEventListener(eventType, listener)
Listen for events on the connection. [See docs.](#automatic-reconnecting)
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc