Rork Maxで個人開発アプリ月収100万円を達成する：収益設計・実装・データ分析の設計書

// src/lib/revenuecat.ts
import Purchases, { LOG_LEVEL } from 'react-native-purchases';
import { Platform } from 'react-native';
 
const REVENUECAT_API_KEY = {
  ios: process.env.EXPO_PUBLIC_REVENUECAT_IOS_KEY ?? '',
  android: process.env.EXPO_PUBLIC_REVENUECAT_ANDROID_KEY ?? '',
};
 
export async function initializePurchases(userId?: string): Promise<void> {
  try {
    // 開発環境ではデバッグログを有効化して挙動を確認しやすくする
    if (__DEV__) {
      Purchases.setLogLevel(LOG_LEVEL.DEBUG);
    }
 
    const apiKey = Platform.select(REVENUECAT_API_KEY);
    if (\!apiKey) {
      throw new Error('RevenueCat API key is not configured for this platform');
    }
 
    await Purchases.configure({
      apiKey,
      // ログイン済みユーザーにはIDを渡してデバイス間の購入履歴を同期する
      appUserID: userId,
    });
 
    console.log('[RevenueCat] Initialized successfully');
  } catch (error) {
    // 初期化失敗はクラッシュではなくログに記録し、アプリの起動を妨げない
    console.error('[RevenueCat] Initialization failed:', error);
    // SentryなどのCrashlytics連携ツールに送信する場合はここに追加
  }
}

// src/hooks/usePaywall.ts
import { useState, useCallback } from 'react';
import Purchases, {
  type PurchasesOffering,
  type CustomerInfo,
  type PurchasesError,
} from 'react-native-purchases';
 
interface UsePaywallResult {
  offering: PurchasesOffering | null;
  customerInfo: CustomerInfo | null;
  isLoading: boolean;
  error: string | null;
  fetchOffering: () => Promise<void>;
  purchasePackage: (packageIdentifier: string) => Promise<boolean>;
  restorePurchases: () => Promise<boolean>;
}
 
export function usePaywall(): UsePaywallResult {
  const [offering, setOffering] = useState<PurchasesOffering | null>(null);
  const [customerInfo, setCustomerInfo] = useState<CustomerInfo | null>(null);
  const [isLoading, setIsLoading] = useState(false);
  const [error, setError] = useState<string | null>(null);
 
  const fetchOffering = useCallback(async () => {
    setIsLoading(true);
    setError(null);
    try {
      const offerings = await Purchases.getOfferings();
      // "default"オファリングを優先し、なければ最初のオファリングを使用する
      const current = offerings.current ?? Object.values(offerings.all)[0];
      if (\!current) {
        throw new Error('オファリングが設定されていません。RevenueCatダッシュボードを確認してください。');
      }
      setOffering(current);
 
      // 現在の購入ステータスをオファリングと同時に取得してUIの表示を確定する
      const info = await Purchases.getCustomerInfo();
      setCustomerInfo(info);
    } catch (err) {
      const message = err instanceof Error ? err.message : '予期しないエラーが発生しました';
      setError(message);
      console.error('[usePaywall] fetchOffering failed:', err);
    } finally {
      setIsLoading(false);
    }
  }, []);
 
  const purchasePackage = useCallback(async (packageIdentifier: string): Promise<boolean> => {
    if (\!offering) return false;
 
    const targetPackage = offering.availablePackages.find(
      (p) => p.identifier === packageIdentifier
    );
    if (\!targetPackage) {
      setError(`パッケージ "${packageIdentifier}" が見つかりません`);
      return false;
    }
 
    setIsLoading(true);
    try {
      const { customerInfo: updatedInfo } = await Purchases.purchasePackage(targetPackage);
      setCustomerInfo(updatedInfo);
 
      // 購入後は "premium" エンタイトルメントの有無でアクセス権を判定する
      const isPremium = updatedInfo.entitlements.active['premium'] \!== undefined;
      return isPremium;
    } catch (err: unknown) {
      // ユーザーが自分でキャンセルした場合はエラーではなく正常系として扱う
      const purchaseError = err as PurchasesError;
      if (purchaseError.userCancelled) {
        return false;
      }
      const message = err instanceof Error ? err.message : '購入処理中にエラーが発生しました';
      setError(message);
      console.error('[usePaywall] purchasePackage failed:', err);
      return false;
    } finally {
      setIsLoading(false);
    }
  }, [offering]);
 
  const restorePurchases = useCallback(async (): Promise<boolean> => {
    setIsLoading(true);
    setError(null);
    try {
      const restoredInfo = await Purchases.restorePurchases();
      setCustomerInfo(restoredInfo);
      // アクティブなエンタイトルメントが1件以上あれば復元成功
      return Object.keys(restoredInfo.entitlements.active).length > 0;
    } catch (err) {
      setError('購入履歴の復元に失敗しました。しばらく経ってから再度お試しください。');
      console.error('[usePaywall] restorePurchases failed:', err);
      return false;
    } finally {
      setIsLoading(false);
    }
  }, []);
 
  return {
    offering,
    customerInfo,
    isLoading,
    error,
    fetchOffering,
    purchasePackage,
    restorePurchases,
  };
}

// src/lib/analytics.ts
import PostHog from 'posthog-react-native';
import type { CustomerInfo } from 'react-native-purchases';
 
// シングルトンパターンでインスタンスを管理し、重複初期化を防ぐ
let posthogClient: PostHog | null = null;
 
export function getAnalytics(): PostHog {
  if (\!posthogClient) {
    posthogClient = new PostHog(
      process.env.EXPO_PUBLIC_POSTHOG_API_KEY ?? 'YOUR_POSTHOG_API_KEY',
      {
        host: 'https://app.posthog.com',
        // 開発中はイベントを送信しない設定
        disabled: __DEV__,
      }
    );
  }
  return posthogClient;
}
 
// 収益に直結するイベントのみをトラッキングする関数群
export const trackRevenue = {
  // ペイウォールが表示された（どの画面から開いたかを記録する）
  paywallViewed: (source: 'onboarding' | 'feature_gate' | 'settings' | 'upgrade_banner') => {
    getAnalytics().capture('paywall_viewed', {
      source,
      timestamp: new Date().toISOString(),
    });
  },
 
  // 購入が成功した（どのパッケージを選んだか・トライアル経由かを記録する）
  purchaseCompleted: (customerInfo: CustomerInfo, packageId: string) => {
    const premiumEntitlement = customerInfo.entitlements.active['premium'];
    getAnalytics().capture('purchase_completed', {
      package_id: packageId,
      is_trial: premiumEntitlement?.periodType === 'TRIAL',
      billing_period: premiumEntitlement?.productPlanIdentifier ?? 'unknown',
    });
 
    // ユーザープロパティを更新することでコホート分析が可能になる
    getAnalytics().identify(customerInfo.originalAppUserId, {
      is_premium: true,
      subscription_status: 'active',
      purchased_at: new Date().toISOString(),
    });
  },
 
  // ペイウォールでキャンセルされた（離脱ポイントの特定に使う）
  paywallDismissed: (source: string, timeSpentSeconds: number) => {
    getAnalytics().capture('paywall_dismissed', {
      source,
      time_spent_seconds: timeSpentSeconds,
    });
  },
};