Update Statistics To Realtime w/ Caching

api/v1/index.js

@@ -33,10 +33,10 @@ v1.use('/health', controllers.HealthController.router);
 v1.use('/checkin', controllers.CheckInController.router);
 v1.use('/rsvp', controllers.RSVPController.router);
 v1.use('/announcement', controllers.AnnouncementController.router);
-v1.use('/stats', controllers.StatsController.router);
 v1.use('/tracking', controllers.TrackingController.router);
 v1.use('/mail', controllers.MailController.router);
 v1.use('/event', controllers.EventController.router);
+v1.use('/stats', controllers.StatsController.router);
 
 // logs resolved requests (the request once processed by various middleware) and outgoing responses
 v1.use((req, res, next) => {

api/v1/models/Stat.js

@@ -0,0 +1,70 @@
+const _ = require('lodash');
+
+const Model = require('./Model');
+const validators = require('../utils/validators');
+
+const CATEGORIES = ['registration', 'rsvp', 'live_event'];
+
+const Stat = Model.extend({
+  tableName: 'stats',
+  idAttribute: 'id',
+  validations: {
+    category: ['required', 'string', validators.in(CATEGORIES)],
+    stat: ['required', 'string'],
+    field: ['required', 'string'],
+    count: ['required', 'integer'] // Change to default 0?
+  }
+});
+
+/**
+ * Adds a row with category `category`, stat `stat`, and field `field`.
+ * Initializes count to 0
+ * @param {String} category
+ * @param {String} stat
+ * @param {String} field
+ * @return {Promise<Stat>} a Promise resolving to the newly-created Stat 
+ */
+Stat.create = (category, stat, field) => {
+  const s = Stat.forge({
+    category: category,
+    stat: stat,
+    field: field,
+    count: 0
+  });
+
+  return s.save();
+};
+
+/**
+ * Increments the specified stat by the amount
+ * @param {String} category
+ * @param {String} stat
+ * @param {String} field
+ * @param {Number} amount defaults to 1
+ * @return {Promise<Stat>} a Promise resolving to the updating Stat model
+ */
+Stat.increment = (category, stat, field, amount) => {
+  if (_.isUndefined(amount)) {
+    amount = 1;
+  }
+
+  const s = Stat.where({
+    category: category,
+    stat: stat,
+    field: field
+  }).fetch();
+
+  return s.then((model) => {
+    if(model == null) {
+      return Stat.create(category, stat, String(field)).then((createdModel) => {
+        createdModel.set('count', createdModel.get('count') + amount);
+        return createdModel.save(); 
+      });
+    } 
+    model.set('count', model.get('count') + amount);
+    return model.save();
+
+  }).catch(() => null);
+};
+
+module.exports = Stat;

api/v1/models/TrackingEvent.js

@@ -17,4 +17,10 @@ TrackingEvent.findByName = function(searchName) {
     .fetch();
 };
 
+TrackingEvent.findAll = function() {
+  return TrackingEvent.where({
+
+  }).fetchAll();
+};
+
 module.exports = TrackingEvent;

api/v1/services/CheckInService.js

@@ -5,6 +5,7 @@ const NetworkCredential = require('../models/NetworkCredential');
 const errors = require('../errors');
 const utils = require('../utils');
 
+const StatsService = require('../services/StatsService');
 
 /**
  * Finds a CheckIn by User ID
@@ -61,6 +62,8 @@ module.exports.createCheckIn = (attributes) => {
   const credentialsRequested = attributes.credentialsRequested;
   delete attributes.credentialsRequested;
 
+  StatsService.incrementStat('liveEvent', 'attendees', 'count');
+
   return CheckIn.transaction((t) => new CheckIn(attributes)
       .save(null, {
         transacting: t

api/v1/services/RSVPService.js

@@ -6,6 +6,10 @@ const RSVP = require('../models/AttendeeRSVP');
 const UserRole = require('../models/UserRole');
 const errors = require('../errors');
 const utils = require('../utils');
+
+const StatsService = require('../services/StatsService');
+const RegistrationService = require('../services/RegistrationService');
+
 /**
  * Gets an rsvp by its id
  * @param {integer} id the id of the RSVP to find
@@ -22,6 +26,19 @@ module.exports.getRSVPById = (id) => RSVP.findById(id);
  * @throws {InvalidParameterError} thrown when an attendee already has an rsvp
  */
 module.exports.createRSVP = (attendee, user, attributes) => {
+
+  if(attributes.isAttending) {
+    StatsService.incrementStat('rsvp', 'school', attendee.get('school'))
+    .then(() => StatsService.incrementStat('rsvp', 'transportation', attendee.get('transportation')))
+    .then(() => StatsService.incrementStat('rsvp', 'diet', attendee.get('diet')))
+    .then(() => StatsService.incrementStat('rsvp', 'shirtSize', attendee.get('shirtSize')))
+    .then(() => StatsService.incrementStat('rsvp', 'gender', attendee.get('gender')))
+    .then(() => StatsService.incrementStat('rsvp', 'graduationYear', attendee.get('graduationYear')))
+    .then(() => StatsService.incrementStat('rsvp', 'major', attendee.get('major')))
+    .then(() => StatsService.incrementStat('rsvp', 'isNovice', attendee.get('isNovice') ? 1 : 0))
+    .then(() => StatsService.incrementStat('rsvp', 'attendees', 'count'));
+  }
+
   attributes.attendeeId = attendee.get('id');
   const rsvp = RSVP.forge(attributes);
 
@@ -66,6 +83,32 @@ module.exports.findRSVPByAttendee = (attendee) => RSVP
  * @returns {Promise} the resolved RSVP
  */
 module.exports.updateRSVP = (user, rsvp, attributes) => {
+  const oldAttending = rsvp.get('isAttending');
+  const newAttending = attributes.isAttending;
+  RegistrationService.findAttendeeByUser(user).then((attendee) => {
+    if(!oldAttending && newAttending) {
+      StatsService.incrementStat('rsvp', 'school', attendee.get('school'))
+      .then(() => StatsService.incrementStat('rsvp', 'transportation', attendee.get('transportation')))
+      .then(() => StatsService.incrementStat('rsvp', 'diet', attendee.get('diet')))
+      .then(() => StatsService.incrementStat('rsvp', 'shirtSize', attendee.get('shirtSize')))
+      .then(() => StatsService.incrementStat('rsvp', 'gender', attendee.get('gender')))
+      .then(() => StatsService.incrementStat('rsvp', 'graduationYear', attendee.get('graduationYear')))
+      .then(() => StatsService.incrementStat('rsvp', 'major', attendee.get('major')))
+      .then(() => StatsService.incrementStat('rsvp', 'isNovice', attendee.get('isNovice') ? 1 : 0))
+      .then(() => StatsService.incrementStat('rsvp', 'attendees', 'count'));
+    } else if(oldAttending && !newAttending) {
+      StatsService.decrementStat('rsvp', 'school', attendee.get('school'))
+      .then(() => StatsService.decrementStat('rsvp', 'transportation', attendee.get('transportation')))
+      .then(() => StatsService.decrementStat('rsvp', 'diet', attendee.get('diet')))
+      .then(() => StatsService.decrementStat('rsvp', 'shirtSize', attendee.get('shirtSize')))
+      .then(() => StatsService.decrementStat('rsvp', 'gender', attendee.get('gender')))
+      .then(() => StatsService.decrementStat('rsvp', 'graduationYear', attendee.get('graduationYear')))
+      .then(() => StatsService.decrementStat('rsvp', 'major', attendee.get('major')))
+      .then(() => StatsService.decrementStat('rsvp', 'isNovice', attendee.get('isNovice') ? 1 : 0))
+      .then(() => StatsService.decrementStat('rsvp', 'attendees', 'count'));
+    }
+  });
+
   rsvp.set(attributes);
 
   return rsvp

api/v1/services/RegistrationService.js

@@ -14,6 +14,8 @@ const errors = require('../errors');
 const utils = require('../utils');
 const config = require('ctx').config();
 
+const StatsService = require('../services/StatsService');
+
 /**
  * Persists (insert or update) a model instance and creates (insert only) any
  * related models as provided by the related mapping. Use #extractRelatedObjects
@@ -325,6 +327,20 @@ module.exports.createAttendee = (user, attributes) => {
     return _Promise.reject(new errors.InvalidParameterError(message, source));
   }
 
+  const statAttributes = attributes.attendee;
+
+  StatsService.incrementStat('registration', 'school', statAttributes.school)
+  .then(() => StatsService.incrementStat('registration', 'transportation', statAttributes.transportation))
+  .then(() => StatsService.incrementStat('registration', 'diet', statAttributes.diet))
+  .then(() => StatsService.incrementStat('registration', 'shirtSize', statAttributes.shirtSize))
+  .then(() => StatsService.incrementStat('registration', 'gender', statAttributes.gender))
+  .then(() => StatsService.incrementStat('registration', 'graduationYear', statAttributes.graduationYear))
+  .then(() => StatsService.incrementStat('registration', 'major', statAttributes.major))
+  .then(() => StatsService.incrementStat('registration', 'isNovice', statAttributes.isNovice ? 1 : 0))
+  .then(() => StatsService.incrementStat('registration', 'attendees', 'count'))
+  .then(() => StatsService.incrementStat('registration', 'status', 'PENDING'));
+
+
   const attendeeAttrs = attributes.attendee;
   delete attributes.attendee;