package com.duqing.missions.ui.login.view;

import android.os.CountDownTimer;
import android.util.Patterns;

import androidx.lifecycle.LiveData;
import androidx.lifecycle.MutableLiveData;
import androidx.lifecycle.ViewModel;

import com.duqing.missions.R;
import com.duqing.missions.retrofit.AndroidScheduler;
import com.duqing.missions.ui.login.data.LoginRepository;
import com.duqing.missions.ui.login.data.model.LoggedInUser;

import io.reactivex.Observable;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.observers.DisposableObserver;
import io.reactivex.schedulers.Schedulers;

public class LoginViewModel extends ViewModel {

    private MutableLiveData<LoginFormState> loginFormState = new MutableLiveData<>();
    private MutableLiveData<LoginResult> loginResult = new MutableLiveData<>();
    private LoginRepository loginRepository;
    private MutableLiveData<Long> countDown = new MutableLiveData<>();
    private CountDownTimer timer;

    LoginViewModel(LoginRepository loginRepository) {
        this.loginRepository = loginRepository;
    }

    LiveData<LoginFormState> getLoginFormState() {
        return loginFormState;
    }

    LiveData<LoginResult> getLoginResult() {
        return loginResult;
    }

    public void login(String username, String password) {
        // can be launched in a separate asynchronous job
        Observable<LoggedInUser> result = loginRepository.login(username, password);
        result.subscribeOn(Schedulers.io())//指定网络请求在io后台线程中进行
            .observeOn(AndroidScheduler.mainThread())//指定observer回调在UI主线程中进行
            .doOnSubscribe(new Consumer<Disposable>() {
                @Override
                public void accept(Disposable disposable) throws Exception {

                }
            }).subscribe(new DisposableObserver<LoggedInUser>(){

                @Override
                public void onNext(LoggedInUser value) {
                    loginResult.setValue(new LoginResult((new LoggedInUserView(value.getDisplayName()))));
                }

                @Override
                public void onError(Throwable e) {
                    loginResult.setValue(new LoginResult(R.string.login_failed));
                }

                @Override
                public void onComplete() {

                }
            });
    }

    public void loginDataChanged(String username, String password) {
        if (!isUserNameValid(username)) {
            loginFormState.setValue(new LoginFormState(R.string.invalid_username, null));
        } else if (!isPasswordValid(password)) {
            loginFormState.setValue(new LoginFormState(null, R.string.invalid_password));
        } else {
            loginFormState.setValue(new LoginFormState(true));
        }
    }

    // A placeholder username validation check
    private boolean isUserNameValid(String username) {
        if (username == null) {
            return false;
        }
        if (username.contains("@")) {
            return Patterns.EMAIL_ADDRESS.matcher(username).matches();
        } else {
            return !username.trim().isEmpty();
        }
    }

    // A placeholder password validation check
    private boolean isPasswordValid(String password) {
        return password != null && password.trim().length() > 5;
    }

    public MutableLiveData<Long> getCountDown() {
        return countDown;
    }

    /**
     * 启动倒计时
     * @param consumedTime
     */
    public void startCountDown(long consumedTime){
        //倒计时
        timer = new CountDownTimer(60 * 1000-consumedTime, 1000) {

            @Override
            public void onTick(long l) {
                countDown.postValue(l / 1000);
            }

            @Override
            public void onFinish() {
                countDown.setValue(0l);
            }
        };
        timer.start();
    }


}