Цепочка методов Swift с успехом и неудачей

Я пытаюсь реализовать цепочку методов для успешных и неудачных вызовов в своем коде, но, похоже, у меня возникли проблемы с вызовом методов onSuccess.

Контроллер представления вызывает функцию getProduct(_:).
getProduct(_:) делает вызов API, а затем вызывает storeProduct(_:) с полученным json
storeProduct(_:) звонит fetchProduct(_:)
fetchProduct(_:) вызывает doSuccess(_:), но это никогда не возвращается к onSuccess предыдущих вызовов.

Некоторые фрагменты кода

BSProductChainable.swift

import Foundation

class BSProductChainable<SuccessParams, FailureParams> {

    var successClosure: ((SuccessParams) -> ())? = nil
    var failureClosure: ((FailureParams) -> ())? = nil

    func onSuccess(closure: (SuccessParams) -> ()) -> BSProductChainable {
        successClosure = closure
        return self
    }
    func onFailure(closure: (FailureParams) -> ()) -> BSProductChainable {
        failureClosure = closure
        return self
    }
    func doSuccess(params: SuccessParams) {
        if let closure = successClosure {
            closure(params)
        }
    }
    func doFailure(params: FailureParams) {
        if let closure = failureClosure {
            closure(params)
        }
    }
}

BSProductManagerSwift.swift

class BSProductManagerSwift: NSObject {

typealias productResponseChain = BSProductChainable<Product, NSError?>
typealias productsResponseChain = BSProductChainable<[Product], NSError?>

var serviceClient: BSNetworkingServiceClient!
var objectContext: NSManagedObjectContext!
var productChains: BSProductChainable<Product, NSError?>!
var productsChains: BSProductChainable<[Product], NSError?>!

convenience init(serviceClient: BSNetworkingServiceClient) {
    self.init()
    self.serviceClient = serviceClient
    self.objectContext = managedObjectContext
    self.productChains = BSProductChainable<Product, NSError?>()
    self.productsChains = BSProductChainable<[Product], NSError?>()
}

func getProduct(ean: String) -> productResponseChain {

    let urlString = BSConstants.BarcodeScanner.productEndpoint.stringByAppendingString(ean)
    serviceClient.GET(urlString, failure: { (error) in
        print("Could not get product")
    }) { (response) in
        if let json = response {
            self.storeProduct(json).onSuccess({ (returedProduct) in
                print("Stored product")
            })
        }
    }

    return productChains
}

func storeProduct(json: JSON) -> productResponseChain {

    fetchProduct(json["ean"].stringValue).onSuccess { (returedProduct) in
        self.productChains.doSuccess(returedProduct)
    }

    return productChains
}

func fetchProduct(ean: String) -> productResponseChain {

    let fetchRequest = NSFetchRequest(entityName: "Product")
    let predicateEAN = NSPredicate(format: "%K == %@", "ean", ean)
    let predicateMarket = NSPredicate(format: "%K == %@", "market", BSCountryManager.sharedInstance().getCurrentCountry().market)
    let predicateLocale = NSPredicate(format: "%K == %@", "locale", BSLocalizationManager.sharedManager().currentLocalization.localeIdentifier())
    let predicateCurrency = NSPredicate(format: "%K == %@", "currency", BSLocalizationManager.sharedManager().currentLocalization.country.currencyIdentifierDMW)
    let compoundPredicate = NSCompoundPredicate(andPredicateWithSubpredicates: [predicateEAN, predicateMarket, predicateLocale, predicateCurrency])
    fetchRequest.predicate = compoundPredicate

    do {
        let matchingProuducts = try objectContext.executeFetchRequest(fetchRequest)

        if matchingProuducts.count == 0 {
            print("No matching products found")
            let entity = NSEntityDescription.entityForName("Product", inManagedObjectContext: objectContext)
            productChains.doSuccess(Product(entity: entity!, insertIntoManagedObjectContext: objectContext))
        } else {
            print("Found matching product")
            let d = matchingProuducts.first as! Product
            productChains.doSuccess(d)
        }
    } catch let error as NSError {
        print("Could not fetch \(error), \(error.userInfo)")
        productChains.doFailure(error)
    }

    return productChains
}

Сначала я инициализировал цепной класс для каждой функции, но у него были свои проблемы, из-за которых я подумал (возможно, неправильно), что я должен только один раз инициализировать цепной класс и передать его ссылку.

Некоторый вклад относительно того, где я ошибаюсь / что я мог бы попробовать дальше, был бы замечательным.

ios swift method-chaining

Hodson 08.08.2016 источник

comment

Почему бы не использовать фреймворк вместо создания собственного? Взгляните на promisekit; github.com/mxcl/PromiseKit - john elemans 08.08.2016

comment

Это может быть мой путь, поскольку я уже потратил слишком много времени на попытки решить эту проблему. - Hodson 08.08.2016

Ответы (1)

arrow_upward
0
arrow_downward

По рекомендации @john elements я решил использовать PromiseKit.

Это не потребовало значительных изменений кода, и вот как теперь выглядят функции (еще нужно немного почистить код, но это работает!):

func getProduct(ean: String) -> Promise<Product> {
    return Promise { fullfill, reject in
        let urlString = BSConstants.BarcodeScanner.productEndpoint.stringByAppendingString(ean)
        serviceClient.GET(urlString, failure: { (error) in
            reject(error!)
        }) { (response) in
            if let json = response {
                self.storeProduct(json).then ({ returnedProduct in
                    print("We stored the product: \(returnedProduct.ean)")
                    fullfill(returnedProduct)
                }).error { returnedError in
                    print("We had a problem storing the product: \(returnedError)")
                }
            }
        }
    }
}

func storeProduct(json: JSON) -> Promise<Product> {
    return Promise { fullfill, reject in
        fetchProduct(json["ean"].stringValue).then ({ returnedProduct in

            var storedProduct: Product!
            var isNewProduct = false

            print("Fetched Product: \(returnedProduct.ean)")

            isNewProduct = returnedProduct.valueForKey("ean") == nil
            storedProduct = returnedProduct
            storedProduct.setValue(json["name"].stringValue, forKey: "name")
            storedProduct.setValue(json["ean"].stringValue, forKey: "ean")
            storedProduct.setValue(json["image"].stringValue, forKey: "image")
            storedProduct.setValue(json["price"].doubleValue, forKey: "price")
            storedProduct.setValue(json["status"].intValue, forKey: "status")
            storedProduct.setValue(json["pdp"].stringValue, forKey: "pdp")
            storedProduct.setValue(BSCountryManager.sharedInstance().getCurrentCountry().market, forKey: "market")
            storedProduct.setValue(BSLocalizationManager.sharedManager().currentLocalization.localeIdentifier(), forKey: "locale")
            storedProduct.setValue(BSLocalizationManager.sharedManager().currentLocalization.country.currencyIdentifierDMW, forKey: "currency")

            do {
                try self.objectContext.save()
                print("Stored Product: \(returnedProduct.ean)")
                fullfill(returnedProduct)

                if isNewProduct {
                    NSNotificationCenter.defaultCenter().postNotificationName("DidAddScanEntry", object: nil)
                }

            } catch let error as NSError {
                print("Could not save \(error), \(error.userInfo)")
                reject(error)
            }

        }).error { returnedError in
            print("We had a problem fetching the product: \(returnedError)")
            reject(returnedError)
        }
    }
}

func fetchProduct(ean: String) -> Promise<Product> {
    return Promise { fullfill, reject in

        let fetchRequest = NSFetchRequest(entityName: "Product")
        let predicateEAN = NSPredicate(format: "%K == %@", "ean", ean)
        let predicateMarket = NSPredicate(format: "%K == %@", "market", BSCountryManager.sharedInstance().getCurrentCountry().market)
        let predicateLocale = NSPredicate(format: "%K == %@", "locale", BSLocalizationManager.sharedManager().currentLocalization.localeIdentifier())
        let predicateCurrency = NSPredicate(format: "%K == %@", "currency", BSLocalizationManager.sharedManager().currentLocalization.country.currencyIdentifierDMW)
        let compoundPredicate = NSCompoundPredicate(andPredicateWithSubpredicates: [predicateEAN, predicateMarket, predicateLocale, predicateCurrency])
        fetchRequest.predicate = compoundPredicate

        do {
            let matchingProuducts = try objectContext.executeFetchRequest(fetchRequest)

            if matchingProuducts.count == 0 {
                print("No matching products found")
                let entity = NSEntityDescription.entityForName("Product", inManagedObjectContext: objectContext)
                fullfill(Product(entity: entity!, insertIntoManagedObjectContext: objectContext))
            } else {
                print("Found matching product")
                let d = matchingProuducts.first as! Product
                fullfill(d)
            }
        } catch let error as NSError {
            print("Could not fetch \(error), \(error.userInfo)")
            reject(error)
        }
    }
}

Hodson 09.08.2016

Цепочка методов Swift с успехом и неудачей

Ответы (1)

Вопросы по теме