Add a subject filter to scan-mailbox args

modules/common/src/main/scala/docspell/common/ScanMailboxArgs.scala

@@ -33,7 +33,9 @@ case class ScanMailboxArgs(
     // set a filter for files when importing archives
     fileFilter: Option[Glob],
     // set a list of tags to apply to new item
-    tags: Option[List[String]]
+    tags: Option[List[String]],
+    // a glob filter for the mail subject
+    subjectFilter: Option[Glob]
 )
 
 object ScanMailboxArgs {

modules/joex/src/main/scala/docspell/joex/scanmailbox/ScanMailboxTask.scala

@@ -142,7 +142,7 @@ object ScanMailboxTask {
         _       <- Kleisli.liftF(ctx.logger.info(s"Processing folder $name"))
         folder  <- requireFolder(a)(name)
         search  <- searchMails(a)(folder)
-        headers <- Kleisli.liftF(filterMessageIds(search.mails))
+        headers <- Kleisli.liftF(filterSubjects(search.mails).flatMap(filterMessageIds))
         _       <- headers.traverse(handleOne(ctx.args, a, upload))
       } yield ScanResult(name, search.mails.size, search.count - search.mails.size)
 
@@ -178,6 +178,26 @@ object ScanMailboxTask {
       } yield mails
     }
 
+    def filterSubjects(headers: Vector[MailHeader]): F[Vector[MailHeader]] =
+      ctx.args.subjectFilter match {
+        case Some(sf) =>
+          def check(mh: MailHeader): F[Option[MailHeader]] =
+            if (sf.matches(mh.subject))
+              ctx.logger.debug(
+                s"Including mail '${mh.subject}', it matches the filter."
+              ) *> Option(mh).pure[F]
+            else
+              ctx.logger.debug(
+                s"Excluding mail '${mh.subject}', it doesn't match the filter."
+              ) *> (None: Option[MailHeader]).pure[F]
+          ctx.logger.info(
+            s"Filtering mails on subject using filter: ${sf.asString}"
+          ) *> headers.traverseFilter(check)
+
+        case None =>
+          ctx.logger.debug("Not matching on subjects. No filter given") *> headers.pure[F]
+      }
+
     def filterMessageIds(headers: Vector[MailHeader]): F[Vector[MailHeader]] =
       NonEmptyList.fromFoldable(headers.flatMap(_.messageId)) match {
         case Some(nl) =>

modules/restapi/src/main/resources/docspell-openapi.yml

@@ -3503,7 +3503,12 @@ components:
           $ref: "#/components/schemas/StringList"
         fileFilter:
           description: |
-            A glob to filter attachments to import.
+            A glob to filter attachments to import by file name.
+          type: string
+          format: glob
+        subjectFilter:
+          description: |
+            A glob to filter attachments to import by subject.
           type: string
           format: glob
 

modules/restserver/src/main/scala/docspell/restserver/routes/ScanMailboxRoutes.scala

@@ -115,7 +115,8 @@ object ScanMailboxRoutes {
           settings.direction,
           settings.itemFolder,
           settings.fileFilter,
-          settings.tags.map(_.items)
+          settings.tags.map(_.items),
+          settings.subjectFilter
         )
       )
     )
@@ -137,7 +138,7 @@ object ScanMailboxRoutes {
       task.id,
       task.enabled,
       conn.getOrElse(Ident.unsafe("")),
-      task.args.folders, //folders
+      task.args.folders,
       task.timer,
       task.args.receivedSince.map(_.hours.toInt),
       task.args.targetFolder,
@@ -145,6 +146,7 @@ object ScanMailboxRoutes {
       task.args.direction,
       task.args.itemFolder,
       task.args.tags.map(StringList.apply),
-      task.args.fileFilter
+      task.args.fileFilter,
+      task.args.subjectFilter
     )
 }