Add retry mechanism for failed requests

apps/web/app/(ee)/api/cron/aggregate-clicks/route.ts

@@ -1,5 +1,4 @@
 import { createId } from "@/lib/api/create-id";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { syncTotalCommissions } from "@/lib/api/partners/sync-total-commissions";
 import { qstash } from "@/lib/cron";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
@@ -14,7 +13,7 @@ import {
   nFormatter,
 } from "@dub/utils";
 import * as z from "zod/v4";
-import { logAndRespond } from "../utils";
+import { handleCronErrorResponse, logAndRespond } from "../utils";
 import { resolveClickRewardAmount } from "./resolve-click-reward-amount";
 
 export const dynamic = "force-dynamic";
@@ -239,7 +238,7 @@ async function handler(req: Request) {
 
     return logAndRespond(endMessage);
   } catch (error) {
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }
 

apps/web/app/(ee)/api/cron/bounties/create-draft-submissions/route.ts

@@ -1,5 +1,4 @@
 import { createId } from "@/lib/api/create-id";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { evaluateWorkflowCondition } from "@/lib/api/workflows/execute-workflows";
 import { qstash } from "@/lib/cron";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
@@ -10,7 +9,7 @@ import { Prisma } from "@dub/prisma/client";
 import { APP_DOMAIN_WITH_NGROK, log } from "@dub/utils";
 import { differenceInMinutes } from "date-fns";
 import * as z from "zod/v4";
-import { logAndRespond } from "../../utils";
+import { handleCronErrorResponse, logAndRespond } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -209,6 +208,6 @@ export async function POST(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/bounties/notify-partners/route.ts

@@ -1,5 +1,4 @@
 import { createId } from "@/lib/api/create-id";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { qstash } from "@/lib/cron";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { ACTIVE_ENROLLMENT_STATUSES } from "@/lib/zod/schemas/partners";
@@ -10,7 +9,7 @@ import { NotificationEmailType } from "@dub/prisma/client";
 import { APP_DOMAIN_WITH_NGROK, log } from "@dub/utils";
 import { differenceInMinutes } from "date-fns";
 import * as z from "zod/v4";
-import { logAndRespond } from "../../utils";
+import { handleCronErrorResponse, logAndRespond } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -217,6 +216,6 @@ export async function POST(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/campaigns/broadcast/route.ts

@@ -1,6 +1,5 @@
 import { validateCampaignFromAddress } from "@/lib/api/campaigns/validate-campaign";
 import { createId } from "@/lib/api/create-id";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { renderCampaignEmailHTML } from "@/lib/api/workflows/render-campaign-email-html";
 import { qstash } from "@/lib/cron";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
@@ -14,7 +13,7 @@ import { APP_DOMAIN_WITH_NGROK, chunk, log } from "@dub/utils";
 import { differenceInMinutes } from "date-fns";
 import { headers } from "next/headers";
 import * as z from "zod/v4";
-import { logAndRespond } from "../../utils";
+import { handleCronErrorResponse, logAndRespond } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -331,6 +330,6 @@ export async function POST(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/cleanup/demo-embed-partners/route.ts

@@ -1,10 +1,9 @@
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { bulkDeletePartners } from "@/lib/api/partners/bulk-delete-partners";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { prisma } from "@dub/prisma";
 import { ACME_PROGRAM_ID, log } from "@dub/utils";
 import { subHours } from "date-fns";
-import { logAndRespond } from "../../utils";
+import { handleCronErrorResponse, logAndRespond } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -81,6 +80,6 @@ export async function POST(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/cleanup/e2e-tests/route.ts

@@ -1,5 +1,4 @@
 import { markDomainAsDeleted } from "@/lib/api/domains/mark-domain-deleted";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { bulkDeleteLinks } from "@/lib/api/links/bulk-delete-links";
 import { includeProgramEnrollment } from "@/lib/api/links/include-program-enrollment";
 import { includeTags } from "@/lib/api/links/include-tags";
@@ -8,6 +7,7 @@ import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { prisma } from "@dub/prisma";
 import { log } from "@dub/utils";
 import { NextResponse } from "next/server";
+import { handleCronErrorResponse } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -165,6 +165,6 @@ export async function POST(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/cleanup/expired-tokens/route.ts

@@ -1,8 +1,8 @@
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { prisma } from "@dub/prisma";
 import { log } from "@dub/utils";
 import { NextResponse } from "next/server";
+import { handleCronErrorResponse } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -64,6 +64,6 @@ export async function POST(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/cleanup/link-retention/route.ts

@@ -1,4 +1,3 @@
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { qstash } from "@/lib/cron";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { recordLink } from "@/lib/tinybird";
@@ -7,6 +6,7 @@ import { Domain } from "@dub/prisma/client";
 import { APP_DOMAIN_WITH_NGROK } from "@dub/utils";
 import { NextResponse } from "next/server";
 import * as z from "zod/v4";
+import { handleCronErrorResponse } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -49,7 +49,7 @@ export async function POST(req: Request) {
 
     return NextResponse.json("OK");
   } catch (error) {
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }
 

apps/web/app/(ee)/api/cron/cleanup/rejected-applications/route.ts

@@ -1,9 +1,9 @@
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { prisma } from "@dub/prisma";
 import { log } from "@dub/utils";
 import { subDays } from "date-fns";
 import { NextResponse } from "next/server";
+import { handleCronErrorResponse } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -66,6 +66,6 @@ export async function POST(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/commissions/export/route.ts

@@ -1,7 +1,6 @@
 import { convertToCSV } from "@/lib/analytics/utils/convert-to-csv";
 import { formatCommissionsForExport } from "@/lib/api/commissions/format-commissions-for-export";
 import { createDownloadableExport } from "@/lib/api/create-downloadable-export";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { generateExportFilename } from "@/lib/api/utils/generate-export-filename";
 import { generateRandomString } from "@/lib/api/utils/generate-random-string";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
@@ -11,7 +10,7 @@ import ExportReady from "@dub/email/templates/export-ready";
 import { prisma } from "@dub/prisma";
 import { log } from "@dub/utils";
 import * as z from "zod/v4";
-import { logAndRespond } from "../../utils";
+import { handleCronErrorResponse, logAndRespond } from "../../utils";
 import { fetchCommissionsBatch } from "./fetch-commissions-batch";
 
 const payloadSchema = commissionsExportQuerySchema.extend({
@@ -109,6 +108,6 @@ export async function POST(req: Request) {
       type: "cron",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/discount-codes/[discountCodeId]/delete/route.ts

@@ -1,8 +1,7 @@
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { disableStripeDiscountCode } from "@/lib/stripe/disable-stripe-discount-code";
 import { prisma } from "@dub/prisma";
-import { logAndRespond } from "../../../utils";
+import { handleCronErrorResponse, logAndRespond } from "../../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -57,6 +56,6 @@ export async function POST(
       `Discount code ${discountCode.code} disabled from Stripe for ${workspace.stripeConnectId}.`,
     );
   } catch (error) {
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/disposable-emails/route.ts

@@ -1,8 +1,8 @@
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { redis } from "@/lib/upstash";
 import { log } from "@dub/utils";
 import { NextResponse } from "next/server";
+import { handleCronErrorResponse } from "../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -39,6 +39,6 @@ export async function POST(req: Request) {
       type: "cron",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/domains/delete/route.ts

@@ -1,5 +1,4 @@
 import { queueDomainDeletion } from "@/lib/api/domains/queue-domain-update";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { linkCache } from "@/lib/api/links/cache";
 import { includeProgramEnrollment } from "@/lib/api/links/include-program-enrollment";
 import { includeTags } from "@/lib/api/links/include-tags";
@@ -10,6 +9,7 @@ import { recordLink } from "@/lib/tinybird/record-link";
 import { prisma } from "@dub/prisma";
 import { R2_URL } from "@dub/utils";
 import * as z from "zod/v4";
+import { handleCronErrorResponse } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -134,6 +134,6 @@ export async function POST(req: Request) {
       `Deleted ${links.length} links, no more links remaining. Domain deleted.`,
     );
   } catch (error) {
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/domains/renewal-payments/route.ts

@@ -1,12 +1,12 @@
 import { createId } from "@/lib/api/create-id";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { verifyVercelSignature } from "@/lib/cron/verify-vercel";
 import { createPaymentIntent } from "@/lib/stripe/create-payment-intent";
 import { prisma } from "@dub/prisma";
 import { Invoice, Project, RegisteredDomain } from "@dub/prisma/client";
 import { log } from "@dub/utils";
 import { addDays, endOfDay, startOfDay } from "date-fns";
 import { NextResponse } from "next/server";
+import { handleCronErrorResponse } from "../../utils";
 
 /**
  * Daily cron job to create payment intents for `.link` domain renewals.
@@ -155,6 +155,6 @@ export async function GET(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/domains/renewal-reminders/route.ts

@@ -1,4 +1,3 @@
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { verifyVercelSignature } from "@/lib/cron/verify-vercel";
 import { sendBatchEmail } from "@dub/email";
 import DomainRenewalReminder from "@dub/email/templates/domain-renewal-reminder";
@@ -12,6 +11,7 @@ import {
   subDays,
 } from "date-fns";
 import { NextResponse } from "next/server";
+import { handleCronErrorResponse } from "../../utils";
 
 /**
  * Daily cron job to send `.link` domain renewal reminders.
@@ -130,6 +130,6 @@ export async function GET(req: Request) {
       type: "errors",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/domains/transfer/route.ts

@@ -1,4 +1,3 @@
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { linkCache } from "@/lib/api/links/cache";
 import { qstash } from "@/lib/cron";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
@@ -7,6 +6,7 @@ import { prisma } from "@dub/prisma";
 import { APP_DOMAIN_WITH_NGROK, log } from "@dub/utils";
 import { NextResponse } from "next/server";
 import * as z from "zod/v4";
+import { handleCronErrorResponse } from "../../utils";
 import { sendDomainTransferredEmail } from "./utils";
 
 const schema = z.object({
@@ -124,6 +124,6 @@ export async function POST(req: Request) {
       type: "cron",
     });
 
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }

apps/web/app/(ee)/api/cron/domains/update/route.ts

@@ -2,7 +2,6 @@ import {
   linkDomainUpdateSchema,
   queueDomainUpdate,
 } from "@/lib/api/domains/queue-domain-update";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { linkCache } from "@/lib/api/links/cache";
 import { includeProgramEnrollment } from "@/lib/api/links/include-program-enrollment";
 import { includeTags } from "@/lib/api/links/include-tags";
@@ -11,7 +10,7 @@ import { recordLink } from "@/lib/tinybird";
 import { prisma } from "@dub/prisma";
 import { Link } from "@dub/prisma/client";
 import { linkConstructorSimple } from "@dub/utils";
-import { logAndRespond } from "../../utils";
+import { handleCronErrorResponse, logAndRespond } from "../../utils";
 
 export const dynamic = "force-dynamic";
 
@@ -113,7 +112,7 @@ export async function POST(req: Request) {
       return logAndRespond("Error scheduling next batch.");
     }
   } catch (error) {
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }
 

apps/web/app/(ee)/api/cron/domains/verify/route.ts

@@ -1,11 +1,11 @@
 import { getConfigResponse } from "@/lib/api/domains/get-config-response";
 import { getDomainResponse } from "@/lib/api/domains/get-domain-response";
 import { verifyDomain } from "@/lib/api/domains/verify-domain";
-import { handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { verifyVercelSignature } from "@/lib/cron/verify-vercel";
 import { prisma } from "@dub/prisma";
 import { log } from "@dub/utils";
 import { NextResponse } from "next/server";
+import { handleCronErrorResponse } from "../../utils";
 import { handleDomainUpdates } from "./utils";
 
 /**
@@ -112,6 +112,6 @@ export async function GET(req: Request) {
       message: "Domains cron failed. Error: " + error.message,
       type: "errors",
     });
-    return handleAndReturnErrorResponse(error);
+    return handleCronErrorResponse({ error });
   }
 }