Queue ordering and lenght for monitoring

CHANGELOG.md

@@ -0,0 +1,5 @@
+# 1.0.2
+* Mejoras en el log para mejor depuración.
+* Ahora se procesará la cola por orden cronológico en que fueron generados.
+* Monitor podrá obtener información de la cola.
+

ondemand.js

@@ -14,6 +14,7 @@ var od_ref = db.ref("devices").child(config.device_id).child("ondemand");
 
 var proc;
 
+
 function process_queue() {
   if (working) return;
   working = true;
@@ -87,7 +88,7 @@ function addAndProc(key, job) {
 function start() {
   queue = [];
 
-  od_ref.on("child_added", snp => {
+  od_ref.orderByChild('fromTime').on("child_added", snp => {
     console.log("added", snp.key);
     addAndProc(snp.key, snp.val());
   });
@@ -102,7 +103,8 @@ endpoint.get('/info', function(request, response) {
   response.send(JSON.stringify({
     'version': version,
     'processID': process.id,
-    'memoryUsage': process.memoryUsage().rss
+    'memoryUsage': process.memoryUsage().rss,
+    'queueSize': queue.length
   }));
 });
 endpoint.listen(49223);

package.json

@@ -6,7 +6,8 @@
   "dependencies": {
     "console-stamp": "^0.2.6",
     "express": "^4.16.2",
-    "fourier-common": "file:../common"
+    "fourier-common": "file:../common",
+    "moment": "^2.20.1"
   },
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1"