Add rrd info

.gitignore

@@ -0,0 +1 @@
+node_modules

package.json

@@ -10,4 +10,8 @@
       "type" : "git"
     , "url" : "https://github.com/plainlystated/coffeescript-rrd"
   }
+  , "devDependencies" : {
+      "coffee-script": "~> 1.1.2"
+    , "vows":          "~> 0.5.3"
+  }
 }

rrd.coffee

@@ -4,6 +4,7 @@ spawn = require('child_process').spawn
 fs = require('fs')
 
 RRDRecord = require('./rrdRecord').RRDRecord
+RRDInfo   = require('./rrdInfo').RRDInfo
 
 class RRD
   constructor: (@filename) ->
@@ -74,6 +75,10 @@ class RRD
 
       cb(undefined, records)
 
+  info: (cb) ->
+    @rrdSpawn "info", [], (err, results) ->
+      return cb(null, new RRDInfo(results))
+
   _rrdTime = (date) ->
     return Math.round(date.valueOf() / 1000)
 

rrdInfo.coffee

@@ -0,0 +1,30 @@
+class RRDInfo
+  constructor: (raw_output) ->
+    this.parse_line(line) for line in raw_output.split('\n')
+
+  ds_names: () ->
+    keys = []
+    keys.push(k) for k of this['ds']
+    return keys
+
+  parse_line: (line) ->
+    line = line.replace(/["\s]/g, '')
+    return if line == ''
+
+    [key, value] = line.split('=')
+
+    key_tree = if key.match  /[\.\[]/
+      key.replace(/\[/g, '.').replace(/[\]\s]/g, '').split('.')
+    else
+      [key]
+
+    _add_value(key_tree, value, this)
+
+  _add_value =  (key_tree, value, obj) ->
+    return obj[key_tree[0]] = value if key_tree.length == 1
+    new_key = key_tree.shift()
+    obj[new_key] ?= new Object
+
+    return _add_value(key_tree, value, obj[new_key])
+
+exports.RRDInfo = RRDInfo

test/info-test.coffee

@@ -0,0 +1,21 @@
+vows = require('vows')
+assert = require('assert')
+RRDInfo = require('../rrdInfo').RRDInfo
+valid_contents = require('fs').readFileSync('./valid.info').toString()
+
+vows.describe('RRDInfo').addBatch(
+  'from a valid rrd file':
+    topic: new RRDInfo(valid_contents)
+
+    'should have the filename set': (topic) ->
+      assert.equal(topic.filename, 'valid.rrd')
+
+    'should parse multi level lines': (topic) ->
+      assert.equal(topic.ds.state.last_ds, 0)
+
+    'should list the ds_names': (topic) ->
+      assert.include(topic.ds_names(), 'temperature')
+      assert.include(topic.ds_names(), 'target_temp')
+      assert.include(topic.ds_names(), 'state')
+
+).export(module, {error: false})

test/rrd-test.coffee

@@ -1,6 +1,7 @@
 vows = require('vows')
 assert = require('assert')
 RRD = require('../rrd').RRD
+RRDInfo = require('../rrdInfo').RRDInfo
 exec = require('child_process').exec
 
 vows.describe('RRD').addBatch(
@@ -99,6 +100,17 @@ vows.describe('RRD').addBatch(
       # Need to figure out how to test this without messing up subsequent test runs
       # 'returns no error': (err) ->
       #   assert.equal(err, undefined)
+    'when infoing':
+      topic: (rrd) ->
+        rrd.info(@callback)
+        return
+
+      'returns no error': (err, data) ->
+        assert.equal(err, null)
+
+      'returns an RRDInfo object': (err, data) ->
+        assert.instanceOf(data, RRDInfo)      
+
   'when restoring':
     'a valid file':
       topic: () ->

test/valid.info

@@ -0,0 +1,73 @@
+filename = "valid.rrd"
+rrd_version = "0003"
+step = 300
+last_update = 1310750319
+header_size = 2320
+ds[temperature].index = 0
+ds[temperature].type = "GAUGE"
+ds[temperature].minimal_heartbeat = 600
+ds[temperature].min = NaN
+ds[temperature].max = NaN
+ds[temperature].last_ds = "131"
+ds[temperature].value = 2.8608000000e+04
+ds[temperature].unknown_sec = 0
+ds[target_temp].index = 1
+ds[target_temp].type = "GAUGE"
+ds[target_temp].minimal_heartbeat = 600
+ds[target_temp].min = NaN
+ds[target_temp].max = NaN
+ds[target_temp].last_ds = "68"
+ds[target_temp].value = 1.4892000000e+04
+ds[target_temp].unknown_sec = 0
+ds[state].index = 2
+ds[state].type = "GAUGE"
+ds[state].minimal_heartbeat = 600
+ds[state].min = NaN
+ds[state].max = NaN
+ds[state].last_ds = "0"
+ds[state].value = 0.0000000000e+00
+ds[state].unknown_sec = 0
+rra[0].cf = "AVERAGE"
+rra[0].rows = 300
+rra[0].cur_row = 182
+rra[0].pdp_per_row = 1
+rra[0].xff = 5.0000000000e-01
+rra[0].cdp_prep[0].value = NaN
+rra[0].cdp_prep[0].unknown_datapoints = 0
+rra[0].cdp_prep[1].value = NaN
+rra[0].cdp_prep[1].unknown_datapoints = 0
+rra[0].cdp_prep[2].value = NaN
+rra[0].cdp_prep[2].unknown_datapoints = 0
+rra[1].cf = "AVERAGE"
+rra[1].rows = 300
+rra[1].cur_row = 38
+rra[1].pdp_per_row = 7
+rra[1].xff = 5.0000000000e-01
+rra[1].cdp_prep[0].value = 6.3484000000e+02
+rra[1].cdp_prep[0].unknown_datapoints = 0
+rra[1].cdp_prep[1].value = 3.4000000000e+02
+rra[1].cdp_prep[1].unknown_datapoints = 0
+rra[1].cdp_prep[2].value = 0.0000000000e+00
+rra[1].cdp_prep[2].unknown_datapoints = 0
+rra[2].cf = "AVERAGE"
+rra[2].rows = 300
+rra[2].cur_row = 177
+rra[2].pdp_per_row = 31
+rra[2].xff = 5.0000000000e-01
+rra[2].cdp_prep[0].value = 3.2700500000e+03
+rra[2].cdp_prep[0].unknown_datapoints = 0
+rra[2].cdp_prep[1].value = 1.8360000000e+03
+rra[2].cdp_prep[1].unknown_datapoints = 0
+rra[2].cdp_prep[2].value = 0.0000000000e+00
+rra[2].cdp_prep[2].unknown_datapoints = 0
+rra[3].cf = "AVERAGE"
+rra[3].rows = 1500
+rra[3].cur_row = 417
+rra[3].pdp_per_row = 352
+rra[3].xff = 5.0000000000e-01
+rra[3].cdp_prep[0].value = 1.4339880000e+04
+rra[3].cdp_prep[0].unknown_datapoints = 0
+rra[3].cdp_prep[1].value = 9.7240000000e+03
+rra[3].cdp_prep[1].unknown_datapoints = 0
+rra[3].cdp_prep[2].value = 0.0000000000e+00
+rra[3].cdp_prep[2].unknown_datapoints = 0