send push notification and update FCM token on zoho

Author: web-dev-akash

.gitignore

@@ -0,0 +1,7 @@
+node_modules
+logs.json
+token.json
+.env
+key.json
+dropbox.json
+key2.json

components/student.component.js

@@ -8,6 +8,12 @@ const moment = require("moment");
 const nodemailer = require("nodemailer");
 const pLimit = require("p-limit");
 const limit = pLimit(20);
+const admin = require("firebase-admin");
+const serviceAccount = require("../key2.json");
+
+admin.initializeApp({
+  credential: admin.credential.cert(serviceAccount),
+});
 
 const getStudentDetails = async (email) => {
   try {
@@ -841,6 +847,23 @@ const getTestSeriesDoubtSessions = async (grade) => {
   }
 };
 
+const sendNotification = async (message, userTokens) => {
+  try {
+    const payload = {
+      notification: {
+        title: message.title,
+        body: message.body,
+      },
+      tokens: userTokens,
+    };
+
+    const response = await admin.messaging().sendEachForMulticast(payload);
+    return response;
+  } catch (error) {
+    return error;
+  }
+};
+
 const getStoryForUsers = async (grade) => {
   try {
     return {
@@ -853,6 +876,47 @@ const getStoryForUsers = async (grade) => {
   }
 };
 
+const updateTokenForUser = async (email, token) => {
+  try {
+    const accessToken = await getZohoTokenOptimized();
+    const zohoConfig = {
+      headers: {
+        "Content-Type": "application/json",
+        "Access-Control-Allow-Origin": "*",
+        Authorization: `Bearer ${accessToken}`,
+      },
+    };
+    const updateTokenBody = {
+      data: [
+        {
+          Email: email,
+          FCM_TOKEN: token,
+        },
+      ],
+      duplicate_check_fields: ["Email"],
+      apply_feature_execution: [
+        {
+          name: "layout_rules",
+        },
+      ],
+      trigger: [],
+    };
+
+    const updateData = await axios.post(
+      `https://www.zohoapis.com/crm/v6/Contacts/upsert`,
+      updateTokenBody,
+      zohoConfig
+    );
+
+    return {
+      status: 200,
+      message: "success",
+    };
+  } catch (error) {
+    return error;
+  }
+};
+
 module.exports = {
   getStudentDetails,
   getStudentOrders,
@@ -864,4 +928,6 @@ module.exports = {
   getTestSeriesByGrade,
   getTestSeriesDoubtSessions,
   getStoryForUsers,
+  sendNotification,
+  updateTokenForUser,
 };

controllers/student.controller.js

@@ -10,6 +10,8 @@ const {
   getTestSeriesByGrade,
   getTestSeriesDoubtSessions,
   getStoryForUsers,
+  sendNotification,
+  updateTokenForUser,
 } = require("../components/student.component");
 const {
   getZohoTokenOptimized,
@@ -178,6 +180,40 @@ studentRouter.post("/feedback", authMiddleware, async (req, res) => {
   }
 });
 
+studentRouter.post("/feedback", authMiddleware, async (req, res) => {
+  try {
+    const reqData = req.body;
+    const data = await sendStudentFeedback(reqData);
+    return res.status(200).send(data);
+  } catch (error) {
+    return res.status(error.status || 500).send({
+      status: "error",
+      message: error.message,
+      code: error.status || 500,
+    });
+  }
+});
+
+studentRouter.post("/send-notification", authMiddleware, async (req, res) => {
+  try {
+    const { message, tokens } = req.body;
+    const data = await sendNotification(message, tokens);
+    return res.status(200).send(data);
+  } catch (error) {
+    return res.status(500).send("Internal Server Error");
+  }
+});
+
+studentRouter.post("/update-fcm-token", authMiddleware, async (req, res) => {
+  try {
+    const { email, token } = req.body;
+    const data = await updateTokenForUser(email, token);
+    return res.status(200).send(data);
+  } catch (error) {
+    return res.status(500).send("Internal Server Error");
+  }
+});
+
 studentRouter.post(
   "/update-analysis-sheet",
   authMiddleware,