package org.apache.fineract.ui.online.loanaccounts.loanaccountlist;

import android.content.Context;

import org.apache.fineract.R;
import org.apache.fineract.data.datamanager.api.DataManagerLoans;
import org.apache.fineract.data.models.loan.LoanAccount;
import org.apache.fineract.data.models.loan.LoanAccountPage;
import org.apache.fineract.exceptions.NoConnectivityException;
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.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.functions.Predicate;
import io.reactivex.observers.DisposableObserver;
import io.reactivex.schedulers.Schedulers;

/**
 * @author Rajan Maurya
 *         On 07/07/17.
 */
@ConfigPersistent
public class LoanAccountsPresenter extends BasePresenter<LoanAccountsContract.View>
        implements LoanAccountsContract.Presenter {

    private final DataManagerLoans dataManagerLoans;
    private final CompositeDisposable compositeDisposable;

    private static final int CUSTOMER_LOAN_LIST_SIZE = 50;
    private boolean loadmore = false;

    @Inject
    public LoanAccountsPresenter(@ApplicationContext Context context,
            DataManagerLoans dataManagerLoans) {
        super(context);
        this.dataManagerLoans = dataManagerLoans;
        compositeDisposable = new CompositeDisposable();
    }

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

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

    @Override
    public void fetchCustomerLoanAccounts(String customerIdentifier,
            Integer pageIndex, Boolean loadmore) {
        this.loadmore = loadmore;
        fetchCustomerLoanAccounts(customerIdentifier, pageIndex);
    }

    @Override
    public void fetchCustomerLoanAccounts(String customerIdentifier, Integer pageIndex) {
        checkViewAttached();
        getMvpView().showProgressbar();
        compositeDisposable.add(dataManagerLoans.fetchCustomerLoanAccounts(customerIdentifier,
                pageIndex, CUSTOMER_LOAN_LIST_SIZE)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeWith(new DisposableObserver<LoanAccountPage>() {
                    @Override
                    public void onNext(LoanAccountPage loanAccountPage) {
                        getMvpView().hideProgressbar();

                        if (!loadmore && loanAccountPage.getTotalElements() == 0) {
                            getMvpView().showEmptyLoanAccounts(
                                    context.getString(R.string.empty_customer_loans));
                        } else if (loadmore && loanAccountPage.getLoanAccounts().size() == 0) {
                            getMvpView().showMessage(
                                    context.getString(R.string.no_more_loans_available));
                        } else {
                            showCustomerLoanAccounts(loanAccountPage.getLoanAccounts());
                        }
                    }

                    @Override
                    public void onError(Throwable throwable) {
                        getMvpView().hideProgressbar();
                        if (loadmore && !(throwable instanceof NoConnectivityException)) {
                            getMvpView().showMessage(
                                    context.getString(R.string.error_loading_customer_loans));
                        } else if (loadmore && (throwable instanceof NoConnectivityException)) {
                            getMvpView().showMessage(
                                    context.getString(R.string.no_internet_connection));
                        } else {
                            showExceptionError(throwable,
                                    context.getString(R.string.error_loading_customer_loans));
                        }
                    }

                    @Override
                    public void onComplete() {

                    }
                })
        );
    }

    @Override
    public void showCustomerLoanAccounts(List<LoanAccount> loanAccounts) {
        if (loadmore) {
            getMvpView().showMoreLoanAccounts(loanAccounts);
        } else {
            getMvpView().showLoanAccounts(loanAccounts);
        }
    }

    @Override
    public void searchLoanAccounts(List<LoanAccount> loanAccountList, final String query) {
        getMvpView().searchedLoanAccounts(Observable.fromIterable(loanAccountList)
                .filter(new Predicate<LoanAccount>() {
                    @Override
                    public boolean test(LoanAccount loanAccount) {
                        return loanAccount.getIdentifier().toLowerCase()
                                .contains(query.toLowerCase());
                    }
                }).toList().blockingGet());
    }
}