Source: mac/yosemite.js

  1. var events        = require('events');
  2. var os            = require('os');
  3. var util          = require('util');
  5. var debug         = require('debug')('yosemite-bindings');
  7. var XpcConnection = require('xpc-connection');
  9. var uuidToAddress = require('./uuid-to-address');
  11. /**
  12.  *  NobleBindings for mac
  13.  */
  14. var NobleBindings = function() {
  15.   this._xpcConnection = new XpcConnection('com.apple.blued');
  16.   this._xpcConnection.on('error', function(message) {this.emit('xpcError', message);}.bind(this));
  17.   this._xpcConnection.on('event', function(event)   {this.emit('xpcEvent', event);  }.bind(this));
  18. };
  20. util.inherits(NobleBindings, events.EventEmitter);
  21. NobleBindings.prototype.setupXpcConnection = function() {this._xpcConnection.setup();};
  22. NobleBindings.prototype.sendXpcMessage = function(message) {this._xpcConnection.sendMessage(message);};
  24. var nobleBindings = new NobleBindings();
  25. nobleBindings._peripherals = {};
  29. // General xpc message handling
  30. nobleBindings.on('xpcEvent', function(event) {
  31.   debug('xpcEvent: ' + JSON.stringify(event, undefined, 2));
  33.   var kCBMsgId   = event.kCBMsgId;
  34.   var kCBMsgArgs = event.kCBMsgArgs;
  35.   this.emit('kCBMsgId' + kCBMsgId, kCBMsgArgs);
  36. });
  38. nobleBindings.on('xpcError', function(message) {
  39.   console.error('xpcError: ' + message);
  40. });
  42. nobleBindings.sendCBMsg = function(id, args) {
  43.   debug('sendCBMsg: ' + id + ', ' + JSON.stringify(args, undefined, 2));
  44.   this.sendXpcMessage({kCBMsgId: id,kCBMsgArgs: args});
  45. };
  50. /**
  51.  * Init xpc connection to blued
  52.  *
  53.  * @discussion tested
  54.  */
  55. nobleBindings.init = function() {
  56.   this.sendCBMsg(1, {
  57.     kCBMsgArgName: 'node-' + (new Date()).getTime(),
  58.     kCBMsgArgOptions: {
  59.         kCBInitOptionShowPowerAlert: 0
  60.     },
  61.     kCBMsgArgType: 0
  62.   });
  63. };
  65. nobleBindings.on('kCBMsgId6', function(args) {
  66.   var state = ['unknown', 'resetting', 'unsupported', 'unauthorized', 'poweredOff', 'poweredOn'][args.kCBMsgArgState];
  67.   debug('state change ' + state);
  68.   this.emit('stateChange', state);
  69. });
  73. /**
  74.  * Start scanning
  75.  * @param  {Array} serviceUuids     Scan for these UUIDs, if undefined then scan for all
  76.  * @param  {Bool}  allowDuplicates  Scan can return duplicates
  77.  *
  78.  * @discussion tested
  79.  */
  80. nobleBindings.startScanning = function(serviceUuids, allowDuplicates) {
  81.   var args = {
  82.     kCBMsgArgOptions: {},
  83.     kCBMsgArgUUIDs: []
  84.   };
  86.   if (serviceUuids) {
  87.     for(var i = 0; i < serviceUuids.length; i++) {
  88.       args.kCBMsgArgUUIDs[i] = new Buffer(serviceUuids[i], 'hex');
  89.     }
  90.   }
  92.   if (allowDuplicates) {
  93.     args.kCBMsgArgOptions.kCBScanOptionAllowDuplicates = 1;
  94.   }
  96.   this.sendCBMsg(29, args);
  97.   this.emit('scanStart');
  98. };
  100. /**
  101.  * Response message to start scanning
  102.  *
  103.  * @example
  104.  * // For `TI Sensortag` the message lookes like this:
  105.  * handleMsg: 37, {
  106.  *     kCBMsgArgAdvertisementData =     {
  107.  *         kCBAdvDataIsConnectable = 1;
  108.  *         kCBAdvDataLocalName = SensorTag;
  109.  *         kCBAdvDataTxPowerLevel = 0;
  110.  *     };
  111.  *     kCBMsgArgDeviceUUID = "<__NSConcreteUUID 0x6180000208e0> 53486C7A-DED2-4AA6-8913-387CD22F25D8";
  112.  *     kCBMsgArgName = SensorTag;
  113.  *     kCBMsgArgRssi = "-68";
  114.  * }
  115.  *
  116.  * @discussion tested
  117.  */
  118. nobleBindings.on('kCBMsgId37', function(args) {
  119.   if (Object.keys(args.kCBMsgArgAdvertisementData).length === 0) {
  120.     return;
  121.   }
  123.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  124.   var advertisement = {
  125.     localName: args.kCBMsgArgAdvertisementData.kCBAdvDataLocalName || args.kCBMsgArgName,
  126.     txPowerLevel: args.kCBMsgArgAdvertisementData.kCBAdvDataTxPowerLevel,
  127.     manufacturerData: args.kCBMsgArgAdvertisementData.kCBAdvDataManufacturerData,
  128.     serviceData: [],
  129.     serviceUuids: []
  130.   };
  131.   var rssi = args.kCBMsgArgRssi;
  132.   var i;
  134.   if (args.kCBMsgArgAdvertisementData.kCBAdvDataServiceUUIDs) {
  135.     for(i = 0; i < args.kCBMsgArgAdvertisementData.kCBAdvDataServiceUUIDs.length; i++) {
  136.       advertisement.serviceUuids.push(args.kCBMsgArgAdvertisementData.kCBAdvDataServiceUUIDs[i].toString('hex'));
  137.     }
  138.   }
  140.   var serviceData = args.kCBMsgArgAdvertisementData.kCBAdvDataServiceData;
  141.   if (serviceData) {
  142.     for (i = 0; i < serviceData.length; i += 2) {
  143.       var serviceDataUuid = serviceData[i].toString('hex');
  144.       var data = serviceData[i + 1];
  146.       advertisement.serviceData.push({
  147.         uuid: serviceDataUuid,
  148.         data: data
  149.       });
  150.     }
  151.   }
  153.   debug('peripheral ' + deviceUuid + ' discovered');
  155.   var uuid = new Buffer(deviceUuid, 'hex');
  156.   uuid.isUuid = true;
  158.   if (!this._peripherals[deviceUuid]) {
  159.     this._peripherals[deviceUuid] = {};
  160.   }
  162.   this._peripherals[deviceUuid].uuid = uuid;
  163.   this._peripherals[deviceUuid].advertisement = advertisement;
  164.   this._peripherals[deviceUuid].rssi = rssi;
  166.   (function(deviceUuid, advertisement, rssi) {
  167.     uuidToAddress(deviceUuid, function(error, address, addressType) {
  168.       address = address || 'unknown';
  169.       addressType = addressType || 'unknown';
  171.       this._peripherals[deviceUuid].address = address;
  172.       this._peripherals[deviceUuid].addressType = addressType;
  174.       this.emit('discover', deviceUuid, address, addressType, advertisement, rssi);
  175.     }.bind(this));
  176.   }.bind(this))(deviceUuid, advertisement, rssi);
  177. });
  180. /**
  181.  * Stop scanning
  182.  *
  183.  * @discussion tested
  184.  */
  185. nobleBindings.stopScanning = function() {
  186.   this.sendCBMsg(30, null);
  187.   this.emit('scanStop');
  188. };
  192. /**
  193.  * Connect to peripheral
  194.  * @param  {String} deviceUuid    Peripheral uuid to connect to
  195.  *
  196.  * @discussion tested
  197.  */
  198. nobleBindings.connect = function(deviceUuid) {
  199.   this.sendCBMsg(31, {
  200.     kCBMsgArgOptions: {
  201.       kCBConnectOptionNotifyOnDisconnection: 1
  202.     },
  203.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid
  204.   });
  205. };
  207. nobleBindings.on('kCBMsgId38', function(args) {
  208.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  210.   debug('peripheral ' + deviceUuid + ' connected');
  212.   this.emit('connect', deviceUuid);
  213. });
  217. /**
  218.  * Disconnect
  219.  *
  220.  * @param  {String} deviceUuid    Peripheral uuid to disconnect
  221.  *
  222.  * @discussion tested
  223.  */
  224. nobleBindings.disconnect = function(deviceUuid) {
  225.   this.sendCBMsg(32, {
  226.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid
  227.   });
  228. };
  230. /**
  231.  * Response to disconnect
  232.  *
  233.  * @discussion tested
  234.  */
  235. nobleBindings.on('kCBMsgId40', function(args) {
  236.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  238.   debug('peripheral ' + deviceUuid + ' disconnected');
  240.   this.emit('disconnect', deviceUuid);
  241. });
  245. /**
  246.  * Update RSSI
  247.  *
  248.  * @discussion tested
  249.  */
  250. nobleBindings.updateRssi = function(deviceUuid) {
  251.   this.sendCBMsg(44, {
  252.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid
  253.   });
  254. };
  256. /**
  257.  * Response to RSSI update
  258.  *
  259.  * @discussion tested
  260.  */
  261. nobleBindings.on('kCBMsgId55', function(args) {
  262.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  263.   var rssi = args.kCBMsgArgData;
  265.   this._peripherals[deviceUuid].rssi = rssi;
  267.   debug('peripheral ' + deviceUuid + ' RSSI update ' + rssi);
  269.   this.emit('rssiUpdate', deviceUuid, rssi);
  270. });
  274. /**
  275.  * Discover services
  276.  *
  277.  * @param  {String} deviceUuid  Device UUID
  278.  * @param  {Array} uuids        Services to discover, if undefined then all
  279.  *
  280.  * @discussion tested
  281.  */
  282. nobleBindings.discoverServices = function(deviceUuid, uuids) {
  283.   var args = {
  284.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  285.     kCBMsgArgUUIDs: []
  286.   };
  288.   if (uuids) {
  289.     for(var i = 0; i < uuids.length; i++) {
  290.       args.kCBMsgArgUUIDs[i] = new Buffer(uuids[i], 'hex');
  291.     }
  292.   }
  294.   this.sendCBMsg(45, args);
  295. };
  297. /**
  298.  * Response to discover service
  299.  *
  300.  * @discussion tested
  301.  */
  302. nobleBindings.on('kCBMsgId56', function(args) {
  303.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  304.   var serviceUuids = [];
  306.   this._peripherals[deviceUuid].services = {};
  308.   if (args.kCBMsgArgServices) {
  309.     for(var i = 0; i < args.kCBMsgArgServices.length; i++) {
  310.       var service = {
  311.         uuid: args.kCBMsgArgServices[i].kCBMsgArgUUID.toString('hex'),
  312.         startHandle: args.kCBMsgArgServices[i].kCBMsgArgServiceStartHandle,
  313.         endHandle: args.kCBMsgArgServices[i].kCBMsgArgServiceEndHandle
  314.       };
  316.       this._peripherals[deviceUuid].services[service.uuid] = this._peripherals[deviceUuid].services[service.startHandle] = service;
  318.       serviceUuids.push(service.uuid);
  319.     }
  320.   }
  321.   // TODO: result 24 => device not connected
  323.   this.emit('servicesDiscover', deviceUuid, serviceUuids);
  324. });
  328. /**
  329.  * [discoverIncludedServices description]
  330.  *
  331.  * @param  {String} deviceUuid
  332.  * @param  {String} serviceUuid
  333.  * @param  {String} serviceUuids
  334.  *
  335.  * @dicussion tested
  336.  */
  337. nobleBindings.discoverIncludedServices = function(deviceUuid, serviceUuid, serviceUuids) {
  338.   var args = {
  339.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  340.     kCBMsgArgServiceStartHandle: this._peripherals[deviceUuid].services[serviceUuid].startHandle,
  341.     kCBMsgArgServiceEndHandle: this._peripherals[deviceUuid].services[serviceUuid].endHandle,
  342.     kCBMsgArgUUIDs: []
  343.   };
  345.   if (serviceUuids) {
  346.     for(var i = 0; i < serviceUuids.length; i++) {
  347.       args.kCBMsgArgUUIDs[i] = new Buffer(serviceUuids[i], 'hex');
  348.     }
  349.   }
  351.   this.sendCBMsg(61, args);
  352. };
  354. /**
  355.  * Response to dicover included services
  356.  *
  357.  * @dicussion tested
  358.  */
  359. nobleBindings.on('kCBMsgId63', function(args) {
  360.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  361.   var serviceStartHandle = args.kCBMsgArgServiceStartHandle;
  362.   var serviceUuid = this._peripherals[deviceUuid].services[serviceStartHandle].uuid;
  363.   var result = args.kCBMsgArgResult;
  364.   var includedServiceUuids = [];
  366.   this._peripherals[deviceUuid].services[serviceStartHandle].includedServices = {};
  368.   for(var i = 0; i < args.kCBMsgArgServices.length; i++) {
  369.     var includedService = {
  370.       uuid: args.kCBMsgArgServices[i].kCBMsgArgUUID.toString('hex'),
  371.       startHandle: args.kCBMsgArgServices[i].kCBMsgArgServiceStartHandle,
  372.       endHandle: args.kCBMsgArgServices[i].kCBMsgArgServiceEndHandle
  373.     };
  375.     this._peripherals[deviceUuid].services[serviceStartHandle].includedServices[includedServices.uuid] =
  376.       this._peripherals[deviceUuid].services[serviceStartHandle].includedServices[includedServices.startHandle] = includedService;
  378.     includedServiceUuids.push(includedService.uuid);
  379.   }
  381.   this.emit('includedServicesDiscover', deviceUuid, serviceUuid, includedServiceUuids);
  382. });
  386. /**
  387.  * Discover characteristic
  388.  *
  389.  * @param  {String} deviceUuid          Peripheral UUID
  390.  * @param  {String} serviceUuid         Service UUID
  391.  * @param  {Array} characteristicUuids  Characteristics to discover, all if empty
  392.  *
  393.  * @discussion tested
  394.  */
  395. nobleBindings.discoverCharacteristics = function(deviceUuid, serviceUuid, characteristicUuids) {
  396.   var args = {
  397.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  398.     kCBMsgArgServiceStartHandle: this._peripherals[deviceUuid].services[serviceUuid].startHandle,
  399.     kCBMsgArgServiceEndHandle: this._peripherals[deviceUuid].services[serviceUuid].endHandle,
  400.     kCBMsgArgUUIDs: []
  401.   };
  403.   if (characteristicUuids) {
  404.     for(var i = 0; i < characteristicUuids.length; i++) {
  405.       args.kCBMsgArgUUIDs[i] = new Buffer(characteristicUuids[i], 'hex');
  406.     }
  407.   }
  409.   this.sendCBMsg(62, args);
  410. };
  412. /**
  413.  * Response to characteristic discovery
  414.  *
  415.  * @discussion tested
  416.  */
  417. nobleBindings.on('kCBMsgId64', function(args) {
  418.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  419.   var serviceStartHandle = args.kCBMsgArgServiceStartHandle;
  420.   var serviceUuid = this._peripherals[deviceUuid].services[serviceStartHandle].uuid;
  421.   var result = args.kCBMsgArgResult;
  422.   var characteristics = [];
  424.   this._peripherals[deviceUuid].services[serviceStartHandle].characteristics = {};
  426.   for(var i = 0; i < args.kCBMsgArgCharacteristics.length; i++) {
  427.     var properties = args.kCBMsgArgCharacteristics[i].kCBMsgArgCharacteristicProperties;
  429.     var characteristic = {
  430.       uuid: args.kCBMsgArgCharacteristics[i].kCBMsgArgUUID.toString('hex'),
  431.       handle: args.kCBMsgArgCharacteristics[i].kCBMsgArgCharacteristicHandle,
  432.       valueHandle: args.kCBMsgArgCharacteristics[i].kCBMsgArgCharacteristicValueHandle,
  433.       properties: []
  434.     };
  436.     if (properties & 0x01) {
  437.       characteristic.properties.push('broadcast');
  438.     }
  440.     if (properties & 0x02) {
  441.       characteristic.properties.push('read');
  442.     }
  444.     if (properties & 0x04) {
  445.       characteristic.properties.push('writeWithoutResponse');
  446.     }
  448.     if (properties & 0x08) {
  449.       characteristic.properties.push('write');
  450.     }
  452.     if (properties & 0x10) {
  453.       characteristic.properties.push('notify');
  454.     }
  456.     if (properties & 0x20) {
  457.       characteristic.properties.push('indicate');
  458.     }
  460.     if (properties & 0x40) {
  461.       characteristic.properties.push('authenticatedSignedWrites');
  462.     }
  464.     if (properties & 0x80) {
  465.       characteristic.properties.push('extendedProperties');
  466.     }
  468.     this._peripherals[deviceUuid].services[serviceStartHandle].characteristics[characteristic.uuid] =
  469.       this._peripherals[deviceUuid].services[serviceStartHandle].characteristics[characteristic.handle] =
  470.       this._peripherals[deviceUuid].services[serviceStartHandle].characteristics[characteristic.valueHandle] = characteristic;
  472.     characteristics.push({
  473.       uuid: characteristic.uuid,
  474.       properties: characteristic.properties
  475.     });
  476.   }
  478.   this.emit('characteristicsDiscover', deviceUuid, serviceUuid, characteristics);
  479. });
  483. /**
  484.  * Read value
  485.  *
  486.  * @param  {[type]} deviceUuid         [description]
  487.  * @param  {[type]} serviceUuid        [description]
  488.  * @param  {[type]} characteristicUuid [description]
  489.  *
  490.  * @discussion tested
  491.  */
  492. nobleBindings.read = function(deviceUuid, serviceUuid, characteristicUuid) {
  493.   this.sendCBMsg(65 , {
  494.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  495.     kCBMsgArgCharacteristicHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].handle,
  496.     kCBMsgArgCharacteristicValueHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].valueHandle
  497.   });
  498. };
  500. /**
  501.  * Response to read value
  502.  *
  503.  * @discussion tested
  504.  */
  505. nobleBindings.on('kCBMsgId71', function(args) {
  506.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  507.   var characteristicHandle = args.kCBMsgArgCharacteristicHandle;
  508.   var isNotification = args.kCBMsgArgIsNotification ? true : false;
  509.   var data = args.kCBMsgArgData;
  511.   var peripheral = this._peripherals[deviceUuid];
  513.   if (peripheral) {
  514.     for(var i in peripheral.services) {
  515.       if (peripheral.services[i].characteristics &&
  516.           peripheral.services[i].characteristics[characteristicHandle]) {
  518.         this.emit('read', deviceUuid, peripheral.services[i].uuid,
  519.           peripheral.services[i].characteristics[characteristicHandle].uuid, data, isNotification);
  520.         break;
  521.       }
  522.     }
  523.   } else {
  524.     console.warn('noble (mac yosemite): received read event from unknown peripheral: ' + deviceUuid + ' !');
  525.   }
  526. });
  530. /**
  531.  * Write value
  532.  * @param  {String} deviceUuid
  533.  * @param  {String} serviceUuid
  534.  * @param  {String} characteristicUuid
  535.  * @param  {[Type]} data
  536.  * @param  {Bool} withoutResponse
  537.  *
  538.  * @discussion tested
  539.  */
  540. nobleBindings.write = function(deviceUuid, serviceUuid, characteristicUuid, data, withoutResponse) {
  541.   this.sendCBMsg(66, {
  542.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  543.     kCBMsgArgCharacteristicHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].handle,
  544.     kCBMsgArgCharacteristicValueHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].valueHandle,
  545.     kCBMsgArgData: data,
  546.     kCBMsgArgType: (withoutResponse ? 1 : 0)
  547.   });
  549.   if (withoutResponse) {
  550.     this.emit('write', deviceUuid, serviceUuid, characteristicUuid);
  551.   }
  552. };
  554. /**
  555.  * Response to write
  556.  *
  557.  * @discussion tested
  558.  */
  559. nobleBindings.on('kCBMsgId72', function(args) {
  560.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  561.   var characteristicHandle = args.kCBMsgArgCharacteristicHandle;
  562.   var result = args.kCBMsgArgResult;
  564.   for(var i in this._peripherals[deviceUuid].services) {
  565.     if (this._peripherals[deviceUuid].services[i].characteristics &&
  566.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle]) {
  567.       this.emit('write', deviceUuid, this._peripherals[deviceUuid].services[i].uuid,
  568.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle].uuid);
  569.       break;
  570.     }
  571.   }
  572. });
  576. /**
  577.  * Broadcast
  578.  *
  579.  * @param  {[type]} deviceUuid         [description]
  580.  * @param  {[type]} serviceUuid        [description]
  581.  * @param  {[type]} characteristicUuid [description]
  582.  * @param  {[type]} broadcast          [description]
  583.  * @return {[type]}                    [description]
  584.  *
  585.  * @discussion The ids were incemented but there seems to be no CoreBluetooth function to call/verify this.
  586.  */
  587. nobleBindings.broadcast = function(deviceUuid, serviceUuid, characteristicUuid, broadcast) {
  588.   this.sendCBMsg(67, {
  589.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  590.     kCBMsgArgCharacteristicHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].handle,
  591.     kCBMsgArgCharacteristicValueHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].valueHandle,
  592.     kCBMsgArgState: (broadcast ? 1 : 0)
  593.   });
  594. };
  596. /**
  597.  * Response to broadcast
  598.  *
  599.  * @discussion The ids were incemented but there seems to be no CoreBluetooth function to call/verify this.
  600.  */
  601. nobleBindings.on('kCBMsgId73', function(args) {
  602.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  603.   var characteristicHandle = args.kCBMsgArgCharacteristicHandle;
  604.   var result = args.kCBMsgArgResult;
  605.   var state = args.kCBMsgArgState ? true : false;
  607.   for(var i in this._peripherals[deviceUuid].services) {
  608.     if (this._peripherals[deviceUuid].services[i].characteristics &&
  609.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle]) {
  610.       this.emit('broadcast', deviceUuid, this._peripherals[deviceUuid].services[i].uuid,
  611.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle].uuid, state);
  612.       break;
  613.     }
  614.   }
  615. });
  619. /**
  620.  * Register notification hanlder
  621.  *
  622.  * @param  {String} deviceUuid            Peripheral UUID
  623.  * @param  {String} serviceUuid           Service UUID
  624.  * @param  {String} characteristicUuid    Charactereistic UUID
  625.  * @param  {Bool}   notify                If want to get notification
  626.  *
  627.  * @discussion tested
  628.  */
  629. nobleBindings.notify = function(deviceUuid, serviceUuid, characteristicUuid, notify) {
  630.   this.sendCBMsg(68, {
  631.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  632.     kCBMsgArgCharacteristicHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].handle,
  633.     kCBMsgArgCharacteristicValueHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].valueHandle,
  634.     kCBMsgArgState: (notify ? 1 : 0)
  635.   });
  636. };
  638. /**
  639.  * Response notification
  640.  *
  641.  * @discussion tested
  642.  */
  643. nobleBindings.on('kCBMsgId74', function(args) {
  644.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  645.   var characteristicHandle = args.kCBMsgArgCharacteristicHandle;
  646.   var result = args.kCBMsgArgResult;
  647.   var state = args.kCBMsgArgState ? true : false;
  649.   for(var i in this._peripherals[deviceUuid].services) {
  650.     if (this._peripherals[deviceUuid].services[i].characteristics &&
  651.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle]) {
  652.       this.emit('notify', deviceUuid, this._peripherals[deviceUuid].services[i].uuid,
  653.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle].uuid, state);
  654.       break;
  655.     }
  656.   }
  657. });
  661. /**
  662.  * Discover service descriptors
  663.  *
  664.  * @param  {String} deviceUuid
  665.  * @param  {String} serviceUuid
  666.  * @param  {String} characteristicUuid
  667.  *
  668.  * @discussion tested
  669.  */
  670. nobleBindings.discoverDescriptors = function(deviceUuid, serviceUuid, characteristicUuid) {
  671.   this.sendCBMsg(70, {
  672.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  673.     kCBMsgArgCharacteristicHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].handle,
  674.     kCBMsgArgCharacteristicValueHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].valueHandle
  675.   });
  676. };
  678. /**
  679.  * Response to descriptor discovery
  680.  *
  681.  * @discussion tested
  682.  */
  683. nobleBindings.on('kCBMsgId76', function(args) {
  684.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  685.   var characteristicHandle = args.kCBMsgArgCharacteristicHandle;
  686.   var result = args.kCBMsgArgResult;
  687.   var descriptors = []; //args.kCBMsgArgDescriptors;
  689.   for(var i in this._peripherals[deviceUuid].services) {
  690.     if (this._peripherals[deviceUuid].services[i].characteristics &&
  691.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle]) {
  693.       this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle].descriptors = {};
  695.       for(var j = 0; j < args.kCBMsgArgDescriptors.length; j++) {
  696.         var descriptor = {
  697.           uuid: args.kCBMsgArgDescriptors[j].kCBMsgArgUUID.toString('hex'),
  698.           handle: args.kCBMsgArgDescriptors[j].kCBMsgArgDescriptorHandle
  699.         };
  701.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle].descriptors[descriptor.uuid] =
  702.           this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle].descriptors[descriptor.handle] = descriptor;
  704.         descriptors.push(descriptor.uuid);
  705.       }
  707.       this.emit('descriptorsDiscover', deviceUuid, this._peripherals[deviceUuid].services[i].uuid,
  708.         this._peripherals[deviceUuid].services[i].characteristics[characteristicHandle].uuid, descriptors);
  709.       break;
  710.     }
  711.   }
  712. });
  716. /**
  717.  * Read value
  718.  *
  719.  * @param  {[type]} deviceUuid         [description]
  720.  * @param  {[type]} serviceUuid        [description]
  721.  * @param  {[type]} characteristicUuid [description]
  722.  * @param  {[type]} descriptorUuid     [description]
  723.  *
  724.  * @discussion tested
  725.  */
  726. nobleBindings.readValue = function(deviceUuid, serviceUuid, characteristicUuid, descriptorUuid) {
  727.   this.sendCBMsg(77, {
  728.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  729.     kCBMsgArgDescriptorHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].descriptors[descriptorUuid].handle
  730.   });
  731. };
  733. /**
  734.  * Response to read value
  735.  *
  736.  * @discussion tested
  737.  */
  738. nobleBindings.on('kCBMsgId79', function(args) {
  739.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  740.   var descriptorHandle = args.kCBMsgArgDescriptorHandle;
  741.   var result = args.kCBMsgArgResult;
  742.   var data = args.kCBMsgArgData;
  744.   this.emit('handleRead', deviceUuid, descriptorHandle, data);
  746.   for(var i in this._peripherals[deviceUuid].services) {
  747.     for(var j in this._peripherals[deviceUuid].services[i].characteristics) {
  748.       if (this._peripherals[deviceUuid].services[i].characteristics[j].descriptors &&
  749.         this._peripherals[deviceUuid].services[i].characteristics[j].descriptors[descriptorHandle]) {
  751.         this.emit('valueRead', deviceUuid, this._peripherals[deviceUuid].services[i].uuid,
  752.           this._peripherals[deviceUuid].services[i].characteristics[j].uuid,
  753.           this._peripherals[deviceUuid].services[i].characteristics[j].descriptors[descriptorHandle].uuid, data);
  754.         return; // break;
  755.       }
  756.     }
  757.   }
  758. });
  762. /**
  763.  * Write value
  764.  *
  765.  * @param  {[type]} deviceUuid         [description]
  766.  * @param  {[type]} serviceUuid        [description]
  767.  * @param  {[type]} characteristicUuid [description]
  768.  * @param  {[type]} descriptorUuid     [description]
  769.  * @param  {[type]} data               [description]
  770.  *
  771.  * @discussion tested
  772.  */
  773. nobleBindings.writeValue = function(deviceUuid, serviceUuid, characteristicUuid, descriptorUuid, data) {
  774.   this.sendCBMsg(78, {
  775.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  776.     kCBMsgArgDescriptorHandle: this._peripherals[deviceUuid].services[serviceUuid].characteristics[characteristicUuid].descriptors[descriptorUuid].handle,
  777.     kCBMsgArgData: data
  778.   });
  779. };
  781. /**
  782.  * Response to write value
  783.  *
  784.  * @discussion tested
  785.  */
  786. nobleBindings.on('kCBMsgId80', function(args) {
  787.   var deviceUuid = args.kCBMsgArgDeviceUUID.toString('hex');
  788.   var descriptorHandle = args.kCBMsgArgDescriptorHandle;
  789.   var result = args.kCBMsgArgResult;
  791.   this.emit('handleWrite', deviceUuid, descriptorHandle);
  793.   for(var i in this._peripherals[deviceUuid].services) {
  794.     for(var j in this._peripherals[deviceUuid].services[i].characteristics) {
  795.       if (this._peripherals[deviceUuid].services[i].characteristics[j].descriptors &&
  796.         this._peripherals[deviceUuid].services[i].characteristics[j].descriptors[descriptorHandle]) {
  798.         this.emit('valueWrite', deviceUuid, this._peripherals[deviceUuid].services[i].uuid,
  799.           this._peripherals[deviceUuid].services[i].characteristics[j].uuid,
  800.           this._peripherals[deviceUuid].services[i].characteristics[j].descriptors[descriptorHandle].uuid);
  801.         return; // break;
  802.       }
  803.     }
  804.   }
  805. });
  809. /**
  810.  * Reade value directly from handle
  811.  *
  812.  * @param  {[type]} deviceUuid [description]
  813.  * @param  {[type]} handle     [description]
  814.  *
  815.  * @discussion tested
  816.  */
  817. nobleBindings.readHandle = function(deviceUuid, handle) {
  818.   this.sendCBMsg(77, {
  819.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  820.     kCBMsgArgDescriptorHandle: handle
  821.   });
  822. };
  826. /**
  827.  * Write value directly to handle
  828.  *
  829.  * @param  {[type]} deviceUuid      [description]
  830.  * @param  {[type]} handle          [description]
  831.  * @param  {[type]} data            [description]
  832.  * @param  {[type]} withoutResponse [description]
  833.  *
  834.  * @discussion tested
  835.  */
  836. nobleBindings.writeHandle = function(deviceUuid, handle, data, withoutResponse) {
  837.   // TODO: use without response
  838.   this.sendCBMsg(78, {
  839.     kCBMsgArgDeviceUUID: this._peripherals[deviceUuid].uuid,
  840.     kCBMsgArgDescriptorHandle: handle,
  841.     kCBMsgArgData: data
  842.   });
  843. };
  846. // Exports
  847. nobleBindings.setupXpcConnection();
  848. nobleBindings.init();
  849. module.exports = nobleBindings;