Merge pull request #113 from bcgov/feature/replicate-student-courses-saga

saga fix to limit number of sagas being run, and add missed file

Author: mightycox

api/src/main/java/ca/bc/gov/educ/api/pen/replication/repository/SagaRepository.java

@@ -24,7 +24,7 @@ public interface SagaRepository extends JpaRepository<Saga, UUID>, JpaSpecificat
    * @return the list
    */
   List<Saga> findAllByStatusInOrderByCreateDate(List<String> statuses);
-
+  List<Saga> findTop500ByStatusInOrderByCreateDate(List<String> statuses);
 
   /**
    * Find all by create date before list.

api/src/main/java/ca/bc/gov/educ/api/pen/replication/schedulers/EventTaskScheduler.java

@@ -58,7 +58,7 @@ public EventTaskScheduler(final SagaRepository sagaRepository, final SagaService
   @Scheduled(cron = "${cron.scheduled.process.uncompleted.saga}")
   @SchedulerLock(name = "REPLAY_UNCOMPLETED_SAGAS", lockAtLeastFor = "${cron.scheduled.process.uncompleted.saga.lockAtLeastFor}", lockAtMostFor = "${cron.scheduled.process.uncompleted.saga.lockAtMostFor}")
   public void findAndProcessUncompletedSagas() {
-    final List<Saga> sagas = this.getSagaRepository().findAllByStatusInOrderByCreateDate(this.getStatusFilters());
+    final List<Saga> sagas = this.getSagaRepository().findTop500ByStatusInOrderByCreateDate(this.getStatusFilters());
     if (!sagas.isEmpty()) {
       this.processUncompletedSagas(sagas);
     }

api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/TraxStudentCourseService.java

@@ -2,8 +2,6 @@
 
 import ca.bc.gov.educ.api.pen.replication.model.TraxStudentCourseEntity;
 import ca.bc.gov.educ.api.pen.replication.repository.TraxStudentCourseRepository;
-import jakarta.persistence.EntityManager;
-import jakarta.persistence.PersistenceContext;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
@@ -16,9 +14,6 @@
 public class TraxStudentCourseService {
   private final TraxStudentCourseRepository traxStudentCourseRepository;
 
-  @PersistenceContext
-  private EntityManager entityManager;
-
   public TraxStudentCourseService(TraxStudentCourseRepository traxStudentCourseRepository) {
     this.traxStudentCourseRepository = traxStudentCourseRepository;
   }
@@ -49,11 +44,7 @@ public void saveTraxStudentCourses(final List<TraxStudentCourseEntity> studentCo
         log.debug("Saving new course list for PEN: {}, count: {}",
             studentCourseEntityList.get(0).getStudXcrseId().getStudNo(),
             studentCourseEntityList.size());
-        entityManager.clear();
-        for (TraxStudentCourseEntity entity : studentCourseEntityList) {
-          entityManager.persist(entity);
-        }
-        entityManager.flush();
+        traxStudentCourseRepository.saveAllAndFlush(studentCourseEntityList);
         log.debug("Saved new trax student courses to the database, count: {}", studentCourseEntityList.size());
       }
     } catch (Exception e) {