import Foundation
import React
import Iaphub

@objc(NativeIaphub)
class RNIaphub: RCTEventEmitter, IaphubDelegate {
   
   private var hasListeners = false
   // Keys listed here are omitted when their native value is null so React Native codegen sees them as optional instead of union types.
   private let optionalProperties: Set<String> = ["subscriptionIntroPhases"]
   
   
   override static func requiresMainQueueSetup() -> Bool {
      return true
   }
   
   override func startObserving() {
      hasListeners = true
   }

   override func stopObserving() {
      hasListeners = false
   }
   
   override func supportedEvents() -> [String]! {
       return ["onUserUpdate", "onDeferredPurchase", "onError", "onBuyRequest", "onReceipt"]
   }
   
   /***************************** EVENTS ******************************/
   
   /**
    Listen for user update event
    */
   func didReceiveUserUpdate() {
      if (!self.hasListeners) {
         return
      }
      self.sendEvent(withName: "onUserUpdate", body: nil)
   }
   
   /**
    Listen for a deferred purchase event
   */
   func didReceiveDeferredPurchase(transaction: IHReceiptTransaction) {
      if (!self.hasListeners) {
         return
      }
      self.sendEvent(withName: "onDeferredPurchase", body: sanitizeValue(transaction.getDictionary()))
   }
   
   /**
    Listen for error event
    */
   func didReceiveError(err: IHError) {
      if (!self.hasListeners) {
         return
      }
      self.sendEvent(withName: "onError", body: sanitizeValue(err.getDictionary()))
   }
   
   /**
    Listen for buy request event
    */
   func didReceiveBuyRequest(sku: String) {
      if (!self.hasListeners) {
         return
      }
      self.sendEvent(withName: "onBuyRequest", body: ["sku": sku])
   }
   
   /**
    Listen for receipt event
    */
   func didProcessReceipt(err: IHError?, receipt: IHReceipt?) {
      if (!self.hasListeners) {
         return
      }
      self.sendEvent(withName: "onReceipt", body: [
         "err": sanitizePayload(err?.getDictionary()) ?? NSNull(),
         "receipt": sanitizePayload(receipt?.getDictionary()) ?? NSNull()
      ])
   }
   
   /***************************** PUBLIC ******************************/

   /**
    Start IAPHUB
    */
    @objc
    func start(_ options: NSDictionary, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) -> Void {
      let appId = options.value(forKey: "appId") as? String ?? ""
      let apiKey = options.value(forKey: "apiKey") as? String ?? ""
      let userId = options.value(forKey: "userId") as? String
      let allowAnonymousPurchase = options.value(forKey: "allowAnonymousPurchase") as? Bool ?? false
      let enableDeferredPurchaseListener = options.value(forKey: "enableDeferredPurchaseListener") as? Bool ?? true
      let enableStorekitV2 = options.value(forKey: "enableStorekitV2") as? Bool ?? false
      let environment = options.value(forKey: "environment") as? String ?? "production"
      let lang = options.value(forKey: "lang") as? String ?? ""
      let sdkVersion = options.value(forKey: "sdkVersion") as? String ?? ""
      var sdk = "react_native"

      if let extraSdk = options.value(forKey: "sdk") as? String {
         sdk = "\(sdk)/\(extraSdk)"
      }
      Iaphub.delegate = self
      Iaphub.start(
         appId: appId,
         apiKey: apiKey,
         userId: userId,
         allowAnonymousPurchase: allowAnonymousPurchase,
         enableDeferredPurchaseListener: enableDeferredPurchaseListener,
         enableStorekitV2: enableStorekitV2,
         environment: environment,
         lang: lang,
         sdk: sdk,
         sdkVersion: sdkVersion
      )
      resolve(nil)
    }
   
   /**
   Stop IAPHUB
   */
   @objc
   func stop(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) -> Void {
      Iaphub.stop()
      resolve(nil)
   }

   /**
    Get SDK version
    */
   @objc
   func getSDKVersion(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) -> Void {
      let version = Iaphub.getSDKVersion();
      resolve(version)
   }

   /**
    Set lang
    */
   @objc
   func setLang(_ lang: String, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      let result = Iaphub.setLang(lang);
      resolve(result);
   }
   
   /**
    Login
    */
   @objc
   func login(_ userId: String, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      Iaphub.login(userId: userId, { (err) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         resolve(nil)
      })
   }
   
   /**
    Get user id
    */
   @objc
   func getUserId(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      let userId = Iaphub.getUserId()
      
      if (userId == nil) {
         reject("iaphub_error", self.createError(code: "unexpected", subcode: "start_missing", message: "iaphub not started"), nil)
      }
      else {
         resolve(userId)
      }
   }

   /**
    Logout
    */
   @objc
   func logout(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      Iaphub.logout()
      resolve(nil)
   }
   
   /**
    Set device params
    */
   @objc
   func setDeviceParams(_ params: Dictionary<String, String>, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      Iaphub.setDeviceParams(params: params)
      resolve(nil)
   }
   
   /**
    Set user tags
    */
   @objc
   func setUserTags(_ tags: Dictionary<String, String>, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      Iaphub.setUserTags(tags: tags, { (err) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         resolve(nil)
      })
   }
   
   /**
    Buy
    */
   @objc
   func buy(_ sku: String, options: NSDictionary, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      let crossPlatformConflict = options.value(forKey: "crossPlatformConflict") as? Bool ?? true
      
      Iaphub.buy(sku: sku, crossPlatformConflict: crossPlatformConflict, { (err, transaction) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         if let transaction = transaction {
            resolve(self.sanitizeValue(transaction.getDictionary()))
         }
         else {
            resolve(nil)
         }
      })
   }
   
   /**
    Restore
    */
   @objc
   func restore(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      Iaphub.restore({ (err, response) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         resolve(self.sanitizePayload(response?.getDictionary()))
      })
   }
   
   /**
    Get active products
    */
   @objc
   func getActiveProducts(_ options: NSDictionary, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      let includeSubscriptionStates = options.value(forKey: "includeSubscriptionStates") as? [String] ?? []
      
      Iaphub.getActiveProducts(includeSubscriptionStates: includeSubscriptionStates, { (err, products) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         if let products = products {
            let data = products.map { product in
               return self.sanitizeValue(product.getDictionary())
            }
            resolve(data)
         }
         else {
            resolve(nil)
         }
      })
   }
   
   /**
    Get products for sale
    */
   @objc
   func getProductsForSale(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      Iaphub.getProductsForSale({ (err, products) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         if let products = products {
            let data = products.map { product in
               return self.sanitizeValue(product.getDictionary())
            }
            resolve(data)
         }
         else {
            resolve(nil)
         }
      })
   }
   
   /**
    Get products (active and for sale)
    */
   @objc
   func getProducts(_ options: NSDictionary, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      let includeSubscriptionStates = options.value(forKey: "includeSubscriptionStates") as? [String] ?? []
      
      Iaphub.getProducts(includeSubscriptionStates: includeSubscriptionStates, { (err, products) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         resolve(self.sanitizePayload(products?.getDictionary()))
      })
   }
   
   /**
    Get billing status
    */
   @objc
   func getBillingStatus(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      let status = Iaphub.getBillingStatus()
      
      resolve(sanitizeValue(status.getDictionary()))
   }
   
   /**
    Present code redemption
    */
   @objc
   func presentCodeRedemptionSheet(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      Iaphub.presentCodeRedemptionSheet({ (err) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         resolve(nil)
      })
   }
   
   /**
    Show manage subscriptions page
    */
   @objc
   func showManageSubscriptions(_ options: NSDictionary, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
      Iaphub.showManageSubscriptions({ (err) in
         if let err = err {
            return reject("iaphub_error", self.createError(err), nil)
         }
         resolve(nil)
      })
   }
   
   /***************************** PRIVATE ******************************/
   
   /**
    Create error
    */
   private func sanitizePayload(_ value: Any?) -> Any? {
      guard let value = value else {
         return nil
      }
      return sanitizeValue(value)
   }
   
   private func sanitizeValue(_ value: Any) -> Any {
      if let dictionary = value as? [String: Any] {
         return sanitizeDictionary(dictionary)
      }
      if let array = value as? [Any] {
         return array.map { sanitizeValue($0) }
      }
      return value
   }
   
   private func sanitizeDictionary(_ dictionary: [String: Any]) -> [String: Any] {
      var sanitized: [String: Any] = [:]
      
      for (key, value) in dictionary {
         if optionalProperties.contains(key), value is NSNull {
            continue
         }
         sanitized[key] = sanitizeValue(value)
      }
      
      return sanitized
   }
   
   func createError(code: String, subcode: String, message: String, params: Dictionary<String, Any> = [:]) -> String? {
      if let json = try? JSONSerialization.data(withJSONObject: ["code": code, "subcode": subcode, "message": message, "params": params]) {
         return String(data: json, encoding: .utf8)
      }
      return nil
   }
   
   /**
    Create error
    */
   func createError(_ err: IHError) -> String? {
      if let json = try? JSONSerialization.data(withJSONObject: err.getDictionary()) {
         return String(data: json, encoding: .utf8)
      }
      return nil
   }
}