123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366 |
- import Foundation
- public protocol ResponseSerializerType {
-
- typealias SerializedObject
-
- typealias ErrorObject: ErrorType
-
- var serializeResponse: (NSURLRequest?, NSHTTPURLResponse?, NSData?, NSError?) -> Result<SerializedObject, ErrorObject> { get }
- }
- public struct ResponseSerializer<Value, Error: ErrorType>: ResponseSerializerType {
-
- public typealias SerializedObject = Value
-
- public typealias ErrorObject = Error
-
- public var serializeResponse: (NSURLRequest?, NSHTTPURLResponse?, NSData?, NSError?) -> Result<Value, Error>
-
- public init(serializeResponse: (NSURLRequest?, NSHTTPURLResponse?, NSData?, NSError?) -> Result<Value, Error>) {
- self.serializeResponse = serializeResponse
- }
- }
- extension Request {
-
- public func response(
- queue queue: dispatch_queue_t? = nil,
- completionHandler: (NSURLRequest?, NSHTTPURLResponse?, NSData?, NSError?) -> Void)
- -> Self
- {
- delegate.queue.addOperationWithBlock {
- dispatch_async(queue ?? dispatch_get_main_queue()) {
- completionHandler(self.request, self.response, self.delegate.data, self.delegate.error)
- }
- }
- return self
- }
-
- public func response<T: ResponseSerializerType>(
- queue queue: dispatch_queue_t? = nil,
- responseSerializer: T,
- completionHandler: Response<T.SerializedObject, T.ErrorObject> -> Void)
- -> Self
- {
- delegate.queue.addOperationWithBlock {
- let result = responseSerializer.serializeResponse(
- self.request,
- self.response,
- self.delegate.data,
- self.delegate.error
- )
- let requestCompletedTime = self.endTime ?? CFAbsoluteTimeGetCurrent()
- let initialResponseTime = self.delegate.initialResponseTime ?? requestCompletedTime
- let timeline = Timeline(
- requestStartTime: self.startTime ?? CFAbsoluteTimeGetCurrent(),
- initialResponseTime: initialResponseTime,
- requestCompletedTime: requestCompletedTime,
- serializationCompletedTime: CFAbsoluteTimeGetCurrent()
- )
- let response = Response<T.SerializedObject, T.ErrorObject>(
- request: self.request,
- response: self.response,
- data: self.delegate.data,
- result: result,
- timeline: timeline
- )
- dispatch_async(queue ?? dispatch_get_main_queue()) { completionHandler(response) }
- }
- return self
- }
- }
- extension Request {
-
- public static func dataResponseSerializer() -> ResponseSerializer<NSData, NSError> {
- return ResponseSerializer { _, response, data, error in
- guard error == nil else { return .Failure(error!) }
- if let response = response where response.statusCode == 204 { return .Success(NSData()) }
- guard let validData = data else {
- let failureReason = "Data could not be serialized. Input data was nil."
- let error = Error.errorWithCode(.DataSerializationFailed, failureReason: failureReason)
- return .Failure(error)
- }
- return .Success(validData)
- }
- }
-
- public func responseData(completionHandler: Response<NSData, NSError> -> Void) -> Self {
- return response(responseSerializer: Request.dataResponseSerializer(), completionHandler: completionHandler)
- }
- }
- extension Request {
-
- public static func stringResponseSerializer(
- encoding encoding: NSStringEncoding? = nil)
- -> ResponseSerializer<String, NSError>
- {
- return ResponseSerializer { _, response, data, error in
- guard error == nil else { return .Failure(error!) }
- if let response = response where response.statusCode == 204 { return .Success("") }
- guard let validData = data else {
- let failureReason = "String could not be serialized. Input data was nil."
- let error = Error.errorWithCode(.StringSerializationFailed, failureReason: failureReason)
- return .Failure(error)
- }
-
- var convertedEncoding = encoding
-
- if let encodingName = response?.textEncodingName where convertedEncoding == nil {
- convertedEncoding = CFStringConvertEncodingToNSStringEncoding(
- CFStringConvertIANACharSetNameToEncoding(encodingName)
- )
- }
- let actualEncoding = convertedEncoding ?? NSISOLatin1StringEncoding
- if let string = String(data: validData, encoding: actualEncoding) {
- return .Success(string)
- } else {
- let failureReason = "String could not be serialized with encoding: \(actualEncoding)"
- let error = Error.errorWithCode(.StringSerializationFailed, failureReason: failureReason)
- return .Failure(error)
- }
- }
- }
-
- public func responseString(
- encoding encoding: NSStringEncoding? = nil,
- completionHandler: Response<String, NSError> -> Void)
- -> Self
- {
- return response(
- responseSerializer: Request.stringResponseSerializer(encoding: encoding),
- completionHandler: completionHandler
- )
- }
- }
- extension Request {
-
- public static func JSONResponseSerializer(
- options options: NSJSONReadingOptions = .AllowFragments)
- -> ResponseSerializer<AnyObject, NSError>
- {
- return ResponseSerializer { _, response, data, error in
- guard error == nil else { return .Failure(error!) }
- if let response = response where response.statusCode == 204 { return .Success(NSNull()) }
- guard let validData = data where validData.length > 0 else {
- let failureReason = "JSON could not be serialized. Input data was nil or zero length."
- let error = Error.errorWithCode(.JSONSerializationFailed, failureReason: failureReason)
- return .Failure(error)
- }
- do {
- let JSON = try NSJSONSerialization.JSONObjectWithData(validData, options: options)
- return .Success(JSON)
- } catch {
- return .Failure(error as NSError)
- }
- }
- }
-
- public func responseJSON(
- options options: NSJSONReadingOptions = .AllowFragments,
- completionHandler: Response<AnyObject, NSError> -> Void)
- -> Self
- {
- return response(
- responseSerializer: Request.JSONResponseSerializer(options: options),
- completionHandler: completionHandler
- )
- }
- }
- extension Request {
-
- public static func propertyListResponseSerializer(
- options options: NSPropertyListReadOptions = NSPropertyListReadOptions())
- -> ResponseSerializer<AnyObject, NSError>
- {
- return ResponseSerializer { _, response, data, error in
- guard error == nil else { return .Failure(error!) }
- if let response = response where response.statusCode == 204 { return .Success(NSNull()) }
- guard let validData = data where validData.length > 0 else {
- let failureReason = "Property list could not be serialized. Input data was nil or zero length."
- let error = Error.errorWithCode(.PropertyListSerializationFailed, failureReason: failureReason)
- return .Failure(error)
- }
- do {
- let plist = try NSPropertyListSerialization.propertyListWithData(validData, options: options, format: nil)
- return .Success(plist)
- } catch {
- return .Failure(error as NSError)
- }
- }
- }
-
- public func responsePropertyList(
- options options: NSPropertyListReadOptions = NSPropertyListReadOptions(),
- completionHandler: Response<AnyObject, NSError> -> Void)
- -> Self
- {
- return response(
- responseSerializer: Request.propertyListResponseSerializer(options: options),
- completionHandler: completionHandler
- )
- }
- }
|