linting, testing and async fixes

abandonware · Sep 21, 2020 · 64b9744 · 64b9744
1 parent 422f4e7
commit 64b9744
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 11 deletions.
diff --git a/lib/hci-socket/hci.js b/lib/hci-socket/hci.js
@@ -80,9 +80,11 @@ const Hci = function (options) {
 
   this._handleBuffers = {};
 
-  this._deviceId =  options.deviceId != null ? parseInt(options.deviceId, 10) :
-                    process.env.NOBLE_HCI_DEVICE_ID ? parseInt(process.env.NOBLE_HCI_DEVICE_ID, 10) :
-                    undefined;
+  this._deviceId = options.deviceId != null
+    ? parseInt(options.deviceId, 10)
+    : process.env.NOBLE_HCI_DEVICE_ID
+      ? parseInt(process.env.NOBLE_HCI_DEVICE_ID, 10)
+      : undefined;
 
   this._userChannel = (typeof options.userChannel === 'undefined' && options.userChannel) || process.env.HCI_CHANNEL_USER;
 

diff --git a/lib/noble.js b/lib/noble.js
@@ -99,14 +99,14 @@ Noble.prototype.setScanParameters = function (interval, window, callback) {
     this.once('scanParametersSet', callback);
   }
   this._bindings.setScanParameters(interval, window);
-}
+};
 
 Noble.prototype.onScanParametersSet = function () {
   debug('scanParametersSet');
   this.emit('scanParametersSet');
 };
 
-Noble.prototype.startScanning = function (serviceUuids, allowDuplicates, callback) {
+const startScanning = function (serviceUuids, allowDuplicates, callback) {
   if (typeof serviceUuids === 'function') {
     this.emit('warning', 'calling startScanning(callback) is deprecated');
   }

diff --git a/lib/peripheral.js b/lib/peripheral.js
@@ -31,7 +31,7 @@ Peripheral.prototype.toString = function () {
   });
 };
 
-Peripheral.prototype.connect = function (options, callback) {
+const connect = function (options, callback) {
   if (typeof options === 'function') {
     callback = options;
     options = undefined;
@@ -46,11 +46,17 @@ Peripheral.prototype.connect = function (options, callback) {
     this.emit('connect', new Error('Peripheral already connected'));
   } else {
     this.state = 'connecting';
+    console.log('connecting');
     this._noble.connect(this.id, options);
   }
 };
 
-Peripheral.prototype.cancelConnect = function (options, callback) {
+Peripheral.prototype.connect = connect;
+Peripheral.prototype.connectAsync = function (options) {
+  return util.promisify((callback) => this.connect(options, callback))();
+};
+
+const cancelConnect = function (options, callback) {
   if (typeof options === 'function') {
     callback = options;
     options = undefined;
@@ -70,8 +76,10 @@ Peripheral.prototype.cancelConnect = function (options, callback) {
   }
 };
 
-Peripheral.prototype.connect = connect;
-Peripheral.prototype.connectAsync = util.promisify(connect);
+Peripheral.prototype.cancelConnect = cancelConnect;
+Peripheral.prototype.cancelConnectAsync = function (options) {
+  return util.promisify((callback) => this.cancleConnect(options, callback))();
+};
 
 const disconnect = function (callback) {
   if (callback) {

diff --git a/test/test-peripheral.js b/test/test-peripheral.js
@@ -67,7 +67,7 @@ describe('Peripheral', function () {
     it('should delegate to noble', function () {
       peripheral.connect();
 
-      mockNoble.connect.calledWithExactly(mockId).should.equal(true);
+      mockNoble.connect.calledWithExactly(mockId, undefined).should.equal(true);
     });
 
     it('should callback', function () {
@@ -105,7 +105,7 @@ describe('Peripheral', function () {
       peripheral.emit('connect');
       await promise;
 
-      mockNoble.connect.calledWithExactly(mockId).should.equal(true);
+      mockNoble.connect.calledWithExactly(mockId, undefined).should.equal(true);
     });
   });