Function handler

apps/web/pages/api/webhook/stripe.ts:43–79

(
  request: NextApiRequest,
  response: NextApiResponse
)

}

export default async function handler(
  request: NextApiRequest,
  response: NextApiResponse
) {
  const signature = request.headers['stripe-signature'] as string;
  const body = await buffer(request);

  let event;

  try {
    event = stripe.webhooks.constructEvent(body, signature, WEBHOOK_SECRET);
  } catch (exception) {
    return response.status(400).json({});
  }

  let communityId;

  switch (event.type) {
    case 'checkout.session.completed':
      communityId = await getCommunityId(event);
      await promoteAccount(communityId);
      break;
    case 'invoice.paid':
      communityId = await getCommunityId(event);
      await promoteAccount(communityId);
      break;
    case 'invoice.payment_failed':
      communityId = await getCommunityId(event);
      await downgradeAccount(communityId);
      break;

    default:
      console.error(`Unhandled event type ${event.type}`);
  }

  response.status(200).json({});
}