bluetest/lib/index.js

/**
 *
 * User: Martin Donnelly
 * Date: 2016-07-06
 * Time: 13:37
 *
 */

var cp = require('child_process');
var spawn = cp.spawn;
var fork = cp.fork;

var EventEmitter = require('events');
var busEmitter = new EventEmitter();

var util = require('util');

var logger = require('log4js').getLogger();

var bluetest = module.exports = function(options) {
  'use strict';

  var core = {
    mac:''
  };




  core.connectGatt = function() {
    logger.info('trying to connect using gatttool');
    var gatt = spawn('gatttool',['-I']);
    var cStr;
    gatt.on('error', function(err) {
      logger.error(err);
    });
    gatt.on('exit', function(code) {

      logger.debug('gatt exit code', code);
    });

    gatt.on('message', function(m) {
      logger.info(m);
    });


    gatt.stdout.on('data', (data) => {
      logger.info(`stdout: ${data}`);
    });

    gatt.stderr.on('data', (data) => {
      logger.info(`stderr: ${data}`);
    });

    gatt.on('close', (code) => {
      logger.warn(`child process exited with code ${code}`);
    });



    logger.info('Trying to connect to ', core.mac);
    cStr = 'connect ' + core.mac + '\n';
    gatt.stdin.write(cStr);

  };

  core.init = function(options) {


    var tool_path = '';
    var hcidev = 'hvi0';

    //If ()
    if (typeof options.mac !== 'undefined') {
      core.mac = options.mac;
    } else {
      console.log('You need to pass a mac address.');
      process.exit(1);
    }
    logger.info('Working with:' , options);


    var hciconfig = spawn(tool_path + 'hciconfig', [hcidev, 'up']);

    hciconfig.on('exit', function(code) {

      logger.debug('code',code);


      if (code !== 0) {

        // Could not get the device UP, maybe due to permissions, should run with sudo.
        busEmitter.emit('error','hciconfig: failed to bring up device ' + hcidev + '. Try running with sudo.');
        return;

      } else {

        core.connectGatt();

      }


    });

  };


  core.init(options);
};
util.inherits(bluetest, EventEmitter);