TryGhost/Ghost
1
0
Fork 0
mirror of https://github.com/TryGhost/Ghost.git synced 2024-12-28 05:14:12 +03:00
Code Issues Projects Releases Wiki Activity

Updated setMemberMetadata to use upsert method

Browse Source 
no-issue

Much cleaner now :)
This commit is contained in:
Fabien O'Carroll 2019-10-08 13:11:30 +07:00
parent 3366bd1254
commit ee0449245a
1 changed files with 2 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
core/server/services/members/api.js
View File

@ -34,51 +34,15 @@ async function setMemberMetadata(member, module, metadata) {
}
if (metadata.customer) {
const model = models.MemberStripeCustomer.forge({
member_id: member.id,
customer_id: metadata.customer.customer_id
}).where({
member_id: member.id,
await models.MemberStripeCustomer.upsert(metadata.customer, {
customer_id: metadata.customer.customer_id
});
try {
await model.save(metadata.customer, {
method: 'update'
});
} catch (err) {
if (!(err instanceof models.MemberStripeCustomer.NoRowsUpdatedError)) {
throw err;
}
console.log(err);
await model.save(metadata.customer, {
method: 'insert'
});
}
}
if (metadata.subscription) {
const model = await models.StripeCustomerSubscription.forge({
customer_id: metadata.subscription.customer_id,
subscription_id: metadata.subscription.subscription_id
}).where({
customer_id: metadata.subscription.customer_id,
await models.StripeCustomerSubscription.upsert(metadata.subscription, {
subscription_id: metadata.subscription.subscription_id
});
try {
await model.save(metadata.subscription, {
method: 'update'
});
} catch (err) {
if (!(err instanceof models.StripeCustomerSubscription.NoRowsUpdatedError)) {
throw err;
}
console.log(err);
await model.save(metadata.subscription, {
method: 'insert'
});
}
}
return;