diff --git a/quarkus-automaton/src/main/java/de/galabau/dateieingang/api/FileProcessingResource.java b/quarkus-automaton/src/main/java/de/galabau/dateieingang/api/FileProcessingResource.java index 53cad99..a8f5345 100644 --- a/quarkus-automaton/src/main/java/de/galabau/dateieingang/api/FileProcessingResource.java +++ b/quarkus-automaton/src/main/java/de/galabau/dateieingang/api/FileProcessingResource.java @@ -38,6 +38,9 @@ public class FileProcessingResource { @POST @Produces(MediaType.APPLICATION_JSON) public Response triggerProcessing(@HeaderParam("X-Api-Key") String apiKey) { + //Log.infof("API-key correct: %s", config.api().key()); + //Log.infof("API-key received: %s", apiKey); + if (apiKey == null || !config.api().key().equals(apiKey)) { Log.warn("Trigger abgelehnt — ungültiger oder fehlender API-Key"); return Response.status(Response.Status.UNAUTHORIZED).build(); diff --git a/quarkus-automaton/src/main/java/de/galabau/dateieingang/oci/OciUploadService.java b/quarkus-automaton/src/main/java/de/galabau/dateieingang/oci/OciUploadService.java index cf3f2b9..d7ec843 100644 --- a/quarkus-automaton/src/main/java/de/galabau/dateieingang/oci/OciUploadService.java +++ b/quarkus-automaton/src/main/java/de/galabau/dateieingang/oci/OciUploadService.java @@ -33,6 +33,7 @@ public class OciUploadService { @PostConstruct void init() { + Log.info("Initialisiere OCI ObjectStorage-Client..."); SimpleAuthenticationDetailsProvider auth = SimpleAuthenticationDetailsProvider.builder() .tenantId(config.tenancyId()) .userId(config.userId()) @@ -47,7 +48,8 @@ public class OciUploadService { } }) .build(); - + + Log.info("Authentifizierung..."); this.client = ObjectStorageClient.builder().build(auth); Log.infof("OCI ObjectStorage-Client initialisiert (Region: %s, Bucket: %s)", config.region(), config.bucket()); } @@ -61,11 +63,12 @@ public class OciUploadService { * @throws OciException bei Verbindungs- oder Upload-Fehlern */ public void upload(ProcessingContext context) throws OciException { + Log.info("OCI Upload gestartet."); List files = context.extractedFiles.stream() .filter(e -> !e.isMarker) .toList(); - Log.infof("OCI-Upload gestartet: %d Datei(en) für '%s'", files.size(), context.zipNameWithoutExt); + Log.infof("OCI-Upload: %d Datei(en) für '%s'", files.size(), context.zipNameWithoutExt); for (FileEntry entry : files) { String key = buildKey(context.zipNameWithoutExt, entry.relativePath); diff --git a/quarkus-automaton/src/main/java/de/galabau/dateieingang/pipeline/FileProcessingPipeline.java b/quarkus-automaton/src/main/java/de/galabau/dateieingang/pipeline/FileProcessingPipeline.java index 20949de..164b082 100644 --- a/quarkus-automaton/src/main/java/de/galabau/dateieingang/pipeline/FileProcessingPipeline.java +++ b/quarkus-automaton/src/main/java/de/galabau/dateieingang/pipeline/FileProcessingPipeline.java @@ -125,6 +125,7 @@ public class FileProcessingPipeline { // --- OCI Upload --- MDC.put("step", "oci-upload"); context.status = ProcessingStatus.PARTIALLY_UPLOADED; + Log.info("Starte OCI-Upload"); ociUploadService.upload(context); context.status = ProcessingStatus.MARKER_UPLOADED;