123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454 |
- import Foundation
- public typealias AFDataResponse<Success> = DataResponse<Success, AFError>
- public typealias AFDownloadResponse<Success> = DownloadResponse<Success, AFError>
- public struct DataResponse<Success, Failure: Error> {
-
- public let request: URLRequest?
-
- public let response: HTTPURLResponse?
-
- public let data: Data?
-
-
-
-
- public let metrics: URLSessionTaskMetrics?
-
- public let serializationDuration: TimeInterval
-
- public let result: Result<Success, Failure>
-
- public var value: Success? { result.success }
-
- public var error: Failure? { result.failure }
-
-
-
-
-
-
-
-
-
- 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
- }
- }
- extension DataResponse: CustomStringConvertible, CustomDebugStringConvertible {
-
-
- public var description: String {
- "\(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 { 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)
- """
- }
- }
- extension DataResponse {
-
-
-
-
-
-
-
-
-
-
-
-
- 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))
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 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))
- }
-
-
-
-
-
-
-
-
-
-
- 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))
- }
-
-
-
-
-
-
-
-
-
-
-
-
- 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))
- }
- }
- public struct DownloadResponse<Success, Failure: Error> {
-
- public let request: URLRequest?
-
- public let response: HTTPURLResponse?
-
- public let fileURL: URL?
-
- public let resumeData: Data?
-
-
-
-
- public let metrics: URLSessionTaskMetrics?
-
- public let serializationDuration: TimeInterval
-
- public let result: Result<Success, Failure>
-
- public var value: Success? { result.success }
-
- public var error: Failure? { result.failure }
-
-
-
-
-
-
-
-
-
-
-
- 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
- }
- }
- extension DownloadResponse: CustomStringConvertible, CustomDebugStringConvertible {
-
-
- public var description: String {
- "\(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)
- """
- }
- }
- extension DownloadResponse {
-
-
-
-
-
-
-
-
-
-
-
-
- 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))
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 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))
- }
-
-
-
-
-
-
-
-
-
-
- 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))
- }
-
-
-
-
-
-
-
-
-
-
-
-
- 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)")
- }
- }
|