Dokploy/dokploy
1
0
Fork 0
mirror of https://github.com/Dokploy/dokploy.git synced 2026-10-12 02:01:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(billing): one reminder at 1 day, guarded by an advisory lock

Browse Source 
Cloud runs two frontend replicas and node-schedule fires on each, so both
would read the same unset marker and every trial user would get the email
twice. A Postgres advisory lock lets one replica run and the other skip;
it lives in the connection rather than the schema, so no migration.

Drops the 3-day reminder, leaving the single notice before billing starts.
This commit is contained in:
Mauricio Siu
2026-09-18 02:45:46 -06:00
parent 14e059784c
commit 037230496c
1 changed files with 31 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/dokploy/server/utils/trial-notifications.ts
+31 -3
View File
@@ -1,21 +1,42 @@
import { IS_CLOUD } from "@dokploy/server";
import { db } from "@dokploy/server/db";
import { db, dbUrl } from "@dokploy/server/db";
import TrialExpiringEmail from "@dokploy/server/emails/emails/trial-expiring";
import { sendEmail } from "@dokploy/server/verification/send-verification-email";
import { render } from "@react-email/components";
import { format } from "date-fns";
import { eq } from "drizzle-orm";
import { scheduleJob } from "node-schedule";
import postgres from "postgres";
import type Stripe from "stripe";
import { user } from "@/server/db/schema";
import { getStripeClient, planFromPriceIds } from "@/server/utils/billing";
import { WEBSITE_URL } from "@/server/utils/stripe";
const REMINDER_THRESHOLDS = [
{ days: 3, metadataKey: "trialReminder3Sent" },
{ days: 1, metadataKey: "trialReminder1Sent" },
] as const;
// Cloud runs several replicas and node-schedule fires on each one, so without
// this every trial user would get one email per replica. Advisory locks live
// in the connection rather than the schema, so no migration is needed.
const ADVISORY_LOCK_KEY = 4820260918;
const withAdvisoryLock = async <T>(run: () => Promise<T>) => {
const sql = postgres(dbUrl, { max: 1 });
try {
const [row] =
await sql`select pg_try_advisory_lock(${ADVISORY_LOCK_KEY}) as locked`;
if (!row?.locked) return null;
try {
return await run();
} finally {
await sql`select pg_advisory_unlock(${ADVISORY_LOCK_KEY})`;
}
} finally {
await sql.end({ timeout: 5 });
}
};
const PLAN_LABELS: Record<string, string> = {
hobby: "Hobby",
startup: "Startup",
@@ -148,7 +169,14 @@ export const initTrialNotificationsCronJob = () => {
scheduleJob("trial-expiration-reminders", "0 14 * * *", async () => {
try {
await processTrialExpirations();
const result = await withAdvisoryLock(processTrialExpirations);
if (!result) {
console.log("Trial reminders: another replica holds the lock");
return;
}
console.log(
`Trial reminders: scanned ${result.scanned}, sent ${result.sent}`,
);
} catch (error) {
console.error(
"Trial reminder job failed:",