* fix start issue
This commit is contained in:
+13
-1
@@ -23,6 +23,7 @@ function HASS(options, log) {
|
||||
const requests = {};
|
||||
let connected;
|
||||
let connectTimeout = null;
|
||||
let closed = false;
|
||||
|
||||
function subscribeEvents(socket, callback) {
|
||||
if (socket && typeof socket.send === 'function') {
|
||||
@@ -184,7 +185,7 @@ function HASS(options, log) {
|
||||
that.emit('disconnected');
|
||||
|
||||
}
|
||||
if (!connectTimeout) {
|
||||
if (!connectTimeout && !closed) {
|
||||
setTimeout(() => {
|
||||
connectTimeout = null;
|
||||
that.connect();
|
||||
@@ -248,6 +249,17 @@ function HASS(options, log) {
|
||||
initSocket(this.socket);
|
||||
};
|
||||
|
||||
this.close = function () {
|
||||
if (connectTimeout) {
|
||||
clearTimeout(connectTimeout);
|
||||
connectTimeout = null;
|
||||
}
|
||||
closed = true;
|
||||
if (this.socket) {
|
||||
this.socket.close();
|
||||
}
|
||||
}
|
||||
|
||||
return this;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user