Add event scheduling, essentially preparing for push notifications

index.js

@@ -3,6 +3,7 @@ var serveIndex = require('serve-index');
 var https = require('https');
 var app = express();
 var route_manager = require("./utils/route-manager.js");
+var scheduler = require("./presenters/schedule-controller.js");
 var bodyParser = require('body-parser');
 var FileStreamRotator = require('file-stream-rotator');
 var morgan = require('morgan');
@@ -10,6 +11,8 @@ var fs = require('fs');
 var logDirectory = 'log'
 var production = process.argv[2];
 
+scheduler.register_existing_events();
+
 // ensure log directory exists
 fs.existsSync(logDirectory) || fs.mkdirSync(logDirectory)
 

presenters/event-controller.js

@@ -3,6 +3,7 @@ var redis = new Redis();
 var permissions_controller = require("./permissions-controller.js");
 var user_controller = require("./user-controller.js");
 var society_controller = require("./society-controller.js");
+var scheduler = require("./schedule-controller.js");
 
 module.exports = {
   create_event: function (soc_name, event, auth, complete) {
@@ -27,6 +28,7 @@ module.exports = {
               redis.hget(soc_query, "events", function (err, events) {
                 redis.hset(soc_query, "events", JSON.stringify(JSON.parse(events).concat(event_id)));
               });
+              scheduler.schedule_event(event_id, event.start);
               complete({
                 "success": 1,
                 "event": {
@@ -71,7 +73,6 @@ module.exports = {
               var soc_events = soc_resp.society.events;
               var completed_count = 1;
               if (soc_events.indexOf(event_id) > -1) {
-                console.log(soc_events.indexOf(event_id));
                 soc_events.splice(soc_events.indexOf(event_id), 1);
                 redis.hset("society:" + soc_resp.society.name.toLowerCase(), "events", JSON.stringify(soc_events));
               }
@@ -98,6 +99,7 @@ module.exports = {
                   }
                   completed_count++;
                   if (completed_count === users.length) {
+                    scheduler.cancel_registered(event_id);
                     complete({
                       "success": 1,
                       "error": 0

presenters/notification-controller.js

@@ -0,0 +1,16 @@
+module.exports = {
+
+  send_notifications_for: function (event_id) {
+    var event_controller = require("./event-controller.js");
+    event_controller.get_event(event_id, "", function (response) {
+      var attendees = response.event.attendees;
+      console.log("Triggered Event: " + response.event.name);
+      console.dir(attendees);
+      attendees.map(function (attendee) {
+        console.log((new Date(Date.now())).toString() + " : Sending push notification to " + attendee + " for event starting at " + (new Date(Number(response.event.start)).toString()));
+      });
+      event_controller.cancel_event(event_id, "", function(){}, true);
+    }, true);
+  }
+
+}

presenters/schedule-controller.js

@@ -0,0 +1,48 @@
+var Redis = require("ioredis");
+var redis = new Redis();
+var scheduler = require("node-schedule");
+var notification_controller = require("./notification-controller.js");
+var registered_events = {};
+
+module.exports = {
+
+  schedule_event: function (event_id, time) {
+    var event_time = new Date(Number(time));
+    console.log("Scheduled event for " + event_time);
+    var job = scheduler.scheduleJob(event_time, function(evt_id) {
+      notification_controller.send_notifications_for(evt_id);
+    }.bind(null, event_id));
+    registered_events[event_id] = job;
+  },
+
+  register_existing_events: function () {
+    var self = this;
+    var stream = redis.scanStream({
+      match: "event:*"
+    });
+    var event_ids = [];
+    stream.on('data', function (keys) {
+      keys.map(function (key) {
+        event_ids.push(key);
+      });
+    })
+    stream.on('end', function () {
+      var event_controller = require("./event-controller.js");
+      for (var ii = 0; ii < event_ids.length; ii++) {
+        event_controller.get_event(event_ids[ii], "", function (response) {
+          var event = response.event;
+          self.schedule_event(event.id, event.start);
+        }, true);
+      }
+    });
+  },
+
+  cancel_registered: function (event_id) {
+    var event = registered_events[event_id];
+    if (event !== undefined) {
+      event.cancel();
+      delete registered_events.event_id;
+    }
+  }
+
+}

presenters/society-controller.js

@@ -28,7 +28,6 @@ module.exports = {
     var soc_query = ("society:" + society_name).toLowerCase();
     admins = decodeURIComponent(admins).toLowerCase();
     description = decodeURIComponent(description);
-    var admins_str = admins;
     admins = JSON.parse(admins);
 
     redis.hget(soc_query, "name", function (err, result) {
@@ -51,9 +50,9 @@ module.exports = {
                 }
                 if (idx === adm.length-1 && users_exist) {
                   redis.hset(soc_query, "name", society_name);
-                  redis.hset(soc_query, "admins", admins_str);
+                  redis.hset(soc_query, "admins", JSON.stringify(admins));
                   redis.hset(soc_query, "description", description);
-                  redis.hset(soc_query, "users", admins_str);
+                  redis.hset(soc_query, "users", JSON.stringify(admins));
                   redis.hset(soc_query, "events", JSON.stringify([]));
                   redis.hset(soc_query, "image", image);
                   admins.map(function (admin_name) {

presenters/user-controller.js

@@ -41,7 +41,6 @@ module.exports = {
   },
 
   get_raw_user: function (user, complete) {
-    console.warn("WARNING: Accessing raw user info, use with care and do not expose to API endpoints.");
     var user_key = "user:" + user;
 
     redis.hgetall(user_key, function(err, result) {