/api/webhooks/billing (management)

BillingEventSchema = z.object({
  eventType: z.enum([
    'subscription.created',
    'subscription.updated', 
    'subscription.cancelled',
    'subscription.deleted',
    'payment.succeeded',
    'payment.failed',
    'invoice.payment_succeeded',
    'invoice.payment_failed'
  ]),
  tenantId: z.string(),
  customerId: z.string().optional(),
  subscriptionId: z.string().optional(),
  plan: z.enum(['free', 'starter', 'pro', 'enterprise']),
  status: z.enum(['active', 'cancelled', 'past_due', 'unpaid']),
  currentPeriodStart: z.string().optional(),
  currentPeriodEnd: z.string().optional(),
  metadata: z.record(z.string()).optional()
})

type BillingEvent = z.infer<typeof BillingEventSchema>

export async function POST(request: NextRequest) {
  const authError = requireBillingWebhookAuth(request)
  if (authError) {
    return authError
  }

  try {
    const body = await request.json()
    
    // Validate event schema
    const event = BillingEventSchema.parse(body)
    
    // Update tenant billing status
    await updateTenantBilling(event)
    
    return NextResponse.json({ received: true }, { status: 200 })
    
  } catch (error) {
    console.error('Billing webhook error:', error)
    
    if (error instanceof z.ZodError) {
      return NextResponse.json(
        { error: 'Invalid event schema', details: error.errors },
        { status: 400 }
      )
    }
    
    return NextResponse.json(
      { error: 'Webhook processing failed' },
      { status: 500 }
    )
  }
}

export async function GET() {
  return NextResponse.json({
    status: 'active',
    webhook: 'stripe',
    timestamp: new Date().toISOString()
  })
}

NextResponse.json(
      { error: 'Billing webhook not configured' },
      { status: 503 }
    )

NextResponse.json({ error: 'Unauthorized' }, { status: 401 })

request.json()

NextResponse.json({ received: true }, { status: 200 })

NextResponse.json(
        { error: 'Invalid event schema', details: error.errors },
        { status: 400 }
      )

NextResponse.json(
      { error: 'Webhook processing failed' },
      { status: 500 }
    )

NextResponse.json({
    status: 'active',
    webhook: 'stripe',
    timestamp: new Date().toISOString()
  })