Merge pull request #52 from andela/bg-fixes-user-notification-168170909

#168170909 fixes user notification

src/controllers/auth.controllers.js

@@ -152,6 +152,7 @@ export default {
         lastName: request.body.lastName || request.foundUser.lastName,
         bio: request.body.bio || request.foundUser.bio,
         userName: request.body.userName || request.foundUser.userName,
+        isNotified: request.body.isNotifyActive || request.foundUser.isNotified,
         twitterHandle:
           request.body.twitterHandle || request.foundUser.twitterHandle,
         facebookHandle:
@@ -167,7 +168,8 @@ export default {
         userName: updatedUser.dataValues.userName,
         twitterHandle: updatedUser.dataValues.twitterHandle,
         facebookHandle: updatedUser.dataValues.facebookHandle,
-        image: updatedUser.dataValues.image
+        image: updatedUser.dataValues.image,
+        isNotifyActive: updatedUser.dataValues.isNotified
       });
     } catch (error) {
       /* istanbul ignore next */

src/controllers/notification.controller.js

@@ -0,0 +1,21 @@
+import { fetchNotificationService } from '../services/notification.service';
+import Helper from '../services/helper';
+
+export default {
+  /**
+     * @method fetchNotification 
+       fetches all notifications
+     * 
+     * @param {*} request
+     * @param {*} response
+     */
+
+  async fetchNotification(request, response) {
+    try {
+      const value = await fetchNotificationService(request);
+      return Helper.successResponse(response, 200, value);
+    } catch (error) {
+      return error;
+    }
+  }
+};

src/routes/v1/index.js

@@ -4,6 +4,7 @@ import article from './article.route';
 import profile from './profile.route';
 import socialAuth from './social.route';
 import search from './search.route';
+import notification from './notification.route';
 
 export default app => {
   app.use(`${process.env.API_VERSION}/users`, auth);
@@ -12,4 +13,5 @@ export default app => {
   app.use(`${process.env.API_VERSION}/profiles`, profile);
   app.use(`${process.env.API_VERSION}/auth`, socialAuth);
   app.use(`${process.env.API_VERSION}/search`, search);
+  app.use(`${process.env.API_VERSION}/notifications`, notification);
 };

src/routes/v1/notification.route.js

@@ -0,0 +1,9 @@
+import express from 'express';
+import notificationController from '../../controllers/notification.controller';
+import authorization from '../../middlewares/auth.middleware';
+
+const { verifyToken } = authorization;
+const { fetchNotification } = notificationController;
+const router = express.Router();
+router.get('/', verifyToken, fetchNotification);
+export default router;

src/services/notification.service.js

@@ -34,6 +34,29 @@ const pushNotification = (receiver, message) => {
   });
 };
 
+/**
+ * @method fetchNotificationService
+ * @description method that fetches all notifications
+ *
+ * @param {Object} request receiver details
+ *
+ * @returns {Object} true or false
+ */
+export const fetchNotificationService = async request => {
+  const userId = request.user.id;
+  // notifications
+  try {
+    const findNotification = await Notification.findAll({
+      where: {
+        receiverUserId: userId
+      }
+    });
+    return findNotification;
+  } catch (error) {
+    throw Error(error);
+  }
+};
+
 /**
  * @method createNotificationMessage
  * @description persist data into the Notification table

src/services/user.service.js

@@ -202,6 +202,7 @@ export const getUserFollowersService = async userId => {
   }
   const followers = await Follow.findAll({
     where: { userId, isFollowing: true },
+    attributes: ['id'],
     include: [
       {
         model: User,