Ticket 6505 | Pick all errorRecords in intial repo call for processing for retry

Author: ramakanthk711

goonj/src/main/java/org/avni_integration_service/goonj/job/AvniGoonjFullErrorJob.java

@@ -49,7 +49,7 @@ public void execute(GoonjConfig goonjConfig) {
             bugsnag.notify(e);
         } finally {
             try {
-                errorRecordsWorker.evaluateNewErrors();
+                errorRecordsWorker.evaluateNewErrors(); //ignoring response on purpose
             } catch (Exception e) {
                 logger.error("Failed to evaluate new errors", e);
                 bugsnag.notify(e);

goonj/src/main/java/org/avni_integration_service/goonj/worker/AvniGoonjErrorRecordsWorker.java

@@ -58,7 +58,7 @@ public class AvniGoonjErrorRecordsWorker {
 
     private static final Logger logger = Logger.getLogger(AvniGoonjErrorRecordsWorker.class);
 
-    private static final int pageSize = 20;
+    private static final int pageSize = 1000;
 
     public void process(SyncDirection syncDirection, boolean allErrors) throws Exception {
         Page<ErrorRecord> errorRecordPage;
@@ -74,8 +74,7 @@ else if (syncDirection.equals(SyncDirection.GoonjToAvni) && !allErrors)
                 errorRecordPage = errorRecordRepository.findAllByIntegratingEntityTypeNotNullAndProcessingDisabledFalseAndErrorRecordLogsErrorTypeNotInAndIntegrationSystemIdOrderById(
                         avniGoonjErrorService.getUnprocessableErrorTypes(), integrationSystemId, pageRequest);
             else if (syncDirection.equals(SyncDirection.GoonjToAvni) && allErrors)
-                errorRecordPage = errorRecordRepository.findAllByIntegratingEntityTypeNotNullAndErrorRecordLogsErrorTypeNotInAndIntegrationSystemIdOrderById(
-                        avniGoonjErrorService.getUnprocessableErrorTypes(), integrationSystemId, pageRequest);
+                errorRecordPage = errorRecordRepository.findAllByIntegratingEntityTypeNotNullAndIntegrationSystemIdOrderById(integrationSystemId, pageRequest);
             else {
                 throw new RuntimeException("Invalid arguments");
             }

integration-data/src/main/java/org/avni_integration_service/integration_data/repository/ErrorRecordRepository.java

@@ -26,6 +26,7 @@ public interface ErrorRecordRepository extends PagingAndSortingRepository<ErrorR
     Page<ErrorRecord> findAllByIntegratingEntityTypeNotNullAndProcessingDisabledFalseAndErrorRecordLogsErrorTypeNotInAndIntegrationSystemIdOrderById(List<ErrorType> errorTypes, int integrationSystemId, Pageable pageable);
     Page<ErrorRecord> findAllByIntegratingEntityTypeNotNullAndErrorRecordLogsErrorTypeNotInAndIntegrationSystemOrderById(List<ErrorType> errorTypes, IntegrationSystem integrationSystem, Pageable pageable);
     Page<ErrorRecord> findAllByIntegratingEntityTypeNotNullAndErrorRecordLogsErrorTypeNotInAndIntegrationSystemIdOrderById(List<ErrorType> errorTypes, int integrationSystemId, Pageable pageable);
+    Page<ErrorRecord> findAllByIntegratingEntityTypeNotNullAndIntegrationSystemIdOrderById(int integrationSystemId, Pageable pageable);
 
     List<ErrorRecord> findAllByAvniEntityTypeNotNull();