fix(dispatcher): dispatcher breaking if single use case fails (#317)

* fix(dispatcher): dispatcher breaking if single use case fails

* chore(dispatcher): implement review feedback

* chore(dispatcher): implement review feedback

* chore(dispatcher): supress PMD.CognitiveComplexity

* refact(dispatcher): handle use case error

Author: simonhir

dispatch-service/src/main/java/de/muenchen/oss/swim/dispatcher/application/usecase/DispatcherUseCase.java

@@ -47,24 +47,33 @@ public class DispatcherUseCase implements DispatcherInPort {
     public void triggerDispatching() {
         log.info("Starting dispatching");
         for (final UseCase useCase : swimDispatcherProperties.getUseCases()) {
-            // handle files directly in directory
-            final String dispatchPath = useCase.getDispatchPath(swimDispatcherProperties);
-            final Map<String, Throwable> errors = new HashMap<>(
-                    this.processDirectory(useCase, dispatchPath, false));
-            // handle recursive by directory
-            if (useCase.isRecursive()) {
-                // get folders
-                final List<String> folders = fileSystemOutPort.getSubDirectories(useCase.getBucket(), dispatchPath);
-                // dispatch files per folder if not in finished folder
-                for (final String folder : folders) {
-                    if (!folder.contains(swimDispatcherProperties.getFinishedFolder())) {
-                        errors.putAll(this.processDirectory(useCase, folder, true));
+            final Map<String, Throwable> errors = new HashMap<>();
+            try {
+                // handle files directly in directory
+                final String dispatchPath = useCase.getDispatchPath(swimDispatcherProperties);
+                errors.putAll(this.processDirectory(useCase, dispatchPath, false));
+                // handle recursive by directory
+                if (useCase.isRecursive()) {
+                    // get folders
+                    final List<String> folders = fileSystemOutPort.getSubDirectories(useCase.getBucket(), dispatchPath);
+                    // dispatch files per folder if not in finished folder
+                    for (final String folder : folders) {
+                        if (!folder.contains(swimDispatcherProperties.getFinishedFolder())) {
+                            errors.putAll(this.processDirectory(useCase, folder, true));
+                        }
                     }
                 }
-            }
-            // send errors
-            if (!errors.isEmpty()) {
-                notificationOutPort.sendDispatchErrors(useCase.getMailAddresses(), useCase.getName(), errors);
+                // send errors
+                if (!errors.isEmpty()) {
+                    notificationOutPort.sendDispatchErrors(useCase.getMailAddresses(), useCase.getName(), errors);
+                }
+            } catch (final Exception e) {
+                log.error("Processing of use case {} failed", useCase.getName(), e);
+                final Map<String, Throwable> enrichedErrors = new HashMap<>();
+                enrichedErrors.put("!!! USE CASE PROCESSING !!!", new UseCaseException(
+                        "Unexpected error during dispatching, use case was not processed completely. Error: %s".formatted(e.getMessage()), e));
+                enrichedErrors.putAll(errors);
+                notificationOutPort.sendDispatchErrors(useCase.getMailAddresses(), useCase.getName(), enrichedErrors);
             }
         }
         log.info("Finished dispatching");