Email domains & Marketing campaigns

apps/web/app/(ee)/api/campaigns/[campaignId]/duplicate/route.ts

@@ -58,6 +58,7 @@ export const POST = withWorkspace(
           workflowId,
           userId: session.user.id,
           status: CampaignStatus.draft,
+          from: campaign.from,
           name: `${campaign.name} (copy)`,
           subject: campaign.subject,
           bodyJson: campaign.bodyJson ?? DEFAULT_CAMPAIGN_BODY,

apps/web/app/(ee)/api/campaigns/[campaignId]/route.ts

@@ -1,21 +1,22 @@
 import { getCampaignOrThrow } from "@/lib/api/campaigns/get-campaign-or-throw";
+import {
+  scheduleMarketingCampaign,
+  scheduleTransactionalCampaign,
+} from "@/lib/api/campaigns/schedule-campaigns";
+import { validateCampaign } from "@/lib/api/campaigns/validate-campaign";
 import { throwIfInvalidGroupIds } from "@/lib/api/groups/throw-if-invalid-group-ids";
 import { getDefaultProgramIdOrThrow } from "@/lib/api/programs/get-default-program-id-or-throw";
 import { parseRequestBody } from "@/lib/api/utils";
 import { parseWorkflowConfig } from "@/lib/api/workflows/parse-workflow-config";
-import { isScheduledWorkflow } from "@/lib/api/workflows/utils";
 import { withWorkspace } from "@/lib/auth";
 import { qstash } from "@/lib/cron";
 import {
   CampaignSchema,
   updateCampaignSchema,
 } from "@/lib/zod/schemas/campaigns";
-import {
-  WORKFLOW_ATTRIBUTE_TRIGGER,
-  WORKFLOW_SCHEDULES,
-} from "@/lib/zod/schemas/workflows";
+import { WORKFLOW_ATTRIBUTE_TRIGGER } from "@/lib/zod/schemas/workflows";
 import { prisma } from "@dub/prisma";
-import { APP_DOMAIN_WITH_NGROK, arrayEqual } from "@dub/utils";
+import { arrayEqual } from "@dub/utils";
 import { PartnerGroup } from "@prisma/client";
 import { waitUntil } from "@vercel/functions";
 import { NextResponse } from "next/server";
@@ -53,16 +54,27 @@ export const PATCH = withWorkspace(
     const { campaignId } = params;
     const programId = getDefaultProgramIdOrThrow(workspace);
 
-    const { name, subject, status, bodyJson, groupIds, triggerCondition } =
-      updateCampaignSchema.parse(await parseRequestBody(req));
-
     const campaign = await getCampaignOrThrow({
       programId,
       campaignId,
       includeWorkflow: true,
       includeGroups: true,
     });
 
+    const {
+      name,
+      subject,
+      from,
+      status,
+      bodyJson,
+      groupIds,
+      triggerCondition,
+      scheduledAt,
+    } = await validateCampaign({
+      input: updateCampaignSchema.parse(await parseRequestBody(req)),
+      campaign,
+    });
+
     // if groupIds is provided and is different from the current groupIds, update the groups
     let updatedPartnerGroups: PartnerGroup[] | undefined = undefined;
     let shouldUpdateGroups = false;
@@ -109,8 +121,10 @@ export const PATCH = withWorkspace(
         data: {
           ...(name && { name }),
           ...(subject && { subject }),
+          ...(from && { from }),
           ...(status && { status }),
           ...(bodyJson && { bodyJson }),
+          ...(scheduledAt !== undefined && { scheduledAt }),
           ...(shouldUpdateGroups && {
             groups: {
               deleteMany: {},
@@ -132,38 +146,16 @@ export const PATCH = withWorkspace(
 
     waitUntil(
       (async () => {
-        if (
-          !updatedCampaign.workflow ||
-          !isScheduledWorkflow(updatedCampaign.workflow)
-        ) {
-          return;
-        }
-
-        // Decide whether to schedule the workflow or delete the schedule
-        const shouldSchedule =
-          (campaign.status === "draft" || campaign.status === "paused") &&
-          updatedCampaign.status === "active";
-
-        const shouldDeleteSchedule =
-          campaign.status === "active" && updatedCampaign.status === "paused";
-
-        const cronSchedule =
-          WORKFLOW_SCHEDULES[updatedCampaign.workflow.trigger];
-
-        if (!cronSchedule) {
-          throw new Error(
-            `Cron schedule not found for trigger ${updatedCampaign.workflow.trigger}`,
-          );
-        }
-
-        if (shouldSchedule) {
-          await qstash.schedules.create({
-            destination: `${APP_DOMAIN_WITH_NGROK}/api/cron/workflows/${updatedCampaign.workflow.id}`,
-            cron: cronSchedule,
-            scheduleId: updatedCampaign.workflow.id,
+        if (updatedCampaign.type === "marketing") {
+          await scheduleMarketingCampaign({
+            campaign,
+            updatedCampaign,
+          });
+        } else if (updatedCampaign.type === "transactional") {
+          await scheduleTransactionalCampaign({
+            campaign,
+            updatedCampaign,
           });
-        } else if (shouldDeleteSchedule) {
-          await qstash.schedules.delete(updatedCampaign.workflow.id);
         }
       })(),
     );
@@ -212,17 +204,17 @@ export const DELETE = withWorkspace(
 
     waitUntil(
       (async () => {
-        if (!campaign.workflow) {
-          return;
-        }
+        if (campaign.type === "marketing" && campaign.qstashMessageId) {
+          await qstash.messages.delete(campaign.qstashMessageId);
+        } else if (campaign.type === "transactional" && campaign.workflow) {
+          const { condition } = parseWorkflowConfig(campaign.workflow);
 
-        const { condition } = parseWorkflowConfig(campaign.workflow);
+          if (condition.attribute === "partnerJoined") {
+            return;
+          }
 
-        if (condition.attribute === "partnerJoined") {
-          return;
+          await qstash.schedules.delete(campaign.workflow.id);
         }
-
-        await qstash.schedules.delete(campaign.workflow.id);
       })(),
     );
 

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

@@ -91,9 +91,12 @@ export const POST = withWorkspace(
       return campaign;
     });
 
-    return NextResponse.json({
-      id: campaign.id,
-    });
+    return NextResponse.json(
+      {
+        id: campaign.id,
+      },
+      { status: 201 },
+    );
   },
   {
     requiredPlan: ["advanced", "enterprise"],

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

@@ -50,7 +50,7 @@ export async function POST(req: Request) {
       });
     }
 
-    let diffMinutes = differenceInMinutes(bounty.startsAt, new Date());
+    const diffMinutes = differenceInMinutes(bounty.startsAt, new Date());
 
     if (diffMinutes >= 10) {
       return logAndRespond(