Billing
-
- Your subscription is{' '}
- {subscription.status !== SubscriptionStatus.INACTIVE ? 'active' : 'inactive'}.
- {subscription?.periodEnd && (
- <>
- {' '}
- Your next payment is due on{' '}
-
-
-
- .
-
+
+ {isMissingOrInactiveOrFreePlan && (
+
+ You are currently on the Free Plan.
+
)}
-
+
+ {!isMissingOrInactiveOrFreePlan &&
+ match(subscription.status)
+ .with('ACTIVE', () => (
+
+ {subscriptionProduct ? (
+
+ You are currently subscribed to{' '}
+ {subscriptionProduct.name}
+
+ ) : (
+ You currently have an active plan
+ )}
+ {subscription.periodEnd && (
+
+ {' '}
+ which is set to{' '}
+ {subscription.cancelAtPeriodEnd ? (
+
+ end on{' '}
+ .
+
+ ) : (
+
+ automatically renew on{' '}
+ .
+
+ )}
+
+ )}
+
+ ))
+ .with('PAST_DUE', () => (
+
Your current plan is past due. Please update your payment information.
+ ))
+ .otherwise(() => null)}
+
- {billingPortalUrl && (
-
- )}
-
- {!billingPortalUrl && (
-
- You do not currently have a customer record, this should not happen. Please contact
- support for assistance.
-
- )}
+
);
}
diff --git a/apps/web/src/pages/api/stripe/webhook/index.ts b/apps/web/src/pages/api/stripe/webhook/index.ts
index 9efab2a78..06f63e293 100644
--- a/apps/web/src/pages/api/stripe/webhook/index.ts
+++ b/apps/web/src/pages/api/stripe/webhook/index.ts
@@ -3,6 +3,7 @@ import { NextApiRequest, NextApiResponse } from 'next';
import { randomBytes } from 'crypto';
import { readFileSync } from 'fs';
import { buffer } from 'micro';
+import { match } from 'ts-pattern';
import { insertImageInPDF } from '@documenso/lib/server-only/pdf/insert-image-in-pdf';
import { insertTextInPDF } from '@documenso/lib/server-only/pdf/insert-text-in-pdf';
@@ -16,6 +17,7 @@ import {
ReadStatus,
SendStatus,
SigningStatus,
+ SubscriptionStatus,
} from '@documenso/prisma/client';
const log = (...args: unknown[]) => console.log('[stripe]', ...args);
@@ -54,6 +56,18 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
);
log('event-type:', event.type);
+ if (event.type === 'customer.subscription.updated') {
+ // eslint-disable-next-line @typescript-eslint/consistent-type-assertions
+ const subscription = event.data.object as Stripe.Subscription;
+
+ await handleCustomerSubscriptionUpdated(subscription);
+
+ return res.status(200).json({
+ success: true,
+ message: 'Webhook received',
+ });
+ }
+
if (event.type === 'checkout.session.completed') {
// This is required since we don't want to create a guard for every event type
// eslint-disable-next-line @typescript-eslint/consistent-type-assertions
@@ -195,3 +209,29 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
message: 'Unhandled webhook event',
});
}
+
+const handleCustomerSubscriptionUpdated = async (subscription: Stripe.Subscription) => {
+ // eslint-disable-next-line @typescript-eslint/consistent-type-assertions
+ const plan = (subscription as unknown as Stripe.SubscriptionItem).plan;
+
+ const customerId =
+ typeof subscription.customer === 'string' ? subscription.customer : subscription.customer.id;
+
+ const status = match(subscription.status)
+ .with('active', () => SubscriptionStatus.ACTIVE)
+ .with('past_due', () => SubscriptionStatus.PAST_DUE)
+ .otherwise(() => SubscriptionStatus.INACTIVE);
+
+ await prisma.subscription.update({
+ where: {
+ customerId: customerId,
+ },
+ data: {
+ planId: plan.id,
+ status,
+ cancelAtPeriodEnd: subscription.cancel_at_period_end,
+ periodEnd: new Date(subscription.current_period_end * 1000),
+ updatedAt: new Date(),
+ },
+ });
+};
diff --git a/packages/ee/server-only/stripe/get-customer.ts b/packages/ee/server-only/stripe/get-customer.ts
new file mode 100644
index 000000000..11e782966
--- /dev/null
+++ b/packages/ee/server-only/stripe/get-customer.ts
@@ -0,0 +1,19 @@
+import { stripe } from '@documenso/lib/server-only/stripe';
+
+export const getStripeCustomerByEmail = async (email: string) => {
+ const foundStripeCustomers = await stripe.customers.list({
+ email,
+ });
+
+ return foundStripeCustomers.data[0] ?? null;
+};
+
+export const getStripeCustomerById = async (stripeCustomerId: string) => {
+ try {
+ const stripeCustomer = await stripe.customers.retrieve(stripeCustomerId);
+
+ return !stripeCustomer.deleted ? stripeCustomer : null;
+ } catch {
+ return null;
+ }
+};
diff --git a/packages/prisma/migrations/20230918111438_update_subscription_constraints_and_columns/migration.sql b/packages/prisma/migrations/20230918111438_update_subscription_constraints_and_columns/migration.sql
new file mode 100644
index 000000000..8125b0cb1
--- /dev/null
+++ b/packages/prisma/migrations/20230918111438_update_subscription_constraints_and_columns/migration.sql
@@ -0,0 +1,17 @@
+/*
+ Warnings:
+
+ - A unique constraint covering the columns `[userId]` on the table `Subscription` will be added. If there are existing duplicate values, this will fail.
+ - Made the column `customerId` on table `Subscription` required. This step will fail if there are existing NULL values in that column.
+
+*/
+
+DELETE FROM "Subscription"
+WHERE "customerId" IS NULL;
+
+-- AlterTable
+ALTER TABLE "Subscription" ADD COLUMN "cancelAtPeriodEnd" BOOLEAN NOT NULL DEFAULT false,
+ALTER COLUMN "customerId" SET NOT NULL;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Subscription_userId_key" ON "Subscription"("userId");
diff --git a/packages/prisma/schema.prisma b/packages/prisma/schema.prisma
index 340b98528..76c1ab552 100644
--- a/packages/prisma/schema.prisma
+++ b/packages/prisma/schema.prisma
@@ -51,15 +51,16 @@ enum SubscriptionStatus {
}
model Subscription {
- id Int @id @default(autoincrement())
- status SubscriptionStatus @default(INACTIVE)
- planId String?
- priceId String?
- customerId String?
- periodEnd DateTime?
- userId Int
- createdAt DateTime @default(now())
- updatedAt DateTime @updatedAt
+ id Int @id @default(autoincrement())
+ status SubscriptionStatus @default(INACTIVE)
+ planId String?
+ priceId String?
+ customerId String
+ periodEnd DateTime?
+ userId Int @unique
+ createdAt DateTime @default(now())
+ updatedAt DateTime @updatedAt
+ cancelAtPeriodEnd Boolean @default(false)
User User @relation(fields: [userId], references: [id], onDelete: Cascade)
diff --git a/packages/tsconfig/process-env.d.ts b/packages/tsconfig/process-env.d.ts
index 1db1ec36a..aec4f1d89 100644
--- a/packages/tsconfig/process-env.d.ts
+++ b/packages/tsconfig/process-env.d.ts
@@ -10,6 +10,7 @@ declare namespace NodeJS {
NEXT_PUBLIC_STRIPE_COMMUNITY_PLAN_MONTHLY_PRICE_ID: string;
NEXT_PUBLIC_STRIPE_COMMUNITY_PLAN_YEARLY_PRICE_ID: string;
+ NEXT_PUBLIC_STRIPE_FREE_PLAN_ID?: string;
NEXT_PRIVATE_STRIPE_API_KEY: string;
NEXT_PRIVATE_STRIPE_WEBHOOK_SECRET: string;
diff --git a/turbo.json b/turbo.json
index 10ff74735..ba52731e9 100644
--- a/turbo.json
+++ b/turbo.json
@@ -2,8 +2,13 @@
"$schema": "https://turbo.build/schema.json",
"pipeline": {
"build": {
- "dependsOn": ["^build"],
- "outputs": [".next/**", "!.next/cache/**"]
+ "dependsOn": [
+ "^build"
+ ],
+ "outputs": [
+ ".next/**",
+ "!.next/cache/**"
+ ]
},
"lint": {},
"clean": {
@@ -20,7 +25,9 @@
"dependsOn": ["^build"]
}
},
- "globalDependencies": ["**/.env.*local"],
+ "globalDependencies": [
+ "**/.env.*local"
+ ],
"globalEnv": [
"APP_VERSION",
"NEXTAUTH_URL",
@@ -33,6 +40,7 @@
"NEXT_PUBLIC_FEATURE_BILLING_ENABLED",
"NEXT_PUBLIC_STRIPE_COMMUNITY_PLAN_YEARLY_PRICE_ID",
"NEXT_PUBLIC_STRIPE_COMMUNITY_PLAN_MONTHLY_PRICE_ID",
+ "NEXT_PUBLIC_STRIPE_FREE_PLAN_ID",
"NEXT_PRIVATE_DATABASE_URL",
"NEXT_PRIVATE_DIRECT_DATABASE_URL",
"NEXT_PRIVATE_GOOGLE_CLIENT_ID",
@@ -77,4 +85,4 @@
"E2E_TEST_AUTHENTICATE_USER_EMAIL",
"E2E_TEST_AUTHENTICATE_USER_PASSWORD"
]
-}
+}
\ No newline at end of file