如何在 Swift 中使用 Combine 读取 JSON 错误对象的属性值？

Question

我所有的 API 端点都返回一个在 Postman 中看起来像这样的响应：

{
    "statusCode": 401,
    "error": "Unauthorized",
    "message": "Missing authentication"
}

我想做的是发出请求，并在 Swift 中访问这些属性。在某些情况下，我会在应用程序的前面使用错误消息属性的值。这将由返回的 statusCode 确定。

我现在拥有的是这样的：

    private var cancellable: AnyCancellable?
    let url = URL(string: "http://abc336699.com/create")
    self.cancellable = URLSession.shared.dataTaskPublisher(for: url!)
      .map { $0.data }

在此之前，我尝试过 tryMap，但它返回的错误类型并没有给我想要的灵活性。然后我继续尝试 Almofire，但对于我想做的事情来说，这似乎是一种过度杀戮。

我想检查我收到的响应中返回的内容，但我收到以下错误：

Cannot assign value of type 'Publishers.Map<URLSession.DataTaskPublisher, Data>' to type 'AnyCancellable'

我想要简单地访问我的响应错误，以便我可以使用 combine 将 API 集成到整个应用程序中。

Answer 1

我不确定您将从哪里获取数据，因为在 JSON 响应中没有数据密钥。在写下面的代码之前，我的理解是你想从提到的 JSON 响应中检查 error 和 statusCode，然后继续你的业务逻辑。下面的代码是为了让您大致了解我们如何做到这一点。

    enum CustomError: Error {

    case custom(_ error: String)
    case unknownStatusCode
    case errorOccurred
}

let url = URL(string: "http://abc336699.com/create")

    func load() -> AnyPublisher<Data,CustomError> {
    URLSession.shared.dataTaskPublisher(for: url!)
        .map(\.data)
        .tryMap { (data) -> Data in
            let genericModel = try? JSONSerialization.jsonObject(with: data, options: .allowFragments) as? [String: AnyObject]

            if let statusCode = genericModel?["statusCode"] as? String {
                switch statusCode {
                case "200":
                    guard let data = genericModel?["message"] as? Data else {
                        throw CustomError.custom("Parsing error")
                    }
                    return data
                default:
                    if let error = genericModel?["error"] as? String {
                        throw CustomError.custom(error)
                    } else {
                        throw CustomError.unknownError
                    }
                }
            }
            throw CustomError.errorOccurred
    }
    .decode(type: YourCustomDecodableModel.self, decoder: JSONDecoder())
    .mapError({ $0 as? CustomError ?? CustomError.errorOccurred })
    .eraseToAnyPublisher()
}