added reactions

src/api/reactions/controller.js

@@ -1,13 +1,11 @@
 import Reaction from './model';
 import { getPageData } from './helper';
-
 import { asyncRoute } from '../../services/express';
-const VIEW = 'view';
 
-export const reactOrView = asyncRoute(async (req, res) => {
+export const add = asyncRoute(async (req, res) => {
   const fingerprint = req.headers.fingerprint;
   const pageId = req.body.pageId || req.query.pageId;
-  const reaction = (req.body.reaction || VIEW).slice(0, 20); // Just in case, limit characters by 20 
+  const reaction = req.body.reaction.slice(0, 20); // Just in case, limit characters by 20
 
   if (!fingerprint) {
     return res.status(500).send('Fingerprint required for reacting.');
@@ -16,17 +14,27 @@ export const reactOrView = asyncRoute(async (req, res) => {
   const searchCondition = { pageId, fingerprint };
   const recordInDB = await Reaction.findOne(searchCondition);
 
-  const newReaction = recordInDB && recordInDB.reaction === reaction ? VIEW : reaction;
-  if (recordInDB && reaction !== VIEW) {
-    recordInDB.reaction = newReaction;
-    await recordInDB.save();
-  }
-
   if (!recordInDB) {
-    await new Reaction({ ...searchCondition, reaction }).save();
+    await Reaction.create({ ...searchCondition, reaction });
+  } else {
+    if (recordInDB.reaction === reaction) {
+      await Reaction.deleteOne(recordInDB);
+    } else {
+      recordInDB.reaction = reaction;
+      await recordInDB.save();
+    }
   }
 
   const reactions = await getPageData(searchCondition);
 
   return res.status(200).json(reactions);
 });
+
+export const list = asyncRoute(async (req, res) => {
+  const fingerprint = req.headers.fingerprint;
+  const pageId = req.body.pageId || req.query.pageId;
+
+  const reactions = await getPageData({ pageId, fingerprint });
+
+  return res.status(200).json(reactions);
+});

src/api/reactions/helper.js

@@ -1,9 +1,11 @@
 import Reaction from './model';
 
 export const getPageData = async ({ fingerprint, pageId }) => {
+  const userReactionPromise = Reaction.findOne({
+    fingerprint,
+    pageId
+  }).select('reaction -_id');
 
-  const userReactionPromise = Reaction.findOne({ fingerprint, pageId }).select('reaction -_id');
-  const pageViewsPromise = Reaction.find({ pageId }).count();
   const aggregationPromise = Reaction.aggregate()
     .match({
       pageId
@@ -13,11 +15,10 @@ export const getPageData = async ({ fingerprint, pageId }) => {
       count: { $count: {} }
     });
 
-  const [aggregation, userReaction, pageViews] = await Promise.all([
+  const [aggregation, userReaction] = await Promise.all([
     aggregationPromise,
-    userReactionPromise,
-    pageViewsPromise
+    userReactionPromise
   ]);
 
-  return { aggregation, userReaction, pageViews };
+  return { aggregation, userReaction };
 };

src/api/reactions/index.js

@@ -1,9 +1,9 @@
 import { Router } from 'express';
-import { reactOrView } from './controller';
+import { list, add } from './controller';
 
 const router = new Router();
 
-router.post('/', reactOrView);
-router.get('/', reactOrView);
+router.post('/', add);
+router.get('/', list);
 
 export default router;