AlamofireRACExtensions.swift

//
//  AlamofireRACExtensions.swift
//  AlamofireRACExtensions
//
//  Created by Indragie on 2/25/15.
//  Copyright (c) 2015 Indragie Karunaratne. All rights reserved.
//

import Alamofire
import ReactiveCocoa
import LlamaKit

public extension Manager {
    public func rac_request(request: URLRequestConvertible, serializer: Request.Serializer) -> SignalProducer<(AnyObject, NSHTTPURLResponse), NSError> {
        return SignalProducer { observer, disposable in
            let request = self.request(request)
                .validate()
                .response(serializer) { (request, response, responseObject, error) in
                    if let error = error {
                        sendError(observer, error)
                    } else if let response = response {
                        if let responseObject: AnyObject = responseObject {
                            sendNext(observer, (responseObject, response))
                            sendCompleted(observer)
                        } else {
                            assertionFailure("Received no response object for successful response \(response) from request \(request)")
                            sendCompleted(observer)
                        }
                    } else {
                        fatalError("Invalid response -- no HTTP response or error")
                    }
            }
            request.resume()
            disposable.addDisposable {
                request.cancel()
            }
        }
    }
    
    public func rac_dataWithRequest(request: URLRequestConvertible) -> SignalProducer<(NSData, NSHTTPURLResponse), NSError> {
        return rac_request(request, serializer: Request.responseDataSerializer())
            |> map { (object, response) in
                if let data = object as? NSData {
                    return (data, response)
                } else {
                    fatalError("Response object \(object) is not of type NSData")
                }
            }
    }
    
    public func rac_JSONWithRequest(request: URLRequestConvertible, options: NSJSONReadingOptions = .allZeros) -> SignalProducer<(AnyObject, NSHTTPURLResponse), NSError> {
        return rac_request(request, serializer: Request.JSONResponseSerializer(options: options))
    }
    
    public func rac_propertyListWithRequest(request: URLRequestConvertible, options: NSPropertyListReadOptions = .allZeros) -> SignalProducer<(AnyObject, NSHTTPURLResponse), NSError> {
        return rac_request(request, serializer: Request.propertyListResponseSerializer(options: options))
    }
}