返金申請に12時間以内で応答する — CONSUMPTION_REQUEST を Cloudflare Workers で受け止める

// Cloudflare Worker — ASSN V2 受信ハンドラ（抜粋）
export default {
  async fetch(request, env, ctx) {
    if (request.method !== "POST") return new Response("ok", { status: 200 });
 
    const body = await request.json();
    // verifyAndDecodeJWS は受信基盤側の関数（x5c チェーン検証 + payload デコード）
    const payload = await verifyAndDecodeJWS(body.signedPayload, env);
 
    if (payload.notificationType === "CONSUMPTION_REQUEST") {
      const tx = await verifyAndDecodeJWS(
        payload.data.signedTransactionInfo, env
      );
      // 受信は即 200。実処理は裏で走らせる（12時間の猶予がある）
      ctx.waitUntil(handleConsumptionRequest(tx, payload, env));
    }
 
    // 他の notificationType の処理は既存のまま
    return new Response("ok", { status: 200 });
  },
};

async function buildConsumptionBody(tx, env) {
  const accountToken = tx.appAccountToken;
  if (!accountToken) return null; // 紐づけ無しは判断材料が薄いので見送り
 
  const user = await env.SUBS.get(`user:${accountToken}`, "json");
  if (!user || !user.consentedToShare) return null; // 同意なしは送らない
 
  return {
    customerConsented: true,
    platform: 1,
    sampleContentProvided: Boolean(user.usedFreeTrial),
    appAccountToken: accountToken,
 
    consumptionStatus: deriveConsumption(user),   // 0–3
    deliveryStatus: user.hadDeliveryIssue ? 1 : 0,
    accountTenure: tenureBucket(user.firstSeenAt), // 0–7
    playTime: playTimeBucket(user.totalPlaySeconds),
    lifetimeDollarsPurchased: dollarsBucket(user.lifetimePurchasedCents),
    lifetimeDollarsRefunded: dollarsBucket(user.lifetimeRefundedCents),
    userStatus: user.banned ? 3 : 1,
 
    refundPreference: decideRefundPreference(user), // 運用ルール
  };
}
 
// 消費の度合い: 機能をどれだけ使ったかで決める
function deriveConsumption(user) {
  if (user.featureUseCount === 0) return 1;        // 未消費
  if (user.totalPlaySeconds > 3600) return 3;      // 使い切り
  return 2;                                        // 一部消費
}
 
// 累計額の帯（USドル換算のセント値を 0–7 にマップ）
function dollarsBucket(cents) {
  const usd = (cents || 0) / 100;
  if (usd <= 0) return 0;
  if (usd < 50) return 1;
  if (usd < 100) return 2;
  if (usd < 500) return 3;
  if (usd < 1000) return 4;
  if (usd < 2000) return 5;
  if (usd < 3000) return 6;
  return 7;
}

function decideRefundPreference(user) {
  // 不具合があった、または購入直後ならニュートラル
  if (user.hadDeliveryIssue) return 3;
  const minutesSincePurchase =
    (Date.now() - user.lastPurchaseAt) / 60000;
  if (minutesSincePurchase < 15) return 3;
 
  // 使い切り + 正常提供 + 返金常習でない → 断る方向
  if (deriveConsumption(user) === 3 && !user.frequentRefunder) {
    return 2;
  }
  // それ以外は表明しない（Apple に委ねる）
  return 0;
}

async function handleConsumptionRequest(tx, payload, env) {
  const consumption = await buildConsumptionBody(tx, env);
  if (!consumption) return; // 同意なし・紐づけ無しは応答しない
 
  const jwt = await makeAppStoreJWT(env); // 既存の ES256 JWT 生成
  const base = env.USE_SANDBOX
    ? "https://api.storekit-sandbox.itunes.apple.com"
    : "https://api.storekit.itunes.apple.com";
 
  const res = await fetch(
    `${base}/inApps/v1/transactions/consumption/${tx.transactionId}`,
    {
      method: "PUT",
      headers: {
        Authorization: `Bearer ${jwt}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify(consumption),
    }
  );
 
  // 成功時は 202 Accepted（ボディ無し）が返る
  if (res.status !== 202) {
    console.error("consumption PUT failed", res.status, await res.text());
    // 失敗は KV にためて、Cron Trigger で12時間以内に再送する
    await env.SUBS.put(
      `retry:consumption:${tx.transactionId}`,
      JSON.stringify({ consumption, at: Date.now() }),
      { expirationTtl: 60 * 60 * 12 }
    );
  }
}