Awesome

OpenBCI Node.js Ganglion SDK

A Node.js module for OpenBCI.

We are proud to support all functionality of the Ganglion (4 channel).

The purpose of this module is to get connected and start streaming as fast as possible.

Table of Contents:

1. TL;DR
2. Prerequisites
3. Installation
4. Ganglion
5. General Overview
6. SDK Reference Guide
   • Events
7. Interfacing With Other Tools
8. Developing
9. Testing
10. Contribute
11. License
12. Roadmap

<a name="tldr"></a> TL;DR:

Get connected and start streaming right now

const Ganglion = require("@openbci/ganglion");
const ganglion = new Ganglion();
ganglion.once("ganglionFound", peripheral => {
  // Stop searching for BLE devices once a ganglion is found.
  ganglion.searchStop();
  ganglion.on("sample", sample => {
    /** Work with sample */
    console.log(sample.sampleNumber);
    for (let i = 0; i < ganglion.numberOfChannels(); i++) {
      console.log(
        "Channel " +
          (i + 1) +
          ": " +
          sample.channelData[i].toFixed(8) +
          " Volts."
      );
    }
  });
  ganglion.once("ready", () => {
    ganglion.streamStart();
  });
  ganglion.connect(peripheral);
});
// Start scanning for BLE devices
ganglion.searchStart();

<a name="prerequisites"></a> Prerequisites:

Please ensure Python 2.7 is installed for all OS.

macOS

• install Xcode

Linux

• Kernel version 3.6 or above
• libbluetooth-dev
• libudev-dev

Running without sudo

In order to stream data on Linux without root/sudo access, you may need to give the node binary privileges to start and stop BLE advertising.

sudo setcap cap_net_raw+eip $(eval readlink -f `which node`)

Note: this command requires setcap to be installed. Install it with the libcap2-bin package.

sudo apt-get install libcap2-bin

Windows 8+

• node-gyp requirements for Windows
  • Python 2.7
  • Visual Studio (Express)
• node-bluetooth-hci-socket prerequisites
  • Compatible Bluetooth 4.0 USB adapter
  • WinUSB driver setup for Bluetooth 4.0 USB adapter, using Zadig tool

See @don's set up guide on Bluetooth LE with Node.js and Noble on Windows.

<a name="install"></a> Installation:

Install from npm:

npm install @openbci/ganglion

<a name="about"></a> About:

The Ganglion driver used by OpenBCI's Processing GUI and Electron Hub.

Check out the automatic tests written for it!

<a name="general-overview"></a> General Overview:

Initialization

Initializing the board:

const Ganglion = require("@openbci/ganglion");
const ganglion = new Ganglion();

For initializing with options, such as verbose print outs:

const Ganglion = require("@openbci/ganglion");
const ourBoard = new Ganglion({
  verbose: true
});

For initializing with callback, such as to catch errors on noble startup:

const Ganglion = require("@openbci/ganglion");
const ourBoard = new Ganglion(error => {
  if (error) {
    console.log("error", error);
  } else {
    console.log("no error");
  }
});

For initializing with options and callback, such as verbose and to catch errors on noble startup:

const Ganglion = require("@openbci/ganglion");
const ourBoard = new Ganglion(
  {
    verbose: true
  },
  error => {
    if (error) {
      console.log("error", error);
    } else {
      console.log("no error");
    }
  }
);

'ready' event

You MUST wait for the 'ready' event to be emitted before streaming/talking with the board. The ready happens asynchronously so installing the 'sample' listener and writing before the ready event might result in... nothing at all.

const Ganglion = require("@openbci/ganglion");
const ourBoard = new Ganglion();
ourBoard
  .connect(portName)
  .then(function(boardSerial) {
    ourBoard.on("ready", function() {
      /** Start streaming, reading registers, what ever your heart desires  */
    });
  })
  .catch(function(err) {
    /** Handle connection errors */
  });

Sample properties:

• sampleNumber (a Number between 0-255)
• channelData (channel data indexed at 0 filled with floating point Numbers in Volts)
• accelData (Array with X, Y, Z accelerometer values when new data available)
• timeStamp (Number the boardTime plus the NTP calculated offset)

The power of this module is in using the sample emitter, to be provided with samples to do with as you wish.

To get a 'sample' event, you need to:

1. Call .connect(localName | peripheral)
2. Install the 'ready' event emitter on resolved promise
3. In callback for 'ready' emitter, call streamStart()
4. Install the 'sample' event emitter

const Ganglion = require("@openbci/ganglion");
const ourBoard = new Ganglion();
ourBoard
  .connect(localName)
  .then(function() {
    ourBoard.on("ready", function() {
      ourBoard.streamStart();
      ourBoard.on("sample", function(sample) {
        /** Work with sample */
      });
    });
  })
  .catch(function(err) {
    /** Handle connection errors */
  });

Close the connection with .streamStop() and disconnect with .disconnect()

const Ganglion = require("@openbci/ganglion");
const ourBoard = new Ganglion();
ourBoard.streamStop().then(ourBoard.disconnect());

See Reference Guide for a complete list of impedance tests.

<a name="sdk-reference-guide"></a> SDK Reference Guide:

Classes

Typedefs

<a name="Ganglion"></a>

Ganglion

Kind: global class
Author: AJ Keller (@pushtheworldllc)

• Ganglion
  • new Ganglion(options, callback)
  • instance
    • .options : <code>InitializationObject</code>
    • ._accelArray
    • ._bled112WriteCharacteristic : <code>BLED112FindInformationFound</code>
    • .buffer
    • .accelStart() ⇒ <code>Promise</code>
    • .accelStop() ⇒ <code>Promise</code>
    • .autoReconnect()
    • .channelOff(channelNumber) ⇒ <code>Promise.<T></code>
    • .channelOn(channelNumber) ⇒ <code>Promise.<T></code> | <code>*</code>
    • .cleanupEmitters()
    • .connect(id) ⇒ <code>Promise</code>
    • .destroyNoble()
    • .destroyBLED112()
    • .destroyMultiPacketBuffer()
    • .disconnect(stopStreaming) ⇒ <code>Promise</code>
    • .getLocalName() ⇒ <code>null</code> | <code>String</code>
    • .getMutliPacketBuffer() ⇒ <code>null</code> | <code>Buffer</code>
    • .impedanceStart() ⇒ <code>global.Promise</code> | <code>Promise</code>
    • .impedanceStop() ⇒ <code>global.Promise</code> | <code>Promise</code>
    • .initDriver() ⇒ <code>Promise.<any></code>
    • .isConnected() ⇒ <code>boolean</code>
    • .isNobleReady() ⇒ <code>boolean</code>
    • .isSearching() ⇒ <code>boolean</code>
    • .isStreaming() ⇒ <code>boolean</code>
    • .numberOfChannels() ⇒ <code>Number</code>
    • .printRegisterSettings() ⇒ <code>Promise.<T></code> | <code>*</code>
    • .sampleRate() ⇒ <code>Number</code>
    • .searchStart(`maxSearchTime`) ⇒ <code>Promise</code>
    • .searchStop() ⇒ <code>global.Promise</code> | <code>Promise</code>
    • .softReset() ⇒ <code>Promise</code>
    • .streamStart() ⇒ <code>Promise</code>
    • .streamStop() ⇒ <code>Promise</code>
    • .syntheticEnable() ⇒ <code>Promise</code>
    • .syntheticDisable() ⇒ <code>Promise</code>
    • .write(data) ⇒ <code>Promise</code>
    • ._bled112WriteAndDrain(data) ⇒ <code>Promise</code>
  • inner
    • ~o

<a name="new_Ganglion_new"></a>

new Ganglion(options, callback)

The initialization method to call first, before any other method.

<a name="Ganglion+options"></a>

ganglion.options : <code>InitializationObject</code>

Kind: instance property of <code>Ganglion</code>
<a name="Ganglion+_accelArray"></a>

ganglion._accelArray

Private Properties (keep alphabetical)

Kind: instance property of <code>Ganglion</code>
<a name="Ganglion+_bled112WriteCharacteristic"></a>

ganglion._bled112WriteCharacteristic : <code>BLED112FindInformationFound</code>

Kind: instance property of <code>Ganglion</code>
<a name="Ganglion+buffer"></a>

ganglion.buffer

Public Properties (keep alphabetical)

Kind: instance property of <code>Ganglion</code>
<a name="Ganglion+accelStart"></a>

ganglion.accelStart() ⇒ <code>Promise</code>

Used to enable the accelerometer. Will result in accelerometer packets arriving 10 times a second. Note that the accelerometer is enabled by default.

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+accelStop"></a>

ganglion.accelStop() ⇒ <code>Promise</code>

Used to disable the accelerometer. Prevents accelerometer data packets from arriving.

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+autoReconnect"></a>

ganglion.autoReconnect()

Used to start a scan if power is on. Useful if a connection is dropped.

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+channelOff"></a>

ganglion.channelOff(channelNumber) ⇒ <code>Promise.<T></code>

Send a command to the board to turn a specified channel off

Kind: instance method of <code>Ganglion</code>
Author: AJ Keller (@pushtheworldllc)

<a name="Ganglion+channelOn"></a>

ganglion.channelOn(channelNumber) ⇒ <code>Promise.<T></code> | <code>*</code>

Send a command to the board to turn a specified channel on

Kind: instance method of <code>Ganglion</code>
Author: AJ Keller (@pushtheworldllc)

<a name="Ganglion+cleanupEmitters"></a>

ganglion.cleanupEmitters()

Used to clean up emitters

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+connect"></a>

ganglion.connect(id) ⇒ <code>Promise</code>

The essential precursor method to be called initially to establish a ble connection to the OpenBCI ganglion board.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - If the board was able to connect.
Author: AJ Keller (@pushtheworldllc)

<a name="Ganglion+destroyNoble"></a>

ganglion.destroyNoble()

Destroys the noble!

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+destroyBLED112"></a>

ganglion.destroyBLED112()

Destroys the noble!

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+destroyMultiPacketBuffer"></a>

ganglion.destroyMultiPacketBuffer()

Destroys the multi packet buffer.

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+disconnect"></a>

ganglion.disconnect(stopStreaming) ⇒ <code>Promise</code>

Closes the connection to the board. Waits for stop streaming command to be sent if currently streaming.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - - fulfilled by a successful close, rejected otherwise.
Author: AJ Keller (@pushtheworldllc)

<a name="Ganglion+getLocalName"></a>

ganglion.getLocalName() ⇒ <code>null</code> | <code>String</code>

Return the local name of the attached Ganglion device.

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+getMutliPacketBuffer"></a>

ganglion.getMutliPacketBuffer() ⇒ <code>null</code> | <code>Buffer</code>

Get's the multi packet buffer.

Kind: instance method of <code>Ganglion</code>
Returns: <code>null</code> | <code>Buffer</code> - - Can be null if no multi packets received.
<a name="Ganglion+impedanceStart"></a>

ganglion.impedanceStart() ⇒ <code>global.Promise</code> | <code>Promise</code>

Call to start testing impedance.

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+impedanceStop"></a>

ganglion.impedanceStop() ⇒ <code>global.Promise</code> | <code>Promise</code>

Call to stop testing impedance.

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+initDriver"></a>

ganglion.initDriver() ⇒ <code>Promise.<any></code>

Initialize the drivers

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+isConnected"></a>

ganglion.isConnected() ⇒ <code>boolean</code>

Checks if the driver is connected to a board.

Kind: instance method of <code>Ganglion</code>
Returns: <code>boolean</code> - - True if connected.
<a name="Ganglion+isNobleReady"></a>

ganglion.isNobleReady() ⇒ <code>boolean</code>

Checks if bluetooth is powered on.

Kind: instance method of <code>Ganglion</code>
Returns: <code>boolean</code> - - True if bluetooth is powered on.
<a name="Ganglion+isSearching"></a>

ganglion.isSearching() ⇒ <code>boolean</code>

Checks if noble is currently scanning.

Kind: instance method of <code>Ganglion</code>
Returns: <code>boolean</code> - - True if streaming.
<a name="Ganglion+isStreaming"></a>

ganglion.isStreaming() ⇒ <code>boolean</code>

Checks if the board is currently sending samples.

Kind: instance method of <code>Ganglion</code>
Returns: <code>boolean</code> - - True if streaming.
<a name="Ganglion+numberOfChannels"></a>

ganglion.numberOfChannels() ⇒ <code>Number</code>

This function is used as a convenience method to determine how many channels the current board is using.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Number</code> - A number Note: This is dependent on if you configured the board correctly on setup options
Author: AJ Keller (@pushtheworldllc)
<a name="Ganglion+printRegisterSettings"></a>

ganglion.printRegisterSettings() ⇒ <code>Promise.<T></code> | <code>*</code>

To print out the register settings to the console

Kind: instance method of <code>Ganglion</code>
Author: AJ Keller (@pushtheworldllc)
<a name="Ganglion+sampleRate"></a>

ganglion.sampleRate() ⇒ <code>Number</code>

Get the the current sample rate is.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Number</code> - The sample rate Note: This is dependent on if you configured the board correctly on setup options
<a name="Ganglion+searchStart"></a>

ganglion.searchStart(`maxSearchTime`) ⇒ <code>Promise</code>

List available peripherals so the user can choose a device when not automatically found.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - - If scan was started

<a name="Ganglion+searchStop"></a>

ganglion.searchStop() ⇒ <code>global.Promise</code> | <code>Promise</code>

Called to end a search.

Kind: instance method of <code>Ganglion</code>
<a name="Ganglion+softReset"></a>

ganglion.softReset() ⇒ <code>Promise</code>

Sends a soft reset command to the board

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - - Fulfilled if the command was sent to board.
Author: AJ Keller (@pushtheworldllc)
<a name="Ganglion+streamStart"></a>

ganglion.streamStart() ⇒ <code>Promise</code>

Sends a start streaming command to the board.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - indicating if the signal was able to be sent. Note: You must have successfully connected to an OpenBCI board using the connect method. Just because the signal was able to be sent to the board, does not mean the board will start streaming.
Author: AJ Keller (@pushtheworldllc)
<a name="Ganglion+streamStop"></a>

ganglion.streamStop() ⇒ <code>Promise</code>

Sends a stop streaming command to the board.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - indicating if the signal was able to be sent. Note: You must have successfully connected to an OpenBCI board using the connect method. Just because the signal was able to be sent to the board, does not mean the board stopped streaming.
Author: AJ Keller (@pushtheworldllc)
<a name="Ganglion+syntheticEnable"></a>

ganglion.syntheticEnable() ⇒ <code>Promise</code>

Puts the board in synthetic data generation mode. Must call streamStart still.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - indicating if the signal was able to be sent.
Author: AJ Keller (@pushtheworldllc)
<a name="Ganglion+syntheticDisable"></a>

ganglion.syntheticDisable() ⇒ <code>Promise</code>

Takes the board out of synthetic data generation mode. Must call streamStart still.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - - fulfilled if the command was sent.
Author: AJ Keller (@pushtheworldllc)
<a name="Ganglion+write"></a>

ganglion.write(data) ⇒ <code>Promise</code>

Used to send data to the board.

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - - fulfilled if command was able to be sent
Author: AJ Keller (@pushtheworldllc)

Example

Sends a single character command to the board.

// ourBoard has fulfilled the promise on .connect() and 'ready' has been observed previously
ourBoard.write("a");

Sends an array of bytes

// ourBoard has fulfilled the promise on .connect() and 'ready' has been observed previously
ourBoard.write(["x", "0", "1", "0", "0", "0", "0", "0", "0", "X"]);

Call crazy? Go for it...

ourBoard.write("t");
ourBoard.write("a");
ourBoard.write("c");
ourBoard.write("o");

<a name="Ganglion+_bled112WriteAndDrain"></a>

ganglion._bled112WriteAndDrain(data) ⇒ <code>Promise</code>

Should be used to send data to the board

Kind: instance method of <code>Ganglion</code>
Returns: <code>Promise</code> - if signal was able to be sent
Author: AJ Keller (@pushtheworldllc)

<a name="Ganglion..o"></a>

Ganglion~o

Configuring Options

Kind: inner property of <code>Ganglion</code>
<a name="kOBCIBLED112ParsingConnectDirect"></a>

kOBCIBLED112ParsingConnectDirect

Used in parsing incoming serial data

Kind: global constant
<a name="InitializationObject"></a>

InitializationObject : <code>Object</code>

Board optional configurations.

Kind: global typedef
Properties

<a name="BLED112AttributeValue"></a>

BLED112AttributeValue : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112AttributeWrite"></a>

BLED112AttributeWrite : <code>Object</code>

Kind: global typedef
Properties

<a name="BLEDConnection"></a>

BLEDConnection : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112FindInformationFound"></a>

BLED112FindInformationFound : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112GapConnectDirect"></a>

BLED112GapConnectDirect : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112GroupService"></a>

BLED112GroupService : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112ParseRawAttributeValue"></a>

BLED112ParseRawAttributeValue : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112ParseRawHeadTail"></a>

BLED112ParseRawHeadTail : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112ParseRawWord"></a>

BLED112ParseRawWord : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112Peripheral"></a>

BLED112Peripheral : <code>Object</code>

Kind: global typedef
Properties

<a name="BLED112RspGroupType"></a>

BLED112RspGroupType : <code>Object</code>

Kind: global typedef
Properties

<a name="event"></a> Events:

<a name="event-accelerometer"></a> .on('accelerometer', callback)

Emitted when the module receives accelerometer data.

Returns an object with properties:

accelData {Array}

Array of floats for each dimension in g's.

NOTE: Only present if sendCounts is true.

accelDataCounts {Array}

Array of integers for each dimension in counts.

NOTE: Only present if sendCounts is false.

Example (if sendCounts is false):

{
  "accelData": [0.0, 0.0, 0.0, 0.0]
}

Example (if sendCounts is true):

{
  "accelDataCounts": [0, 0, 0, 0]
}

<a name="event-dropped-packet"></a> .on('droppedPacket', callback)

Emitted when a packet (or packets) are dropped. Returns an array.

<a name="event-error"></a> .on('error', callback)

Emitted when there is an on the serial port.

<a name="event-impedance"></a> .on('impedance', callback)

Emitted when there is a new impedance available.

Returns an object with properties:

channelNumber {Number}

The channel number: 1, 2, 3, 4 respectively and 0 for reference.

impedanceValue {Number}

The impedance in ohms.

Example:

{
  "channelNumber": 0,
  "impedanceValue": 0
}

<a name="event-raw-data-packet"></a> .on('rawDataPacket', callback)

Emitted when there is a new raw data packet available.

<a name="event-ready"></a> .on('ready', callback)

Emitted when the board is in a ready to start streaming state.

<a name="event-sample"></a> .on('sample', callback)

Emitted when there is a new sample available.

Returns an object with properties:

channelData {Array}

Array of floats for each channel in volts..

NOTE: Only present if sendCounts is true.

channelDataCounts {Array}

Array of integers for each channel in counts.

NOTE: Only present if sendCounts is false.

sampleNumber {Number}

The sample number. Only goes up to 254.

timeStamp {Number}

The time the sample is packed up. Not accurate for ERP.

Example (if sendCounts is false):

{
  "channelData": [0.0, 0.0, 0.0, 0.0],
  "sampleNumber": 0,
  "timeStamp": 0
}

Example (if sendCounts is true):

{
  "channelDataCounts": [0, 0, 0, 0],
  "sampleNumber": 0,
  "timeStamp": 0
}

<a name="event-scan-start"></a> .on('scanStart', callback)

Emitted when a noble scan is started.

<a name="event-scan-stop"></a> .on('scanStop', callback)

Emitted when a noble scan is stopped.

<a name="interfacing-with-other-tools"></a> Interfacing With Other Tools:

<a name="interfacing-with-other-tools-labstreaminglayer"></a> LabStreamingLayer

LabStreamingLayer is a tool for streaming or recording time-series data. It can be used to interface with Matlab, Python, Unity, and many other programs.

To use LSL with the NodeJS SDK, go to our labstreaminglayer example, which contains code that is ready to start an LSL stream of OpenBCI data.

Follow the directions in the readme to get started.

<a name="developing"></a> Developing:

<a name="developing-running"></a> Running:

npm install

<a name="developing-testing"></a> Testing:

npm test

<a name="contribute"></a> Contribute:

1. Fork it!
2. Branch off of development: git checkout development
3. Create your feature branch: git checkout -b my-new-feature
4. Make changes
5. If adding a feature, please add test coverage.
6. Ensure tests all pass. (npm test)
7. Commit your changes: git commit -m 'Add some feature'
8. Push to the branch: git push origin my-new-feature
9. Submit a pull request. Make sure it is based off of the development branch when submitting! :D

<a name="license"></a> License:

MIT