Rork × StoreKit 2 で会員資格の同期を三層化する — 起動時・バックグラウンド・復元購入の役割分担

import StoreKit
import Observation
 
@Observable
final class SubscriptionStore {
    private(set) var isActive: Bool = false
    private(set) var lastVerifiedAt: Date? = nil
    private var updatesTask: Task<Void, Never>? = nil
 
    // 第一層: アプリ起動直後・onAppear 直後に必ず呼ぶ
    func refreshAtLaunch() async {
        var active = false
        for await result in Transaction.currentEntitlements {
            if case .verified(let tx) = result,
               tx.revocationDate == nil,
               tx.expirationDate.map({ $0 > Date() }) ?? false {
                active = true
            }
        }
        await MainActor.run {
            self.isActive = active
            self.lastVerifiedAt = Date()
        }
    }
 
    // updates ストリーム購読（補助的に動かす）
    func startObservingUpdates() {
        updatesTask?.cancel()
        updatesTask = Task.detached { [weak self] in
            for await update in Transaction.updates {
                guard let self else { return }
                if case .verified = update {
                    await self.refreshAtLaunch()
                }
            }
        }
    }
}

import BackgroundTasks
import StoreKit
 
// 1. Info.plist に BGTaskSchedulerPermittedIdentifiers を登録
//    例: jp.dolice.wallpaper.subscription.refresh
 
enum BackgroundIdentifier {
    static let subscriptionRefresh = "jp.dolice.wallpaper.subscription.refresh"
}
 
final class BackgroundRefreshScheduler {
    static let shared = BackgroundRefreshScheduler()
 
    func register(store: SubscriptionStore) {
        BGTaskScheduler.shared.register(
            forTaskWithIdentifier: BackgroundIdentifier.subscriptionRefresh,
            using: nil
        ) { task in
            guard let task = task as? BGAppRefreshTask else {
                task.setTaskCompleted(success: false); return
            }
            self.handle(task: task, store: store)
        }
    }
 
    func schedule() {
        let request = BGAppRefreshTaskRequest(
            identifier: BackgroundIdentifier.subscriptionRefresh
        )
        // 約 6 時間後を希望する（実際の発火は iOS が判断する）
        request.earliestBeginDate = Date(timeIntervalSinceNow: 6 * 60 * 60)
        try? BGTaskScheduler.shared.submit(request)
    }
 
    private func handle(task: BGAppRefreshTask, store: SubscriptionStore) {
        // 次のスケジュールを先に積んでおく
        schedule()
 
        let work = Task {
            await store.refreshAtLaunch()
            task.setTaskCompleted(success: true)
        }
        task.expirationHandler = { work.cancel() }
    }
}

// 第三層: ユーザ起点の復元購入
extension SubscriptionStore {
    enum RestoreResult {
        case restored
        case noPurchaseFound
        case networkError
    }
 
    func restorePurchases() async -> RestoreResult {
        do {
            // AppStore.sync() は実行に時間がかかる
            // ユーザの確認ダイアログが出る場合もある
            try await AppStore.sync()
        } catch {
            return .networkError
        }
        await refreshAtLaunch()
        return self.isActive ? .restored : .noPurchaseFound
    }
}

@main
struct WallpaperApp: App {
    @State private var store = SubscriptionStore()
 
    init() {
        // 第二層の BGTask 登録は init で 1 回だけ
        BackgroundRefreshScheduler.shared.register(store: store)
    }
 
    var body: some Scene {
        WindowGroup {
            RootView()
                .environment(store)
                .task {
                    // 第一層: 起動時の即時照合（updates 開始より前）
                    await store.refreshAtLaunch()
                    // updates 購読は補助的に開始
                    store.startObservingUpdates()
                    // 第二層: 次回スケジュール
                    BackgroundRefreshScheduler.shared.schedule()
                }
        }
    }
}

import { Hono } from "hono"
 
const app = new Hono<{ Bindings: { SLACK_WEBHOOK_URL: string } }>()
 
app.post("/asn-v2", async (c) => {
  const body = await c.req.json<{ signedPayload: string }>()
  // 1. JWS の検証（apple-jws-verifier 等）
  const payload = await verifyAppleJWS(body.signedPayload)
  // 2. notificationType を Slack 整形して通知
  await fetch(c.env.SLACK_WEBHOOK_URL, {
    method: "POST",
    headers: { "content-type": "application/json" },
    body: JSON.stringify({
      text: `Apple: ${payload.notificationType} / ${payload.subtype ?? "-"}`,
    }),
  })
  return c.body(null, 204)
})
 
export default app