feat: update quotation status on expired

src/app.ts

@@ -7,6 +7,7 @@ import { RegisterRoutes } from "./routes";
 import { initThailandAreaDatabase } from "./utils/thailand-area";
 import { initFirstAdmin } from "./utils/database";
 import { apiReference } from "@scalar/express-api-reference";
+import { initSchedule } from "./services/schedule";
 
 const APP_HOST = process.env.APP_HOST || "0.0.0.0";
 const APP_PORT = +(process.env.APP_PORT || 3000);
@@ -17,6 +18,8 @@ const APP_PORT = +(process.env.APP_PORT || 3000);
   await initThailandAreaDatabase();
   await initFirstAdmin();
 
+  initSchedule();
+
   const originalSend = app.response.json;
 
   app.response.json = function (body: unknown) {

src/services/schedule.ts

@@ -0,0 +1,25 @@
+import { CronJob } from "cron";
+
+import prisma from "../db";
+
+const jobs = [
+  CronJob.from({
+    cronTime: "0 0 0 * * *",
+    runOnInit: true,
+    onTick: async () => {
+      await prisma.quotation
+        .updateMany({
+          where: {
+            dueDate: { lte: new Date() },
+          },
+          data: { quotationStatus: "Expired" },
+        })
+        .then(() => console.log("[INFO]: Update expired quotation status, OK."))
+        .catch((e) => console.error(e));
+    },
+  }),
+];
+
+export function initSchedule() {
+  for (const job of jobs) job.start();
+}