gramora/gramora/Managers/SubscriptionManager.swift

import AppKit
import Combine
import Foundation
import StoreKit

enum PurchaseError: Equatable {
    case productsLoadTimeout
    case subscriptionUnavailable
    case planUnavailable
    case purchaseNotVerified
    case purchasePending
    case noActiveSubscriptions
    case generic

    var message: String {
        switch self {
        case .productsLoadTimeout:
            "Couldn't load subscription products right now. Check your StoreKit configuration / internet and try again."
        case .subscriptionUnavailable:
            "This subscription is currently unavailable. Please try again in a moment."
        case .planUnavailable:
            "This plan isn't available right now. Please try again later."
        case .purchaseNotVerified:
            "Apple couldn't verify this purchase."
        case .purchasePending:
            "This purchase is waiting for approval (for example, Ask to Buy)."
        case .noActiveSubscriptions:
            "No active purchases were found for this Apple ID."
        case .generic:
            "Something went wrong with your subscription. Please try again."
        }
    }
}

@MainActor
final class SubscriptionManager: ObservableObject {
    static let maxFreeAIUses = 4
    private static let freeAIUsesConsumedKey = "freeAIUsesConsumed"

    private enum ProductLoadError: Error {
        case timeout
    }

    private static let cachedPremiumAccessKey = "subscription.cachedPremiumAccess"

    @Published private(set) var productsByID: [String: Product] = [:]
    @Published private(set) var isLoadingProducts = false
    @Published private(set) var purchasingPlan: PaywallPlan?
    @Published private(set) var hasPremiumAccess = false
    @Published private(set) var hasManageableSubscription = false
    @Published private(set) var hasResolvedPremiumStatus = false
    @Published private(set) var activePlan: PaywallPlan?
    @Published private(set) var activeRecurringPlan: PaywallPlan?
    @Published private(set) var introOfferEligibleByPlan: [PaywallPlan: Bool] = [:]
    @Published private(set) var freeAIUsesConsumed = 0
    @Published var purchaseError: PurchaseError?
    @Published var subscriptionSuccessMessage: String?
    @Published var showsCancelSubscriptionReminder = false
    @Published private(set) var recurringPlanPendingCancellation: PaywallPlan?

    var hasAllProductsLoaded: Bool {
        SubscriptionProductID.all.allSatisfy { productsByID[$0] != nil }
    }

    var remainingFreeAIUses: Int {
        max(0, Self.maxFreeAIUses - freeAIUsesConsumed)
    }

    var canUseAIFeatures: Bool {
        hasPremiumAccess || remainingFreeAIUses > 0
    }

    private var inFlightProductLoad: Task<Void, Never>?
    private var cancellables = Set<AnyCancellable>()
    private let defaults: UserDefaults

    init(defaults: UserDefaults = .standard) {
        self.defaults = defaults
        hasPremiumAccess = defaults.bool(forKey: Self.cachedPremiumAccessKey)
        freeAIUsesConsumed = min(
            defaults.integer(forKey: Self.freeAIUsesConsumedKey),
            Self.maxFreeAIUses
        )

        observeAIFeatureUsage()

        Task { await listenForTransactionUpdates() }
        Task { await refreshPremiumAccess() }
        Task { await loadProducts(presentLoadingUI: false) }
        observeAppLifecycle()
    }

    func recordSuccessfulAIUse() {
        guard !hasPremiumAccess else { return }
        guard freeAIUsesConsumed < Self.maxFreeAIUses else { return }

        freeAIUsesConsumed += 1
        defaults.set(freeAIUsesConsumed, forKey: Self.freeAIUsesConsumedKey)
    }

    private func observeAIFeatureUsage() {
        NotificationCenter.default.publisher(for: .aiFeatureDidSucceed)
            .receive(on: DispatchQueue.main)
            .sink { [weak self] _ in
                self?.recordSuccessfulAIUse()
            }
            .store(in: &cancellables)
    }

    func loadProducts(presentLoadingUI: Bool? = nil) async {
        if let existing = inFlightProductLoad {
            await existing.value
            return
        }

        let uiFlag = presentLoadingUI
        let task = Task { @MainActor in
            await performLoadProducts(presentLoadingUI: uiFlag)
        }
        inFlightProductLoad = task
        await task.value
        inFlightProductLoad = nil
    }

    func product(for plan: PaywallPlan) -> Product? {
        productsByID[plan.productID]
    }

    func displayTitle(for plan: PaywallPlan) -> String {
        product(for: plan)?.displayName ?? plan.rawValue.capitalized
    }

    func mainPrice(for plan: PaywallPlan) -> String {
        product(for: plan)?.displayPrice ?? "—"
    }

    func secondaryPrice(for plan: PaywallPlan) -> String {
        guard let product = product(for: plan) else { return "—" }

        let formatStyle = product.priceFormatStyle

        switch plan {
        case .weekly:
            let doubled = product.price * 2
            return "\(doubled.formatted(formatStyle)) / week"
        case .monthly:
            let weekly = product.price / Decimal(4.33)
            return "\(weekly.formatted(formatStyle)) / week"
        case .yearly:
            let weekly = product.price / Decimal(52)
            return "\(weekly.formatted(formatStyle)) / week"
        case .lifetime:
            let doubled = product.price * 2
            return doubled.formatted(formatStyle)
        }
    }

    func tagText(for plan: PaywallPlan) -> String? {
        if hasFreeTrialOffer(for: plan) {
            return "Free Trial"
        }

        switch plan {
        case .weekly:
            return "Basic"
        case .yearly:
            return savingsTagText(for: plan)
        case .lifetime:
            return "Pay Once"
        case .monthly:
            return nil
        }
    }

    func ctaTitle(for plan: PaywallPlan) -> String {
        if hasFreeTrialOffer(for: plan) {
            return "START FOR FREE"
        }

        switch plan {
        case .weekly: return "START WEEKLY PLAN"
        case .monthly: return "START MONTHLY PLAN"
        case .yearly: return "START YEARLY PLAN"
        case .lifetime: return "UNLOCK LIFETIME"
        }
    }

    func billingDescription(for plan: PaywallPlan) -> String {
        guard let product = product(for: plan) else {
            return "Loading pricing…"
        }

        if hasFreeTrialOffer(for: plan),
           let subscription = product.subscription,
           let intro = subscription.introductoryOffer {
            let trialPeriod = formattedPeriod(intro.period)
            let billingPeriod = formattedSubscriptionPeriod(subscription.subscriptionPeriod)
            return "\(trialPeriod) Free Trial, then \(product.displayPrice) per \(billingPeriod)"
        }

        switch plan {
        case .weekly:
            return "Billed at \(product.displayPrice) every week"
        case .monthly:
            return "Billed at \(product.displayPrice) per month"
        case .yearly:
            return "Billed at \(product.displayPrice) every year"
        case .lifetime:
            return "One-time payment of \(product.displayPrice)"
        }
    }

    func showsStrikethroughSecondaryPrice(for plan: PaywallPlan) -> Bool {
        plan == .weekly || plan == .lifetime
    }

    private func savingsTagText(for plan: PaywallPlan) -> String? {
        guard plan == .yearly,
              let yearlyProduct = product(for: .yearly),
              let weeklyProduct = product(for: .weekly),
              weeklyProduct.price > 0 else { return nil }

        let yearlyWeeklyEquivalent = yearlyProduct.price / Decimal(52)
        let savings = (1 - (yearlyWeeklyEquivalent / weeklyProduct.price)) * 100
        let rounded = Int(NSDecimalNumber(decimal: savings).doubleValue.rounded())
        guard rounded > 0 else { return nil }
        return "Save \(rounded)%"
    }

    func hasFreeTrialOffer(for plan: PaywallPlan) -> Bool {
        guard introOfferEligibleByPlan[plan] == true else { return false }
        guard let product = product(for: plan),
              let subscription = product.subscription,
              let intro = subscription.introductoryOffer,
              intro.paymentMode == .freeTrial else { return false }
        return true
    }

    func purchase(_ plan: PaywallPlan) async -> Bool {
        purchaseError = nil

        if hasPremiumAccess {
            if !hasManageableSubscription {
                return true
            }
            if let activePlan, plan == activePlan {
                return true
            }
            if let activeRecurringPlan, plan == activeRecurringPlan {
                return true
            }
        }

        var product = productsByID[plan.productID]
        if product == nil {
            await loadProducts(presentLoadingUI: false)
            product = productsByID[plan.productID]
        }

        guard let product else {
            purchaseError = productsByID.isEmpty ? .productsLoadTimeout : .planUnavailable
            #if DEBUG
            let missingProductIDs = SubscriptionProductID.all.filter { productsByID[$0] == nil }
            if !missingProductIDs.isEmpty {
                print(
                    """
                    [SubscriptionManager] Missing StoreKit products: \(missingProductIDs.joined(separator: ", "))
                    To test locally, attach `Paywall.storekit` in Xcode:
                    Product > Scheme > Edit Scheme > Run > Options > StoreKit Configuration.
                    """
                )
            }
            #endif
            return false
        }

        purchasingPlan = plan
        defer { purchasingPlan = nil }

        let shouldRemindToCancelSubscription = plan == .lifetime && hasManageableSubscription
        let recurringPlanBeforePurchase = activeRecurringPlan ?? activePlan

        do {
            let result = try await product.purchase()
            switch result {
            case .success(let verification):
                guard case .verified(let transaction) = verification else {
                    purchaseError = .purchaseNotVerified
                    return false
                }
                await transaction.finish()
                applyOptimisticPremiumAccess(for: transaction)
                await refreshPremiumAccessWithRetry()
                if hasPremiumAccess {
                    NotificationCenter.default.post(name: .subscriptionPurchased, object: nil)
                }
                if shouldRemindToCancelSubscription {
                    recurringPlanPendingCancellation = recurringPlanBeforePurchase
                    showsCancelSubscriptionReminder = true
                } else if !hasPremiumAccess {
                    subscriptionSuccessMessage = "Purchase successful. If premium features don't unlock right away, tap Restore Purchases."
                }
                return hasPremiumAccess || shouldRemindToCancelSubscription
            case .userCancelled:
                return false
            case .pending:
                purchaseError = .purchasePending
                return false
            @unknown default:
                purchaseError = .generic
                return false
            }
        } catch {
            purchaseError = .generic
            return false
        }
    }

    func openSubscriptionManagement() {
        guard let url = URL(string: "https://apps.apple.com/account/subscriptions") else { return }
        NSWorkspace.shared.open(url)
    }

    func restorePurchases() async {
        purchaseError = nil
        subscriptionSuccessMessage = nil
        let hadPremium = hasPremiumAccess
        do {
            try await AppStore.sync()
            await refreshPremiumAccess()
            if hasPremiumAccess {
                if !hadPremium {
                    subscriptionSuccessMessage = "Your purchases have been restored."
                }
            } else {
                purchaseError = .noActiveSubscriptions
            }
        } catch {
            purchaseError = .generic
        }
    }

    func clearSubscriptionSuccessMessage() {
        subscriptionSuccessMessage = nil
    }

    func clearCancelSubscriptionReminder() {
        showsCancelSubscriptionReminder = false
        recurringPlanPendingCancellation = nil
    }

    var cancelSubscriptionReminderMessage: String {
        if let plan = recurringPlanPendingCancellation {
            let planName = displayTitle(for: plan)
            return "Your lifetime access is active. Your \(planName) subscription is still active and will renew automatically. Cancel it in the App Store to avoid future charges."
        }
        return "Your lifetime access is active. Your recurring subscription is still active and will renew automatically. Cancel it in the App Store to avoid future charges."
    }

    private func performLoadProducts(presentLoadingUI: Bool?) async {
        let missingAny = SubscriptionProductID.all.contains { productsByID[$0] == nil }
        let shouldShowLoading = presentLoadingUI ?? missingAny

        if !missingAny, presentLoadingUI != true {
            purchaseError = nil
            await refreshIntroOfferEligibility()
            await refreshPremiumAccess()
            return
        }

        if shouldShowLoading {
            isLoadingProducts = true
        }
        defer {
            if shouldShowLoading {
                isLoadingProducts = false
            }
        }

        purchaseError = nil
        do {
            let loaded = try await loadProductsWithTimeout(seconds: 12)
            var map: [String: Product] = [:]
            for product in loaded {
                map[product.id] = product
            }
            productsByID = map
            await refreshIntroOfferEligibility()
            await refreshPremiumAccess()
        } catch is ProductLoadError {
            if presentLoadingUI == true {
                purchaseError = .productsLoadTimeout
            }
        } catch {
            if presentLoadingUI == true {
                purchaseError = .generic
            }
        }
    }

    private func loadProductsWithTimeout(seconds: TimeInterval) async throws -> [Product] {
        try await withThrowingTaskGroup(of: [Product].self) { group in
            group.addTask {
                try await Product.products(for: SubscriptionProductID.all)
            }
            group.addTask {
                let timeoutNanoseconds = UInt64(seconds * 1_000_000_000)
                try await Task.sleep(nanoseconds: timeoutNanoseconds)
                throw ProductLoadError.timeout
            }

            guard let first = try await group.next() else {
                throw ProductLoadError.timeout
            }
            group.cancelAll()
            return first
        }
    }

    private func refreshPremiumAccess() async {
        var hasPremium = false
        var manageableSubscription = false
        var resolvedPlan: PaywallPlan?
        var resolvedRecurringPlan: PaywallPlan?

        for await result in Transaction.currentEntitlements {
            guard case .verified(let transaction) = result else { continue }
            guard SubscriptionProductID.all.contains(transaction.productID) else { continue }
            guard transaction.revocationDate == nil else { continue }

            guard let plan = SubscriptionProductID.plan(for: transaction.productID) else { continue }

            if SubscriptionProductID.recurring.contains(transaction.productID) {
                guard await isRecurringSubscriptionEntitled(productID: transaction.productID) else {
                    continue
                }
                manageableSubscription = true
                if resolvedRecurringPlan == nil {
                    resolvedRecurringPlan = plan
                }
            }

            hasPremium = true
            if resolvedPlan == nil {
                resolvedPlan = plan
            }
        }

        hasPremiumAccess = hasPremium
        hasManageableSubscription = manageableSubscription
        activePlan = resolvedPlan
        activeRecurringPlan = resolvedRecurringPlan
        hasResolvedPremiumStatus = true
        defaults.set(hasPremium, forKey: Self.cachedPremiumAccessKey)
    }

    private func applyOptimisticPremiumAccess(for transaction: Transaction) {
        guard SubscriptionProductID.all.contains(transaction.productID),
              transaction.revocationDate == nil,
              let plan = SubscriptionProductID.plan(for: transaction.productID) else { return }

        hasPremiumAccess = true
        activePlan = plan
        if SubscriptionProductID.recurring.contains(transaction.productID) {
            hasManageableSubscription = true
            activeRecurringPlan = plan
        }
        defaults.set(true, forKey: Self.cachedPremiumAccessKey)
    }

    private func refreshIntroOfferEligibility() async {
        var eligibility: [PaywallPlan: Bool] = [:]

        for plan in PaywallPlan.allCases {
            guard let product = productsByID[plan.productID],
                  let subscription = product.subscription,
                  let intro = subscription.introductoryOffer,
                  intro.paymentMode == .freeTrial else { continue }

            eligibility[plan] = await subscription.isEligibleForIntroOffer
        }

        introOfferEligibleByPlan = eligibility
    }

    private func refreshPremiumAccessWithRetry() async {
        await refreshPremiumAccess()
        guard !hasPremiumAccess else { return }

        for _ in 0..<6 {
            try? await Task.sleep(nanoseconds: 500_000_000)
            await refreshPremiumAccess()
            if hasPremiumAccess { return }
        }
    }

    private func isRecurringSubscriptionEntitled(productID: String) async -> Bool {
        let product: Product?
        if let cached = productsByID[productID] {
            product = cached
        } else if let loaded = try? await Product.products(for: [productID]).first {
            product = loaded
        } else {
            // Entitlement is already in currentEntitlements; defer to StoreKit when product metadata is unavailable.
            return true
        }

        guard let product, let subscription = product.subscription else { return true }

        do {
            let statuses = try await subscription.status
            return statuses.contains { status in
                switch status.state {
                case .subscribed, .inGracePeriod, .inBillingRetryPeriod:
                    return true
                case .expired, .revoked:
                    return false
                default:
                    return false
                }
            }
        } catch {
            return false
        }
    }

    private func observeAppLifecycle() {
        NotificationCenter.default.publisher(for: NSApplication.didBecomeActiveNotification)
            .sink { [weak self] _ in
                Task { await self?.refreshPremiumAccess() }
            }
            .store(in: &cancellables)
    }

    private func listenForTransactionUpdates() async {
        for await update in Transaction.updates {
            switch update {
            case .verified(let transaction):
                await transaction.finish()
                await refreshPremiumAccess()
            case .unverified(_, let error):
                #if DEBUG
                print("[SubscriptionManager] Unverified transaction update: \(error)")
                #endif
                purchaseError = .purchaseNotVerified
            }
        }
    }

    private func formattedPeriod(_ period: Product.SubscriptionPeriod) -> String {
        switch period.unit {
        case .day where period.value == 1: "1 Day"
        case .day: "\(period.value) Days"
        case .week where period.value == 1: "1 Week"
        case .week: "\(period.value) Weeks"
        case .month where period.value == 1: "1 Month"
        case .month: "\(period.value) Months"
        case .year where period.value == 1: "1 Year"
        case .year: "\(period.value) Years"
        @unknown default: "\(period.value) Days"
        }
    }

    private func formattedSubscriptionPeriod(_ period: Product.SubscriptionPeriod) -> String {
        switch period.unit {
        case .day: period.value == 1 ? "day" : "\(period.value) days"
        case .week: period.value == 1 ? "week" : "\(period.value) weeks"
        case .month: period.value == 1 ? "month" : "\(period.value) months"
        case .year: period.value == 1 ? "year" : "\(period.value) years"
        @unknown default: "billing period"
        }
    }
}