added logs

pagopa · Nov 30, 2023 · f5ef17a · f5ef17a
1 parent 0dcb5d0
commit f5ef17a
Showing 1 changed file with 29 additions and 8 deletions.
diff --git a/src/main/java/it/pagopa/interop/signalhub/persister/service/impl/SignalServiceImpl.java b/src/main/java/it/pagopa/interop/signalhub/persister/service/impl/SignalServiceImpl.java
@@ -6,22 +6,20 @@
 import it.pagopa.interop.signalhub.persister.repository.DeadSignalRepository;
 import it.pagopa.interop.signalhub.persister.repository.SignalRepository;
 import it.pagopa.interop.signalhub.persister.service.SignalService;
+import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import reactor.core.publisher.Mono;
 import static it.pagopa.interop.signalhub.persister.exception.ExceptionTypeEnum.DUPLICATE_SIGNAL_ERROR;
 
 
-@Service
 @Slf4j
+@Service
+@AllArgsConstructor
 public class SignalServiceImpl implements SignalService {
-    @Autowired
     private SignalRepository signalRepository;
-    @Autowired
     private DeadSignalRepository deadSignalRepository;
-    @Autowired
     private DeadSignalMapper deadSignalMapper;
 
 
@@ -35,9 +33,32 @@ public Mono<Signal> signalServiceFlow(Signal signal) {
                 .switchIfEmpty(Mono.defer(() -> saveToDeadSignal(signal)));
     }
 
-    private Mono<Signal> getSignalById(Long signalId, String eserviceId) { return this.signalRepository.findByIndexSignalAndEserviceId(signalId, eserviceId); }
-    private Mono<Signal> createSignal(Signal signal) { return this.signalRepository.save(signal); }
-    private Mono<DeadSignal> createDeadSignal(DeadSignal signal) { return this.deadSignalRepository.save(signal); }
+    private Mono<Signal> getSignalById(Long signalId, String eserviceId) {
+        return this.signalRepository.findByIndexSignalAndEserviceId(signalId, eserviceId)
+                .switchIfEmpty(Mono.defer(() -> {
+                    log.info("[{}] Signal not present with {} signalId", eserviceId, signalId);
+                    return Mono.empty();
+                }))
+                .doOnNext(signal -> log.info("[{}] Signal is present with {} signalId", eserviceId, signalId));
+    }
+
+    private Mono<Signal> createSignal(Signal signal) {
+        return this.signalRepository.save(signal)
+                .doOnNext(data -> log.info("[{}] Signal saved with {} signal id", signal.getEserviceId(), signal.getSignalId()))
+                .doOnError(error ->
+                        log.error("[{}] Error saving signal with {} signal id", signal.getEserviceId(), signal.getSignalId())
+                );
+    }
+
+    private Mono<DeadSignal> createDeadSignal(DeadSignal signal) {
+        log.info("[{}] Save dead signal with {} signal id", signal.getEserviceId(), signal.getSignalId());
+        return this.deadSignalRepository.save(signal)
+                .doOnNext(data -> log.info("[{}] Dead signal saved with {} signal id", signal.getEserviceId(), signal.getSignalId()))
+                .doOnError(error ->
+                        log.error("[{}] Error saving dead signal with {} signal id", signal.getEserviceId(), signal.getSignalId())
+                );
+
+    }
 
     private Mono<DeadSignal> getDeadSignal(Signal signal) {
         DeadSignal deadSignal = deadSignalMapper.signalToDeadSignal(signal);