From f72bc28d702716749f048ae8b8da11634a302f2b Mon Sep 17 00:00:00 2001
From: Mauricio Siu <siumauricio@icloud.com>
Date: Thu, 29 Jan 2026 22:54:52 -0600
Subject: [PATCH] Refactor enterprise backup cron job initialization:
 Simplified the cron job setup by consolidating user retrieval and validation
 logic into a single scheduled job. Updated the schedule to run every 3 days
 and removed redundant checks for user length.

---
 packages/server/src/utils/crons/enterprise.ts | 44 +++++++------------
 1 file changed, 17 insertions(+), 27 deletions(-)

diff --git a/packages/server/src/utils/crons/enterprise.ts b/packages/server/src/utils/crons/enterprise.ts
index 8e915b35f..4fded2e7a 100644
--- a/packages/server/src/utils/crons/enterprise.ts
+++ b/packages/server/src/utils/crons/enterprise.ts
@@ -5,32 +5,22 @@ import { db } from "../../db/index";
 import { user as userSchema } from "../../db/schema/user";
 
 export const initEnterpriseBackupCronJobs = async () => {
-	const users = await db.query.user.findMany({
-		where: and(
-			isNotNull(userSchema.licenseKey),
-			isNotNull(userSchema.enableEnterpriseFeatures),
-			eq(userSchema.isValidEnterpriseLicense, true),
-		),
-	});
-
-	if (users.length === 0) {
-		return;
-	}
-
-	console.log(
-		"Setting up enterprise backup cron jobs for users....",
-		users.length,
-	);
-
-	for (const user of users) {
-		if (user.isValidEnterpriseLicense) {
-			scheduleJob(`enterprise-backup-${user.id}`, "0 0 */14 * *", async () => {
+	scheduleJob("enterprise-check", "0 0 */3 * *", async () => {
+		const users = await db.query.user.findMany({
+			where: and(
+				isNotNull(userSchema.licenseKey),
+				isNotNull(userSchema.enableEnterpriseFeatures),
+				eq(userSchema.isValidEnterpriseLicense, true),
+			),
+		});
+		for (const user of users) {
+			if (user.isValidEnterpriseLicense) {
+				console.log(
+					"Validating license key....",
+					user.firstName,
+					user.lastName,
+				);
 				try {
-					console.log(
-						"Validating license key....",
-						user.firstName,
-						user.lastName,
-					);
 					const isValid = await validateLicenseKey(user.licenseKey || "");
 					if (!isValid) {
 						throw new Error("License key is invalid");
@@ -41,9 +31,9 @@ export const initEnterpriseBackupCronJobs = async () => {
 						.set({ isValidEnterpriseLicense: false })
 						.where(eq(userSchema.id, user.id));
 				}
-			});
+			}
 		}
-	}
+	});
 };
 
 export const validateLicenseKey = async (licenseKey: string) => {