import android.util.Log;

import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.annotations.NonNull;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;

public class AuthUserInteractorImpl implements AuthUserInteractor {

    private static final String TAG = AuthUserInteractorImpl.class.getSimpleName();
    private AuthUserPresenter presenter;
    private AuthService authService;

    public AuthUserInteractorImpl(AuthUserPresenter presenter) {
        this.presenter = presenter;
        authService = NetworkGenerator.createNetworkClient(AuthService.class);
    }

    @Override
    public void loginUser(LoginRequest loginRequest) {
        authService.loginUser(loginRequest)
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<LoginResponse>() {
                    @Override
                    public void onSubscribe(@NonNull Disposable d) {

                    }

                    @Override
                    public void onNext(@NonNull LoginResponse loginResponse) {
                        Log.d(TAG, "onNext: Auth");
                        presenter.getAuthData(loginResponse);
                    }

                    @Override
                    public void onError(@NonNull Throwable e) {

                    }

                    @Override
                    public void onComplete() {

                    }
                });
    }

    @Override
    public void activateUser(final ActivationRequest activationRequest) {
        authService.activateUser(activationRequest)
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<ActivationResponse>() {
                    @Override
                    public void onSubscribe(@NonNull Disposable d) {

                    }

                    @Override
                    public void onNext(@NonNull ActivationResponse activationResponse) {
                        Log.d(TAG, "onNext:activateUser");
                        Log.d(TAG, "onNext:loginUser = " + activationResponse.toString());
                        presenter.getActivationData(activationResponse);
                    }

                    @Override
                    public void onError(@NonNull Throwable e) {
                        Log.d(TAG, "onError:activateUser");
                        presenter.onFailed();
                    }

                    @Override
                    public void onComplete() {

                    }
                });
    }
}