smart_printer/smart_printer/PaywallConfigService.swift

import Foundation

@MainActor
final class PaywallConfigService {
    static let shared = PaywallConfigService()

    private static let remoteConfigURL = URL(
        string: "https://git.mqldevelopment.com/ahtasham.shahzad/smart_printer/-/raw/main/smart_printer/paywall.json"
    )!

    private(set) var config: PaywallConfig
    private var hasStarted = false

    private init() {
        config = PaywallConfig.loadBundled()
    }

    func start() {
        guard !hasStarted else { return }
        hasStarted = true
        #if DEBUG
        Task { await refreshFromRemote() }
        #endif
    }

    func refreshFromRemote() async {
        var request = URLRequest(url: Self.remoteConfigURL)
        request.cachePolicy = .reloadIgnoringLocalCacheData
        request.timeoutInterval = 15

        do {
            let (data, response) = try await URLSession.shared.data(for: request)
            guard let http = response as? HTTPURLResponse, (200 ... 299).contains(http.statusCode) else {
                return
            }
            let remoteConfig = try JSONDecoder().decode(PaywallConfig.self, from: data)
            apply(remoteConfig)
        } catch {
            NSLog("Failed to refresh paywall config: \(error.localizedDescription)")
        }
    }

    private func apply(_ remoteConfig: PaywallConfig) {
        let bundledConfig = PaywallConfig.loadBundled()
        let mergedConfig = bundledConfig.mergingMarketing(from: remoteConfig)
        guard mergedConfig != config else { return }
        config = mergedConfig
        NotificationCenter.default.post(name: .paywallConfigDidUpdate, object: nil)
    }
}

extension PaywallConfig: Equatable {
    static func == (lhs: PaywallConfig, rhs: PaywallConfig) -> Bool {
        guard let lhsData = try? JSONEncoder().encode(lhs),
              let rhsData = try? JSONEncoder().encode(rhs) else {
            return false
        }
        return lhsData == rhsData
    }
}