app/src/main/java/net/ktnx/mobileledger/ui/MainModel.java

   1 /*
   2  * Copyright © 2021 Damyan Ivanov.
   3  * This file is part of MoLe.
   4  * MoLe is free software: you can distribute it and/or modify it
   5  * under the term of the GNU General Public License as published by
   6  * the Free Software Foundation, either version 3 of the License, or
   7  * (at your opinion), any later version.
   8  *
   9  * MoLe is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12  * GNU General Public License terms for details.
  13  *
  14  * You should have received a copy of the GNU General Public License
  15  * along with MoLe. If not, see <https://www.gnu.org/licenses/>.
  16  */
  17
  18 package net.ktnx.mobileledger.ui;
  19
  20 import androidx.lifecycle.LiveData;
  21 import androidx.lifecycle.MutableLiveData;
  22 import androidx.lifecycle.ViewModel;
  23
  24 import net.ktnx.mobileledger.async.RetrieveTransactionsTask;
  25 import net.ktnx.mobileledger.async.TransactionAccumulator;
  26 import net.ktnx.mobileledger.db.Profile;
  27 import net.ktnx.mobileledger.model.Data;
  28 import net.ktnx.mobileledger.model.LedgerAccount;
  29 import net.ktnx.mobileledger.model.LedgerTransaction;
  30 import net.ktnx.mobileledger.model.TransactionListItem;
  31 import net.ktnx.mobileledger.utils.Logger;
  32 import net.ktnx.mobileledger.utils.SimpleDate;
  33
  34 import java.util.ArrayList;
  35 import java.util.List;
  36 import java.util.Locale;
  37
  38 public class MainModel extends ViewModel {
  39     public final MutableLiveData<Integer> foundTransactionItemIndex = new MutableLiveData<>(null);
  40     private final MutableLiveData<Boolean> updatingFlag = new MutableLiveData<>(false);
  41     private final MutableLiveData<String> accountFilter = new MutableLiveData<>(null);
  42     private final MutableLiveData<List<TransactionListItem>> displayedTransactions =
  43             new MutableLiveData<>(new ArrayList<>());
  44     private final MutableLiveData<String> updateError = new MutableLiveData<>();
  45     private SimpleDate firstTransactionDate;
  46     private SimpleDate lastTransactionDate;
  47     transient private RetrieveTransactionsTask retrieveTransactionsTask;
  48     transient private Thread displayedAccountsUpdater;
  49     private TransactionsDisplayedFilter displayedTransactionsUpdater;
  50     public LiveData<Boolean> getUpdatingFlag() {
  51         return updatingFlag;
  52     }
  53     public LiveData<String> getUpdateError() {
  54         return updateError;
  55     }
  56     public LiveData<List<TransactionListItem>> getDisplayedTransactions() {
  57         return displayedTransactions;
  58     }
  59     public void setDisplayedTransactions(List<TransactionListItem> list, int transactionCount) {
  60         displayedTransactions.postValue(list);
  61         Data.lastUpdateTransactionCount.postValue(transactionCount);
  62     }
  63     public SimpleDate getFirstTransactionDate() {
  64         return firstTransactionDate;
  65     }
  66     public void setFirstTransactionDate(SimpleDate earliestDate) {
  67         this.firstTransactionDate = earliestDate;
  68     }
  69     public MutableLiveData<String> getAccountFilter() {
  70         return accountFilter;
  71     }
  72     public SimpleDate getLastTransactionDate() {
  73         return lastTransactionDate;
  74     }
  75     public void setLastTransactionDate(SimpleDate latestDate) {
  76         this.lastTransactionDate = latestDate;
  77     }
  78     public synchronized void scheduleTransactionListRetrieval() {
  79         if (retrieveTransactionsTask != null) {
  80             Logger.debug("db", "Ignoring request for transaction retrieval - already active");
  81             return;
  82         }
  83         Profile profile = Data.getProfile();
  84
  85         retrieveTransactionsTask = new RetrieveTransactionsTask(profile);
  86         Logger.debug("db", "Created a background transaction retrieval task");
  87
  88         retrieveTransactionsTask.start();
  89     }
  90     public synchronized void stopTransactionsRetrieval() {
  91         if (retrieveTransactionsTask != null)
  92             retrieveTransactionsTask.interrupt();
  93         else
  94             Data.backgroundTaskProgress.setValue(null);
  95     }
  96     public void transactionRetrievalDone() {
  97         retrieveTransactionsTask = null;
  98     }
  99     synchronized public void updateDisplayedTransactionsFromWeb(List<LedgerTransaction> list) {
 100         if (displayedTransactionsUpdater != null) {
 101             displayedTransactionsUpdater.interrupt();
 102         }
 103         displayedTransactionsUpdater = new TransactionsDisplayedFilter(this, list);
 104         displayedTransactionsUpdater.start();
 105     }
 106     public void clearUpdateError() {
 107         updateError.postValue(null);
 108     }
 109     public void clearTransactions() {
 110         displayedTransactions.setValue(new ArrayList<>());
 111     }
 112
 113     static class TransactionsDisplayedFilter extends Thread {
 114         private final MainModel model;
 115         private final List<LedgerTransaction> list;
 116         TransactionsDisplayedFilter(MainModel model, List<LedgerTransaction> list) {
 117             this.model = model;
 118             this.list = list;
 119         }
 120         @Override
 121         public void run() {
 122             List<LedgerAccount> newDisplayed = new ArrayList<>();
 123             Logger.debug("dFilter", String.format(Locale.US,
 124                     "entered synchronized block (about to examine %d transactions)", list.size()));
 125             String accNameFilter = model.getAccountFilter()
 126                                         .getValue();
 127
 128             TransactionAccumulator acc = new TransactionAccumulator(accNameFilter, accNameFilter);
 129             for (LedgerTransaction tr : list) {
 130                 if (isInterrupted()) {
 131                     return;
 132                 }
 133
 134                 if (accNameFilter == null || tr.hasAccountNamedLike(accNameFilter)) {
 135                     acc.put(tr, tr.getDate());
 136                 }
 137             }
 138
 139             if (isInterrupted())
 140                 return;
 141
 142             acc.publishResults(model);
 143             Logger.debug("dFilter", "transaction list updated");
 144         }
 145     }
 146 }