#Ft: Migrate to sendGrid and Add notifications with Socket

package.json

@@ -34,6 +34,7 @@
   "homepage": "https://github.com/denislohan/codehills-be#readme",
   "dependencies": {
     "@babel/cli": "^7.20.7",
+    "@sendgrid/mail": "^8.1.1",
     "cors": "^2.8.5",
     "coveralls": "^3.1.1",
     "cron": "^2.3.0",
@@ -50,6 +51,7 @@
     "pg": "^8.9.0",
     "pg-hstore": "^2.3.4",
     "sequelize": "^6.29.0",
+    "socket.io": "^4.7.5",
     "source-map": "^0.7.4",
     "swagger-ui-express": "^4.6.1",
     "valibot": "^0.30.0"

src/app.js

@@ -1,5 +1,6 @@
 /* eslint-disable no-undef */
 import express from "express";
+import * as http from "http";
 import session from "express-session";
 import dotenv from "dotenv";
 import cors from "cors";
@@ -8,12 +9,20 @@ import router from "./restful/routes/index";
 import fileUploader from "express-fileupload";
 import { associate } from "./database/relationships";
 import { passport } from "./restful/routes/authRouters";
+import {
+  listenToUserProjectAssigned,
+  listenToLeadProjectAssigned,
+} from "./system/utils/listenToEvent";
+import { SocketUtil } from "./system/utils/SocketUtil";
 import cronJob from "./system/utils/cronjob";
+
 dotenv.config();
 
 const PORT = process.env.PORT || 4000;
 
 const app = express();
+const server = http.createServer(app);
+SocketUtil.config(server);
 cronJob();
 app.use(express.urlencoded({ extended: false }));
 app.use(cors());
@@ -47,7 +56,7 @@ const initializeDatabase = async () => {
 const start = () => {
   try {
     initializeDatabase();
-    app.listen({ port: PORT }, () =>
+    server.listen({ port: PORT }, () =>
       process.stdout.write(`http://localhost:${PORT} \n`)
     );
   } catch (error) {

src/database/relationships/index.js

@@ -102,6 +102,10 @@ export const associate = () => {
   DB.FieldReview.belongsTo(DB.RatingField, {
     foreignKey: "ratingFieldId",
     as: "ratingField",
+  });
+  DB.Notification.belongsTo(DB.User, {
+    foreignKey: "userId",
+    as: "user",
     onDelete: "CASCADE",
   });
 };

src/documentation/index.js

@@ -9,6 +9,7 @@ import search from "./search";
 import dashboard from "./auth/dashboard";
 import ratingCategories from "./ratingCategory";
 import ratingFields from "./ratingField";
+import notification from "./notification";
 
 const defaults = swaggerDoc.paths;
 
@@ -30,6 +31,7 @@ const paths = {
   ...search,
   ...ratingCategories,
   ...ratingFields,
+  ...notification,
 };
 
 const config = {