PrivateEvents

package.json

@@ -44,6 +44,7 @@
     "lusca": "^1.6.1",
     "mongoose": "^5.7.5",
     "mongoose-unique-validator": "^2.0.3",
+    "node-cron": "^3.0.0",
     "nodemailer": "^6.2.1",
     "request": "^2.88.0",
     "request-promise": "^4.2.4",
@@ -65,6 +66,7 @@
     "@types/mongoose": "^5.5.6",
     "@types/mongoose-unique-validator": "^1.0.1",
     "@types/node": "^13.11.1",
+    "@types/node-cron": "^2.0.4",
     "@types/nodemailer": "^6.2.0",
     "@types/request-promise": "^4.1.44",
     "@types/slug": "^0.9.1",

src/app.ts

@@ -8,7 +8,8 @@ import * as compression from 'compression';
 import * as admin from 'firebase-admin';
 import * as fs from 'fs';
 import {MONGODB_URI} from './utils/secrets';
-
+import * as cron from 'node-cron';
+import {trendUpdate} from './cronJobs/trendUpdate';
 import routes from './routes';
 
 let serviceAccount;
@@ -91,4 +92,6 @@ app.use(
   }
 );
 
+// Schedule cron-Jobs
+cron.schedule('0 */30 * * * *', trendUpdate);
 export default app;

src/controllers/body.ts

@@ -25,6 +25,11 @@ export const addBody = async (
   next: NextFunction
 ) => {
   try {
+    const user = await User.findById(req.payload);
+
+    if (user === null || user.superSuperAdmin === false) {
+      throw createError(401, 'Unauthorized', 'Invalid');
+    }
     const newBody = new Body(req.body);
     await newBody.save();
     res.send(createResponse('Body Created Successfully', newBody));

src/controllers/event.ts

@@ -137,19 +137,61 @@ export const deleteEvent = async (
   }
 };
 
-export const getEvent = async (req: Request, res: Response) => {
-  const [user, event] = await Promise.all([
-    User.findById(req.payload),
-    Event.findById(req.params.id).populate('body').populate('updates').exec(),
-  ]);
-  if (user === null || event === null) {
-    return res.status(400).json({message: 'Error'});
+export const getStarredEvents = async (
+  req: Request,
+  res: Response,
+  next: NextFunction
+) => {
+  try {
+    const user = await User.findById(req.payload);
+
+    if (user === null) {
+      throw createError(401, 'Unauthorized', 'Invalid');
+    }
+    const starredEvents = user.staredEvents;
+    res.send(createResponse('Starred Events', starredEvents));
+  } catch (error) {
+    next(error);
+  }
+};
+
+export const getEvent = async (
+  req: Request,
+  res: Response,
+  next: NextFunction
+) => {
+  try {
+    const user = await User.findById(req.payload);
+    const event = await Event.findById(req.params.id)
+      .populate('body')
+      .populate('updates');
+    if (user === null) {
+      throw createError(401, 'Unauthorized', 'Invalid');
+    }
+    if (event === null) {
+      throw createError(400, 'Error ', 'Invalid Event');
+    }
+    // console.log(event);
+    const body = await Body.findById(event.body);
+    if (!body) {
+      throw createError(400, 'Error ', 'Invalid');
+    }
+    const members = body.members;
+    const valid_member = members.filter(member => {
+      return member.userId.toString() === user._id.toString();
+    });
+    // console.log(valid_member);
+    if (event.private === false || valid_member.length !== 0) {
+      const respData = {
+        event: toEventJSON(event, user),
+      };
+      res.send(createResponse('Event Found', respData));
+    } else {
+      throw createError(400, 'Error', 'Event is not public');
+    }
+  } catch (error) {
+    next(error);
   }
-  // console.log(event);
-  const respData = {
-    event: toEventJSON(event, user),
-  };
-  return res.send(respData);
 };
 
 export const getEvents = async (
@@ -159,36 +201,58 @@ export const getEvents = async (
 ) => {
   //!TODO IF WE WANT TO ADD THE OPTION TO FILTER BY CLUB OR YEAR OR ANYTHING
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
-  const query: any = {};
-  if (typeof req.query.body !== 'undefined') {
-    query.body = req.query.body;
-  }
-  return Promise.all([
-    Event.find(query)
-      // .sort({ endDate: "desc" })
-      .populate('body')
-      .populate('updates')
-      .exec(),
-    User.findById(req.payload),
-  ])
-    .then(([events, user]) => {
-      if (user === null) {
-        throw createError(401, 'Unauthorized', 'Invalid');
-      }
-      if (events !== null) {
-        const respData = {
-          events: events.map(event => toEventJSON(event, user)),
-        };
-        return res.send(createResponse('Events Found', respData));
+  try {
+    const user = await User.findById(req.payload);
+    if (user === null) {
+      throw createError(401, 'Unauthorized', 'Invalid');
+    }
+    let events;
+    let priv = false;
+    if (req.query) {
+      if (req.query.p === '1') {
+        priv = true;
       }
-      const respData = {
+    }
+    events = await Event.find({private: priv})
+      .populate('body')
+      .populate('updates');
+    // events = await Event.find().populate('body').populate('updates');
+    if (priv) {
+      //using maps to return an array of promises
+      const promises = events.map(event => Body.findById(event.body));
+      const bodies = await Promise.all(promises);
+      const fevents = events.filter((event, index) => {
+        const body = bodies[index];
+        if (!body) {
+          return false;
+        }
+        const members = body.members;
+        const valid_member = members.filter(member => {
+          return member.userId.toString() === user._id.toString();
+        });
+        if (valid_member.length !== 0) {
+          return true;
+        } else {
+          return false;
+        }
+      });
+      events = fevents;
+    }
+
+    let respData;
+    if (events !== null) {
+      respData = {
+        events: events.map(event => toEventJSON(event, user)),
+      };
+    } else {
+      respData = {
         events: [],
       };
-      return res.send(createResponse('Events Found', respData));
-    })
-    .catch(e => {
-      next(e);
-    });
+    }
+    res.send(createResponse('Events Found', respData));
+  } catch (error) {
+    next(error);
+  }
 };
 
 export const addUpdate = async (
@@ -279,49 +343,48 @@ export const removeUpdate = async (
   }
 };
 
-export const putUpdateEvent = (
+export const putUpdateEvent = async (
   req: Request,
   res: Response,
   next: NextFunction
 ) => {
-  return Promise.all([
-    Event.findById(req.params.id),
-    User.findById(req.payload),
-  ])
-    .then(([event, user]) => {
-      if (event === null || user === null) {
-        throw createError(400, 'Invalid', 'No Such Event Exists');
-      }
-      if (req.body.name !== null) {
-        event.name = req.body.name;
-      }
-      if (req.body.about !== null) {
-        event.about = req.body.about;
-      }
-      if (req.body.imageLink !== null) {
-        event.imageLink = req.body.imageLink;
-      }
-      if (req.body.venue !== null) {
-        event.venue = req.body.venue;
-      }
-      if (req.body.startDate !== null) {
-        event.startDate = req.body.startDate;
-      }
-      if (req.body.endDate !== null) {
-        event.endDate = req.body.endDate;
-      }
-      event.save().then(event => {
-        // const respData = {
-        //   event: toEventJSON(event, user)
-        // };
-        // console.log(respData);
-        const respData = {
-          id: event._id,
-        };
-        return res.send(createResponse('Event Updated Successfully', respData));
-      });
-    })
-    .catch(e => {
-      next(e);
+  try {
+    const [event, user] = await Promise.all([
+      Event.findById(req.params.id),
+      User.findById(req.payload),
+    ]);
+    if (event === null || user === null) {
+      throw createError(400, 'Invalid', 'No Such Event Exists');
+    }
+    if (req.body.name !== null) {
+      event.name = req.body.name;
+    }
+    if (req.body.about !== null) {
+      event.about = req.body.about;
+    }
+    if (req.body.imageLink !== null) {
+      event.imageLink = req.body.imageLink;
+    }
+    if (req.body.venue !== null) {
+      event.venue = req.body.venue;
+    }
+    if (req.body.startDate !== null) {
+      event.startDate = req.body.startDate;
+    }
+    if (req.body.endDate !== null) {
+      event.endDate = req.body.endDate;
+    }
+    event.save().then(event_1 => {
+      // const respData = {
+      //   event: toEventJSON(event, user)
+      // };
+      // console.log(respData);
+      const respData = {
+        id: event_1._id,
+      };
+      return res.send(createResponse('Event Updated Successfully', respData));
     });
+  } catch (e) {
+    next(e);
+  }
 };

src/controllers/news.ts

@@ -32,6 +32,7 @@ export const getNews = async (
         title: 1,
         sourceName: 1,
         createdAt: 1,
+        trendRate: 1,
       },
       {
         limit: parseInt(req.query.limit),
@@ -56,7 +57,7 @@ export const newsDetails = async (
       throw createError(401, 'Unauthorized', 'Invalid Credentials');
     }
     const news = await News.findById(req.params.id);
-    if (!news) {
+    if (!news || news.visible === false) {
       throw createError(
         401,
         'Doesnot Exists',

src/controllers/role.ts

@@ -0,0 +1 @@
+//Controllers File for Roles

src/controllers/user.ts

@@ -349,16 +349,15 @@ export const removeAdmin = async (
 //   }
 // };
 
-export const loggedInUserDetails = (
+export const loggedInUserDetails = async (
   req: Request,
   res: Response,
   next: NextFunction
 ) => {
   try {
-    const user = User.findById(req.payload)
+    const user = await User.findById(req.payload)
       .populate('adminOf')
-      .populate('superAdminOf')
-      .exec();
+      .populate('superAdminOf');
 
     if (user === null) {
       throw createError(401, 'Unauthorized', 'No Such User Found');

src/cronJobs/README.md

@@ -0,0 +1,9 @@
+## Cron-Jobs
+
+---
+
+> This folder contains Jobs that are required to run regularly at specified period of time. This is done using `node-cron` npm package
+
+_**Currently The Jobs are :**_
+
+1. **TrendUpdate** : It updates the trendRate for all the news documents. Runs every 30 minutes

src/cronJobs/trendUpdate.ts

@@ -0,0 +1,19 @@
+import News from '../models/news';
+
+export const trendUpdate = async () => {
+  try {
+    console.log('News TrendUpdate:Start', Date.now());
+    const news = await News.find({visible: true});
+    news.forEach(async thisDoc => {
+      const timeElapsedInHours =
+        (new Date().getTime() - thisDoc.createdAt.getTime()) / (1000 * 60 * 60);
+      const trendRate = thisDoc.clicks / timeElapsedInHours;
+      thisDoc.trendRate = trendRate;
+
+      await News.updateOne({_id: thisDoc._id}, {$set: {trendRate: trendRate}});
+    });
+    console.log('News TrendUpdate:Stop', Date.now());
+  } catch (err) {
+    console.log(err);
+  }
+};