Email service

config/database.js

@@ -1,9 +1,16 @@
-const { Sequelize } = require('sequelize');
 require('dotenv').config();
+const Sequelize = require('sequelize');
+const pg = require('pg');
 
-const sequelize = new Sequelize(process.env.DB_NAME, process.env.DB_USER, process.env.DB_PASSWORD, {
-    host: process.env.DB_HOST,
-    dialect: 'postgres',
-});
+const sequelize = new Sequelize(
+  process.env.DB_NAME,
+  process.env.DB_USER,
+  process.env.DB_PASSWORD,
+  {
+    host: "localhost",
+    dialect: "postgres",
+    dialectModule: pg,
+  }
+)
 
-module.exports = sequelize;
+module.exports = sequelize;

config/emailConfig.js

@@ -0,0 +1,12 @@
+const nodemailer= require('nodemailer');
+
+
+const transporter = nodemailer.createTransport({
+    service: 'Gmail',
+    auth: {
+        user: process.env.EMAIL_ID,
+        pass: process.env.EMAIL_PASS
+    }
+});
+
+module.exports =    transporter;

controllers/authController.js

@@ -9,6 +9,7 @@ const registerUser = async (req, res) => {
         const hashedPassword = await bcrypt.hash(req.body.password, 10);
         const user = await User.create({
             username: req.body.username,
+            email: req.body.email,
             password: hashedPassword,
             role: req.body.role
         });

controllers/bookingController.js

@@ -2,6 +2,7 @@ const sequelize = require('../config/database');
 const Booking = require('../models/booking');
 const Train = require('../models/train'); 
 const User = require("../models/user")
+const sendBasicEmail = require('../utils/emailService');
 
 const bookSeat = async (req, res) => {
     const { train_id } = req.body;
@@ -16,10 +17,13 @@ const bookSeat = async (req, res) => {
     try {
         const train = await Train.findByPk(train_id, { transaction: t });
         if (!train) {
+            console.log('Could not find train');
             await t.rollback(); 
             return res.status(404).json({ message: 'Train not found' });
         }
+
         if (train.available_seats > 0) {
+
             train.available_seats -= 1;
             await train.save({ transaction: t });
 
@@ -28,7 +32,19 @@ const bookSeat = async (req, res) => {
                 TrainId: train_id
             }, { transaction: t });
 
-            await t.commit();
+            await t.commit(); 
+
+             // Send email to the user
+           try{
+            const user = await User.findByPk(userId);
+            const mailSubject = 'Booking Confirmation';
+            const mailBody = `Dear ${user.username},\n\nYour booking has been confirmed. Details:\nBooking ID: ${booking.id}\nBooking Time: ${booking.booking_time}\nTrain Name: ${train.train_name}\nSource: ${train.source}\nDestination: ${train.destination}\n\nThank you for choosing our service.`;
+            await sendBasicEmail(user.email, mailSubject, mailBody);
+            console.log('Email sent');
+           }
+           catch(error){
+            console.log('Error sending email',error);
+           }
             res.status(201).json(booking);
         } else {
             await t.rollback();

models/user.js

@@ -7,6 +7,11 @@ const User = sequelize.define('User', {
         autoIncrement: true,
         primaryKey: true
     },
+    email:{
+        type: DataTypes.STRING,
+        unique: true,
+        allowNull: false
+    },
     username: {
         type: DataTypes.STRING,
         unique: true,

package.json

@@ -16,10 +16,14 @@
     "cors": "^2.8.5",
     "dotenv": "^16.4.5",
     "express": "^4.19.2",
+    "i": "^0.3.7",
+    "iconv-lite": "^0.6.3",
     "jsonwebtoken": "^9.0.2",
+    "nodemailer": "^6.9.13",
     "nodemon": "^3.1.0",
     "pg": "^8.11.5",
     "pg-hstore": "^2.3.4",
+    "pg-types": "^4.0.2",
     "sequelize": "^6.37.3"
   }
 }

utils/emailService.js

@@ -0,0 +1,20 @@
+const transporter = require('../config/emailConfig');
+
+
+const sendBasicEmail = async ( mailTo, mailSubject, mailBody) => {
+    try {
+        const response = await transporter.sendMail({
+            from: {
+                name: 'IRCTC Backend Service',
+                address: "[email protected]"
+            },
+            to: mailTo,
+            subject: mailSubject,
+            text: mailBody
+        });
+    } catch (error) {
+        console.log(error);
+    }
+}
+
+module.exports = sendBasicEmail;