LuxChanLu/moleculer-stripe

/*
 * moleculer-stripe
 * Copyright (c) 2022 LuxChan S.A R.L.-S (https://github.com/LuxChanLu/moleculer-stripe)
 * MIT Licensed
 */

'use strict'

const Pluralize = require('pluralize')
const ChangeCase = require('change-case')
const { v4: UUIDV4 } = require('uuid')

const StripeMethods = { create: true, retrieve: true, update: true, del: true, list: true, confirm: false, capture: false, cancel: false, reject: false }

module.exports = {
  StripeMethods(stripeResource, options = StripeMethods, single = false, accessResource) {
    options = { ...StripeMethods, ...options }

    // Trying to normalize these !#*@$# stripe resource name
    const resource = ChangeCase.snakeCase(stripeResource, { delimiter: '.' })
    const stripeResourcePlural = Pluralize(stripeResource)
    const plural = Pluralize(resource)
    const name = ((resource.match(/\.[^.]*$/) || [])[0] || resource).replace('.', '')

    accessResource = accessResource || (stripe => stripe[stripeResourcePlural])

    const actions = {
      create: {
        handler: ({ stripe, params, meta }) => accessResource(stripe).create(params, module.exports.extra(meta))
      },
      retrieve: {
        params: { id: 'string' },
        handler: ({ stripe, params, meta }) => accessResource(stripe).retrieve(params.id, module.exports.extra(meta))
      },
      update: {
        params: { id: 'string', [name]: 'object' },
        handler: ({ stripe, params, meta }) => accessResource(stripe).update(params.id, params[name], module.exports.extra(meta))
      },
      del: {
        params: { id: 'string' },
        handler: ({ stripe, params, meta }) => accessResource(stripe).del(params.id, module.exports.extra(meta))
      },
      confirm: {
        params: { id: 'string' },
        handler: ({ stripe, params, meta }) => accessResource(stripe).confirm(params.id, module.exports.extra(meta))
      },
      capture: {
        params: { id: 'string' },
        handler: ({ stripe, params, meta }) => accessResource(stripe).capture(params.id, module.exports.extra(meta))
      },
      cancel: {
        params: { id: 'string' },
        handler: ({ stripe, params, meta }) => accessResource(stripe).cancel(params.id, module.exports.extra(meta))
      },
      reject: {
        params: { id: 'string' },
        handler: ({ stripe, params, meta }) => accessResource(stripe).reject(params.id, module.exports.extra(meta))
      },
      list: {
        handler: (ctx) => {
          const { stripe, params, meta } = ctx
          const list = accessResource(stripe).list(params, module.exports.extra(meta))
          if (meta.pagination) {
            if (!isNaN(meta.pagination)) {
              return list.autoPagingToArray({ limit: meta.pagination })
            } else if (typeof meta.pagination === 'string') {
              return list.autoPagingEach(async item => ctx.call(meta.pagination, item))
            }
          }
          return list
        }
      }
    }
    return {
      actions: Object.entries(actions)
        .filter((([name]) => options[name]))
        .reduce((actions, [name, action]) => ({ ...actions, [`${single ? resource : plural}.${name}`]: action }), {})
    }
  },
  extra(meta) {
    meta.stripe = meta.stripe || {}
    const { account, idempotency } = meta.stripe
    const extra = {
      idempotency_key: idempotency || (meta.stripe.idempotency = UUIDV4())
    }
    if (account) {
      extra.stripe_account = account
    }
    return extra
  }
}