extension CLLocationManager: HasDelegate {}

// RxCLLocationManagerDelegateProxy는 Observable이 생성되고 구독이 있는 직후 CLLocationManager 인스턴스에 연결하는 프록시가 된다.
// 이것은 RxCocoa가 제공하는 HasDelegate 프로토콜에 의해 단순화.
// 예상대로 래핑을 통하여 CLLocationManagerDelegate 그 자체 역할을 대신한다.

class RxCLLocationManagerDelegateProxy : DelegateProxy<CLLocationManager, CLLocationManagerDelegate>, DelegateProxyType, CLLocationManagerDelegate {

  // 이 두 가지 메서드를 사용하면 대리자를 초기화하고 CLLocationManager 인스턴스에서 연결된 관측값으로 데이터를 구동하는 데 사용되는 프록시인 모든 구현을 등록가능
  // RxCocoa의 delegate proxy 패턴을 사용하도록 클래스를 확장

  public init(locationManager: CLLocationManager) {
    super.init(parentObject: locationManager, delegateProxy: RxCLLocationManagerDelegateProxy.self)
  }

  static func registerKnownImplementations() {
    self.register { RxCLLocationManagerDelegateProxy(locationManager: $0) }
  }
}

// didUpdateLocations을 사용하면 연결된 proxy를 통하여 delegate에서   didUpdateLocations 메서드의 모든 호출을 수신하고 데이터를 가져와서 CLLocation.methodInvoked(_:)의 array로 캐스팅 한다.
// methodInvoked(_:)는 지정된 메서드가 호출될 때마다 다음 이벤트를 보내는 Observable을 return한다. 각 방출된 요소는 메서드가 호출된 매개 변수의 배열이다. 매개 변수[1]로 두 번째 매개 변수인 didUpdateLocations에 액세스하고 CLLocation 배열로 캐스팅한다.

public extension Reactive where Base: CLLocationManager {
  var delegate: DelegateProxy<CLLocationManager, CLLocationManagerDelegate> {
    return RxCLLocationManagerDelegateProxy.proxy(for: base)
  }

  var didUpdateLocations: Observable<[CLLocation]> {
    return delegate.methodInvoked(#selector(CLLocationManagerDelegate.locationManager(_:didUpdateLocations:)))
      .map { parameters in
        return parameters[1] as! [CLLocation]
    }
  }
}

extension MKMapView: HasDelegate {}

class RxMKMapViewDelegateProxy: DelegateProxy<MKMapView, MKMapViewDelegate>, DelegateProxyType, MKMapViewDelegate {
    weak public private(set) var mapView: MKMapView?

    public init(mapView: ParentObject) {
        self.mapView = mapView
        super.init(parentObject: mapView,
                   delegateProxy: RxMKMapViewDelegateProxy.self)
    }

    static func registerKnownImplementations() {
        register { RxMKMapViewDelegateProxy(mapView: $0) }
    }
}

public extension Reactive where Base: MKMapView {
    var delegate: DelegateProxy<MKMapView, MKMapViewDelegate> { RxMKMapViewDelegateProxy.proxy(for: base)
    }

    // 기존 딜리게이트와 같이 사용할 수 있도록 구성해준다.
    func setDelegate(_ delegate: MKMapViewDelegate) -> Disposable {
        RxMKMapViewDelegateProxy.installForwardDelegate(
            delegate,
            retainDelegate: false,
            onProxyForObject: self.base
        )
    }

    // MKOverlay의 모든 인스턴스를 받을 것이고 또한 이들은 현재 지도에 나타내준다
    // Binder의 사용은 bind 또는 drive 함수를 사용할 수 있게 해준다.
    // overlays binding observable 내서는 이전 Overlay들은 매번 Subject에 새 array가 보내질 때마다 사라지고 재생성
    var overlay: Binder<MKOverlay> {
        Binder(base) { mapView, overlay in
            mapView.removeOverlays(mapView.overlays)
            mapView.addOverlay(overlay)
            mapView.setRegion(MKCoordinateRegion(center: overlay.coordinate, span: MKCoordinateSpan(latitudeDelta: 3, longitudeDelta: 3)), animated: true)
        }
    }

    // return이 없는 일반적인 메서드의 관찰은 이전과 동일하다
    var regionDidChangeAnimated: ControlEvent<Bool> {
        let source = delegate
            .methodInvoked(#selector(MKMapViewDelegate.mapView(_:regionDidChangeAnimated:)))
            .map { parameters in
                return (parameters[1] as? Bool) ?? false
            }
        return ControlEvent(events: source)
    }
}