123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453 |
- //
- // Response.swift
- //
- // Copyright (c) 2014-2018 Alamofire Software Foundation (http://alamofire.org/)
- //
- // Permission is hereby granted, free of charge, to any person obtaining a copy
- // of this software and associated documentation files (the "Software"), to deal
- // in the Software without restriction, including without limitation the rights
- // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
- // copies of the Software, and to permit persons to whom the Software is
- // furnished to do so, subject to the following conditions:
- //
- // The above copyright notice and this permission notice shall be included in
- // all copies or substantial portions of the Software.
- //
- // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
- // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
- // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
- // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
- // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
- // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
- // THE SOFTWARE.
- //
- import Foundation
- /// Default type of `DataResponse` returned by Alamofire, with an `AFError` `Failure` type.
- public typealias AFDataResponse<Success> = DataResponse<Success, AFError>
- /// Default type of `DownloadResponse` returned by Alamofire, with an `AFError` `Failure` type.
- public typealias AFDownloadResponse<Success> = DownloadResponse<Success, AFError>
- /// Type used to store all values associated with a serialized response of a `DataRequest` or `UploadRequest`.
- public struct DataResponse<Success, Failure: Error> {
- /// The URL request sent to the server.
- public let request: URLRequest?
- /// The server's response to the URL request.
- public let response: HTTPURLResponse?
- /// The data returned by the server.
- public let data: Data?
- /// The final metrics of the response.
- ///
- /// - Note: Due to `FB7624529`, collection of `URLSessionTaskMetrics` on watchOS is currently disabled.`
- ///
- public let metrics: URLSessionTaskMetrics?
- /// The time taken to serialize the response.
- public let serializationDuration: TimeInterval
- /// The result of response serialization.
- public let result: Result<Success, Failure>
- /// Returns the associated value of the result if it is a success, `nil` otherwise.
- public var value: Success? { result.success }
- /// Returns the associated error value if the result if it is a failure, `nil` otherwise.
- public var error: Failure? { result.failure }
- /// Creates a `DataResponse` instance with the specified parameters derived from the response serialization.
- ///
- /// - Parameters:
- /// - request: The `URLRequest` sent to the server.
- /// - response: The `HTTPURLResponse` from the server.
- /// - data: The `Data` returned by the server.
- /// - metrics: The `URLSessionTaskMetrics` of the `DataRequest` or `UploadRequest`.
- /// - serializationDuration: The duration taken by serialization.
- /// - result: The `Result` of response serialization.
- public init(request: URLRequest?,
- response: HTTPURLResponse?,
- data: Data?,
- metrics: URLSessionTaskMetrics?,
- serializationDuration: TimeInterval,
- result: Result<Success, Failure>) {
- self.request = request
- self.response = response
- self.data = data
- self.metrics = metrics
- self.serializationDuration = serializationDuration
- self.result = result
- }
- }
- // MARK: -
- extension DataResponse: CustomStringConvertible, CustomDebugStringConvertible {
- /// The textual representation used when written to an output stream, which includes whether the result was a
- /// success or failure.
- public var description: String {
- "\(result)"
- }
- /// The debug textual representation used when written to an output stream, which includes (if available) a summary
- /// of the `URLRequest`, the request's headers and body (if decodable as a `String` below 100KB); the
- /// `HTTPURLResponse`'s status code, headers, and body; the duration of the network and serialization actions; and
- /// the `Result` of serialization.
- public var debugDescription: String {
- guard let urlRequest = request else { return "[Request]: None\n[Result]: \(result)" }
- let requestDescription = DebugDescription.description(of: urlRequest)
- let responseDescription = response.map { response in
- let responseBodyDescription = DebugDescription.description(for: data, headers: response.headers)
- return """
- \(DebugDescription.description(of: response))
- \(responseBodyDescription.indentingNewlines())
- """
- } ?? "[Response]: None"
- let networkDuration = metrics.map { "\($0.taskInterval.duration)s" } ?? "None"
- return """
- \(requestDescription)
- \(responseDescription)
- [Network Duration]: \(networkDuration)
- [Serialization Duration]: \(serializationDuration)s
- [Result]: \(result)
- """
- }
- }
- // MARK: -
- extension DataResponse {
- /// Evaluates the specified closure when the result of this `DataResponse` is a success, passing the unwrapped
- /// result value as a parameter.
- ///
- /// Use the `map` method with a closure that does not throw. For example:
- ///
- /// let possibleData: DataResponse<Data> = ...
- /// let possibleInt = possibleData.map { $0.count }
- ///
- /// - parameter transform: A closure that takes the success value of the instance's result.
- ///
- /// - returns: A `DataResponse` whose result wraps the value returned by the given closure. If this instance's
- /// result is a failure, returns a response wrapping the same failure.
- public func map<NewSuccess>(_ transform: (Success) -> NewSuccess) -> DataResponse<NewSuccess, Failure> {
- DataResponse<NewSuccess, Failure>(request: request,
- response: response,
- data: data,
- metrics: metrics,
- serializationDuration: serializationDuration,
- result: result.map(transform))
- }
- /// Evaluates the given closure when the result of this `DataResponse` is a success, passing the unwrapped result
- /// value as a parameter.
- ///
- /// Use the `tryMap` method with a closure that may throw an error. For example:
- ///
- /// let possibleData: DataResponse<Data> = ...
- /// let possibleObject = possibleData.tryMap {
- /// try JSONSerialization.jsonObject(with: $0)
- /// }
- ///
- /// - parameter transform: A closure that takes the success value of the instance's result.
- ///
- /// - returns: A success or failure `DataResponse` depending on the result of the given closure. If this instance's
- /// result is a failure, returns the same failure.
- public func tryMap<NewSuccess>(_ transform: (Success) throws -> NewSuccess) -> DataResponse<NewSuccess, Error> {
- DataResponse<NewSuccess, Error>(request: request,
- response: response,
- data: data,
- metrics: metrics,
- serializationDuration: serializationDuration,
- result: result.tryMap(transform))
- }
- /// Evaluates the specified closure when the `DataResponse` is a failure, passing the unwrapped error as a parameter.
- ///
- /// Use the `mapError` function with a closure that does not throw. For example:
- ///
- /// let possibleData: DataResponse<Data> = ...
- /// let withMyError = possibleData.mapError { MyError.error($0) }
- ///
- /// - Parameter transform: A closure that takes the error of the instance.
- ///
- /// - Returns: A `DataResponse` instance containing the result of the transform.
- public func mapError<NewFailure: Error>(_ transform: (Failure) -> NewFailure) -> DataResponse<Success, NewFailure> {
- DataResponse<Success, NewFailure>(request: request,
- response: response,
- data: data,
- metrics: metrics,
- serializationDuration: serializationDuration,
- result: result.mapError(transform))
- }
- /// Evaluates the specified closure when the `DataResponse` is a failure, passing the unwrapped error as a parameter.
- ///
- /// Use the `tryMapError` function with a closure that may throw an error. For example:
- ///
- /// let possibleData: DataResponse<Data> = ...
- /// let possibleObject = possibleData.tryMapError {
- /// try someFailableFunction(taking: $0)
- /// }
- ///
- /// - Parameter transform: A throwing closure that takes the error of the instance.
- ///
- /// - Returns: A `DataResponse` instance containing the result of the transform.
- public func tryMapError<NewFailure: Error>(_ transform: (Failure) throws -> NewFailure) -> DataResponse<Success, Error> {
- DataResponse<Success, Error>(request: request,
- response: response,
- data: data,
- metrics: metrics,
- serializationDuration: serializationDuration,
- result: result.tryMapError(transform))
- }
- }
- // MARK: -
- /// Used to store all data associated with a serialized response of a download request.
- public struct DownloadResponse<Success, Failure: Error> {
- /// The URL request sent to the server.
- public let request: URLRequest?
- /// The server's response to the URL request.
- public let response: HTTPURLResponse?
- /// The final destination URL of the data returned from the server after it is moved.
- public let fileURL: URL?
- /// The resume data generated if the request was cancelled.
- public let resumeData: Data?
- /// The final metrics of the response.
- ///
- /// - Note: Due to `FB7624529`, collection of `URLSessionTaskMetrics` on watchOS is currently disabled.`
- ///
- public let metrics: URLSessionTaskMetrics?
- /// The time taken to serialize the response.
- public let serializationDuration: TimeInterval
- /// The result of response serialization.
- public let result: Result<Success, Failure>
- /// Returns the associated value of the result if it is a success, `nil` otherwise.
- public var value: Success? { result.success }
- /// Returns the associated error value if the result if it is a failure, `nil` otherwise.
- public var error: Failure? { result.failure }
- /// Creates a `DownloadResponse` instance with the specified parameters derived from response serialization.
- ///
- /// - Parameters:
- /// - request: The `URLRequest` sent to the server.
- /// - response: The `HTTPURLResponse` from the server.
- /// - fileURL: The final destination URL of the data returned from the server after it is moved.
- /// - resumeData: The resume `Data` generated if the request was cancelled.
- /// - metrics: The `URLSessionTaskMetrics` of the `DownloadRequest`.
- /// - serializationDuration: The duration taken by serialization.
- /// - result: The `Result` of response serialization.
- public init(request: URLRequest?,
- response: HTTPURLResponse?,
- fileURL: URL?,
- resumeData: Data?,
- metrics: URLSessionTaskMetrics?,
- serializationDuration: TimeInterval,
- result: Result<Success, Failure>) {
- self.request = request
- self.response = response
- self.fileURL = fileURL
- self.resumeData = resumeData
- self.metrics = metrics
- self.serializationDuration = serializationDuration
- self.result = result
- }
- }
- // MARK: -
- extension DownloadResponse: CustomStringConvertible, CustomDebugStringConvertible {
- /// The textual representation used when written to an output stream, which includes whether the result was a
- /// success or failure.
- public var description: String {
- "\(result)"
- }
- /// The debug textual representation used when written to an output stream, which includes the URL request, the URL
- /// response, the temporary and destination URLs, the resume data, the durations of the network and serialization
- /// actions, and the response serialization result.
- public var debugDescription: String {
- guard let urlRequest = request else { return "[Request]: None\n[Result]: \(result)" }
- let requestDescription = DebugDescription.description(of: urlRequest)
- let responseDescription = response.map(DebugDescription.description(of:)) ?? "[Response]: None"
- let networkDuration = metrics.map { "\($0.taskInterval.duration)s" } ?? "None"
- let resumeDataDescription = resumeData.map { "\($0)" } ?? "None"
- return """
- \(requestDescription)
- \(responseDescription)
- [File URL]: \(fileURL?.path ?? "None")
- [Resume Data]: \(resumeDataDescription)
- [Network Duration]: \(networkDuration)
- [Serialization Duration]: \(serializationDuration)s
- [Result]: \(result)
- """
- }
- }
- // MARK: -
- extension DownloadResponse {
- /// Evaluates the given closure when the result of this `DownloadResponse` is a success, passing the unwrapped
- /// result value as a parameter.
- ///
- /// Use the `map` method with a closure that does not throw. For example:
- ///
- /// let possibleData: DownloadResponse<Data> = ...
- /// let possibleInt = possibleData.map { $0.count }
- ///
- /// - parameter transform: A closure that takes the success value of the instance's result.
- ///
- /// - returns: A `DownloadResponse` whose result wraps the value returned by the given closure. If this instance's
- /// result is a failure, returns a response wrapping the same failure.
- public func map<NewSuccess>(_ transform: (Success) -> NewSuccess) -> DownloadResponse<NewSuccess, Failure> {
- DownloadResponse<NewSuccess, Failure>(request: request,
- response: response,
- fileURL: fileURL,
- resumeData: resumeData,
- metrics: metrics,
- serializationDuration: serializationDuration,
- result: result.map(transform))
- }
- /// Evaluates the given closure when the result of this `DownloadResponse` is a success, passing the unwrapped
- /// result value as a parameter.
- ///
- /// Use the `tryMap` method with a closure that may throw an error. For example:
- ///
- /// let possibleData: DownloadResponse<Data> = ...
- /// let possibleObject = possibleData.tryMap {
- /// try JSONSerialization.jsonObject(with: $0)
- /// }
- ///
- /// - parameter transform: A closure that takes the success value of the instance's result.
- ///
- /// - returns: A success or failure `DownloadResponse` depending on the result of the given closure. If this
- /// instance's result is a failure, returns the same failure.
- public func tryMap<NewSuccess>(_ transform: (Success) throws -> NewSuccess) -> DownloadResponse<NewSuccess, Error> {
- DownloadResponse<NewSuccess, Error>(request: request,
- response: response,
- fileURL: fileURL,
- resumeData: resumeData,
- metrics: metrics,
- serializationDuration: serializationDuration,
- result: result.tryMap(transform))
- }
- /// Evaluates the specified closure when the `DownloadResponse` is a failure, passing the unwrapped error as a parameter.
- ///
- /// Use the `mapError` function with a closure that does not throw. For example:
- ///
- /// let possibleData: DownloadResponse<Data> = ...
- /// let withMyError = possibleData.mapError { MyError.error($0) }
- ///
- /// - Parameter transform: A closure that takes the error of the instance.
- ///
- /// - Returns: A `DownloadResponse` instance containing the result of the transform.
- public func mapError<NewFailure: Error>(_ transform: (Failure) -> NewFailure) -> DownloadResponse<Success, NewFailure> {
- DownloadResponse<Success, NewFailure>(request: request,
- response: response,
- fileURL: fileURL,
- resumeData: resumeData,
- metrics: metrics,
- serializationDuration: serializationDuration,
- result: result.mapError(transform))
- }
- /// Evaluates the specified closure when the `DownloadResponse` is a failure, passing the unwrapped error as a parameter.
- ///
- /// Use the `tryMapError` function with a closure that may throw an error. For example:
- ///
- /// let possibleData: DownloadResponse<Data> = ...
- /// let possibleObject = possibleData.tryMapError {
- /// try someFailableFunction(taking: $0)
- /// }
- ///
- /// - Parameter transform: A throwing closure that takes the error of the instance.
- ///
- /// - Returns: A `DownloadResponse` instance containing the result of the transform.
- public func tryMapError<NewFailure: Error>(_ transform: (Failure) throws -> NewFailure) -> DownloadResponse<Success, Error> {
- DownloadResponse<Success, Error>(request: request,
- response: response,
- fileURL: fileURL,
- resumeData: resumeData,
- metrics: metrics,
- serializationDuration: serializationDuration,
- result: result.tryMapError(transform))
- }
- }
- private enum DebugDescription {
- static func description(of request: URLRequest) -> String {
- let requestSummary = "\(request.httpMethod!) \(request)"
- let requestHeadersDescription = DebugDescription.description(for: request.headers)
- let requestBodyDescription = DebugDescription.description(for: request.httpBody, headers: request.headers)
- return """
- [Request]: \(requestSummary)
- \(requestHeadersDescription.indentingNewlines())
- \(requestBodyDescription.indentingNewlines())
- """
- }
- static func description(of response: HTTPURLResponse) -> String {
- """
- [Response]:
- [Status Code]: \(response.statusCode)
- \(DebugDescription.description(for: response.headers).indentingNewlines())
- """
- }
- static func description(for headers: HTTPHeaders) -> String {
- guard !headers.isEmpty else { return "[Headers]: None" }
- let headerDescription = "\(headers.sorted())".indentingNewlines()
- return """
- [Headers]:
- \(headerDescription)
- """
- }
- static func description(for data: Data?,
- headers: HTTPHeaders,
- allowingPrintableTypes printableTypes: [String] = ["json", "xml", "text"],
- maximumLength: Int = 100_000) -> String {
- guard let data = data, !data.isEmpty else { return "[Body]: None" }
- guard
- data.count <= maximumLength,
- printableTypes.compactMap({ headers["Content-Type"]?.contains($0) }).contains(true)
- else { return "[Body]: \(data.count) bytes" }
- return """
- [Body]:
- \(String(decoding: data, as: UTF8.self)
- .trimmingCharacters(in: .whitespacesAndNewlines)
- .indentingNewlines())
- """
- }
- }
- extension String {
- fileprivate func indentingNewlines(by spaceCount: Int = 4) -> String {
- let spaces = String(repeating: " ", count: spaceCount)
- return replacingOccurrences(of: "\n", with: "\n\(spaces)")
- }
- }
|