サブスクの返金にアプリが気づかない — REFUND 通知と Voided Purchases で権限を失効させる実装メモ

// 起動時とフォアグラウンド復帰時に entitlement をストアの正と照合する
import { useEffect } from 'react';
import { AppState } from 'react-native';
import Purchases, { CustomerInfo } from 'react-native-purchases';
import { useEntitlementStore } from '@/stores/entitlement';
 
function applyCustomerInfo(info: CustomerInfo) {
  const isPremium = info.entitlements.active['premium'] !== undefined;
  // キャッシュは true でも false でも必ず上書きする
  useEntitlementStore.getState().setPremium(isPremium);
}
 
export function useEntitlementSync() {
  useEffect(() => {
    // 1. 起動直後: キャッシュではなくストア側の最新状態で上書き
    Purchases.getCustomerInfo().then(applyCustomerInfo).catch(() => {});
 
    // 2. 起動中の変化（返金・期限切れ・別端末での購入）を受け取る
    Purchases.addCustomerInfoUpdateListener(applyCustomerInfo);
 
    // 3. フォアグラウンド復帰時にも照合する
    const sub = AppState.addEventListener('change', (state) => {
      if (state === 'active') {
        Purchases.getCustomerInfo().then(applyCustomerInfo).catch(() => {});
      }
    });
    return () => sub.remove();
  }, []);
}

// App Store Server Notifications V2 を受けて REFUND で権限を失効させる
import express from 'express';
import {
  SignedDataVerifier,
  Environment,
} from '@apple/app-store-server-library';
import { readFileSync } from 'node:fs';
import { revokeEntitlement } from './entitlement-store';
 
const appleRootCAs = [readFileSync('certs/AppleRootCA-G3.cer')];
 
const verifier = new SignedDataVerifier(
  appleRootCAs,
  true, // オンラインの証明書失効確認を有効化
  Environment.PRODUCTION,
  'com.example.wallpaper', // 自分の bundleId に置き換える
);
 
const app = express();
app.use(express.json());
 
app.post('/webhooks/app-store', async (req, res) => {
  try {
    const payload = await verifier.verifyAndDecodeNotification(
      req.body.signedPayload,
    );
    if (payload.notificationType === 'REFUND') {
      const tx = await verifier.verifyAndDecodeTransaction(
        payload.data?.signedTransactionInfo ?? '',
      );
      // appAccountToken は購入時にアプリ側から渡した自社ユーザーID
      await revokeEntitlement(tx.appAccountToken, tx.productId);
    }
    res.sendStatus(200);
  } catch {
    // 署名検証に失敗したリクエストは偽装の可能性があるため拒否する
    res.sendStatus(401);
  }
});

// Google Play: 返金で無効化された購入を日次バッチで照合する
import { google } from 'googleapis';
 
const androidpublisher = google.androidpublisher('v3');
 
export async function syncVoidedPurchases(packageName: string) {
  const auth = new google.auth.GoogleAuth({
    scopes: ['https://www.googleapis.com/auth/androidpublisher'],
  });
  const res = await androidpublisher.purchases.voidedpurchases.list({
    auth,
    packageName,
  });
  for (const voided of res.data.voidedPurchases ?? []) {
    // voidedReason: 1=返金 2=チャージバック（0はその他）
    await revokeByPurchaseToken(voided.purchaseToken);
  }
}