Alamofire+Reactive.swift

//
//  Alamofire+Reactive.swift
//  architecture
//
//  Created by MakotoAoyama on 9/8/17.
//

import Foundation
import ReactiveSwift
import Alamofire
import Result

private let defaultSessionError = NSError(domain: "Reactivity.Alamofiew.SessionManager.dataWithRequest",
                                          code: 1,
                                          userInfo: nil)

extension SessionManager : ReactiveExtensionsProvider {
}

extension Reactive where Base: SessionManager {

    func request(_ url: URLConvertible, method: HTTPMethod, parameters: Parameters?, encoding: ParameterEncoding, headers: HTTPHeaders?) -> SignalProducer<(Data, URLResponse), AnyError> {
        return SignalProducer { [base = self.base] observer, lifetime in
            let dataRequest = base.request(url, method: method, parameters: parameters, encoding: encoding, headers: headers)
            dataRequest.response { (dataResponce) in
                if let data = dataResponce.data, let responce = dataResponce.response {
                    observer.send(value: (data, responce))
                    observer.sendCompleted()
                } else {
                    observer.send(error: AnyError(dataResponce.error ?? defaultSessionError))
                }
            }
            lifetime.observeEnded {
                dataRequest.cancel()
            }
            dataRequest.resume()
        }
    }

}