fix: add items from stash

packages/ee/server-only/stripe/create-customer.ts

@@ -0,0 +1,31 @@
+import { stripe } from '@documenso/lib/server-only/stripe';
+import { getSubscriptionByUserId } from '@documenso/lib/server-only/subscription/get-subscription-by-user-id';
+import { prisma } from '@documenso/prisma';
+import { User } from '@documenso/prisma/client';
+
+export type CreateCustomerOptions = {
+  user: User;
+};
+
+export const createCustomer = async ({ user }: CreateCustomerOptions) => {
+  const existingSubscription = await getSubscriptionByUserId({ userId: user.id });
+
+  if (existingSubscription) {
+    throw new Error('User already has a subscription');
+  }
+
+  const customer = await stripe.customers.create({
+    name: user.name ?? undefined,
+    email: user.email,
+    metadata: {
+      userId: user.id,
+    },
+  });
+
+  return await prisma.subscription.create({
+    data: {
+      userId: user.id,
+      customerId: customer.id,
+    },
+  });
+};

packages/ee/server-only/stripe/get-portal-session.ts

@@ -0,0 +1,19 @@
+'use server';
+
+import { stripe } from '@documenso/lib/server-only/stripe';
+
+export type GetPortalSessionOptions = {
+  customerId: string;
+  returnUrl: string;
+};
+
+export const getPortalSession = async ({ customerId, returnUrl }: GetPortalSessionOptions) => {
+  'use server';
+
+  const session = await stripe.billingPortal.sessions.create({
+    customer: customerId,
+    return_url: returnUrl,
+  });
+
+  return session.url;
+};