new findall and filter

src/main/java/com/databasepreservation/common/server/ViewerFactory.java

@@ -7,13 +7,16 @@
  */
 package com.databasepreservation.common.server;
 
+import com.databasepreservation.common.client.ViewerConstants;
 import com.databasepreservation.common.client.index.IndexResult;
+import com.databasepreservation.common.client.index.filter.BasicSearchFilterParameter;
 import com.databasepreservation.common.client.index.filter.Filter;
 import com.databasepreservation.common.client.index.sort.Sorter;
 import com.databasepreservation.common.client.models.structure.ViewerDatabase;
 import com.databasepreservation.common.client.index.facets.Facets;
 import com.databasepreservation.common.client.models.structure.ViewerDatabaseStatus;
 import com.databasepreservation.common.client.models.structure.ViewerDatabaseValidationStatus;
+import com.databasepreservation.common.server.index.utils.IterableDatabaseResult;
 import org.apache.solr.client.solrj.SolrClient;
 import org.roda.core.data.exceptions.GenericException;
 import org.roda.core.data.exceptions.RequestNotValidException;
@@ -25,6 +28,8 @@
 import com.databasepreservation.common.server.index.DatabaseRowsSolrManager;
 import com.databasepreservation.common.server.index.factory.SolrClientFactory;
 
+import java.util.ArrayList;
+
 /**
  * @author Bruno Ferreira <[email protected]>
  */
@@ -55,17 +60,12 @@ private static synchronized void instantiate() {
   }
 
   public static void checkIngestingDBs() throws RequestNotValidException, GenericException {
-    Filter emptyFilter = new Filter();
-    Facets emptyFacet = new Facets();
+    Filter ingestingFilter = new Filter(new BasicSearchFilterParameter(ViewerConstants.SOLR_DATABASES_STATUS, ViewerDatabaseStatus.INGESTING.toString()));
 
-    int dbCounter = solrManager.count(ViewerDatabase.class, emptyFilter).intValue();
-    IndexResult<ViewerDatabase> dataBases = solrManager.find(ViewerDatabase.class, emptyFilter, Sorter.NONE,
-      new Sublist(0, dbCounter), emptyFacet);
+    IterableDatabaseResult<ViewerDatabase> dataBases = solrManager.findAll(ViewerDatabase.class, ingestingFilter, Sorter.NONE, new ArrayList<>());
 
-    for (ViewerDatabase db : dataBases.getResults()) {
-      if (db.getStatus().equals(ViewerDatabaseStatus.INGESTING)) {
-        solrManager.markDatabaseCollection(db.getUuid(), ViewerDatabaseStatus.ERROR);
-      }
+    for (ViewerDatabase db : dataBases) {
+      solrManager.markDatabaseCollection(db.getUuid(), ViewerDatabaseStatus.ERROR);
     }
   }