luulam/AFFiNE
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix(server): should update stripe customer email if changed (#7181)

Browse Source
This commit is contained in:
forehalo
2024-06-08 15:52:23 +00:00
parent ab26e0f360
commit 41bc683eed
1 changed files with 29 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
packages/backend/server/src/plugins/payment/service.ts
View File

@@ -14,7 +14,7 @@ import Stripe from 'stripe';
import { CurrentUser } from '../../core/auth'; import { CurrentUser } from '../../core/auth';
import { EarlyAccessType, FeatureManagementService } from '../../core/features'; import { EarlyAccessType, FeatureManagementService } from '../../core/features';
import { Config, EventEmitter } from '../../fundamentals'; import { Config, EventEmitter, OnEvent } from '../../fundamentals';
import { ScheduleManager } from './schedule'; import { ScheduleManager } from './schedule';
import { import {
InvoiceStatus, InvoiceStatus,
@@ -24,7 +24,7 @@ import {
SubscriptionStatus, SubscriptionStatus,
} from './types'; } from './types';
const OnEvent = ( const OnStripeEvent = (
event: Stripe.Event.Type, event: Stripe.Event.Type,
opts?: Parameters<typeof RawOnEvent>[1] opts?: Parameters<typeof RawOnEvent>[1]
) => RawOnEvent(event, opts); ) => RawOnEvent(event, opts);
@@ -419,8 +419,8 @@ export class SubscriptionService {
} }
} }
@OnEvent('customer.subscription.created') @OnStripeEvent('customer.subscription.created')
@OnEvent('customer.subscription.updated') @OnStripeEvent('customer.subscription.updated')
async onSubscriptionChanges(subscription: Stripe.Subscription) { async onSubscriptionChanges(subscription: Stripe.Subscription) {
subscription = await this.stripe.subscriptions.retrieve(subscription.id); subscription = await this.stripe.subscriptions.retrieve(subscription.id);
if (subscription.status === 'active') { if (subscription.status === 'active') {
@@ -436,7 +436,7 @@ export class SubscriptionService {
} }
} }
@OnEvent('customer.subscription.deleted') @OnStripeEvent('customer.subscription.deleted')
async onSubscriptionDeleted(subscription: Stripe.Subscription) { async onSubscriptionDeleted(subscription: Stripe.Subscription) {
const user = await this.retrieveUserFromCustomer( const user = await this.retrieveUserFromCustomer(
typeof subscription.customer === 'string' typeof subscription.customer === 'string'
@@ -457,7 +457,7 @@ export class SubscriptionService {
}); });
} }
@OnEvent('invoice.paid') @OnStripeEvent('invoice.paid')
async onInvoicePaid(stripeInvoice: Stripe.Invoice) { async onInvoicePaid(stripeInvoice: Stripe.Invoice) {
stripeInvoice = await this.stripe.invoices.retrieve(stripeInvoice.id); stripeInvoice = await this.stripe.invoices.retrieve(stripeInvoice.id);
await this.saveInvoice(stripeInvoice); await this.saveInvoice(stripeInvoice);
@@ -469,9 +469,9 @@ export class SubscriptionService {
} }
} }
@OnEvent('invoice.created') @OnStripeEvent('invoice.created')
@OnEvent('invoice.finalization_failed') @OnStripeEvent('invoice.finalization_failed')
@OnEvent('invoice.payment_failed') @OnStripeEvent('invoice.payment_failed')
async saveInvoice(stripeInvoice: Stripe.Invoice) { async saveInvoice(stripeInvoice: Stripe.Invoice) {
stripeInvoice = await this.stripe.invoices.retrieve(stripeInvoice.id); stripeInvoice = await this.stripe.invoices.retrieve(stripeInvoice.id);
if (!stripeInvoice.customer) { if (!stripeInvoice.customer) {
@@ -674,6 +674,26 @@ export class SubscriptionService {
return customer; return customer;
} }
@OnEvent('user.updated')
async onUserUpdated(user: User) {
const customer = await this.db.userStripeCustomer.findUnique({
where: {
userId: user.id,
},
});
if (customer) {
const stripeCustomer = await this.stripe.customers.retrieve(
customer.stripeCustomerId
);
if (!stripeCustomer.deleted && stripeCustomer.email !== user.email) {
await this.stripe.customers.update(customer.stripeCustomerId, {
email: user.email,
});
}
}
}
private async retrieveUserFromCustomer(customerId: string) { private async retrieveUserFromCustomer(customerId: string) {
const customer = await this.db.userStripeCustomer.findUnique({ const customer = await this.db.userStripeCustomer.findUnique({
where: { where: {