diff --git a/.gitignore b/.gitignore
index 40b878db..8b182cf8 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1 +1,25 @@
-node_modules/
\ No newline at end of file
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+/.pnp
+.pnp.js
+
+# testing
+/coverage
+
+# production
+/build
+
+# misc
+.DS_Store
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+.env
diff --git a/.sequelizerc b/.sequelizerc
new file mode 100644
index 00000000..20fef43b
--- /dev/null
+++ b/.sequelizerc
@@ -0,0 +1,8 @@
+const path = require("path");
+
+module.exports = {
+ config: path.resolve("config", "database.js"),
+ "models-path": path.resolve("db", "models"),
+ "seeders-path": path.resolve("db", "seeders"),
+ "migrations-path": path.resolve("db", "migrations"),
+};
\ No newline at end of file
diff --git a/config/database.js b/config/database.js
new file mode 100644
index 00000000..bed84df2
--- /dev/null
+++ b/config/database.js
@@ -0,0 +1,11 @@
+require("dotenv").config();
+
+module.exports = {
+ development: {
+ username: process.env.DB_USERNAME,
+ password: process.env.DB_PASSWORD,
+ database: process.env.DB_NAME,
+ host: process.env.DB_HOST,
+ dialect: process.env.DB_DIALECT,
+ },
+};
diff --git a/controllers/adminsController.js b/controllers/adminsController.js
new file mode 100644
index 00000000..b048a210
--- /dev/null
+++ b/controllers/adminsController.js
@@ -0,0 +1,59 @@
+const BaseController = require("./baseController");
+
+class AdminsController extends BaseController {
+ constructor(model) {
+ super(model);
+ }
+
+ // Create user database
+ async insertUser(req, res) {
+ const { email, name } = req.body;
+ try {
+ const output = await this.model.findOrCreate({
+ where: { email: email },
+ defaults: { name: name },
+ });
+ return res.json(output);
+ } catch (err) {
+ console.log(err.message);
+ return res.status(400).json({ error: true, msg: err.message });
+ }
+ }
+
+ async getUser(req, res) {
+ const { email } = req.body;
+ try {
+ const output = await this.model.findOne({
+ where: { email: email },
+ });
+ return res.json(output);
+ } catch (err) {
+ console.log(err.message);
+ return res.status(400).json({ error: true, msg: err.message });
+ }
+ }
+
+ async updateUserName(req, res) {
+ const { adminID } = req.params;
+ const { newName } = req.body;
+ try {
+ const admin = await this.model.findOne({
+ where: { id: adminID },
+ });
+
+ if (!admin) {
+ return res.status(404).json({ error: true, msg: "Admin not found" });
+ }
+
+ admin.name = newName;
+ await admin.save();
+
+ return res.json({ success: true, msg: "Name updated successfully" });
+ } catch (err) {
+ console.log(err.message);
+ return res.status(400).json({ error: true, msg: err.message });
+ }
+ }
+}
+
+module.exports = AdminsController;
diff --git a/controllers/baseController.js b/controllers/baseController.js
new file mode 100644
index 00000000..5f8e0960
--- /dev/null
+++ b/controllers/baseController.js
@@ -0,0 +1,18 @@
+class BaseController {
+ constructor(model) {
+ this.model = model;
+ }
+
+ async getAll(req, res) {
+ console.log(this.model);
+ try {
+ const output = await this.model.findAll();
+ return res.json(output);
+ } catch (err) {
+ console.log(err);
+ return res.status(400).json({ error: true, msg: err });
+ }
+ }
+}
+
+module.exports = BaseController;
diff --git a/controllers/bookingsController.js b/controllers/bookingsController.js
new file mode 100644
index 00000000..b48c70a4
--- /dev/null
+++ b/controllers/bookingsController.js
@@ -0,0 +1,683 @@
+const { sequelize } = require("../db/models");
+const { Op } = require("sequelize");
+const nodemailer = require("nodemailer");
+const stripe = require("stripe")(process.env.STRIPE_SECRET_KEY);
+const BaseController = require("./baseController");
+const BACKEND_URL = process.env.BACKEND_URL;
+const FRONTEND_URL = process.env.FRONTEND_URL;
+const path = require("path");
+
+class BookingsController extends BaseController {
+ constructor(model, eventModel, paymentModel, venueModel, userModel) {
+ super(model);
+ this.paymentModel = paymentModel;
+ this.eventModel = eventModel;
+ this.venueModel = venueModel;
+ this.userModel = userModel;
+ }
+
+ //check number of tickets bought per event
+ async getAvailableCapacity(req, res, next) {
+ const { eventId } = req.params;
+ try {
+ const totalTicketsBought = await this.model.sum("quantity_bought", {
+ where: {
+ eventId: eventId,
+ booking_status: "complete",
+ },
+ });
+
+ //get event capacity
+ const event = await this.eventModel.findByPk(eventId);
+ const totalCapacity = event.capacity;
+
+ // Calculate the available capacity
+ const availableCapacity = totalCapacity - totalTicketsBought;
+
+ res.json({ availableCapacity });
+ } catch (err) {
+ console.log(err);
+ next(err);
+ return res.status(400).json({ error: true, msg: err });
+ }
+ }
+
+ //create a stripe checkout session
+ async createCheckoutSession(req, res) {
+ const { eventId } = req.params;
+ const { quantity_bought } = req.body;
+ const { user_id } = req.body;
+
+ try {
+ const event = await this.eventModel.findByPk(eventId);
+
+ // Create a checkout session
+ const session = await stripe.checkout.sessions.create({
+ ui_mode: "embedded",
+ line_items: [
+ {
+ price_data: {
+ currency: "SGD",
+ product_data: {
+ name: event.title,
+ },
+ unit_amount: event.price * 100,
+ },
+ quantity: quantity_bought,
+ },
+ ],
+ mode: "payment",
+ ui_mode: "embedded",
+
+ return_url: `${FRONTEND_URL}/return?session_id={CHECKOUT_SESSION_ID}&eventId=${eventId}&quantity=${quantity_bought}&user=${user_id}`,
+ });
+ res.send({ clientSecret: session.client_secret });
+ } catch (err) {
+ console.log(err);
+ return res.status(400).json({ error: true, msg: err });
+ }
+ }
+
+ //handle success
+ async getSessionStatus(req, res) {
+ try {
+ const eventId = req.query.eventId;
+ const quantity_bought = req.query.quantity;
+ const user = req.query.user;
+
+ const session = await stripe.checkout.sessions.retrieve(
+ req.query.session_id
+ );
+ const payment_intent = session.payment_intent;
+
+ const event = await this.eventModel.findOne({ where: { id: eventId } });
+
+ // Check if payment intent is successful and whether it's already stored in the database, if not, insert a new one
+ if (session.status === "complete") {
+ const payment = await this.paymentModel.findOne({
+ where: {
+ payment_intent: payment_intent,
+ },
+ });
+ if (!payment) {
+ await this.insertOne(
+ eventId,
+ quantity_bought,
+ payment_intent,
+ user,
+ req,
+ res
+ );
+ console.log("Payment inserted successfully");
+ }
+ }
+
+ // Return the response with session status and payment status
+ let transporter = nodemailer.createTransport({
+ host: "smtp.gmail.com",
+ port: 587,
+ service: "gmail",
+ secure: false, // Use `true` for port 465, `false` for all other ports
+ auth: {
+ user: process.env.USER_APP_EMAIL,
+ pass: process.env.USER_APP_PASSWORD,
+ },
+ });
+
+ const mailOptions = {
+ from: {
+ name: "Event Link",
+ address: process.env.USER_APP_EMAIL,
+ },
+ to: session?.customer_details?.email,
+ subject: "Event Booking Email",
+ text: "Your Event booking is done.",
+ html: `
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ |
+
+ |
+
+ |
+
+
+
+
+
+
+ Your Event booking is done.
+ ${event && event.title}
+ Tickets bought: ${quantity_bought}
+ Contact Us for queries
+
+ eventlink@gmail.com
+
+ |
+
+
+ |
+
+
+