はじめに
支払いイベントが発生したときに、サーバーレス関数とバックグラウンドジョブを自動的に実行します。支払いを処理し、通知を送信し、データベースを更新し、Inngestの信頼性の高い関数実行プラットフォームを使用して複雑なワークフローを実行します。
この統合には、関数設定からのInngestのWebhook URLが必要です。
始め方
Webhookセクションを開く
Dodo Paymentsのダッシュボードで、Webhooks → + エンドポイントを追加に移動し、統合のドロップダウンを展開します。 Inngestを選択
Inngest統合カードを選択します。
Inngest関数を作成
Inngestで新しい関数を作成し、関数設定からWebhook URLをコピーします。
Webhook URLを貼り付け
InngestのWebhook URLをエンドポイント設定に貼り付けます。
変換を設定
イベントをInngest関数用にフォーマットするために変換コードを編集します。
テストと作成
サンプルペイロードでテストし、作成をクリックして統合を有効にします。
完了！
🎉 支払いイベントが自動的にInngest関数をトリガーします。
変換コードの例
基本的なイベントペイロード
function handler(webhook) {
if (webhook.eventType === "payment.succeeded") {
const p = webhook.payload.data;
webhook.payload = {
name: "payment.succeeded",
data: {
payment_id: p.payment_id,
amount: (p.total_amount / 100).toFixed(2),
currency: p.currency || "USD",
customer_email: p.customer.email,
customer_name: p.customer.name,
payment_method: p.payment_method || "unknown"
},
user: {
email: p.customer.email
},
ts: Math.floor(new Date(webhook.payload.timestamp).getTime() / 1000)
};
}
return webhook;
}
サブスクリプションイベントハンドラー
function handler(webhook) {
const s = webhook.payload.data;
switch (webhook.eventType) {
case "subscription.active":
webhook.payload = {
name: "subscription.started",
data: {
subscription_id: s.subscription_id,
customer_email: s.customer.email,
customer_name: s.customer.name,
product_id: s.product_id,
amount: (s.recurring_pre_tax_amount / 100).toFixed(2),
frequency: s.payment_frequency_interval,
next_billing: s.next_billing_date
},
user: {
email: s.customer.email
},
ts: Math.floor(new Date(webhook.payload.timestamp).getTime() / 1000)
};
break;
case "subscription.cancelled":
webhook.payload = {
name: "subscription.cancelled",
data: {
subscription_id: s.subscription_id,
customer_email: s.customer.email,
cancelled_at: s.cancelled_at,
cancel_at_next_billing: s.cancel_at_next_billing_date
},
user: {
email: s.customer.email
},
ts: Math.floor(new Date(webhook.payload.timestamp).getTime() / 1000)
};
break;
}
return webhook;
}
争議イベントハンドラー
function handler(webhook) {
if (webhook.eventType.startsWith("dispute.")) {
const d = webhook.payload.data;
webhook.payload = {
name: webhook.eventType,
data: {
dispute_id: d.dispute_id,
payment_id: d.payment_id,
amount: (d.amount / 100).toFixed(2),
status: d.dispute_status,
stage: d.dispute_stage,
remarks: d.remarks || "",
urgent: webhook.eventType === "dispute.opened"
},
user: {
email: d.customer?.email || "unknown"
},
ts: Math.floor(new Date(webhook.payload.timestamp).getTime() / 1000)
};
}
return webhook;
}
一般的なInngestの使用例
- 確認メールを送信
- 顧客記録を更新
- 返金を処理
- 請求書を生成
- 在庫を更新
- 新しいサブスクライバーを歓迎
- キャンセルを処理
- 更新リマインダーを送信
- 請求サイクルを更新
- 失敗した支払いを処理
- 収益指標を更新
- 顧客行動を追跡
- レポートを生成
- データを分析プラットフォームに同期
- 離脱率を計算
ヒント
- より良い関数の整理のために説明的なイベント名を使用する
- 関数実行のためにユーザーコンテキストを含める
- イベントの順序付けのために適切なタイムスタンプを設定する
- イベント間でデータを一貫して構造化する
- Inngestの再試行とエラーハンドリング機能を使用する
トラブルシューティング
- Webhook URLが正しくアクティブであることを確認する
- Inngest関数がデプロイされてアクティブであることを確認する
- イベント名が関数トリガーと一致していることを確認する
- Inngest関数のログを確認してエラーを探す
- ペイロード構造がInngestの期待に一致していることを確認する
- イベント名が正しくフォーマットされていることを確認する
- 必要なすべてのフィールドが含まれていることを確認する
- InngestのWebhookテストツールでテストする
