add a cron job for execute the migrate-roles script every 10 minutes

package.json

@@ -28,6 +28,7 @@
     "ai": "^5.0.68",
     "bson": "^6.10.4",
     "bullmq": "^5.61.0",
+    "cron": "^4.3.4",
     "discord-api-types": "^0.38.30",
     "ioredis": "^5.8.1",
     "zod": "^4.1.12"

src/index.ts

@@ -17,6 +17,7 @@ import { ObjectId } from "bson";
 import { rateLimiter } from "./services/rate-limiter";
 import { messageQueue, setWorkerContext } from "./services/message-queue";
 import axios from "axios";
+import { startMigrationCronJob } from "./scripts/cron-jobs";
 import { startServer } from "./server";
 
 const prisma = new PrismaClient();
@@ -74,6 +75,8 @@ client.once(GatewayDispatchEvents.Ready, ({ data }) => {
   });
 
   console.log("✅ Worker context initialized");
+
+  startMigrationCronJob(client.api, botId);
 });
 
 client.on(

src/scripts/cron-jobs.ts

@@ -0,0 +1,36 @@
+import { CronJob } from "cron";
+import { migrateRoles } from "./migrate-roles";
+import { Client } from "@discordjs/core";
+
+export function startMigrationCronJob(api: Client["api"], botId: string) {
+  console.log("[CRON] 🕒 Scheduling role migration job...");
+
+  const migrateRolesJob = new CronJob(
+    "*/10 * * * *",
+    async () => {
+      try {
+        console.log("[CRON] 🚀 Starting scheduled role migration...");
+        const stats = await migrateRoles(api, botId);
+        console.log(
+          `[CRON] ✅ Scheduled role migration finished successfully. Added/Removed: ${
+            stats.premiumAdded +
+            stats.premiumRemoved +
+            stats.freemiumAdded +
+            stats.freemiumRemoved
+          }`,
+        );
+      } catch (error) {
+        console.error("[CRON] ❌ Scheduled role migration failed:", error);
+      }
+    },
+    null,
+    true,
+    "America/Sao_Paulo",
+  );
+
+  console.log(
+    `[CRON] ✅ Role migration job scheduled. Next run: ${migrateRolesJob
+      .nextDate()
+      .toString()}`,
+  );
+}