Fix logging for applying the topleft correction

dasch-swiss · Aug 23, 2023 · 1af403f · 1af403f
1 parent 1d51466
commit 1af403f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git 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
@@ -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 correction 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)