TheAnachronism/docspell
1
0
Fork 0
mirror of https://github.com/TheAnachronism/docspell.git synced 2025-06-07 15:45:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use more prominent log line to indicate start of processing

Browse Source 
Issue: #530
This commit is contained in:
Eike Kettner 2021-01-02 21:37:46 +01:00
parent 97dfcece97
commit 611e480eb4
1 changed files with 20 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
modules/joex/src/main/scala/docspell/joex/process/ItemHandler.scala
View File

@ -35,18 +35,20 @@ object ItemHandler {
analyser: TextAnalyser[F], analyser: TextAnalyser[F],
regexNer: RegexNerFile[F] regexNer: RegexNerFile[F]
): Task[F, Args, Unit] = ): Task[F, Args, Unit] =
DuplicateCheck[F] logBeginning.flatMap(_ =>
.flatMap(args => DuplicateCheck[F]
if (args.files.isEmpty) logNoFiles .flatMap(args =>
else { if (args.files.isEmpty) logNoFiles
val create: Task[F, Args, ItemData] = else {
CreateItem[F].contramap(_ => args.pure[F]) val create: Task[F, Args, ItemData] =
create CreateItem[F].contramap(_ => args.pure[F])
.flatMap(itemStateTask(ItemState.Processing)) create
.flatMap(safeProcess[F](cfg, itemOps, fts, analyser, regexNer)) .flatMap(itemStateTask(ItemState.Processing))
.map(_ => ()) .flatMap(safeProcess[F](cfg, itemOps, fts, analyser, regexNer))
} .map(_ => ())
) }
)
)
def itemStateTask[F[_]: Sync, A]( def itemStateTask[F[_]: Sync, A](
state: ItemState state: ItemState
@ -131,11 +133,16 @@ object ItemHandler {
) )
private def logWarn[F[_]](msg: => String): Task[F, Args, Unit] = private def logWarn[F[_]](msg: => String): Task[F, Args, Unit] =
Task(_.logger.warn(msg)) Task.log(_.warn(msg))
private def logNoFiles[F[_]]: Task[F, Args, Unit] = private def logNoFiles[F[_]]: Task[F, Args, Unit] =
logWarn( logWarn(
"No files to process! Either no files were given or duplicate check removed all." "No files to process! Either no files were given or duplicate check removed all."
) )
private def logBeginning[F[_]]: Task[F, Args, Unit] =
Task { ctx =>
val files = ctx.args.files.flatMap(_.name).mkString(", ")
ctx.logger.info(s"============ Start processing $files ============")
}
} }