adding cron job to products (#76)

* ft clear wishList (#75)

* adding cron job to products

* adding cron job to products

* adding cron job to products

* resolving conflicts

---------

Co-authored-by: Niyonshuti Jean De Dieu <152473876+Jadowacu1@users.noreply.github.com>

src/databases/seeders/20240520202759-users.ts

@@ -31,8 +31,8 @@ const userOne = {
   role: "admin",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
-}
+  is2FAEnabled: false,
+};
 const userTwo = {
   id: userTwoId,
   createdAt: new Date(),
@@ -50,8 +50,8 @@ const userTwo = {
   role: "buyer",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
-}
+  is2FAEnabled: false,
+};
 
 const userThree = {
   id: userThreeId,
@@ -70,8 +70,8 @@ const userThree = {
   role: "buyer",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: true
-}
+  is2FAEnabled: true,
+};
 
 const userFour = {
   id: userFourId,
@@ -90,8 +90,8 @@ const userFour = {
   role: "seller",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
-}
+  is2FAEnabled: false,
+};
 
 const userFive = {
   id: userFiveId,
@@ -110,7 +110,7 @@ const userFive = {
   role: "seller",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
+  is2FAEnabled: false,
 };
 
 const userSix = {
@@ -130,7 +130,7 @@ const userSix = {
   role: "seller",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
+  is2FAEnabled: false,
 };
 
 const userSeven = {
@@ -150,7 +150,7 @@ const userSeven = {
   role: "seller",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
+  is2FAEnabled: false,
 };
 
 const userEight = {
@@ -170,8 +170,8 @@ const userEight = {
   role: "buyer",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
-}
+  is2FAEnabled: false,
+};
 const userNine = {
   id: userNineId,
   createdAt: new Date(),
@@ -189,8 +189,8 @@ const userNine = {
   role: "nurse",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
-}
+  is2FAEnabled: false,
+};
 
 const userTen = {
   id: userTenId,
@@ -209,12 +209,12 @@ const userTen = {
   role: "buyer",
   status: "enabled",
   isVerified: true,
-  is2FAEnabled: false
-}
+  is2FAEnabled: false,
+};
 
 export const up = (queryInterface: QueryInterface) =>
   queryInterface.bulkInsert("users", [
-    userOne, 
+    userOne,
     userTwo,
     userThree,
     userFour,
@@ -223,9 +223,9 @@ export const up = (queryInterface: QueryInterface) =>
     userSeven,
     userEight,
     userNine,
-    userTen
+    userTen,
   ]);
 
 export const down = async (queryInterface: QueryInterface) => {
   await queryInterface.bulkDelete("users", {});
-};
+};

src/databases/seeders/20240601224835-products.ts

@@ -12,7 +12,8 @@ const productOne = {
   id: productOneId,
   shopId: shopOneId,
   name: "Lotion",
-  description: "Our luxurious lotion store, offering a curated selection of nourishing formulas designed to hydrate and pamper. From silky-smooth textures to delightful fragrances, experience the ultimate in skincare indulgence at our boutique",
+  description:
+    "Our luxurious lotion store, offering a curated selection of nourishing formulas designed to hydrate and pamper. From silky-smooth textures to delightful fragrances, experience the ultimate in skincare indulgence at our boutique",
   price: 19.99,
   discount: "10%",
   category: "Cosmetics",
@@ -30,7 +31,8 @@ const productTwo = {
   id: productTwoId,
   shopId: shopTwoId,
   name: "Pizza",
-  description: "Our authentic pizza store, where each slice is crafted with love and tradition. From classic Margherita to adventurous toppings, indulge in a culinary journey that delights the senses.",
+  description:
+    "Our authentic pizza store, where each slice is crafted with love and tradition. From classic Margherita to adventurous toppings, indulge in a culinary journey that delights the senses.",
   price: 19.99,
   discount: "10%",
   category: "Food",
@@ -48,7 +50,8 @@ const productThree = {
   id: productThreeId,
   shopId: shopTwoId,
   name: "Fanta",
-  description: "Our Fanta store, where fizzy refreshment meets bold fruit sensations. From tangy orange to exotic tropical blends, quench your thirst with our vibrant array of sodas.",
+  description:
+    "Our Fanta store, where fizzy refreshment meets bold fruit sensations. From tangy orange to exotic tropical blends, quench your thirst with our vibrant array of sodas.",
   price: 19.99,
   discount: "10%",
   category: "Drinks",

src/helpers/updateExpiredProducts.ts

@@ -0,0 +1,71 @@
+import Product from "../databases/models/products";
+import { Op } from "sequelize";
+import { sendEmail } from "../services/sendEmail";
+import Shop from "../databases/models/shops";
+import User from "../databases/models/users";
+
+const updateExpiredProducts = async () => {
+  try {
+    const expiredProducts = await Product.findAll({
+      where: {
+        expiryDate: { [Op.lt]: new Date() },
+        expired: false
+      },
+      attributes: ["id", "shopId", "name"]
+    });
+
+    for (const product of expiredProducts) {
+      await product.update({
+        expired: true,
+        status: "unavailable"
+      });
+    }
+
+    const shopIds = expiredProducts.map((product) => product.shopId);
+    const shops = await Shop.findAll({
+      where: {
+        id: {
+          [Op.in]: shopIds
+        }
+      },
+      attributes: ["id", "userId"]
+    });
+
+    const userIds = shops.map((shop) => shop.userId);
+
+    const users = await User.findAll({
+      where: {
+        id: {
+          [Op.in]: userIds
+        }
+      },
+      attributes: ["id", "email", "firstName"]
+    });
+
+    const userMap = {};
+    users.forEach((user) => {
+      userMap[user.id] = {
+        email: user.email,
+        firstName: user.firstName
+      };
+    });
+
+    for (const product of expiredProducts) {
+      const UserShop = shops.find((shop) => shop.id === product.shopId);
+      if (UserShop) {
+        const user = userMap[UserShop.userId];
+        if (user) {
+          await sendEmail(
+            user.email,
+            "Product Expired",
+            `Dear ${user.firstName}, your product ${product.name} has expired and now is unavailable.`
+          );
+        }
+      }
+    }
+  } catch (error) {
+    console.error("Error updating expired products:", error.message);
+  }
+};
+
+export default updateExpiredProducts;

src/index.ts

@@ -10,6 +10,7 @@ import httpStatus from "http-status";
 import chat from "./services/chat";
 import { createServer } from "http";
 import { Server } from "socket.io";
+import "./services/cronJob"
 
 dotenv.config();
 
@@ -38,6 +39,8 @@ app.get("**", (req: Request, res: Response) => {
     message: "Welcome to the e-Commerce Ninjas BackEnd."
   });
 });
+
+
 server.listen(PORT, () => {
   console.log(`Server is running on the port ${PORT}`);
 });

src/modules/product/test/product.spec.ts

@@ -16,6 +16,11 @@ import userRepositories from "../../user/repository/userRepositories";
 import userControllers from "../../user/controller/userControllers";
 import authRepositories from "../../auth/repository/authRepositories";
 import { ExtendRequest } from "../../../types";
+import Product from "../../../databases/models/products";
+import Shop from "../../../databases/models/shops";
+import User from "../../../databases/models/users";
+import { sendEmail, transporter } from "../../../services/sendEmail";
+import updateExpiredProducts from "../../../helpers/updateExpiredProducts";
 
 chai.use(chaiHttp);
 const router = () => chai.request(app);
@@ -1176,4 +1181,79 @@ describe("Wishlist Routes", () => {
       expect(res.json.calledWith({ message: "Internal server error", error: errorMessage })).to.be.true;
     });
   });
+});
+
+describe("updateExpiredProducts", () => {
+  let req: Partial<Request>;
+  let res: Partial<Response>;
+  let productFindAllStub: sinon.SinonStub;
+  let productUpdateStub: sinon.SinonStub;
+  let shopFindAllStub: sinon.SinonStub;
+  let userFindAllStub: sinon.SinonStub;
+
+  beforeEach(() => {
+    req = {};
+    res = {
+      status: sinon.stub().returnsThis(),
+      json: sinon.stub().returnsThis()
+    };
+
+    productFindAllStub = sinon.stub(Product, "findAll");
+    productUpdateStub = sinon.stub();
+    shopFindAllStub = sinon.stub(Shop, "findAll");
+    userFindAllStub = sinon.stub(User, "findAll");
+
+    Product.prototype.update = productUpdateStub;
+  });
+
+  afterEach(() => {
+    sinon.restore();
+  });
+
+  it("should update expired products and send emails to the respective users", async () => {
+    const expiredProducts = [
+      {
+        id: "productId1",
+        shopId: "shopId1",
+        name: "Product1",
+        update: productUpdateStub
+      },
+      {
+        id: "productId2",
+        shopId: "shopId2",
+        name: "Product2",
+        update: productUpdateStub
+      }
+    ];
+
+    const shops = [
+      { id: "shopId1", userId: "userId1" },
+      { id: "shopId2", userId: "userId2" }
+    ];
+
+    const users = [
+      { id: "userId1", email: "user1@example.com", firstName: "User1" },
+      { id: "userId2", email: "user2@example.com", firstName: "User2" }
+    ];
+
+    productFindAllStub.onFirstCall().resolves(expiredProducts);
+    shopFindAllStub.resolves(shops);
+    userFindAllStub.resolves(users);
+
+    await updateExpiredProducts();
+
+    expect(productFindAllStub).to.have.been.calledOnce;
+    expect(productUpdateStub).to.have.been.calledTwice;
+    expect(shopFindAllStub).to.have.been.calledOnce;
+    expect(userFindAllStub).to.have.been.calledOnce;
+    expect(res.status).not.to.have.been.called;
+    expect(res.json).not.to.have.been.called;
+  });
+
+  it("should return 500 if an error occurs", async () => {
+    productFindAllStub.rejects(new Error("Internal Server Error"));
+
+    await updateExpiredProducts();
+    expect(productFindAllStub).to.have.been.calledOnce;
+  });
 });

src/services/cronJob.ts

@@ -0,0 +1,15 @@
+import cron from "node-cron";
+import updateExpiredProducts from "../helpers/updateExpiredProducts";
+
+cron.schedule(
+  "0 6 * * *",
+  async () => {
+    try {
+      console.log("Cron Job Started..");
+      await updateExpiredProducts();
+    } catch (error) {
+      console.error(`Something wrong occured " ${error.toString()} "`);
+    }
+  },
+  { scheduled: true, timezone: "Asia/Kolkata" }
+);