⏰ Add cron job to delete expired pro entires (#yoginth/eng-101-add-cr…

…on-job-to-delete-expired-pro-entires)

Summary: Added a cron job to delete expired pro entries.

Highlights:

• Created `cleanExpiredPro.ts` to delete expired pro entries using Prisma.
• Integrated `cleanExpiredPro` into the cron job scheduler in `index.ts` to run every 5 minutes.

Read more: https://pierre.co/hey/hey/yoginth/eng-101-add-cron-job-to-delete-expired-pro-entires

apps/cron/src/cleanExpiredPro.ts

@@ -0,0 +1,16 @@
+import prisma from "@hey/db/prisma/db/client";
+import logger from "@hey/helpers/logger";
+
+const cleanExpiredPro = async () => {
+  try {
+    await prisma.pro.deleteMany({
+      where: { expiresAt: { lt: new Date() } }
+    });
+
+    logger.info("[Cron] cleanExpiredPro - Cleaned up expired pro");
+  } catch (error) {
+    logger.error("[Cron] cleanExpiredPro - Error cleaning expired pro", error);
+  }
+};
+
+export default cleanExpiredPro;

apps/cron/src/index.ts

@@ -6,6 +6,7 @@ import batchProcessEvents from "./batchProcessEvents";
 import batchProcessImpressions from "./batchProcessImpressions";
 import cleanClickhouse from "./cleanClickhouse";
 import cleanEmailTokens from "./cleanEmailTokens";
+import cleanExpiredPro from "./cleanExpiredPro";
 import cleanPreferences from "./cleanPreferences";
 import dbVacuum from "./dbVacuum";
 import heartbeat from "./heartbeat";
@@ -39,6 +40,11 @@ const startCronJobs = () => {
     return;
   });
 
+  cron.schedule("*/5 * * * *", async () => {
+    await cleanExpiredPro();
+    return;
+  });
+
   cron.schedule("0 */6 * * *", async () => {
     await dbVacuum();
     return;