Space Bunny is the IoT platform that makes it easy for you and your devices to send and exchange messages with a server or even with each other. You can store the data, receive timely event notifications, monitor live streams and remotely control your devices. Easy to use, and ready to scale at any time.

This is the source code repository for Node SDK. Please feel free to contribute!

Installation

npm install spacebunny --save

Basic usage

Device

Devices can publish messages on configured channels and receive messages on their inbox channel

AMQP publisher

In this example a device publishes a single message on the first configured channel

'use strict';varAmqpClient=require('spacebunny').AmqpClient;// Use your Api KeyvarconnectionParams={apiKey: 'your-api-key'};varamqpClient=newAmqpClient(connectionParams);varcontent={some: 'json'};varchannels=amqpClient.channels();amqpClient.publish(channels[0],content).then(function(res){console.log('Message published!');amqpClient.disconnect();process.exit(0);}).catch(function(reason){console.error(reason);process.exit(1);});

AMQP receiver

In this example a device waits for incoming messages on its inbox channel

'use strict';varAmqpClient=require('spacebunny').AmqpClient;// callback called whan a message is receivedvarmessageCallback=function(content,field,properties){console.log(content);};// Use your Api KeyvarconnectionParams={apiKey: 'your-api-key'};varamqpClient=newAmqpClient(connectionParams);amqpClient.onReceive(messageCallback).then(function(res){console.log('Start receiving..');}).catch(function(reason){console.error(reason);});

For more advanced usage please refer to example files in examples folder

Stream

A stream client can read from multiple live streams hooks

AMQP streamer

In this example the streamer receives all messages from stream my-stream and my-stream-2

'use strict';varAmqpStreamClient=require('spacebunny').AmqpStreamClient;// callback called when a message is receivedvarmessageCallback=function(content,field,properties){console.log(content);};// Use your client ID and secretvarconnectionParams={client: 'your-client-id',secret: 'your-secret'};varstreamClient=newAmqpStreamClient(connectionParams);// Use your stream namevarstreamHooks=[{stream: 'my-stream',callback: messageCallback},{stream: 'my-stream-2',callback: messageCallback}];streamClient.streamFrom(streamHooks).then(function(res){console.log(res);}).catch(function(reason){console.error(reason);});

For more advanced usage please refer to example files in examples folder

Usage within a web page (plain JS)

Space Bunny Node SDK is bundled using Webpack to allow the integration of the library within a web page

Device

STOMP receiver and publisher

In this example a device waits for incoming messages on its inbox channel and publishes a single message on the first configured channel

<scriptsrc="https://github.com/space-bunny/node-sdk/blob/master/lib/spacebunny.var.js"></script><script>[...]// Use your Api KeyvarconnectionParams={apiKey: 'your-api-key'};varwebStompClient=newStompClient(connectionParams);webStompClient.onReceive(messageCallback).then(function(res){console.log('Successfully connected!');}).catch(function(reason){console.error(reason);});varcontent={some: 'json'};varchannels=webStompClient.channels();webStompClient.publish(channels[0],content).then(function(res){console.log('Message published!');}).catch(function(reason){console.error(reason);});[...]</script>

For more advanced usage please refer to example files in public and examples folders

Stream

A stream client can read from multiple live streams hooks

STOMP streamer

In this example the streamer receives all messages from stream my-stream and my-stream-2

<scriptsrc="https://github.com/space-bunny/node-sdk/blob/master/lib/spacebunny.var.js"></script><script>[...]varconnectionParams={client: 'your-client-id',secret: 'your-secret'};varstreamClient=newStompStreamClient(connectionParams);// Use your stream namevarstreamHooks=[{stream: 'my-stream',callback: messageCallback},{stream: 'my-stream-2',callback: messageCallback}];streamClient.streamFrom(streamHooks).then(function(res){console.log(res);}).catch(function(reason){console.error(reason);});[...]</script>

For more advanced usage please refer to example files in public and examples folders

Run NODE examples

Examples cover device and stream scenarios:

AMQP

npm run start:node-sample examples/device/amqp/receiver.js -- --deviceKey=my-device-key
npm run start:node-sample examples/device/amqp/publisher.js -- --deviceKey=my-device-key --channel=data
npm run start:node-sample examples/stream/amqp/streamer.js -- --client=client-id --secret=secret
--stream=data --stream=alarms

MQTT

npm run start:node-sample examples/device/mqtt/receiver.js -- --deviceKey=my-device-key
npm run start:node-sample examples/device/mqtt/publisher.js -- --deviceKey=my-device-key --channel=data
npm run start:node-sample examples/stream/mqtt/streamer.js -- --client=client-id --secret=secret
--stream=data --stream=alarms

STOMP

npm run start:node-sample examples/device/stomp/receiver.js -- --deviceKey=my-device-key
npm run start:node-sample examples/device/stomp/publisher.js -- --deviceKey=my-device-key --channel=data
npm run start:node-sample examples/stream/stomp/streamer.js -- --client=client-id --secret=secret
--stream=data --stream=alarms

For more advanced usage please refer to example files in public and examples folders

Run HTML examples

npm run start:samples

Examples will be available on port 8080

Build dist version

npm run build

Generate documentation

npm run docs

License

The library is available as open source under the terms of the MIT License.