move to production

k8s/auth-service/values-prod.yaml

@@ -6,7 +6,7 @@ app:
 replicaCount: 3
 image:
   repository: eu.gcr.io/airqo-250220/airqo-auth-api
-  tag: prod-d831e59b-1736322897
+  tag: prod-a8a141f1-1736326087
 nameOverride: ''
 fullnameOverride: ''
 podAnnotations: {}

k8s/auth-service/values-stage.yaml

@@ -6,7 +6,7 @@ app:
 replicaCount: 2
 image:
   repository: eu.gcr.io/airqo-250220/airqo-stage-auth-api
-  tag: stage-5d451842-1736194286
+  tag: stage-7edfc2f7-1736401595
 nameOverride: ''
 fullnameOverride: ''
 podAnnotations: {}

k8s/device-registry/values-prod.yaml

@@ -6,7 +6,7 @@ app:
 replicaCount: 3
 image:
   repository: eu.gcr.io/airqo-250220/airqo-device-registry-api
-  tag: prod-d831e59b-1736322897
+  tag: prod-a8a141f1-1736326087
 nameOverride: ''
 fullnameOverride: ''
 podAnnotations: {}

k8s/device-registry/values-stage.yaml

@@ -6,7 +6,7 @@ app:
 replicaCount: 2
 image:
   repository: eu.gcr.io/airqo-250220/airqo-stage-device-registry-api
-  tag: stage-4ca1c803-1736183154
+  tag: stage-4a24d391-1736401971
 nameOverride: ''
 fullnameOverride: ''
 podAnnotations: {}

k8s/exceedance/values-prod-airqo.yaml

@@ -4,6 +4,6 @@ app:
   configmap: env-exceedance-production
 image:
   repository: eu.gcr.io/airqo-250220/airqo-exceedance-job
-  tag: prod-d831e59b-1736322897
+  tag: prod-a8a141f1-1736326087
 nameOverride: ''
 fullnameOverride: ''

k8s/exceedance/values-prod-kcca.yaml

@@ -4,6 +4,6 @@ app:
   configmap: env-exceedance-production
 image:
   repository: eu.gcr.io/airqo-250220/kcca-exceedance-job
-  tag: prod-d831e59b-1736322897
+  tag: prod-a8a141f1-1736326087
 nameOverride: ''
 fullnameOverride: ''

k8s/meta-data/values-prod.yaml

@@ -8,7 +8,7 @@ images:
   repositories:
     api: eu.gcr.io/airqo-250220/airqo-meta-data-api
     sitesConsumer: eu.gcr.io/airqo-250220/airqo-meta-data-sites-consumer
-  tag: prod-d831e59b-1736322897
+  tag: prod-a8a141f1-1736326087
 nameOverride: ''
 fullnameOverride: ''
 podAnnotations: {}

k8s/predict/values-prod.yaml

@@ -7,7 +7,7 @@ images:
     predictJob: eu.gcr.io/airqo-250220/airqo-predict-job
     trainJob: eu.gcr.io/airqo-250220/airqo-train-job
     predictPlaces: eu.gcr.io/airqo-250220/airqo-predict-places-air-quality
-  tag: prod-d831e59b-1736322897
+  tag: prod-a8a141f1-1736326087
 api:
   name: airqo-prediction-api
   label: prediction-api

k8s/spatial/values-prod.yaml

@@ -6,7 +6,7 @@ app:
 replicaCount: 3
 image:
   repository: eu.gcr.io/airqo-250220/airqo-spatial-api
-  tag: prod-d831e59b-1736322897
+  tag: prod-a8a141f1-1736326087
 nameOverride: ''
 fullnameOverride: ''
 podAnnotations: {}

k8s/workflows/values-prod.yaml

@@ -10,7 +10,7 @@ images:
     initContainer: eu.gcr.io/airqo-250220/airqo-workflows-xcom
     redisContainer: eu.gcr.io/airqo-250220/airqo-redis
     containers: eu.gcr.io/airqo-250220/airqo-workflows
-  tag: prod-d831e59b-1736322897
+  tag: prod-a8a141f1-1736326087
 nameOverride: ''
 fullnameOverride: ''
 podAnnotations: {}

k8s/workflows/values-stage.yaml

@@ -10,7 +10,7 @@ images:
     initContainer: eu.gcr.io/airqo-250220/airqo-stage-workflows-xcom
     redisContainer: eu.gcr.io/airqo-250220/airqo-stage-redis
     containers: eu.gcr.io/airqo-250220/airqo-stage-workflows
-  tag: stage-36d65c6f-1736322817
+  tag: stage-c223ba1b-1736326045
 nameOverride: ''
 fullnameOverride: ''
 podAnnotations: {}

src/auth-service/bin/jobs/check-subscription-status.js

@@ -0,0 +1,79 @@
+// @utils/subscriptionUtils.js
+const paddleClient = require("@config/paddle");
+const TransactionModel = require("@models/Transaction");
+const UserModel = require("@models/User");
+const constants = require("@config/constants");
+const log4js = require("log4js");
+const stringify = require("@utils/stringify");
+const httpStatus = require("http-status");
+
+const logger = log4js.getLogger(
+  `${constants.ENVIRONMENT} -- subscription-utils`
+);
+
+const checkSubscriptionStatuses = async () => {
+  try {
+    const batchSize = 100;
+    let skip = 0;
+
+    while (true) {
+      // Find users with active subscriptions
+      const users = await UserModel("airqo")
+        .find({
+          subscriptionStatus: "active",
+          isActive: true,
+        })
+        .limit(batchSize)
+        .skip(skip)
+        .select("_id email currentSubscriptionId")
+        .lean();
+
+      if (users.length === 0) break;
+
+      for (const user of users) {
+        try {
+          // Fetch subscription status from Paddle
+          const subscriptionStatus = await paddleClient.subscriptions.get(
+            user.currentSubscriptionId
+          );
+
+          // Update local user record based on Paddle subscription status
+          await UserModel("airqo").findByIdAndUpdate(user._id, {
+            $set: {
+              subscriptionStatus: subscriptionStatus.status,
+              lastSubscriptionCheck: new Date(),
+            },
+          });
+
+          // Log significant status changes or actions needed
+          if (subscriptionStatus.status === "past_due") {
+            // Send reminder email or notification
+            await mailer.sendSubscriptionReminderEmail({
+              email: user.email,
+              subscriptionId: user.currentSubscriptionId,
+            });
+          }
+        } catch (error) {
+          logger.error(
+            `Failed to check subscription for user ${
+              user.email
+            } --- ${stringify(error)}`
+          );
+        }
+      }
+
+      skip += batchSize;
+    }
+  } catch (error) {
+    logger.error(`Subscription status check error --- ${stringify(error)}`);
+  }
+};
+
+// Schedule the subscription status check job
+const schedule = "0 1 * * *"; // every day at 1 AM
+cron.schedule(schedule, checkSubscriptionStatuses, {
+  scheduled: true,
+  timezone: "Africa/Nairobi",
+});
+
+module.exports = subscriptionUtils;

src/auth-service/bin/jobs/subscription-renewal-job.js

@@ -0,0 +1,204 @@
+// @utils/subscriptionRenewalUtils.js
+const paddleClient = require("@config/paddle");
+const TransactionModel = require("@models/Transaction");
+const UserModel = require("@models/User");
+const constants = require("@config/constants");
+const log4js = require("log4js");
+const stringify = require("@utils/stringify");
+const httpStatus = require("http-status");
+const cron = require("node-cron");
+const mailer = require("@utils/mailer");
+
+const logger = log4js.getLogger(
+  `${constants.ENVIRONMENT} -- subscription-renewal-utils`
+);
+
+const subscriptionRenewalUtils = {
+  /**
+   * Automatically renew subscriptions and process transactions
+   */
+  processAutomaticRenewal: async () => {
+    try {
+      const batchSize = 100;
+      let skip = 0;
+
+      while (true) {
+        // Find users eligible for automatic renewal
+        const users = await UserModel("airqo")
+          .find({
+            subscriptionStatus: "active",
+            isActive: true,
+            automaticRenewal: true,
+            nextBillingDate: { $lte: new Date() },
+          })
+          .limit(batchSize)
+          .skip(skip)
+          .select("_id email currentSubscriptionId currentPlanDetails")
+          .lean();
+
+        if (users.length === 0) break;
+
+        for (const user of users) {
+          try {
+            // Fetch current subscription details
+            const subscriptionDetails = await paddleClient.subscriptions.get(
+              user.currentSubscriptionId
+            );
+
+            // Prepare transaction data
+            const transactionData = {
+              customerId: subscriptionDetails.customerId,
+              items: [
+                {
+                  priceId: user.currentPlanDetails.priceId,
+                  quantity: 1,
+                },
+              ],
+              currency: user.currentPlanDetails.currency || "USD",
+            };
+
+            // Create renewal transaction
+            const renewalTransaction = await paddleClient.transactions.create(
+              transactionData
+            );
+
+            // Record transaction in local database
+            const transactionRecord = await TransactionModel("airqo").register({
+              paddle_transaction_id: renewalTransaction.id,
+              paddle_event_type: "transaction.completed",
+              user_id: user._id,
+              paddle_customer_id: subscriptionDetails.customerId,
+              amount: renewalTransaction.total,
+              currency: transactionData.currency,
+              status: "completed",
+              payment_method: renewalTransaction.paymentMethod,
+              items: transactionData.items,
+              description: "Subscription Automatic Renewal",
+              metadata: {
+                subscriptionId: user.currentSubscriptionId,
+                originalTransactionData: renewalTransaction,
+              },
+            });
+
+            // Update user's next billing date
+            const nextBillingDate = new Date();
+            nextBillingDate.setMonth(nextBillingDate.getMonth() + 1); // Assuming monthly subscription
+
+            await UserModel("airqo").findByIdAndUpdate(user._id, {
+              $set: {
+                nextBillingDate: nextBillingDate,
+                lastRenewalDate: new Date(),
+              },
+            });
+
+            // Send successful renewal notification
+            await mailer.sendSubscriptionRenewalConfirmation({
+              email: user.email,
+              transactionId: renewalTransaction.id,
+              amount: renewalTransaction.total,
+              currency: transactionData.currency,
+            });
+          } catch (error) {
+            // Handle renewal failure
+            logger.error(
+              `Automatic renewal failed for user ${user.email} --- ${stringify(
+                error
+              )}`
+            );
+
+            // Send failure notification
+            await mailer.sendSubscriptionRenewalFailure({
+              email: user.email,
+              subscriptionId: user.currentSubscriptionId,
+              errorMessage: error.message,
+            });
+
+            // Update user status if multiple renewal attempts fail
+            await UserModel("airqo").findByIdAndUpdate(user._id, {
+              $set: {
+                subscriptionStatus: "past_due",
+                automaticRenewal: false,
+              },
+            });
+          }
+        }
+
+        skip += batchSize;
+      }
+    } catch (error) {
+      logger.error(
+        `Subscription renewal process error --- ${stringify(error)}`
+      );
+    }
+  },
+
+  /**
+   * Notify users about upcoming renewals
+   */
+  sendUpcomingRenewalNotifications: async () => {
+    try {
+      const batchSize = 100;
+      let skip = 0;
+
+      // Find users with renewals in next 3 days
+      const threeeDaysFromNow = new Date();
+      threeeDaysFromNow.setDate(threeeDaysFromNow.getDate() + 3);
+
+      while (true) {
+        const users = await UserModel("airqo")
+          .find({
+            subscriptionStatus: "active",
+            isActive: true,
+            automaticRenewal: true,
+            nextBillingDate: {
+              $gte: new Date(),
+              $lte: threeeDaysFromNow,
+            },
+          })
+          .limit(batchSize)
+          .skip(skip)
+          .select("_id email nextBillingDate currentPlanDetails")
+          .lean();
+
+        if (users.length === 0) break;
+
+        for (const user of users) {
+          await mailer.sendUpcomingRenewalNotification({
+            email: user.email,
+            nextBillingDate: user.nextBillingDate,
+            planDetails: user.currentPlanDetails,
+          });
+        }
+
+        skip += batchSize;
+      }
+    } catch (error) {
+      logger.error(
+        `Upcoming renewal notifications error --- ${stringify(error)}`
+      );
+    }
+  },
+};
+
+// Schedule jobs
+const renewalSchedule = "0 2 * * *"; // every day at 2 AM
+cron.schedule(
+  renewalSchedule,
+  subscriptionRenewalUtils.processAutomaticRenewal,
+  {
+    scheduled: true,
+    timezone: "Africa/Nairobi",
+  }
+);
+
+const notificationSchedule = "0 9 * * *"; // every day at 9 AM
+cron.schedule(
+  notificationSchedule,
+  subscriptionRenewalUtils.sendUpcomingRenewalNotifications,
+  {
+    scheduled: true,
+    timezone: "Africa/Nairobi",
+  }
+);
+
+module.exports = subscriptionRenewalUtils;