Skip to content

Stripe Webhook

本文介绍如何使用 Hono 创建 API 以接收 Stripe Webhook 事件。

准备工作

请首先安装官方 Stripe SDK:

bash
npm install stripe

并将以下值放入 .dev.vars 文件中以插入 Stripe API 密钥:

STRIPE_API_KEY=sk_test_xxx
STRIPE_WEBHOOK_SECRET=whsec_xxx

你可以通过以下文档了解有关 Stripe API 密钥的更多信息:

如何保护 Stripe Webhook 事件的 API

处理 webhook 事件的 API 是公开可访问的。因此,需要一种机制来保护它免受攻击,例如恶意第三方欺骗 Stripe 的 webhook 事件对象并发送请求。在 Stripe 的情况下,你可以通过颁发 webhook secret 并验证每个请求来保护 API。

了解更多: https://docs.stripe.com/webhooks?lang=node#verify-official-libraries

通过托管环境或框架实现 Webhook API

为了使用 Stripe 执行签名验证,需要原始请求体(raw request body)。当使用框架时,你需要确保原始请求体未被修改。如果对原始请求体进行了任何更改,验证将失败。

在 Hono 的情况下,我们可以通过 context.req.text() 方法获取原始请求体。因此,我们可以像以下示例一样创建 webhook API:

ts
import Stripe from 'stripe'
import { Hono } from 'hono'
import { env } from 'hono/adapter'

const app = new Hono()

app.post('/webhook', async (context) => {
  const { STRIPE_SECRET_API_KEY, STRIPE_WEBHOOK_SECRET } =
    env(context)
  const stripe = new Stripe(STRIPE_SECRET_API_KEY)
  const signature = context.req.header('stripe-signature')
  try {
    if (!signature) {
      return context.text('', 400)
    }
    const body = await context.req.text()
    const event = await stripe.webhooks.constructEventAsync(
      body,
      signature,
      STRIPE_WEBHOOK_SECRET
    )
    switch (event.type) {
      case 'payment_intent.created': {
        console.log(event.data.object)
        break
      }
      default:
        break
    }
    return context.text('', 200)
  } catch (err) {
    const errorMessage = `⚠️  Webhook 签名验证失败。 ${ // Webhook 签名验证失败。
      err instanceof Error ? err.message : '内部服务器错误' // 内部服务器错误
    }`
    console.log(errorMessage)
    return context.text(errorMessage, 400)
  }
})

export default app

另请参阅

在 MIT 许可证下发布。