Jayden/AFFiNE-Mirror
0
0
Fork 0
mirror of https://github.com/toeverything/AFFiNE.git synced 2026-08-23 04:51:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(server): avoid store unpaid subscriptions

Browse Source
This commit is contained in:
forehalo
2024-04-17 16:25:03 +08:00
parent 5b315bfc81
commit 651a99a48e
1 changed files with 16 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/backend/server/src/plugins/payment/service.ts
+16 -11
View File
@@ -95,7 +95,10 @@ export class SubscriptionService {
}); });
oldSubscriptions.data.forEach(sub => { oldSubscriptions.data.forEach(sub => {
if (sub.items.data[0].price.lookup_key) { if (
(sub.status === 'past_due' || sub.status === 'canceled') &&
sub.items.data[0].price.lookup_key
) {
const [oldPlan] = decodeLookupKey(sub.items.data[0].price.lookup_key); const [oldPlan] = decodeLookupKey(sub.items.data[0].price.lookup_key);
if (oldPlan === SubscriptionPlan.Pro) { if (oldPlan === SubscriptionPlan.Pro) {
canHaveEarlyAccessDiscount = false; canHaveEarlyAccessDiscount = false;
@@ -415,23 +418,22 @@ export class SubscriptionService {
@OnEvent('customer.subscription.created') @OnEvent('customer.subscription.created')
@OnEvent('customer.subscription.updated') @OnEvent('customer.subscription.updated')
async onSubscriptionChanges(subscription: Stripe.Subscription) { async onSubscriptionChanges(subscription: Stripe.Subscription) {
const user = await this.retrieveUserFromCustomer( if (subscription.status === 'active') {
subscription.customer as string const user = await this.retrieveUserFromCustomer(
); subscription.customer as string
);
await this.saveSubscription(user, subscription); await this.saveSubscription(user, subscription);
} else {
await this.onSubscriptionDeleted(subscription);
}
} }
@OnEvent('customer.subscription.deleted') @OnEvent('customer.subscription.deleted')
async onSubscriptionDeleted(subscription: Stripe.Subscription) { async onSubscriptionDeleted(subscription: Stripe.Subscription) {
const user = await this.retrieveUserFromCustomer(
subscription.customer as string
);
await this.db.userSubscription.deleteMany({ await this.db.userSubscription.deleteMany({
where: { where: {
stripeSubscriptionId: subscription.id, stripeSubscriptionId: subscription.id,
userId: user.id,
}, },
}); });
} }
@@ -749,7 +751,10 @@ export class SubscriptionService {
const subscribed = oldSubscriptions.data.some(sub => { const subscribed = oldSubscriptions.data.some(sub => {
if (sub.items.data[0].price.lookup_key) { if (sub.items.data[0].price.lookup_key) {
const [oldPlan] = decodeLookupKey(sub.items.data[0].price.lookup_key); const [oldPlan] = decodeLookupKey(sub.items.data[0].price.lookup_key);
return oldPlan === plan; return (
oldPlan === plan &&
(sub.status === 'past_due' || sub.status === 'canceled')
);
} }
return false; return false;
}); });