Claude API × Stripe で使用量ベース課金を最小構成で実装する

import Anthropic from "@anthropic-ai/sdk";
 
const client = new Anthropic({ apiKey: process.env.ANTHROPIC_API_KEY });
 
const response = await client.messages.create({
  model: "claude-sonnet-4-6",
  max_tokens: 1024,
  messages: [{ role: "user", content: "こんにちは" }],
});
 
// トークン使用量を取得
const inputTokens = response.usage.input_tokens;
const outputTokens = response.usage.output_tokens;
const totalTokens = inputTokens + outputTokens;
 
console.log(
  `消費トークン: 入力 ${inputTokens} + 出力 ${outputTokens} = 合計 ${totalTokens}`
);
// 例: 消費トークン: 入力 12 + 出力 38 = 合計 50

// claude-billing.js
import Anthropic from "@anthropic-ai/sdk";
import Stripe from "stripe";
 
const anthropic = new Anthropic({ apiKey: process.env.ANTHROPIC_API_KEY });
const stripe = new Stripe(process.env.STRIPE_SECRET_KEY);
 
// Stripe ダッシュボードで作成した Meter のイベント名
const METER_EVENT_NAME = "claude_tokens";
 
/**
 * Claude API を呼び出し、消費トークン数を Stripe に記録する
 * @param {string} stripeCustomerId - Stripe の顧客 ID（例: "cus_XXXXXXXXXX"）
 * @param {string} userMessage - ユーザーのメッセージ
 */
async function callClaudeWithBilling(stripeCustomerId, userMessage) {
  // 1. Claude API を呼び出す
  const response = await anthropic.messages.create({
    model: "claude-sonnet-4-6",
    max_tokens: 1024,
    messages: [{ role: "user", content: userMessage }],
  });
 
  const totalTokens =
    response.usage.input_tokens + response.usage.output_tokens;
 
  // 2. Stripe Meter Event を送信する（課金記録）
  try {
    await stripe.v2.billing.meterEvents.create({
      event_name: METER_EVENT_NAME,
      payload: {
        value: String(totalTokens), // 文字列型で渡す必要がある
        stripe_customer_id: stripeCustomerId,
      },
    });
    console.log(
      `✅ 課金記録完了: ${totalTokens} トークン / 顧客 ${stripeCustomerId}`
    );
  } catch (billingError) {
    // 課金記録の失敗は必ずログに残す（サイレント漏れを防ぐ）
    console.error(`⚠️ 課金記録失敗: ${billingError.message}`, {
      customerId: stripeCustomerId,
      tokens: totalTokens,
      timestamp: new Date().toISOString(),
    });
    // TODO: リトライキューへの追加
  }
 
  return {
    content: response.content[0].text,
    tokensUsed: totalTokens,
  };
}
 
// 使用例
const result = await callClaudeWithBilling(
  "cus_XXXXXXXXXX", // Stripe の顧客 ID
  "Next.js のパフォーマンス最適化について教えてください"
);
 
console.log("応答:", result.content);
console.log("消費トークン:", result.tokensUsed);

// ユーザーがサインアップした際にサブスクリプションを作成
const subscription = await stripe.subscriptions.create({
  customer: stripeCustomerId,
  items: [{ price: process.env.STRIPE_USAGE_PRICE_ID }],
});

// DB に月間使用量を記録し、上限をチェックするミドルウェア
export async function checkAndTrackUsage(
  userId: string,
  estimatedCredits: number
): Promise<{ allowed: boolean; currentUsage: number; limit: number }> {
  const plan = await getUserPlan(userId);
  const currentUsage = await getMonthlyUsage(userId);
  const limit = plan.monthlyCredits; // 例: ライトプランなら1000クレジット
 
  if (currentUsage + estimatedCredits > limit) {
    return { allowed: false, currentUsage, limit };
  }
 
  await incrementMonthlyUsage(userId, estimatedCredits);
  return { allowed: true, currentUsage: currentUsage + estimatedCredits, limit };
}
 
// API エンドポイントでの利用例
export async function POST(request: Request) {
  const { prompt, userId } = await request.json();
 
  const usageCheck = await checkAndTrackUsage(userId, 10); // 推定10クレジット
  if (!usageCheck.allowed) {
    return Response.json(
      {
        error: "月間利用上限に達しました。プランをアップグレードしてください。",
        currentUsage: usageCheck.currentUsage,
        limit: usageCheck.limit,
      },
      { status: 429 }
    );
  }
 
  const subscriptionItemId = await getSubscriptionItemId(userId);
  const result = await callClaudeWithMetering(prompt, userId, subscriptionItemId);
  return Response.json({ result });
}

// app/api/stripe-webhook/route.ts
export async function POST(request: Request) {
  const sig = request.headers.get("stripe-signature")!;
  const body = await request.text();
 
  let event: Stripe.Event;
  try {
    event = stripe.webhooks.constructEvent(
      body,
      sig,
      process.env.STRIPE_WEBHOOK_SECRET!
    );
  } catch {
    return new Response("Webhook signature verification failed", { status: 400 });
  }
 
  switch (event.type) {
    case "invoice.payment_succeeded": {
      const invoice = event.data.object as Stripe.Invoice;
      await resetMonthlyUsage(invoice.customer as string); // 月間使用量をリセット
      break;
    }
    case "invoice.payment_failed": {
      const invoice = event.data.object as Stripe.Invoice;
      await suspendUserService(invoice.customer as string); // 支払い失敗時は停止
      break;
    }
  }
 
  return new Response("ok");
}