diff --git a/pdf-umbenenner-application/src/main/java/de/gecheckt/pdf/umbenenner/application/usecase/DefaultBatchRunProcessingUseCase.java b/pdf-umbenenner-application/src/main/java/de/gecheckt/pdf/umbenenner/application/usecase/DefaultBatchRunProcessingUseCase.java index c43c67b..07b8431 100644 --- a/pdf-umbenenner-application/src/main/java/de/gecheckt/pdf/umbenenner/application/usecase/DefaultBatchRunProcessingUseCase.java +++ b/pdf-umbenenner-application/src/main/java/de/gecheckt/pdf/umbenenner/application/usecase/DefaultBatchRunProcessingUseCase.java @@ -87,7 +87,7 @@ public class DefaultBatchRunProcessingUseCase implements BatchRunProcessingUseCa private final SourceDocumentCandidatesPort sourceDocumentCandidatesPort; private final PdfTextExtractionPort pdfTextExtractionPort; private final FingerprintPort fingerprintPort; - private final DocumentProcessingCoordinator m4DocumentProcessor; + private final DocumentProcessingCoordinator documentProcessingCoordinator; /** * Creates the batch use case with the already-loaded startup configuration and all @@ -104,7 +104,7 @@ public class DefaultBatchRunProcessingUseCase implements BatchRunProcessingUseCa * must not be null * @param fingerprintPort for computing the SHA-256 fingerprint of a candidate; * must not be null - * @param m4DocumentProcessor for applying decision logic and persisting results; + * @param documentProcessingCoordinator for applying decision logic and persisting results; * must not be null * @throws NullPointerException if any parameter is null */ @@ -114,7 +114,7 @@ public class DefaultBatchRunProcessingUseCase implements BatchRunProcessingUseCa SourceDocumentCandidatesPort sourceDocumentCandidatesPort, PdfTextExtractionPort pdfTextExtractionPort, FingerprintPort fingerprintPort, - DocumentProcessingCoordinator m4DocumentProcessor) { + DocumentProcessingCoordinator documentProcessingCoordinator) { this.configuration = Objects.requireNonNull(configuration, "configuration must not be null"); this.runLockPort = Objects.requireNonNull(runLockPort, "runLockPort must not be null"); this.sourceDocumentCandidatesPort = Objects.requireNonNull( @@ -122,8 +122,8 @@ public class DefaultBatchRunProcessingUseCase implements BatchRunProcessingUseCa this.pdfTextExtractionPort = Objects.requireNonNull( pdfTextExtractionPort, "pdfTextExtractionPort must not be null"); this.fingerprintPort = Objects.requireNonNull(fingerprintPort, "fingerprintPort must not be null"); - this.m4DocumentProcessor = Objects.requireNonNull( - m4DocumentProcessor, "m4DocumentProcessor must not be null"); + this.documentProcessingCoordinator = Objects.requireNonNull( + documentProcessingCoordinator, "documentProcessingCoordinator must not be null"); } @Override @@ -236,10 +236,10 @@ public class DefaultBatchRunProcessingUseCase implements BatchRunProcessingUseCa // Delegate the complete processing logic to the processor // The processor handles loading document master record, checking terminal status, // executing pipeline only when needed, and persisting results consistently - m4DocumentProcessor.processWithM3Execution( - candidate, - fingerprint, - context, + documentProcessingCoordinator.processWithM3Execution( + candidate, + fingerprint, + context, attemptStart, this::runM3Pipeline); // Pass the executor as a function } diff --git a/pdf-umbenenner-bootstrap/src/main/java/de/gecheckt/pdf/umbenenner/bootstrap/BootstrapRunner.java b/pdf-umbenenner-bootstrap/src/main/java/de/gecheckt/pdf/umbenenner/bootstrap/BootstrapRunner.java index ce1d919..720548b 100644 --- a/pdf-umbenenner-bootstrap/src/main/java/de/gecheckt/pdf/umbenenner/bootstrap/BootstrapRunner.java +++ b/pdf-umbenenner-bootstrap/src/main/java/de/gecheckt/pdf/umbenenner/bootstrap/BootstrapRunner.java @@ -172,7 +172,7 @@ public class BootstrapRunner { new SqliteProcessingAttemptRepositoryAdapter(jdbcUrl); UnitOfWorkPort unitOfWorkPort = new SqliteUnitOfWorkAdapter(jdbcUrl); - DocumentProcessingCoordinator m4Processor = + DocumentProcessingCoordinator documentProcessingCoordinator = new DocumentProcessingCoordinator(documentRecordRepository, processingAttemptRepository, unitOfWorkPort); return new DefaultBatchRunProcessingUseCase( config, @@ -180,7 +180,7 @@ public class BootstrapRunner { new SourceDocumentCandidatesPortAdapter(config.sourceFolder()), new PdfTextExtractionPortAdapter(), fingerprintPort, - m4Processor); + documentProcessingCoordinator); }; this.commandFactory = SchedulerBatchCommand::new; }