payload-billing/src/index.ts

import type { Config } from 'payload'

import type { BillingPluginConfig, CustomerInfoExtractor } from './types'

import { createInvoicesCollection } from './collections/invoices'
import { createPaymentsCollection } from './collections/payments'
import { createRefundsCollection } from './collections/refunds'

export * from './types'

// Default customer info extractor for the built-in customer collection
export const defaultCustomerInfoExtractor: CustomerInfoExtractor = (customer) => {
  return {
    name: customer.name || '',
    email: customer.email || '',
    phone: customer.phone,
    company: customer.company,
    taxId: customer.taxId,
    billingAddress: customer.address ? {
      line1: customer.address.line1 || '',
      line2: customer.address.line2,
      city: customer.address.city || '',
      state: customer.address.state,
      postalCode: customer.address.postalCode || '',
      country: customer.address.country || '',
    } : undefined,
  }
}

export const billingPlugin = (pluginConfig: BillingPluginConfig = {}) => (config: Config): Config => {
  if (pluginConfig.disabled) {
    return config
  }

  // Initialize collections
  if (!config.collections) {
    config.collections = []
  }

  const customerSlug = pluginConfig.collections?.customers || 'customers'

  config.collections.push(
    createPaymentsCollection(pluginConfig.collections?.payments || 'payments'),
    createInvoicesCollection(
      pluginConfig.collections?.invoices || 'invoices',
      pluginConfig.collections?.customerRelation !== false ? customerSlug : undefined,
      pluginConfig.customerInfoExtractor
    ),
    createRefundsCollection(pluginConfig.collections?.refunds || 'refunds'),
  )

  // Initialize endpoints
  if (!config.endpoints) {
    config.endpoints = []
  }

  config.endpoints?.push(
    // Webhook endpoints
    {
      handler: (req) => {
        try {
          const provider = null
          if (!provider) {
            return Response.json({ error: 'Provider not found' }, { status: 404 })
          }


          // TODO: Process webhook event and update database

          return Response.json({ received: true })
        } catch (error) {
          console.error('[BILLING] Webhook error:', error)
          return Response.json({ error: 'Webhook processing failed' }, { status: 400 })
        }
      },
      method: 'post',
      path: '/billing/webhooks/:provider'
    },
  )

  // Initialize providers and onInit hook
  const incomingOnInit = config.onInit

  config.onInit = async (payload) => {
    // Execute any existing onInit functions first
    if (incomingOnInit) {
      await incomingOnInit(payload)
    }

  }

  return config
}

export default billingPlugin