Merge pull request #2113 from dubinc/fix-reward-import

fix reward import

Author: steven-tey

apps/web/app/api/mock/rewardful/campaigns/[campaignId]/route.ts

@@ -0,0 +1,13 @@
+import { NextResponse } from "next/server";
+import { campaigns } from "../campaigns";
+
+export async function GET(
+  request: Request,
+  { params }: { params: { campaignId: string } },
+) {
+  const { campaignId } = params;
+
+  const campaign = campaigns.find((c) => c.id === campaignId);
+
+  return NextResponse.json(campaign);
+}

apps/web/app/api/mock/rewardful/campaigns/[campaign]/route.ts

@@ -0,0 +1,64 @@
+export const campaigns = [
+  {
+    id: "ceaef6d9-767e-49aa-a6ab-46c02aa79604",
+    created_at: "2021-11-24T06:31:06.672Z",
+    updated_at: "2022-02-22T23:17:55.119Z",
+    name: "Campaign 1",
+    url: "https://rewardful.com/",
+    private: false,
+    private_tokens: false,
+    commission_amount_cents: null,
+    commission_amount_currency: null,
+    minimum_payout_cents: 0,
+    max_commission_period_months: 12,
+    max_commissions: null,
+    days_before_referrals_expire: 30,
+    days_until_commissions_are_due: 30,
+    affiliate_dashboard_text: "",
+    custom_reward_description: "",
+    welcome_text: "",
+    customers_visible_to_affiliates: false,
+    sale_description_visible_to_affiliates: true,
+    parameter_type: "query",
+    stripe_coupon_id: "jo45MTj3",
+    default: false,
+    reward_type: "percent",
+    commission_percent: 30.0,
+    minimum_payout_currency: "USD",
+    visitors: 150,
+    leads: 39,
+    conversions: 7,
+    affiliates: 12,
+  },
+  {
+    id: "ceaef6d9-767e-49aa-a6ab-46c02aa79605",
+    created_at: "2021-11-24T06:31:06.672Z",
+    updated_at: "2022-02-22T23:17:55.119Z",
+    name: "Campaign 2",
+    url: "https://rewardful.com/",
+    private: false,
+    private_tokens: false,
+    commission_amount_cents: 5000, // $50.00
+    commission_amount_currency: "USD",
+    minimum_payout_cents: 0,
+    max_commission_period_months: 24,
+    max_commissions: null,
+    days_before_referrals_expire: 30,
+    days_until_commissions_are_due: 30,
+    affiliate_dashboard_text: "",
+    custom_reward_description: "",
+    welcome_text: "",
+    customers_visible_to_affiliates: false,
+    sale_description_visible_to_affiliates: true,
+    parameter_type: "query",
+    stripe_coupon_id: "jo45MTj3",
+    default: false,
+    reward_type: "amount",
+    commission_percent: null,
+    minimum_payout_currency: "USD",
+    visitors: 150,
+    leads: 39,
+    conversions: 7,
+    affiliates: 12,
+  },
+];

apps/web/app/api/mock/rewardful/campaigns/campaigns.ts

@@ -1,71 +1,7 @@
 import { NextResponse } from "next/server";
+import { campaigns } from "./campaigns";
 
 export async function GET() {
-  const campaigns = [
-    {
-      id: "ceaef6d9-767e-49aa-a6ab-46c02aa79604",
-      created_at: "2021-11-24T06:31:06.672Z",
-      updated_at: "2022-02-22T23:17:55.119Z",
-      name: "Campaign 1",
-      url: "https://rewardful.com/",
-      private: false,
-      private_tokens: false,
-      commission_amount_cents: null,
-      commission_amount_currency: null,
-      minimum_payout_cents: 0,
-      max_commission_period_months: 12,
-      max_commissions: null,
-      days_before_referrals_expire: 30,
-      days_until_commissions_are_due: 30,
-      affiliate_dashboard_text: "",
-      custom_reward_description: "",
-      welcome_text: "",
-      customers_visible_to_affiliates: false,
-      sale_description_visible_to_affiliates: true,
-      parameter_type: "query",
-      stripe_coupon_id: "jo45MTj3",
-      default: false,
-      reward_type: "percent",
-      commission_percent: 30.0,
-      minimum_payout_currency: "USD",
-      visitors: 150,
-      leads: 39,
-      conversions: 7,
-      affiliates: 12,
-    },
-    {
-      id: "ceaef6d9-767e-49aa-a6ab-46c02aa79605",
-      created_at: "2021-11-24T06:31:06.672Z",
-      updated_at: "2022-02-22T23:17:55.119Z",
-      name: "Campaign 2",
-      url: "https://rewardful.com/",
-      private: false,
-      private_tokens: false,
-      commission_amount_cents: 5000, // $50.00
-      commission_amount_currency: "USD",
-      minimum_payout_cents: 0,
-      max_commission_period_months: 24,
-      max_commissions: null,
-      days_before_referrals_expire: 30,
-      days_until_commissions_are_due: 30,
-      affiliate_dashboard_text: "",
-      custom_reward_description: "",
-      welcome_text: "",
-      customers_visible_to_affiliates: false,
-      sale_description_visible_to_affiliates: true,
-      parameter_type: "query",
-      stripe_coupon_id: "jo45MTj3",
-      default: false,
-      reward_type: "amount",
-      commission_percent: null,
-      minimum_payout_currency: "USD",
-      visitors: 150,
-      leads: 39,
-      conversions: 7,
-      affiliates: 12,
-    },
-  ];
-
   return NextResponse.json({
     data: campaigns,
   });

apps/web/app/api/mock/rewardful/campaigns/route.ts

@@ -1,4 +1,5 @@
 import { prisma } from "@dub/prisma";
+import { CommissionType, EventType } from "@dub/prisma/client";
 import { createId } from "../api/create-id";
 import { RewardfulApi } from "./api";
 import { rewardfulImporter } from "./importer";
@@ -25,34 +26,53 @@ export async function importCampaign({ programId }: { programId: string }) {
     reward_type,
   } = campaign;
 
-  const reward = await prisma.reward.create({
-    data: {
-      id: createId({ prefix: "rw_" }),
-      programId,
-      event: "sale",
-      maxDuration: max_commission_period_months,
-      type: reward_type === "amount" ? "flat" : "percentage",
-      amount:
-        reward_type === "amount" ? commission_amount_cents : commission_percent,
-    },
+  const newReward = {
+    programId,
+    event: EventType.sale,
+    maxDuration: max_commission_period_months,
+    type:
+      reward_type === "amount"
+        ? CommissionType.flat
+        : CommissionType.percentage,
+    amount:
+      reward_type === "amount" ? commission_amount_cents : commission_percent,
+  };
+
+  let rewardId: string | null = null;
+
+  const rewardFound = await prisma.reward.findFirst({
+    where: newReward,
   });
 
-  if (!defaultRewardId) {
-    await prisma.program.update({
-      where: {
-        id: programId,
-      },
+  if (!rewardFound) {
+    const reward = await prisma.reward.create({
       data: {
-        defaultRewardId: reward.id,
+        id: createId({ prefix: "rw_" }),
+        ...newReward,
       },
     });
+
+    if (!defaultRewardId) {
+      await prisma.program.update({
+        where: {
+          id: programId,
+        },
+        data: {
+          defaultRewardId: reward.id,
+        },
+      });
+    }
+
+    rewardId = reward.id;
+  } else {
+    rewardId = rewardFound.id;
   }
 
   return await rewardfulImporter.queue({
     programId,
     // we will only need to assign rewardId to affiliates
     // if it's not the defaultRewardId of the program (there's already a defaultRewardId)
-    ...(defaultRewardId && { rewardId: reward.id }),
+    ...(defaultRewardId && { rewardId }),
     action: "import-affiliates",
   });
 }