Ajout d'un compteur de notifications

Author: hardware

routes/cron.js

@@ -15,6 +15,10 @@ var requestModel = require('../models/requests');
 exports.handleRequests = function( req, res, next ) {
 
     checkSecureKey(req, res, req.params.secureKey, function() {
+
+    var mailNotificationCounter = 0;
+    var pushNotificationCounter = 0;
+
     requestModel.getPendingRequests(next, function( pendingRequests ) {
     ovh.getJson(next, function( json ) {
 
@@ -41,6 +45,10 @@ exports.handleRequests = function( req, res, next ) {
 
                     availableOffers.push( offer );
                     inform( res, request, next );
+                    mailNotificationCounter++;
+
+                    if( request.pushbullet_token )
+                        pushNotificationCounter++;
 
                 }
 
@@ -60,22 +68,47 @@ exports.handleRequests = function( req, res, next ) {
             for( var key in arr )
                 availableOffers.push( arr[key] );
 
-            var events = [];
+            var newRelicEvents = [];
 
             async.each(availableOffers, function( availableOffer, nextOffer ) {
 
-                var eventObject = {
+                var eventAvailableOffersObject = {
                     "eventType":"availableOffers",
                     "offer":availableOffer.offer,
                     "zone":availableOffer.zone
                 };
 
-                events.push( eventObject );
+                newRelicEvents.push( eventAvailableOffersObject );
                 nextOffer();
 
             }, function( err ) {
 
-                newrelic.submitEvents( events );
+                if( mailNotificationCounter > 0 ) {
+
+                    var eventMailNotificationObject = {
+                        "eventType":"mailNotifications",
+                        "mailCounter":mailNotificationCounter,
+                    };
+
+                    newRelicEvents.push( eventMailNotificationObject );
+
+                }
+
+                if( pushNotificationCounter > 0 ) {
+
+                    var eventPushNotificationObject = {
+                        "eventType":"pushNotifications",
+                        "pushCounter":pushNotificationCounter,
+                    };
+
+                    newRelicEvents.push( eventPushNotificationObject );
+
+                }
+
+                if( newRelicEvents.length > 0 )
+                    // Envoi des évènement à l'API de NewRelic Insights
+                    newrelic.submitEvents( newRelicEvents );
+
                 res.send('PROCESSING REQUESTS COMPLETED !');
 
             });

routes/index.js

@@ -127,7 +127,7 @@ exports.run = function( req, res, next ) {
                     requestModel.unique({ ref:req.body.server, mail:req.body.mail }, next, function( unique ) {
 
                         if( ! unique )
-                            callback("Votre demande est toujours en attente, vous ne pouvez pas en créer plusieurs à la fois. Merci d'attendre de recevoir la notification par mail / SMS.");
+                            callback("Votre demande est toujours en attente, vous ne pouvez pas en créer plusieurs à la fois. Merci d'attendre de recevoir la notification par mail / Pushbullet.");
                         else
                             callback();