TheAnachronism/docspell
1
0
Fork 0
mirror of https://github.com/TheAnachronism/docspell.git synced 2025-04-05 02:49:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Don't do duplicate check on retries

Browse Source
This commit is contained in:
Eike Kettner 2020-10-01 22:48:24 +02:00
parent e26d7129e7
commit 5e21552358
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
modules/joex/src/main/scala/docspell/joex/process/DuplicateCheck.scala
View File

@ -7,6 +7,7 @@ import docspell.common._
import docspell.joex.scheduler.{Context, Task}
import docspell.store.queries.QItem
import docspell.store.records.RFileMeta
import docspell.store.records.RJob
import bitpeace.FileMeta
import doobie._
@ -17,7 +18,13 @@ object DuplicateCheck {
def apply[F[_]: Sync]: Task[F, Args, Args] =
Task { ctx =>
if (ctx.args.meta.skipDuplicate)
ctx.logger.debug("Checking for duplicate files") *> removeDuplicates(ctx)
for {
retries <- getRetryCount(ctx)
res <-
if (retries == 0)
ctx.logger.debug("Checking for duplicate files") *> removeDuplicates(ctx)
else ctx.args.pure[F]
} yield res
else ctx.logger.debug("Not checking for duplicates") *> ctx.args.pure[F]
}
@ -30,6 +37,9 @@ object DuplicateCheck {
ctx.args.files.filterNot(f => ids.contains(f.fileMetaId.id))
)
private def getRetryCount[F[_]: Sync](ctx: Context[F, Args]): F[Int] =
ctx.store.transact(RJob.getRetries(ctx.jobId)).map(_.getOrElse(0))
private def deleteDuplicate[F[_]: Sync](
ctx: Context[F, Args]
)(fd: FileMetaDupes): F[Unit] = {