fixed disperser

venatir · May 16, 2014 · cf308d7 · cf308d7
1 parent 5c26539
commit cf308d7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/lib/analytics/aggregator.js b/lib/analytics/aggregator.js
@@ -470,7 +470,7 @@ exports.register = function (dbs, endpoints, options) {
         };
 
     options.aggregations.forEach(function (aggregationObject) {
-        validateAndRunAggregation(aggregationObject, 20);
+        validateAndRunAggregation(aggregationObject, 1000);  // aggregation refresh frequency
     });
 };
 
diff --git a/lib/analytics/genericGetter.js b/lib/analytics/genericGetter.js
@@ -28,7 +28,9 @@ function customQuery(collectionObj, filter, sort, limit, batchSize, streamified,
     if (streamified) {
         stream = cursor.sort({$natural: -1}).stream();
         stream.on('data', function (document) {
-            documentHandler({id: document._id, time: document.t, data: (document.d === undefined ? document.key : document.d)});
+            document.time = document.t;
+            document.data = (document.d === undefined ? document.key : document.d);
+            documentHandler(document);
         });
     }
     else {