overleaf/services/web/scripts/recurly/get_paypal_accounts_csv.js

108 lines
3.1 KiB
JavaScript
Raw Normal View History

const RecurlyWrapper = require('../../app/src/Features/Subscription/RecurlyWrapper')
const async = require('async')
const CSVParser = require('json2csv').Parser
const NOW = new Date()
const slowCallback = (callback, error, data) =>
setTimeout(() => callback(error, data), 80)
const handleAPIError = (type, account, error, callback) => {
console.warn(
`Errors getting ${type} for account ${account.account_code}`,
error
)
if (typeof error === 'string' && error.match(/429$/)) {
return setTimeout(callback, 1000 * 60 * 5)
}
slowCallback(callback)
}
const getAccountSubscription = (account, callback) =>
RecurlyWrapper.getSubscriptions(account.account_code, (error, response) => {
if (error) {
return handleAPIError('subscriptions', account, error, callback)
}
slowCallback(callback, null, response.subscriptions[0])
})
const isAccountUsingPaypal = (account, callback) =>
RecurlyWrapper.getBillingInfo(account.account_code, (error, response) => {
if (error) {
return handleAPIError('billing info', account, error, callback)
}
if (response.billing_info.paypal_billing_agreement_id) {
return slowCallback(callback, null, true)
}
slowCallback(callback, null, false)
})
const printAccountCSV = (account, callback) => {
isAccountUsingPaypal(account, (error, isPaypal) => {
if (error || !isPaypal) {
return callback(error)
}
getAccountSubscription(account, (error, subscription) => {
if (error || !subscription) {
return callback(error)
}
const endAt = new Date(subscription.current_period_ends_at)
if (subscription.expires_at) {
return callback()
}
const csvData = {
email: account.email,
first_name: account.first_name,
last_name: account.last_name,
hosted_login_token: account.hosted_login_token,
billing_info_url: `https://sharelatex.recurly.com/account/billing_info/edit?ht=${account.hosted_login_token}`,
account_management_url: `https://sharelatex.recurly.com/account/${account.hosted_login_token}`,
current_period_ends_at: `${endAt.getFullYear()}-${
endAt.getMonth() + 1
}-${endAt.getDate()}`,
current_period_ends_at_segment: parseInt(
((endAt - NOW) / 1000 / 3600 / 24 / 365) * 7
),
}
callback(null, csvData)
})
})
}
const printAccountsCSV = callback => {
RecurlyWrapper.getPaginatedEndpoint(
'accounts',
{ state: 'subscriber' },
(error, accounts) => {
if (error) {
return callback(error)
}
async.mapSeries(accounts, printAccountCSV, (error, csvData) => {
csvData = csvData.filter(d => !!d)
callback(error, csvData)
})
}
)
}
const csvFields = [
'email',
'first_name',
'last_name',
'hosted_login_token',
'billing_info_url',
'account_management_url',
'current_period_ends_at',
'current_period_ends_at_segment',
]
const csvParser = new CSVParser({ csvFields })
// print each account
printAccountsCSV((error, csvData) => {
if (error) {
throw error
}
console.log(csvParser.parse(csvData))
process.exit()
})