Event follow and RSVP

app.js

@@ -103,4 +103,7 @@ if (process.env.INSTALL === 'yes' || args[0] === 'install') {
   });
 }
 
+const child_process = require('child_process');
+child_process.fork('rsvp_sender');
+
 module.exports = app;

public/css/style.css

@@ -366,7 +366,6 @@ input::-webkit-calendar-picker-indicator {
     padding-top: 10px;
     z-index: 1050;
     font-size: 15px;
-    background-color: #51a351;
     color: #ffffff;
     text-align: center;
     border-bottom-left-radius: 20px 10px;

routes/event/event.js

@@ -6,31 +6,54 @@ const authService = require('../services/authorization_service');
 
 router.get('/', function (req, res, next) {
     let offset = 0;
-    event_db.getEventSet(offset, function (err, eventsSet) {
+    let uid = req.session.uid;
+    event_db.getEventSet(offset, function (err, events_set) {
         if (err) {
             console.log(err);
             res.status(400).json({msg: 'Database Error'});
             return;
         }
-        user_db.getUserRoleByUid(req.session.uid, function (err, user_role) {
+        user_db.getUserRoleByUid(uid, (err, user_role) => {
             if (err) {
+                console.log(err);
                 res.status(400).json({msg: 'Database Error'});
                 return;
             }
-            eventsSet = eventsSet.sort(function (a, b) {
-                return a.event_time - b.event_time
-            })
-            let now = new Date();
-            now = new Date(now - (5.5 * 60 * 60 * 1000));
-            var centerIdx = eventsSet.length - 1;
-            for (var i = eventsSet.length - 1; i >= 0; i--) {
-                // show the event thats coming up soon
-                if (eventsSet[i].event_time < now) {
-                    break;
+            user_db.getUserFollowedEventsByUid(uid, (err, followed_events) => {
+                if (err) {
+                    console.log(err);
+                    res.status(400).json({msg: 'Database Error'});
+                    return;
                 }
-                centerIdx = i;
-            }
-            res.render('event/index', {eventsSet: eventsSet, uid: req.session.uid, all_user_role: authService.UserRole, user_role: user_role, centerIdx: centerIdx});
+                user_db.getUserRSVPEventsByUid(uid, (err, rsvp_events) => {
+                    if (err) {
+                        console.log(err);
+                        res.status(400).json({msg: 'Database Error'});
+                        return;
+                    }
+                    events_set = events_set.sort((event_a, event_b) => {
+                        return event_a.event_time - event_b.event_time
+                    })
+                    let now = new Date();
+                    now = new Date(now - (5.5 * 60 * 60 * 1000));
+                    let center_idx = events_set.length - 1;
+                    for (let i = events_set.length - 1; i >= 0; i--) {
+                        if (events_set[i].event_time < now) {
+                            break;
+                        }
+                        center_idx = i;
+                    }
+                    res.render('event/index', {
+                        followed_events: JSON.parse(followed_events),
+                        rsvp_events: JSON.parse(rsvp_events),
+                        eventsSet: events_set,
+                        uid: req.session.uid,
+                        all_user_role: authService.UserRole,
+                        user_role: user_role,
+                        centerIdx: center_idx
+                    });
+                });
+            });
         });
     });
 });
@@ -86,4 +109,43 @@ router.get('/edit', function (req, res, next) {
     });
 });
 
+router.get('/followed', function (req, res, next) {
+    let uid = req.query.user_id ? req.query.user_id : req.session.uid;
+    authService.authorizationCheck(null, req.session.uid, function(err, authorized){
+        if (err) {
+            console.log(err);
+            res.status(400).json({msg: 'Database Error'});
+        }
+        else if(!authorized) {
+            res.redirect('/login');
+        } else {
+            user_db.getUserFollowedEventsByUid(uid, (err, followed_events) => {
+                if (err) {
+                    console.log(err);
+                    res.status(400).json({msg: 'Database Error'});
+                } else {
+                    event_db.getEventSet((err, event_set) => {
+                        if (err) {
+                            console.log(err);
+                            res.status(400).json({msg: 'Database Error'});
+                        }
+                        let followed_event_ids = JSON.parse(followed_events);
+                        let followed_event_set = [];
+
+                        event_set.forEach(function (event) {
+                            if (followed_event_ids.includes(event.id)) {
+                                followed_event_set.push(event);
+                            }
+                        });
+
+                        res.render('event/followed', {
+                            event_set: followed_event_set
+                        });
+                    });
+                }
+            });
+        }
+    });
+});
+
 module.exports = router;

routes/event/event_api.js

@@ -1,5 +1,6 @@
 const express = require('express');
 const event_db = require('../../server/event_db');
+const user_db = require('../../server/user_db');
 const router = express.Router();
 const authService = require('../services/authorization_service');
 
@@ -106,4 +107,101 @@ router.post('/changeEventStatus', function(req, res, next){
     });
 });
 
+router.post('/followEvent', function(req, res, next) {
+    if(!req.body.uid){
+        res.status(403).json({msg: 'Not Authorized'});
+        return;
+    }
+    user_db.hasUserEventEntry(req.body.uid, (err, has_entry) => {
+        if (err) {
+            console.log(err);
+            res.status(400).json({msg: 'Failed to check entry'});
+            return;
+        }
+        if (has_entry) {
+            user_db.followEvent(req.body.uid, req.body.eid, (err) => {
+                if (err) {
+                    console.log(err);
+                    res.status(400).json({msg: 'Failed to follow event'});
+                    return;
+                }
+                res.json({});
+            });
+        } else {
+            user_db.createEntryAndFollowEvent(req.body.uid, req.body.eid, (err) => {
+                if (err) {
+                    console.log(err);
+                    res.status(400).json({msg: 'Failed to create entry and follow event'});
+                    return;
+                }
+                res.json({});
+            })
+        }
+    });
+});
+
+router.post('/unfollowEvent', function(req, res, next) {
+    if(!req.body.uid){
+        res.status(403).json({msg: 'Not Authorized'});
+        return;
+    }
+    user_db.unfollowEvent(req.body.uid, req.body.eid, ((err) => {
+        if (err) {
+            console.log(err);
+            res.status(400).json({msg: 'Failed to unfollow event'});
+            return;
+        }
+        res.json({});
+    }))
+});
+
+router.post('/rsvpEvent', function (req, res, next) {
+    if(!req.body.uid){
+        res.status(403).json({msg: 'Not Authorized'});
+        return;
+    }
+    user_db.hasUserEventEntry(req.body.uid, (err, has_entry) => {
+        if (err) {
+            console.log(err);
+            res.status(400).json({msg: 'Failed to check entry'});
+            return;
+        }
+        if (has_entry) {
+            user_db.rsvpEvent(req.body.uid, req.body.eid, (err) => {
+                if (err) {
+                    console.log(err);
+                    res.status(400).json({msg: 'Failed to RSVP event'});
+                    return;
+                }
+
+                res.json({});
+            });
+        } else {
+            user_db.createEntryAndRSVPEvent(req.body.uid, req.body.eid, (err) => {
+                if (err) {
+                    console.log(err);
+                    res.status(400).json({msg: 'Failed to create entry and RSVP event'});
+                    return;
+                }
+                res.json({});
+            });
+        }
+    });
+});
+
+router.post('/unrsvpEvent', function(req, res, next) {
+    if(!req.body.uid){
+        res.status(403).json({msg: 'Not Authorized'});
+        return;
+    }
+    user_db.unrsvpEvent(req.body.uid, req.body.eid, ((err) => {
+        if (err) {
+            console.log(err);
+            res.status(400).json({msg: 'Failed to unfollow event'});
+            return;
+        }
+        res.json({});
+    }))
+});
+
 module.exports = router;

rsvp_sender.js

@@ -0,0 +1,56 @@
+const nodemailer = require('nodemailer');
+const user_db = require('./server/user_db');
+const event_db = require('./server/event_db');
+
+
+setInterval(() => {
+    user_db.getAllEntriesFromUserEvent((err, user_event_entries) => {
+        if (err) {
+            console.log("Failed to get all entries from user event");
+            return;
+        }
+        user_event_entries.rows.forEach((row) => {
+            const uid = row.uid;
+            const rsvp_events = JSON.parse(row.rsvp_events);
+            rsvp_events.forEach((rsvp_event) => {
+                event_db.getEventById(rsvp_event, (err, event_info) => {
+                    if (!err) {
+                        let now = new Date();
+                        // TODO: !!!!!!!!
+                        if (!(now.toLocaleDateString() === event_info.event_time.toLocaleDateString())) {
+                            user_db.getUserEmailById(uid, (err, user_email) => {
+                                if (!err) {
+                                    let mail_options = {
+                                        from: process.env.EMAILUSER,
+                                        to: user_email.email,
+                                        subject: 'Event Reminder: ' + event_info.title,
+                                        text: event_info.description,
+                                    };
+                                    let transporter = nodemailer.createTransport({
+                                        service: 'gmail',
+                                        auth: {
+                                            user: process.env.EMAILUSER,
+                                            pass: process.env.EMAILPASS,
+                                        }
+                                    });
+                                    transporter.sendMail(mail_options, (err, info) => {
+                                        if (err) {
+                                            console.log(err);
+                                        } else {
+                                            user_db.unrsvpEvent(uid, event_info.id, (err) => {
+                                                if (err) {
+                                                    console.log(err);
+                                                }
+                                                console.log('Email sent: ' + info.response);
+                                            });
+                                        }
+                                    });
+                                }
+                            });
+                        }
+                    }
+                });
+            });
+        })
+    });
+}, 1000);