export async function POST(req: Request) {
  const { productId, email } = await req.json()

  const response = await fetch('https://api.creem.io/v1/checkouts', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.CREEM_API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      product_id: productId,
      customer_email: email,
      success_url: `${process.env.NEXT_PUBLIC_URL}/success`,
      cancel_url: `${process.env.NEXT_PUBLIC_URL}/cancel`,
    }),
  })

  const data = await response.json()
  return Response.json({ url: data.url })
}

import crypto from 'crypto'

export async function POST(req: Request) {
  const body = await req.text()
  const signature = req.headers.get('creem-signature')

  // 验证签名
  const expectedSignature = crypto
    .createHmac('sha256', process.env.CREEM_WEBHOOK_SECRET!)
    .update(body)
    .digest('hex')

  if (signature !== expectedSignature) {
    return new Response('Invalid signature', { status: 400 })
  }

  const event = JSON.parse(body)

  switch (event.type) {
    case 'checkout.completed':
      await handleCheckoutCompleted(event.data)
      break

    case 'subscription.created':
      await handleSubscriptionCreated(event.data)
      break

    case 'subscription.updated':
      await handleSubscriptionUpdated(event.data)
      break

    case 'subscription.canceled':
      await handleSubscriptionCanceled(event.data)
      break

    case 'payment.failed':
      await handlePaymentFailed(event.data)
      break
  }

  return new Response('OK')
}

const CREEM_API_URL = 'https://api.creem.io/v1'

export async function createCheckout(productId: string, email: string) {
  const response = await fetch(`${CREEM_API_URL}/checkouts`, {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.CREEM_API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      product_id: productId,
      customer_email: email,
      success_url: `${process.env.NEXT_PUBLIC_URL}/success`,
      cancel_url: `${process.env.NEXT_PUBLIC_URL}/pricing`,
    }),
  })

  if (!response.ok) {
    throw new Error('Failed to create checkout')
  }

  return response.json()
}

export async function getCustomerSubscriptions(customerId: string) {
  const response = await fetch(
    `${CREEM_API_URL}/customers/${customerId}/subscriptions`,
    {
      headers: {
        Authorization: `Bearer ${process.env.CREEM_API_KEY}`,
      },
    }
  )

  return response.json()
}

'use client'

import { useState } from 'react'

const plans = [
  { id: 'prod_free', name: 'Free', price: 0, features: ['基础功能'] },
  { id: 'prod_pro', name: 'Pro', price: 19, features: ['全部功能', '优先支持'] },
]

export default function PricingPage() {
  const [loading, setLoading] = useState<string | null>(null)

  async function handleSubscribe(productId: string) {
    setLoading(productId)

    const response = await fetch('/api/checkout', {
      method: 'POST',
      body: JSON.stringify({ productId }),
    })

    const { url } = await response.json()
    window.location.href = url
  }

  return (
    <div className="grid grid-cols-2 gap-4">
      {plans.map((plan) => (
        <div key={plan.id} className="border p-6 rounded-lg">
          <h3>{plan.name}</h3>
          <p>${plan.price}/月</p>
          <ul>
            {plan.features.map((f) => (
              <li key={f}>{f}</li>
            ))}
          </ul>
          <button
            onClick={() => handleSubscribe(plan.id)}
            disabled={loading === plan.id}
          >
            {loading === plan.id ? '处理中...' : '订阅'}
          </button>
        </div>
      ))}
    </div>
  )
}