Added some vows

lib/collector.js

@@ -81,15 +81,12 @@ Collector.prototype.scheduleAgents = function() {
         if (typeof agent.frequency == 'string') {
             // check the pattern is a valid cron pattern, and then register the job
             new cron.CronTime(agent.frequency);
-            console.log('pattern ok, registering agent');
 
             agent.cron = new cron.CronJob(agent.frequency, function() {
                 collector.runAgent(agent);
             });
         }
         else {
-            console.log('agent specified interval, scheduling');
-
             setInterval(function() {
                 collector.runAgent(agent);
             }, agent.frequency);

lib/sampledb.js

@@ -10,7 +10,8 @@ SampleDB.prototype.close = function() {
 }; // close
 
 SampleDB.prototype.getSince = function(time, callback, maxItems) {
-    var targetKey = time.toString(),
+    var error, 
+        targetKey = time.toString(),
         iterator = this.storage.newIterator({}),
         itemCount = maxItems || 1000,
         startTick,
@@ -54,13 +55,15 @@ SampleDB.prototype.getSince = function(time, callback, maxItems) {
     } // while
 
     // trigger the callback
-    callback({
-        start: startTick,
-        end: lastTick,
-        more: itemCount <= 0,
-
-        items: items
-    });
+    if (callback) {
+        callback(error, {
+            start: startTick,
+            end: lastTick,
+            more: itemCount <= 0,
+
+            items: items
+        });
+    } // if
 }; // getSince
 
 SampleDB.prototype.save = function(type, data, details) {

tests/db.js

@@ -0,0 +1,34 @@
+var vows = require('vows'),
+    assert = require('assert'),
+    collector = require('../lib/collector'),
+    startTick = new Date().getTime();
+
+vows.describe('Collection to DB').addBatch({
+    'When collecting samples': {
+        topic: function() {
+            var collectionProcess = collector.collectToDB(),
+                callback = this.callback;
+
+            setTimeout(function() {
+                collectionProcess.db.getSince(startTick, callback);
+                collectionProcess.stop();
+            }, 2000);
+        }, 
+
+        'we have results': function(err, results) {
+            assert.ok(results);
+        },
+
+        'samples have been collected': function(err, results) {
+            assert.ok(results.items.cpu && results.items.cpu.length > 0);
+        },
+
+        'start tick in results is sensible': function(err, results) {
+            assert.ok(Math.abs(results.start - startTick) < 500);
+        },
+
+        'end tick in results is sensible': function(err, results) {
+            assert.ok(Math.abs(results.end - (startTick + 2000)) < 500);
+        }
+    }
+}).run();