payload-billing/src/index.ts

import type { Config } from 'payload'

import type { BillingPluginConfig } from './types'

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

export * from './types'

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'),
    createCustomersCollection(customerSlug),
    createInvoicesCollection(
      pluginConfig.collections?.invoices || 'invoices',
      pluginConfig.collections?.customerRelation !== false ? customerSlug : undefined
    ),
    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