Group move (#3232)

Co-authored-by: Steven Tey <stevensteel97@gmail.com>
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>

Author: 3 people

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

@@ -1,6 +1,6 @@
 import { createId } from "@/lib/api/create-id";
 import { handleAndReturnErrorResponse } from "@/lib/api/errors";
-import { evaluateWorkflowCondition } from "@/lib/api/workflows/execute-workflows";
+import { evaluateWorkflowConditions } from "@/lib/api/workflows/evaluate-workflow-conditions";
 import { qstash } from "@/lib/cron";
 import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { aggregatePartnerLinksStats } from "@/lib/partners/aggregate-partner-links-stats";
@@ -152,8 +152,8 @@ export async function POST(req: Request) {
         .map((partner) => {
           const performanceCount = partner[condition.attribute];
 
-          const conditionMet = evaluateWorkflowCondition({
-            condition,
+          const conditionMet = evaluateWorkflowConditions({
+            conditions: [condition],
             attributes: {
               [condition.attribute]: performanceCount,
             },

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

@@ -0,0 +1,41 @@
+import { withCron } from "@/lib/cron/with-cron";
+import { disableStripeDiscountCode } from "@/lib/stripe/disable-stripe-discount-code";
+import { prisma } from "@dub/prisma";
+import * as z from "zod/v4";
+import { logAndRespond } from "../../utils";
+
+export const dynamic = "force-dynamic";
+
+const inputSchema = z.object({
+  code: z.string(),
+  programId: z.string(),
+});
+
+// POST /api/cron/discount-codes/delete
+export const POST = withCron(async ({ rawBody }) => {
+  const { code, programId } = inputSchema.parse(JSON.parse(rawBody));
+
+  const workspace = await prisma.project.findUniqueOrThrow({
+    where: {
+      defaultProgramId: programId,
+    },
+    select: {
+      stripeConnectId: true,
+    },
+  });
+
+  const disabledDiscountCode = await disableStripeDiscountCode({
+    code,
+    stripeConnectId: workspace.stripeConnectId,
+  });
+
+  if (!disabledDiscountCode) {
+    return logAndRespond(
+      `Failed to disable discount code ${code} in Stripe for ${workspace.stripeConnectId}.`,
+    );
+  }
+
+  return logAndRespond(
+    `Discount code ${code} disabled from Stripe for ${workspace.stripeConnectId}.`,
+  );
+});

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

@@ -6,7 +6,12 @@ import { verifyQstashSignature } from "@/lib/cron/verify-qstash";
 import { WorkspaceProps } from "@/lib/types";
 import { MAX_DEFAULT_LINKS_PER_GROUP } from "@/lib/zod/schemas/groups";
 import { prisma } from "@dub/prisma";
-import { APP_DOMAIN_WITH_NGROK, isFulfilled, log } from "@dub/utils";
+import {
+  APP_DOMAIN_WITH_NGROK,
+  isFulfilled,
+  log,
+  prettyPrint,
+} from "@dub/utils";
 import * as z from "zod/v4";
 import { logAndRespond } from "../../utils";
 import { remapPartnerGroupDefaultLinks } from "./utils";
@@ -217,15 +222,29 @@ export async function POST(req: Request) {
       );
     }
 
-    const res = await qstash.publishJSON({
+    const syncUtmJob = await qstash.publishJSON({
       url: `${APP_DOMAIN_WITH_NGROK}/api/cron/groups/sync-utm`,
       body: {
         groupId,
         partnerIds,
       },
     });
+
+    console.log(
+      `Scheduled sync-utm job for group ${groupId}: ${prettyPrint(syncUtmJob)}`,
+    );
+
+    const remapDiscountCodesJob = await qstash.publishJSON({
+      url: `${APP_DOMAIN_WITH_NGROK}/api/cron/groups/remap-discount-codes`,
+      body: {
+        programId,
+        partnerIds,
+        groupId,
+      },
+    });
+
     console.log(
-      `Scheduled sync-utm job for group ${groupId}: ${JSON.stringify(res, null, 2)}`,
+      `Scheduled remap-discount-codes job for group ${groupId}: ${prettyPrint(remapDiscountCodesJob)}`,
     );
 
     return logAndRespond(`Finished creating default links for the partners.`);