Merge pull request #2425 from airqo-platform/hotfix-schedule-sim-status

scheduling daily SIM status checks

src/incentives/bin/cronJob.js

@@ -0,0 +1,58 @@
+const cron = require("node-cron");
+const SimModel = require("@models/Sim");
+const constants = require("@config/constants");
+const log4js = require("log4js");
+const logger = log4js.getLogger(
+  `${constants.ENVIRONMENT} -- bin/cronJob script`
+);
+const checkStatus = require("@utils/create-sim").checkStatus;
+const secondsDelayBetweenRequests = 20000;
+const internetDataBalanceThreshold = 5;
+
+// Everyday at midnight
+cron.schedule("0 0 * * *", async () => {
+  try {
+    const batchSize = 100; // Process 100 SIM cards at a time
+    let skip = 0;
+
+    const simCards = await SimModel("airqo").find({}).select("_id").lean();
+
+    while (true) {
+      const simBatch = simCards.slice(skip, skip + batchSize);
+
+      if (simBatch.length === 0) {
+        break;
+      }
+
+      await processSimCardsWithDelay(simBatch);
+
+      skip += batchSize;
+    }
+  } catch (error) {
+    logger.error(
+      `An error occurred in the cron job --- ${JSON.stringify(error)}`
+    );
+  }
+});
+
+async function processSimCardsWithDelay(simBatch) {
+  for (const sim of simBatch) {
+    const responseFromCheckStatus = await checkStatus({
+      query: { tenant: "airqo" },
+      params: { sim_id: sim._id },
+    });
+
+    // Check if data.balance is less than the declared threshold and log it
+    if (
+      responseFromCheckStatus.success &&
+      responseFromCheckStatus.data.balance < internetDataBalanceThreshold
+    ) {
+      logger.info(
+        `SIM card ${sim._id} has a balance less than ${internetDataBalanceThreshold}`
+      );
+    }
+    await new Promise((resolve) =>
+      setTimeout(resolve, secondsDelayBetweenRequests)
+    );
+  }
+}

src/incentives/package.json

@@ -54,6 +54,7 @@
         "mongoose-unique-validator": "^2.0.3",
         "morgan": "~1.9.0",
         "mtn-momo": "^2.0.0",
+        "node-cron": "^3.0.2",
         "node-fetch": "^2.6.1",
         "node-schedule": "^2.1.1",
         "nodemailer": "^6.9.4",