djkovrik / bakingapp Goto Github PK

@Singleton
public class LocalDataSource implements DataSource {

@Override
public Observable getServerSettings() {
return mDBHelper.createQuery(ServerSettingsEntry.TABLE_NAME,
DbUtils.getSelectAllQuery(ServerSettingsEntry.TABLE_NAME))
.mapToOne(DbUtils::getServerSettings);

@Singleton
public class MyRepository implements DataSource {
@Override
    public Observable<ServerSettings> getServerSettings() {
        return mLocalDataSource.getServerSettings().compose(RxUtils.applySchedulers());

public class LoginPresenter implements LoginActivityContract.Presenter{
 @Override
    public void checkServerDbSynced() {
        mCompositeDisposable.clear();
        Disposable subscription = mRepository
                .getServerSettings()
                .doOnSubscribe(disposable -> {
                    Timber.d(" onSubscribe");
                    mView.showLoadingIndicator(true, "Checking Server ....");
                })
                .subscribe(serverSettings -> {
                            if (serverSettings == null) {
                                Timber.d("*** Server Db Synced ****" + "\n" + "*** Checking Licence Key **** ");
                                checkLicenceKey();
                                } else {
                                Timber.d("*** Server Db Not Synced *** " + " \n" + "*** Opening Login Dialog ****");
                                mView.showLoadingIndicator(false, "Db Not Synced ....");
                                mView.openLoginDialog();
                                }
                                },
                        throwable -> {
                            mView.showErrorMessage(throwable.getLocalizedMessage());
                            });
        mCompositeDisposable.add(subscription);
    }
}



    @Override
    public void subscribe() {
        checkServerDbSynced();
    }

    @Override
    public void unSubscribe() {
        mCompositeDisposable.clear();
    }