final class ConfirmCodeViewController: BaseViewController {
  /// поле ввода кода
  private lazy var codeTextField = CodeTextField()
  /// лейбл для отображения ошибок
  private lazy var errorLabel = UILabel()
  /// один лоадер для запросов на отправку кода и на повторный запрос кода
  private lazy var loader = UIActivityIndicatorView()
  /// лейбл с обратным отсчетом для повторной отправки кода
  private lazy var timerLabel = UILabel()
  /// кнопка повторной отправки кода
  private lazy var retryButton = UIButton(type: .system)
  /// это все будет в стеквью
  private lazy var stackView = UIStackView()
}

/// Например, после успешного подтверждения кода нам могут предложить ввести перс. данные
enum AuthResult {
  case success
  case needPersonalData
}
protocol ConfirmCodeViewModelProtocol {
    /// Введенный пользователем код для подтверждения
    var code: AnyObserver<String> { get }
    /// Пользователь нажал на «отправить повторно»
    var getNewCode: AnyObserver<Void> { get }
    /// Результат подтверждения кода
    var didAuthorize: Driver<AuthResult> { get }
    /// Один индикатор на все запросы на этом экране
    var isLoading: Driver<Bool> { get }
    /// Ошибки из всех запросов на этом экране
    var errors: Driver<String> { get }
    /// Таймер отправки нового кода
    var newCodeTimer: Driver<Int> { get }
    /// Запросили новый код при нажатии на «отправить заново»
    var didRequestNewCode: Driver<Void> { get }
    /// Таймер отправки нового кода запущен
    var codeTimerIsActive: Driver<Bool> { get }
}

let codeText = codeTextField.rx.text.share()
codeText
    .bind(to: viewModel.code)
    .disposed(by: disposeBag)
retryButton.rx.tap
    .bind(to: viewModel.getNewCode)
    .disposed(by: disposeBag)

let _codeSubject = PublishSubject<String>()
self.code = _codeSubject.asObserver()
let codeObservable = _codeSubject.asObservable()
let validCodeObservable = codeObservable.filter { $0.count == codeLength }

let codeEvents: Observable<Result<Void, Error>> = validCodeObservable
    .flatMap { (code) in
        authService.confirmCode(code: code, token: token).materialize()
    }.share()

viewModel.codeTimerIsActive
    .drive(retryButton.rx.isHidden)
    .disposed(by: disposeBag)
viewModel.codeTimerIsActive
    .not()
    .drive(timerLabel.rx.isHidden)
    .disposed(by: disposeBag)

errors = codeEvents.errors().merge(with: fetchNewCode.errors())
            .compactMap { ($0 as? ErrorType)?.localizedDescription }
            .asDriver(onErrorJustReturn: "")

viewModel.isLoading
    .not()
    .drive(codeTextField.rx.isEnabled)
    .disposed(by: disposeBag)

class ConfirmCodeViewModelTests: XCTestCase {
// properties
// methods
    //MARK:- Helpers
    private func bindCodeInputEvents(
        _ events: [Recorded<Event<String>>] = [.next(100, "1"), .next(200, "11"), .next(300, "111"), .next(400, "1111")])
    {
        codeInputEvents = scheduler.createHotObservable(events)
        codeInputEvents.bind(to: viewModel.code).disposed(by: disposeBag)
    }
}

func test_timerInvokedAutomatically() {
        let sut = scheduler.start(created: 0, subscribed: 0, disposed: 1000) { self.viewModel.newCodeTimer }
        XCTAssertEqual(sut.events, [.next(1, 2), .next(2, 1), .next(3, 0)])
    }

func test_errorEmmitedValueAtFailure() throws {
        bindCodeInputEvents()
        setConfirmCodeResult(.error(0, MockError.confirmFailure))
        let sut = scheduler.start { self.viewModel.errors }
        XCTAssertEqual(sut.events, [.next(400, "confirmFailure")])
    }