Leahnaya/website
1
0
Fork 0
mirror of https://github.com/PretendoNetwork/website.git synced 2026-08-23 17:17:02 -05:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Updated webhook timestamp updates and remove all past subscriptions

Browse Source
This commit is contained in:
Jonathan Barrow
2022-07-04 11:54:15 -04:00
parent 2f02d5a1f6
commit 8e7ca070a0
1 changed files with 29 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/util.js
View File

@@ -139,16 +139,21 @@ async function handleStripeEvent(event) {
return;
}
const oldSubscriptionId = pnid.get('connections.stripe.subscription_id');
const currentSubscriptionId = pnid.get('connections.stripe.subscription_id');
if (subscription.status === 'canceled' && oldSubscriptionId && subscription.id !== oldSubscriptionId) {
if (subscription.status === 'canceled' && currentSubscriptionId && subscription.id !== currentSubscriptionId) {
// Canceling old subscription, do nothing but update webhook date
const updateData = {
'connections.stripe.latest_webhook_timestamp': event.created
};
await database.PNID.updateOne({ pid }, { $set: updateData }, { upsert: true }).exec();
await database.PNID.updateOne({
pid,
'connections.stripe.latest_webhook_timestamp': {
$lte: event.created
}
}, { $set: updateData }).exec();
return;
}
@@ -180,14 +185,31 @@ async function handleStripeEvent(event) {
}
}
await database.PNID.updateOne({ pid }, { $set: updateData }, { upsert: true }).exec();
await database.PNID.updateOne({
pid,
'connections.stripe.latest_webhook_timestamp': {
$lte: event.created
}
}, { $set: updateData }).exec();
if (subscription.status === 'active') {
if (oldSubscriptionId) {
// Get all the customers active subscriptions
const { data: activeSubscriptions } = await stripe.subscriptions.list({
limit: 100,
status: 'active',
customer: customer.id
});
// Order subscriptions by creation time and remove the latest one
const orderedActiveSubscriptions = activeSubscriptions.sort((a, b) => b.created - a.created);
const pastSubscriptions = orderedActiveSubscriptions.slice(1);
// Remove any old past subscriptions that might still be hanging around
for (const pastSubscription of pastSubscriptions) {
try {
await stripe.subscriptions.del(oldSubscriptionId);
await stripe.subscriptions.del(pastSubscription.id);
} catch (error) {
logger.error(`Error canceling old user subscription | ${customer.id}, ${pid}, ${oldSubscriptionId} | - ${error.message}`);
logger.error(`Error canceling old user subscription | ${customer.id}, ${pid}, ${pastSubscription.id} | - ${error.message}`);
}
}
@@ -225,7 +247,6 @@ async function handleStripeEvent(event) {
logger.error(`Error sending email | ${customer.id}, ${customer.email}, ${pid} | - ${error.message}`);
}
}
}
}