Attendee Photo

gistfile.swift

private func bindAttendeePhoto() {
    let attendeePhoto = viewModel.photo
      .flatMap { image -> Observable<UIImage> in
        self.printBadge()
        return Observable.just(image!)
      }
      .observeOn(ConcurrentDispatchQueueScheduler(qos: .background))
      .flatMapLatest { image -> Observable<(UIImage, Bool)> in
        let eventId = self.event.id
        let fileSize = image.getFilesize()
        let isUploaded = self.viewModel.uploadAttendeePhoto(eventId: eventId!, fileSize: fileSize)
        return Observable.combineLatest(Observable.just(image), isUploaded)
      }
      .share()

    attendeePhoto
      .map { $0 }
      .observeOn(MainScheduler.instance)
      .subscribe(onNext: { [weak self] image, _ in
        if !(self?.viewModel.isPhotoSaved.value)! {
          self?.saveImage(image: image)
        }
      }, onError: { err in
        NotificationCenter.default.post(name: .attendeePhotoFailed, object: nil, userInfo: [
          "error": err,
          "attendeeId": self.viewModel.attendeeId.value
        ])
      })
      .disposed(by: bag)

    attendeePhoto
      .map { $1 }
      .bind(to: viewModel.isUploaded)
      .disposed(by: bag)

		viewModel.isUploaded
			.asDriver(onErrorJustReturn: false)
			.drive(onNext: { [weak self] isUploaded in
				self?.toggleAttendeePhoto(hasUploaded: isUploaded)
			})
			.disposed(by: bag)
	}