Project 3 - Ecommerce App (Marina and Ian)

.gitignore

@@ -1 +1,3 @@
-node_modules/
+node_modules/
+
+.env

.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'),
+};

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,
+  },
+};

controllers/addressesController.js

@@ -0,0 +1,119 @@
+const BaseController = require('./baseController');
+const { QueryTypes } = require('sequelize'); // Import DataTypes and QueryTypes
+
+class AddressesController extends BaseController {
+  constructor(model, userModel) {
+    super(model);
+    this.userModel = userModel;
+  }
+
+  async getAllAddresses(req, res) {
+    try {
+      const address = await this.model.sequelize.query(
+        `SELECT "id", "buyer_id", "address", "created_at" AS "createdAt", "updated_at" AS "updatedAt", "buyer_id" AS "user_id" FROM "addresses"`,
+        {
+          type: this.model.sequelize.QueryTypes.SELECT,
+        },
+      );
+
+      return res.json(address); // Assuming you expect only one address
+    } catch (err) {
+      console.error(err);
+      return res.status(400).send(err);
+    }
+  }
+
+  // Get a single address
+  async getAddress(req, res) {
+    const { addressId } = req.params;
+    try {
+      const address = await this.model.sequelize.query(
+        `SELECT "id", "buyer_id", "address", "created_at" AS "createdAt", "updated_at" AS "updatedAt", "buyer_id" AS "user_id" FROM "addresses" WHERE "id" = :addressId`,
+        {
+          replacements: { addressId },
+          type: this.model.sequelize.QueryTypes.SELECT,
+        },
+      );
+      return res.json(address[0]); // Assuming you expect only one address
+    } catch (err) {
+      console.error(err);
+      return res.status(400).send(err);
+    }
+  }
+
+  async getAddressIdBasedOnActualAddress(req, res) {
+    const { delivery_address } = req.query;
+
+    try {
+      const address = await this.model.findOne({
+        where: {
+          address: delivery_address,
+        },
+      });
+
+      return res.status(200).json(address.id);
+    } catch (err) {
+      console.error(err);
+      return res.status(400).json({ error: true, msg: err });
+    }
+  }
+
+  async postNewAddress(req, res) {
+    const { email, address } = req.body;
+
+    const allAddresses = await this.model.sequelize.query(
+      `SELECT "id", "buyer_id", "address", "created_at" AS "createdAt", "updated_at" AS "updatedAt", "buyer_id" AS "user_id" FROM "addresses"`,
+      {
+        type: this.model.sequelize.QueryTypes.SELECT,
+      },
+    );
+
+    const arrayOfAddresses = allAddresses.map(
+      (singleAddress) => singleAddress.address,
+    );
+
+    if (!arrayOfAddresses.includes(address)) {
+      try {
+        const [buyer] = await this.userModel.findOrCreate({
+          where: { email: email },
+        });
+
+        const queryResult = await this.model.sequelize.query(
+          'INSERT INTO "addresses" ("buyer_id", "address", "created_at", "updated_at") VALUES ($1, $2, $3, $4) RETURNING "id", "buyer_id", "address", "created_at", "updated_at"',
+          {
+            bind: [buyer.id, address, new Date(), new Date()],
+            type: QueryTypes.INSERT,
+          },
+        );
+
+        const newAddress = queryResult[0];
+
+        return res.json(newAddress);
+      } catch (err) {
+        console.error(err);
+        return res.status(400).json({ error: true, msg: err.message });
+      }
+    } else {
+      return res.send('Address already exists!');
+    }
+  }
+
+  async deleteOne(req, res) {
+    const { addressId } = req.params;
+
+    try {
+      await this.model.destroy({
+        where: {
+          id: addressId,
+        },
+      });
+
+      res.status(200).send(`Successfully deleted address at id ${addressId}`);
+    } catch (error) {
+      console.error(error);
+      res.status(400).send({ error: true, msg: error });
+    }
+  }
+}
+
+module.exports = AddressesController;

controllers/baseController.js

@@ -0,0 +1,16 @@
+class BaseController {
+  constructor(model) {
+    this.model = model;
+  }
+
+  async getAll(req, res) {
+    try {
+      const output = await this.model.findAll();
+      return res.json(output);
+    } catch (err) {
+      return res.status(400).json({ error: true, msg: err });
+    }
+  }
+}
+
+module.exports = BaseController;

controllers/categoriesController.js

@@ -0,0 +1,70 @@
+const BaseController = require('./baseController');
+
+class CategoriesController extends BaseController {
+  constructor(model, productModel) {
+    super(model);
+    this.productModel = productModel;
+  }
+
+  async getOne(req, res) {
+    const { categoryId } = req.params;
+
+    try {
+      const category = await this.model.findByPk(categoryId);
+
+      res.send(category);
+    } catch (err) {
+      res.status(400).json({ error: true, msg: err });
+    }
+  }
+
+  async postOne(req, res) {
+    const { name } = req.body;
+
+    try {
+      const newCategory = await this.model.create({
+        name: name,
+      });
+
+      res.send(newCategory);
+    } catch (err) {
+      res.status(400).json({ error: true, msg: err });
+    }
+  }
+
+  async updateOne(req, res) {
+    const { categoryId } = req.params;
+
+    const { name } = req.body;
+
+    try {
+      const categoryToBeUpdated = await this.model.findByPk(categoryId);
+
+      const updatedCategory = await categoryToBeUpdated.update({
+        name: name,
+      });
+
+      res.send(updatedCategory);
+    } catch (err) {
+      return res.status(400).json({ error: true, msg: err });
+    }
+  }
+
+  async deleteOne(req, res) {
+    const { categoryId } = req.params;
+
+    try {
+      await this.model.destroy({
+        where: {
+          id: categoryId,
+        },
+      });
+
+      res.send('Category has been deleted!');
+    } catch (err) {
+      res.status(400).json({ error: true, msg: err });
+    }
+  }
+}
+
+module.exports = CategoriesController;

controllers/ordersController.js

@@ -0,0 +1,143 @@
+const BaseController = require('./baseController');
+const Sequelize = require('sequelize');
+const sequelize = new Sequelize(
+  `postgres://${process.env.DB_USERNAME}:@${process.env.DB_HOST}:5432/${process.env.DB_NAME}`,
+);
+
+class OrdersController extends BaseController {
+  constructor(model, userModel, productModel, orderProductModel, addressModel) {
+    super(model);
+    this.userModel = userModel;
+    this.productModel = productModel;
+    this.orderProductModel = orderProductModel;
+    this.addressModel = addressModel;
+  }
+
+  async getAllOrdersOfCurrUser(req, res) {
+    const { email } = req.query;
+    try {
+      const user = await this.userModel.findOrCreate({
+        where: { email: email },
+      });
+      const user_id = user[0].dataValues.id;
+      const orders = await this.model.findAll({
+        where: { user_id: user_id },
+        include: [
+          {
+            model: this.productModel,
+            attributes: ['id', 'title', 'price', 'img'],
+            through: {
+              model: this.orderProductModel,
+              attributes: ['quantity'],
+            },
+          },
+          { model: this.addressModel, attributes: ['address'] },
+        ],
+      });
+      return res.json(orders);
+    } catch (err) {
+      return res.status(400).json({ error: true, msg: err.message });
+    }
+  }
+
+  async postOne(req, res) {
+    const { address_id, user_id, total_price, products } = req.body;
+
+    if (!products || products.length === 0) {
+      return res
+        .status(400)
+        .json({ error: true, msg: 'No products in the order' });
+    }
+
+    try {
+      await sequelize.transaction(async (t) => {
+        const newOrder = await this.model.create(
+          {
+            address_id: address_id,
+            user_id: user_id,
+            total_price: total_price,
+          },
+          { transaction: t },
+        );
+
+        const arrayOfJunctionTableEntries = [];
+        for (let i = 0; i < products.length; i++) {
+          const productObj = products[i];
+          const [id, quantity] = Object.entries(productObj)[0];
+          const newEntryInOrderProducts = await this.orderProductModel.create(
+            {
+              order_id: newOrder.dataValues.id,
+              product_id: id,
+              quantity: quantity,
+            },
+            { transaction: t },
+          );
+          arrayOfJunctionTableEntries.push(newEntryInOrderProducts);
+        }
+
+        const purchasedProducts = [];
+
+        for (let i = 0; i < products.length; i++) {
+          const productObj = products[i];
+          const [id, quantity] = Object.entries(productObj)[0];
+
+          const product = await this.productModel.findByPk(id);
+
+          const stock = product.dataValues.stock_left;
+
+          const stock_left = stock - quantity;
+
+          const updatedProduct = await product.update(
+            { stock_left: stock_left },
+            { transaction: t },
+          );
+
+          purchasedProducts.push(updatedProduct);
+        }
+
+        return res.send([
+          newOrder,
+          arrayOfJunctionTableEntries,
+          purchasedProducts,
+        ]);
+      });
+    } catch (err) {
+      console.error(err.message);
+      return res.status(400).json({ error: true, msg: err });
+    }
+  }
+
+  async getOne(req, res) {
+    const { orderId } = req.params;
+
+    const order = await this.model.findByPk(orderId, {
+      include: [
+        {
+          association: 'products',
+        },
+        { model: this.addressModel, attributes: ['address'] },
+      ],
+    });
+
+    return res.send(order);
+  }
+
+  async deleteOne(req, res) {
+    const { orderId } = req.params;
+
+    try {
+      await this.model.destroy({
+        where: {
+          id: orderId,
+        },
+      });
+
+      res.status(200).send('Success:');
+    } catch (error) {
+      console.error(error);
+      res.status(400).send({ error: true, msg: error });
+    }
+  }
+}
+
+module.exports = OrdersController;