Use one transaction for inserting status and results. (#80)

Author: antoinebhs

src/main/java/org/gridsuite/securityanalysis/server/repositories/SecurityAnalysisResultRepository.java

@@ -154,7 +154,7 @@ public SecurityAnalysisResult find(UUID resultUuid, Set<LimitViolationType> limi
     }
 
     @Transactional
-    public void insert(UUID resultUuid, SecurityAnalysisResult result) {
+    public void insert(UUID resultUuid, SecurityAnalysisResult result, SecurityAnalysisStatus status) {
         Objects.requireNonNull(resultUuid);
         Objects.requireNonNull(result);
 
@@ -169,6 +169,7 @@ public void insert(UUID resultUuid, SecurityAnalysisResult result) {
         );
         computationStatusRepository.save(toEntity(resultUuid, null, result.getPreContingencyResult().getStatus().name()));
         limitViolationRepository.saveAll(toEntity(resultUuid, null, result.getPreContingencyResult().getLimitViolationsResult().getLimitViolations()));
+        globalStatusRepository.save(toEntity(resultUuid, status));
     }
 
     public void insertStatus(List<UUID> resultUuids, SecurityAnalysisStatus status) {

src/main/java/org/gridsuite/securityanalysis/server/service/SecurityAnalysisWorkerService.java

@@ -258,9 +258,9 @@ public Consumer<Message<String>> consumeRun() {
                         .flatMap(result -> {
                             long nanoTime = System.nanoTime();
                             LOGGER.info("Just run in {}s", TimeUnit.NANOSECONDS.toSeconds(nanoTime - startTime.getAndSet(nanoTime)));
-                            return Mono.fromRunnable(() -> resultRepository.insert(resultContext.getResultUuid(), result))
-                                    .then(Mono.fromRunnable(() -> resultRepository.insertStatus(List.of(resultContext.getResultUuid()),
-                                            result.getPreContingencyResult().getStatus() == LoadFlowResult.ComponentResult.Status.CONVERGED ? SecurityAnalysisStatus.CONVERGED : SecurityAnalysisStatus.DIVERGED)))
+                            return Mono.fromRunnable(() -> resultRepository.insert(resultContext.getResultUuid(),
+                                            result,
+                                            result.getPreContingencyResult().getStatus() == LoadFlowResult.ComponentResult.Status.CONVERGED ? SecurityAnalysisStatus.CONVERGED : SecurityAnalysisStatus.DIVERGED))
                                     .then(Mono.just(result))
                                     .doFinally(ignored -> {
                                         long finalNanoTime = System.nanoTime();