4nk/lecoffre-back
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed webhooks by env

Browse Source
This commit is contained in:
Vins 2024-04-18 11:31:00 +02:00
parent 55519a845a
commit dacb9f0b90
2 changed files with 25 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/common/webhooks/stripeWebhooks.ts
View File

@ -24,10 +24,14 @@ export default class StripeWebhooks extends ApiController {
const event = req.body; const event = req.body;
switch (event.type) { switch (event.type) {
case "invoice.payment_succeeded": //Manage plan switch + recurring payment
if (event.data.object.billing_reason !== "subscription_update") break; case "invoice.payment_succeeded":
if (event.data.object.billing_reason !== "subscription_update" && event.data.object.billing_reason !== "subscription_cycle") break;
const stripeSubscription = await this.stripeService.getClient().subscriptions.retrieve(event.data.object.subscription); const stripeSubscription = await this.stripeService.getClient().subscriptions.retrieve(event.data.object.subscription);
if(stripeSubscription.metadata['env'] !== this.backendVariables.ENV) break;
const existingSubscription = await this.subscriptionsService.get({where : {stripe_subscription_id : stripeSubscription.id}}); const existingSubscription = await this.subscriptionsService.get({where : {stripe_subscription_id : stripeSubscription.id}});
if(!existingSubscription[0]) break; if(!existingSubscription[0]) break;
const subscriptionUpdate: any = {}; const subscriptionUpdate: any = {};
@ -42,19 +46,30 @@ export default class StripeWebhooks extends ApiController {
subscriptionUpdate.type = "UNLIMITED"; subscriptionUpdate.type = "UNLIMITED";
} }
const subscriptionEntityUpdate = Subscription.hydrate<Subscription>(subscriptionUpdate); const subscriptionEntityUpdate = Subscription.hydrate<Subscription>(subscriptionUpdate);
await validateOrReject(subscriptionEntityUpdate, { groups: ["updateSubscription"], forbidUnknownValues: false }); await validateOrReject(subscriptionEntityUpdate, { groups: ["updateSubscription"], forbidUnknownValues: false });
await this.subscriptionsService.update(existingSubscription[0].uid ,subscriptionEntityUpdate); await this.subscriptionsService.update(existingSubscription[0].uid ,subscriptionEntityUpdate);
//Manage subscription creation and first payment
case "checkout.session.completed": case "checkout.session.completed":
if (event.data.object.status !== "complete") break; if (event.data.object.status !== "complete") break;
const subscription = JSON.parse(event.data.object.metadata.subscription); const subscription = JSON.parse(event.data.object.metadata.subscription);
const env = event.data.object.metadata.env;
if (env !== this.backendVariables.ENV) break;
subscription.stripe_subscription_id = event.data.object.subscription; subscription.stripe_subscription_id = event.data.object.subscription;
await this.stripeService.getClient().subscriptions.update(subscription.stripe_subscription_id, {
metadata: {
env: env,
},
}
)
const subscriptionInfo = await this.stripeService const subscriptionInfo = await this.stripeService
.getClient() .getClient()
.subscriptions.retrieve(subscription.stripe_subscription_id); .subscriptions.retrieve(subscription.stripe_subscription_id);
@ -65,10 +80,14 @@ export default class StripeWebhooks extends ApiController {
const subscriptionEntity = Subscription.hydrate<Subscription>(subscription); const subscriptionEntity = Subscription.hydrate<Subscription>(subscription);
await validateOrReject(subscriptionEntity, { groups: ["createSubscription"], forbidUnknownValues: false }); await validateOrReject(subscriptionEntity, { groups: ["createSubscription"], forbidUnknownValues: false });
await this.subscriptionsService.create(subscriptionEntity); await this.subscriptionsService.create(subscriptionEntity);
break; break;
//Manage plan expiration
case "customer.subscription.deleted": case "customer.subscription.deleted":
const currentSubscription = await this.stripeService.getClient().subscriptions.retrieve(event.data.object.id);
if(currentSubscription.metadata['env'] !== this.backendVariables.ENV) break;
const subscriptionToDelete = await this.subscriptionsService.get({where : {stripe_subscription_id : event.data.object.id}}); const subscriptionToDelete = await this.subscriptionsService.get({where : {stripe_subscription_id : event.data.object.id}});
if(!subscriptionToDelete[0]) break; if(!subscriptionToDelete[0]) break;
await this.subscriptionsService.delete(subscriptionToDelete[0].uid); await this.subscriptionsService.delete(subscriptionToDelete[0].uid);

1
src/services/common/StripeService/StripeService.ts
View File

@ -30,6 +30,7 @@ export default class StripeService {
cancel_url: this.variables.APP_HOST + "/subscription/error", cancel_url: this.variables.APP_HOST + "/subscription/error",
metadata: { metadata: {
subscription: JSON.stringify(subscription), subscription: JSON.stringify(subscription),
env: this.variables.ENV,
}, },
}); });