#579 added tests for the different scenarios

joola · Aug 11, 2014 · 682af64 · 682af64
1 parent 99dc943
commit 682af64
Show file tree

Hide file tree

Showing 3 changed files with 84 additions and 4 deletions.
diff --git a/lib/common/redis.js b/lib/common/redis.js
@@ -40,7 +40,6 @@ var redis = module.exports = function (options) {
     self.auth = options.auth || null;
     self.redisOptions = options.options || null;
   }
-  console.log(self.port, self.host, self.redisOptions);
   self.redis = _redis.createClient(self.port, self.host, self.redisOptions);
   self.connect = options.connect || function () {
     joola.state.set('runtime-redis', 'working', 'redis [runtime-redis] is up.');

diff --git a/lib/dispatch/beacon.js b/lib/dispatch/beacon.js
@@ -34,10 +34,7 @@ etl.verify = function (context, workspace, collection, documents, callback) {
   if (documents.length > 0)
     _document = ce.clone(documents[0]);
 
-  //console.log('doc', _document);
-
   if (!_document.timestamp) {
-    console.log('generating timestamp');
     _document.timestamp = new Date();
   }
 

diff --git a/test/unit/7_query/query-basic.spec.js b/test/unit/7_query/query-basic.spec.js
@@ -565,4 +565,88 @@ describe("query-basic", function () {
       return done();
     });
   });
+
+  it("should perform a freestyle unique count by attribute", function (done) {
+    var query = {
+      timeframe: 'this_day',
+      interval: 'minute',
+      dimensions: ['attribute'],
+      metrics: [
+        {
+          key: 'uniquevalue',
+          name: 'uniquevalue',
+          aggregation: 'ucount',
+          datatype: 'number',
+          dependsOn: ['attribute']
+        }
+      ],
+      collection: this.collection
+    };
+    joola_proxy.query.fetch(this.context, query, function (err, result) {
+      if (err)
+        return done(err);
+      result.documents.forEach(function(doc){
+        console.log(doc);
+      });
+      expect(result).to.be.ok;
+      expect(result.documents).to.be.ok;
+      expect(result.documents.length).to.be.greaterThan(0);
+      expect(result.documents[0].values.uniquevalue).to.equal(1);
+      return done();
+    });
+  });
+
+  it("should perform an last_n_items query", function (done) {
+    var query = {
+      timeframe: 'last_1_items',
+      interval: 'minute',
+      dimensions: ['timestamp'],
+      metrics: [
+        {
+          key: 'uniquevalue',
+          name: 'uniquevalue',
+          aggregation: 'ucount',
+          datatype: 'number',
+          dependsOn: ['attribute']
+        }
+      ],
+      collection: this.collection
+    };
+    joola_proxy.query.fetch(this.context, query, function (err, result) {
+      if (err)
+        return done(err);
+      result.documents.forEach(function(doc){
+        console.log(doc);
+      })
+      expect(result).to.be.ok;
+      expect(result.documents).to.be.ok;
+      expect(result.documents.length).to.be.greaterThan(0);
+      expect(result.documents[0].values.uniquevalue).to.equal(1);
+      return done();
+    });
+  });
+
+  it("should perform an last_n_items query w/o metrics", function (done) {
+    var query = {
+      timeframe: 'last_1_items',
+      interval: 'minute',
+      dimensions: ['timestamp'],
+      metrics: [
+
+      ],
+      collection: this.collection
+    };
+    joola_proxy.query.fetch(this.context, query, function (err, result) {
+      if (err)
+        return done(err);
+      result.documents.forEach(function(doc){
+        console.log(doc);
+      })
+      expect(result).to.be.ok;
+      expect(result.documents).to.be.ok;
+      expect(result.documents.length).to.be.greaterThan(0);
+      expect(result.documents[0].values.uniquevalue).to.equal(1);
+      return done();
+    });
+  });
 });