xbee.js

const rx = require("rx");
const xbeeRx = require("xbee-rx");
const R = require("ramda");
const xbee_api = require("xbee-api");


const destinationId = '0013A20040B51A26';
const data = 'TIESTO';


module.exports = xbee = xbeeRx({
    serialport: "/dev/ttyUSB4",
    serialportOptions: {
        baudrate: 57600
    },
    module: "ZigBee",
    api_mode: 2,
    debug: false
});

console.log("Monitoring incoming packets (press CTRL-C to stop)");

var stdin = process.stdin;
stdin.setRawMode(true);

/**
 * define the sequence of data that is a Ctrl+C
 * we use this later to determine when to stop listening
 * to the serial port
 */
module.exports.ctrlCStream = rx.Observable.fromEvent(stdin, "data")
    .where(function monitorCtrlCOnData(data) {
        return data.length === 1 && data[0] === 0x03; // Ctrl+C
    })
    .take(1);

/**
 * configure a stream for handling HELLOs from controlpoints
 * the HELLO packet type is within type 144 (0x90) ZIGBEE_RECEIVE_PACKET
 */
 module.exports.helloStream = xbee
    .monitorTransmissions()
    .where(R.propEq("type", 144)) // ZIGBEE_RECEIVE_PACKET
    .pluck("data")
    .map(function (buffer) {
        var s = buffer.toString();
        return (s === "\r") ? "\n" : s;
    })
    .where(R.is(String))
    .where(R.equals('DCXHI'));



module.exports.errorCb = function (error) {
    console.log("Error during monitoring:\n", error);
    xbee.close();
    process.exit();
}


module.exports.exitCb = function () {
    console.log("\nGot CTRL-C; exiting.");
    xbee.close();
    process.exit();
}