Infrastructure/ghost
0
Fork 0
mirror of https://github.com/TryGhost/Ghost.git synced 2025-01-06 22:40:14 -05:00
Code Issues Activity

Updated members api to store/retrieve subscriptions

Browse source 
no-issue
This commit is contained in:
Fabien O'Carroll 2019-10-08 11:16:51 +07:00
parent 37bb12afb3
commit a6354d1acb
1 changed files with 65 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

71
core/server/services/members/api.js
View file

@ -32,9 +32,55 @@ async function setMemberMetadata(member, module, metadata) {
if (module !== 'stripe') {
return;
}
await models.Member.edit({
stripe_customers: metadata
}, {id: member.id, withRelated: ['stripe_customers']});
if (metadata.customer) {
const model = models.MemberStripeCustomer.forge({
member_id: member.id,
customer_id: metadata.customer.customer_id
}).where({
member_id: member.id,
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,
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;
}
@ -42,9 +88,22 @@ async function getMemberMetadata(member, module) {
if (module !== 'stripe') {
return;
}
const model = await models.Member.where({id: member.id}).fetch({withRelated: ['stripe_customers']});
const metadata = await model.related('stripe_customers');
return metadata.toJSON();
const customers = (await models.MemberStripeCustomer.where({
member_id: member.id
}).fetchAll()).toJSON();
const subscriptions = await customers.reduce(async (subscriptionsPromise, customer) => {
const customerSubscriptions = await models.StripeCustomerSubscription.where({
customer_id: customer.customer_id
}).fetchAll();
return (await subscriptionsPromise).concat(customerSubscriptions.toJSON());
}, []);
return {
customers: customers,
subscriptions: subscriptions
};
}
function updateMember({name}, options) {