StoreKit 2 を「実装して終わり」にしない — 解約通知・復帰オファー・価格実験で購読収益を育てる運用設計

// iOS クライアント側 — 購読状態変化を Firebase Analytics に記録
import FirebaseAnalytics
import StoreKit
 
class SubscriptionAnalyticsManager {
    static let shared = SubscriptionAnalyticsManager()
 
    // 購読開始イベントを記録
    func logSubscriptionStarted(product: Product, isFreeTrial: Bool) {
        Analytics.logEvent("subscription_started", parameters: [
            "product_id": product.id,
            "is_free_trial": isFreeTrial,
            "price_locale": product.priceLocale.identifier,
            "price": product.price as NSDecimalNumber,
        ])
    }
 
    // 解約フロー開始（Manage Subscriptions 遷移）を記録
    func logSubscriptionCancelIntent(source: String) {
        Analytics.logEvent("subscription_cancel_intent", parameters: [
            "source": source,  // "settings" | "paywall" | "offboarding_flow"
            "days_since_start": daysSinceSubscriptionStart(),
        ])
    }
 
    // 解約完了を Server Notification 経由で Firebase に記録
    func logSubscriptionCancelled(originalTransactionId: String, daysActive: Int) {
        Analytics.logEvent("subscription_cancelled", parameters: [
            "days_active": daysActive,
            "cancel_reason_category": inferCancelCategory(daysActive: daysActive),
        ])
    }
 
    private func inferCancelCategory(daysActive: Int) -> String {
        switch daysActive {
        case 0...3: return "immediate_churn"    // 価値を感じられなかった
        case 4...14: return "early_churn"       // オンボーディング失敗
        case 15...60: return "mid_term_churn"   // 利用頻度低下
        default: return "long_term_churn"        // 競合への乗り換え等
        }
    }
}

-- Antigravity に「月別コホートの30日チャーン率を計算するBigQueryクエリ」を依頼
 
WITH cohorts AS (
  SELECT
    FORMAT_DATE('%Y-%m', DATE(TIMESTAMP_MICROS(event_timestamp))) AS cohort_month,
    user_pseudo_id,
    MIN(event_timestamp) AS first_subscribe_ts
  FROM `your_project.analytics_XXXXXXXX.events_*`
  WHERE event_name = 'subscription_started'
  GROUP BY 1, 2
),
cancellations AS (
  SELECT
    user_pseudo_id,
    event_timestamp AS cancel_ts
  FROM `your_project.analytics_XXXXXXXX.events_*`
  WHERE event_name = 'subscription_cancelled'
)
SELECT
  c.cohort_month,
  COUNT(DISTINCT c.user_pseudo_id) AS subscribers,
  COUNT(DISTINCT CASE
    WHEN TIMESTAMP_DIFF(TIMESTAMP_MICROS(can.cancel_ts), TIMESTAMP_MICROS(c.first_subscribe_ts), DAY) <= 30
    THEN c.user_pseudo_id
  END) AS churned_within_30d,
  ROUND(
    100.0 * COUNT(DISTINCT CASE
      WHEN TIMESTAMP_DIFF(TIMESTAMP_MICROS(can.cancel_ts), TIMESTAMP_MICROS(c.first_subscribe_ts), DAY) <= 30
      THEN c.user_pseudo_id END) / COUNT(DISTINCT c.user_pseudo_id),
    1
  ) AS churn_rate_30d_pct
FROM cohorts c
LEFT JOIN cancellations can USING (user_pseudo_id)
GROUP BY 1
ORDER BY 1 DESC
LIMIT 24

// OffboardingFlowManager.swift
// 解約フロー中にPromo Offerを提示するロジック
 
import StoreKit
 
class OffboardingFlowManager: ObservableObject {
    @Published var promoOfferState: PromoOfferState = .checking
 
    enum PromoOfferState {
        case checking
        case available(Product.SubscriptionOffer)
        case notAvailable
        case redeemed
    }
 
    // 解約フロー開始時に呼び出す
    func loadPromoOffer(for product: Product) async {
        guard let subscription = product.subscription else { return }
 
        // サーバー側でユーザーの購読履歴を確認してオファー適用可否を決定
        let eligibility = await checkOfferEligibility(for: product)
        guard eligibility.isEligible else {
            await MainActor.run { promoOfferState = .notAvailable }
            return
        }
 
        // Promotional Offer の一覧から適切なものを選択
        // オファーIDは App Store Connect で設定（例: "winback_3months_50pct"）
        if let offer = subscription.promotionalOffers.first(where: {
            $0.id == eligibility.offerId
        }) {
            await MainActor.run { promoOfferState = .available(offer) }
        }
    }
 
    // Promotional Offer を使って購入（再契約）を実行
    func redeemOffer(product: Product, offer: Product.SubscriptionOffer) async throws {
        // サーバーから署名付きオファーパラメータを取得
        let signature = try await fetchOfferSignature(
            productId: product.id,
            offerId: offer.id
        )
 
        let purchaseOptions: Set<Product.PurchaseOption> = [
            .promotionalOffer(offerID: offer.id, keyID: signature.keyId,
                              nonce: signature.nonce, signature: signature.signature,
                              timestamp: signature.timestamp)
        ]
 
        let result = try await product.purchase(options: purchaseOptions)
        switch result {
        case .success(let verification):
            // 購入確認 → Server Notification でも状態更新される
            await MainActor.run { promoOfferState = .redeemed }
        case .userCancelled:
            break  // ユーザーが断った場合は通常の解約フローへ
        case .pending:
            break
        @unknown default:
            break
        }
    }
}

// PricingExperimentManager.swift
// Firebase Remote Config で価格実験を管理
 
import FirebaseRemoteConfig
 
class PricingExperimentManager {
    private let remoteConfig = RemoteConfig.remoteConfig()
 
    // 初期化：Remote Config のデフォルト値を設定
    func configure() {
        let defaults: [String: NSObject] = [
            "paywall_variant": "control" as NSObject,  // "control" | "annual_emphasis" | "trial_emphasis"
            "show_promo_badge": false as NSObject,
            "trial_duration_days": 7 as NSObject,
        ]
        remoteConfig.setDefaults(defaults)
    }
 
    // 現在のバリアント取得
    var paywallVariant: String {
        remoteConfig.configValue(forKey: "paywall_variant").stringValue ?? "control"
    }
 
    var trialDurationDays: Int {
        Int(remoteConfig.configValue(forKey: "trial_duration_days").numberValue)
    }
 
    // Remote Config を最新化（アプリ起動時に呼び出す）
    func fetchAndActivate() async throws {
        try await remoteConfig.fetchAndActivate()
        // バリアントが変化したらログを記録
        Analytics.logEvent("experiment_assigned", parameters: [
            "paywall_variant": paywallVariant,
        ])
    }
}
 
// PaywallView.swift — バリアントに応じて表示を変える
struct PaywallView: View {
    @StateObject private var pricing = PricingExperimentManager()
 
    var body: some View {
        Group {
            switch pricing.paywallVariant {
            case "annual_emphasis":
                AnnualEmphasisPaywallView()  // 年額プランを先頭に
            case "trial_emphasis":
                TrialEmphasisPaywallView()    // 無料トライアルを強調
            default:
                ControlPaywallView()         // デフォルト表示
            }
        }
        .task {
            try? await pricing.fetchAndActivate()
        }
    }
}

// win-back-campaign.ts (Cloudflare Workers + Queues)
// EXPIRED イベント受信 → 自動Win-backシーケンス開始
 
export async function triggerWinBackCampaign(
  originalTransactionId: string,
  userId: string,
  productId: string,
  env: Env
) {
  // Step 1: Win-back対象ユーザーとしてキューに積む
  await env.WIN_BACK_QUEUE.send({
    userId,
    originalTransactionId,
    productId,
    expiredAt: new Date().toISOString(),
    sequence: 0,  // シーケンス番号（0から開始）
  });
}
 
// キューのコンシューマ（別ワーカー）
export default {
  async queue(batch: MessageBatch<WinBackMessage>, env: Env) {
    for (const message of batch.messages) {
      const { userId, sequence, expiredAt } = message.body;
      const expiredDate = new Date(expiredAt);
      const daysSinceExpiry = Math.floor(
        (Date.now() - expiredDate.getTime()) / (1000 * 60 * 60 * 24)
      );
 
      // シーケンス別のアクション
      if (sequence === 0 && daysSinceExpiry >= 3) {
        // Day 3: プッシュ通知「お帰りなさい + 特別オファー」
        await sendPushNotification(userId, {
          title: "いつもありがとうございます",
          body: "復帰特典として1ヶ月無料をご用意しました",
          data: { type: "win_back", offerId: "winback_1month_free" },
        }, env);
        // 次のシーケンスをDay 14にスケジュール
        await scheduleNextSequence(message.body, 1, 14, env);
 
      } else if (sequence === 1 && daysSinceExpiry >= 14) {
        // Day 14: プッシュ通知「最後のオファー」
        await sendPushNotification(userId, {
          title: "最後のご提案です",
          body: "3ヶ月間40%オフでご利用いただけます",
          data: { type: "win_back", offerId: "winback_3months_40pct" },
        }, env);
        // シーケンス終了（それ以降はメール等の別チャネルへ）
      }
 
      message.ack();
    }
  }
};

# 毎週月曜 7:00 に実行（cron 側で管理）
antigravity run \
  --agent subscription-report \
  --prompt "先週分の MRR・トライアル転換率・30日チャーン率を前週比とあわせて Markdown で出力してください。閾値超過（チャーン率5%以上）があれば先頭に警告を付けてください。" \
  --output reports/weekly-$(date +%Y-%m-%d).md