From 2d0324ff3670c716c0f8ca6244f917d83fb0861e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Christian=20Kleinb=C3=B6lting?= Date: Wed, 23 Aug 2023 11:57:02 +0200 Subject: [PATCH] Fix logging for applying the topleft correction --- .../swiss/dasch/api/MaintenanceEndpointRoutes.scala | 1 - .../scala/swiss/dasch/domain/MaintenanceActions.scala | 10 ++++++---- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/main/scala/swiss/dasch/api/MaintenanceEndpointRoutes.scala b/src/main/scala/swiss/dasch/api/MaintenanceEndpointRoutes.scala index a9d87ed5..d779a77b 100644 --- a/src/main/scala/swiss/dasch/api/MaintenanceEndpointRoutes.scala +++ b/src/main/scala/swiss/dasch/api/MaintenanceEndpointRoutes.scala @@ -128,7 +128,6 @@ object MaintenanceEndpointRoutes { applyTopLeftCorrectionEndpoint.implement(shortcodeStr => for { projectPath <- getProjectPath(shortcodeStr) - _ <- ZIO.logInfo(s"Creating originals for $projectPath") _ <- MaintenanceActions .applyTopLeftCorrections(projectPath) .tap(count => ZIO.logInfo(s"Corrected $count top left images for $projectPath")) diff --git a/src/main/scala/swiss/dasch/domain/MaintenanceActions.scala b/src/main/scala/swiss/dasch/domain/MaintenanceActions.scala index 5fcb41e4..5a10dd6e 100644 --- a/src/main/scala/swiss/dasch/domain/MaintenanceActions.scala +++ b/src/main/scala/swiss/dasch/domain/MaintenanceActions.scala @@ -17,10 +17,12 @@ import zio.stream.{ ZSink, ZStream } object MaintenanceActions { def applyTopLeftCorrections(projectPath: Path): ZIO[ImageService, Throwable, Int] = - findJpeg2000Files(projectPath) - .mapZIOPar(8)(ImageService.applyTopLeftCorrection) - .map(_.map(_ => 1).getOrElse(0)) - .run(ZSink.sum) + ZIO.logInfo(s"Starting top left corrections in $projectPath") *> + findJpeg2000Files(projectPath) + .mapZIOPar(8)(ImageService.applyTopLeftCorrection) + .map(_.map(_ => 1).getOrElse(0)) + .run(ZSink.sum) <* + ZIO.logInfo(s"Top left corrections applied in $projectPath") private def findJpeg2000Files(projectPath: Path) = StorageService.findInPath(projectPath, isJpeg2000)