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

const RecurlyWrapper = require('../../app/src/Features/Subscription/RecurlyWrapper')
const async = require('async')
const minimist = require('minimist')

const slowCallback = (callback, error, data) =>
  setTimeout(() => callback(error, data), 80)

const handleAPIError = (source, id, error, callback) => {
  console.warn(`Errors in ${source} with id=${id}`, error)
  if (typeof error === 'string' && error.match(/429$/)) {
    return setTimeout(callback, 1000 * 60 * 5)
  }
  slowCallback(callback)
}

const attemptInvoiceCollection = (invoice, callback) => {
  isAccountUsingPaypal(invoice, (error, isPaypal) => {
    if (error || !isPaypal) {
      return callback(error)
    }
    const accountId = invoice.account.url.match(/accounts\/(.*)/)[1]
    if (USERS_COLLECTED.indexOf(accountId) > -1) {
      console.warn(`Skipping duplicate user ${accountId}`)
      return callback()
    }
    INVOICES_COLLECTED.push(invoice.invoice_number)
    USERS_COLLECTED.push(accountId)
    if (DRY_RUN) {
      return callback()
    }
    RecurlyWrapper.attemptInvoiceCollection(
      invoice.invoice_number,
      (error, response) => {
        if (error) {
          return handleAPIError(
            'attemptInvoiceCollection',
            invoice.invoice_number,
            error,
            callback
          )
        }
        slowCallback(callback, null)
      }
    )
  })
}

const isAccountUsingPaypal = (invoice, callback) => {
  const accountId = invoice.account.url.match(/accounts\/(.*)/)[1]
  RecurlyWrapper.getBillingInfo(accountId, (error, response) => {
    if (error) {
      return handleAPIError('billing info', accountId, error, callback)
    }
    if (response.billing_info.paypal_billing_agreement_id) {
      return slowCallback(callback, null, true)
    }
    slowCallback(callback, null, false)
  })
}

const attemptInvoicesCollection = callback => {
  RecurlyWrapper.getPaginatedEndpoint(
    'invoices',
    { state: 'past_due' },
    (error, invoices) => {
      console.log('invoices', invoices.length)
      if (error) {
        return callback(error)
      }
      async.eachSeries(invoices, attemptInvoiceCollection, callback)
    }
  )
}

const argv = minimist(process.argv.slice(2))
const DRY_RUN = argv.n !== undefined
const INVOICES_COLLECTED = []
const USERS_COLLECTED = []
attemptInvoicesCollection(error => {
  if (error) {
    throw error
  }
  console.log(
    `DONE (DRY_RUN=${DRY_RUN}). ${
      INVOICES_COLLECTED.length
    } invoices collected for ${USERS_COLLECTED.length} users.`
  )
  console.log({ INVOICES_COLLECTED, USERS_COLLECTED })
  process.exit()
})