nkellenicki/node-poweredup
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Prevent multiple connection attempts

Browse Source
This commit is contained in:
Nathan Kellenicki 2019-02-04 16:14:31 -08:00
parent aaccfb7182
commit f009bc3e2a
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/hub.ts
View File

@ -41,6 +41,9 @@ export class Hub extends EventEmitter {
private _uuid: string; private _uuid: string;
private _rssi: number = -100; private _rssi: number = -100;
private _isConnecting = false;
private _isConnected = false;
constructor (peripheral: Peripheral, autoSubscribe: boolean = true) { constructor (peripheral: Peripheral, autoSubscribe: boolean = true) {
super(); super();
this.autoSubscribe = !!autoSubscribe; this.autoSubscribe = !!autoSubscribe;
@ -127,6 +130,13 @@ export class Hub extends EventEmitter {
const self = this; const self = this;
if (this._isConnecting) {
return connectReject("Already connecting");
} else if (this._isConnected) {
return connectReject("Already connected");
}
this._isConnecting = true;
this._peripheral.connect((err: string) => { this._peripheral.connect((err: string) => {
this._rssi = this._peripheral.rssi; this._rssi = this._peripheral.rssi;
@ -142,6 +152,8 @@ export class Hub extends EventEmitter {
self._peripheral.on("disconnect", () => { self._peripheral.on("disconnect", () => {
clearInterval(rssiUpdateInterval); clearInterval(rssiUpdateInterval);
this._isConnecting = false;
this._isConnected = false;
this.emit("disconnect"); this.emit("disconnect");
}); });
@ -167,6 +179,8 @@ export class Hub extends EventEmitter {
Promise.all(servicePromises).then(() => { Promise.all(servicePromises).then(() => {
debug("Service/characteristic discovery finished"); debug("Service/characteristic discovery finished");
this._isConnecting = false;
this._isConnected = true;
this.emit("connect"); this.emit("connect");
return connectResolve(); return connectResolve();
}); });