Stablecoin payouts: account link useCase, collection_options, recommended UI, backfill

Author: devkiran

apps/web/app/(ee)/partners.dub.co/(dashboard)/payouts/partner-payout-settings-sheet.tsx

@@ -207,13 +207,26 @@ function PayoutMethodsSection() {
     return null;
   }
 
+  // Show stablecoin as a recommended option when available but not yet connected, to encourage partners to add it
+  const showStablecoinRecommended =
+    availablePayoutMethods.includes("stablecoin") &&
+    !payoutMethodsData?.some((m) => m.type === "stablecoin" && m.connected);
+
   return (
     <div>
       <h4 className="text-content-emphasis mb-3 text-base font-semibold leading-6">
         Payout account
       </h4>
       {hasConnectedAccount ? (
-        <PayoutMethodsDropdown />
+        <div className="space-y-3">
+          <PayoutMethodsDropdown />
+          {showStablecoinRecommended && (
+            <PayoutMethodSelector
+              payoutMethods={["stablecoin"]}
+              variant="compact"
+            />
+          )}
+        </div>
       ) : (
         <PayoutMethodSelector
           payoutMethods={currentMethod ? [currentMethod.id] : []}

apps/web/lib/actions/partners/generate-stripe-recipient-account-link.ts

@@ -18,6 +18,8 @@ export const generateStripeRecipientAccountLink =
       permission: "payout_settings.update",
     });
 
+    let useCase: "account_onboarding" | "account_update" = "account_update";
+
     if (!partner.stripeRecipientId) {
       if (!partner.email) {
         throw new Error(
@@ -58,11 +60,13 @@ export const generateStripeRecipientAccountLink =
           stripeRecipientId: recipientAccount.id,
         },
       });
+
+      useCase = "account_onboarding";
     }
 
     const accountLink = await createStripeRecipientAccountLink({
-      stripeRecipientId: partner.stripeRecipientId,
-      useCase: "account_update",
+      stripeRecipientId: partner.stripeRecipientId!,
+      useCase,
     });
 
     return {

apps/web/lib/stripe/create-stripe-recipient-account-link.ts

@@ -10,32 +10,20 @@ export async function createStripeRecipientAccountLink({
   stripeRecipientId,
   useCase,
 }: CreateStripeRecipientAccountLinkParams) {
-  const returnUrl = `${PARTNERS_DOMAIN}/payouts`;
-  const refreshUrl = `${PARTNERS_DOMAIN}/payouts`;
-
-  const useCaseConfig =
-    useCase === "account_onboarding"
-      ? {
-          type: "account_onboarding" as const,
-          account_onboarding: {
-            configurations: ["recipient" as const],
-            return_url: returnUrl,
-            refresh_url: refreshUrl,
-          },
-        }
-      : {
-          type: "account_update" as const,
-          account_update: {
-            configurations: ["recipient" as const],
-            return_url: returnUrl,
-            refresh_url: refreshUrl,
-          },
-        };
-
   const { data, error } = await stripeV2Fetch("/v2/core/account_links", {
     body: {
       account: stripeRecipientId,
-      use_case: useCaseConfig,
+      use_case: {
+        type: useCase,
+        [useCase]: {
+          configurations: ["recipient"],
+          return_url: `${PARTNERS_DOMAIN}/payouts`,
+          refresh_url: `${PARTNERS_DOMAIN}/payouts`,
+          collection_options: {
+            fields: "eventually_due",
+          },
+        },
+      },
     },
   });
 

apps/web/lib/stripe/create-stripe-recipient-account.ts

@@ -2,8 +2,9 @@ import type { Partner } from "@dub/prisma/client";
 import { stripeV2Fetch } from "./stripe-v2-client";
 
 interface CreateStripeRecipientAccountParams
-  extends Pick<Partner, "name" | "country" | "profileType"> {
+  extends Pick<Partner, "name" | "profileType"> {
   email: NonNullable<Partner["email"]>;
+  country: NonNullable<Partner["country"]>;
 }
 
 export async function createStripeRecipientAccount({
@@ -17,7 +18,7 @@ export async function createStripeRecipientAccount({
       contact_email: email,
       display_name: name,
       identity: {
-        country: (country ?? "us").toLowerCase(),
+        country: country.toLowerCase(),
         entity_type: profileType,
       },
       configuration: {

apps/web/lib/stripe/stripe-v2-schemas.ts

@@ -33,6 +33,9 @@ export const createAccountLinkInputSchema = z.object({
         configurations: z.array(z.literal("recipient")),
         refresh_url: z.url(),
         return_url: z.url().optional(),
+        collection_options: z.object({
+          fields: z.enum(["currently_due", "eventually_due"]),
+        }),
       })
       .optional(),
     account_update: z

apps/web/scripts/migrations/backfill-default-payout-method.ts

@@ -0,0 +1,70 @@
+import { prisma } from "@dub/prisma";
+import { PartnerPayoutMethod } from "@dub/prisma/client";
+import "dotenv-flow/config";
+
+const BATCH_SIZE = 100;
+
+async function main() {
+  let cursor: string | undefined;
+  let totalUpdated = 0;
+
+  while (true) {
+    const partners = await prisma.partner.findMany({
+      where: {
+        defaultPayoutMethod: null,
+      },
+      select: {
+        id: true,
+        stripeConnectId: true,
+        stripeRecipientId: true,
+        paypalEmail: true,
+      },
+      ...(cursor
+        ? {
+            skip: 1,
+            cursor: {
+              id: cursor,
+            },
+          }
+        : {}),
+      take: BATCH_SIZE,
+      orderBy: {
+        id: "asc",
+      },
+    });
+
+    if (partners.length === 0) {
+      break;
+    }
+
+    for (const partner of partners) {
+      let defaultPayoutMethod: PartnerPayoutMethod | null = null;
+
+      if (partner.stripeConnectId) {
+        defaultPayoutMethod = PartnerPayoutMethod.connect;
+      } else if (partner.paypalEmail) {
+        defaultPayoutMethod = PartnerPayoutMethod.paypal;
+      } else if (partner.stripeRecipientId) {
+        defaultPayoutMethod = PartnerPayoutMethod.stablecoin;
+      }
+
+      if (defaultPayoutMethod) {
+        await prisma.partner.update({
+          where: {
+            id: partner.id,
+            defaultPayoutMethod: null,
+          },
+          data: {
+            defaultPayoutMethod,
+          },
+        });
+      }
+    }
+
+    cursor = partners[partners.length - 1].id;
+  }
+
+  console.log("Backfill finished.");
+}
+
+main();