Initial commit

Author: greguz

.gitignore

@@ -0,0 +1,3 @@
+node_modules
+.idea
+dump

dumper.js

@@ -0,0 +1,35 @@
+var socket  = require('./libs/socket')
+  , path    = require('path')
+  , fs      = require('fs');
+
+var folder = path.join(process.argv[2] || __dirname, 'dump');
+
+socket.on('error', function(err) {
+  console.log('ERROR', err);
+});
+
+socket.on('message', function(msg) {
+  var id    = new Date().getTime()
+    , file  = path.join(folder, id + '.readynas');
+
+  console.log('Writing ' + file + '...');
+
+  fs.writeFile(file, msg, function(err) {
+    if (err)  console.log('ERROR', err);
+    else      console.log('OK');
+  });
+});
+
+console.log('Creating folder ' + folder + '...');
+
+fs.mkdir(folder, function(err) {
+  if (err)
+    console.log('ERROR', err);
+  else
+    socket.sendMagic();
+});
+
+setTimeout(function() {
+  console.log('END');
+  process.exit();
+}, 10000);

index.js

@@ -0,0 +1,75 @@
+// #########################################################################
+// dependencies
+// #########################################################################
+
+var socket    = require('./libs/socket')
+  , ReadyNAS  = require('./libs/readynas')
+  , _         = require('lodash');
+
+
+
+// #########################################################################
+// module vars
+// #########################################################################
+
+var _events = {};
+
+
+
+// #########################################################################
+// utility functions
+// #########################################################################
+
+var notifyEvent = function() {
+  var args      = _.values(arguments)
+    , event     = args.shift()
+    , callback  = _events[event];
+
+  if (typeof callback !== 'function') return;
+
+  callback.apply(this, args);
+};
+
+
+
+// #########################################################################
+// socket settings
+// #########################################################################
+
+socket.on('error', function(err) {
+  notifyEvent('error', err);
+});
+
+socket.on('message', function(msg) {
+  try {
+    var device = new ReadyNAS(msg);
+
+    notifyEvent('device', device);
+    notifyEvent(device.ip, device);
+    notifyEvent(device.hostname, device);
+    notifyEvent(device.mac, device);
+  } catch(e) {
+    notifyEvent('error', e);
+  }
+});
+
+socket.open();
+
+
+
+// #########################################################################
+// functions
+// #########################################################################
+
+module.exports.options = function(options) {
+  socket.close();
+  socket.open(options);
+};
+
+module.exports.sendMagic = function(options, callback) {
+  socket.sendMagic();
+};
+
+module.exports.on = function(event, callback) {
+  _events[event] = callback;
+};

libs/readynas.js

@@ -0,0 +1,118 @@
+// #########################################################################
+// class definition
+// #########################################################################
+
+var ReadyNAS = function(buffer) {
+  if (!buffer instanceof Buffer) throw new Error('RAIDar buffer message required!');
+
+  this.buffer   = buffer;
+  this.message  = buffer.toString('utf8');
+
+  this.header   = null;
+
+  this.mac      = null;
+  this.hostname = null;
+  this.ip       = null;
+
+  this.info     = {};
+
+  this.initInfo();
+
+  return this;
+};
+
+
+
+// #########################################################################
+// private
+// #########################################################################
+
+ReadyNAS.prototype.initInfo = function() {
+  this.initHeaderInfo();
+  this.initBodyInfo();
+  this.initFooterInfo();
+};
+
+ReadyNAS.prototype.initHeaderInfo = function() {
+  this.header = this.message.substr(0, 28);
+
+  var self      = this
+    , firstLine = this.message.substring(28, this.message.indexOf('\n'))
+    , firstInfo = firstLine.split('\t')
+    , otherInfo = firstInfo.slice(3);
+
+  this.mac      = firstInfo[0];
+  this.hostname = firstInfo[1];
+  this.ip       = firstInfo[2];
+
+  otherInfo.forEach(function(info) {
+    self.parseInfo(info);
+  });
+};
+
+ReadyNAS.prototype.initBodyInfo = function() {
+  var self  = this
+    , lines = this.message.split('\n').slice(1);
+
+  lines.forEach(function(line) {
+    if (line[0] === '\t') return;
+    self.parseInfo(line);
+  });
+};
+
+ReadyNAS.prototype.initFooterInfo = function() {
+
+  // TODO write footer data initialization
+
+};
+
+ReadyNAS.prototype.parseInfo = function(str) {
+  var arr     = str.split('!!')
+    , name    = arr[0]
+    , info    = { _info : arr[1] };
+
+  if (!this.info[name]) this.info[name] = [];
+  if (!arr[2]) return this.info[name].push(info);
+
+  var otherInfo = arr[2].split('::');
+
+  otherInfo.forEach(function(str) {
+    var arr   = str.split('=')
+      , field = arr[0]
+      , value = arr[1];
+
+    if (value) {
+      info[field] = value;
+    } else {
+      info['_status'] = field;
+    }
+  });
+
+  return this.info[name].push(info);
+};
+
+
+
+// #########################################################################
+// public
+// #########################################################################
+
+ReadyNAS.prototype.toJSON = function(string) {
+  var res = {
+    message   : this.message,
+    mac       : this.mac,
+    hostname  : this.hostname,
+    ip        : this.ip,
+    info      : this.info
+  };
+
+  return string === true ? JSON.stringify(res) : res;
+};
+
+
+
+// #########################################################################
+// export
+// #########################################################################
+
+module.exports = ReadyNAS;

libs/socket.js

@@ -0,0 +1,87 @@
+// #########################################################################
+// dependencies
+// #########################################################################
+
+var dgram = require('dgram')
+  , _     = require('lodash');
+
+
+
+// #########################################################################
+// module vars
+// #########################################################################
+
+var exports   = {}
+  , _options  = null
+  , _socket   = null
+  , _events   = {};
+
+var _defaultOptions = {
+  socketType    : 'udp4',
+  portToListen  : 57877,
+  targetHost    : '255.255.255.255',
+  targetPort    : 22081,
+  magicPacket   : new Buffer('0000073e0000000100000000f8d496c3ffffffff0000001c00000000', 'hex')
+};
+
+
+
+// #########################################################################
+// utility functions
+// #########################################################################
+
+var notifyEvent = function() {
+  var args      = _.values(arguments)
+    , event     = args.shift()
+    , callback  = _events[event];
+
+  if (typeof callback !== 'function') return;
+
+  callback.apply(this, args);
+};
+
+var socketError = function(err) {
+  notifyEvent('error', err);
+};
+
+var socketMessage = function(msg) {
+  notifyEvent('message', msg);
+};
+
+
+
+// #########################################################################
+// exports
+// #########################################################################
+
+exports.open = function(options) {
+  _options = _.extend(_.clone(_defaultOptions), options);
+
+  _socket = dgram.createSocket(_options.socketType);
+
+  _socket.on('error', socketError);
+  _socket.on('message', socketMessage);
+
+  _socket.bind(_options.portToListen, function() {
+    _socket.setBroadcast(true);
+  });
+};
+
+exports.close = function() {
+  if (_socket) _socket.close();
+  _socket = null;
+};
+
+exports.on = function(event, callback) {
+  _events[event] = callback;
+};
+
+exports.sendMagic = function() {
+  if (!_socket) exports.open();
+
+  _socket.send(_options.magicPacket, 0, _options.magicPacket.length, _options.targetPort, _options.targetHost, function(err) {
+    if (err) notifyEvent('error', err);
+  });
+};
+
+module.exports = exports;

package.json

@@ -0,0 +1,15 @@
+{
+  "name": "raidar",
+  "version": "0.1.0",
+  "description": "NetGear RAIDar node.js implementation",
+  "main": "index.js",
+  "scripts": {
+    "test": "node test.js",
+    "dump": "node dumper.js $1"
+  },
+  "author": "Gregoletto Giacomo",
+  "license": "MIT",
+  "dependencies": {
+    "lodash": "^3.4.0"
+  }
+}

test.js

@@ -0,0 +1,18 @@
+var raidar = require('./index');
+
+console.log('Testing for 10 seconds...');
+
+raidar.on('error', function(err) {
+  console.log('ERROR', err);
+});
+
+raidar.on('device', function(device) {
+  console.log('Response from ' + device.ip + ' - ' + device.hostname + ' (' + device.mac + ')');
+});
+
+raidar.sendMagic();
+
+setTimeout(function() {
+  console.log('END');
+  process.exit();
+}, 10000);