Replace Single<Boolean> by Completable for login call

app/src/main/java/com/readrops/app/account/AccountViewModel.java

@@ -42,7 +42,7 @@ public class AccountViewModel extends ViewModel {
                 () -> DefinitionParametersKt.parametersOf(account));
     }
 
-    public Single<Boolean> login(Account account, boolean insert) {
+    public Completable login(Account account, boolean insert) {
         return repository.login(account, insert);
     }
 

app/src/main/java/com/readrops/app/account/AddAccountActivity.java

@@ -2,6 +2,7 @@ package com.readrops.app.account;
 
 import android.content.Intent;
 import android.os.Bundle;
+import android.util.Log;
 import android.util.Patterns;
 import android.view.KeyEvent;
 import android.view.MenuItem;
@@ -19,9 +20,7 @@ import com.readrops.db.entities.account.AccountType;
 
 import org.koin.androidx.viewmodel.compat.ViewModelCompat;
 
-import io.reactivex.Completable;
 import io.reactivex.CompletableObserver;
-import io.reactivex.SingleObserver;
 import io.reactivex.android.schedulers.AndroidSchedulers;
 import io.reactivex.disposables.Disposable;
 import io.reactivex.schedulers.Schedulers;
@@ -32,6 +31,8 @@ import static com.readrops.app.utils.ReadropsKeys.EDIT_ACCOUNT;
 
 public class AddAccountActivity extends AppCompatActivity {
 
+    private static final String TAG = AddAccountActivity.class.getSimpleName();
+
     private ActivityAddAccountBinding binding;
     private AccountViewModel viewModel;
 
@@ -101,7 +102,7 @@ public class AddAccountActivity extends AppCompatActivity {
                 viewModel.login(account, true)
                         .subscribeOn(Schedulers.io())
                         .observeOn(AndroidSchedulers.mainThread())
-                        .subscribe(new SingleObserver<Boolean>() {
+                        .subscribe(new CompletableObserver() {
 
                             @Override
                             public void onSubscribe(Disposable d) {
@@ -110,33 +111,25 @@ public class AddAccountActivity extends AppCompatActivity {
                             }
 
                             @Override
-                            public void onSuccess(Boolean success) {
+                            public void onComplete() {
-                                binding.addAccountLoading.setVisibility(View.GONE);
+                                saveLoginPassword(account);
 
-                                if (success) {
+                                if (forwardResult) {
-                                    saveLoginPassword(account);
+                                    Intent intent = new Intent();
-
+                                    intent.putExtra(ACCOUNT, account);
-                                    if (forwardResult) {
+                                    setResult(RESULT_OK, intent);
-                                        Intent intent = new Intent();
-                                        intent.putExtra(ACCOUNT, account);
-                                        setResult(RESULT_OK, intent);
-                                        finish();
-
-                                    } else {
-                                        Intent intent = new Intent(getApplicationContext(), MainActivity.class);
-                                        intent.putExtra(ACCOUNT, account);
-                                        startActivity(intent);
-                                    }
-
-                                    finish();
                                 } else {
-                                    binding.addAccountValidate.setEnabled(true);
+                                    Intent intent = new Intent(getApplicationContext(), MainActivity.class);
-                                    Utils.showSnackbar(binding.addAccountRoot, getString(R.string.login_failed));
+                                    intent.putExtra(ACCOUNT, account);
+                                    startActivity(intent);
                                 }
+
+                                finish();
                             }
 
                             @Override
                             public void onError(Throwable e) {
+                                Log.d(TAG, e.getMessage());
                                 binding.addAccountLoading.setVisibility(View.GONE);
                                 binding.addAccountValidate.setEnabled(true);
 
@@ -198,20 +191,8 @@ public class AddAccountActivity extends AppCompatActivity {
     private void updateAccount() {
         viewModel.login(accountToEdit, false)
                 .doOnError(throwable -> Utils.showSnackbar(binding.addAccountRoot, throwable.getMessage()))
-                .flatMapCompletable(b -> {
+                .doAfterTerminate(() -> saveLoginPassword(accountToEdit))
-                    if (b) {
+                .andThen(viewModel.update(accountToEdit))
-                        saveLoginPassword(accountToEdit);
-                        return viewModel.update(accountToEdit);
-                    } else {
-                        runOnUiThread(() -> {
-                            binding.addAccountLoading.setVisibility(View.GONE);
-                            binding.addAccountValidate.setEnabled(true);
-                            Utils.showSnackbar(binding.addAccountRoot, getString(R.string.login_failed));
-                        });
-
-                        return Completable.never();
-                    }
-                })
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new CompletableObserver() {

app/src/main/java/com/readrops/app/repositories/ARepository.java

@@ -54,8 +54,7 @@ public abstract class ARepository {
                 .setCredentials(account != null && !account.isLocal() ? Credentials.toCredentials(account) : null);
     }
 
-    // TODO : replace Single by Completable
+    public abstract Completable login(Account account, boolean insert);
-    public abstract Single<Boolean> login(Account account, boolean insert);
 
     public abstract Observable<Feed> sync(List<Feed> feeds);
 

app/src/main/java/com/readrops/app/repositories/FreshRSSRepository.java

@@ -42,7 +42,7 @@ public class FreshRSSRepository extends ARepository {
     }
 
     @Override
-    public Single<Boolean> login(Account account, boolean insert) {
+    public Completable login(Account account, boolean insert) {
         setCredentials(account);
 
         return dataSource.login(account.getLogin(), account.getPassword())
@@ -57,19 +57,19 @@ public class FreshRSSRepository extends ARepository {
 
                     return dataSource.getUserInfo();
                 })
-                .flatMap(userInfo -> {
+                .flatMapCompletable(userInfo -> {
                     account.setDisplayedName(userInfo.getUserName());
 
                     if (insert) {
                         return database.accountDao().insert(account)
-                                .flatMap(id -> {
+                                .flatMapCompletable(id -> {
                                     account.setId(id.intValue());
 
-                                    return Single.just(true);
+                                    return Completable.complete();
                                 });
                     }
 
-                    return Single.just(true);
+                    return Completable.complete();
                 });
     }
 

app/src/main/java/com/readrops/app/repositories/LocalFeedRepository.java

@@ -29,6 +29,7 @@ import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
 
+import io.reactivex.Completable;
 import io.reactivex.Observable;
 import io.reactivex.Single;
 import kotlin.Pair;
@@ -48,7 +49,7 @@ public class LocalFeedRepository extends ARepository {
     }
 
     @Override
-    public Single<Boolean> login(Account account, boolean insert) {
+    public Completable login(Account account, boolean insert) {
         return null;
     }
 

app/src/main/java/com/readrops/app/repositories/NextNewsRepository.java

@@ -46,7 +46,7 @@ public class NextNewsRepository extends ARepository {
     }
 
     @Override
-    public Single<Boolean> login(Account account, boolean insert) {
+    public Completable login(Account account, boolean insert) {
         setCredentials(account);
         return Single.<NextNewsUser>create(emitter -> {
             NextNewsUser user = dataSource.login();
@@ -56,19 +56,19 @@ public class NextNewsRepository extends ARepository {
             } else {
                 emitter.onError(new Exception("Login failed. Please check your credentials and your Nextcloud News setup."));
             }
-        }).flatMap(user -> {
+        }).flatMapCompletable(user -> {
             account.setDisplayedName(user.getDisplayName());
             account.setCurrentAccount(true);
 
             if (insert) {
                 return database.accountDao().insert(account)
-                        .flatMap(id -> {
+                        .flatMapCompletable(id -> {
                             account.setId(id.intValue());
-                            return Single.just(true);
+                            return Completable.complete();
                         });
             }
 
-            return Single.just(true);
+            return Completable.complete();
         });
     }