package org.apache.fineract.ui.online.roles.roleslist;

import android.content.Context;

import org.apache.fineract.R;
import org.apache.fineract.data.datamanager.api.DataManagerRoles;
import org.apache.fineract.data.models.rolesandpermission.Role;
import org.apache.fineract.injection.ApplicationContext;
import org.apache.fineract.injection.ConfigPersistent;
import org.apache.fineract.ui.base.BasePresenter;

import java.util.List;

import javax.inject.Inject;

import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.observers.DisposableObserver;
import io.reactivex.schedulers.Schedulers;

/**
 * @author Rajan Maurya
 *         On 24/08/17.
 */
@ConfigPersistent
public class RolesPresenter extends BasePresenter<RolesContract.View>
        implements RolesContract.Presenter {

    private final DataManagerRoles dataManagerRoles;
    private CompositeDisposable compositeDisposable;

    @Inject
    public RolesPresenter(@ApplicationContext Context context,
            DataManagerRoles dataManagerRoles) {
        super(context);
        this.dataManagerRoles = dataManagerRoles;
        compositeDisposable = new CompositeDisposable();
    }

    @Override
    public void attachView(RolesContract.View mvpView) {
        super.attachView(mvpView);
    }

    @Override
    public void detachView() {
        super.detachView();
        compositeDisposable.clear();
    }

    @Override
    public void fetchRoles() {
        checkViewAttached();
        getMvpView().showProgressbar();
        compositeDisposable.add(dataManagerRoles.getRoles()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeWith(new DisposableObserver<List<Role>>() {
                    @Override
                    public void onNext(List<Role> roles) {
                        getMvpView().hideProgressbar();
                        if (!roles.isEmpty()) {
                            getMvpView().showRoles(roles);
                        } else {
                            getMvpView().showEmptyRoles();
                        }
                    }

                    @Override
                    public void onError(Throwable throwable) {
                        getMvpView().hideProgressbar();
                        showExceptionError(throwable,
                                context.getString(R.string.error_fetching_roles));
                    }

                    @Override
                    public void onComplete() {

                    }
                })
        );
    }
}